blob: 686d058165ccc3369480b8e2a073430ed3dd8d71 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
|
/*++
Copyright (c) 1993 Microsoft Corporation
Module Name:
vwasync.c
Abstract:
ntVdm netWare (Vw) IPX/SPX Functions
Vw: The peoples' network
Contains Asyncrhonous Event Scheduler (thread)
Contents:
VwAesThread
(CheckPendingIpxRequests)
Author:
Richard L Firth (rfirth) 30-Sep-1993
Environment:
User-mode Win32
Revision History:
30-Sep-1993 rfirth
Created
--*/
#include "vw.h"
#pragma hdrstop
//
// private routine prototypes
//
PRIVATE
VOID
CheckPendingIpxRequests(
VOID
);
//
// global data
//
WORD AesTickCount;
//
// functions
//
DWORD
VwAesThread(
IN LPVOID Parameters
)
/*++
Routine Description:
Provides the functionality of the Asynchronous Event Scheduler (AES) in the
Netware world:
- updates the tick count
- completes any matured timer events
- checks any pending requests and schedules the next action
This thread wakes up every PC tick (1/18 second)
Arguments:
Parameters - unused
Return Value:
DWORD
0
--*/
{
BOOL fOperationPerformed = FALSE ;
static int n = 1 ;
UNREFERENCED_PARAMETER(Parameters);
while (TRUE)
{
//
// we will always yield in this loop to be friendly to others,
// but occasionally we will forcefully do a non zero sleep for
// lower priority threads to run.
//
if ((n % 100) == 0)
{
Sleep(ONE_TICK) ;
n = 1 ;
}
if (!fOperationPerformed && ((n % 4) == 0))
{
Sleep(10) ;
n++ ;
}
else
{
Sleep(0) ;
n++ ;
}
++AesTickCount;
ScanTimerList();
CheckPendingIpxRequests();
CheckPendingSpxRequests(&fOperationPerformed);
}
return 0; // compiler-pacifier
}
PRIVATE
VOID
CheckPendingIpxRequests(
VOID
)
/*++
Routine Description:
Polls the opened, active non-blocking IPX sockets to see if there is anything
to do (data to receive, availability to send, timeouts)
Arguments:
None.
Return Value:
None.
--*/
{
LPSOCKET_INFO pActiveSocket = NULL;
//
// search SOCKET_INFO structures for something to do. Could do select()
// but we have most of the info anyway. We use the BFI filter mechanism
//
while (pActiveSocket = FindActiveSocket(pActiveSocket)) {
if (pActiveSocket->Flags & SOCKET_FLAG_SENDING) {
IpxSendNext(pActiveSocket);
}
if (pActiveSocket->Flags & SOCKET_FLAG_LISTENING) {
IpxReceiveNext(pActiveSocket);
}
}
}
|
