X-Git-Url: https://git.saurik.com/apple/xnu.git/blobdiff_plain/d7e50217d7adf6e52786a38bcaa4cd698cb9a79e..cb3231590a3c94ab4375e2228bd5e86b0cf1ad7e:/iokit/Kernel/IOEventSource.cpp diff --git a/iokit/Kernel/IOEventSource.cpp b/iokit/Kernel/IOEventSource.cpp index 6ddbac302..3415fd34a 100644 --- a/iokit/Kernel/IOEventSource.cpp +++ b/iokit/Kernel/IOEventSource.cpp @@ -1,17 +1,20 @@ /* - * Copyright (c) 1998-2000 Apple Computer, Inc. All rights reserved. + * Copyright (c) 1998-2000, 2009 Apple Inc. All rights reserved. + * + * @APPLE_OSREFERENCE_LICENSE_HEADER_START@ * - * @APPLE_LICENSE_HEADER_START@ - * - * Copyright (c) 1999-2003 Apple Computer, Inc. All Rights Reserved. - * * This file contains Original Code and/or Modifications of Original Code * as defined in and that are subject to the Apple Public Source License * Version 2.0 (the 'License'). You may not use this file except in - * compliance with the License. Please obtain a copy of the License at - * http://www.opensource.apple.com/apsl/ and read it before using this - * file. - * + * compliance with the License. The rights granted to you under the License + * may not be used to create, or enable the creation or redistribution of, + * unlawful or unlicensed copies of an Apple operating system, or to + * circumvent, violate, or enable the circumvention or violation of, any + * terms of an Apple operating system software license agreement. + * + * Please obtain a copy of the License at + * http://www.opensource.apple.com/apsl/ and read it before using this file. + * * The Original Code and all software distributed under the License are * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES, @@ -19,24 +22,26 @@ * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT. * Please see the License for the specific language governing rights and * limitations under the License. - * - * @APPLE_LICENSE_HEADER_END@ + * + * @APPLE_OSREFERENCE_LICENSE_HEADER_END@ */ /* -Copyright (c) 1998 Apple Computer, Inc. All rights reserved. - -HISTORY - 1998-7-13 Godfrey van der Linden(gvdl) - Created. -]*/ + * Copyright (c) 1998 Apple Computer, Inc. All rights reserved. + * + * HISTORY + * 1998-7-13 Godfrey van der Linden(gvdl) + * Created. + * ]*/ #include #include #include +#include #define super OSObject OSDefineMetaClassAndAbstractStructors(IOEventSource, OSObject) + OSMetaClassDefineReservedUnused(IOEventSource, 0); OSMetaClassDefineReservedUnused(IOEventSource, 1); OSMetaClassDefineReservedUnused(IOEventSource, 2); @@ -46,77 +51,247 @@ OSMetaClassDefineReservedUnused(IOEventSource, 5); OSMetaClassDefineReservedUnused(IOEventSource, 6); OSMetaClassDefineReservedUnused(IOEventSource, 7); +bool +IOEventSource::checkForWork() +{ + return false; +} + /* inline function implementations */ -void IOEventSource::signalWorkAvailable() { workLoop->signalWorkAvailable(); } -void IOEventSource::openGate() { workLoop->openGate(); } -void IOEventSource::closeGate() { workLoop->closeGate(); } -bool IOEventSource::tryCloseGate() { return workLoop->tryCloseGate(); } -int IOEventSource::sleepGate(void *event, UInt32 type) - { return workLoop->sleepGate(event, type); } -void IOEventSource::wakeupGate(void *event, bool oneThread) - { workLoop->wakeupGate(event, oneThread); } -bool IOEventSource::init(OSObject *inOwner, - Action inAction = 0) +#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 /* IOKITSTATS */ + +void +IOEventSource::signalWorkAvailable() { - if (!inOwner) - return false; + workLoop->signalWorkAvailable(); +} - owner = inOwner; +void +IOEventSource::openGate() +{ + IOStatisticsOpenGate(); + workLoop->openGate(); +} - if ( !super::init() ) - return false; +void +IOEventSource::closeGate() +{ + workLoop->closeGate(); + IOStatisticsCloseGate(); +} - (void) setAction(inAction); - enabled = true; +bool +IOEventSource::tryCloseGate() +{ + bool res; + if ((res = workLoop->tryCloseGate())) { + IOStatisticsCloseGate(); + } + return res; +} - return true; +int +IOEventSource::sleepGate(void *event, UInt32 type) +{ + int res; + IOStatisticsOpenGate(); + res = workLoop->sleepGate(event, type); + IOStatisticsCloseGate(); + return res; } -IOEventSource::Action IOEventSource::getAction () const { return action; }; +int +IOEventSource::sleepGate(void *event, AbsoluteTime deadline, UInt32 type) +{ + int res; + IOStatisticsOpenGate(); + res = workLoop->sleepGate(event, deadline, type); + IOStatisticsCloseGate(); + return res; +} -void IOEventSource::setAction(Action inAction) +void +IOEventSource::wakeupGate(void *event, bool oneThread) { - action = inAction; + workLoop->wakeupGate(event, oneThread); } -IOEventSource *IOEventSource::getNext() const { return eventChainNext; }; -void IOEventSource::setNext(IOEventSource *inNext) +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 ((kActionBlock & flags) && actionBlock) { + Block_release(actionBlock); + } + + if (reserved) { + IODelete(reserved, ExpansionData, 1); + } + + super::free(); +} + +void +IOEventSource::setRefcon(void *newrefcon) +{ + refcon = newrefcon; +} + +void * +IOEventSource::getRefcon() const +{ + return refcon; +} + +IOEventSource::Action +IOEventSource::getAction() const +{ + if (kActionBlock & flags) { + return NULL; + } + return action; +} + +IOEventSource::ActionBlock +IOEventSource::getActionBlock(ActionBlock) const +{ + if (kActionBlock & flags) { + return actionBlock; + } + return NULL; +} + +void +IOEventSource::setAction(Action inAction) +{ + if ((kActionBlock & flags) && actionBlock) { + Block_release(actionBlock); + } + action = inAction; +} + +void +IOEventSource::setActionBlock(ActionBlock block) +{ + if ((kActionBlock & flags) && actionBlock) { + Block_release(actionBlock); + } + actionBlock = Block_copy(block); + flags |= kActionBlock; +} + +IOEventSource * +IOEventSource::getNext() const +{ + return eventChainNext; +}; + +void +IOEventSource::setNext(IOEventSource *inNext) { - eventChainNext = inNext; + eventChainNext = inNext; } -void IOEventSource::enable() +void +IOEventSource::enable() { - enabled = true; - if (workLoop) - return signalWorkAvailable(); + enabled = true; + if (workLoop) { + return signalWorkAvailable(); + } } -void IOEventSource::disable() +void +IOEventSource::disable() { - enabled = false; + enabled = false; } -bool IOEventSource::isEnabled() const +bool +IOEventSource::isEnabled() const { - return enabled; + return enabled; } -void IOEventSource::setWorkLoop(IOWorkLoop *inWorkLoop) +void +IOEventSource::setWorkLoop(IOWorkLoop *inWorkLoop) { - if ( !inWorkLoop ) - disable(); - workLoop = inWorkLoop; + if (!inWorkLoop) { + disable(); + } + workLoop = inWorkLoop; } -IOWorkLoop *IOEventSource::getWorkLoop() const +IOWorkLoop * +IOEventSource::getWorkLoop() const { - return workLoop; + return workLoop; } -bool IOEventSource::onThread() const +bool +IOEventSource::onThread() const { - return (workLoop != 0) && workLoop->onThread(); + return (workLoop != NULL) && workLoop->onThread(); }