windows-server-2003/base/fs/rdr2/rdbss/cancel.c

/*++

Copyright (c) 1989  Microsoft Corporation

Module Name:

    cancel.c

Abstract:

    This module implements the support for cancelling operations in the RDBSS driver

Author:

    Balan Sethu Raman [SethuR]    7-June-95

Revision History:

--*/

#include "precomp.h"
#pragma hdrstop

//
//  The debug trace level
//

#define Dbg  (DEBUG_TRACE_CANCEL)


NTSTATUS
RxSetMinirdrCancelRoutine (
    IN OUT PRX_CONTEXT RxContext,
    IN PMRX_CALLDOWN MRxCancelRoutine
    )
/*++

Routine Description:

    The routine sets up a  mini rdr cancel routine for an RxContext.

Arguments:

    RxContext - the context

    MRxCancelRoutine - the cancel routine

Return Value:

    None.

Notes:

--*/
{
   NTSTATUS Status;
   KIRQL   SavedIrql;

   KeAcquireSpinLock( &RxStrucSupSpinLock, &SavedIrql );

   if (!FlagOn( RxContext->Flags, RX_CONTEXT_FLAG_CANCELLED )) {
      
      RxContext->MRxCancelRoutine = MRxCancelRoutine;
      Status = STATUS_SUCCESS;
   
   } else {
      Status = STATUS_CANCELLED;
   }

   KeReleaseSpinLock( &RxStrucSupSpinLock, SavedIrql );

   return Status;
}

VOID
RxpCancelRoutine (
    PRX_CONTEXT RxContext
    )
/*++

Routine Description:

    This routine is invoked to the underlying mini rdr cancel routine at a non
    DPC level. Note: cancel is not generally synchronized with irp completion. So
    an irp can complete and cancel can still be called at the same time. The rxcontext is
    ref counted so it will stick around. The irp can only be manipulated if some flag in the 
    rxcontext indicates its still active. This occurs in 2 cases
    
    1)  The irp is in the overflow queue
    
    2)  This is pipe operation that is being synchronized in the blocking queues

Arguments:

    RxContext - the context

Return Value:

    None.

Notes:

--*/
{

    PMRX_CALLDOWN MRxCancelRoutine;

    PAGED_CODE();

    MRxCancelRoutine = RxContext->MRxCancelRoutine;

    if (MRxCancelRoutine != NULL) {
        (MRxCancelRoutine)( RxContext );
    } else if (!RxCancelOperationInOverflowQueue( RxContext )) {

        RxCancelBlockingOperation( RxContext, RxContext->CurrentIrp );
    }

    RxLog(( "Dec RxC %lx L %ld %lx\n", RxContext, __LINE__, RxContext->ReferenceCount ));
    RxWmiLog( LOG,
              RxpCancelRoutine,
              LOGPTR( RxContext )
              LOGULONG( RxContext->ReferenceCount ));

    RxDereferenceAndDeleteRxContext( RxContext );
}

VOID
RxCancelRoutine (
    IN PDEVICE_OBJECT DeviceObject,
    IN PIRP Irp
    )
/*++

Routine Description:

    The cancel routine for RDBSS

Arguments:

    DeviceObject - the device object

    Irp          - the IRP to be cancelled

Return Value:

    None.

Notes:

    Any request can be in one of three states in RDBSS ---

    1) the request is being processed.

    2) the request is waiting for the results of a calldown to a minirdr.

    3) the request is waiting on a resource.

    Any request that has been accepted by RDBSS ( the corresponding RxContext has been
    created and the cancel routine has been set ) is a valid target for cancel. The RDBSS
    driver does not make any effort to cancel requests that are in state (1) as described
    above.

    The cancelling action is invoked on those requests which are either in state (2),
    state(3) or when it is about to transition to/from either of these states.

    In order to expedite cancelling a similar strategy needs to be in place for the mini
    redirectors. This is provided by enabling the mini redirectors to register a cancel routine
    and rreserving fields in the RxContext for the mini redirectors to store the state information.

    As part of the RDBSS cancel routine the following steps will be taken .....

    1) Locate the RxContext corresponding to the given IRP.

    2) If the RxContext is waiting for a minirdr invoke the appropriate cancel routine.

    Note that the request is not immediately completed in all cases. This implies that there
    will be latencies in cancelling a request. The goal is to minimise the latency rather
    than completely eliminate them.

--*/
{
    KIRQL         SavedIrql;
    PRX_CONTEXT   RxContext;
    PLIST_ENTRY   ListEntry;

    //
    //  Locate the context corresponding to the given Irp.
    //

    KeAcquireSpinLock( &RxStrucSupSpinLock, &SavedIrql );

    ListEntry = RxActiveContexts.Flink;

    while (ListEntry != &RxActiveContexts) {
        
        RxContext = CONTAINING_RECORD( ListEntry, RX_CONTEXT, ContextListEntry );

        if (RxContext->CurrentIrp == Irp) {
            break;
        } else {
            ListEntry = ListEntry->Flink;
        }
    }

    if ((ListEntry != &RxActiveContexts) &&
        !FlagOn( RxContext->Flags, RX_CONTEXT_FLAG_CANCELLED )) {
        
        SetFlag( RxContext->Flags, RX_CONTEXT_FLAG_CANCELLED );
        InterlockedIncrement( &RxContext->ReferenceCount );
    } else {
        RxContext = NULL;
    }

    KeReleaseSpinLock( &RxStrucSupSpinLock, SavedIrql );
    IoReleaseCancelSpinLock( Irp->CancelIrql );

    if (RxContext != NULL) {
        if (!RxShouldPostCompletion()) {
            RxpCancelRoutine( RxContext );
        } else {
            RxDispatchToWorkerThread( RxFileSystemDeviceObject,
                                      CriticalWorkQueue,
                                      RxpCancelRoutine,
                                      RxContext );
        }
    }
}

NTSTATUS
RxCancelNotifyChangeDirectoryRequestsForVNetRoot (
    IN PV_NET_ROOT VNetRoot,
    IN BOOLEAN ForceFilesClosed
    )
/*++

Routine Description:

    This routine cancels all the outstanding requests for a given instance of V_NET_ROOT. The
    V_NET_ROOT's are created/deleted are independent of the files that are opened/manipulated
    in them. Therefore it is imperative that when a delete operation is attempted
    all the outstanding requests are cancelled.

Arguments:

    VNetRoot - the V_NET_ROOT instance about to be deleted

    ForceFilesClosed - if true force close, otherwise fai if opens exist

Return Value:

    None.

Notes:

--*/
{
    KIRQL SavedIrql;
    PRX_CONTEXT RxContext;
    PLIST_ENTRY ListEntry;
    LIST_ENTRY CancelledContexts;
    PMRX_CALLDOWN MRxCancelRoutine;
    NTSTATUS Status = STATUS_SUCCESS;

    InitializeListHead( &CancelledContexts );

    //
    //  Locate the context corresponding to the given Irp.
    //

    KeAcquireSpinLock( &RxStrucSupSpinLock, &SavedIrql );

    ListEntry = RxActiveContexts.Flink;

    while (ListEntry != &RxActiveContexts) {
        
        RxContext = CONTAINING_RECORD( ListEntry, RX_CONTEXT, ContextListEntry );
        ListEntry = ListEntry->Flink;

        if ((RxContext->MajorFunction == IRP_MJ_DIRECTORY_CONTROL) &&
            (RxContext->MinorFunction == IRP_MN_NOTIFY_CHANGE_DIRECTORY) &&
            (RxContext->pFcb != NULL) &&
            (!FlagOn( RxContext->Flags, RX_CONTEXT_FLAG_CANCELLED )) &&
            (RxContext->NotifyChangeDirectory.pVNetRoot == (PMRX_V_NET_ROOT)VNetRoot) &&
            (RxContext->MRxCancelRoutine != NULL)) {

            if (!ForceFilesClosed) {
                
                Status = STATUS_FILES_OPEN;
                break;
            }

            //
            //  After this flag is set no one else will invoke the cancel routine or
            //  change it
            //  

            SetFlag( RxContext->Flags, RX_CONTEXT_FLAG_CANCELLED );
            RemoveEntryList( &RxContext->ContextListEntry );
            InsertTailList( &CancelledContexts, &RxContext->ContextListEntry );
            InterlockedIncrement( &RxContext->ReferenceCount );
        }
    }

    KeReleaseSpinLock( &RxStrucSupSpinLock, SavedIrql );

    if (Status == STATUS_SUCCESS) {
        
        while (!IsListEmpty( &CancelledContexts )) {
            
            ListEntry = RemoveHeadList( &CancelledContexts );

            InitializeListHead( ListEntry );
            RxContext = CONTAINING_RECORD( ListEntry, RX_CONTEXT, ContextListEntry);

            //
            //  check to see if this guy is already completed..........if so, don't call down.
            //

            if (RxContext->CurrentIrp != NULL) {
                
                MRxCancelRoutine = RxContext->MRxCancelRoutine;
                RxContext->MRxCancelRoutine = NULL;

                ASSERT( MRxCancelRoutine != NULL );

                RxLog(( "CCtx %lx CRtn %lx\n", RxContext, MRxCancelRoutine ));
                RxWmiLog( LOG,
                          RxCancelNotifyChangeDirectoryRequestsForVNetRoot,
                          LOGPTR( RxContext )
                          LOGPTR( MRxCancelRoutine ));

                (MRxCancelRoutine)( RxContext );
            }

            RxDereferenceAndDeleteRxContext( RxContext );
        }
    }
    return Status;
}

VOID
RxCancelNotifyChangeDirectoryRequestsForFobx (
    PFOBX Fobx
    )
/*++

Routine Description:

    This routine cancels all the outstanding requests for a given FileObject This
    handles the case when a directory handle is closed while it has outstanding
    change notify requests pending.

Arguments:

    Fobx - the FOBX instance about to be closed

Return Value:

    None.

Notes:

--*/
{
    KIRQL         SavedIrql;
    PRX_CONTEXT   RxContext;
    PLIST_ENTRY   ListEntry;
    LIST_ENTRY    CancelledContexts;
    PMRX_CALLDOWN MRxCancelRoutine;

    InitializeListHead( &CancelledContexts );

    //
    //  Locate the context corresponding to the given Irp.
    //

    KeAcquireSpinLock( &RxStrucSupSpinLock, &SavedIrql );

    ListEntry = RxActiveContexts.Flink;

    while (ListEntry != &RxActiveContexts) {
        
        RxContext = CONTAINING_RECORD( ListEntry, RX_CONTEXT, ContextListEntry );
        ListEntry = ListEntry->Flink;

        if ((RxContext->MajorFunction == IRP_MJ_DIRECTORY_CONTROL) &&
            (RxContext->MinorFunction == IRP_MN_NOTIFY_CHANGE_DIRECTORY) &&
            (!FlagOn( RxContext->Flags, RX_CONTEXT_FLAG_CANCELLED )) &&
            (RxContext->pFobx == (PMRX_FOBX)Fobx) &&
            (RxContext->MRxCancelRoutine != NULL)) {

            //
            //  After this flag is set no one else will invoke the cancel routine
            //  or change it
            //  

            SetFlag( RxContext->Flags, RX_CONTEXT_FLAG_CANCELLED );
            RemoveEntryList(&RxContext->ContextListEntry);
            InsertTailList(&CancelledContexts,&RxContext->ContextListEntry);
            InterlockedIncrement(&RxContext->ReferenceCount);
        }
    }

    KeReleaseSpinLock( &RxStrucSupSpinLock, SavedIrql );

    while (!IsListEmpty(&CancelledContexts )) {
        
        ListEntry = RemoveHeadList(&CancelledContexts);

        InitializeListHead( ListEntry );
        RxContext = CONTAINING_RECORD( ListEntry, RX_CONTEXT, ContextListEntry );

        //
        //  check to see if this IRP is already completed..........if so,
        //  don't call down.
        //

        if (RxContext->CurrentIrp != NULL) {
            MRxCancelRoutine = RxContext->MRxCancelRoutine;
            RxContext->MRxCancelRoutine = NULL;

            ASSERT(MRxCancelRoutine != NULL);

            RxLog(( "CCtx %lx CRtn %lx\n", RxContext, MRxCancelRoutine ));
            RxWmiLog( LOG,
                      RxCancelNotifyChangeDirectoryRequestsForFobx,
                      LOGPTR( RxContext )
                      LOGPTR( MRxCancelRoutine ));

            (MRxCancelRoutine)( RxContext );
        }

        RxDereferenceAndDeleteRxContext( RxContext );
    }
}