#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 0;
}
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);
}
}