ApfelTeeSaft/reactos
1
0
Fork 0
mirror of https://github.com/ApfelTeeSaft/reactos.git synced 2026-09-02 04:13:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

[RXCE]

Browse Source 
- Implement RxAcquireFcbForLazyWrite(), RxAcquireFcbForReadAhead(), RxReleaseFcbFromLazyWrite(), RxReleaseFcbFromReadAhead()

This makes RXCE better at dealing with Cc (and the other way round ;-)). This notably avoids infinite acquire loops from Cc when writing on a NFS share.

CORE-8204
CORE-11327

svn path=/trunk/; revision=75441
This commit is contained in:
Pierre Schweitzer
2017-07-30 07:58:25 +00:00
parent d09d1d8165
commit 0eacafad27
3 changed files with 188 additions and 81 deletions
Download Patch File Download Diff File Expand all files Collapse all files
reactos/sdk/include/ddk/nodetype.h
+2
View File
@@ -63,6 +63,8 @@ typedef enum _RX_FILE_TYPE
#define RDBSS_NTC_NONPAGED_FCB ((NODE_TYPE_CODE)0xebfd)
#define RDBSS_NTC_MINIRDR_DISPATCH ((NODE_TYPE_CODE)0xebff)
#define RDBSS_NTC_FCB RDBSS_NTC_STORAGE_TYPE_FILE
#define NodeTypeIsFcb(FCB) ((((NodeType(FCB) & 0xff00) == RDBSS_NTC_STORAGE_TYPE_UNKNOWN)) || ((NodeType(FCB) & 0xfff0) == 0xeb90))
#define RX_SCAVENGER_MASK (0x1000)
reactos/sdk/lib/drivers/rdbsslib/rdbss.c
-81
View File
@@ -743,53 +743,6 @@ __RxWriteReleaseResources(
}
}
NTSTATUS
NTAPI
RxAcquireExclusiveFcbResourceInMRx(
_Inout_ PMRX_FCB Fcb)
{
UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
BOOLEAN
NTAPI
RxAcquireFcbForLazyWrite(
PVOID Context,
BOOLEAN Wait)
{
UNIMPLEMENTED;
return FALSE;
}
BOOLEAN
NTAPI
RxAcquireFcbForReadAhead(
PVOID Context,
BOOLEAN Wait)
{
UNIMPLEMENTED;
return FALSE;
}
VOID
NTAPI
RxAcquireFileForNtCreateSection(
PFILE_OBJECT FileObject)
{
UNIMPLEMENTED;
}
NTSTATUS
NTAPI
RxAcquireForCcFlush(
PFILE_OBJECT FileObject,
PDEVICE_OBJECT DeviceObject)
{
UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
/*
* @implemented
*/
@@ -8162,40 +8115,6 @@ RxRegisterMinirdr(
return STATUS_SUCCESS;
}
VOID
NTAPI
RxReleaseFcbFromLazyWrite(
PVOID Context)
{
UNIMPLEMENTED;
}
VOID
NTAPI
RxReleaseFcbFromReadAhead(
PVOID Context)
{
UNIMPLEMENTED;
}
VOID
NTAPI
RxReleaseFileForNtCreateSection(
PFILE_OBJECT FileObject)
{
UNIMPLEMENTED;
}
NTSTATUS
NTAPI
RxReleaseForCcFlush(
PFILE_OBJECT FileObject,
PDEVICE_OBJECT DeviceObject)
{
UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
/*
* @implemented
*/
reactos/sdk/lib/drivers/rxce/rxce.c
+186
View File
@@ -174,6 +174,118 @@ BOOLEAN DumpDispatchRoutine = FALSE;
/* FUNCTIONS ****************************************************************/
NTSTATUS
NTAPI
RxAcquireExclusiveFcbResourceInMRx(
_Inout_ PMRX_FCB Fcb)
{
UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
/*
* @implemented
*/
BOOLEAN
NTAPI
RxAcquireFcbForLazyWrite(
PVOID Context,
BOOLEAN Wait)
{
PFCB Fcb;
BOOLEAN Ret;
PAGED_CODE();
Fcb = Context;
/* The received context is a FCB */
ASSERT(NodeType(Fcb) == RDBSS_NTC_FCB);
ASSERT_CORRECT_FCB_STRUCTURE(Fcb);
ASSERT(Fcb->Specific.Fcb.LazyWriteThread == NULL);
/* Acquire the paging resource (shared) */
Ret = ExAcquireResourceSharedLite(Fcb->Header.PagingIoResource, Wait);
if (Ret)
{
/* Update tracker information */
Fcb->PagingIoResourceFile = __FILE__;
Fcb->PagingIoResourceLine = __LINE__;
/* Lazy writer thread is the current one */
Fcb->Specific.Fcb.LazyWriteThread = PsGetCurrentThread();
/* There is no top level IRP */
ASSERT(RxIsThisTheTopLevelIrp(NULL));
/* Now, there will be! */
Ret = RxTryToBecomeTheTopLevelIrp(NULL, (PIRP)FSRTL_CACHE_TOP_LEVEL_IRP,
Fcb->RxDeviceObject, TRUE);
/* In case of failure, release the lock and reset everything */
if (!Ret)
{
Fcb->PagingIoResourceFile = NULL;
Fcb->PagingIoResourceLine = 0;
ExReleaseResourceLite(Fcb->Header.PagingIoResource);
Fcb->Specific.Fcb.LazyWriteThread = NULL;
}
}
return Ret;
}
/*
* @implemented
*/
BOOLEAN
NTAPI
RxAcquireFcbForReadAhead(
PVOID Context,
BOOLEAN Wait)
{
PFCB Fcb;
BOOLEAN Ret;
PAGED_CODE();
Fcb = Context;
/* The received context is a FCB */
ASSERT(NodeType(Fcb) == RDBSS_NTC_FCB);
ASSERT_CORRECT_FCB_STRUCTURE(Fcb);
Ret = ExAcquireResourceSharedLite(Fcb->Header.Resource, Wait);
if (Ret)
{
/* There is no top level IRP */
ASSERT(RxIsThisTheTopLevelIrp(NULL));
/* Now, there will be! */
Ret = RxTryToBecomeTheTopLevelIrp(NULL, (PIRP)FSRTL_CACHE_TOP_LEVEL_IRP,
Fcb->RxDeviceObject, TRUE);
/* In case of failure, release the lock and reset everything */
if (!Ret)
{
ExReleaseResourceLite(Fcb->Header.Resource);
}
}
return Ret;
}
VOID
NTAPI
RxAcquireFileForNtCreateSection(
PFILE_OBJECT FileObject)
{
UNIMPLEMENTED;
}
NTSTATUS
NTAPI
RxAcquireForCcFlush(
PFILE_OBJECT FileObject,
PDEVICE_OBJECT DeviceObject)
{
UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
/*
* @implemented
*/
@@ -7319,6 +7431,80 @@ RxReinitializeContext(
RxInitializeContext(Irp, RxDeviceObject, InitialContextFlags, RxContext);
}
/*
* @implemented
*/
VOID
NTAPI
RxReleaseFcbFromLazyWrite(
PVOID Context)
{
PFCB Fcb;
PAGED_CODE();
Fcb = Context;
/* The received context is a FCB */
ASSERT(NodeType(Fcb) == RDBSS_NTC_FCB);
ASSERT_CORRECT_FCB_STRUCTURE(Fcb);
/* Lazy writer is releasing lock, so forget about it */
Fcb->Specific.Fcb.LazyWriteThread = NULL;
/* If we were top level IRP, unwind */
if (RxGetTopIrpIfRdbssIrp() == (PIRP)FSRTL_CACHE_TOP_LEVEL_IRP)
{
RxUnwindTopLevelIrp(NULL);
}
/* And finally, release the lock */
Fcb->PagingIoResourceFile = NULL;
Fcb->PagingIoResourceLine = 0;
ExReleaseResourceLite(Fcb->Header.PagingIoResource);
}
/*
* @implemented
*/
VOID
NTAPI
RxReleaseFcbFromReadAhead(
PVOID Context)
{
PFCB Fcb;
PAGED_CODE();
Fcb = Context;
/* The received context is a FCB */
ASSERT(NodeType(Fcb) == RDBSS_NTC_FCB);
ASSERT_CORRECT_FCB_STRUCTURE(Fcb);
/* Top Level IRP is CC */
ASSERT(RxGetTopIrpIfRdbssIrp() == (PIRP)FSRTL_CACHE_TOP_LEVEL_IRP);
RxUnwindTopLevelIrp(NULL);
ExReleaseResourceLite(Fcb->Header.Resource);
}
VOID
NTAPI
RxReleaseFileForNtCreateSection(
PFILE_OBJECT FileObject)
{
UNIMPLEMENTED;
}
NTSTATUS
NTAPI
RxReleaseForCcFlush(
PFILE_OBJECT FileObject,
PDEVICE_OBJECT DeviceObject)
{
UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
/*
* @implemented
*/