#include <IOKit/IOLib.h>
#include <IOKit/IOEventSource.h>
#include <IOKit/IOWorkLoop.h>
#define super OSObject
OSDefineMetaClassAndAbstractStructors(IOEventSource, OSObject)
OSMetaClassDefineReservedUnused(IOEventSource, 0);
OSMetaClassDefineReservedUnused(IOEventSource, 1);
OSMetaClassDefineReservedUnused(IOEventSource, 2);
OSMetaClassDefineReservedUnused(IOEventSource, 3);
OSMetaClassDefineReservedUnused(IOEventSource, 4);
OSMetaClassDefineReservedUnused(IOEventSource, 5);
OSMetaClassDefineReservedUnused(IOEventSource, 6);
OSMetaClassDefineReservedUnused(IOEventSource, 7);
bool IOEventSource::checkForWork() { return false; }
#if IOKITSTATS
#define IOStatisticsRegisterCounter() \
do { \
reserved->counter = IOStatistics::registerEventSource(inOwner); \
} while (0)
#define IOStatisticsUnregisterCounter() \
do { \
if (reserved) \
IOStatistics::unregisterEventSource(reserved->counter); \
} while (0)
#define IOStatisticsOpenGate() \
do { \
IOStatistics::countOpenGate(reserved->counter); \
} while (0)
#define IOStatisticsCloseGate() \
do { \
IOStatistics::countCloseGate(reserved->counter); \
} while (0)
#else
#define IOStatisticsRegisterCounter()
#define IOStatisticsUnregisterCounter()
#define IOStatisticsOpenGate()
#define IOStatisticsCloseGate()
#endif
void IOEventSource::signalWorkAvailable()
{
workLoop->signalWorkAvailable();
}
void IOEventSource::openGate()
{
IOStatisticsOpenGate();
workLoop->openGate();
}
void IOEventSource::closeGate()
{
workLoop->closeGate();
IOStatisticsCloseGate();
}
bool IOEventSource::tryCloseGate()
{
bool res;
if ((res = workLoop->tryCloseGate())) {
IOStatisticsCloseGate();
}
return res;
}
int IOEventSource::sleepGate(void *event, UInt32 type)
{
bool res;
IOStatisticsOpenGate();
res = workLoop->sleepGate(event, type);
IOStatisticsCloseGate();
return res;
}
int IOEventSource::sleepGate(void *event, AbsoluteTime deadline, UInt32 type)
{
bool res;
IOStatisticsOpenGate();
res = workLoop->sleepGate(event, deadline, type);
IOStatisticsCloseGate();
return res;
}
void IOEventSource::wakeupGate(void *event, bool oneThread) { workLoop->wakeupGate(event, oneThread); }
bool IOEventSource::init(OSObject *inOwner,
Action inAction)
{
if (!inOwner)
return false;
owner = inOwner;
if ( !super::init() )
return false;
(void) setAction(inAction);
enabled = true;
if(!reserved) {
reserved = IONew(ExpansionData, 1);
if (!reserved) {
return false;
}
}
IOStatisticsRegisterCounter();
return true;
}
void IOEventSource::free( void )
{
IOStatisticsUnregisterCounter();
if (reserved)
IODelete(reserved, ExpansionData, 1);
super::free();
}
IOEventSource::Action IOEventSource::getAction () const { return action; };
void IOEventSource::setAction(Action inAction)
{
action = inAction;
}
IOEventSource *IOEventSource::getNext() const { return eventChainNext; };
void IOEventSource::setNext(IOEventSource *inNext)
{
eventChainNext = inNext;
}
void IOEventSource::enable()
{
enabled = true;
if (workLoop)
return signalWorkAvailable();
}
void IOEventSource::disable()
{
enabled = false;
}
bool IOEventSource::isEnabled() const
{
return enabled;
}
void IOEventSource::setWorkLoop(IOWorkLoop *inWorkLoop)
{
if ( !inWorkLoop )
disable();
workLoop = inWorkLoop;
}
IOWorkLoop *IOEventSource::getWorkLoop() const
{
return workLoop;
}
bool IOEventSource::onThread() const
{
return (workLoop != 0) && workLoop->onThread();
}