/*
- * Copyright (c) 1998-2000 Apple Computer, Inc. All rights reserved.
+ * Copyright (c) 1998-2010 Apple Inc. All rights reserved.
*
* @APPLE_OSREFERENCE_LICENSE_HEADER_START@
*
*
* @APPLE_OSREFERENCE_LICENSE_HEADER_END@
*/
-/*
-Copyright (c) 1999 Apple Computer, Inc. All rights reserved.
-HISTORY
- 1999-4-15 Godfrey van der Linden(gvdl)
- Created.
-*/
#include <IOKit/IOFilterInterruptEventSource.h>
#include <IOKit/IOService.h>
+#include <IOKit/IOKitDebug.h>
#include <IOKit/IOTimeStamp.h>
#include <IOKit/IOWorkLoop.h>
+#include <IOKit/IOInterruptAccountingPrivate.h>
+#include <libkern/Block.h>
+
+#if IOKITSTATS
-#if KDEBUG
+#define IOStatisticsInitializeCounter() \
+do { \
+ IOStatistics::setCounterType(IOEventSource::reserved->counter, kIOStatisticsFilterInterruptEventSourceCounter); \
+} while (0)
-#define IOTimeTypeStampS(t) \
-do { \
- IOTimeStampStart(IODBG_INTES(t), \
- (unsigned int) this, (unsigned int) owner); \
-} while(0)
+#define IOStatisticsInterrupt() \
+do { \
+ IOStatistics::countInterrupt(IOEventSource::reserved->counter); \
+} while (0)
-#define IOTimeTypeStampE(t) \
-do { \
- IOTimeStampEnd(IODBG_INTES(t), \
- (unsigned int) this, (unsigned int) owner); \
-} while(0)
+#else
-#define IOTimeStampLatency() \
-do { \
- IOTimeStampEnd(IODBG_INTES(IOINTES_LAT), \
- (unsigned int) this, (unsigned int) owner); \
-} while(0)
+#define IOStatisticsInitializeCounter()
+#define IOStatisticsInterrupt()
-#else /* !KDEBUG */
-#define IOTimeTypeStampS(t)
-#define IOTimeTypeStampE(t)
-#define IOTimeStampLatency()
-#endif /* KDEBUG */
+#endif /* IOKITSTATS */
#define super IOInterruptEventSource
return false;
filterAction = inFilterAction;
+
+ IOStatisticsInitializeCounter();
+
return true;
}
return me;
}
-void IOFilterInterruptEventSource::signalInterrupt()
+
+IOFilterInterruptEventSource *IOFilterInterruptEventSource
+::filterInterruptEventSource(OSObject *inOwner,
+ IOService *inProvider,
+ int inIntIndex,
+ ActionBlock inAction,
+ FilterBlock inFilterAction)
{
-IOTimeStampLatency();
+ IOFilterInterruptEventSource *me = new IOFilterInterruptEventSource;
- producerCount++;
+ FilterBlock filter = Block_copy(inFilterAction);
+ if (!filter) return 0;
+
+ if (me
+ && !me->init(inOwner, (Action) NULL, (Filter) filter, inProvider, inIntIndex)) {
+ me->release();
+ Block_release(filter);
+ return 0;
+ }
+ me->flags |= kFilterBlock;
+ me->setActionBlock((IOEventSource::ActionBlock) inAction);
+
+ return me;
+}
+
+
+void IOFilterInterruptEventSource::free( void )
+{
+ if ((kFilterBlock & flags) && filterActionBlock) Block_release(filterActionBlock);
-IOTimeTypeStampS(IOINTES_SEMA);
+ super::free();
+}
+
+void IOFilterInterruptEventSource::signalInterrupt()
+{
+ bool trace = (gIOKitTrace & kIOTraceIntEventSource) ? true : false;
+
+ IOStatisticsInterrupt();
+ producerCount++;
+
+ if (trace)
+ IOTimeStampStartConstant(IODBG_INTES(IOINTES_SEMA), VM_KERNEL_ADDRHIDE(this), VM_KERNEL_ADDRHIDE(owner));
+
signalWorkAvailable();
-IOTimeTypeStampE(IOINTES_SEMA);
+
+ if (trace)
+ IOTimeStampEndConstant(IODBG_INTES(IOINTES_SEMA), VM_KERNEL_ADDRHIDE(this), VM_KERNEL_ADDRHIDE(owner));
+
}
IOFilterInterruptEventSource::Filter
IOFilterInterruptEventSource::getFilterAction() const
{
+ 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*/)
{
- bool filterRes;
-
-IOTimeTypeStampS(IOINTES_INTCTXT);
-
-IOTimeTypeStampS(IOINTES_INTFLTR);
- IOTimeStampConstant(IODBG_INTES(IOINTES_FILTER),
- (unsigned int) filterAction, (unsigned int) owner);
- filterRes = (*filterAction)(owner, this);
-IOTimeTypeStampE(IOINTES_INTFLTR);
-
+ 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), VM_KERNEL_ADDRHIDE(owner), VM_KERNEL_ADDRHIDE(this), VM_KERNEL_ADDRHIDE(workLoop));
+
+ if (IOInterruptEventSource::reserved->statistics) {
+ if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelTimeIndex)) {
+ startTime = mach_absolute_time();
+ }
+ }
+
+ // 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_ADDRHIDE(filterAction), VM_KERNEL_ADDRHIDE(owner),
+ VM_KERNEL_ADDRHIDE(this), VM_KERNEL_ADDRHIDE(workLoop));
+
if (filterRes)
signalInterrupt();
-
-IOTimeTypeStampE(IOINTES_INTCTXT);
}
void IOFilterInterruptEventSource::disableInterruptOccurred
(void */*refcon*/, IOService *prov, int source)
{
- bool filterRes;
-
-IOTimeTypeStampS(IOINTES_INTCTXT);
-
-IOTimeTypeStampS(IOINTES_INTFLTR);
- IOTimeStampConstant(IODBG_INTES(IOINTES_FILTER),
- (unsigned int) filterAction, (unsigned int) owner);
- filterRes = (*filterAction)(owner, this);
-IOTimeTypeStampE(IOINTES_INTFLTR);
+ 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), VM_KERNEL_ADDRHIDE(owner), VM_KERNEL_ADDRHIDE(this), VM_KERNEL_ADDRHIDE(workLoop));
+
+ if (IOInterruptEventSource::reserved->statistics) {
+ if (IA_GET_STATISTIC_ENABLED(kInterruptAccountingFirstLevelTimeIndex)) {
+ startTime = mach_absolute_time();
+ }
+ }
+
+ // 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), VM_KERNEL_ADDRHIDE(owner), VM_KERNEL_ADDRHIDE(this), VM_KERNEL_ADDRHIDE(workLoop));
+
if (filterRes) {
prov->disableInterrupt(source); /* disable the interrupt */
-
signalInterrupt();
}
-IOTimeTypeStampE(IOINTES_INTCTXT);
}