2 * COPYRIGHT: See COPYING in the top level directory
3 * PROJECT: ReactOS kernel
4 * FILE: drivers/fs/np/finfo.c
5 * PURPOSE: Named pipe filesystem
6 * PROGRAMMER: Eric Kohl
9 /* INCLUDES ******************************************************************/
16 /* FUNCTIONS *****************************************************************/
20 NpfsSetPipeInformation(PDEVICE_OBJECT DeviceObject
,
22 PFILE_PIPE_INFORMATION Info
,
26 PFILE_PIPE_INFORMATION Request
;
27 DPRINT("NpfsSetPipeInformation()\n");
29 /* Get the Pipe and data */
31 Request
= (PFILE_PIPE_INFORMATION
)Info
;
33 if ((Fcb
->PipeType
== FILE_PIPE_BYTE_STREAM_TYPE
) && (Request
->ReadMode
== FILE_PIPE_MESSAGE_MODE
))
35 DPRINT("Cannot change readmode to message type on a byte type pipe!\n");
36 return STATUS_ACCESS_DENIED
;
40 if (Ccb
->PipeEnd
== FILE_PIPE_CLIENT_END
)
42 Fcb
->ClientReadMode
= Request
->ReadMode
;
46 Fcb
->ServerReadMode
= Request
->ReadMode
;
49 Fcb
->CompletionMode
= Request
->CompletionMode
;
52 return STATUS_SUCCESS
;
57 NpfsSetPipeRemoteInformation(PDEVICE_OBJECT DeviceObject
,
59 PFILE_PIPE_INFORMATION Info
,
63 PFILE_PIPE_REMOTE_INFORMATION Request
;
64 DPRINT("NpfsSetPipeRemoteInformation()\n");
66 /* Get the Pipe and data */
68 Request
= (PFILE_PIPE_REMOTE_INFORMATION
)Info
;
70 /* Set the Settings */
71 Fcb
->TimeOut
= Request
->CollectDataTime
;
72 Fcb
->InboundQuota
= Request
->MaximumCollectionCount
;
75 return STATUS_SUCCESS
;
80 NpfsQueryPipeInformation(PDEVICE_OBJECT DeviceObject
,
82 PFILE_PIPE_INFORMATION Info
,
86 ULONG ConnectionSideReadMode
;
87 DPRINT("NpfsQueryPipeInformation()\n");
93 RtlZeroMemory(Info
, sizeof(FILE_PIPE_INFORMATION
));
95 if (Ccb
->PipeEnd
== FILE_PIPE_CLIENT_END
) ConnectionSideReadMode
=Ccb
->Fcb
->ClientReadMode
;
96 else ConnectionSideReadMode
= Ccb
->Fcb
->ServerReadMode
;
99 Info
->CompletionMode
= Fcb
->CompletionMode
;
100 Info
->ReadMode
= ConnectionSideReadMode
;
103 *BufferLength
-= sizeof(FILE_PIPE_INFORMATION
);
104 return STATUS_SUCCESS
;
109 NpfsQueryPipeRemoteInformation(PDEVICE_OBJECT DeviceObject
,
111 PFILE_PIPE_REMOTE_INFORMATION Info
,
115 DPRINT("NpfsQueryPipeRemoteInformation()\n");
121 RtlZeroMemory(Info
, sizeof(FILE_PIPE_REMOTE_INFORMATION
));
124 Info
->MaximumCollectionCount
= Fcb
->InboundQuota
;
125 Info
->CollectDataTime
= Fcb
->TimeOut
;
128 *BufferLength
-= sizeof(FILE_PIPE_REMOTE_INFORMATION
);
129 return STATUS_SUCCESS
;
134 NpfsQueryLocalPipeInformation(PDEVICE_OBJECT DeviceObject
,
136 PFILE_PIPE_LOCAL_INFORMATION Info
,
141 DPRINT("NpfsQueryLocalPipeInformation()\n");
146 sizeof(FILE_PIPE_LOCAL_INFORMATION
));
148 Info
->NamedPipeType
= Fcb
->PipeType
;
149 Info
->NamedPipeConfiguration
= Fcb
->PipeConfiguration
;
150 Info
->MaximumInstances
= Fcb
->MaximumInstances
;
151 Info
->CurrentInstances
= Fcb
->CurrentInstances
;
152 Info
->InboundQuota
= Fcb
->InboundQuota
;
153 Info
->OutboundQuota
= Fcb
->OutboundQuota
;
154 Info
->NamedPipeState
= Ccb
->PipeState
;
155 Info
->NamedPipeEnd
= Ccb
->PipeEnd
;
157 if (Ccb
->PipeEnd
== FILE_PIPE_SERVER_END
)
159 Info
->ReadDataAvailable
= Ccb
->ReadDataAvailable
;
160 Info
->WriteQuotaAvailable
= Ccb
->WriteQuotaAvailable
;
162 else if (Ccb
->OtherSide
!= NULL
)
164 Info
->ReadDataAvailable
= Ccb
->OtherSide
->ReadDataAvailable
;
165 Info
->WriteQuotaAvailable
= Ccb
->OtherSide
->WriteQuotaAvailable
;
168 *BufferLength
-= sizeof(FILE_PIPE_LOCAL_INFORMATION
);
169 return STATUS_SUCCESS
;
174 NpfsQueryInformation(PDEVICE_OBJECT DeviceObject
,
177 PIO_STACK_LOCATION IoStack
;
178 FILE_INFORMATION_CLASS FileInformationClass
;
179 PFILE_OBJECT FileObject
;
180 PNPFS_DEVICE_EXTENSION DeviceExtension
;
187 DPRINT("NpfsQueryInformation(DeviceObject %p Irp %p)\n", DeviceObject
, Irp
);
189 IoStack
= IoGetCurrentIrpStackLocation (Irp
);
190 FileInformationClass
= IoStack
->Parameters
.QueryFile
.FileInformationClass
;
191 DeviceExtension
= DeviceObject
->DeviceExtension
;
192 FileObject
= IoStack
->FileObject
;
193 Ccb
= (PNPFS_CCB
)FileObject
->FsContext2
;
196 SystemBuffer
= Irp
->AssociatedIrp
.SystemBuffer
;
197 BufferLength
= IoStack
->Parameters
.QueryFile
.Length
;
199 DPRINT("Pipe name: %wZ\n", &Fcb
->PipeName
);
200 DPRINT("FileInformationClass %d\n", FileInformationClass
);
201 DPRINT("SystemBuffer %p\n", SystemBuffer
);
202 DPRINT("BufferLength %lu\n", BufferLength
);
204 switch (FileInformationClass
)
206 case FilePipeInformation
:
207 Status
= NpfsQueryPipeInformation(DeviceObject
,
213 case FilePipeLocalInformation
:
214 Status
= NpfsQueryLocalPipeInformation(DeviceObject
,
220 case FilePipeRemoteInformation
:
221 Status
= NpfsQueryPipeRemoteInformation(DeviceObject
,
228 Status
= STATUS_NOT_SUPPORTED
;
231 Irp
->IoStatus
.Status
= Status
;
232 if (NT_SUCCESS(Status
))
233 Irp
->IoStatus
.Information
=
234 IoStack
->Parameters
.QueryFile
.Length
- BufferLength
;
236 Irp
->IoStatus
.Information
= 0;
237 IoCompleteRequest (Irp
, IO_NO_INCREMENT
);
244 NpfsSetInformation(PDEVICE_OBJECT DeviceObject
,
247 PIO_STACK_LOCATION IoStack
;
248 FILE_INFORMATION_CLASS FileInformationClass
;
249 PFILE_OBJECT FileObject
;
256 DPRINT("NpfsSetInformation(DeviceObject %p Irp %p)\n", DeviceObject
, Irp
);
258 IoStack
= IoGetCurrentIrpStackLocation (Irp
);
259 FileInformationClass
= IoStack
->Parameters
.QueryFile
.FileInformationClass
;
260 FileObject
= IoStack
->FileObject
;
261 Ccb
= (PNPFS_CCB
)FileObject
->FsContext2
;
264 SystemBuffer
= Irp
->AssociatedIrp
.SystemBuffer
;
265 BufferLength
= IoStack
->Parameters
.QueryFile
.Length
;
267 DPRINT("Pipe name: %wZ\n", &Fcb
->PipeName
);
268 DPRINT("FileInformationClass %d\n", FileInformationClass
);
269 DPRINT("SystemBuffer %p\n", SystemBuffer
);
270 DPRINT("BufferLength %lu\n", BufferLength
);
272 switch (FileInformationClass
)
274 case FilePipeInformation
:
275 /* Call the handler */
276 Status
= NpfsSetPipeInformation(DeviceObject
,
282 case FilePipeLocalInformation
:
283 Status
= STATUS_NOT_IMPLEMENTED
;
286 case FilePipeRemoteInformation
:
287 /* Call the handler */
288 Status
= NpfsSetPipeRemoteInformation(DeviceObject
,
294 Status
= STATUS_NOT_SUPPORTED
;
297 Irp
->IoStatus
.Status
= Status
;
298 Irp
->IoStatus
.Information
= 0;
299 IoCompleteRequest(Irp
, IO_NO_INCREMENT
);