#include "testthreadcall.h"
#include <kern/thread_call.h>
+#include <pexpert/pexpert.h>
#define super IOService
OSDefineMetaClassAndStructors(testthreadcall, super);
static void thread_call_test_func(thread_call_param_t param0,
thread_call_param_t param1);
+static void thread_call_test_func2(thread_call_param_t param0,
+ thread_call_param_t param1);
+
}
+static int my_event;
+
bool
testthreadcall::start( IOService * provider )
{
- boolean_t ret;
- uint64_t deadline;
+ boolean_t ret;
+ uint64_t deadline;
+ int sleepret;
+ uint32_t kernel_configuration;
IOLog("%s\n", __PRETTY_FUNCTION__);
if (!super::start(provider)) {
return false;
}
+
+ kernel_configuration = PE_i_can_has_kernel_configuration();
+ IOLog("%s: Assertions %s\n", __PRETTY_FUNCTION__,
+ (kernel_configuration & kPEICanHasAssertions) ? "enabled" : "disabled");
+ IOLog("%s: Statistics %s\n", __PRETTY_FUNCTION__,
+ (kernel_configuration & kPEICanHasStatistics) ? "enabled" : "disabled");
+ IOLog("%s: Diagnostic API %s\n", __PRETTY_FUNCTION__,
+ (kernel_configuration & kPEICanHasDiagnosticAPI) ? "enabled" : "disabled");
IOLog("Attempting thread_call_allocate\n");
tcall = thread_call_allocate(thread_call_test_func, this);
IOLog("%d sec deadline is %llu\n", 5, deadline);
ret = thread_call_enter_delayed(tcall, deadline);
+
+ IOLog("Attempting thread_call_allocate\n");
+ tcall2 = thread_call_allocate(thread_call_test_func2, this);
+ IOLog("thread_call_t %p\n", tcall);
+
+ tlock2 = IOLockAlloc();
+ IOLog("tlock2 %p\n", tlock2);
+
+ clock_interval_to_deadline(2, NSEC_PER_SEC, &deadline);
+ IOLog("%d sec deadline is %llu\n", 2, deadline);
+
+ ret = thread_call_enter_delayed(tcall2, deadline);
+
+ IOLockLock(tlock2);
+
+ clock_interval_to_deadline(3, NSEC_PER_SEC, &deadline);
+ IOLog("%d sec deadline is %llu\n", 3, deadline);
+ sleepret = IOLockSleepDeadline(tlock2, &my_event, deadline, THREAD_INTERRUPTIBLE);
+ IOLog("IOLockSleepDeadline(&my_event, %llu) returned %d, expected 0\n", deadline, sleepret);
+
+ IOLockUnlock(tlock2);
+
+ clock_interval_to_deadline(4, NSEC_PER_SEC, &deadline);
+ IOLog("%d sec deadline is %llu\n", 4, deadline);
+
+ ret = thread_call_enter_delayed(tcall2, deadline);
+
+ IOLockLock(tlock2);
+
+ clock_interval_to_deadline(3, NSEC_PER_SEC, &deadline);
+ IOLog("%d sec deadline is %llu\n", 3, deadline);
+ sleepret = IOLockSleepDeadline(tlock2, &my_event, deadline, THREAD_INTERRUPTIBLE);
+ IOLog("IOLockSleepDeadline(&my_event, %llu) returned %d, expected 1\n", deadline, sleepret);
+
+ IOLockUnlock(tlock2);
return true;
}
IOSimpleLockLock(self->tlock);
IOSimpleLockUnlock(self->tlock);
+}
-#if 1
- IOSimpleLockLock(self->tlock);
-#else
- IOSimpleLockUnlock(self->tlock);
-#endif
+static void thread_call_test_func2(thread_call_param_t param0,
+ thread_call_param_t param1)
+{
+ testthreadcall *self = (testthreadcall *)param0;
+
+ IOLog("thread_call_test_func2 %p %p\n", param0, param1);
+
+ IOLockWakeup(self->tlock2, &my_event, false);
}