#include <IOKit/IOLib.h>
#include <IOKit/IOSyncer.h>
OSDefineMetaClassAndStructors(IOSyncer, OSObject)
IOSyncer * IOSyncer::create(bool twoRetains)
{
IOSyncer * me = new IOSyncer;
if (me && !me->init(twoRetains)) {
me->release();
return NULL;
}
return me;
}
bool
IOSyncer::init(bool twoRetains)
{
if (!OSObject::init()) {
return false;
}
if (!(guardLock = IOSimpleLockAlloc())) {
return false;
}
IOSimpleLockInit(guardLock);
if (twoRetains) {
retain();
}
fResult = kIOReturnSuccess;
reinit();
return true;
}
void
IOSyncer::reinit()
{
IOInterruptState is = IOSimpleLockLockDisableInterrupt(guardLock);
threadMustStop = true;
IOSimpleLockUnlockEnableInterrupt(guardLock, is);
}
void
IOSyncer::free()
{
privateSignal();
if (guardLock != NULL) {
IOSimpleLockFree(guardLock);
}
OSObject::free();
}
IOReturn
IOSyncer::wait(bool autoRelease)
{
IOInterruptState is = IOSimpleLockLockDisableInterrupt(guardLock);
if (threadMustStop) {
assert_wait((void *) &threadMustStop, false);
IOSimpleLockUnlockEnableInterrupt(guardLock, is);
thread_block(THREAD_CONTINUE_NULL);
} else {
IOSimpleLockUnlockEnableInterrupt(guardLock, is);
}
IOReturn result = fResult;
if (autoRelease) {
release();
}
return result;
}
void
IOSyncer::signal(IOReturn res, bool autoRelease)
{
fResult = res;
privateSignal();
if (autoRelease) {
release();
}
}
void
IOSyncer::privateSignal()
{
if (threadMustStop) {
IOInterruptState is = IOSimpleLockLockDisableInterrupt(guardLock);
threadMustStop = false;
thread_wakeup_one((void *) &threadMustStop);
IOSimpleLockUnlockEnableInterrupt(guardLock, is);
}
}