source: trunk/include/overlappedio.h@ 8082

Last change on this file since 8082 was 7631, checked in by sandervl, 24 years ago

enabled overlapped io for custom device drivers
File size: 4.6 KB
RevLine 
[7631]1/* $Id: overlappedio.h,v 1.1 2001-12-14 12:45:49 sandervl Exp $ */
2
3/*
4 * Win32 overlapped IO class
5 *
6 * Copyright 2001 Sander van Leeuwen <sandervl@xs4all.nl>
7 *
8 * Project Odin Software License can be found in LICENSE.TXT
9 *
10 */
11
12#ifndef __OVERLAPPEDIO_H__
13#define __OVERLAPPEDIO_H__
14
15#define NR_ASYNC_OPERATIONS 4
16#define ASYNC_INDEX_READ 0
17#define ASYNC_INDEX_WRITE 1
18#define ASYNC_INDEX_POLL 2
19#define ASYNC_INDEX_BUSY 3
20
21#define ASYNC_TYPE_HALFDUPLEX 0
22#define ASYNC_TYPE_FULLDUPLEX 1
23
24#define ASYNCIO_READ 1
25#define ASYNCIO_WRITE 2
26#define ASYNCIO_READWRITE 4
27#define ASYNCIO_POLL 8
28
29//forward decl
30class OverlappedIOHandler;
31
32typedef struct {
33 DWORD dwOperation;
34 OverlappedIOHandler *lpOverlappedObj;
35} OVERLAPPED_THREAD_PARAM, *LPOVERLAPPED_THREAD_PARAM;
36
37
38class ASYNCIOREQUEST
39{
40public:
41 ASYNCIOREQUEST()
42 {
43 memset(this, 0, sizeof(ASYNCIOREQUEST));
44 };
45
46 DWORD dwAsyncType;
47 HANDLE hHandle;
48 LPCVOID lpBuffer;
49 DWORD nNumberOfBytes;
50 DWORD dwTimeOut;
51 LPOVERLAPPED lpOverlapped;
52 LPOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine;
53 DWORD *lpdwResult;
54 DWORD dwLastError;
55 DWORD dwEventMask;
56 DWORD dwUserData;
57 BOOL fCancelled;
58 ASYNCIOREQUEST *next;
59};
60
61typedef ASYNCIOREQUEST *LPASYNCIOREQUEST;
62
63typedef DWORD (* LPOVERLAPPED_HANDLER)(LPASYNCIOREQUEST lpRequest, DWORD *lpdwResult, DWORD *lpdwTimeOut);
64
65enum OverlappedIOError {
66 InvalidParameter, OutOfMemory, EventCreationFailed, ThreadCreationFailed
67};
68
69class OverlappedIOHandler
70{
71public:
72 OverlappedIOHandler(LPOVERLAPPED_HANDLER lpReadHandler,
73 LPOVERLAPPED_HANDLER lpWriteHandler,
74 LPOVERLAPPED_HANDLER lpPollHandler = NULL,
75 BOOL fFullDuplex = ASYNC_TYPE_HALFDUPLEX);
76 ~OverlappedIOHandler();
77
78 BOOL WriteFile(HANDLE hHandle,
79 LPCVOID lpBuffer,
80 DWORD nNumberOfBytesToWrite,
81 LPDWORD lpNumberOfBytesWritten,
82 LPOVERLAPPED lpOverlapped,
83 LPOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine,
84 DWORD dwUserData,
85 DWORD dwTimeOut = INFINITE);
86
87 BOOL ReadFile(HANDLE hHandle,
88 LPCVOID lpBuffer,
89 DWORD nNumberOfBytesToRead,
90 LPDWORD lpNumberOfBytesRead,
91 LPOVERLAPPED lpOverlapped,
92 LPOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine,
93 DWORD dwUserData,
94 DWORD dwTimeOut = INFINITE);
95
96 BOOL WaitForEvent(HANDLE hHandle,
97 DWORD dwEventMask,
98 LPDWORD lpfdwEvtMask,
99 LPOVERLAPPED lpOverlapped,
100 LPOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine,
101 DWORD dwUserData,
102 DWORD dwTimeOut = INFINITE);
103
104 BOOL CancelIo(HANDLE hHandle);
105
106 BOOL GetOverlappedResult(HANDLE hHandle,
107 LPOVERLAPPED lpoOverlapped,
108 LPDWORD lpcbTransfer,
109 BOOL fWait);
110
111protected:
112
113private:
114 LPASYNCIOREQUEST findAndRemoveRequest(int index, HANDLE hHandle);
115
116 DWORD threadHandler(DWORD fEvent);
117
118 HANDLE hThreadPoll;
119 HANDLE hThreadRead;
120 HANDLE hThreadWrite;
121 HANDLE hEventExit;
122 HANDLE hEventCancel;
123 HANDLE hEventPoll;
124 HANDLE hEventRead;
125 HANDLE hEventWrite;
126
127 LPOVERLAPPED_HANDLER lpReadHandler;
128 LPOVERLAPPED_HANDLER lpWriteHandler;
129 LPOVERLAPPED_HANDLER lpPollHandler;
130
131 CRITICAL_SECTION critsect;
132
133 DWORD dwAsyncType;
134 BOOL fFullDuplex;
135 //[ASYNC_INDEX_READ] list of pending read (+ write if half-duplex mode) operations
136 //[ASYNC_INDEX_WRITE] list of pending write (full-duplex mode) operations
137 //[ASYNC_INDEX_POLL] list of pending poll operations
138 //[ASYNC_INDEX_BUSY] list of operations that are being handled
139 LPASYNCIOREQUEST pending[NR_ASYNC_OPERATIONS];
140
141 friend DWORD CALLBACK OverlappedIOThread(LPVOID lpThreadParam);
142};
143
144
145#endif // __OVERLAPPEDIO_H__
Note: See TracBrowser for help on using the repository browser.