Changeset 7551 for trunk/src

Timestamp:

Dec 5, 2001, 7:06:57 PM (24 years ago)

Author:

sandervl

Message:

overlapped io updates

Location:

trunk/src/kernel32

Files:

• overlappedio.cpp (modified) (2 diffs)
• overlappedio.h (modified) (5 diffs)

trunk/src/kernel32/overlappedio.cpp

@@ -1 @@
-/* $Id: overlappedio.cpp,v 1.2 2001-12-05 18:06:02 sandervl Exp $ */
+/* $Id: overlappedio.cpp,v 1.3 2001-12-05 18:06:57 sandervl Exp $ */
 
 /*
@@ -86 +86 @@
     //fall through
 failed:
-    //SvL: NOTE: We might not failed gracefully when threads have already been 
+    //SvL: NOTE: We might not fail gracefully when threads have already been 
     //           created. (thread accessing memory that has been freed)
     //           Don't feel like wasting time to fix this as this should never

trunk/src/kernel32/overlappedio.h

@@ -1 @@
-/* $Id: overlappedio.h,v 1.1 2001-12-05 14:16:38 sandervl Exp $ */
+/* $Id: overlappedio.h,v 1.2 2001-12-05 18:06:03 sandervl Exp $ */
 
 /*
@@ -13 +13 @@
 #define __OVERLAPPEDIO_H__
 
+#define EVENT_READ              1
+#define EVENT_WRITE             2
+#define EVENT_READWRITE         (EVENT_WRITE|EVENT_READ)
+#define EVENT_POLL              4
+
+//forward decl
+class OverlappedIOHandler;
+
+typedef struct {
+    DWORD                fEvent;
+    OverlappedIOHandler *lpOverlappedObj;
+} OVERLAPPED_THREAD_PARAM, *LPOVERLAPPED_THREAD_PARAM;
+
+typedef DWORD (* SYSTEM LPOVERLAPPED_HANDLER)(DWORD dwUserData, LPOVERLAPPED lpOverlapped);
+
+enum OverlappedIOError {
+  OutOfMemory, EventCreationFailed, ThreadCreationFailed
+};
 
 class OverlappedIOHandler
 {
 public:
-     OverlappedIOHandler(
+     OverlappedIOHandler(LPOVERLAPPED_HANDLER lpReadHandler, 
+                         LPOVERLAPPED_HANDLER lpWriteHandler, 
+                         LPOVERLAPPED_HANDLER lpPollHandler = NULL);
+    ~OverlappedIOHandler();
 
      BOOL   WriteFile(HANDLE        hOS2Handle,
@@ -38 +59 @@
                                 LPOVERLAPPED  lpoOverlapped,
                                 LPDWORD       lpcbTransfer,
-                                DWORD         dwTimeout)
+                                DWORD         dwTimeout);
 
 protected:
@@ -44 +65 @@
 private:
 
-     HANDLE       hThreadEvent;
+     DWORD        threadHandler(DWORD fEvent);
+
+     HANDLE       hThreadPoll;
      HANDLE       hThreadRead;
      HANDLE       hThreadWrite;
@@ -52 +75 @@
      HANDLE       hEventWrite;
 
+     LPOVERLAPPED_HANDLER lpReadHandler;
+     LPOVERLAPPED_HANDLER lpWriteHandler;
+     LPOVERLAPPED_HANDLER lpPollHandler;
+
+     CRITICAL_SECTION     critsect;
+
      //linked list of pending operations
      LPOVERLAPPED pending;
 
+
+     friend       DWORD CALLBACK OverlappedIOThread(LPVOID lpThreadParam);
 };