ReactOS  0.4.13-dev-92-gf251225
dispatch.c
Go to the documentation of this file.
1 /*
2  * ReactOS kernel
3  * Copyright (C) 2008 ReactOS Team
4  *
5  * This program is free software; you can redistribute it and/or modify
6  * it under the terms of the GNU General Public License as published by
7  * the Free Software Foundation; either version 2 of the License, or
8  * (at your option) any later version.
9  *
10  * This program is distributed in the hope that it will be useful,
11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13  * GNU General Public License for more details.
14  *
15  * You should have received a copy of the GNU General Public License
16  * along with this program; if not, write to the Free Software
17  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA.
18  *
19  * COPYRIGHT: See COPYING in the top level directory
20  * PROJECT: ReactOS kernel
21  * FILE: drivers/filesystem/ntfs/dispatch.c
22  * PURPOSE: NTFS filesystem driver
23  * PROGRAMMER: Pierre Schweitzer
24  * UPDATE HISTORY:
25  */
26 
27 /* INCLUDES *****************************************************************/
28 
29 #include "ntfs.h"
30 
31 #define NDEBUG
32 #include <debug.h>
33 
34 static LONG QueueCount = 0;
35 
36 /* FUNCTIONS ****************************************************************/
37 
38 static WORKER_THREAD_ROUTINE NtfsDoRequest;
39 
40 static
43 {
45  DPRINT("NtfsQueueRequest(IrpContext %p), %d\n", IrpContext, QueueCount);
46 
47  ASSERT(!(IrpContext->Flags & IRPCONTEXT_QUEUE) &&
48  (IrpContext->Flags & IRPCONTEXT_COMPLETE));
49  IrpContext->Flags |= IRPCONTEXT_CANWAIT;
50  IoMarkIrpPending(IrpContext->Irp);
51  ExInitializeWorkItem(&IrpContext->WorkQueueItem, NtfsDoRequest, IrpContext);
53 
54  return STATUS_PENDING;
55 }
56 
57 static
60 {
61  PIRP Irp = IrpContext->Irp;
63 
64  TRACE_(NTFS, "NtfsDispatch()\n");
65 
67 
69 
70  switch (IrpContext->MajorFunction)
71  {
73  Status = NtfsQueryVolumeInformation(IrpContext);
74  break;
75 
77  Status = NtfsSetVolumeInformation(IrpContext);
78  break;
79 
81  Status = NtfsQueryInformation(IrpContext);
82  break;
83 
86  {
87  DPRINT1("NTFS write-support is EXPERIMENTAL and is disabled by default!\n");
89  }
90  else
91  {
92  Status = NtfsSetInformation(IrpContext);
93  }
94  break;
95 
97  Status = NtfsDirectoryControl(IrpContext);
98  break;
99 
100  case IRP_MJ_READ:
101  Status = NtfsRead(IrpContext);
102  break;
103 
105  Status = NtfsDeviceControl(IrpContext);
106  break;
107 
108  case IRP_MJ_WRITE:
110  {
111  DPRINT1("NTFS write-support is EXPERIMENTAL and is disabled by default!\n");
113  }
114  else
115  {
116  Status = NtfsWrite(IrpContext);
117  }
118  break;
119 
120  case IRP_MJ_CLOSE:
121  Status = NtfsClose(IrpContext);
122  break;
123 
124  case IRP_MJ_CLEANUP:
125  Status = NtfsCleanup(IrpContext);
126  break;
127 
128  case IRP_MJ_CREATE:
129  Status = NtfsCreate(IrpContext);
130  break;
131 
133  Status = NtfsFileSystemControl(IrpContext);
134  break;
135  }
136 
137  ASSERT((!(IrpContext->Flags & IRPCONTEXT_COMPLETE) && !(IrpContext->Flags & IRPCONTEXT_QUEUE)) ||
138  ((IrpContext->Flags & IRPCONTEXT_COMPLETE) && !(IrpContext->Flags & IRPCONTEXT_QUEUE)) ||
139  (!(IrpContext->Flags & IRPCONTEXT_COMPLETE) && (IrpContext->Flags & IRPCONTEXT_QUEUE)));
140 
141  if (IrpContext->Flags & IRPCONTEXT_COMPLETE)
142  {
143  Irp->IoStatus.Status = Status;
144  IoCompleteRequest(Irp, IrpContext->PriorityBoost);
145  }
146 
147  if (IrpContext->Flags & IRPCONTEXT_QUEUE)
148  {
149  /* Reset our status flags before queueing the IRP */
150  IrpContext->Flags |= IRPCONTEXT_COMPLETE;
151  IrpContext->Flags &= ~IRPCONTEXT_QUEUE;
152  Status = NtfsQueueRequest(IrpContext);
153  }
154  else
155  {
156  ExFreeToNPagedLookasideList(&NtfsGlobalData->IrpContextLookasideList, IrpContext);
157  }
158 
161 
162  return Status;
163 }
164 
165 static
166 VOID
167 NTAPI
168 NtfsDoRequest(PVOID IrpContext)
169 {
171  DPRINT("NtfsDoRequest(IrpContext %p), MajorFunction %x, %d\n",
172  IrpContext, ((PNTFS_IRP_CONTEXT)IrpContext)->MajorFunction, QueueCount);
173  NtfsDispatch((PNTFS_IRP_CONTEXT)IrpContext);
174 }
175 
176 /*
177  * FUNCTION: This function manages IRP for various major functions
178  * ARGUMENTS:
179  * DriverObject = object describing this driver
180  * Irp = IRP to be passed to internal functions
181  * RETURNS: Status of I/O Request
182  */
183 NTSTATUS
184 NTAPI
186  PIRP Irp)
187 {
188  PNTFS_IRP_CONTEXT IrpContext = NULL;
190 
191  TRACE_(NTFS, "NtfsFsdDispatch()\n");
192 
193  IrpContext = NtfsAllocateIrpContext(DeviceObject, Irp);
194  if (IrpContext == NULL)
195  {
197  Irp->IoStatus.Status = Status;
199  }
200  else
201  {
202  Status = NtfsDispatch(IrpContext);
203  }
204 
205  return Status;
206 }
#define IRP_MJ_CREATE
Definition: rdpdr.c:44
VOID NTAPI ExQueueWorkItem(IN PWORK_QUEUE_ITEM WorkItem, IN WORK_QUEUE_TYPE QueueType)
Definition: work.c:717
#define STATUS_INSUFFICIENT_RESOURCES
Definition: udferr_usr.h:158
#define FsRtlEnterFileSystem
#define FsRtlExitFileSystem
#define IRPCONTEXT_COMPLETE
Definition: vfat.h:570
_In_ PIRP Irp
Definition: csq.h:116
static LONG QueueCount
Definition: dispatch.c:34
LONG NTSTATUS
Definition: precomp.h:26
#define IRP_MJ_SET_VOLUME_INFORMATION
BOOLEAN NtfsIsIrpTopLevel(PIRP Irp)
Definition: misc.c:43
WORK_QUEUE_ITEM WorkQueueItem
Definition: ntfs.h:470
PNTFS_GLOBAL_DATA NtfsGlobalData
Definition: ntfs.c:41
static NTSTATUS NtfsQueueRequest(PNTFS_IRP_CONTEXT IrpContext)
Definition: dispatch.c:42
ARC_STATUS NtfsRead(ULONG FileId, VOID *Buffer, ULONG N, ULONG *Count)
Definition: ntfs.c:828
static NTSTATUS NtfsDispatch(PNTFS_IRP_CONTEXT IrpContext)
Definition: dispatch.c:59
NTSTATUS(* NTAPI)(IN PFILE_FULL_EA_INFORMATION EaBuffer, IN ULONG EaLength, OUT PULONG ErrorOffset)
Definition: IoEaTest.cpp:117
PNTFS_IRP_CONTEXT NtfsAllocateIrpContext(PDEVICE_OBJECT DeviceObject, PIRP Irp)
Definition: misc.c:66
long LONG
Definition: pedump.c:60
ARC_STATUS NtfsClose(ULONG FileId)
Definition: ntfs.c:755
#define IRPCONTEXT_QUEUE
Definition: vfat.h:571
smooth NULL
Definition: ftsmooth.c:416
#define IRPCONTEXT_CANWAIT
Definition: vfat.h:569
#define IoCompleteRequest
Definition: irp.c:1240
void DPRINT(...)
Definition: polytest.cpp:61
#define IRP_MJ_QUERY_VOLUME_INFORMATION
Definition: rdpdr.c:50
static WORKER_THREAD_ROUTINE NtfsDoRequest
Definition: dispatch.c:38
#define IRP_MJ_DIRECTORY_CONTROL
Definition: rdpdr.c:51
#define TRACE_(x)
Definition: compat.h:66
#define ExInitializeWorkItem(Item, Routine, Context)
Definition: exfuncs.h:265
#define STATUS_PENDING
Definition: ntstatus.h:82
#define IRP_MJ_FILE_SYSTEM_CONTROL
UCHAR MajorFunction
Definition: ntfs.h:468
#define STATUS_ACCESS_DENIED
Definition: udferr_usr.h:145
ASSERT((InvokeOnSuccess||InvokeOnError||InvokeOnCancel) ?(CompletionRoutine !=NULL) :TRUE)
NTSTATUS NtfsCleanup(PNTFS_IRP_CONTEXT IrpContext)
Definition: cleanup.c:89
#define STATUS_UNSUCCESSFUL
Definition: udferr_usr.h:132
#define IRP_MJ_CLOSE
Definition: rdpdr.c:45
VOID NTAPI IoSetTopLevelIrp(IN PIRP Irp)
Definition: irp.c:2000
#define InterlockedDecrement
Definition: armddk.h:52
ULONG Flags
Definition: ntfs.h:466
NTSTATUS NtfsQueryInformation(PNTFS_IRP_CONTEXT IrpContext)
Definition: finfo.c:418
NTSTATUS NtfsDirectoryControl(PNTFS_IRP_CONTEXT IrpContext)
Definition: dirctl.c:590
Status
Definition: gdiplustypes.h:24
IN PDEVICE_OBJECT DeviceObject
Definition: fatprocs.h:1560
NTSTATUS NtfsFileSystemControl(PNTFS_IRP_CONTEXT IrpContext)
Definition: fsctl.c:963
#define InterlockedIncrement
Definition: armddk.h:53
NPAGED_LOOKASIDE_LIST IrpContextLookasideList
Definition: ntfs.h:152
NTSTATUS NTAPI NtfsFsdDispatch(PDEVICE_OBJECT DeviceObject, PIRP Irp)
Definition: dispatch.c:185
NTSTATUS NtfsCreate(PNTFS_IRP_CONTEXT IrpContext)
Definition: create.c:622
#define DPRINT1
Definition: precomp.h:8
#define IRP_MJ_READ
Definition: rdpdr.c:46
#define IRP_MJ_CLEANUP
#define IRP_MJ_SET_INFORMATION
Definition: rdpdr.c:49
#define IO_NO_INCREMENT
Definition: iotypes.h:565
CCHAR PriorityBoost
Definition: ntfs.h:476
#define IRP_MJ_WRITE
Definition: rdpdr.c:47
#define IRP_MJ_QUERY_INFORMATION
Definition: rdpdr.c:48
NTSTATUS NtfsSetInformation(PNTFS_IRP_CONTEXT IrpContext)
Definition: finfo.c:717
IoMarkIrpPending(Irp)
BOOLEAN EnableWriteSupport
Definition: ntfs.h:155
NTSTATUS NtfsQueryVolumeInformation(PNTFS_IRP_CONTEXT IrpContext)
Definition: volinfo.c:343
NTSTATUS NtfsSetVolumeInformation(PNTFS_IRP_CONTEXT IrpContext)
Definition: volinfo.c:420
NTSTATUS NtfsWrite(PNTFS_IRP_CONTEXT IrpContext)
Definition: rw.c:530
#define IRP_MJ_DEVICE_CONTROL
Definition: rdpdr.c:52
NTSTATUS NtfsDeviceControl(PNTFS_IRP_CONTEXT IrpContext)
Definition: devctl.c:36