mirror of https://github.com/tongzx/nt5src
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
185 lines
4.6 KiB
185 lines
4.6 KiB
/*++
|
|
Copyright (c) 1989 Microsoft Corporation
|
|
|
|
Module Name:
|
|
|
|
Shutdown.c
|
|
|
|
Abstract:
|
|
|
|
This module implements the file system shutdown routine for Rx
|
|
|
|
Author:
|
|
|
|
Gary Kimura [GaryKi] 19-Aug-1991
|
|
|
|
Revision History:
|
|
|
|
DANGER DANGER DANGER
|
|
|
|
THIS IS THE OLD FAT CODE....MINIMAL MODIFICATIONS HAVE BEEN MADE TO MAKE IT COMPILE.........
|
|
CODE.IMPROVEMENT
|
|
--*/
|
|
|
|
#include "precomp.h"
|
|
#pragma hdrstop
|
|
|
|
|
|
#define RxFlushVolume( __x, __y) (RtlAssert("dont call rxflushvolume", __FILE__, __LINE__, NULL))
|
|
|
|
|
|
//
|
|
// Local debug trace level
|
|
//
|
|
|
|
#define Dbg (DEBUG_TRACE_SHUTDOWN)
|
|
|
|
#ifdef ALLOC_PRAGMA
|
|
#pragma alloc_text(PAGE, RxCommonShutdown)
|
|
#endif
|
|
|
|
|
|
NTSTATUS
|
|
RxCommonShutdown ( RXCOMMON_SIGNATURE )
|
|
|
|
/*++
|
|
|
|
Routine Description:
|
|
|
|
This is the common routine for shutdown called by both the fsd and
|
|
fsp threads.
|
|
|
|
Arguments:
|
|
|
|
Irp - Supplies the Irp being processed
|
|
Return Value:
|
|
|
|
RXSTATUS - The return status for the operation
|
|
|
|
--*/
|
|
|
|
{
|
|
//PKEVENT Event;
|
|
|
|
//PLIST_ENTRY Links;
|
|
//PVCB Vcb;
|
|
//PIRP NewIrp;
|
|
//IO_STATUS_BLOCK Iosb;
|
|
|
|
PAGED_CODE();
|
|
|
|
//
|
|
// Make sure we don't get any pop-ups, and write everything through.
|
|
//
|
|
ASSERT(!"Shutdown is not implemented");
|
|
|
|
#if 0
|
|
//BUGBUG
|
|
// we should do a forced finalize here! i wonder what rdr1 does...............
|
|
|
|
SetFlag(RxContext->Flags, RX_CONTEXT_FLAG_DISABLE_POPUPS |
|
|
RX_CONTEXT_FLAG_WRITE_THROUGH);
|
|
|
|
//
|
|
// Allocate an initialize an event for doing calls down to
|
|
// our target deivce objects
|
|
//
|
|
|
|
Event = RxAllocatePoolWithTag( NonPagedPool, sizeof(KEVENT), RX_MISC_POOLTAG );
|
|
KeInitializeEvent( Event, NotificationEvent, FALSE );
|
|
|
|
//
|
|
// Get everyone else out of the way
|
|
//
|
|
|
|
(VOID) RxAcquireExclusiveGlobal( RxContext );
|
|
|
|
try {
|
|
|
|
//
|
|
// For every volume that is mounted we will flush the
|
|
// volume and then shutdown the target device objects.
|
|
//
|
|
|
|
for (Links = RxData.VcbQueue.Flink;
|
|
Links != &RxData.VcbQueue;
|
|
Links = Links->Flink) {
|
|
|
|
Vcb = CONTAINING_RECORD(Links, VCB, VcbLinks);
|
|
|
|
//
|
|
// If we have already been called before for this volume
|
|
// (and yes this does happen), skip this volume as no writes
|
|
// have been allowed since the first shutdown.
|
|
//
|
|
|
|
if ( FlagOn( Vcb->VcbState, VCB_STATE_FLAG_SHUTDOWN) ||
|
|
(Vcb->VcbCondition != VcbGood) ) {
|
|
|
|
continue;
|
|
}
|
|
|
|
//joejoe an underlying routine for this macro has been removed
|
|
// this code is never executed in the remote case because we never haver a
|
|
// VCB queue formed!
|
|
//RxAcquireExclusiveVolume( RxContext, Vcb );
|
|
|
|
try {
|
|
|
|
if ( (Vcb->VcbCondition == VcbGood) &&
|
|
(!FlagOn(Vcb->VcbState, VCB_STATE_FLAG_FLOPPY)) ) {
|
|
|
|
(VOID)RxFlushVolume( RxContext, Vcb );
|
|
|
|
NewIrp = IoBuildSynchronousFsdRequest( IRP_MJ_SHUTDOWN,
|
|
Vcb->TargetDeviceObject,
|
|
NULL,
|
|
0,
|
|
NULL,
|
|
Event,
|
|
&Iosb );
|
|
|
|
if (NewIrp != NULL) {
|
|
|
|
if (NT_SUCCESS(IoCallDriver( Vcb->TargetDeviceObject, NewIrp ))) {
|
|
|
|
(VOID) KeWaitForSingleObject( Event,
|
|
Executive,
|
|
KernelMode,
|
|
FALSE,
|
|
NULL );
|
|
|
|
(VOID) KeResetEvent( Event );
|
|
}
|
|
}
|
|
}
|
|
|
|
} except( EXCEPTION_EXECUTE_HANDLER ) {
|
|
|
|
NOTHING;
|
|
}
|
|
|
|
SetFlag( Vcb->VcbState, VCB_STATE_FLAG_SHUTDOWN );
|
|
|
|
//joejoe see comment above
|
|
//RxReleaseVolume( RxContext, Vcb );
|
|
}
|
|
|
|
} finally {
|
|
|
|
RxFreePool( Event );
|
|
|
|
RxReleaseGlobal( RxContext );
|
|
|
|
//RxCompleteRequest( RxContext, RxStatus(SUCCESS) );
|
|
}
|
|
|
|
//
|
|
// And return to our caller
|
|
//
|
|
|
|
#endif
|
|
//RxCompleteRequest( RxContext, RxStatus(SUCCESS) );
|
|
return STATUS_SUCCESS;
|
|
}
|
|
|