Intravision/reactos
1
0
Fork 0
mirror of https://github.com/reactos/reactos.git synced 2024-07-31 00:28:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Replaced filesystem list spinlock by an executive resource.

Browse source 
svn path=/trunk/; revision=4148
This commit is contained in:
Eric Kohl 2003-02-14 22:54:38 +00:00
parent 75e27edb71
commit e8f191a72e
1 changed files with 53 additions and 49 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

102
reactos/ntoskrnl/io/fs.c
View file

@ -1,4 +1,4 @@
/* $Id: fs.c,v 1.29 2002/09/08 10:23:25 chorns Exp $ /* $Id: fs.c,v 1.30 2003/02/14 22:54:38 ekohl Exp $
* *
* COPYRIGHT: See COPYING in the top level directory * COPYRIGHT: See COPYING in the top level directory
* PROJECT: ReactOS kernel * PROJECT: ReactOS kernel
@ -38,7 +38,7 @@ typedef struct _FS_CHANGE_NOTIFY_ENTRY
/* GLOBALS ******************************************************************/ /* GLOBALS ******************************************************************/
static KSPIN_LOCK FileSystemListLock; static ERESOURCE FileSystemListLock;
static LIST_ENTRY FileSystemListHead; static LIST_ENTRY FileSystemListHead;
static KSPIN_LOCK FsChangeNotifyListLock; static KSPIN_LOCK FsChangeNotifyListLock;
@ -159,7 +159,7 @@ VOID
IoInitFileSystemImplementation(VOID) IoInitFileSystemImplementation(VOID)
{ {
InitializeListHead(&FileSystemListHead); InitializeListHead(&FileSystemListHead);
KeInitializeSpinLock(&FileSystemListLock); ExInitializeResourceLite(&FileSystemListLock);
InitializeListHead(&FsChangeNotifyListHead); InitializeListHead(&FsChangeNotifyListHead);
KeInitializeSpinLock(&FsChangeNotifyListLock); KeInitializeSpinLock(&FsChangeNotifyListLock);
@ -169,43 +169,48 @@ IoInitFileSystemImplementation(VOID)
VOID VOID
IoShutdownRegisteredFileSystems(VOID) IoShutdownRegisteredFileSystems(VOID)
{ {
KIRQL oldlvl; PLIST_ENTRY current_entry;
PLIST_ENTRY current_entry; FILE_SYSTEM_OBJECT* current;
FILE_SYSTEM_OBJECT* current; PIRP Irp;
PIRP Irp; KEVENT Event;
KEVENT Event; IO_STATUS_BLOCK IoStatusBlock;
IO_STATUS_BLOCK IoStatusBlock; NTSTATUS Status;
NTSTATUS Status;
DPRINT("IoShutdownRegisteredFileSystems()\n"); DPRINT("IoShutdownRegisteredFileSystems()\n");
KeAcquireSpinLock(&FileSystemListLock,&oldlvl); ExAcquireResourceSharedLite(&FileSystemListLock,TRUE);
KeInitializeEvent(&Event,NotificationEvent,FALSE); KeInitializeEvent(&Event,
NotificationEvent,
FALSE);
current_entry = FileSystemListHead.Flink; current_entry = FileSystemListHead.Flink;
while (current_entry!=(&FileSystemListHead)) while (current_entry!=(&FileSystemListHead))
{ {
current = CONTAINING_RECORD(current_entry,FILE_SYSTEM_OBJECT,Entry); current = CONTAINING_RECORD(current_entry,FILE_SYSTEM_OBJECT,Entry);
/* send IRP_MJ_SHUTDOWN */ /* send IRP_MJ_SHUTDOWN */
Irp = IoBuildSynchronousFsdRequest(IRP_MJ_SHUTDOWN, Irp = IoBuildSynchronousFsdRequest(IRP_MJ_SHUTDOWN,
current->DeviceObject, current->DeviceObject,
NULL, NULL,
0, 0,
0, 0,
&Event, &Event,
&IoStatusBlock); &IoStatusBlock);
Status = IoCallDriver(current->DeviceObject,Irp); Status = IoCallDriver(current->DeviceObject,Irp);
if (Status==STATUS_PENDING) if (Status == STATUS_PENDING)
{ {
KeWaitForSingleObject(&Event,Executive,KernelMode,FALSE,NULL); KeWaitForSingleObject(&Event,
} Executive,
KernelMode,
FALSE,
NULL);
}
current_entry = current_entry->Flink; current_entry = current_entry->Flink;
} }
KeReleaseSpinLock(&FileSystemListLock,oldlvl); ExReleaseResourceLite(&FileSystemListLock);
} }
@ -330,7 +335,6 @@ IoMountVolume(IN PDEVICE_OBJECT DeviceObject,
* RETURNS: Status * RETURNS: Status
*/ */
{ {
KIRQL oldlvl;
PLIST_ENTRY current_entry; PLIST_ENTRY current_entry;
FILE_SYSTEM_OBJECT* current; FILE_SYSTEM_OBJECT* current;
NTSTATUS Status; NTSTATUS Status;
@ -366,7 +370,7 @@ IoMountVolume(IN PDEVICE_OBJECT DeviceObject,
return(STATUS_UNRECOGNIZED_VOLUME); return(STATUS_UNRECOGNIZED_VOLUME);
} }
KeAcquireSpinLock(&FileSystemListLock,&oldlvl); ExAcquireResourceSharedLite(&FileSystemListLock,TRUE);
current_entry = FileSystemListHead.Flink; current_entry = FileSystemListHead.Flink;
while (current_entry!=(&FileSystemListHead)) while (current_entry!=(&FileSystemListHead))
{ {
@ -376,27 +380,24 @@ IoMountVolume(IN PDEVICE_OBJECT DeviceObject,
current_entry = current_entry->Flink; current_entry = current_entry->Flink;
continue; continue;
} }
KeReleaseSpinLock(&FileSystemListLock,oldlvl);
Status = IopMountFileSystem(current->DeviceObject, Status = IopMountFileSystem(current->DeviceObject,
DeviceObject); DeviceObject);
KeAcquireSpinLock(&FileSystemListLock,&oldlvl);
switch (Status) switch (Status)
{ {
case STATUS_FS_DRIVER_REQUIRED: case STATUS_FS_DRIVER_REQUIRED:
KeReleaseSpinLock(&FileSystemListLock,oldlvl);
Status = IopLoadFileSystem(current->DeviceObject); Status = IopLoadFileSystem(current->DeviceObject);
if (!NT_SUCCESS(Status)) if (!NT_SUCCESS(Status))
{ {
return(Status); ExReleaseResourceLite(&FileSystemListLock);
return(Status);
} }
KeAcquireSpinLock(&FileSystemListLock,&oldlvl);
current_entry = FileSystemListHead.Flink; current_entry = FileSystemListHead.Flink;
continue; continue;
case STATUS_SUCCESS: case STATUS_SUCCESS:
DeviceObject->Vpb->Flags = DeviceObject->Vpb->Flags | DeviceObject->Vpb->Flags = DeviceObject->Vpb->Flags |
VPB_MOUNTED; VPB_MOUNTED;
KeReleaseSpinLock(&FileSystemListLock,oldlvl); ExReleaseResourceLite(&FileSystemListLock);
return(STATUS_SUCCESS); return(STATUS_SUCCESS);
case STATUS_UNRECOGNIZED_VOLUME: case STATUS_UNRECOGNIZED_VOLUME:
@ -404,7 +405,7 @@ IoMountVolume(IN PDEVICE_OBJECT DeviceObject,
current_entry = current_entry->Flink; current_entry = current_entry->Flink;
} }
} }
KeReleaseSpinLock(&FileSystemListLock,oldlvl); ExReleaseResourceLite(&FileSystemListLock);
return(STATUS_UNRECOGNIZED_VOLUME); return(STATUS_UNRECOGNIZED_VOLUME);
} }
@ -565,9 +566,13 @@ IoRegisterFileSystem(IN PDEVICE_OBJECT DeviceObject)
assert(Fs!=NULL); assert(Fs!=NULL);
Fs->DeviceObject = DeviceObject; Fs->DeviceObject = DeviceObject;
ExInterlockedInsertTailList(&FileSystemListHead, ExAcquireResourceExclusiveLite(&FileSystemListLock, TRUE);
&Fs->Entry,
&FileSystemListLock); InsertTailList(&FileSystemListHead,
&Fs->Entry);
ExReleaseResourceLite(&FileSystemListLock);
IopNotifyFileSystemChange(DeviceObject, IopNotifyFileSystemChange(DeviceObject,
TRUE); TRUE);
} }
@ -576,13 +581,12 @@ IoRegisterFileSystem(IN PDEVICE_OBJECT DeviceObject)
VOID STDCALL VOID STDCALL
IoUnregisterFileSystem(IN PDEVICE_OBJECT DeviceObject) IoUnregisterFileSystem(IN PDEVICE_OBJECT DeviceObject)
{ {
KIRQL oldlvl;
PLIST_ENTRY current_entry; PLIST_ENTRY current_entry;
PFILE_SYSTEM_OBJECT current; PFILE_SYSTEM_OBJECT current;
DPRINT("IoUnregisterFileSystem(DeviceObject %x)\n",DeviceObject); DPRINT("IoUnregisterFileSystem(DeviceObject %x)\n",DeviceObject);
KeAcquireSpinLock(&FileSystemListLock,&oldlvl); ExAcquireResourceExclusiveLite(&FileSystemListLock, TRUE);
current_entry = FileSystemListHead.Flink; current_entry = FileSystemListHead.Flink;
while (current_entry!=(&FileSystemListHead)) while (current_entry!=(&FileSystemListHead))
{ {
@ -591,13 +595,13 @@ IoUnregisterFileSystem(IN PDEVICE_OBJECT DeviceObject)
{ {
RemoveEntryList(current_entry); RemoveEntryList(current_entry);
ExFreePool(current); ExFreePool(current);
KeReleaseSpinLock(&FileSystemListLock,oldlvl); ExReleaseResourceLite(&FileSystemListLock);
IopNotifyFileSystemChange(DeviceObject, FALSE); IopNotifyFileSystemChange(DeviceObject, FALSE);
return; return;
} }
current_entry = current_entry->Flink; current_entry = current_entry->Flink;
} }
KeReleaseSpinLock(&FileSystemListLock,oldlvl); ExReleaseResourceLite(&FileSystemListLock);
} }