[NTOS:CC]
[reactos.git] / reactos / ntoskrnl / cc / pin.c
index d6e764a..26d375e 100644 (file)
@@ -24,13 +24,13 @@ extern NPAGED_LOOKASIDE_LIST iBcbLookasideList;
  */
 BOOLEAN
 NTAPI
-CcMapData(
+CcMapData (
     IN PFILE_OBJECT FileObject,
-       IN PLARGE_INTEGER FileOffset,
-       IN ULONG Length,
-       IN ULONG Flags,
-       OUT PVOID *pBcb,
-       OUT PVOID *pBuffer)
+    IN PLARGE_INTEGER FileOffset,
+    IN ULONG Length,
+    IN ULONG Flags,
+    OUT PVOID *pBcb,
+    OUT PVOID *pBuffer)
 {
     ULONG ReadOffset;
     BOOLEAN Valid;
@@ -40,7 +40,7 @@ CcMapData(
     PINTERNAL_BCB iBcb;
     ULONG ROffset;
 
-    DPRINT("CcMapData(FileObject 0x%p, FileOffset %I64x, Length %d, Flags %d,"
+    DPRINT("CcMapData(FileObject 0x%p, FileOffset %I64x, Length %lu, Flags 0x%lx,"
            " pBcb 0x%p, pBuffer 0x%p)\n", FileObject, FileOffset->QuadPart,
            Length, Flags, pBcb, pBuffer);
 
@@ -57,18 +57,22 @@ CcMapData(
            Bcb->AllocationSize.QuadPart,
            Bcb->FileSize.QuadPart);
 
-    if (ReadOffset % Bcb->CacheSegmentSize + Length > Bcb->CacheSegmentSize)
+    if (ReadOffset % VACB_MAPPING_GRANULARITY + Length > VACB_MAPPING_GRANULARITY)
     {
         return FALSE;
     }
-    ROffset = ROUND_DOWN (ReadOffset, Bcb->CacheSegmentSize);
-    Status = CcRosRequestCacheSegment(Bcb, ROffset,
-                                             pBuffer, &Valid,
+
+    ROffset = ROUND_DOWN(ReadOffset, VACB_MAPPING_GRANULARITY);
+    Status = CcRosRequestCacheSegment(Bcb,
+                                      ROffset,
+                                      pBuffer,
+                                      &Valid,
                                       &CacheSeg);
     if (!NT_SUCCESS(Status))
     {
         return FALSE;
     }
+
     if (!Valid)
     {
         if (!(Flags & MAP_WAIT))
@@ -76,21 +80,23 @@ CcMapData(
             CcRosReleaseCacheSegment(Bcb, CacheSeg, FALSE, FALSE, FALSE);
             return FALSE;
         }
+
         if (!NT_SUCCESS(ReadCacheSegment(CacheSeg)))
         {
             CcRosReleaseCacheSegment(Bcb, CacheSeg, FALSE, FALSE, FALSE);
-               return FALSE;
+            return FALSE;
         }
     }
 
-    *pBuffer = (PVOID)((ULONG_PTR)(*pBuffer) + (ReadOffset % Bcb->CacheSegmentSize));
+    *pBuffer = (PVOID)((ULONG_PTR)(*pBuffer) + ReadOffset % VACB_MAPPING_GRANULARITY);
     iBcb = ExAllocateFromNPagedLookasideList(&iBcbLookasideList);
     if (iBcb == NULL)
     {
         CcRosReleaseCacheSegment(Bcb, CacheSeg, TRUE, FALSE, FALSE);
         return FALSE;
     }
-    memset(iBcb, 0, sizeof(INTERNAL_BCB));
+
+    RtlZeroMemory(iBcb, sizeof(*iBcb));
     iBcb->PFCB.NodeTypeCode = 0xDE45; /* Undocumented (CAPTIVE_PUBLIC_BCB_NODETYPECODE) */
     iBcb->PFCB.NodeByteSize = sizeof(PUBLIC_BCB);
     iBcb->PFCB.MappedLength = Length;
@@ -99,6 +105,7 @@ CcMapData(
     iBcb->Dirty = FALSE;
     iBcb->RefCount = 1;
     *pBcb = (PVOID)iBcb;
+
     return TRUE;
 }
 
@@ -108,15 +115,14 @@ CcMapData(
 BOOLEAN
 NTAPI
 CcPinMappedData (
-       IN      PFILE_OBJECT            FileObject,
-       IN      PLARGE_INTEGER          FileOffset,
-       IN      ULONG                   Length,
-       IN      ULONG                   Flags,
-       OUT     PVOID                   * Bcb
-       )
+    IN PFILE_OBJECT FileObject,
+    IN PLARGE_INTEGER FileOffset,
+    IN ULONG Length,
+    IN ULONG Flags,
+    OUT        PVOID * Bcb)
 {
-  /* no-op for current implementation. */
-  return TRUE;
+    /* no-op for current implementation. */
+    return TRUE;
 }
 
 /*
@@ -125,22 +131,21 @@ CcPinMappedData (
 BOOLEAN
 NTAPI
 CcPinRead (
-       IN      PFILE_OBJECT            FileObject,
-       IN      PLARGE_INTEGER          FileOffset,
-       IN      ULONG                   Length,
-       IN      ULONG                   Flags,
-       OUT     PVOID                   * Bcb,
-       OUT     PVOID                   * Buffer
-       )
+    IN PFILE_OBJECT FileObject,
+    IN PLARGE_INTEGER FileOffset,
+    IN ULONG Length,
+    IN ULONG Flags,
+    OUT        PVOID * Bcb,
+    OUT        PVOID * Buffer)
 {
-  if (CcMapData(FileObject, FileOffset, Length, Flags, Bcb, Buffer))
-  {
-    if (CcPinMappedData(FileObject, FileOffset, Length, Flags, Bcb))
-      return TRUE;
-    else
-      CcUnpinData(Bcb);
-  }
-  return FALSE;
+    if (CcMapData(FileObject, FileOffset, Length, Flags, Bcb, Buffer))
+    {
+        if (CcPinMappedData(FileObject, FileOffset, Length, Flags, Bcb))
+            return TRUE;
+        else
+            CcUnpinData(Bcb);
+    }
+    return FALSE;
 }
 
 /*
@@ -149,35 +154,35 @@ CcPinRead (
 BOOLEAN
 NTAPI
 CcPreparePinWrite (
-       IN      PFILE_OBJECT            FileObject,
-       IN      PLARGE_INTEGER          FileOffset,
-       IN      ULONG                   Length,
-       IN      BOOLEAN                 Zero,
-       IN      ULONG                   Flags,
-       OUT     PVOID                   * Bcb,
-       OUT     PVOID                   * Buffer
-       )
+    IN PFILE_OBJECT FileObject,
+    IN PLARGE_INTEGER FileOffset,
+    IN ULONG Length,
+    IN BOOLEAN Zero,
+    IN ULONG Flags,
+    OUT        PVOID * Bcb,
+    OUT        PVOID * Buffer)
 {
-        /*
-         * 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.
-         *
-         * For now calling CcPinRead is better than returning error or
-         * just having UNIMPLEMENTED here.
-         */
-        return CcPinRead(FileObject, FileOffset, Length, Flags, Bcb, Buffer);
+    /*
+     * 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.
+     *
+     * For now calling CcPinRead is better than returning error or
+     * just having UNIMPLEMENTED here.
+     */
+    return CcPinRead(FileObject, FileOffset, Length, Flags, Bcb, Buffer);
 }
 
 /*
  * @implemented
  */
 VOID NTAPI
-CcSetDirtyPinnedData (IN PVOID Bcb,
-                     IN PLARGE_INTEGER Lsn)
+CcSetDirtyPinnedData (
+    IN PVOID Bcb,
+    IN PLARGE_INTEGER Lsn)
 {
-   PINTERNAL_BCB iBcb = Bcb;
-   iBcb->Dirty = TRUE;
+    PINTERNAL_BCB iBcb = Bcb;
+    iBcb->Dirty = TRUE;
 }
 
 
@@ -185,15 +190,20 @@ CcSetDirtyPinnedData (IN PVOID Bcb,
  * @implemented
  */
 VOID NTAPI
-CcUnpinData (IN PVOID Bcb)
+CcUnpinData (
+    IN PVOID Bcb)
 {
-  PINTERNAL_BCB iBcb = Bcb;
-  CcRosReleaseCacheSegment(iBcb->CacheSegment->Bcb, iBcb->CacheSegment, TRUE,
-                           iBcb->Dirty, FALSE);
-  if (--iBcb->RefCount == 0)
-  {
-    ExFreeToNPagedLookasideList(&iBcbLookasideList, iBcb);
-  }
+    PINTERNAL_BCB iBcb = Bcb;
+
+    CcRosReleaseCacheSegment(iBcb->CacheSegment->Bcb,
+                             iBcb->CacheSegment,
+                             TRUE,
+                             iBcb->Dirty,
+                             FALSE);
+    if (--iBcb->RefCount == 0)
+    {
+        ExFreeToNPagedLookasideList(&iBcbLookasideList, iBcb);
+    }
 }
 
 /*
@@ -202,11 +212,10 @@ CcUnpinData (IN PVOID Bcb)
 VOID
 NTAPI
 CcUnpinDataForThread (
-       IN      PVOID                   Bcb,
-       IN      ERESOURCE_THREAD        ResourceThreadId
-       )
+    IN PVOID Bcb,
+    IN ERESOURCE_THREAD ResourceThreadId)
 {
-       UNIMPLEMENTED;
+    UNIMPLEMENTED;
 }
 
 /*
@@ -215,11 +224,10 @@ CcUnpinDataForThread (
 VOID
 NTAPI
 CcRepinBcb (
-       IN      PVOID   Bcb
-       )
+    IN PVOID Bcb)
 {
-  PINTERNAL_BCB iBcb = Bcb;
-  iBcb->RefCount++;
+    PINTERNAL_BCB iBcb = Bcb;
+    iBcb->RefCount++;
 }
 
 /*
@@ -228,38 +236,38 @@ CcRepinBcb (
 VOID
 NTAPI
 CcUnpinRepinnedBcb (
-       IN      PVOID                   Bcb,
-       IN      BOOLEAN                 WriteThrough,
-       IN      PIO_STATUS_BLOCK        IoStatus
-       )
+    IN PVOID Bcb,
+    IN BOOLEAN WriteThrough,
+    IN PIO_STATUS_BLOCK IoStatus)
 {
-  PINTERNAL_BCB iBcb = Bcb;
+    PINTERNAL_BCB iBcb = Bcb;
 
-  if (--iBcb->RefCount == 0)
+    IoStatus->Status = STATUS_SUCCESS;
+    if (--iBcb->RefCount == 0)
     {
-      IoStatus->Information = 0;
-      if (WriteThrough)
+        IoStatus->Information = 0;
+        if (WriteThrough)
         {
             KeWaitForSingleObject(&iBcb->CacheSegment->Mutex,
                                   Executive,
                                   KernelMode,
                                   FALSE,
                                   NULL);
-          if (iBcb->CacheSegment->Dirty)
+            if (iBcb->CacheSegment->Dirty)
             {
-              IoStatus->Status = CcRosFlushCacheSegment(iBcb->CacheSegment);
+                IoStatus->Status = CcRosFlushCacheSegment(iBcb->CacheSegment);
             }
-          else
+            else
             {
-              IoStatus->Status = STATUS_SUCCESS;
+                IoStatus->Status = STATUS_SUCCESS;
             }
-          KeReleaseMutex(&iBcb->CacheSegment->Mutex, 0);
+            KeReleaseMutex(&iBcb->CacheSegment->Mutex, FALSE);
         }
-      else
+        else
         {
-          IoStatus->Status = STATUS_SUCCESS;
+            IoStatus->Status = STATUS_SUCCESS;
         }
 
-      ExFreeToNPagedLookasideList(&iBcbLookasideList, iBcb);
+        ExFreeToNPagedLookasideList(&iBcbLookasideList, iBcb);
     }
 }