/*
* Copyright (c) 1998-2000 Apple Computer, Inc. All rights reserved.
*
- * @APPLE_LICENSE_HEADER_START@
+ * @APPLE_LICENSE_OSREFERENCE_HEADER_START@
*
- * The contents of this file constitute Original Code as defined in and
- * are subject to the Apple Public Source License Version 1.1 (the
- * "License"). You may not use this file except in compliance with the
- * License. Please obtain a copy of the License at
- * http://www.apple.com/publicsource and read it before using this file.
- *
- * This 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,
- * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
- * FITNESS FOR A PARTICULAR PURPOSE OR NON-INFRINGEMENT. Please see the
- * License for the specific language governing rights and limitations
- * under the License.
- *
- * @APPLE_LICENSE_HEADER_END@
+ * 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. 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,
+ * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
+ * 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_OSREFERENCE_HEADER_END@
*/
-#include <libkern/OSDebug.h>
-
#include <IOKit/IOCommandGate.h>
#include <IOKit/IOWorkLoop.h>
#include <IOKit/IOReturn.h>
return me;
}
-/* virtual */ void IOCommandGate::disable()
-{
- if (workLoop && !workLoop->inGate())
- OSReportWithBacktrace("IOCommandGate::disable() called when not gated");
-
- super::disable();
-}
-
-/* virtual */ void IOCommandGate::enable()
+IOReturn IOCommandGate::runCommand(void *arg0, void *arg1,
+ void *arg2, void *arg3)
{
- if (workLoop) {
- closeGate();
- super::enable();
- wakeupGate(&enabled, /* oneThread */ false); // Unblock sleeping threads
- openGate();
- }
-}
+ IOReturn res;
-/* virtual */ void IOCommandGate::free()
-{
- setWorkLoop(0);
- super::free();
-}
+ if (!enabled)
+ return kIOReturnNotPermitted;
-/* virtual */ void IOCommandGate::setWorkLoop(IOWorkLoop *inWorkLoop)
-{
- uintptr_t *sleepersP = (uintptr_t *) &reserved;
- if (!inWorkLoop && workLoop) { // tearing down
- closeGate();
- *sleepersP |= 1;
- while (*sleepersP >> 1) {
- thread_wakeup_with_result(&enabled, THREAD_INTERRUPTED);
- sleepGate(sleepersP, THREAD_UNINT);
- }
- *sleepersP = 0;
- openGate();
- }
- else
+ if (!action)
+ return kIOReturnNoResources;
- super::setWorkLoop(inWorkLoop);
-}
+ // closeGate is recursive so don't worry if we already hold the lock.
+ IOTimeStampConstant(IODBG_CMDQ(IOCMDQ_ACTION),
+ (unsigned int) action, (unsigned int) owner);
-IOReturn IOCommandGate::runCommand(void *arg0, void *arg1,
- void *arg2, void *arg3)
-{
- return runAction((Action) action, arg0, arg1, arg2, arg3);
-}
+ closeGate();
+ res = (*(Action) action)(owner, arg0, arg1, arg2, arg3);
+ openGate();
-IOReturn IOCommandGate::attemptCommand(void *arg0, void *arg1,
- void *arg2, void *arg3)
-{
- return attemptAction((Action) action, arg0, arg1, arg2, arg3);
+ return res;
}
IOReturn IOCommandGate::runAction(Action inAction,
void *arg0, void *arg1,
void *arg2, void *arg3)
{
+ IOReturn res;
+
+ if (!enabled)
+ return kIOReturnNotPermitted;
+
if (!inAction)
return kIOReturnBadArgument;
IOTimeStampConstant(IODBG_CMDQ(IOCMDQ_ACTION),
(unsigned int) inAction, (unsigned int) owner);
- // closeGate is recursive needn't worry if we already hold the lock.
+ // closeGate is recursive so don't worry if we already hold the lock.
closeGate();
+ res = (*inAction)(owner, arg0, arg1, arg2, arg3);
+ openGate();
- // If the command gate is disabled and we aren't on the workloop thread
- // itself then sleep until we get enabled.
+ return res;
+}
+
+IOReturn IOCommandGate::attemptCommand(void *arg0, void *arg1,
+ void *arg2, void *arg3)
+{
IOReturn res;
- if (!workLoop->onThread()) {
- while (!enabled) {
- uintptr_t *sleepersP = (uintptr_t *) &reserved;
- *sleepersP += 2;
- IOReturn res = sleepGate(&enabled, THREAD_ABORTSAFE);
- *sleepersP -= 2;
+ if (!enabled)
+ return kIOReturnNotPermitted;
- bool wakeupTearDown = (*sleepersP & 1);
- if (res || wakeupTearDown) {
- openGate();
+ if (!action)
+ return kIOReturnNoResources;
- if (wakeupTearDown)
- commandWakeup(sleepersP); // No further resources used
+ // Try to hold the lock if can't get return immediately.
+ if (!tryCloseGate())
+ return kIOReturnCannotLock;
- return kIOReturnAborted;
- }
- }
- }
+ // closeGate is recursive so don't worry if we already hold the lock.
+ IOTimeStampConstant(IODBG_CMDQ(IOCMDQ_ACTION),
+ (unsigned int) action, (unsigned int) owner);
- // Must be gated and on the work loop or enabled
- res = (*inAction)(owner, arg0, arg1, arg2, arg3);
+ res = (*(Action) action)(owner, arg0, arg1, arg2, arg3);
openGate();
return res;
{
IOReturn res;
+ if (!enabled)
+ return kIOReturnNotPermitted;
+
if (!inAction)
return kIOReturnBadArgument;
if (!tryCloseGate())
return kIOReturnCannotLock;
- // If the command gate is disabled then sleep until we get a wakeup
- if (!workLoop->onThread() && !enabled)
- res = kIOReturnNotPermitted;
- else {
- IOTimeStampConstant(IODBG_CMDQ(IOCMDQ_ACTION),
- (unsigned int) inAction, (unsigned int) owner);
-
- res = (*inAction)(owner, arg0, arg1, arg2, arg3);
- }
+ IOTimeStampConstant(IODBG_CMDQ(IOCMDQ_ACTION),
+ (unsigned int) inAction, (unsigned int) owner);
+ res = (*inAction)(owner, arg0, arg1, arg2, arg3);
openGate();
return res;
projects / apple / xnu.git / blobdiff