* FILE: ntoskrnl/cc/pin.c
* PURPOSE: Implements cache managers pinning interface
*
- * PROGRAMMERS:
+ * PROGRAMMERS: ?
+ Pierre Schweitzer (pierre@reactos.org)
*/
/* INCLUDES ******************************************************************/
{
ULONG ReadOffset;
BOOLEAN Valid;
- PBCB Bcb;
- PCACHE_SEGMENT CacheSeg;
+ PROS_SHARED_CACHE_MAP SharedCacheMap;
+ PROS_VACB Vacb;
NTSTATUS Status;
PINTERNAL_BCB iBcb;
ULONG ROffset;
ASSERT(FileObject->SectionObjectPointer);
ASSERT(FileObject->SectionObjectPointer->SharedCacheMap);
- Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
- ASSERT(Bcb);
+ SharedCacheMap = FileObject->SectionObjectPointer->SharedCacheMap;
+ ASSERT(SharedCacheMap);
- DPRINT("AllocationSize %I64x, FileSize %I64x\n",
- Bcb->AllocationSize.QuadPart,
- Bcb->FileSize.QuadPart);
+ DPRINT("SectionSize %I64x, FileSize %I64x\n",
+ SharedCacheMap->SectionSize.QuadPart,
+ SharedCacheMap->FileSize.QuadPart);
if (ReadOffset % VACB_MAPPING_GRANULARITY + Length > VACB_MAPPING_GRANULARITY)
{
+ CCTRACE(CC_API_DEBUG, "FileObject=%p FileOffset=%p Length=%lu Flags=0x%lx -> FALSE\n",
+ FileObject, FileOffset, Length, Flags);
+ ExRaiseStatus(STATUS_INVALID_PARAMETER);
return FALSE;
}
ROffset = ROUND_DOWN(ReadOffset, VACB_MAPPING_GRANULARITY);
- Status = CcRosRequestCacheSegment(Bcb,
- ROffset,
- pBuffer,
- &Valid,
- &CacheSeg);
+ Status = CcRosRequestVacb(SharedCacheMap,
+ ROffset,
+ pBuffer,
+ &Valid,
+ &Vacb);
if (!NT_SUCCESS(Status))
{
+ CCTRACE(CC_API_DEBUG, "FileObject=%p FileOffset=%p Length=%lu Flags=0x%lx -> FALSE\n",
+ FileObject, FileOffset, Length, Flags);
+ ExRaiseStatus(Status);
return FALSE;
}
{
if (!(Flags & MAP_WAIT))
{
- CcRosReleaseCacheSegment(Bcb, CacheSeg, FALSE, FALSE, FALSE);
+ CcRosReleaseVacb(SharedCacheMap, Vacb, FALSE, FALSE, FALSE);
+ CCTRACE(CC_API_DEBUG, "FileObject=%p FileOffset=%p Length=%lu Flags=0x%lx -> FALSE\n",
+ FileObject, FileOffset, Length, Flags);
return FALSE;
}
- if (!NT_SUCCESS(ReadCacheSegment(CacheSeg)))
+ Status = CcReadVirtualAddress(Vacb);
+ if (!NT_SUCCESS(Status))
{
- CcRosReleaseCacheSegment(Bcb, CacheSeg, FALSE, FALSE, FALSE);
+ CcRosReleaseVacb(SharedCacheMap, Vacb, FALSE, FALSE, FALSE);
+ CCTRACE(CC_API_DEBUG, "FileObject=%p FileOffset=%p Length=%lu Flags=0x%lx -> FALSE\n",
+ FileObject, FileOffset, Length, Flags);
+ ExRaiseStatus(Status);
return FALSE;
}
}
iBcb = ExAllocateFromNPagedLookasideList(&iBcbLookasideList);
if (iBcb == NULL)
{
- CcRosReleaseCacheSegment(Bcb, CacheSeg, TRUE, FALSE, FALSE);
+ CcRosReleaseVacb(SharedCacheMap, Vacb, TRUE, FALSE, FALSE);
+ CCTRACE(CC_API_DEBUG, "FileObject=%p FileOffset=%p Length=%lu Flags=0x%lx -> FALSE\n",
+ FileObject, FileOffset, Length, Flags);
+ ExRaiseStatus(STATUS_INSUFFICIENT_RESOURCES);
return FALSE;
}
iBcb->PFCB.NodeByteSize = sizeof(PUBLIC_BCB);
iBcb->PFCB.MappedLength = Length;
iBcb->PFCB.MappedFileOffset = *FileOffset;
- iBcb->CacheSegment = CacheSeg;
+ iBcb->Vacb = Vacb;
iBcb->Dirty = FALSE;
+ iBcb->Pinned = FALSE;
iBcb->RefCount = 1;
+ ExInitializeResourceLite(&iBcb->Lock);
*pBcb = (PVOID)iBcb;
+ CCTRACE(CC_API_DEBUG, "FileObject=%p FileOffset=%p Length=%lu Flags=0x%lx -> TRUE Bcb=%p\n",
+ FileObject, FileOffset, Length, Flags, iBcb);
return TRUE;
}
IN ULONG Flags,
OUT PVOID * Bcb)
{
+ PROS_SHARED_CACHE_MAP SharedCacheMap;
+
+ CCTRACE(CC_API_DEBUG, "FileOffset=%p FileOffset=%p Length=%lu Flags=0x%lx\n",
+ FileObject, FileOffset, Length, Flags);
+
+ ASSERT(FileObject);
+ ASSERT(FileObject->SectionObjectPointer);
+ ASSERT(FileObject->SectionObjectPointer->SharedCacheMap);
+
+ SharedCacheMap = FileObject->SectionObjectPointer->SharedCacheMap;
+ ASSERT(SharedCacheMap);
+ ASSERT(SharedCacheMap->PinAccess);
+
/* no-op for current implementation. */
return TRUE;
}
OUT PVOID * Bcb,
OUT PVOID * Buffer)
{
+ PINTERNAL_BCB iBcb;
+
+ CCTRACE(CC_API_DEBUG, "FileOffset=%p FileOffset=%p Length=%lu Flags=0x%lx\n",
+ FileObject, FileOffset, Length, Flags);
+
if (CcMapData(FileObject, FileOffset, Length, Flags, Bcb, Buffer))
{
if (CcPinMappedData(FileObject, FileOffset, Length, Flags, Bcb))
+ {
+ iBcb = *Bcb;
+
+ ASSERT(iBcb->Pinned == FALSE);
+
+ iBcb->Pinned = TRUE;
+ if (InterlockedIncrement(&iBcb->Vacb->PinCount) == 1)
+ {
+ CcRosReleaseVacbLock(iBcb->Vacb);
+ }
+
+ if (Flags & PIN_EXCLUSIVE)
+ {
+ ExAcquireResourceExclusiveLite(&iBcb->Lock, TRUE);
+ }
+ else
+ {
+ ExAcquireResourceSharedLite(&iBcb->Lock, TRUE);
+ }
+
return TRUE;
+ }
else
- CcUnpinData(Bcb);
+ CcUnpinData(*Bcb);
}
return FALSE;
}
OUT PVOID * Bcb,
OUT PVOID * Buffer)
{
+ CCTRACE(CC_API_DEBUG, "FileOffset=%p FileOffset=%p Length=%lu Zero=%d Flags=0x%lx\n",
+ FileObject, FileOffset, Length, Zero, Flags);
+
/*
* FIXME: This is function is similar to CcPinRead, but doesn't
* read the data if they're not present. Instead it should just
- * prepare the cache segments and zero them out if Zero == TRUE.
+ * prepare the VACBs and zero them out if Zero != FALSE.
*
* For now calling CcPinRead is better than returning error or
* just having UNIMPLEMENTED here.
IN PLARGE_INTEGER Lsn)
{
PINTERNAL_BCB iBcb = Bcb;
+
+ CCTRACE(CC_API_DEBUG, "Bcb=%p Lsn=%p\n",
+ Bcb, Lsn);
+
iBcb->Dirty = TRUE;
}
CcUnpinData (
IN PVOID Bcb)
{
- PINTERNAL_BCB iBcb = Bcb;
+ CCTRACE(CC_API_DEBUG, "Bcb=%p\n", Bcb);
- CcRosReleaseCacheSegment(iBcb->CacheSegment->Bcb,
- iBcb->CacheSegment,
- TRUE,
- iBcb->Dirty,
- FALSE);
- if (--iBcb->RefCount == 0)
- {
- ExFreeToNPagedLookasideList(&iBcbLookasideList, iBcb);
- }
+ CcUnpinDataForThread(Bcb, (ERESOURCE_THREAD)PsGetCurrentThread());
}
/*
IN PVOID Bcb,
IN ERESOURCE_THREAD ResourceThreadId)
{
- UNIMPLEMENTED;
+ PINTERNAL_BCB iBcb = Bcb;
+
+ CCTRACE(CC_API_DEBUG, "Bcb=%p ResourceThreadId=%lu\n", Bcb, ResourceThreadId);
+
+ if (iBcb->Pinned)
+ {
+ ExReleaseResourceForThreadLite(&iBcb->Lock, ResourceThreadId);
+ iBcb->Pinned = FALSE;
+ if (InterlockedDecrement(&iBcb->Vacb->PinCount) == 0)
+ {
+ CcRosAcquireVacbLock(iBcb->Vacb, NULL);
+ }
+ }
+
+ CcRosReleaseVacb(iBcb->Vacb->SharedCacheMap,
+ iBcb->Vacb,
+ TRUE,
+ iBcb->Dirty,
+ FALSE);
+
+ if (--iBcb->RefCount == 0)
+ {
+ ExDeleteResourceLite(&iBcb->Lock);
+ ExFreeToNPagedLookasideList(&iBcbLookasideList, iBcb);
+ }
}
/*
IN PVOID Bcb)
{
PINTERNAL_BCB iBcb = Bcb;
+
+ CCTRACE(CC_API_DEBUG, "Bcb=%p\n", Bcb);
+
iBcb->RefCount++;
}
{
PINTERNAL_BCB iBcb = Bcb;
+ CCTRACE(CC_API_DEBUG, "Bcb=%p WriteThrough=%d\n", Bcb, WriteThrough);
+
IoStatus->Status = STATUS_SUCCESS;
if (--iBcb->RefCount == 0)
{
IoStatus->Information = 0;
if (WriteThrough)
{
- KeWaitForSingleObject(&iBcb->CacheSegment->Mutex,
- Executive,
- KernelMode,
- FALSE,
- NULL);
- if (iBcb->CacheSegment->Dirty)
+ CcRosAcquireVacbLock(iBcb->Vacb, NULL);
+ if (iBcb->Vacb->Dirty)
{
- IoStatus->Status = CcRosFlushCacheSegment(iBcb->CacheSegment);
+ IoStatus->Status = CcRosFlushVacb(iBcb->Vacb);
}
else
{
IoStatus->Status = STATUS_SUCCESS;
}
- KeReleaseMutex(&iBcb->CacheSegment->Mutex, FALSE);
+ CcRosReleaseVacbLock(iBcb->Vacb);
}
else
{
IoStatus->Status = STATUS_SUCCESS;
}
+ if (iBcb->Pinned)
+ {
+ ExReleaseResourceLite(&iBcb->Lock);
+ iBcb->Pinned = FALSE;
+ if (InterlockedDecrement(&iBcb->Vacb->PinCount) == 0)
+ {
+ CcRosAcquireVacbLock(iBcb->Vacb, NULL);
+ }
+ }
+ ExDeleteResourceLite(&iBcb->Lock);
ExFreeToNPagedLookasideList(&iBcbLookasideList, iBcb);
}
}
projects / reactos.git / blobdiff