[FASTFAT] Start implementing FAT32 statistics support
[reactos.git] / drivers / filesystems / npfs / flushbuf.c
1 /*
2 * PROJECT: ReactOS Named Pipe FileSystem
3 * LICENSE: BSD - See COPYING.ARM in the top level directory
4 * FILE: drivers/filesystems/npfs/flushbuf.c
5 * PURPOSE: Buffers Flushing Support
6 * PROGRAMMERS: ReactOS Portable Systems Group
7 */
8
9 /* INCLUDES *******************************************************************/
10
11 #include "npfs.h"
12
13 // File ID number for NPFS bugchecking support
14 #define NPFS_BUGCHECK_FILE_ID (NPFS_BUGCHECK_FLUSHBUF)
15
16 /* FUNCTIONS ******************************************************************/
17
18 NTSTATUS
19 NTAPI
20 NpCommonFlushBuffers(IN PDEVICE_OBJECT DeviceObject,
21 IN PIRP Irp)
22 {
23 NODE_TYPE_CODE NodeTypeCode;
24 PNP_CCB Ccb;
25 ULONG NamedPipeEnd;
26 NTSTATUS Status;
27 PNP_DATA_QUEUE FlushQueue;
28 PAGED_CODE();
29
30 NodeTypeCode = NpDecodeFileObject(IoGetCurrentIrpStackLocation(Irp)->FileObject,
31 NULL,
32 &Ccb,
33 &NamedPipeEnd);
34 if (NodeTypeCode != NPFS_NTC_CCB) return STATUS_PIPE_DISCONNECTED;
35
36 ExAcquireResourceExclusiveLite(&Ccb->NonPagedCcb->Lock, TRUE);
37
38 if (NamedPipeEnd == FILE_PIPE_SERVER_END)
39 {
40 FlushQueue = &Ccb->DataQueue[FILE_PIPE_OUTBOUND];
41 }
42 else
43 {
44 FlushQueue = &Ccb->DataQueue[FILE_PIPE_INBOUND];
45 }
46
47 if (FlushQueue->QueueState == WriteEntries)
48 {
49 Status = NpAddDataQueueEntry(NamedPipeEnd,
50 Ccb,
51 FlushQueue,
52 WriteEntries,
53 2,
54 0,
55 Irp,
56 NULL,
57 0);
58 }
59 else
60 {
61 Status = STATUS_SUCCESS;
62 }
63
64 ExReleaseResourceLite(&Ccb->NonPagedCcb->Lock);
65 return Status;
66 }
67
68 NTSTATUS
69 NTAPI
70 NpFsdFlushBuffers(IN PDEVICE_OBJECT DeviceObject,
71 IN PIRP Irp)
72 {
73 NTSTATUS Status;
74 PAGED_CODE();
75
76 FsRtlEnterFileSystem();
77 NpAcquireSharedVcb();
78
79 Status = NpCommonFlushBuffers(DeviceObject, Irp);
80
81 NpReleaseVcb();
82 FsRtlExitFileSystem();
83
84 if (Status != STATUS_PENDING)
85 {
86 Irp->IoStatus.Status = Status;
87 IoCompleteRequest(Irp, IO_NAMED_PIPE_INCREMENT);
88 }
89
90 return Status;
91 }
92
93 /* EOF */