clntirp.c File Reference

#include "classp.h"
#include "debug.h"

Include dependency graph for clntirp.c:

Go to the source code of this file.

Functions
VOID	ClasspStartIdleTimer (IN PCLASS_PRIVATE_FDO_DATA FdoData)
VOID	ClasspStopIdleTimer (PCLASS_PRIVATE_FDO_DATA FdoData)
VOID	ClasspServiceIdleRequest (PFUNCTIONAL_DEVICE_EXTENSION FdoExtension, BOOLEAN PostToDpc)
PIRP	ClasspDequeueIdleRequest (PFUNCTIONAL_DEVICE_EXTENSION FdoExtension)
VOID	EnqueueDeferredClientIrp (PDEVICE_OBJECT Fdo, PIRP Irp)
PIRP	DequeueDeferredClientIrp (PDEVICE_OBJECT Fdo)
VOID	ClasspInitializeIdleTimer (PFUNCTIONAL_DEVICE_EXTENSION FdoExtension)
ULONGLONG	ClasspGetIdleTime (IN PCLASS_PRIVATE_FDO_DATA FdoData, IN LARGE_INTEGER CurrentTime)
LOGICAL	ClasspIdleDurationSufficient (IN PCLASS_PRIVATE_FDO_DATA FdoData, OUT LARGE_INTEGER **CurrentTimeIn)
VOID NTAPI	ClasspIdleTimerDpc (IN PKDPC Dpc, IN PVOID Context, IN PVOID SystemArgument1, IN PVOID SystemArgument2)
NTSTATUS	ClasspEnqueueIdleRequest (PDEVICE_OBJECT DeviceObject, PIRP Irp)
VOID	ClasspCompleteIdleRequest (PFUNCTIONAL_DEVICE_EXTENSION FdoExtension)

Variables
KDEFERRED_ROUTINE	ClasspIdleTimerDpc

Function Documentation

ClasspCompleteIdleRequest()

VOID ClasspCompleteIdleRequest

(

PFUNCTIONAL_DEVICE_EXTENSION

FdoExtension

)

Definition at line 713 of file clntirp.c.

{
    PCLASS_PRIVATE_FDO_DATA fdoData = FdoExtension->PrivateFdoData;
 
    //
    // Issue the next idle request if there are any left in the queue, there are
    // no non-idle requests outstanding, there are less than max idle requests
    // outstanding, and it has been long enough since the completion of the last
    // non-idle request.
    //
    if ((fdoData->IdleIoCount > 0) &&
        (fdoData->ActiveIdleIoCount < fdoData->IdleActiveIoMax) &&
        (fdoData->ActiveIoCount <= 0) &&
        (ClasspIdleDurationSufficient(fdoData, NULL))) {
        TracePrint((TRACE_LEVEL_INFORMATION, TRACE_FLAG_TIMER, "ClasspCompleteIdleRequest: Service next idle reqeusts\n"));
        ClasspServiceIdleRequest(FdoExtension, TRUE);
    }
 
    return;
}

Referenced by TransferPktComplete().

ClasspDequeueIdleRequest()

PIRP ClasspDequeueIdleRequest

(

PFUNCTIONAL_DEVICE_EXTENSION

FdoExtension

)

Definition at line 654 of file clntirp.c.

{
    PCLASS_PRIVATE_FDO_DATA fdoData = FdoExtension->PrivateFdoData;
    PLIST_ENTRY listEntry = NULL;
    PIRP irp = NULL;
    KIRQL oldIrql;
 
    KeAcquireSpinLock(&fdoData->IdleListLock, &oldIrql);
 
    if (fdoData->IdleIoCount > 0) {
        listEntry = RemoveHeadList(&fdoData->IdleIrpList);
        //
        // Make sure we actaully removed a request from the list
        //
        NT_ASSERT(listEntry != &fdoData->IdleIrpList);
        //
        // Decrement the idle I/O count.
        //
        fdoData->IdleIoCount--;
        //
        // Stop the timer on last request
        //
        if (fdoData->IdleIoCount == 0) {
            ClasspStopIdleTimer(fdoData);
        }
        irp = CONTAINING_RECORD(listEntry, IRP, Tail.Overlay.ListEntry);
        NT_ASSERT(irp->Type == IO_TYPE_IRP);
 
 
        InitializeListHead(&irp->Tail.Overlay.ListEntry);
    }
 
    KeReleaseSpinLock(&fdoData->IdleListLock, oldIrql);
 
 
    return irp;
}

Referenced by ClasspServiceIdleRequest().

ClasspEnqueueIdleRequest()

NTSTATUS ClasspEnqueueIdleRequest	(	PDEVICE_OBJECT	DeviceObject,
		PIRP	Irp
	)

Definition at line 576 of file clntirp.c.

{
    PFUNCTIONAL_DEVICE_EXTENSION fdoExtension = DeviceObject->DeviceExtension;
    PCLASS_PRIVATE_FDO_DATA fdoData = fdoExtension->PrivateFdoData;
    KIRQL oldIrql;
    BOOLEAN issueRequest = TRUE;
    LARGE_INTEGER currentTime;
    LARGE_INTEGER* pCurrentTime;
 
    TracePrint((TRACE_LEVEL_INFORMATION, TRACE_FLAG_TIMER, "ClasspEnqueueIdleRequest: Queue idle request %p\n", Irp));
 
    IoMarkIrpPending(Irp);
 
    //
    // Reset issueRequest if the idle duration is not sufficient.
    //
    pCurrentTime = &currentTime;
    if (ClasspIdleDurationSufficient(fdoData, &pCurrentTime) == FALSE) {
        issueRequest = FALSE;
    }
 
    //
    // If there are already max active idle requests in the port driver, then
    // queue this idle request.
    //
    if (fdoData->ActiveIdleIoCount >= fdoData->IdleActiveIoMax) {
        issueRequest = FALSE;
    }
 
 
    KeAcquireSpinLock(&fdoData->IdleListLock, &oldIrql);
    if (IsListEmpty(&fdoData->IdleIrpList)) {
        NT_ASSERT(fdoData->IdleIoCount == 0);
    }
    InsertTailList(&fdoData->IdleIrpList, &Irp->Tail.Overlay.ListEntry);
 
 
    fdoData->IdleIoCount++;
    if (!fdoData->IdleTimerStarted) {
        ClasspStartIdleTimer(fdoData);
    }
 
    if (fdoData->IdleIoCount != 1) {
        issueRequest = FALSE;
    }
 
 
    KeReleaseSpinLock(&fdoData->IdleListLock, oldIrql);
 
    if (issueRequest) {
        ClasspServiceIdleRequest(fdoExtension, FALSE);
    }
 
    return STATUS_PENDING;
}

Referenced by ClassReadWrite().

ClasspGetIdleTime()

ULONGLONG ClasspGetIdleTime	(	IN PCLASS_PRIVATE_FDO_DATA	FdoData,
		IN LARGE_INTEGER	CurrentTime
	)

Definition at line 351 of file clntirp.c.

{
    ULONGLONG idleTime;
    NTSTATUS status;
 
    //
    // Get the time difference between current time and last I/O
    // complete time.
    //
 
    status = RtlULongLongSub((ULONGLONG)CurrentTime.QuadPart,
                             (ULONGLONG)FdoData->LastNonIdleIoTime.QuadPart,
                             &idleTime);
 
    if (NT_SUCCESS(status)) {
        //
        // Convert the time to milliseconds.
        //
        idleTime = ClasspTimeDiffToMs(idleTime);
    } else {
        //
        // Failed to get time difference, assume enough time passed.
        //
        idleTime = FdoData->IdleInterval;
    }
 
    return idleTime;
}

Referenced by ClasspIdleDurationSufficient().

ClasspIdleDurationSufficient()

LOGICAL ClasspIdleDurationSufficient	(	IN PCLASS_PRIVATE_FDO_DATA	FdoData,
		OUT LARGE_INTEGER **	CurrentTimeIn
	)

Definition at line 406 of file clntirp.c.

{
    ULONGLONG idleInterval;
    LARGE_INTEGER CurrentTime;
 
    //
    // If there are any outstanding non-idle requests, then there has been no
    // idle time.
    //
    if (FdoData->ActiveIoCount > 0) {
        if (CurrentTimeIn != NULL) {
            *CurrentTimeIn = NULL;
        }
        return FALSE;
    }
 
    //
    // Check whether an idle request should be issued now or on the next timer
    // expiration.
    //
 
    CurrentTime = ClasspGetCurrentTime();
    idleInterval = ClasspGetIdleTime(FdoData, CurrentTime);
 
    if (CurrentTimeIn != NULL) {
        **CurrentTimeIn = CurrentTime;
    }
 
    if (idleInterval >= FdoData->IdleInterval) {
        return TRUE;
    }
 
    return FALSE;
}

Referenced by ClasspCompleteIdleRequest(), ClasspEnqueueIdleRequest(), and ClasspIdleTimerDpc().

ClasspIdleTimerDpc()

VOID NTAPI ClasspIdleTimerDpc	(	IN PKDPC	Dpc,
		IN PVOID	Context,
		IN PVOID	SystemArgument1,
		IN PVOID	SystemArgument2
	)

Definition at line 468 of file clntirp.c.

{
    PFUNCTIONAL_DEVICE_EXTENSION fdoExtension = Context;
    PCLASS_PRIVATE_FDO_DATA fdoData;
    ULONGLONG idleTime;
    NTSTATUS status;
    LARGE_INTEGER currentTime;
    LARGE_INTEGER* pCurrentTime;
 
    UNREFERENCED_PARAMETER(Dpc);
    UNREFERENCED_PARAMETER(SystemArgument1);
    UNREFERENCED_PARAMETER(SystemArgument2);
 
    if (fdoExtension == NULL) {
        NT_ASSERT(fdoExtension != NULL);
        return;
    }
 
    fdoData = fdoExtension->PrivateFdoData;
 
    if (fdoData->ActiveIoCount <= 0) {
 
        //
        // If there are max active idle requests, do not issue another one here.
        //
        if (fdoData->ActiveIdleIoCount >= fdoData->IdleActiveIoMax) {
            return;
        }
 
        //
        // Check whether enough idle time has passed since the last non-idle
        // request has completed.
        //
 
        pCurrentTime = &currentTime;
        if (ClasspIdleDurationSufficient(fdoData, &pCurrentTime)) {
            //
            // We are going to issue an idle request so reset the anti-starvation
            // timer counter.
            // If we are here (Idle duration is sufficient), pCurrentTime is
            // expected to be set.
            //
            NT_ASSERT(pCurrentTime != NULL);
            fdoData->AntiStarvationStartTime = *pCurrentTime;
            ClasspServiceIdleRequest(fdoExtension, FALSE);
        }
        return;
    }
 
    //
    // Get the time difference between current time and last I/O
    // complete time.
    //
 
    currentTime = ClasspGetCurrentTime();
    status = RtlULongLongSub((ULONGLONG)currentTime.QuadPart,
                             (ULONGLONG)fdoData->AntiStarvationStartTime.QuadPart,
                             &idleTime);
 
    if (NT_SUCCESS(status)) {
        //
        // Convert the time to milliseconds.
        //
        idleTime = ClasspTimeDiffToMs(idleTime);
    } else {
        //
        // Failed to get time difference, assume enough time passed.
        //
        idleTime = fdoData->StarvationDuration;
    }
 
    //
    // If the timer is running then there must be at least one idle priority I/O pending
    //
    if (idleTime >= fdoData->StarvationDuration) {
        fdoData->AntiStarvationStartTime = currentTime;
        TracePrint((TRACE_LEVEL_INFORMATION, TRACE_FLAG_TIMER, "ClasspIdleTimerDpc: Starvation timer. Send one idle request\n"));
        ClasspServiceIdleRequest(fdoExtension, FALSE);
    }
    return;
}

ClasspInitializeIdleTimer()

VOID ClasspInitializeIdleTimer

(

PFUNCTIONAL_DEVICE_EXTENSION

FdoExtension

)

Definition at line 175 of file clntirp.c.

{
    PCLASS_PRIVATE_FDO_DATA fdoData = FdoExtension->PrivateFdoData;
    ULONG idleInterval = CLASS_IDLE_INTERVAL;
    ULONG idlePrioritySupported = TRUE;
    ULONG activeIdleIoMax = 1;
 
    ClassGetDeviceParameter(FdoExtension,
                            CLASSP_REG_SUBKEY_NAME,
                            CLASSP_REG_IDLE_PRIORITY_SUPPORTED,
                            &idlePrioritySupported);
 
 
    if (idlePrioritySupported == FALSE) {
        //
        // User has set the registry to disable idle priority for this disk.
        // No need to initialize any further.
        // Always ensure that none of the other fields used for idle priority
        // io are ever used without checking if it is supported.
        //
        TracePrint((TRACE_LEVEL_INFORMATION, TRACE_FLAG_TIMER, "ClasspInitializeIdleTimer: Idle priority not supported for disk %p\n", FdoExtension));
        fdoData->IdlePrioritySupported = FALSE;
        fdoData->IdleIoCount = 0;
        fdoData->ActiveIoCount = 0;
        return;
    }
 
    ClassGetDeviceParameter(FdoExtension,
                            CLASSP_REG_SUBKEY_NAME,
                            CLASSP_REG_IDLE_INTERVAL_NAME,
                            &idleInterval);
 
    if ((idleInterval < CLASS_IDLE_INTERVAL_MIN) || (idleInterval > USHORT_MAX)) {
        //
        // If the interval is too low or too high, reset it to the default value.
        //
        idleInterval = CLASS_IDLE_INTERVAL;
    }
 
    fdoData->IdlePrioritySupported = TRUE;
    KeInitializeSpinLock(&fdoData->IdleListLock);
    KeInitializeTimer(&fdoData->IdleTimer);
    KeInitializeDpc(&fdoData->IdleDpc, ClasspIdleTimerDpc, FdoExtension);
    InitializeListHead(&fdoData->IdleIrpList);
    fdoData->IdleTimerStarted = FALSE;
    fdoData->StarvationDuration = CLASS_STARVATION_INTERVAL;
    fdoData->IdleInterval = (USHORT)(idleInterval);
    fdoData->IdleIoCount = 0;
    fdoData->ActiveIoCount = 0;
    fdoData->ActiveIdleIoCount = 0;
 
    ClassGetDeviceParameter(FdoExtension,
                            CLASSP_REG_SUBKEY_NAME,
                            CLASSP_REG_IDLE_ACTIVE_MAX,
                            &activeIdleIoMax);
 
    activeIdleIoMax = max(activeIdleIoMax, 1);
    activeIdleIoMax = min(activeIdleIoMax, USHORT_MAX);
 
    fdoData->IdleActiveIoMax = (USHORT)activeIdleIoMax;
 
    return;
}

ClasspServiceIdleRequest()

VOID ClasspServiceIdleRequest	(	PFUNCTIONAL_DEVICE_EXTENSION	FdoExtension,
		BOOLEAN	PostToDpc
	)

Definition at line 757 of file clntirp.c.

{
    PIRP irp;
 
    irp = ClasspDequeueIdleRequest(FdoExtension);
    if (irp != NULL) {
        ServiceTransferRequest(FdoExtension->DeviceObject, irp, PostToDpc);
    }
    return;
}

Referenced by ClasspCompleteIdleRequest(), ClasspEnqueueIdleRequest(), and ClasspIdleTimerDpc().

ClasspStartIdleTimer()

VOID ClasspStartIdleTimer

(

IN PCLASS_PRIVATE_FDO_DATA

FdoData

)

Definition at line 261 of file clntirp.c.

{
    LARGE_INTEGER dueTime;
    LONG mstotimer;
    LONG timerStarted;
 
    TracePrint((TRACE_LEVEL_INFORMATION, TRACE_FLAG_TIMER, "ClasspStartIdleTimer: Start idle timer\n"));
 
    timerStarted = InterlockedCompareExchange(&FdoData->IdleTimerStarted, 1, 0);
 
    if (!timerStarted) {
 
        //
        // Reset the anti-starvation start time.
        //
        FdoData->AntiStarvationStartTime = ClasspGetCurrentTime();
 
        //
        // convert milliseconds to a relative 100ns
        //
        mstotimer = (-10) * 1000;
 
        //
        // multiply the period
        //
        dueTime.QuadPart = Int32x32To64(FdoData->IdleInterval, mstotimer);
 
        KeSetTimerEx(&FdoData->IdleTimer,
                     dueTime,
                     FdoData->IdleInterval,
                     &FdoData->IdleDpc);
    }
    return;
}

Referenced by ClasspEnqueueIdleRequest().

ClasspStopIdleTimer()

VOID ClasspStopIdleTimer

(

PCLASS_PRIVATE_FDO_DATA

FdoData

)

Definition at line 316 of file clntirp.c.

{
    LONG timerStarted;
 
    TracePrint((TRACE_LEVEL_INFORMATION, TRACE_FLAG_TIMER, "ClasspStopIdleTimer: Stop idle timer\n"));
 
    timerStarted = InterlockedCompareExchange(&FdoData->IdleTimerStarted, 0, 1);
 
    if (timerStarted) {
        (VOID)KeCancelTimer(&FdoData->IdleTimer);
    }
    return;
}

Referenced by ClasspDequeueIdleRequest().

DequeueDeferredClientIrp()

PIRP DequeueDeferredClientIrp

(

PDEVICE_OBJECT

Fdo

)

Definition at line 113 of file clntirp.c.

{
    PFUNCTIONAL_DEVICE_EXTENSION fdoExtension = Fdo->DeviceExtension;
    PCLASS_PRIVATE_FDO_DATA fdoData = fdoExtension->PrivateFdoData;
    PIRP irp;
 
    //
    // The DeferredClientIrpList is almost always empty.
    // We don't want to grab the spinlock every time we check it (which is on every xfer completion)
    // so check once first before we grab the spinlock.
    //
    if (IsListEmpty(&fdoData->DeferredClientIrpList)){
        irp = NULL;
    }
    else {
        PLIST_ENTRY listEntry;
        KIRQL oldIrql;
 
        KeAcquireSpinLock(&fdoData->SpinLock, &oldIrql);
        if (IsListEmpty(&fdoData->DeferredClientIrpList)){
            listEntry = NULL;
        }
        else {
            listEntry = RemoveHeadList(&fdoData->DeferredClientIrpList);
        }
        KeReleaseSpinLock(&fdoData->SpinLock, oldIrql);
 
        if (listEntry == NULL) {
            irp = NULL;
        }
        else {
            irp = CONTAINING_RECORD(listEntry, IRP, Tail.Overlay.ListEntry);
            NT_ASSERT(irp->Type == IO_TYPE_IRP);
 
 
            InitializeListHead(&irp->Tail.Overlay.ListEntry);
        }
    }
 
    return irp;
}

Referenced by TransferPktComplete().

EnqueueDeferredClientIrp()

VOID EnqueueDeferredClientIrp	(	PDEVICE_OBJECT	Fdo,
		PIRP	Irp
	)

Definition at line 78 of file clntirp.c.

{
    PFUNCTIONAL_DEVICE_EXTENSION fdoExtension = Fdo->DeviceExtension;
    PCLASS_PRIVATE_FDO_DATA fdoData = fdoExtension->PrivateFdoData;
    KIRQL oldIrql;
 
 
    KeAcquireSpinLock(&fdoData->SpinLock, &oldIrql);
    InsertTailList(&fdoData->DeferredClientIrpList, &Irp->Tail.Overlay.ListEntry);
 
 
    KeReleaseSpinLock(&fdoData->SpinLock, oldIrql);
}

Referenced by ServiceTransferRequest().

Variable Documentation

ClasspIdleTimerDpc

KDEFERRED_ROUTINE ClasspIdleTimerDpc

Definition at line 42 of file clntirp.c.

Referenced by ClasspInitializeIdleTimer().