* 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,
* 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@
*/
#include <IOKit/IOKitDebug.h>
#include <IOKit/IOTimeStamp.h>
#include <IOKit/IOWorkLoop.h>
+#include <IOKit/IOInterruptAccountingPrivate.h>
+#include <libkern/Block.h>
#if IOKITSTATS
#define super IOInterruptEventSource
OSDefineMetaClassAndStructors
- (IOFilterInterruptEventSource, IOInterruptEventSource)
+(IOFilterInterruptEventSource, IOInterruptEventSource)
OSMetaClassDefineReservedUnused(IOFilterInterruptEventSource, 0);
OSMetaClassDefineReservedUnused(IOFilterInterruptEventSource, 1);
OSMetaClassDefineReservedUnused(IOFilterInterruptEventSource, 2);
/*
* 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;
- 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),
- (uintptr_t) filterAction, (uintptr_t) owner, (uintptr_t) this, (uintptr_t) workLoop);
-
- // Call the filter.
- filterRes = (*filterAction)(owner, this);
-
- 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),
- (uintptr_t) 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;
- 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),
- (uintptr_t) filterAction, (uintptr_t) owner, (uintptr_t) this, (uintptr_t) workLoop);
-
- // Call the filter.
- filterRes = (*filterAction)(owner, this);
-
- 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),
- (uintptr_t) 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();
+ }
}