[NPFS/KERNEL32]

[reactos.git] / reactos / drivers / filesystems / npfs / create.c

diff --git a/reactos/drivers/filesystems/npfs/create.c b/reactos/drivers/filesystems/npfs/create.c
index 7114b98..abdfe5e 100644 (file)
--- a/reactos/drivers/filesystems/npfs/create.c
+++ b/reactos/drivers/filesystems/npfs/create.c
@@ -13,6 +13,8 @@
 #define NDEBUG
 #include <debug.h>
 
+//#define USING_PROPER_NPFS_WAIT_SEMANTICS
+
 /* FUNCTIONS *****************************************************************/
 
 VOID
@@ -249,6 +251,10 @@ NpfsCreate(PDEVICE_OBJECT DeviceObject,
     PNPFS_CCB ServerCcb = NULL;
     PNPFS_VCB Vcb;
     NTSTATUS Status;
+#ifndef USING_PROPER_NPFS_WAIT_SEMANTICS
+    ACCESS_MASK DesiredAccess;
+    BOOLEAN SpecialAccess;
+#endif
 
     DPRINT("NpfsCreate(DeviceObject %p Irp %p)\n", DeviceObject, Irp);
 
@@ -257,12 +263,23 @@ NpfsCreate(PDEVICE_OBJECT DeviceObject,
     FileObject = IoStack->FileObject;
     RelatedFileObject = FileObject->RelatedFileObject;
     FileName = &FileObject->FileName;
+#ifndef USING_PROPER_NPFS_WAIT_SEMANTICS
+    DesiredAccess = IoStack->Parameters.CreatePipe.SecurityContext->DesiredAccess;
+#endif
 
     DPRINT("FileObject %p\n", FileObject);
     DPRINT("FileName %wZ\n", &FileObject->FileName);
 
     Irp->IoStatus.Information = 0;
 
+#ifndef USING_PROPER_NPFS_WAIT_SEMANTICS
+    SpecialAccess = ((DesiredAccess & SPECIFIC_RIGHTS_ALL) == FILE_READ_ATTRIBUTES);
+    if (SpecialAccess)
+    {
+        DPRINT("NpfsCreate() open client end for special use!\n");
+    }
+#endif
+
     DPRINT("FileName->Length: %hu  RelatedFileObject: %p\n", FileName->Length, RelatedFileObject);
 
     /* Open the file system */
@@ -336,7 +353,11 @@ NpfsCreate(PDEVICE_OBJECT DeviceObject,
     ClientCcb->FileObject = FileObject;
     ClientCcb->Thread = (struct ETHREAD *)Irp->Tail.Overlay.Thread;
     ClientCcb->PipeEnd = FILE_PIPE_CLIENT_END;
+#ifndef USING_PROPER_NPFS_WAIT_SEMANTICS
+    ClientCcb->PipeState = SpecialAccess ? 0 : FILE_PIPE_DISCONNECTED_STATE;
+#else
     ClientCcb->PipeState = FILE_PIPE_DISCONNECTED_STATE;
+#endif
     InitializeListHead(&ClientCcb->ReadRequestListHead);
 
     DPRINT("CCB: %p\n", ClientCcb);
@@ -377,62 +398,85 @@ NpfsCreate(PDEVICE_OBJECT DeviceObject,
     /*
     * Step 3. Search for listening server CCB.
     */
-    /*
-    * WARNING: Point of no return! Once we get the server CCB it's
-    * possible that we completed a wait request and so we have to
-    * complete even this request.
-    */
-
-    ServerCcb = NpfsFindListeningServerInstance(Fcb);
-    if (ServerCcb == NULL)
+#ifndef USING_PROPER_NPFS_WAIT_SEMANTICS
+    if (!SpecialAccess)
     {
-        PLIST_ENTRY CurrentEntry;
-        PNPFS_CCB Ccb;
-
+#endif
         /*
-        * If no waiting server CCB was found then try to pick
-        * one of the listing server CCB on the pipe.
+        * WARNING: Point of no return! Once we get the server CCB it's
+        * possible that we completed a wait request and so we have to
+        * complete even this request.
         */
 
-        CurrentEntry = Fcb->ServerCcbListHead.Flink;
-        while (CurrentEntry != &Fcb->ServerCcbListHead)
+        ServerCcb = NpfsFindListeningServerInstance(Fcb);
+        if (ServerCcb == NULL)
         {
-            Ccb = CONTAINING_RECORD(CurrentEntry, NPFS_CCB, CcbListEntry);
-            if (Ccb->PipeState == FILE_PIPE_LISTENING_STATE)
+            PLIST_ENTRY CurrentEntry;
+            PNPFS_CCB Ccb;
+
+            /*
+            * If no waiting server CCB was found then try to pick
+            * one of the listing server CCB on the pipe.
+            */
+
+            CurrentEntry = Fcb->ServerCcbListHead.Flink;
+            while (CurrentEntry != &Fcb->ServerCcbListHead)
             {
-                ServerCcb = Ccb;
-                break;
+                Ccb = CONTAINING_RECORD(CurrentEntry, NPFS_CCB, CcbListEntry);
+                if (Ccb->PipeState == FILE_PIPE_LISTENING_STATE)
+                {
+                    ServerCcb = Ccb;
+                    break;
+                }
+                CurrentEntry = CurrentEntry->Flink;
             }
-            CurrentEntry = CurrentEntry->Flink;
-        }
 
-        /*
-        * No one is listening to me?! I'm so lonely... :(
-        */
+            /*
+            * No one is listening to me?! I'm so lonely... :(
+            */
 
-        if (ServerCcb == NULL)
-        {
-            /* Not found, bail out with error for FILE_OPEN requests. */
-            DPRINT("No listening server CCB found!\n");
-            if (ClientCcb->Data)
+            if (ServerCcb == NULL)
             {
-                ExFreePoolWithTag(ClientCcb->Data, TAG_NPFS_CCB_DATA);
-            }
+                /* Not found, bail out with error for FILE_OPEN requests. */
+                DPRINT("No listening server CCB found!\n");
+                if (ClientCcb->Data)
+                {
+                    ExFreePoolWithTag(ClientCcb->Data, TAG_NPFS_CCB_DATA);
+                }
 
-            NpfsDereferenceCcb(ClientCcb);
-            KeUnlockMutex(&Fcb->CcbListLock);
-            NpfsDereferenceFcb(Fcb);
-            Irp->IoStatus.Status = STATUS_OBJECT_NAME_NOT_FOUND;
-            IoCompleteRequest(Irp, IO_NO_INCREMENT);
-            return STATUS_OBJECT_NAME_NOT_FOUND;
+                NpfsDereferenceCcb(ClientCcb);
+                KeUnlockMutex(&Fcb->CcbListLock);
+                NpfsDereferenceFcb(Fcb);
+                Irp->IoStatus.Status = STATUS_OBJECT_NAME_NOT_FOUND;
+                IoCompleteRequest(Irp, IO_NO_INCREMENT);
+                return STATUS_OBJECT_NAME_NOT_FOUND;
+            }
         }
+        else
+        {
+            /* Signal the server thread and remove it from the waiter list */
+            /* FIXME: Merge this with the NpfsFindListeningServerInstance routine. */
+            NpfsSignalAndRemoveListeningServerInstance(Fcb, ServerCcb);
+        }
+#ifndef USING_PROPER_NPFS_WAIT_SEMANTICS
     }
-    else
+    else if (IsListEmpty(&Fcb->ServerCcbListHead))
     {
-        /* Signal the server thread and remove it from the waiter list */
-        /* FIXME: Merge this with the NpfsFindListeningServerInstance routine. */
-        NpfsSignalAndRemoveListeningServerInstance(Fcb, ServerCcb);
+        DPRINT("No server fcb found!\n");
+
+        if (ClientCcb->Data)
+        {
+            ExFreePoolWithTag(ClientCcb->Data, TAG_NPFS_CCB_DATA);
+        }
+
+        NpfsDereferenceCcb(ClientCcb);
+        KeUnlockMutex(&Fcb->CcbListLock);
+        NpfsDereferenceFcb(Fcb);
+        Irp->IoStatus.Status = STATUS_UNSUCCESSFUL;
+        IoCompleteRequest(Irp, IO_NO_INCREMENT);
+        return STATUS_UNSUCCESSFUL;
     }
+#endif
 
     /*
     * Step 4. Add the client CCB to a list and connect it if possible.