Changeset 7598 for trunk/src/kernel32/overlappedio.cpp

Timestamp:

Dec 9, 2001, 10:55:17 PM (24 years ago)

Author:

sandervl

Message:

added half or full duplex support

File:

• trunk/src/kernel32/overlappedio.cpp (modified) (9 diffs)

trunk/src/kernel32/overlappedio.cpp

@@ -1 @@
-/* $Id: overlappedio.cpp,v 1.8 2001-12-09 21:19:28 sandervl Exp $ */
+/* $Id: overlappedio.cpp,v 1.9 2001-12-09 21:55:17 sandervl Exp $ */
 
 /*
@@ -27 +27 @@
 OverlappedIOHandler::OverlappedIOHandler(LPOVERLAPPED_HANDLER lpReadHandler,
                                          LPOVERLAPPED_HANDLER lpWriteHandler,
-                                         LPOVERLAPPED_HANDLER lpPollHandler) :
+                                         LPOVERLAPPED_HANDLER lpPollHandler,
+                                         BOOL fFullDuplex) :
                    hThreadRead(0), hThreadWrite(0), hThreadPoll(0)
 {
     OverlappedIOError errcode = OutOfMemory;
+
+    this->fFullDuplex = fFullDuplex;
 
     if(lpReadHandler == NULL || lpPollHandler == NULL) {
@@ -49 +52 @@
     hEventRead   = ::CreateEventA(NULL, FALSE, FALSE, NULL);
     hEventWrite  = ::CreateEventA(NULL, FALSE, FALSE, NULL);
+
+    dprintf(("OverlappedIOThread: hEventRead %x hEventWrite %x hEventPoll %x", hEventRead, hEventWrite, hEventPoll));
 
     //the exit event semaphore is manual reset, because this event
@@ -63 +68 @@
     LPOVERLAPPED_THREAD_PARAM threadparam;
 
-    dwAsyncType = (lpWriteHandler) ? ASYNCIO_READ : ASYNCIO_READWRITE;
+    dwAsyncType = (lpWriteHandler && fFullDuplex) ? ASYNCIO_READ : ASYNCIO_READWRITE;
     threadparam = (LPOVERLAPPED_THREAD_PARAM)malloc(sizeof(OVERLAPPED_THREAD_PARAM));
     if(!threadparam) goto outofmem;
@@ -70 +75 @@
     hThreadRead  = ::CreateThread(NULL, 32*1024, OverlappedIOThread, (LPVOID)threadparam, 0, &dwThreadId);
 
-    if(lpWriteHandler) {
+    if(lpWriteHandler && fFullDuplex) {
         dwAsyncType |= ASYNCIO_WRITE;
 
@@ -90 +95 @@
     }
 
-    if((lpPollHandler && !hThreadPoll) || !hThreadRead || (lpWriteHandler && !hThreadWrite))
+    if((lpPollHandler && !hThreadPoll) || !hThreadRead || (lpWriteHandler && fFullDuplex && !hThreadWrite))
     {
         DebugInt3();
@@ -226 +231 @@
         case ASYNCIO_READ:
         case ASYNCIO_READWRITE:
-            lpRequest->dwLastError = lpReadHandler(lpRequest, &dwResult, NULL);
+            if(lpRequest->dwAsyncType == ASYNCIO_READ || lpWriteHandler == NULL) {
+                 lpRequest->dwLastError = lpReadHandler(lpRequest, &dwResult, NULL);
+            }
+            else lpRequest->dwLastError = lpWriteHandler(lpRequest, &dwResult, NULL);
+
             lpOverlapped->Internal     = lpRequest->dwLastError;
             lpOverlapped->InternalHigh = dwResult;
@@ -331 +340 @@
     lpRequest->next                = NULL;
 
-    if(dwAsyncType == ASYNCIO_READWRITE) {
+    if(dwAsyncType & ASYNCIO_READWRITE) {
          index = ASYNC_INDEX_READ;
     }
@@ -355 +364 @@
 
     //wake up async thread
-    ::SetEvent((dwAsyncType == ASYNCIO_READWRITE) ? hEventRead : hEventWrite);
+    ::SetEvent((dwAsyncType & ASYNCIO_READWRITE) ? hEventRead : hEventWrite);
 
     ::SetLastError(ERROR_IO_PENDING);