[gvg] 17899: Open handle to sfd.sys as asynchromous. This fixes bug 713.

Open handle to sfd.sys as asynchromous. This fixes bug 713.
Modified: trunk/reactos/lib/msafd/misc/dllmain.c
  _____  

Modified: trunk/reactos/lib/msafd/misc/dllmain.c
--- trunk/reactos/lib/msafd/misc/dllmain.c	2005-09-17 18:56:16 UTC
(rev 17898)
+++ trunk/reactos/lib/msafd/misc/dllmain.c	2005-09-17 19:30:05 UTC
(rev 17899)
@@ -65,7 +65,6 @@

 	PHELPER_DATA				HelperData;
 	PVOID
HelperDLLContext;
 	DWORD						HelperEvents;
-	DWORD						IOOptions = 0;
 	UNICODE_STRING				TransportName;
 	UNICODE_STRING				DevName;
 	LARGE_INTEGER				GroupData;
@@ -204,10 +203,10 @@
 								0, 
 								0);
 
-	/* Set IO Flag */
-    if ((dwFlags & WSA_FLAG_OVERLAPPED) == 0) IOOptions =
FILE_SYNCHRONOUS_IO_NONALERT;
-
-	/* Create the Socket */
+	/* Create the Socket as asynchronous. That means we have to
block
+	   ourselves after every call to NtDeviceIoControlFile. This is
+	   because the kernel doesn't support overlapping synchronous
I/O
+	   requests (made from multiple threads) at this time (Sep 2005)
*/
 	ZwCreateFile(&Sock,
 			GENERIC_READ | GENERIC_WRITE | SYNCHRONIZE,
 			&Object,
@@ -216,7 +215,7 @@
 			0,
 			FILE_SHARE_READ | FILE_SHARE_WRITE,
 			FILE_OPEN_IF,
-			IOOptions,
+			0,
 			EABuffer,
 			SizeOfEA);
 
@@ -510,6 +509,11 @@
 					0xA +
Socket->SharedData.SizeOfLocalAddress, /* Can't figure out a way to
calculate this in C*/
 					BindData,
 					0xA +
Socket->SharedData.SizeOfLocalAddress); /* Can't figure out a way to
calculate this C */
+        
+	/* Wait for return */
+	if (Status == STATUS_PENDING) {
+		WaitForSingleObject(SockEvent, INFINITE);
+	}         
 	
 	/* Set up Socket Data */
 	Socket->SharedData.State = SocketBound;
@@ -558,6 +562,11 @@
 					sizeof(ListenData),
 					NULL,
 					0);
+        
+	/* Wait for return */
+	if (Status == STATUS_PENDING) {
+		WaitForSingleObject(SockEvent, INFINITE);
+	}         
 
 	/* Set to Listening */
 	Socket->SharedData.Listening = TRUE;
@@ -827,6 +836,12 @@
 
sizeof(PendingAcceptData),
 
&PendingAcceptData,
 
sizeof(PendingAcceptData));
+        
+			/* Wait for return */
+			if (Status == STATUS_PENDING) {
+				WaitForSingleObject(SockEvent,
INFINITE);
+				Status = IOSB.Status;
+			}
 
 			if (!NT_SUCCESS(Status)) {
 				NtClose( SockEvent );
@@ -856,6 +871,12 @@
 
PendingData,
 
PendingDataLength);
 
+				/* Wait for return */
+				if (Status == STATUS_PENDING) {
+					WaitForSingleObject(SockEvent,
INFINITE);
+					Status = IOSB.Status;
+				}
+
 				if (!NT_SUCCESS(Status)) {
 					NtClose( SockEvent );
 					MsafdReturnWithErrno( Status,
lpErrno, 0, NULL );
@@ -942,6 +963,12 @@
 							NULL,
 							0);
 
+			/* Wait for return */
+			if (Status == STATUS_PENDING) {
+				WaitForSingleObject(SockEvent,
INFINITE);
+				Status = IOSB.Status;
+			}
+
 			NtClose( SockEvent );
 
 			if (!NT_SUCCESS(Status)) {
@@ -987,6 +1014,12 @@
 					sizeof(AcceptData),
 					NULL,
 					0);
+
+	/* Wait for return */
+	if (Status == STATUS_PENDING) {
+		WaitForSingleObject(SockEvent, INFINITE);
+		Status = IOSB.Status;
+	}
 	
 	if (!NT_SUCCESS(Status)) {
 		WSPCloseSocket( AcceptSocket, lpErrno );
@@ -1077,6 +1110,11 @@
 
ConnectDataLength,
 
NULL,
 
0);
+		/* Wait for return */
+		if (Status == STATUS_PENDING) {
+			WaitForSingleObject(SockEvent, INFINITE);
+			Status = IOSB.Status;
+		}
 	}
 
 	/* Dynamic Structure...ugh */
@@ -1113,6 +1151,12 @@
 
sizeof(InConnectDataLength),
 
NULL,
 
0);
+
+		/* Wait for return */
+		if (Status == STATUS_PENDING) {
+			WaitForSingleObject(SockEvent, INFINITE);
+			Status = IOSB.Status;
+		}
 	}
 
 	/* AFD doesn't seem to care if these are invalid, but let's 0
them anyways */
@@ -1136,6 +1180,11 @@
 
0x22,
 
NULL,
 
0);
+	/* Wait for return */
+	if (Status == STATUS_PENDING) {
+		WaitForSingleObject(SockEvent, INFINITE);
+		Status = IOSB.Status;
+	}
 
 	/* Get any pending connect data */
 	 if (lpCalleeData != NULL) {
@@ -1149,6 +1198,11 @@
 
0,
 
lpCalleeData->buf,
 
lpCalleeData->len);
+		/* Wait for return */
+		if (Status == STATUS_PENDING) {
+			WaitForSingleObject(SockEvent, INFINITE);
+			Status = IOSB.Status;
+		}
 	 }
 
     /* Re-enable Async Event */