Changeset 7567 for trunk/src/kernel32/overlappedio.h

Timestamp:

Dec 7, 2001, 3:13:39 PM (24 years ago)

Author:

sandervl

Message:

overlapped io, com, thread & process updates

File:

• trunk/src/kernel32/overlappedio.h (modified) (5 diffs)

trunk/src/kernel32/overlappedio.h

@@ -1 @@
-/* $Id: overlappedio.h,v 1.5 2001-12-07 11:28:11 sandervl Exp $ */
+/* $Id: overlappedio.h,v 1.6 2001-12-07 14:13:38 sandervl Exp $ */
 
 /*
@@ -13 +13 @@
 #define __OVERLAPPEDIO_H__
 
-#define NR_ASYNC_OPERATIONS 3
+#define NR_ASYNC_OPERATIONS     4
 #define ASYNC_INDEX_READ        0
 #define ASYNC_INDEX_WRITE       1
 #define ASYNC_INDEX_POLL        2
+#define ASYNC_INDEX_BUSY        3
 
 #define ASYNCIO_READ        1
@@ -31 +32 @@
 } OVERLAPPED_THREAD_PARAM, *LPOVERLAPPED_THREAD_PARAM;
 
-typedef struct tagOVERLAPPED_ODIN{
-  DWORD               dwAsyncType;
-  HANDLE              hHandle;
-  LPCVOID             lpBuffer;
-  DWORD               nNumberOfBytes;
-  DWORD               dwTimeOut;
-  LPOVERLAPPED        lpOverlapped;
-  LPOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine;
-  DWORD              *lpdwResult;
-  DWORD               dwLastError;
-  DWORD               dwUserData;
-  tagOVERLAPPED_ODIN *next;
-} ASYNCIOREQUEST, *LPASYNCIOREQUEST;
 
-typedef BOOL (* LPOVERLAPPED_HANDLER)(LPASYNCIOREQUEST lpRequest, DWORD *lpdwResult, DWORD *lpdwTimeOut);
+class ASYNCIOREQUEST
+{
+public:
+    ASYNCIOREQUEST()
+    {
+        memset(this, 0, sizeof(ASYNCIOREQUEST));
+        hEventCancel = ::CreateEventA(NULL, TRUE, FALSE, NULL);
+        if(hEventCancel == 0) DebugInt3();
+    };
+
+    ~ASYNCIOREQUEST()
+    {
+        ::CloseHandle(hEventCancel);
+    };
+
+    DWORD               dwAsyncType;
+    HANDLE              hHandle;
+    LPCVOID             lpBuffer;
+    DWORD               nNumberOfBytes;
+    DWORD               dwTimeOut;
+    LPOVERLAPPED        lpOverlapped;
+    LPOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine;
+    DWORD              *lpdwResult;
+    DWORD               dwLastError;
+    DWORD               dwEventMask;
+    DWORD               dwUserData;
+    HANDLE              hEventCancel;
+    ASYNCIOREQUEST     *next;
+};
+
+typedef ASYNCIOREQUEST *LPASYNCIOREQUEST;
+
+typedef DWORD (* LPOVERLAPPED_HANDLER)(LPASYNCIOREQUEST lpRequest, DWORD *lpdwResult, DWORD *lpdwTimeOut);
 
 enum OverlappedIOError {
@@ -78 +98 @@
 
      BOOL   WaitForEvent(HANDLE        hHandle,
+                         DWORD         dwEventMask,
                          LPDWORD       lpfdwEvtMask,
                          LPOVERLAPPED  lpOverlapped,
@@ -116 +137 @@
      //[ASYNC_INDEX_WRITE] list of pending write (full-duplex mode) operations
      //[ASYNC_INDEX_POLL]  list of pending poll operations
+     //[ASYNC_INDEX_BUSY]  list of operations that are being handled
      LPASYNCIOREQUEST     pending[NR_ASYNC_OPERATIONS];