FAST_MUTEX HeaderMutex;
} TEST_FCB, *PTEST_FCB;
+typedef struct _TEST_CONTEXT
+{
+ PVOID Bcb;
+ PVOID Buffer;
+ ULONG Length;
+} TEST_CONTEXT, *PTEST_CONTEXT;
+
static ULONG TestTestId = -1;
static PFILE_OBJECT TestFileObject;
static PDEVICE_OBJECT TestDeviceObject;
return MmGetSystemAddressForMdlSafe(Irp->MdlAddress, NormalPagePriority);
}
+static
+VOID
+NTAPI
+MapInAnotherThread(IN PVOID Context)
+{
+ BOOLEAN Ret;
+ PULONG Buffer;
+ PVOID Bcb;
+ LARGE_INTEGER Offset;
+ PTEST_CONTEXT TestContext;
+
+ ok(TestFileObject != NULL, "Called in invalid context!\n");
+ ok_eq_ulong(TestTestId, 3);
+
+ TestContext = Context;
+ ok(TestContext != NULL, "Called in invalid context!\n");
+ ok(TestContext->Bcb != NULL, "Called in invalid context!\n");
+ ok(TestContext->Buffer != NULL, "Called in invalid context!\n");
+ ok(TestContext->Length != 0, "Called in invalid context!\n");
+
+ Ret = FALSE;
+ Offset.QuadPart = 0x1000;
+ KmtStartSeh();
+ Ret = CcMapData(TestFileObject, &Offset, TestContext->Length, MAP_WAIT, &Bcb, (PVOID *)&Buffer);
+ KmtEndSeh(STATUS_SUCCESS);
+
+ if (!skip(Ret == TRUE, "CcMapData failed\n"))
+ {
+ ok_eq_pointer(Bcb, TestContext->Bcb);
+ ok_eq_pointer(Buffer, TestContext->Buffer);
+
+ CcUnpinData(Bcb);
+ }
+
+ KmtStartSeh();
+ Ret = CcPinRead(TestFileObject, &Offset, TestContext->Length, 0, &Bcb, (PVOID *)&Buffer);
+ KmtEndSeh(STATUS_SUCCESS);
+
+ if (!skip(Ret == TRUE, "CcPinRead failed\n"))
+ {
+ ok(Bcb != TestContext->Bcb, "Returned same BCB!\n");
+ ok_eq_pointer(Buffer, TestContext->Buffer);
+
+ CcUnpinData(Bcb);
+ }
+
+ KmtStartSeh();
+ Ret = CcPinRead(TestFileObject, &Offset, TestContext->Length, PIN_IF_BCB, &Bcb, (PVOID *)&Buffer);
+ KmtEndSeh(STATUS_SUCCESS);
+ ok(Ret == FALSE, "CcPinRead succeed\n");
+
+ if (Ret)
+ {
+ CcUnpinData(Bcb);
+ }
+
+ KmtStartSeh();
+ Ret = CcPinRead(TestFileObject, &Offset, TestContext->Length, PIN_EXCLUSIVE, &Bcb, (PVOID *)&Buffer);
+ KmtEndSeh(STATUS_SUCCESS);
+
+ if (!skip(Ret == TRUE, "CcPinRead failed\n"))
+ {
+ ok(Bcb != TestContext->Bcb, "Returned same BCB!\n");
+ ok_eq_pointer(Buffer, TestContext->Buffer);
+
+ CcUnpinData(Bcb);
+ }
+
+ Offset.QuadPart = 0x1500;
+ TestContext->Length -= 0x500;
+
+ KmtStartSeh();
+ Ret = CcMapData(TestFileObject, &Offset, TestContext->Length, MAP_WAIT, &Bcb, (PVOID *)&Buffer);
+ KmtEndSeh(STATUS_SUCCESS);
+
+ if (!skip(Ret == TRUE, "CcMapData failed\n"))
+ {
+ ok_eq_pointer(Bcb, TestContext->Bcb);
+ ok_eq_pointer(Buffer, (PVOID)((ULONG_PTR)TestContext->Buffer + 0x500));
+
+ CcUnpinData(Bcb);
+ }
+
+ return;
+}
+
static
VOID
PerformTest(
if (!skip(CcIsFileCached(TestFileObject) == TRUE, "CcInitializeCacheMap failed\n"))
{
- Ret = FALSE;
- Offset.QuadPart = TestId * 0x1000;
- KmtStartSeh();
- Ret = CcMapData(TestFileObject, &Offset, FileSizes.FileSize.QuadPart - Offset.QuadPart, MAP_WAIT, &Bcb, (PVOID *)&Buffer);
- KmtEndSeh(STATUS_SUCCESS);
-
- if (!skip(Ret == TRUE, "CcMapData failed\n"))
+ if (TestId < 3)
{
- ok_eq_ulong(Buffer[(0x3000 - TestId * 0x1000) / sizeof(ULONG)], 0xDEADBABE);
-
- CcUnpinData(Bcb);
+ Ret = FALSE;
+ Offset.QuadPart = TestId * 0x1000;
+ KmtStartSeh();
+ Ret = CcMapData(TestFileObject, &Offset, FileSizes.FileSize.QuadPart - Offset.QuadPart, MAP_WAIT, &Bcb, (PVOID *)&Buffer);
+ KmtEndSeh(STATUS_SUCCESS);
+
+ if (!skip(Ret == TRUE, "CcMapData failed\n"))
+ {
+ ok_eq_ulong(Buffer[(0x3000 - TestId * 0x1000) / sizeof(ULONG)], 0xDEADBABE);
+
+ CcUnpinData(Bcb);
+ }
+ }
+ else if (TestId == 3)
+ {
+ PTEST_CONTEXT TestContext;
+
+ TestContext = ExAllocatePool(NonPagedPool, sizeof(TEST_CONTEXT));
+ if (!skip(TestContext != NULL, "ExAllocatePool failed\n"))
+ {
+ Ret = FALSE;
+ Offset.QuadPart = 0x1000;
+ KmtStartSeh();
+ Ret = CcMapData(TestFileObject, &Offset, FileSizes.FileSize.QuadPart - Offset.QuadPart, MAP_WAIT, &TestContext->Bcb, &TestContext->Buffer);
+ KmtEndSeh(STATUS_SUCCESS);
+
+ if (!skip(Ret == TRUE, "CcMapData failed\n"))
+ {
+ PKTHREAD ThreadHandle;
+
+#ifdef _X86_
+ /* FIXME: Should be fixed, will fail under certains conditions */
+ ok(TestContext->Buffer > (PVOID)0xC1000000 && TestContext->Buffer < (PVOID)0xDCFFFFFF,
+ "Buffer %p not mapped in system space\n", TestContext->Buffer);
+#else
+#ifdef _M_AMD64
+ ok(TestContext->Buffer > (PVOID)0xFFFFF98000000000 && TestContext->Buffer < (PVOID)0xFFFFFA8000000000,
+ "Buffer %p not mapped in system space\n", TestContext->Buffer);
+#else
+ skip(FALSE, "System space mapping not defined\n");
+#endif
+#endif
+
+ TestContext->Length = FileSizes.FileSize.QuadPart - Offset.QuadPart;
+ ThreadHandle = KmtStartThread(MapInAnotherThread, TestContext);
+ KmtFinishThread(ThreadHandle, NULL);
+
+ TestContext->Length = FileSizes.FileSize.QuadPart - 2 * Offset.QuadPart;
+ ThreadHandle = KmtStartThread(MapInAnotherThread, TestContext);
+ KmtFinishThread(ThreadHandle, NULL);
+
+ CcUnpinData(TestContext->Bcb);
+ }
+
+ ExFreePool(TestContext);
+ }
+ }
+ else if (TestId == 4)
+ {
+ /* Map after EOF */
+ Ret = FALSE;
+ Offset.QuadPart = FileSizes.FileSize.QuadPart + 0x1000;
+
+ KmtStartSeh();
+ Ret = CcMapData(TestFileObject, &Offset, 0x1000, 0, &Bcb, (PVOID *)&Buffer);
+ KmtEndSeh(STATUS_SUCCESS);
+ ok(Ret == FALSE, "CcMapData succeed\n");
+
+ if (Ret)
+ {
+ CcUnpinData(Bcb);
+ }
+
+ /* Map a VACB after EOF */
+ Ret = FALSE;
+ Offset.QuadPart = FileSizes.FileSize.QuadPart + 0x1000 + VACB_MAPPING_GRANULARITY;
+
+ KmtStartSeh();
+ Ret = CcMapData(TestFileObject, &Offset, 0x1000, 0, &Bcb, (PVOID *)&Buffer);
+ KmtEndSeh(STATUS_ACCESS_VIOLATION);
+ ok(Ret == FALSE, "CcMapData succeed\n");
+
+ if (Ret)
+ {
+ CcUnpinData(Bcb);
+ }
+
+ /* Map more than a VACB */
+ Ret = FALSE;
+ Offset.QuadPart = 0x0;
+
+ KmtStartSeh();
+ Ret = CcMapData(TestFileObject, &Offset, 0x1000 + VACB_MAPPING_GRANULARITY, 0, &Bcb, (PVOID *)&Buffer);
+ KmtEndSeh(STATUS_SUCCESS);
+ ok(Ret == FALSE, "CcMapData succeed\n");
+
+ if (Ret)
+ {
+ CcUnpinData(Bcb);
+ }
}
}
}
ULONG TestId,
PDEVICE_OBJECT DeviceObject)
{
+ LARGE_INTEGER Zero = RTL_CONSTANT_LARGE_INTEGER(0LL);
CACHE_UNINITIALIZE_EVENT CacheUninitEvent;
ok_eq_pointer(TestDeviceObject, DeviceObject);
if (CcIsFileCached(TestFileObject))
{
KeInitializeEvent(&CacheUninitEvent.Event, NotificationEvent, FALSE);
- CcUninitializeCacheMap(TestFileObject, NULL, &CacheUninitEvent);
+ CcUninitializeCacheMap(TestFileObject, &Zero, &CacheUninitEvent);
KeWaitForSingleObject(&CacheUninitEvent.Event, Executive, KernelMode, FALSE, NULL);
}
{
NTSTATUS Status = STATUS_SUCCESS;
+ FsRtlEnterFileSystem();
+
switch (ControlCode)
{
case IOCTL_START_TEST:
break;
}
+ FsRtlExitFileSystem();
+
return Status;
}
DPRINT("IRP %x/%x\n", IoStack->MajorFunction, IoStack->MinorFunction);
ASSERT(IoStack->MajorFunction == IRP_MJ_READ);
+ FsRtlEnterFileSystem();
+
Status = STATUS_NOT_SUPPORTED;
Irp->IoStatus.Information = 0;
IoCompleteRequest(Irp, IO_NO_INCREMENT);
}
+ FsRtlExitFileSystem();
+
return Status;
}
projects / reactos.git / blobdiff