]> git.saurik.com Git - apple/xnu.git/blobdiff - iokit/Kernel/IOFilterInterruptEventSource.cpp
xnu-6153.81.5.tar.gz
[apple/xnu.git] / iokit / Kernel / IOFilterInterruptEventSource.cpp
index 83b6ed6e0c37d64dfbdced44e9f55664a00c1f40..5e3371a10445859e58d5e38b5a1cbc81dfb53abb 100644 (file)
@@ -2,7 +2,7 @@
  * Copyright (c) 1998-2010 Apple Inc. All rights reserved.
  *
  * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
- * 
+ *
  * 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
  * 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,
@@ -22,7 +22,7 @@
  * 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_OSREFERENCE_LICENSE_HEADER_END@
  */
 
@@ -32,6 +32,7 @@
 #include <IOKit/IOTimeStamp.h>
 #include <IOKit/IOWorkLoop.h>
 #include <IOKit/IOInterruptAccountingPrivate.h>
+#include <libkern/Block.h>
 
 #if IOKITSTATS
 
@@ -55,7 +56,7 @@ do { \
 #define super IOInterruptEventSource
 
 OSDefineMetaClassAndStructors
-    (IOFilterInterruptEventSource, IOInterruptEventSource)
+(IOFilterInterruptEventSource, IOInterruptEventSource)
 OSMetaClassDefineReservedUnused(IOFilterInterruptEventSource, 0);
 OSMetaClassDefineReservedUnused(IOFilterInterruptEventSource, 1);
 OSMetaClassDefineReservedUnused(IOFilterInterruptEventSource, 2);
@@ -68,166 +69,245 @@ OSMetaClassDefineReservedUnused(IOFilterInterruptEventSource, 7);
 /*
  * Implement the call throughs for the private protection conversion
  */
-bool IOFilterInterruptEventSource::init(OSObject *inOwner,
-                                        Action inAction,
-                                        IOService *inProvider,
-                                        int inIntIndex)
+bool
+IOFilterInterruptEventSource::init(OSObject *inOwner,
+    Action inAction,
+    IOService *inProvider,
+    int inIntIndex)
 {
-    return false;
+       return false;
 }
 
 IOInterruptEventSource *
 IOFilterInterruptEventSource::interruptEventSource(OSObject *inOwner,
-                                                   Action inAction,
-                                                   IOService *inProvider,
-                                                   int inIntIndex)
+    Action inAction,
+    IOService *inProvider,
+    int inIntIndex)
 {
-    return 0;
+       return NULL;
 }
 
 bool
 IOFilterInterruptEventSource::init(OSObject *inOwner,
-                                   Action inAction,
-                                   Filter inFilterAction,
-                                   IOService *inProvider,
-                                   int inIntIndex)
+    Action inAction,
+    Filter inFilterAction,
+    IOService *inProvider,
+    int inIntIndex)
 {
-    if ( !super::init(inOwner, inAction, inProvider, inIntIndex) )
-        return false;
+       if (!super::init(inOwner, inAction, inProvider, inIntIndex)) {
+               return false;
+       }
 
-    if (!inFilterAction)
-        return false;
+       if (!inFilterAction) {
+               return false;
+       }
 
-    filterAction = inFilterAction;
+       filterAction = inFilterAction;
 
-    IOStatisticsInitializeCounter();
-       
-    return true;
+       IOStatisticsInitializeCounter();
+
+       return true;
 }
 
-IOFilterInterruptEventSource *IOFilterInterruptEventSource
+IOFilterInterruptEventSource *
+IOFilterInterruptEventSource
 ::filterInterruptEventSource(OSObject *inOwner,
-                             Action inAction,
-                             Filter inFilterAction,
-                             IOService *inProvider,
-                             int inIntIndex)
+    Action inAction,
+    Filter inFilterAction,
+    IOService *inProvider,
+    int inIntIndex)
 {
-    IOFilterInterruptEventSource *me = new IOFilterInterruptEventSource;
+       IOFilterInterruptEventSource *me = new IOFilterInterruptEventSource;
 
-    if (me
-    && !me->init(inOwner, inAction, inFilterAction, inProvider, inIntIndex)) {
-        me->release();
-        return 0;
-    }
+       if (me
+           && !me->init(inOwner, inAction, inFilterAction, inProvider, inIntIndex)) {
+               me->release();
+               return NULL;
+       }
 
-    return me;
+       return me;
 }
 
-void IOFilterInterruptEventSource::signalInterrupt()
+
+IOFilterInterruptEventSource *
+IOFilterInterruptEventSource
+::filterInterruptEventSource(OSObject *inOwner,
+    IOService *inProvider,
+    int inIntIndex,
+    ActionBlock inAction,
+    FilterBlock inFilterAction)
+{
+       IOFilterInterruptEventSource *me = new IOFilterInterruptEventSource;
+
+       FilterBlock filter = Block_copy(inFilterAction);
+       if (!filter) {
+               OSSafeReleaseNULL(me);
+               return NULL;
+       }
+
+       if (me
+           && !me->init(inOwner, (Action) NULL, (Filter) filter, inProvider, inIntIndex)) {
+               me->release();
+               Block_release(filter);
+               return NULL;
+       }
+       me->flags |= kFilterBlock;
+       me->setActionBlock((IOEventSource::ActionBlock) inAction);
+
+       return me;
+}
+
+
+void
+IOFilterInterruptEventSource::free( void )
+{
+       if ((kFilterBlock & flags) && filterActionBlock) {
+               Block_release(filterActionBlock);
+       }
+
+       super::free();
+}
+
+void
+IOFilterInterruptEventSource::signalInterrupt()
 {
        bool trace = (gIOKitTrace & kIOTraceIntEventSource) ? true : false;
-    
-    IOStatisticsInterrupt();
-    producerCount++;
-       
-       if (trace)
-           IOTimeStampStartConstant(IODBG_INTES(IOINTES_SEMA), (uintptr_t) this, (uintptr_t) owner);
-    
-    signalWorkAvailable();
-       
-       if (trace)
-           IOTimeStampEndConstant(IODBG_INTES(IOINTES_SEMA), (uintptr_t) this, (uintptr_t) owner);
-       
+
+       IOStatisticsInterrupt();
+       producerCount++;
+
+       if (trace) {
+               IOTimeStampStartConstant(IODBG_INTES(IOINTES_SEMA), VM_KERNEL_ADDRHIDE(this), VM_KERNEL_ADDRHIDE(owner));
+       }
+
+       signalWorkAvailable();
+
+       if (trace) {
+               IOTimeStampEndConstant(IODBG_INTES(IOINTES_SEMA), VM_KERNEL_ADDRHIDE(this), VM_KERNEL_ADDRHIDE(owner));
+       }
 }
 
 
 IOFilterInterruptEventSource::Filter
 IOFilterInterruptEventSource::getFilterAction() const
 {
-    return filterAction;
+       if (kFilterBlock & flags) {
+               return NULL;
+       }
+       return filterAction;
 }
 
+IOFilterInterruptEventSource::FilterBlock
+IOFilterInterruptEventSource::getFilterActionBlock() const
+{
+       if (kFilterBlock & flags) {
+               return filterActionBlock;
+       }
+       return NULL;
+}
 
-
-
-void IOFilterInterruptEventSource::normalInterruptOccurred
-    (void */*refcon*/, IOService */*prov*/, int /*source*/)
+void
+IOFilterInterruptEventSource::normalInterruptOccurred
+(void */*refcon*/, IOService */*prov*/, int /*source*/)
 {
-    bool       filterRes;
-    uint64_t   startTime = 0;
-    uint64_t   endTime = 0;
-       bool    trace = (gIOKitTrace & kIOTraceIntEventSource) ? true : false;
-       
-       if (trace)
+       bool        filterRes;
+       uint64_t    startTime = 0;
+       uint64_t    endTime = 0;
+       bool    trace = (gIOKitTrace & kIOTraceIntEventSource) ? true : false;
+
+       if (trace) {
                IOTimeStampStartConstant(IODBG_INTES(IOINTES_FILTER),
-                                        VM_KERNEL_UNSLIDE(filterAction), (uintptr_t) owner, (uintptr_t) this, (uintptr_t) workLoop);
-
-    if (IOInterruptEventSource::reserved->statistics) {
-        if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelTimeIndex)) {
-            startTime = mach_absolute_time();
-        }
-    }
-    
-    // Call the filter.
-    filterRes = (*filterAction)(owner, this);
-
-    if (IOInterruptEventSource::reserved->statistics) {
-        if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelCountIndex)) {
-            IA_ADD_VALUE(&IOInterruptEventSource::reserved->statistics->interruptStatistics[kInterruptAccountingFirstLevelCountIndex], 1);
-        }
-
-        if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelTimeIndex)) {
-            endTime = mach_absolute_time();
-            IA_ADD_VALUE(&IOInterruptEventSource::reserved->statistics->interruptStatistics[kInterruptAccountingFirstLevelTimeIndex], endTime - startTime);
-        }
-    }
-       
-       if (trace)
+                   VM_KERNEL_UNSLIDE(filterAction), VM_KERNEL_ADDRHIDE(owner), VM_KERNEL_ADDRHIDE(this), VM_KERNEL_ADDRHIDE(workLoop));
+       }
+
+       if (IOInterruptEventSource::reserved->statistics) {
+               if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelTimeIndex)
+                   || IOInterruptEventSource::reserved->statistics->enablePrimaryTimestamp) {
+                       startTime = mach_absolute_time();
+               }
+               if (IOInterruptEventSource::reserved->statistics->enablePrimaryTimestamp) {
+                       IOInterruptEventSource::reserved->statistics->primaryTimestamp = startTime;
+               }
+       }
+
+       // Call the filter.
+       if (kFilterBlock & flags) {
+               filterRes = (filterActionBlock)(this);
+       } else {
+               filterRes = (*filterAction)(owner, this);
+       }
+
+       if (IOInterruptEventSource::reserved->statistics) {
+               if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelCountIndex)) {
+                       IA_ADD_VALUE(&IOInterruptEventSource::reserved->statistics->interruptStatistics[kInterruptAccountingFirstLevelCountIndex], 1);
+               }
+
+               if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelTimeIndex)) {
+                       endTime = mach_absolute_time();
+                       IA_ADD_VALUE(&IOInterruptEventSource::reserved->statistics->interruptStatistics[kInterruptAccountingFirstLevelTimeIndex], endTime - startTime);
+               }
+       }
+
+       if (trace) {
                IOTimeStampEndConstant(IODBG_INTES(IOINTES_FILTER),
-                                      VM_KERNEL_UNSLIDE(filterAction), (uintptr_t) owner, (uintptr_t) this, (uintptr_t) workLoop);
-       
-    if (filterRes)
-        signalInterrupt();
+                   VM_KERNEL_ADDRHIDE(filterAction), VM_KERNEL_ADDRHIDE(owner),
+                   VM_KERNEL_ADDRHIDE(this), VM_KERNEL_ADDRHIDE(workLoop));
+       }
+
+       if (filterRes) {
+               signalInterrupt();
+       }
 }
 
-void IOFilterInterruptEventSource::disableInterruptOccurred
-    (void */*refcon*/, IOService *prov, int source)
+void
+IOFilterInterruptEventSource::disableInterruptOccurred
+(void */*refcon*/, IOService *prov, int source)
 {
-    bool       filterRes;
-    uint64_t   startTime = 0;
-    uint64_t   endTime = 0;
-       bool    trace = (gIOKitTrace & kIOTraceIntEventSource) ? true : false;
-       
-       if (trace)
+       bool        filterRes;
+       uint64_t    startTime = 0;
+       uint64_t    endTime = 0;
+       bool    trace = (gIOKitTrace & kIOTraceIntEventSource) ? true : false;
+
+       if (trace) {
                IOTimeStampStartConstant(IODBG_INTES(IOINTES_FILTER),
-                                        VM_KERNEL_UNSLIDE(filterAction), (uintptr_t) owner, (uintptr_t) this, (uintptr_t) workLoop);
-
-    if (IOInterruptEventSource::reserved->statistics) {
-        if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelTimeIndex)) {
-            startTime = mach_absolute_time();
-        }
-    }
-    
-    // Call the filter.
-    filterRes = (*filterAction)(owner, this);
-
-    if (IOInterruptEventSource::reserved->statistics) {
-        if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelCountIndex)) {
-            IA_ADD_VALUE(&IOInterruptEventSource::reserved->statistics->interruptStatistics[kInterruptAccountingFirstLevelCountIndex], 1);
-        }
-
-        if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelTimeIndex)) {
-            endTime = mach_absolute_time();
-            IA_ADD_VALUE(&IOInterruptEventSource::reserved->statistics->interruptStatistics[kInterruptAccountingFirstLevelTimeIndex], endTime - startTime);
-        }
-    }
-
-       if (trace)
+                   VM_KERNEL_UNSLIDE(filterAction), VM_KERNEL_ADDRHIDE(owner), VM_KERNEL_ADDRHIDE(this), VM_KERNEL_ADDRHIDE(workLoop));
+       }
+
+       if (IOInterruptEventSource::reserved->statistics) {
+               if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelTimeIndex)
+                   || IOInterruptEventSource::reserved->statistics->enablePrimaryTimestamp) {
+                       startTime = mach_absolute_time();
+               }
+               if (IOInterruptEventSource::reserved->statistics->enablePrimaryTimestamp) {
+                       IOInterruptEventSource::reserved->statistics->primaryTimestamp = startTime;
+               }
+       }
+
+       // Call the filter.
+       if (kFilterBlock & flags) {
+               filterRes = (filterActionBlock)(this);
+       } else {
+               filterRes = (*filterAction)(owner, this);
+       }
+
+       if (IOInterruptEventSource::reserved->statistics) {
+               if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelCountIndex)) {
+                       IA_ADD_VALUE(&IOInterruptEventSource::reserved->statistics->interruptStatistics[kInterruptAccountingFirstLevelCountIndex], 1);
+               }
+
+               if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelTimeIndex)) {
+                       endTime = mach_absolute_time();
+                       IA_ADD_VALUE(&IOInterruptEventSource::reserved->statistics->interruptStatistics[kInterruptAccountingFirstLevelTimeIndex], endTime - startTime);
+               }
+       }
+
+       if (trace) {
                IOTimeStampEndConstant(IODBG_INTES(IOINTES_FILTER),
-                                      VM_KERNEL_UNSLIDE(filterAction), (uintptr_t) owner, (uintptr_t) this, (uintptr_t) workLoop);
-       
-    if (filterRes) {
-        prov->disableInterrupt(source);        /* disable the interrupt */
-        signalInterrupt();
-    }
+                   VM_KERNEL_UNSLIDE(filterAction), VM_KERNEL_ADDRHIDE(owner), VM_KERNEL_ADDRHIDE(this), VM_KERNEL_ADDRHIDE(workLoop));
+       }
+
+       if (filterRes) {
+               prov->disableInterrupt(source); /* disable the interrupt */
+               signalInterrupt();
+       }
 }