+++ /dev/null
-/*
- * PROJECT: ReactOS Named Pipe FileSystem
- * LICENSE: BSD - See COPYING.ARM in the top level directory
- * FILE: drivers/filesystems/npfs/datasup.c
- * PURPOSE: Data Queues Support
- * PROGRAMMERS: ReactOS Portable Systems Group
- */
-
-/* INCLUDES *******************************************************************/
-
-#include "npfs.h"
-
-// File ID number for NPFS bugchecking support
-#define NPFS_BUGCHECK_FILE_ID (NPFS_BUGCHECK_DATASUP)
-
-/* FUNCTIONS ******************************************************************/
-
-NTSTATUS
-NTAPI
-NpUninitializeDataQueue(IN PNP_DATA_QUEUE DataQueue)
-{
- PAGED_CODE();
-
- ASSERT(DataQueue->QueueState == Empty);
-
- RtlZeroMemory(DataQueue, sizeof(*DataQueue));
- return STATUS_SUCCESS;
-}
-
-NTSTATUS
-NTAPI
-NpInitializeDataQueue(IN PNP_DATA_QUEUE DataQueue,
- IN ULONG Quota)
-{
- PAGED_CODE();
-
- DataQueue->BytesInQueue = 0;
- DataQueue->EntriesInQueue = 0;
- DataQueue->QuotaUsed = 0;
- DataQueue->ByteOffset = 0;
- DataQueue->QueueState = Empty;
- DataQueue->Quota = Quota;
- InitializeListHead(&DataQueue->Queue);
- return STATUS_SUCCESS;
-}
-
-VOID
-NTAPI
-NpCompleteStalledWrites(IN PNP_DATA_QUEUE DataQueue,
- IN PLIST_ENTRY List)
-{
- ULONG QuotaLeft, ByteOffset, DataLeft, NewQuotaLeft;
- PNP_DATA_QUEUE_ENTRY DataQueueEntry;
- PIRP Irp;
- PLIST_ENTRY NextEntry;
-
- QuotaLeft = DataQueue->Quota - DataQueue->QuotaUsed;
- ByteOffset = DataQueue->ByteOffset;
-
- NextEntry = DataQueue->Queue.Flink;
- while (NextEntry != &DataQueue->Queue)
- {
- if (!QuotaLeft) break;
-
- DataQueueEntry = CONTAINING_RECORD(NextEntry,
- NP_DATA_QUEUE_ENTRY,
- QueueEntry);
-
- Irp = DataQueueEntry->Irp;
-
- if ((DataQueueEntry->DataEntryType == Buffered) && (Irp))
- {
- DataLeft = DataQueueEntry->DataSize - ByteOffset;
-
- if (DataQueueEntry->QuotaInEntry < DataLeft)
- {
- NewQuotaLeft = DataLeft - DataQueueEntry->QuotaInEntry;
- if (NewQuotaLeft > QuotaLeft) NewQuotaLeft = QuotaLeft;
-
- QuotaLeft -= NewQuotaLeft;
- DataQueueEntry->QuotaInEntry += NewQuotaLeft;
-
- if (DataQueueEntry->QuotaInEntry == DataLeft &&
- IoSetCancelRoutine(Irp, NULL))
- {
- DataQueueEntry->Irp = NULL;
-
- Irp->IoStatus.Status = STATUS_SUCCESS;
- Irp->IoStatus.Information = DataQueueEntry->DataSize;
-
- InsertTailList(List, &Irp->Tail.Overlay.ListEntry);
- }
- }
- }
-
- NextEntry = NextEntry->Flink;
- ByteOffset = 0;
- }
-
- DataQueue->QuotaUsed = DataQueue->Quota - QuotaLeft;
-}
-
-PIRP
-NTAPI
-NpRemoveDataQueueEntry(IN PNP_DATA_QUEUE DataQueue,
- IN BOOLEAN Flag,
- IN PLIST_ENTRY List)
-{
- PIRP Irp;
- PNP_DATA_QUEUE_ENTRY QueueEntry;
- BOOLEAN HasWrites;
-
- if (DataQueue->QueueState == Empty)
- {
- Irp = NULL;
- ASSERT(IsListEmpty(&DataQueue->Queue));
- ASSERT(DataQueue->EntriesInQueue == 0);
- ASSERT(DataQueue->BytesInQueue == 0);
- ASSERT(DataQueue->QuotaUsed == 0);
- }
- else
- {
- QueueEntry = CONTAINING_RECORD(RemoveHeadList(&DataQueue->Queue),
- NP_DATA_QUEUE_ENTRY,
- QueueEntry);
-
- DataQueue->BytesInQueue -= QueueEntry->DataSize;
- --DataQueue->EntriesInQueue;
-
- HasWrites = TRUE;
- if (DataQueue->QueueState != WriteEntries ||
- DataQueue->QuotaUsed < DataQueue->Quota ||
- !QueueEntry->QuotaInEntry)
- {
- HasWrites = FALSE;
- }
-
- DataQueue->QuotaUsed -= QueueEntry->QuotaInEntry;
-
- if (IsListEmpty(&DataQueue->Queue))
- {
- DataQueue->QueueState = Empty;
- HasWrites = FALSE;
- }
-
- Irp = QueueEntry->Irp;
- NpFreeClientSecurityContext(QueueEntry->ClientSecurityContext);
-
- if (Irp && !IoSetCancelRoutine(Irp, NULL))
- {
- Irp->Tail.Overlay.DriverContext[3] = NULL;
- Irp = NULL;
- }
-
- ExFreePool(QueueEntry);
-
- if (Flag)
- {
- NpGetNextRealDataQueueEntry(DataQueue, List);
- }
-
- if (HasWrites)
- {
- NpCompleteStalledWrites(DataQueue, List);
- }
- }
-
- DataQueue->ByteOffset = 0;
- return Irp;
-}
-
-PLIST_ENTRY
-NTAPI
-NpGetNextRealDataQueueEntry(IN PNP_DATA_QUEUE DataQueue,
- IN PLIST_ENTRY List)
-{
- PNP_DATA_QUEUE_ENTRY DataEntry;
- ULONG Type;
- PIRP Irp;
- PLIST_ENTRY NextEntry;
- PAGED_CODE();
-
- for (NextEntry = DataQueue->Queue.Flink;
- NextEntry != &DataQueue->Queue;
- NextEntry = DataQueue->Queue.Flink)
- {
- DataEntry = CONTAINING_RECORD(NextEntry,
- NP_DATA_QUEUE_ENTRY,
- QueueEntry);
-
- Type = DataEntry->DataEntryType;
- if (Type == Buffered || Type == Unbuffered) break;
-
- Irp = NpRemoveDataQueueEntry(DataQueue, FALSE, List);
- if (Irp)
- {
- Irp->IoStatus.Status = STATUS_SUCCESS;
- InsertTailList(List, &Irp->Tail.Overlay.ListEntry);
- }
- }
-
- return NextEntry;
-}
-
-VOID
-NTAPI
-NpCancelDataQueueIrp(IN PDEVICE_OBJECT DeviceObject,
- IN PIRP Irp)
-{
- PNP_DATA_QUEUE DataQueue;
- PNP_DATA_QUEUE_ENTRY DataEntry;
- LIST_ENTRY DeferredList;
- PSECURITY_CLIENT_CONTEXT ClientSecurityContext;
- BOOLEAN CompleteWrites, FirstEntry;
-
- if (DeviceObject) IoReleaseCancelSpinLock(Irp->CancelIrql);
-
- InitializeListHead(&DeferredList);
-
- DataQueue = Irp->Tail.Overlay.DriverContext[2];
- ClientSecurityContext = NULL;
-
- if (DeviceObject)
- {
- FsRtlEnterFileSystem();
- NpAcquireExclusiveVcb();
- }
-
- DataEntry = Irp->Tail.Overlay.DriverContext[3];
- if (DataEntry)
- {
- if (DataEntry->QueueEntry.Blink == &DataQueue->Queue)
- {
- DataQueue->ByteOffset = 0;
- FirstEntry = TRUE;
- }
- else
- {
- FirstEntry = FALSE;
- }
-
- RemoveEntryList(&DataEntry->QueueEntry);
-
- ClientSecurityContext = DataEntry->ClientSecurityContext;
-
- CompleteWrites = TRUE;
- if (DataQueue->QueueState != WriteEntries ||
- DataQueue->QuotaUsed < DataQueue->Quota ||
- !DataEntry->QuotaInEntry)
- {
- CompleteWrites = FALSE;
- }
-
- DataQueue->BytesInQueue -= DataEntry->DataSize;
- DataQueue->QuotaUsed -= DataEntry->QuotaInEntry;
- --DataQueue->EntriesInQueue;
-
- if (IsListEmpty(&DataQueue->Queue))
- {
- DataQueue->QueueState = Empty;
- ASSERT(DataQueue->BytesInQueue == 0);
- ASSERT(DataQueue->EntriesInQueue == 0);
- ASSERT(DataQueue->QuotaUsed == 0);
- }
- else
- {
- if (FirstEntry)
- {
- NpGetNextRealDataQueueEntry(DataQueue, &DeferredList);
- }
- if (CompleteWrites)
- {
- NpCompleteStalledWrites(DataQueue, &DeferredList);
- }
- }
- }
-
- if (DeviceObject)
- {
- NpReleaseVcb();
- FsRtlExitFileSystem();
- }
-
- if (DataEntry) ExFreePool(DataEntry);
-
- NpFreeClientSecurityContext(ClientSecurityContext);
- Irp->IoStatus.Status = STATUS_CANCELLED;
- IoCompleteRequest(Irp, IO_NAMED_PIPE_INCREMENT);
-
- NpCompleteDeferredIrps(&DeferredList);
-}
-
-NTSTATUS
-NTAPI
-NpAddDataQueueEntry(IN ULONG NamedPipeEnd,
- IN PNP_CCB Ccb,
- IN PNP_DATA_QUEUE DataQueue,
- IN ULONG Who,
- IN ULONG Type,
- IN ULONG DataSize,
- IN PIRP Irp,
- IN PVOID Buffer,
- IN ULONG ByteOffset)
-{
- NTSTATUS Status;
- PNP_DATA_QUEUE_ENTRY DataEntry;
- SIZE_T EntrySize;
- ULONG QuotaInEntry;
- PSECURITY_CLIENT_CONTEXT ClientContext;
- BOOLEAN HasSpace;
-
- ClientContext = NULL;
- ASSERT((DataQueue->QueueState == Empty) || (DataQueue->QueueState == Who));
-
- Status = STATUS_SUCCESS;
-
- if ((Type != 2) && (Who == WriteEntries))
- {
- Status = NpGetClientSecurityContext(NamedPipeEnd,
- Ccb,
- Irp ? Irp->Tail.Overlay.Thread :
- PsGetCurrentThread(),
- &ClientContext);
- if (!NT_SUCCESS(Status))
- {
- return Status;
- }
- }
-
- switch (Type)
- {
- case Unbuffered:
- case 2:
- case 3:
-
- ASSERT(Irp != NULL);
- DataEntry = ExAllocatePoolWithQuotaTag(NonPagedPool | POOL_QUOTA_FAIL_INSTEAD_OF_RAISE,
- sizeof(*DataEntry),
- NPFS_DATA_ENTRY_TAG);
- if (!DataEntry)
- {
- NpFreeClientSecurityContext(ClientContext);
- return STATUS_INSUFFICIENT_RESOURCES;
- }
-
- DataEntry->DataEntryType = Type;
- DataEntry->QuotaInEntry = 0;
- DataEntry->Irp = Irp;
- DataEntry->DataSize = DataSize;
- DataEntry->ClientSecurityContext = ClientContext;
- ASSERT((DataQueue->QueueState == Empty) || (DataQueue->QueueState == Who));
- Status = STATUS_PENDING;
- break;
-
- case Buffered:
-
- EntrySize = sizeof(*DataEntry);
- if (Who != ReadEntries)
- {
- EntrySize += DataSize;
- if (EntrySize < DataSize)
- {
- NpFreeClientSecurityContext(ClientContext);
- return STATUS_INVALID_PARAMETER;
- }
- }
-
- QuotaInEntry = DataSize - ByteOffset;
- if (DataQueue->Quota - DataQueue->QuotaUsed < QuotaInEntry)
- {
- QuotaInEntry = DataQueue->Quota - DataQueue->QuotaUsed;
- HasSpace = TRUE;
- }
- else
- {
- HasSpace = FALSE;
- }
-
- DataEntry = ExAllocatePoolWithQuotaTag(NonPagedPool | POOL_QUOTA_FAIL_INSTEAD_OF_RAISE,
- EntrySize,
- NPFS_DATA_ENTRY_TAG);
- if (!DataEntry)
- {
- NpFreeClientSecurityContext(ClientContext);
- return STATUS_INSUFFICIENT_RESOURCES;
- }
-
- DataEntry->QuotaInEntry = QuotaInEntry;
- DataEntry->Irp = Irp;
- DataEntry->DataEntryType = Buffered;
- DataEntry->ClientSecurityContext = ClientContext;
- DataEntry->DataSize = DataSize;
-
- if (Who == ReadEntries)
- {
- ASSERT(Irp);
-
- Status = STATUS_PENDING;
- ASSERT((DataQueue->QueueState == Empty) ||
- (DataQueue->QueueState == Who));
- }
- else
- {
- _SEH2_TRY
- {
- RtlCopyMemory(DataEntry + 1,
- Irp ? Irp->UserBuffer: Buffer,
- DataSize);
- }
- _SEH2_EXCEPT(EXCEPTION_EXECUTE_HANDLER)
- {
- NpFreeClientSecurityContext(ClientContext);
- _SEH2_YIELD(return _SEH2_GetExceptionCode());
- }
- _SEH2_END;
-
- if (HasSpace && Irp)
- {
- Status = STATUS_PENDING;
- }
- else
- {
- DataEntry->Irp = NULL;
- Status = STATUS_SUCCESS;
- }
-
- ASSERT((DataQueue->QueueState == Empty) ||
- (DataQueue->QueueState == Who));
- }
- break;
-
- default:
- ASSERT(FALSE);
- NpFreeClientSecurityContext(ClientContext);
- return STATUS_INVALID_PARAMETER;
- }
-
- ASSERT((DataQueue->QueueState == Empty) || (DataQueue->QueueState == Who));
- if (DataQueue->QueueState == Empty)
- {
- ASSERT(DataQueue->BytesInQueue == 0);
- ASSERT(DataQueue->EntriesInQueue == 0);
- ASSERT(IsListEmpty(&DataQueue->Queue));
- }
- else
- {
- ASSERT(DataQueue->QueueState == Who);
- ASSERT(DataQueue->QueueState != Empty);
- ASSERT(DataQueue->EntriesInQueue != 0);
- }
-
- DataQueue->QuotaUsed += DataEntry->QuotaInEntry;
- DataQueue->QueueState = Who;
- DataQueue->BytesInQueue += DataEntry->DataSize;
- DataQueue->EntriesInQueue++;
-
- if (ByteOffset)
- {
- DataQueue->ByteOffset = ByteOffset;
- ASSERT(Who == WriteEntries);
- ASSERT(ByteOffset < DataEntry->DataSize);
- ASSERT(DataQueue->EntriesInQueue == 1);
- }
-
- InsertTailList(&DataQueue->Queue, &DataEntry->QueueEntry);
-
- if (Status == STATUS_PENDING)
- {
- IoMarkIrpPending(Irp);
- Irp->Tail.Overlay.DriverContext[2] = DataQueue;
- Irp->Tail.Overlay.DriverContext[3] = DataEntry;
-
- IoSetCancelRoutine(Irp, NpCancelDataQueueIrp);
-
- if ((Irp->Cancel) && (IoSetCancelRoutine(Irp, NULL)))
- {
- NpCancelDataQueueIrp(NULL, Irp);
- }
- }
-
- return Status;
-}
-
-/* EOF */
projects / reactos.git / blobdiff