File: | pr/Linux4.19_x86_64_gcc_glibc_PTH_64_DBG.OBJ/pr/tests/../../../pr/tests/provider.c |
Warning: | line 806, column 5 Access to field 'thread' results in a dereference of a null pointer (loaded from variable 'worker') |
Press '?' to see keyboard shortcuts
Keyboard shortcuts:
1 | /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ | |||
2 | /* This Source Code Form is subject to the terms of the Mozilla Public | |||
3 | * License, v. 2.0. If a copy of the MPL was not distributed with this | |||
4 | * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ | |||
5 | ||||
6 | /* | |||
7 | * | |||
8 | * Notes: | |||
9 | * [1] lth. The call to Sleep() is a hack to get the test case to run | |||
10 | * on Windows 95. Without it, the test case fails with an error | |||
11 | * WSAECONNRESET following a recv() call. The error is caused by the | |||
12 | * server side thread termination without a shutdown() or closesocket() | |||
13 | * call. Windows docmunentation suggests that this is predicted | |||
14 | * behavior; that other platforms get away with it is ... serindipity. | |||
15 | * The test case should shutdown() or closesocket() before | |||
16 | * thread termination. I didn't have time to figure out where or how | |||
17 | * to do it. The Sleep() call inserts enough delay to allow the | |||
18 | * client side to recv() all his data before the server side thread | |||
19 | * terminates. Whew! ... | |||
20 | * | |||
21 | ** Modification History: | |||
22 | * 14-May-97 AGarcia- Converted the test to accomodate the debug_mode flag. | |||
23 | * The debug mode will print all of the printfs associated with this test. | |||
24 | * The regress mode will be the default mode. Since the regress tool limits | |||
25 | * the output to a one line status:PASS or FAIL,all of the printf statements | |||
26 | * have been handled with an if (debug_mode) statement. | |||
27 | */ | |||
28 | ||||
29 | #include "prclist.h" | |||
30 | #include "prcvar.h" | |||
31 | #include "prerror.h" | |||
32 | #include "prinit.h" | |||
33 | #include "prinrval.h" | |||
34 | #include "prio.h" | |||
35 | #include "prlock.h" | |||
36 | #include "prlog.h" | |||
37 | #include "prtime.h" | |||
38 | #include "prmem.h" | |||
39 | #include "prnetdb.h" | |||
40 | #include "prprf.h" | |||
41 | #include "prthread.h" | |||
42 | ||||
43 | #include "pprio.h" | |||
44 | #include "primpl.h" | |||
45 | ||||
46 | #include "plstr.h" | |||
47 | #include "plerror.h" | |||
48 | #include "plgetopt.h" | |||
49 | ||||
50 | #include <stdlib.h> | |||
51 | #include <string.h> | |||
52 | ||||
53 | #if defined(XP_UNIX1) | |||
54 | #include <math.h> | |||
55 | #endif | |||
56 | ||||
57 | /* | |||
58 | ** This is the beginning of the test | |||
59 | */ | |||
60 | ||||
61 | #ifdef DEBUG1 | |||
62 | #define PORT_INC_DO+100 +100 | |||
63 | #else | |||
64 | #define PORT_INC_DO+100 | |||
65 | #endif | |||
66 | #ifdef IS_64 | |||
67 | #define PORT_INC_3264+200 +200 | |||
68 | #else | |||
69 | #define PORT_INC_3264+200 | |||
70 | #endif | |||
71 | ||||
72 | #define RECV_FLAGS0 0 | |||
73 | #define SEND_FLAGS0 0 | |||
74 | #define BUFFER_SIZE1024 1024 | |||
75 | #define DEFAULT_BACKLOG5 5 | |||
76 | #define DEFAULT_PORT13000 +100 +200 13000 PORT_INC_DO+100 PORT_INC_3264+200 | |||
77 | #define DEFAULT_CLIENTS1 1 | |||
78 | #define ALLOWED_IN_ACCEPT1 1 | |||
79 | #define DEFAULT_CLIPPING1000 1000 | |||
80 | #define DEFAULT_WORKERS_MIN1 1 | |||
81 | #define DEFAULT_WORKERS_MAX1 1 | |||
82 | #define DEFAULT_SERVER"localhost" "localhost" | |||
83 | #define DEFAULT_EXECUTION_TIME10 10 | |||
84 | #define DEFAULT_CLIENT_TIMEOUT4000 4000 | |||
85 | #define DEFAULT_SERVER_TIMEOUT4000 4000 | |||
86 | #define DEFAULT_SERVER_PRIORITYPR_PRIORITY_HIGH PR_PRIORITY_HIGH | |||
87 | ||||
88 | typedef enum CSState_e {cs_init, cs_run, cs_stop, cs_exit} CSState_t; | |||
89 | ||||
90 | static void PR_CALLBACK Worker(void *arg); | |||
91 | typedef struct CSPool_s CSPool_t; | |||
92 | typedef struct CSWorker_s CSWorker_t; | |||
93 | typedef struct CSServer_s CSServer_t; | |||
94 | typedef enum Verbosity | |||
95 | { | |||
96 | TEST_LOG_ALWAYS, | |||
97 | TEST_LOG_ERROR, | |||
98 | TEST_LOG_WARNING, | |||
99 | TEST_LOG_NOTICE, | |||
100 | TEST_LOG_INFO, | |||
101 | TEST_LOG_STATUS, | |||
102 | TEST_LOG_VERBOSE | |||
103 | } Verbosity; | |||
104 | ||||
105 | static enum { | |||
106 | thread_nspr, thread_pthread, thread_sproc, thread_win32 | |||
107 | } thread_provider; | |||
108 | ||||
109 | static PRInt32 domain = AF_INET2; | |||
110 | static PRInt32 protocol = 6; /* TCP */ | |||
111 | static PRFileDesc *debug_out = NULL((void*)0); | |||
112 | static PRBool debug_mode = PR_FALSE0; | |||
113 | static PRBool pthread_stats = PR_FALSE0; | |||
114 | static Verbosity verbosity = TEST_LOG_ALWAYS; | |||
115 | static PRThreadScope thread_scope = PR_LOCAL_THREAD; | |||
116 | ||||
117 | struct CSWorker_s | |||
118 | { | |||
119 | PRCList element; /* list of the server's workers */ | |||
120 | ||||
121 | PRThread *thread; /* this worker objects thread */ | |||
122 | CSServer_t *server; /* back pointer to server structure */ | |||
123 | }; | |||
124 | ||||
125 | struct CSPool_s | |||
126 | { | |||
127 | PRCondVar *exiting; | |||
128 | PRCondVar *acceptComplete; | |||
129 | PRUint32 accepting, active, workers; | |||
130 | }; | |||
131 | ||||
132 | struct CSServer_s | |||
133 | { | |||
134 | PRCList list; /* head of worker list */ | |||
135 | ||||
136 | PRLock *ml; | |||
137 | PRThread *thread; /* the main server thread */ | |||
138 | PRCondVar *stateChange; | |||
139 | ||||
140 | PRUint16 port; /* port we're listening on */ | |||
141 | PRUint32 backlog; /* size of our listener backlog */ | |||
142 | PRFileDesc *listener; /* the fd accepting connections */ | |||
143 | ||||
144 | CSPool_t pool; /* statistics on worker threads */ | |||
145 | CSState_t state; /* the server's state */ | |||
146 | struct /* controlling worker counts */ | |||
147 | { | |||
148 | PRUint32 minimum, maximum, accepting; | |||
149 | } workers; | |||
150 | ||||
151 | /* statistics */ | |||
152 | PRIntervalTime started, stopped; | |||
153 | PRUint32 operations, bytesTransferred; | |||
154 | }; | |||
155 | ||||
156 | typedef struct CSDescriptor_s | |||
157 | { | |||
158 | PRInt32 size; /* size of transfer */ | |||
159 | char filename[60]; /* filename, null padded */ | |||
160 | } CSDescriptor_t; | |||
161 | ||||
162 | typedef struct CSClient_s | |||
163 | { | |||
164 | PRLock *ml; | |||
165 | PRThread *thread; | |||
166 | PRCondVar *stateChange; | |||
167 | PRNetAddr serverAddress; | |||
168 | ||||
169 | CSState_t state; | |||
170 | ||||
171 | /* statistics */ | |||
172 | PRIntervalTime started, stopped; | |||
173 | PRUint32 operations, bytesTransferred; | |||
174 | } CSClient_t; | |||
175 | ||||
176 | #define TEST_LOG(l, p, a)do { if (debug_mode || (p <= verbosity)) printf a; } while (0) \ | |||
177 | do { \ | |||
178 | if (debug_mode || (p <= verbosity)) printf a; \ | |||
179 | } while (0) | |||
180 | ||||
181 | PRLogModuleInfo *cltsrv_log_file = NULL((void*)0); | |||
182 | ||||
183 | #define MY_ASSERT(_expr)((_expr)?((void)0):_MY_Assert("_expr","../../../pr/tests/provider.c" ,183)) \ | |||
184 | ((_expr)?((void)0):_MY_Assert(# _expr,__FILE__"../../../pr/tests/provider.c",__LINE__184)) | |||
185 | ||||
186 | #define TEST_ASSERT(_expr)((_expr)?((void)0):_MY_Assert("_expr","../../../pr/tests/provider.c" ,186)) \ | |||
187 | ((_expr)?((void)0):_MY_Assert(# _expr,__FILE__"../../../pr/tests/provider.c",__LINE__187)) | |||
188 | ||||
189 | static void _MY_Assert(const char *s, const char *file, PRIntn ln) | |||
190 | { | |||
191 | PL_PrintError(NULL((void*)0)); | |||
192 | PR_Assert(s, file, ln); | |||
193 | } /* _MY_Assert */ | |||
194 | ||||
195 | static PRBool Aborted(PRStatus rv) | |||
196 | { | |||
197 | return ((PR_FAILURE == rv) && (PR_PENDING_INTERRUPT_ERROR(-5993L) == PR_GetError())) ? | |||
198 | PR_TRUE1 : PR_FALSE0; | |||
199 | } | |||
200 | ||||
201 | static void TimeOfDayMessage(const char *msg, PRThread* me) | |||
202 | { | |||
203 | char buffer[100]; | |||
204 | PRExplodedTime tod; | |||
205 | PR_ExplodeTime(PR_Now(), PR_LocalTimeParameters, &tod); | |||
206 | (void)PR_FormatTime(buffer, sizeof(buffer), "%H:%M:%S", &tod); | |||
207 | ||||
208 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("%s(0x%p): %s\n", msg, me, buffer); } while (0) | |||
209 | cltsrv_log_file, TEST_LOG_ALWAYS,do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("%s(0x%p): %s\n", msg, me, buffer); } while (0) | |||
210 | ("%s(0x%p): %s\n", msg, me, buffer))do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("%s(0x%p): %s\n", msg, me, buffer); } while (0); | |||
211 | } /* TimeOfDayMessage */ | |||
212 | ||||
213 | ||||
214 | static void PR_CALLBACK Client(void *arg) | |||
215 | { | |||
216 | PRStatus rv; | |||
217 | PRIntn index; | |||
218 | char buffer[1024]; | |||
219 | PRFileDesc *fd = NULL((void*)0); | |||
220 | PRUintn clipping = DEFAULT_CLIPPING1000; | |||
221 | CSClient_t *client = (CSClient_t*)arg; | |||
222 | PRThread *me = client->thread = PR_GetCurrentThread(); | |||
223 | CSDescriptor_t *descriptor = PR_NEW(CSDescriptor_t)((CSDescriptor_t *) (PR_Malloc((sizeof(CSDescriptor_t))))); | |||
224 | PRIntervalTime timeout = PR_MillisecondsToInterval(DEFAULT_CLIENT_TIMEOUT4000); | |||
225 | ||||
226 | ||||
227 | for (index = 0; index < sizeof(buffer); ++index) { | |||
228 | buffer[index] = (char)index; | |||
229 | } | |||
230 | ||||
231 | client->started = PR_IntervalNow(); | |||
232 | ||||
233 | PR_Lock(client->ml); | |||
234 | client->state = cs_run; | |||
235 | PR_NotifyCondVar(client->stateChange); | |||
236 | PR_Unlock(client->ml); | |||
237 | ||||
238 | TimeOfDayMessage("Client started at", me); | |||
239 | ||||
240 | while (cs_run == client->state) | |||
241 | { | |||
242 | PRInt32 bytes, descbytes, filebytes, netbytes; | |||
243 | ||||
244 | (void)PR_NetAddrToString(&client->serverAddress, buffer, sizeof(buffer)); | |||
245 | TEST_LOG(cltsrv_log_file, TEST_LOG_INFO,do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("\tClient(0x%p): connecting to server at %s\n", me, buffer) ; } while (0) | |||
246 | ("\tClient(0x%p): connecting to server at %s\n", me, buffer))do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("\tClient(0x%p): connecting to server at %s\n", me, buffer) ; } while (0); | |||
247 | ||||
248 | fd = PR_Socket(domain, SOCK_STREAMSOCK_STREAM, protocol); | |||
249 | TEST_ASSERT(NULL != fd)((((void*)0) != fd)?((void)0):_MY_Assert("NULL != fd","../../../pr/tests/provider.c" ,249)); | |||
250 | rv = PR_Connect(fd, &client->serverAddress, timeout); | |||
251 | if (PR_FAILURE == rv) | |||
252 | { | |||
253 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): conection failed\n", me); } while (0) | |||
254 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): conection failed\n", me); } while (0) | |||
255 | ("\tClient(0x%p): conection failed\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): conection failed\n", me); } while (0); | |||
256 | goto aborted; | |||
257 | } | |||
258 | ||||
259 | memset(descriptor, 0, sizeof(*descriptor)); | |||
260 | descriptor->size = PR_htonl(descbytes = rand() % clipping); | |||
261 | PR_snprintf( | |||
262 | descriptor->filename, sizeof(descriptor->filename), | |||
263 | "CS%p%p-%p.dat", client->started, me, client->operations); | |||
264 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tClient(0x%p): sending descriptor for %u bytes\n", me, descbytes ); } while (0) | |||
265 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tClient(0x%p): sending descriptor for %u bytes\n", me, descbytes ); } while (0) | |||
266 | ("\tClient(0x%p): sending descriptor for %u bytes\n", me, descbytes))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tClient(0x%p): sending descriptor for %u bytes\n", me, descbytes ); } while (0); | |||
267 | bytes = PR_Send( | |||
268 | fd, descriptor, sizeof(*descriptor), SEND_FLAGS0, timeout); | |||
269 | if (sizeof(CSDescriptor_t) != bytes) | |||
270 | { | |||
271 | if (Aborted(PR_FAILURE)) { | |||
272 | goto aborted; | |||
273 | } | |||
274 | if (PR_IO_TIMEOUT_ERROR(-5990L) == PR_GetError()) | |||
275 | { | |||
276 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): send descriptor timeout\n", me); } while ( 0) | |||
277 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): send descriptor timeout\n", me); } while ( 0) | |||
278 | ("\tClient(0x%p): send descriptor timeout\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): send descriptor timeout\n", me); } while ( 0); | |||
279 | goto retry; | |||
280 | } | |||
281 | } | |||
282 | TEST_ASSERT(sizeof(*descriptor) == bytes)((sizeof(*descriptor) == bytes)?((void)0):_MY_Assert("sizeof(*descriptor) == bytes" ,"../../../pr/tests/provider.c",282)); | |||
283 | ||||
284 | netbytes = 0; | |||
285 | while (netbytes < descbytes) | |||
286 | { | |||
287 | filebytes = sizeof(buffer); | |||
288 | if ((descbytes - netbytes) < filebytes) { | |||
289 | filebytes = descbytes - netbytes; | |||
290 | } | |||
291 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tClient(0x%p): sending %d bytes\n", me, filebytes); } while (0) | |||
292 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tClient(0x%p): sending %d bytes\n", me, filebytes); } while (0) | |||
293 | ("\tClient(0x%p): sending %d bytes\n", me, filebytes))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tClient(0x%p): sending %d bytes\n", me, filebytes); } while (0); | |||
294 | bytes = PR_Send(fd, buffer, filebytes, SEND_FLAGS0, timeout); | |||
295 | if (filebytes != bytes) | |||
296 | { | |||
297 | if (Aborted(PR_FAILURE)) { | |||
298 | goto aborted; | |||
299 | } | |||
300 | if (PR_IO_TIMEOUT_ERROR(-5990L) == PR_GetError()) | |||
301 | { | |||
302 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): send data timeout\n", me); } while (0) | |||
303 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): send data timeout\n", me); } while (0) | |||
304 | ("\tClient(0x%p): send data timeout\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): send data timeout\n", me); } while (0); | |||
305 | goto retry; | |||
306 | } | |||
307 | } | |||
308 | TEST_ASSERT(bytes == filebytes)((bytes == filebytes)?((void)0):_MY_Assert("bytes == filebytes" ,"../../../pr/tests/provider.c",308)); | |||
309 | netbytes += bytes; | |||
310 | } | |||
311 | filebytes = 0; | |||
312 | while (filebytes < descbytes) | |||
313 | { | |||
314 | netbytes = sizeof(buffer); | |||
315 | if ((descbytes - filebytes) < netbytes) { | |||
316 | netbytes = descbytes - filebytes; | |||
317 | } | |||
318 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tClient(0x%p): receiving %d bytes\n", me, netbytes); } while (0) | |||
319 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tClient(0x%p): receiving %d bytes\n", me, netbytes); } while (0) | |||
320 | ("\tClient(0x%p): receiving %d bytes\n", me, netbytes))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tClient(0x%p): receiving %d bytes\n", me, netbytes); } while (0); | |||
321 | bytes = PR_Recv(fd, buffer, netbytes, RECV_FLAGS0, timeout); | |||
322 | if (-1 == bytes) | |||
323 | { | |||
324 | if (Aborted(PR_FAILURE)) | |||
325 | { | |||
326 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): receive data aborted\n", me); } while (0) | |||
327 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): receive data aborted\n", me); } while (0) | |||
328 | ("\tClient(0x%p): receive data aborted\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): receive data aborted\n", me); } while (0); | |||
329 | goto aborted; | |||
330 | } | |||
331 | else if (PR_IO_TIMEOUT_ERROR(-5990L) == PR_GetError()) | |||
332 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): receive data timeout\n", me); } while (0) | |||
333 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): receive data timeout\n", me); } while (0) | |||
334 | ("\tClient(0x%p): receive data timeout\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): receive data timeout\n", me); } while (0); | |||
335 | else | |||
336 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): receive error (%d, %d)\n", me, PR_GetError (), PR_GetOSError()); } while (0) | |||
337 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): receive error (%d, %d)\n", me, PR_GetError (), PR_GetOSError()); } while (0) | |||
338 | ("\tClient(0x%p): receive error (%d, %d)\n",do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): receive error (%d, %d)\n", me, PR_GetError (), PR_GetOSError()); } while (0) | |||
339 | me, PR_GetError(), PR_GetOSError()))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tClient(0x%p): receive error (%d, %d)\n", me, PR_GetError (), PR_GetOSError()); } while (0); | |||
340 | goto retry; | |||
341 | } | |||
342 | if (0 == bytes) | |||
343 | { | |||
344 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tClient(0x%p): unexpected end of stream\n", PR_GetCurrentThread ()); } while (0) | |||
345 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tClient(0x%p): unexpected end of stream\n", PR_GetCurrentThread ()); } while (0) | |||
346 | ("\t\tClient(0x%p): unexpected end of stream\n",do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tClient(0x%p): unexpected end of stream\n", PR_GetCurrentThread ()); } while (0) | |||
347 | PR_GetCurrentThread()))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tClient(0x%p): unexpected end of stream\n", PR_GetCurrentThread ()); } while (0); | |||
348 | break; | |||
349 | } | |||
350 | filebytes += bytes; | |||
351 | } | |||
352 | ||||
353 | rv = PR_Shutdown(fd, PR_SHUTDOWN_BOTH); | |||
354 | if (Aborted(rv)) { | |||
355 | goto aborted; | |||
356 | } | |||
357 | TEST_ASSERT(PR_SUCCESS == rv)((PR_SUCCESS == rv)?((void)0):_MY_Assert("PR_SUCCESS == rv","../../../pr/tests/provider.c" ,357)); | |||
358 | retry: | |||
359 | (void)PR_Close(fd); fd = NULL((void*)0); | |||
360 | TEST_LOG(do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("\tClient(0x%p): disconnected from server\n", me); } while ( 0) | |||
361 | cltsrv_log_file, TEST_LOG_INFO,do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("\tClient(0x%p): disconnected from server\n", me); } while ( 0) | |||
362 | ("\tClient(0x%p): disconnected from server\n", me))do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("\tClient(0x%p): disconnected from server\n", me); } while ( 0); | |||
363 | ||||
364 | PR_Lock(client->ml); | |||
365 | client->operations += 1; | |||
366 | client->bytesTransferred += 2 * descbytes; | |||
367 | rv = PR_WaitCondVar(client->stateChange, rand() % clipping); | |||
368 | PR_Unlock(client->ml); | |||
369 | if (Aborted(rv)) { | |||
370 | break; | |||
371 | } | |||
372 | } | |||
373 | ||||
374 | aborted: | |||
375 | client->stopped = PR_IntervalNow(); | |||
376 | ||||
377 | PR_ClearInterrupt(); | |||
378 | if (NULL((void*)0) != fd) { | |||
379 | rv = PR_Close(fd); | |||
380 | } | |||
381 | ||||
382 | PR_Lock(client->ml); | |||
383 | client->state = cs_exit; | |||
384 | PR_NotifyCondVar(client->stateChange); | |||
385 | PR_Unlock(client->ml); | |||
386 | PR_DELETE(descriptor){ PR_Free(descriptor); (descriptor) = ((void*)0); }; | |||
387 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("\tClient(0x%p): stopped after %u operations and %u bytes\n" , PR_GetCurrentThread(), client->operations, client->bytesTransferred ); } while (0) | |||
388 | cltsrv_log_file, TEST_LOG_ALWAYS,do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("\tClient(0x%p): stopped after %u operations and %u bytes\n" , PR_GetCurrentThread(), client->operations, client->bytesTransferred ); } while (0) | |||
389 | ("\tClient(0x%p): stopped after %u operations and %u bytes\n",do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("\tClient(0x%p): stopped after %u operations and %u bytes\n" , PR_GetCurrentThread(), client->operations, client->bytesTransferred ); } while (0) | |||
390 | PR_GetCurrentThread(), client->operations, client->bytesTransferred))do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("\tClient(0x%p): stopped after %u operations and %u bytes\n" , PR_GetCurrentThread(), client->operations, client->bytesTransferred ); } while (0); | |||
391 | ||||
392 | } /* Client */ | |||
393 | ||||
394 | static PRStatus ProcessRequest(PRFileDesc *fd, CSServer_t *server) | |||
395 | { | |||
396 | PRStatus drv, rv; | |||
397 | char buffer[1024]; | |||
398 | PRFileDesc *file = NULL((void*)0); | |||
399 | PRThread * me = PR_GetCurrentThread(); | |||
400 | PRInt32 bytes, descbytes, netbytes, filebytes = 0; | |||
401 | CSDescriptor_t *descriptor = PR_NEW(CSDescriptor_t)((CSDescriptor_t *) (PR_Malloc((sizeof(CSDescriptor_t))))); | |||
402 | PRIntervalTime timeout = PR_MillisecondsToInterval(DEFAULT_SERVER_TIMEOUT4000); | |||
403 | ||||
404 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tProcessRequest(0x%p): receiving desciptor\n", me); } while (0) | |||
405 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tProcessRequest(0x%p): receiving desciptor\n", me); } while (0) | |||
406 | ("\tProcessRequest(0x%p): receiving desciptor\n", me))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tProcessRequest(0x%p): receiving desciptor\n", me); } while (0); | |||
407 | bytes = PR_Recv( | |||
408 | fd, descriptor, sizeof(*descriptor), RECV_FLAGS0, timeout); | |||
409 | if (-1 == bytes) | |||
410 | { | |||
411 | rv = PR_FAILURE; | |||
412 | if (Aborted(rv)) { | |||
413 | goto exit; | |||
414 | } | |||
415 | if (PR_IO_TIMEOUT_ERROR(-5990L) == PR_GetError()) | |||
416 | { | |||
417 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tProcessRequest(0x%p): receive timeout\n", me); } while ( 0) | |||
418 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tProcessRequest(0x%p): receive timeout\n", me); } while ( 0) | |||
419 | ("\tProcessRequest(0x%p): receive timeout\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tProcessRequest(0x%p): receive timeout\n", me); } while ( 0); | |||
420 | } | |||
421 | goto exit; | |||
422 | } | |||
423 | if (0 == bytes) | |||
424 | { | |||
425 | rv = PR_FAILURE; | |||
426 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tProcessRequest(0x%p): unexpected end of file\n", me); } while (0) | |||
427 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tProcessRequest(0x%p): unexpected end of file\n", me); } while (0) | |||
428 | ("\tProcessRequest(0x%p): unexpected end of file\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tProcessRequest(0x%p): unexpected end of file\n", me); } while (0); | |||
429 | goto exit; | |||
430 | } | |||
431 | descbytes = PR_ntohl(descriptor->size); | |||
432 | TEST_ASSERT(sizeof(*descriptor) == bytes)((sizeof(*descriptor) == bytes)?((void)0):_MY_Assert("sizeof(*descriptor) == bytes" ,"../../../pr/tests/provider.c",432)); | |||
433 | ||||
434 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): read descriptor {%d, %s}\n", me, descbytes, descriptor->filename); } while (0) | |||
435 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): read descriptor {%d, %s}\n", me, descbytes, descriptor->filename); } while (0) | |||
436 | ("\t\tProcessRequest(0x%p): read descriptor {%d, %s}\n",do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): read descriptor {%d, %s}\n", me, descbytes, descriptor->filename); } while (0) | |||
437 | me, descbytes, descriptor->filename))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): read descriptor {%d, %s}\n", me, descbytes, descriptor->filename); } while (0); | |||
438 | ||||
439 | file = PR_Open( | |||
440 | descriptor->filename, (PR_CREATE_FILE0x08 | PR_WRONLY0x02), 0666); | |||
441 | if (NULL((void*)0) == file) | |||
442 | { | |||
443 | rv = PR_FAILURE; | |||
444 | if (Aborted(rv)) { | |||
445 | goto aborted; | |||
446 | } | |||
447 | if (PR_IO_TIMEOUT_ERROR(-5990L) == PR_GetError()) | |||
448 | { | |||
449 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tProcessRequest(0x%p): open file timeout\n", me); } while (0) | |||
450 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tProcessRequest(0x%p): open file timeout\n", me); } while (0) | |||
451 | ("\tProcessRequest(0x%p): open file timeout\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\tProcessRequest(0x%p): open file timeout\n", me); } while (0); | |||
452 | goto aborted; | |||
453 | } | |||
454 | } | |||
455 | TEST_ASSERT(NULL != file)((((void*)0) != file)?((void)0):_MY_Assert("NULL != file","../../../pr/tests/provider.c" ,455)); | |||
456 | ||||
457 | filebytes = 0; | |||
458 | while (filebytes < descbytes) | |||
459 | { | |||
460 | netbytes = sizeof(buffer); | |||
461 | if ((descbytes - filebytes) < netbytes) { | |||
462 | netbytes = descbytes - filebytes; | |||
463 | } | |||
464 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tProcessRequest(0x%p): receive %d bytes\n", me, netbytes) ; } while (0) | |||
465 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tProcessRequest(0x%p): receive %d bytes\n", me, netbytes) ; } while (0) | |||
466 | ("\tProcessRequest(0x%p): receive %d bytes\n", me, netbytes))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tProcessRequest(0x%p): receive %d bytes\n", me, netbytes) ; } while (0); | |||
467 | bytes = PR_Recv(fd, buffer, netbytes, RECV_FLAGS0, timeout); | |||
468 | if (-1 == bytes) | |||
469 | { | |||
470 | rv = PR_FAILURE; | |||
471 | if (Aborted(rv)) { | |||
472 | goto aborted; | |||
473 | } | |||
474 | if (PR_IO_TIMEOUT_ERROR(-5990L) == PR_GetError()) | |||
475 | { | |||
476 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): receive data timeout\n", me); } while (0) | |||
477 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): receive data timeout\n", me); } while (0) | |||
478 | ("\t\tProcessRequest(0x%p): receive data timeout\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): receive data timeout\n", me); } while (0); | |||
479 | goto aborted; | |||
480 | } | |||
481 | /* | |||
482 | * XXX: I got (PR_CONNECT_RESET_ERROR, ERROR_NETNAME_DELETED) | |||
483 | * on NT here. This is equivalent to ECONNRESET on Unix. | |||
484 | * -wtc | |||
485 | */ | |||
486 | TEST_LOG(do { if (debug_mode || (TEST_LOG_WARNING <= verbosity)) printf ("\t\tProcessRequest(0x%p): unexpected error (%d, %d)\n", me , PR_GetError(), PR_GetOSError()); } while (0) | |||
487 | cltsrv_log_file, TEST_LOG_WARNING,do { if (debug_mode || (TEST_LOG_WARNING <= verbosity)) printf ("\t\tProcessRequest(0x%p): unexpected error (%d, %d)\n", me , PR_GetError(), PR_GetOSError()); } while (0) | |||
488 | ("\t\tProcessRequest(0x%p): unexpected error (%d, %d)\n",do { if (debug_mode || (TEST_LOG_WARNING <= verbosity)) printf ("\t\tProcessRequest(0x%p): unexpected error (%d, %d)\n", me , PR_GetError(), PR_GetOSError()); } while (0) | |||
489 | me, PR_GetError(), PR_GetOSError()))do { if (debug_mode || (TEST_LOG_WARNING <= verbosity)) printf ("\t\tProcessRequest(0x%p): unexpected error (%d, %d)\n", me , PR_GetError(), PR_GetOSError()); } while (0); | |||
490 | goto aborted; | |||
491 | } | |||
492 | if(0 == bytes) | |||
493 | { | |||
494 | TEST_LOG(do { if (debug_mode || (TEST_LOG_WARNING <= verbosity)) printf ("\t\tProcessRequest(0x%p): unexpected end of stream\n", me) ; } while (0) | |||
495 | cltsrv_log_file, TEST_LOG_WARNING,do { if (debug_mode || (TEST_LOG_WARNING <= verbosity)) printf ("\t\tProcessRequest(0x%p): unexpected end of stream\n", me) ; } while (0) | |||
496 | ("\t\tProcessRequest(0x%p): unexpected end of stream\n", me))do { if (debug_mode || (TEST_LOG_WARNING <= verbosity)) printf ("\t\tProcessRequest(0x%p): unexpected end of stream\n", me) ; } while (0); | |||
497 | rv = PR_FAILURE; | |||
498 | goto aborted; | |||
499 | } | |||
500 | filebytes += bytes; | |||
501 | netbytes = bytes; | |||
502 | /* The byte count for PR_Write should be positive */ | |||
503 | MY_ASSERT(netbytes > 0)((netbytes > 0)?((void)0):_MY_Assert("netbytes > 0","../../../pr/tests/provider.c" ,503)); | |||
504 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tProcessRequest(0x%p): write %d bytes to file\n", me, netbytes ); } while (0) | |||
505 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tProcessRequest(0x%p): write %d bytes to file\n", me, netbytes ); } while (0) | |||
506 | ("\tProcessRequest(0x%p): write %d bytes to file\n", me, netbytes))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tProcessRequest(0x%p): write %d bytes to file\n", me, netbytes ); } while (0); | |||
507 | bytes = PR_Write(file, buffer, netbytes); | |||
508 | if (netbytes != bytes) | |||
509 | { | |||
510 | rv = PR_FAILURE; | |||
511 | if (Aborted(rv)) { | |||
512 | goto aborted; | |||
513 | } | |||
514 | if (PR_IO_TIMEOUT_ERROR(-5990L) == PR_GetError()) | |||
515 | { | |||
516 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): write file timeout\n", me); } while (0) | |||
517 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): write file timeout\n", me); } while (0) | |||
518 | ("\t\tProcessRequest(0x%p): write file timeout\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): write file timeout\n", me); } while (0); | |||
519 | goto aborted; | |||
520 | } | |||
521 | } | |||
522 | TEST_ASSERT(bytes > 0)((bytes > 0)?((void)0):_MY_Assert("bytes > 0","../../../pr/tests/provider.c" ,522)); | |||
523 | } | |||
524 | ||||
525 | PR_Lock(server->ml); | |||
526 | server->operations += 1; | |||
527 | server->bytesTransferred += filebytes; | |||
528 | PR_Unlock(server->ml); | |||
529 | ||||
530 | rv = PR_Close(file); file = NULL((void*)0); | |||
531 | if (Aborted(rv)) { | |||
532 | goto aborted; | |||
533 | } | |||
534 | TEST_ASSERT(PR_SUCCESS == rv)((PR_SUCCESS == rv)?((void)0):_MY_Assert("PR_SUCCESS == rv","../../../pr/tests/provider.c" ,534)); | |||
535 | ||||
536 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): opening %s\n", me, descriptor-> filename); } while (0) | |||
537 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): opening %s\n", me, descriptor-> filename); } while (0) | |||
538 | ("\t\tProcessRequest(0x%p): opening %s\n", me, descriptor->filename))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): opening %s\n", me, descriptor-> filename); } while (0); | |||
539 | file = PR_Open(descriptor->filename, PR_RDONLY0x01, 0); | |||
540 | if (NULL((void*)0) == file) | |||
541 | { | |||
542 | rv = PR_FAILURE; | |||
543 | if (Aborted(rv)) { | |||
544 | goto aborted; | |||
545 | } | |||
546 | if (PR_IO_TIMEOUT_ERROR(-5990L) == PR_GetError()) | |||
547 | { | |||
548 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): open file timeout\n", PR_GetCurrentThread ()); } while (0) | |||
549 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): open file timeout\n", PR_GetCurrentThread ()); } while (0) | |||
550 | ("\t\tProcessRequest(0x%p): open file timeout\n",do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): open file timeout\n", PR_GetCurrentThread ()); } while (0) | |||
551 | PR_GetCurrentThread()))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): open file timeout\n", PR_GetCurrentThread ()); } while (0); | |||
552 | goto aborted; | |||
553 | } | |||
554 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): other file open error (%u, %u)\n" , me, PR_GetError(), PR_GetOSError()); } while (0) | |||
555 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): other file open error (%u, %u)\n" , me, PR_GetError(), PR_GetOSError()); } while (0) | |||
556 | ("\t\tProcessRequest(0x%p): other file open error (%u, %u)\n",do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): other file open error (%u, %u)\n" , me, PR_GetError(), PR_GetOSError()); } while (0) | |||
557 | me, PR_GetError(), PR_GetOSError()))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): other file open error (%u, %u)\n" , me, PR_GetError(), PR_GetOSError()); } while (0); | |||
558 | goto aborted; | |||
559 | } | |||
560 | TEST_ASSERT(NULL != file)((((void*)0) != file)?((void)0):_MY_Assert("NULL != file","../../../pr/tests/provider.c" ,560)); | |||
561 | ||||
562 | netbytes = 0; | |||
563 | while (netbytes < descbytes) | |||
564 | { | |||
565 | filebytes = sizeof(buffer); | |||
566 | if ((descbytes - netbytes) < filebytes) { | |||
567 | filebytes = descbytes - netbytes; | |||
568 | } | |||
569 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tProcessRequest(0x%p): read %d bytes from file\n", me, filebytes ); } while (0) | |||
570 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tProcessRequest(0x%p): read %d bytes from file\n", me, filebytes ); } while (0) | |||
571 | ("\tProcessRequest(0x%p): read %d bytes from file\n", me, filebytes))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tProcessRequest(0x%p): read %d bytes from file\n", me, filebytes ); } while (0); | |||
572 | bytes = PR_Read(file, buffer, filebytes); | |||
573 | if (filebytes != bytes) | |||
574 | { | |||
575 | rv = PR_FAILURE; | |||
576 | if (Aborted(rv)) { | |||
577 | goto aborted; | |||
578 | } | |||
579 | if (PR_IO_TIMEOUT_ERROR(-5990L) == PR_GetError()) | |||
580 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): read file timeout\n", me); } while (0) | |||
581 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): read file timeout\n", me); } while (0) | |||
582 | ("\t\tProcessRequest(0x%p): read file timeout\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): read file timeout\n", me); } while (0); | |||
583 | else | |||
584 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): other file error (%d, %d)\n", me , PR_GetError(), PR_GetOSError()); } while (0) | |||
585 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): other file error (%d, %d)\n", me , PR_GetError(), PR_GetOSError()); } while (0) | |||
586 | ("\t\tProcessRequest(0x%p): other file error (%d, %d)\n",do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): other file error (%d, %d)\n", me , PR_GetError(), PR_GetOSError()); } while (0) | |||
587 | me, PR_GetError(), PR_GetOSError()))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): other file error (%d, %d)\n", me , PR_GetError(), PR_GetOSError()); } while (0); | |||
588 | goto aborted; | |||
589 | } | |||
590 | TEST_ASSERT(bytes > 0)((bytes > 0)?((void)0):_MY_Assert("bytes > 0","../../../pr/tests/provider.c" ,590)); | |||
591 | netbytes += bytes; | |||
592 | filebytes = bytes; | |||
593 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): sending %d bytes\n", me, filebytes ); } while (0) | |||
594 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): sending %d bytes\n", me, filebytes ); } while (0) | |||
595 | ("\t\tProcessRequest(0x%p): sending %d bytes\n", me, filebytes))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): sending %d bytes\n", me, filebytes ); } while (0); | |||
596 | bytes = PR_Send(fd, buffer, filebytes, SEND_FLAGS0, timeout); | |||
597 | if (filebytes != bytes) | |||
598 | { | |||
599 | rv = PR_FAILURE; | |||
600 | if (Aborted(rv)) { | |||
601 | goto aborted; | |||
602 | } | |||
603 | if (PR_IO_TIMEOUT_ERROR(-5990L) == PR_GetError()) | |||
604 | { | |||
605 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): send data timeout\n", me); } while (0) | |||
606 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): send data timeout\n", me); } while (0) | |||
607 | ("\t\tProcessRequest(0x%p): send data timeout\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tProcessRequest(0x%p): send data timeout\n", me); } while (0); | |||
608 | goto aborted; | |||
609 | } | |||
610 | break; | |||
611 | } | |||
612 | TEST_ASSERT(bytes > 0)((bytes > 0)?((void)0):_MY_Assert("bytes > 0","../../../pr/tests/provider.c" ,612)); | |||
613 | } | |||
614 | ||||
615 | PR_Lock(server->ml); | |||
616 | server->bytesTransferred += filebytes; | |||
617 | PR_Unlock(server->ml); | |||
618 | ||||
619 | rv = PR_Shutdown(fd, PR_SHUTDOWN_BOTH); | |||
620 | if (Aborted(rv)) { | |||
621 | goto aborted; | |||
622 | } | |||
623 | ||||
624 | rv = PR_Close(file); file = NULL((void*)0); | |||
625 | if (Aborted(rv)) { | |||
626 | goto aborted; | |||
627 | } | |||
628 | TEST_ASSERT(PR_SUCCESS == rv)((PR_SUCCESS == rv)?((void)0):_MY_Assert("PR_SUCCESS == rv","../../../pr/tests/provider.c" ,628)); | |||
629 | ||||
630 | aborted: | |||
631 | PR_ClearInterrupt(); | |||
632 | if (NULL((void*)0) != file) { | |||
633 | PR_Close(file); | |||
634 | } | |||
635 | drv = PR_Delete(descriptor->filename); | |||
636 | TEST_ASSERT(PR_SUCCESS == drv)((PR_SUCCESS == drv)?((void)0):_MY_Assert("PR_SUCCESS == drv" ,"../../../pr/tests/provider.c",636)); | |||
637 | exit: | |||
638 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): Finished\n", me); } while (0) | |||
639 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): Finished\n", me); } while (0) | |||
640 | ("\t\tProcessRequest(0x%p): Finished\n", me))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tProcessRequest(0x%p): Finished\n", me); } while (0); | |||
641 | ||||
642 | PR_DELETE(descriptor){ PR_Free(descriptor); (descriptor) = ((void*)0); }; | |||
643 | ||||
644 | #if defined(WIN95) | |||
645 | PR_Sleep(PR_MillisecondsToInterval(200)); /* lth. see note [1] */ | |||
646 | #endif | |||
647 | return rv; | |||
648 | } /* ProcessRequest */ | |||
649 | ||||
650 | typedef void (*StartFn)(void*); | |||
651 | typedef struct StartObject | |||
652 | { | |||
653 | StartFn start; | |||
654 | void *arg; | |||
655 | } StartObject; | |||
656 | ||||
657 | #if defined(_PR_PTHREADS1) | |||
658 | #include "md/_pth.h" | |||
659 | #include <pthread.h> | |||
660 | ||||
661 | static void *pthread_start(void *arg) | |||
662 | { | |||
663 | StartObject *so = (StartObject*)arg; | |||
664 | StartFn start = so->start; | |||
665 | void *data = so->arg; | |||
666 | PR_Free(so); | |||
667 | start(data); | |||
668 | return NULL((void*)0); | |||
669 | } /* pthread_start */ | |||
670 | #endif /* defined(_PR_PTHREADS) */ | |||
671 | ||||
672 | #if defined(WIN32) | |||
673 | #include <process.h> /* for _beginthreadex() */ | |||
674 | ||||
675 | static PRUintn __stdcall windows_start(void *arg) | |||
676 | { | |||
677 | StartObject *so = (StartObject*)arg; | |||
678 | StartFn start = so->start; | |||
679 | void *data = so->arg; | |||
680 | PR_Free(so); | |||
681 | start(data); | |||
682 | return 0; | |||
683 | } /* windows_start */ | |||
684 | #endif /* defined(WIN32) */ | |||
685 | ||||
686 | static PRStatus JoinThread(PRThread *thread) | |||
687 | { | |||
688 | PRStatus rv; | |||
689 | switch (thread_provider) | |||
690 | { | |||
691 | case thread_nspr: | |||
692 | rv = PR_JoinThread(thread); | |||
693 | break; | |||
694 | case thread_pthread: | |||
695 | #if defined(_PR_PTHREADS1) | |||
696 | rv = PR_SUCCESS; | |||
697 | break; | |||
698 | #endif /* defined(_PR_PTHREADS) */ | |||
699 | case thread_win32: | |||
700 | #if defined(WIN32) | |||
701 | rv = PR_SUCCESS; | |||
702 | break; | |||
703 | #endif | |||
704 | default: | |||
705 | rv = PR_FAILURE; | |||
706 | break; | |||
707 | } | |||
708 | return rv; | |||
709 | } /* JoinThread */ | |||
710 | ||||
711 | static PRStatus NewThread( | |||
712 | StartFn start, void *arg, PRThreadPriority prio, PRThreadState state) | |||
713 | { | |||
714 | PRStatus rv; | |||
715 | ||||
716 | switch (thread_provider) | |||
717 | { | |||
718 | case thread_nspr: | |||
719 | { | |||
720 | PRThread *thread = PR_CreateThread( | |||
721 | PR_USER_THREAD, start, arg, | |||
722 | PR_PRIORITY_NORMAL, PR_GLOBAL_THREAD, | |||
723 | PR_JOINABLE_THREAD, 0); | |||
724 | rv = (NULL((void*)0) == thread) ? PR_FAILURE : PR_SUCCESS; | |||
725 | } | |||
726 | break; | |||
727 | case thread_pthread: | |||
728 | #if defined(_PR_PTHREADS1) | |||
729 | { | |||
730 | int rv; | |||
731 | pthread_t id; | |||
732 | pthread_attr_t tattr; | |||
733 | StartObject *start_object; | |||
734 | start_object = PR_NEW(StartObject)((StartObject *) (PR_Malloc((sizeof(StartObject))))); | |||
735 | PR_ASSERT(NULL != start_object)((((void*)0) != start_object)?((void)0):PR_Assert("NULL != start_object" ,"../../../pr/tests/provider.c",735)); | |||
736 | start_object->start = start; | |||
737 | start_object->arg = arg; | |||
738 | ||||
739 | rv = _PT_PTHREAD_ATTR_INITpthread_attr_init(&tattr); | |||
740 | PR_ASSERT(0 == rv)((0 == rv)?((void)0):PR_Assert("0 == rv","../../../pr/tests/provider.c" ,740)); | |||
741 | ||||
742 | rv = pthread_attr_setdetachstate(&tattr, PTHREAD_CREATE_DETACHEDPTHREAD_CREATE_DETACHED); | |||
743 | PR_ASSERT(0 == rv)((0 == rv)?((void)0):PR_Assert("0 == rv","../../../pr/tests/provider.c" ,743)); | |||
744 | ||||
745 | rv = pthread_attr_setstacksize(&tattr, 64 * 1024); | |||
746 | PR_ASSERT(0 == rv)((0 == rv)?((void)0):PR_Assert("0 == rv","../../../pr/tests/provider.c" ,746)); | |||
747 | ||||
748 | rv = _PT_PTHREAD_CREATE(&id, tattr, pthread_start, start_object)pthread_create(&id, &tattr, pthread_start, start_object ); | |||
749 | (void)_PT_PTHREAD_ATTR_DESTROYpthread_attr_destroy(&tattr); | |||
750 | return (0 == rv) ? PR_SUCCESS : PR_FAILURE; | |||
751 | } | |||
752 | #else | |||
753 | PR_SetError(PR_NOT_IMPLEMENTED_ERROR(-5992L), 0); | |||
754 | rv = PR_FAILURE; | |||
755 | #endif /* defined(_PR_PTHREADS) */ | |||
756 | break; | |||
757 | ||||
758 | case thread_sproc: | |||
759 | PR_SetError(PR_NOT_IMPLEMENTED_ERROR(-5992L), 0); | |||
760 | rv = PR_FAILURE; | |||
761 | break; | |||
762 | case thread_win32: | |||
763 | #if defined(WIN32) | |||
764 | { | |||
765 | void *th; | |||
766 | PRUintn id; | |||
767 | StartObject *start_object; | |||
768 | start_object = PR_NEW(StartObject)((StartObject *) (PR_Malloc((sizeof(StartObject))))); | |||
769 | PR_ASSERT(NULL != start_object)((((void*)0) != start_object)?((void)0):PR_Assert("NULL != start_object" ,"../../../pr/tests/provider.c",769)); | |||
770 | start_object->start = start; | |||
771 | start_object->arg = arg; | |||
772 | th = (void*)_beginthreadex( | |||
773 | NULL((void*)0), /* LPSECURITY_ATTRIBUTES - pointer to thread security attributes */ | |||
774 | 0U, /* DWORD - initial thread stack size, in bytes */ | |||
775 | windows_start, /* LPTHREAD_START_ROUTINE - pointer to thread function */ | |||
776 | start_object, /* LPVOID - argument for new thread */ | |||
777 | STACK_SIZE_PARAM_IS_A_RESERVATION, /*DWORD dwCreationFlags - creation flags */ | |||
778 | &id /* LPDWORD - pointer to returned thread identifier */ ); | |||
779 | ||||
780 | rv = (NULL((void*)0) == th) ? PR_FAILURE : PR_SUCCESS; | |||
781 | } | |||
782 | #else | |||
783 | PR_SetError(PR_NOT_IMPLEMENTED_ERROR(-5992L), 0); | |||
784 | rv = PR_FAILURE; | |||
785 | #endif | |||
786 | break; | |||
787 | default: | |||
788 | PR_SetError(PR_NOT_IMPLEMENTED_ERROR(-5992L), 0); | |||
789 | rv = PR_FAILURE; | |||
790 | } | |||
791 | return rv; | |||
792 | } /* NewThread */ | |||
793 | ||||
794 | static PRStatus CreateWorker(CSServer_t *server, CSPool_t *pool) | |||
795 | { | |||
796 | PRStatus rv; | |||
797 | CSWorker_t *worker = PR_NEWZAP(CSWorker_t)((CSWorker_t*)PR_Calloc(1, sizeof(CSWorker_t))); | |||
798 | worker->server = server; | |||
799 | PR_INIT_CLIST(&worker->element)do { (&worker->element)->next = (&worker->element ); (&worker->element)->prev = (&worker->element ); } while (0); | |||
800 | rv = NewThread( | |||
801 | Worker, worker, DEFAULT_SERVER_PRIORITYPR_PRIORITY_HIGH, PR_UNJOINABLE_THREAD); | |||
802 | if (PR_FAILURE == rv) { | |||
803 | PR_DELETE(worker){ PR_Free(worker); (worker) = ((void*)0); }; | |||
804 | } | |||
805 | ||||
806 | TEST_LOG(cltsrv_log_file, TEST_LOG_STATUS,do { if (debug_mode || (TEST_LOG_STATUS <= verbosity)) printf ("\tCreateWorker(0x%p): create new worker (0x%p)\n", PR_GetCurrentThread (), worker->thread); } while (0) | |||
| ||||
807 | ("\tCreateWorker(0x%p): create new worker (0x%p)\n",do { if (debug_mode || (TEST_LOG_STATUS <= verbosity)) printf ("\tCreateWorker(0x%p): create new worker (0x%p)\n", PR_GetCurrentThread (), worker->thread); } while (0) | |||
808 | PR_GetCurrentThread(), worker->thread))do { if (debug_mode || (TEST_LOG_STATUS <= verbosity)) printf ("\tCreateWorker(0x%p): create new worker (0x%p)\n", PR_GetCurrentThread (), worker->thread); } while (0); | |||
809 | ||||
810 | return rv; | |||
811 | } /* CreateWorker */ | |||
812 | ||||
813 | static void PR_CALLBACK Worker(void *arg) | |||
814 | { | |||
815 | PRStatus rv; | |||
816 | PRNetAddr from; | |||
817 | PRFileDesc *fd = NULL((void*)0); | |||
818 | CSWorker_t *worker = (CSWorker_t*)arg; | |||
819 | CSServer_t *server = worker->server; | |||
820 | CSPool_t *pool = &server->pool; | |||
821 | ||||
822 | PRThread *me = worker->thread = PR_GetCurrentThread(); | |||
823 | ||||
824 | TEST_LOG(do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\t\tWorker(0x%p): started [%u]\n", me, pool->workers + 1 ); } while (0) | |||
825 | cltsrv_log_file, TEST_LOG_NOTICE,do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\t\tWorker(0x%p): started [%u]\n", me, pool->workers + 1 ); } while (0) | |||
826 | ("\t\tWorker(0x%p): started [%u]\n", me, pool->workers + 1))do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\t\tWorker(0x%p): started [%u]\n", me, pool->workers + 1 ); } while (0); | |||
827 | ||||
828 | PR_Lock(server->ml); | |||
829 | PR_APPEND_LINK(&worker->element, &server->list)do { (&worker->element)->next = (&server->list ); (&worker->element)->prev = (&server->list )->prev; (&server->list)->prev->next = (& worker->element); (&server->list)->prev = (& worker->element); } while (0); | |||
830 | pool->workers += 1; /* define our existance */ | |||
831 | ||||
832 | while (cs_run == server->state) | |||
833 | { | |||
834 | while (pool->accepting >= server->workers.accepting) | |||
835 | { | |||
836 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tWorker(0x%p): waiting for accept slot[%d]\n", me, pool ->accepting); } while (0) | |||
837 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tWorker(0x%p): waiting for accept slot[%d]\n", me, pool ->accepting); } while (0) | |||
838 | ("\t\tWorker(0x%p): waiting for accept slot[%d]\n",do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tWorker(0x%p): waiting for accept slot[%d]\n", me, pool ->accepting); } while (0) | |||
839 | me, pool->accepting))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tWorker(0x%p): waiting for accept slot[%d]\n", me, pool ->accepting); } while (0); | |||
840 | rv = PR_WaitCondVar(pool->acceptComplete, PR_INTERVAL_NO_TIMEOUT0xffffffffUL); | |||
841 | if (Aborted(rv) || (cs_run != server->state)) | |||
842 | { | |||
843 | TEST_LOG(do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\tWorker(0x%p): has been %s\n", me, (Aborted(rv) ? "interrupted" : "stopped")); } while (0) | |||
844 | cltsrv_log_file, TEST_LOG_NOTICE,do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\tWorker(0x%p): has been %s\n", me, (Aborted(rv) ? "interrupted" : "stopped")); } while (0) | |||
845 | ("\tWorker(0x%p): has been %s\n",do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\tWorker(0x%p): has been %s\n", me, (Aborted(rv) ? "interrupted" : "stopped")); } while (0) | |||
846 | me, (Aborted(rv) ? "interrupted" : "stopped")))do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\tWorker(0x%p): has been %s\n", me, (Aborted(rv) ? "interrupted" : "stopped")); } while (0); | |||
847 | goto exit; | |||
848 | } | |||
849 | } | |||
850 | pool->accepting += 1; /* how many are really in accept */ | |||
851 | PR_Unlock(server->ml); | |||
852 | ||||
853 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tWorker(0x%p): calling accept\n", me); } while (0) | |||
854 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tWorker(0x%p): calling accept\n", me); } while (0) | |||
855 | ("\t\tWorker(0x%p): calling accept\n", me))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\t\tWorker(0x%p): calling accept\n", me); } while (0); | |||
856 | fd = PR_Accept(server->listener, &from, PR_INTERVAL_NO_TIMEOUT0xffffffffUL); | |||
857 | ||||
858 | PR_Lock(server->ml); | |||
859 | pool->accepting -= 1; | |||
860 | PR_NotifyCondVar(pool->acceptComplete); | |||
861 | ||||
862 | if ((NULL((void*)0) == fd) && Aborted(PR_FAILURE)) | |||
863 | { | |||
864 | if (NULL((void*)0) != server->listener) | |||
865 | { | |||
866 | PR_Close(server->listener); | |||
867 | server->listener = NULL((void*)0); | |||
868 | } | |||
869 | goto exit; | |||
870 | } | |||
871 | ||||
872 | if (NULL((void*)0) != fd) | |||
873 | { | |||
874 | /* | |||
875 | ** Create another worker of the total number of workers is | |||
876 | ** less than the minimum specified or we have none left in | |||
877 | ** accept() AND we're not over the maximum. | |||
878 | ** This sort of presumes that the number allowed in accept | |||
879 | ** is at least as many as the minimum. Otherwise we'll keep | |||
880 | ** creating new threads and deleting them soon after. | |||
881 | */ | |||
882 | PRBool another = | |||
883 | ((pool->workers < server->workers.minimum) || | |||
884 | ((0 == pool->accepting) | |||
885 | && (pool->workers < server->workers.maximum))) ? | |||
886 | PR_TRUE1 : PR_FALSE0; | |||
887 | pool->active += 1; | |||
888 | PR_Unlock(server->ml); | |||
889 | ||||
890 | if (another) { | |||
891 | (void)CreateWorker(server, pool); | |||
892 | } | |||
893 | ||||
894 | rv = ProcessRequest(fd, server); | |||
895 | if (PR_SUCCESS != rv) | |||
896 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tWorker(0x%p): server process ended abnormally\n", me); } while (0) | |||
897 | cltsrv_log_file, TEST_LOG_ERROR,do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tWorker(0x%p): server process ended abnormally\n", me); } while (0) | |||
898 | ("\t\tWorker(0x%p): server process ended abnormally\n", me))do { if (debug_mode || (TEST_LOG_ERROR <= verbosity)) printf ("\t\tWorker(0x%p): server process ended abnormally\n", me); } while (0); | |||
899 | (void)PR_Close(fd); fd = NULL((void*)0); | |||
900 | ||||
901 | PR_Lock(server->ml); | |||
902 | pool->active -= 1; | |||
903 | } | |||
904 | } | |||
905 | ||||
906 | exit: | |||
907 | PR_ClearInterrupt(); | |||
908 | PR_Unlock(server->ml); | |||
909 | ||||
910 | if (NULL((void*)0) != fd) | |||
911 | { | |||
912 | (void)PR_Shutdown(fd, PR_SHUTDOWN_BOTH); | |||
913 | (void)PR_Close(fd); | |||
914 | } | |||
915 | ||||
916 | TEST_LOG(do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\t\tWorker(0x%p): exiting [%u]\n", PR_GetCurrentThread(), pool ->workers); } while (0) | |||
917 | cltsrv_log_file, TEST_LOG_NOTICE,do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\t\tWorker(0x%p): exiting [%u]\n", PR_GetCurrentThread(), pool ->workers); } while (0) | |||
918 | ("\t\tWorker(0x%p): exiting [%u]\n", PR_GetCurrentThread(), pool->workers))do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\t\tWorker(0x%p): exiting [%u]\n", PR_GetCurrentThread(), pool ->workers); } while (0); | |||
919 | ||||
920 | PR_Lock(server->ml); | |||
921 | pool->workers -= 1; /* undefine our existance */ | |||
922 | PR_REMOVE_AND_INIT_LINK(&worker->element)do { (&worker->element)->prev->next = (&worker ->element)->next; (&worker->element)->next-> prev = (&worker->element)->prev; (&worker->element )->next = (&worker->element); (&worker->element )->prev = (&worker->element); } while (0); | |||
923 | PR_NotifyCondVar(pool->exiting); | |||
924 | PR_Unlock(server->ml); | |||
925 | ||||
926 | PR_DELETE(worker){ PR_Free(worker); (worker) = ((void*)0); }; /* destruction of the "worker" object */ | |||
927 | ||||
928 | } /* Worker */ | |||
929 | ||||
930 | static void PR_CALLBACK Server(void *arg) | |||
931 | { | |||
932 | PRStatus rv; | |||
933 | PRNetAddr serverAddress; | |||
934 | CSServer_t *server = (CSServer_t*)arg; | |||
935 | PRThread *me = server->thread = PR_GetCurrentThread(); | |||
936 | PRSocketOptionData sockOpt; | |||
937 | ||||
938 | server->listener = PR_Socket(domain, SOCK_STREAMSOCK_STREAM, protocol); | |||
939 | ||||
940 | sockOpt.option = PR_SockOpt_Reuseaddr; | |||
941 | sockOpt.value.reuse_addr = PR_TRUE1; | |||
942 | rv = PR_SetSocketOption(server->listener, &sockOpt); | |||
943 | TEST_ASSERT(PR_SUCCESS == rv)((PR_SUCCESS == rv)?((void)0):_MY_Assert("PR_SUCCESS == rv","../../../pr/tests/provider.c" ,943)); | |||
| ||||
944 | ||||
945 | memset(&serverAddress, 0, sizeof(serverAddress)); | |||
946 | rv = PR_InitializeNetAddr(PR_IpAddrAny, DEFAULT_PORT13000 +100 +200, &serverAddress); | |||
947 | ||||
948 | rv = PR_Bind(server->listener, &serverAddress); | |||
949 | TEST_ASSERT(PR_SUCCESS == rv)((PR_SUCCESS == rv)?((void)0):_MY_Assert("PR_SUCCESS == rv","../../../pr/tests/provider.c" ,949)); | |||
950 | ||||
951 | rv = PR_Listen(server->listener, server->backlog); | |||
952 | TEST_ASSERT(PR_SUCCESS == rv)((PR_SUCCESS == rv)?((void)0):_MY_Assert("PR_SUCCESS == rv","../../../pr/tests/provider.c" ,952)); | |||
953 | ||||
954 | server->started = PR_IntervalNow(); | |||
955 | TimeOfDayMessage("Server started at", me); | |||
956 | ||||
957 | PR_Lock(server->ml); | |||
958 | server->state = cs_run; | |||
959 | PR_NotifyCondVar(server->stateChange); | |||
960 | PR_Unlock(server->ml); | |||
961 | ||||
962 | /* | |||
963 | ** Create the first worker (actually, a thread that accepts | |||
964 | ** connections and then processes the work load as needed). | |||
965 | ** From this point on, additional worker threads are created | |||
966 | ** as they are needed by existing worker threads. | |||
967 | */ | |||
968 | rv = CreateWorker(server, &server->pool); | |||
969 | TEST_ASSERT(PR_SUCCESS == rv)((PR_SUCCESS == rv)?((void)0):_MY_Assert("PR_SUCCESS == rv","../../../pr/tests/provider.c" ,969)); | |||
970 | ||||
971 | /* | |||
972 | ** From here on this thread is merely hanging around as the contact | |||
973 | ** point for the main test driver. It's just waiting for the driver | |||
974 | ** to declare the test complete. | |||
975 | */ | |||
976 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tServer(0x%p): waiting for state change\n", me); } while ( 0) | |||
977 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tServer(0x%p): waiting for state change\n", me); } while ( 0) | |||
978 | ("\tServer(0x%p): waiting for state change\n", me))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tServer(0x%p): waiting for state change\n", me); } while ( 0); | |||
979 | ||||
980 | PR_Lock(server->ml); | |||
981 | while ((cs_run == server->state) && !Aborted(rv)) | |||
982 | { | |||
983 | rv = PR_WaitCondVar(server->stateChange, PR_INTERVAL_NO_TIMEOUT0xffffffffUL); | |||
984 | } | |||
985 | PR_Unlock(server->ml); | |||
986 | PR_ClearInterrupt(); | |||
987 | ||||
988 | TEST_LOG(do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("\tServer(0x%p): shutting down workers\n", me); } while (0) | |||
989 | cltsrv_log_file, TEST_LOG_INFO,do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("\tServer(0x%p): shutting down workers\n", me); } while (0) | |||
990 | ("\tServer(0x%p): shutting down workers\n", me))do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("\tServer(0x%p): shutting down workers\n", me); } while (0); | |||
991 | ||||
992 | /* | |||
993 | ** Get all the worker threads to exit. They know how to | |||
994 | ** clean up after themselves, so this is just a matter of | |||
995 | ** waiting for clorine in the pool to take effect. During | |||
996 | ** this stage we're ignoring interrupts. | |||
997 | */ | |||
998 | server->workers.minimum = server->workers.maximum = 0; | |||
999 | ||||
1000 | PR_Lock(server->ml); | |||
1001 | while (!PR_CLIST_IS_EMPTY(&server->list)((&server->list)->next == (&server->list))) | |||
1002 | { | |||
1003 | PRCList *head = PR_LIST_HEAD(&server->list)(&server->list)->next; | |||
1004 | CSWorker_t *worker = (CSWorker_t*)head; | |||
1005 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tServer(0x%p): interrupting worker(0x%p)\n", me, worker); } while (0) | |||
1006 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tServer(0x%p): interrupting worker(0x%p)\n", me, worker); } while (0) | |||
1007 | ("\tServer(0x%p): interrupting worker(0x%p)\n", me, worker))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("\tServer(0x%p): interrupting worker(0x%p)\n", me, worker); } while (0); | |||
1008 | rv = PR_Interrupt(worker->thread); | |||
1009 | TEST_ASSERT(PR_SUCCESS == rv)((PR_SUCCESS == rv)?((void)0):_MY_Assert("PR_SUCCESS == rv","../../../pr/tests/provider.c" ,1009)); | |||
1010 | PR_REMOVE_AND_INIT_LINK(head)do { (head)->prev->next = (head)->next; (head)->next ->prev = (head)->prev; (head)->next = (head); (head) ->prev = (head); } while (0); | |||
1011 | } | |||
1012 | ||||
1013 | while (server->pool.workers > 0) | |||
1014 | { | |||
1015 | TEST_LOG(do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\tServer(0x%p): waiting for %u workers to exit\n", me, server ->pool.workers); } while (0) | |||
1016 | cltsrv_log_file, TEST_LOG_NOTICE,do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\tServer(0x%p): waiting for %u workers to exit\n", me, server ->pool.workers); } while (0) | |||
1017 | ("\tServer(0x%p): waiting for %u workers to exit\n",do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\tServer(0x%p): waiting for %u workers to exit\n", me, server ->pool.workers); } while (0) | |||
1018 | me, server->pool.workers))do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("\tServer(0x%p): waiting for %u workers to exit\n", me, server ->pool.workers); } while (0); | |||
1019 | (void)PR_WaitCondVar(server->pool.exiting, PR_INTERVAL_NO_TIMEOUT0xffffffffUL); | |||
1020 | } | |||
1021 | ||||
1022 | server->state = cs_exit; | |||
1023 | PR_NotifyCondVar(server->stateChange); | |||
1024 | PR_Unlock(server->ml); | |||
1025 | ||||
1026 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("\tServer(0x%p): stopped after %u operations and %u bytes\n" , me, server->operations, server->bytesTransferred); } while (0) | |||
1027 | cltsrv_log_file, TEST_LOG_ALWAYS,do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("\tServer(0x%p): stopped after %u operations and %u bytes\n" , me, server->operations, server->bytesTransferred); } while (0) | |||
1028 | ("\tServer(0x%p): stopped after %u operations and %u bytes\n",do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("\tServer(0x%p): stopped after %u operations and %u bytes\n" , me, server->operations, server->bytesTransferred); } while (0) | |||
1029 | me, server->operations, server->bytesTransferred))do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("\tServer(0x%p): stopped after %u operations and %u bytes\n" , me, server->operations, server->bytesTransferred); } while (0); | |||
1030 | ||||
1031 | if (NULL((void*)0) != server->listener) { | |||
1032 | PR_Close(server->listener); | |||
1033 | } | |||
1034 | server->stopped = PR_IntervalNow(); | |||
1035 | ||||
1036 | } /* Server */ | |||
1037 | ||||
1038 | static void WaitForCompletion(PRIntn execution) | |||
1039 | { | |||
1040 | while (execution > 0) | |||
1041 | { | |||
1042 | PRIntn dally = (execution > 30) ? 30 : execution; | |||
1043 | PR_Sleep(PR_SecondsToInterval(dally)); | |||
1044 | if (pthread_stats) { | |||
1045 | PT_FPrintStats(debug_out, "\nPThread Statistics\n"); | |||
1046 | } | |||
1047 | execution -= dally; | |||
1048 | } | |||
1049 | } /* WaitForCompletion */ | |||
1050 | ||||
1051 | static void Help(void) | |||
1052 | { | |||
1053 | PR_fprintf(debug_out, "cltsrv test program usage:\n"); | |||
1054 | PR_fprintf(debug_out, "\t-a <n> threads allowed in accept (5)\n"); | |||
1055 | PR_fprintf(debug_out, "\t-b <n> backlock for listen (5)\n"); | |||
1056 | PR_fprintf(debug_out, "\t-c <threads> number of clients to create (1)\n"); | |||
1057 | PR_fprintf(debug_out, "\t-w <threads> minimal number of server threads (1)\n"); | |||
1058 | PR_fprintf(debug_out, "\t-W <threads> maximum number of server threads (1)\n"); | |||
1059 | PR_fprintf(debug_out, "\t-e <seconds> duration of the test in seconds (10)\n"); | |||
1060 | PR_fprintf(debug_out, "\t-s <string> dsn name of server (localhost)\n"); | |||
1061 | PR_fprintf(debug_out, "\t-G use GLOBAL threads (LOCAL)\n"); | |||
1062 | PR_fprintf(debug_out, "\t-T <string> thread provider ('n' | 'p' | 'w')(n)\n"); | |||
1063 | PR_fprintf(debug_out, "\t-X use XTP as transport (TCP)\n"); | |||
1064 | PR_fprintf(debug_out, "\t-6 Use IPv6 (IPv4)\n"); | |||
1065 | PR_fprintf(debug_out, "\t-v verbosity (accumulative) (0)\n"); | |||
1066 | PR_fprintf(debug_out, "\t-p pthread statistics (FALSE)\n"); | |||
1067 | PR_fprintf(debug_out, "\t-d debug mode (FALSE)\n"); | |||
1068 | PR_fprintf(debug_out, "\t-h this message\n"); | |||
1069 | } /* Help */ | |||
1070 | ||||
1071 | static Verbosity IncrementVerbosity(void) | |||
1072 | { | |||
1073 | PRIntn verboge = (PRIntn)verbosity + 1; | |||
1074 | return (Verbosity)verboge; | |||
1075 | } /* IncrementVerbosity */ | |||
1076 | ||||
1077 | int main(int argc, char **argv) | |||
1078 | { | |||
1079 | PRUintn index; | |||
1080 | PRBool boolean; | |||
1081 | CSClient_t *client; | |||
1082 | PRStatus rv, joinStatus; | |||
1083 | CSServer_t *server = NULL((void*)0); | |||
1084 | char *thread_type; | |||
1085 | ||||
1086 | PRUintn backlog = DEFAULT_BACKLOG5; | |||
1087 | PRUintn clients = DEFAULT_CLIENTS1; | |||
1088 | const char *serverName = DEFAULT_SERVER"localhost"; | |||
1089 | PRBool serverIsLocal = PR_TRUE1; | |||
1090 | PRUintn accepting = ALLOWED_IN_ACCEPT1; | |||
1091 | PRUintn workersMin = DEFAULT_WORKERS_MIN1; | |||
1092 | PRUintn workersMax = DEFAULT_WORKERS_MAX1; | |||
1093 | PRIntn execution = DEFAULT_EXECUTION_TIME10; | |||
1094 | ||||
1095 | /* | |||
1096 | * -G use global threads | |||
1097 | * -a <n> threads allowed in accept | |||
1098 | * -b <n> backlock for listen | |||
1099 | * -c <threads> number of clients to create | |||
1100 | * -w <threads> minimal number of server threads | |||
1101 | * -W <threads> maximum number of server threads | |||
1102 | * -e <seconds> duration of the test in seconds | |||
1103 | * -s <string> dsn name of server (implies no server here) | |||
1104 | * -v verbosity | |||
1105 | */ | |||
1106 | ||||
1107 | PLOptStatus os; | |||
1108 | PLOptState *opt = PL_CreateOptState(argc, argv, "GX6b:a:c:w:W:e:s:T:vdhp"); | |||
1109 | ||||
1110 | #if defined(WIN32) | |||
1111 | thread_provider = thread_win32; | |||
1112 | #elif defined(_PR_PTHREADS1) | |||
1113 | thread_provider = thread_pthread; | |||
1114 | #else | |||
1115 | thread_provider = thread_nspr; | |||
1116 | #endif | |||
1117 | ||||
1118 | debug_out = PR_GetSpecialFD(PR_StandardError); | |||
1119 | ||||
1120 | while (PL_OPT_EOL != (os = PL_GetNextOpt(opt))) | |||
1121 | { | |||
1122 | if (PL_OPT_BAD == os) { | |||
1123 | continue; | |||
1124 | } | |||
1125 | switch (opt->option) | |||
1126 | { | |||
1127 | case 'G': /* use global threads */ | |||
1128 | thread_scope = PR_GLOBAL_THREAD; | |||
1129 | break; | |||
1130 | case 'X': /* use XTP as transport */ | |||
1131 | protocol = 36; | |||
1132 | break; | |||
1133 | case '6': /* Use IPv6 */ | |||
1134 | domain = PR_AF_INET610; | |||
1135 | break; | |||
1136 | case 'a': /* the value for accepting */ | |||
1137 | accepting = atoi(opt->value); | |||
1138 | break; | |||
1139 | case 'b': /* the value for backlock */ | |||
1140 | backlog = atoi(opt->value); | |||
1141 | break; | |||
1142 | case 'T': /* the thread provider */ | |||
1143 | if ('n' == *opt->value) { | |||
1144 | thread_provider = thread_nspr; | |||
1145 | } | |||
1146 | else if ('p' == *opt->value) { | |||
1147 | thread_provider = thread_pthread; | |||
1148 | } | |||
1149 | else if ('w' == *opt->value) { | |||
1150 | thread_provider = thread_win32; | |||
1151 | } | |||
1152 | else { | |||
1153 | Help(); | |||
1154 | return 2; | |||
1155 | } | |||
1156 | break; | |||
1157 | case 'c': /* number of client threads */ | |||
1158 | clients = atoi(opt->value); | |||
1159 | break; | |||
1160 | case 'w': /* minimum server worker threads */ | |||
1161 | workersMin = atoi(opt->value); | |||
1162 | break; | |||
1163 | case 'W': /* maximum server worker threads */ | |||
1164 | workersMax = atoi(opt->value); | |||
1165 | break; | |||
1166 | case 'e': /* program execution time in seconds */ | |||
1167 | execution = atoi(opt->value); | |||
1168 | break; | |||
1169 | case 's': /* server's address */ | |||
1170 | serverName = opt->value; | |||
1171 | break; | |||
1172 | case 'v': /* verbosity */ | |||
1173 | verbosity = IncrementVerbosity(); | |||
1174 | break; | |||
1175 | case 'd': /* debug mode */ | |||
1176 | debug_mode = PR_TRUE1; | |||
1177 | break; | |||
1178 | case 'p': /* pthread mode */ | |||
1179 | pthread_stats = PR_TRUE1; | |||
1180 | break; | |||
1181 | case 'h': | |||
1182 | default: | |||
1183 | Help(); | |||
1184 | return 2; | |||
1185 | } | |||
1186 | } | |||
1187 | PL_DestroyOptState(opt); | |||
1188 | ||||
1189 | if (0 != PL_strcmp(serverName, DEFAULT_SERVER"localhost")) { | |||
1190 | serverIsLocal = PR_FALSE0; | |||
1191 | } | |||
1192 | if (0 == execution) { | |||
1193 | execution = DEFAULT_EXECUTION_TIME10; | |||
1194 | } | |||
1195 | if (0 == workersMax) { | |||
1196 | workersMax = DEFAULT_WORKERS_MAX1; | |||
1197 | } | |||
1198 | if (0 == workersMin) { | |||
1199 | workersMin = DEFAULT_WORKERS_MIN1; | |||
1200 | } | |||
1201 | if (0 == accepting) { | |||
1202 | accepting = ALLOWED_IN_ACCEPT1; | |||
1203 | } | |||
1204 | if (0 == backlog) { | |||
1205 | backlog = DEFAULT_BACKLOG5; | |||
1206 | } | |||
1207 | ||||
1208 | if (workersMin > accepting) { | |||
1209 | accepting = workersMin; | |||
1210 | } | |||
1211 | ||||
1212 | PR_STDIO_INIT(); | |||
1213 | TimeOfDayMessage("Client/Server started at", PR_GetCurrentThread()); | |||
1214 | ||||
1215 | cltsrv_log_file = PR_NewLogModule("cltsrv_log"); | |||
1216 | MY_ASSERT(NULL != cltsrv_log_file)((((void*)0) != cltsrv_log_file)?((void)0):_MY_Assert("NULL != cltsrv_log_file" ,"../../../pr/tests/provider.c",1216)); | |||
1217 | boolean = PR_SetLogFile("cltsrv.log"); | |||
1218 | MY_ASSERT(boolean)((boolean)?((void)0):_MY_Assert("boolean","../../../pr/tests/provider.c" ,1218)); | |||
1219 | ||||
1220 | if (serverIsLocal) | |||
1221 | { | |||
1222 | /* Establish the server */ | |||
1223 | TEST_LOG(do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("main(0x%p): starting server\n", PR_GetCurrentThread()); } while (0) | |||
1224 | cltsrv_log_file, TEST_LOG_INFO,do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("main(0x%p): starting server\n", PR_GetCurrentThread()); } while (0) | |||
1225 | ("main(0x%p): starting server\n", PR_GetCurrentThread()))do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("main(0x%p): starting server\n", PR_GetCurrentThread()); } while (0); | |||
1226 | ||||
1227 | server = PR_NEWZAP(CSServer_t)((CSServer_t*)PR_Calloc(1, sizeof(CSServer_t))); | |||
1228 | PR_INIT_CLIST(&server->list)do { (&server->list)->next = (&server->list) ; (&server->list)->prev = (&server->list); } while (0); | |||
1229 | server->state = cs_init; | |||
1230 | server->ml = PR_NewLock(); | |||
1231 | server->backlog = backlog; | |||
1232 | server->port = DEFAULT_PORT13000 +100 +200; | |||
1233 | server->workers.minimum = workersMin; | |||
1234 | server->workers.maximum = workersMax; | |||
1235 | server->workers.accepting = accepting; | |||
1236 | server->stateChange = PR_NewCondVar(server->ml); | |||
1237 | server->pool.exiting = PR_NewCondVar(server->ml); | |||
1238 | server->pool.acceptComplete = PR_NewCondVar(server->ml); | |||
1239 | ||||
1240 | TEST_LOG(do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("main(0x%p): creating server thread\n", PR_GetCurrentThread ()); } while (0) | |||
1241 | cltsrv_log_file, TEST_LOG_NOTICE,do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("main(0x%p): creating server thread\n", PR_GetCurrentThread ()); } while (0) | |||
1242 | ("main(0x%p): creating server thread\n", PR_GetCurrentThread()))do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("main(0x%p): creating server thread\n", PR_GetCurrentThread ()); } while (0); | |||
1243 | ||||
1244 | rv = NewThread( | |||
1245 | Server, server, PR_PRIORITY_HIGH, PR_JOINABLE_THREAD); | |||
1246 | TEST_ASSERT(PR_SUCCESS == rv)((PR_SUCCESS == rv)?((void)0):_MY_Assert("PR_SUCCESS == rv","../../../pr/tests/provider.c" ,1246)); | |||
1247 | ||||
1248 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): waiting for server init\n", PR_GetCurrentThread ()); } while (0) | |||
1249 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): waiting for server init\n", PR_GetCurrentThread ()); } while (0) | |||
1250 | ("main(0x%p): waiting for server init\n", PR_GetCurrentThread()))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): waiting for server init\n", PR_GetCurrentThread ()); } while (0); | |||
1251 | ||||
1252 | PR_Lock(server->ml); | |||
1253 | while (server->state == cs_init) { | |||
1254 | PR_WaitCondVar(server->stateChange, PR_INTERVAL_NO_TIMEOUT0xffffffffUL); | |||
1255 | } | |||
1256 | PR_Unlock(server->ml); | |||
1257 | ||||
1258 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): server init complete (port #%d)\n", PR_GetCurrentThread (), server->port); } while (0) | |||
1259 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): server init complete (port #%d)\n", PR_GetCurrentThread (), server->port); } while (0) | |||
1260 | ("main(0x%p): server init complete (port #%d)\n",do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): server init complete (port #%d)\n", PR_GetCurrentThread (), server->port); } while (0) | |||
1261 | PR_GetCurrentThread(), server->port))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): server init complete (port #%d)\n", PR_GetCurrentThread (), server->port); } while (0); | |||
1262 | } | |||
1263 | ||||
1264 | if (clients != 0) | |||
1265 | { | |||
1266 | /* Create all of the clients */ | |||
1267 | PRHostEnt host; | |||
1268 | char buffer[BUFFER_SIZE1024]; | |||
1269 | client = (CSClient_t*)PR_CALLOC(clients * sizeof(CSClient_t))(PR_Calloc(1, (clients * sizeof(CSClient_t)))); | |||
1270 | ||||
1271 | TEST_LOG(do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): creating %d client threads\n", PR_GetCurrentThread (), clients); } while (0) | |||
1272 | cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): creating %d client threads\n", PR_GetCurrentThread (), clients); } while (0) | |||
1273 | ("main(0x%p): creating %d client threads\n",do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): creating %d client threads\n", PR_GetCurrentThread (), clients); } while (0) | |||
1274 | PR_GetCurrentThread(), clients))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): creating %d client threads\n", PR_GetCurrentThread (), clients); } while (0); | |||
1275 | ||||
1276 | if (!serverIsLocal) | |||
1277 | { | |||
1278 | rv = PR_GetHostByName(serverName, buffer, BUFFER_SIZE1024, &host); | |||
1279 | if (PR_SUCCESS != rv) | |||
1280 | { | |||
1281 | PL_FPrintError(PR_STDERRPR_GetSpecialFD(PR_StandardError), "PR_GetHostByName"); | |||
1282 | return 2; | |||
1283 | } | |||
1284 | } | |||
1285 | ||||
1286 | for (index = 0; index < clients; ++index) | |||
1287 | { | |||
1288 | client[index].state = cs_init; | |||
1289 | client[index].ml = PR_NewLock(); | |||
1290 | if (serverIsLocal) | |||
1291 | { | |||
1292 | (void)PR_InitializeNetAddr( | |||
1293 | PR_IpAddrLoopback, DEFAULT_PORT13000 +100 +200, | |||
1294 | &client[index].serverAddress); | |||
1295 | } | |||
1296 | else | |||
1297 | { | |||
1298 | (void)PR_EnumerateHostEnt( | |||
1299 | 0, &host, DEFAULT_PORT13000 +100 +200, &client[index].serverAddress); | |||
1300 | } | |||
1301 | client[index].stateChange = PR_NewCondVar(client[index].ml); | |||
1302 | TEST_LOG(do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("main(0x%p): creating client threads\n", PR_GetCurrentThread ()); } while (0) | |||
1303 | cltsrv_log_file, TEST_LOG_INFO,do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("main(0x%p): creating client threads\n", PR_GetCurrentThread ()); } while (0) | |||
1304 | ("main(0x%p): creating client threads\n", PR_GetCurrentThread()))do { if (debug_mode || (TEST_LOG_INFO <= verbosity)) printf ("main(0x%p): creating client threads\n", PR_GetCurrentThread ()); } while (0); | |||
1305 | rv = NewThread( | |||
1306 | Client, &client[index], PR_PRIORITY_NORMAL, PR_JOINABLE_THREAD); | |||
1307 | TEST_ASSERT(PR_SUCCESS == rv)((PR_SUCCESS == rv)?((void)0):_MY_Assert("PR_SUCCESS == rv","../../../pr/tests/provider.c" ,1307)); | |||
1308 | PR_Lock(client[index].ml); | |||
1309 | while (cs_init == client[index].state) { | |||
1310 | PR_WaitCondVar(client[index].stateChange, PR_INTERVAL_NO_TIMEOUT0xffffffffUL); | |||
1311 | } | |||
1312 | PR_Unlock(client[index].ml); | |||
1313 | } | |||
1314 | } | |||
1315 | ||||
1316 | /* Then just let them go at it for a bit */ | |||
1317 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("main(0x%p): waiting for execution interval (%d seconds)\n" , PR_GetCurrentThread(), execution); } while (0) | |||
1318 | cltsrv_log_file, TEST_LOG_ALWAYS,do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("main(0x%p): waiting for execution interval (%d seconds)\n" , PR_GetCurrentThread(), execution); } while (0) | |||
1319 | ("main(0x%p): waiting for execution interval (%d seconds)\n",do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("main(0x%p): waiting for execution interval (%d seconds)\n" , PR_GetCurrentThread(), execution); } while (0) | |||
1320 | PR_GetCurrentThread(), execution))do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("main(0x%p): waiting for execution interval (%d seconds)\n" , PR_GetCurrentThread(), execution); } while (0); | |||
1321 | ||||
1322 | WaitForCompletion(execution); | |||
1323 | ||||
1324 | TimeOfDayMessage("Shutting down", PR_GetCurrentThread()); | |||
1325 | ||||
1326 | if (clients != 0) | |||
1327 | { | |||
1328 | for (index = 0; index < clients; ++index) | |||
1329 | { | |||
1330 | TEST_LOG(cltsrv_log_file, TEST_LOG_STATUS,do { if (debug_mode || (TEST_LOG_STATUS <= verbosity)) printf ("main(0x%p): notifying client(0x%p) to stop\n", PR_GetCurrentThread (), client[index].thread); } while (0) | |||
1331 | ("main(0x%p): notifying client(0x%p) to stop\n",do { if (debug_mode || (TEST_LOG_STATUS <= verbosity)) printf ("main(0x%p): notifying client(0x%p) to stop\n", PR_GetCurrentThread (), client[index].thread); } while (0) | |||
1332 | PR_GetCurrentThread(), client[index].thread))do { if (debug_mode || (TEST_LOG_STATUS <= verbosity)) printf ("main(0x%p): notifying client(0x%p) to stop\n", PR_GetCurrentThread (), client[index].thread); } while (0); | |||
1333 | ||||
1334 | PR_Lock(client[index].ml); | |||
1335 | if (cs_run == client[index].state) | |||
1336 | { | |||
1337 | client[index].state = cs_stop; | |||
1338 | PR_Interrupt(client[index].thread); | |||
1339 | while (cs_stop == client[index].state) | |||
1340 | PR_WaitCondVar( | |||
1341 | client[index].stateChange, PR_INTERVAL_NO_TIMEOUT0xffffffffUL); | |||
1342 | } | |||
1343 | PR_Unlock(client[index].ml); | |||
1344 | ||||
1345 | TEST_LOG(cltsrv_log_file, TEST_LOG_VERBOSE,do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): joining client(0x%p)\n", PR_GetCurrentThread() , client[index].thread); } while (0) | |||
1346 | ("main(0x%p): joining client(0x%p)\n",do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): joining client(0x%p)\n", PR_GetCurrentThread() , client[index].thread); } while (0) | |||
1347 | PR_GetCurrentThread(), client[index].thread))do { if (debug_mode || (TEST_LOG_VERBOSE <= verbosity)) printf ("main(0x%p): joining client(0x%p)\n", PR_GetCurrentThread() , client[index].thread); } while (0); | |||
1348 | ||||
1349 | joinStatus = JoinThread(client[index].thread); | |||
1350 | TEST_ASSERT(PR_SUCCESS == joinStatus)((PR_SUCCESS == joinStatus)?((void)0):_MY_Assert("PR_SUCCESS == joinStatus" ,"../../../pr/tests/provider.c",1350)); | |||
1351 | PR_DestroyCondVar(client[index].stateChange); | |||
1352 | PR_DestroyLock(client[index].ml); | |||
1353 | } | |||
1354 | PR_DELETE(client){ PR_Free(client); (client) = ((void*)0); }; | |||
1355 | } | |||
1356 | ||||
1357 | if (NULL((void*)0) != server) | |||
1358 | { | |||
1359 | /* All clients joined - retrieve the server */ | |||
1360 | TEST_LOG(do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("main(0x%p): notifying server(0x%p) to stop\n", PR_GetCurrentThread (), server->thread); } while (0) | |||
1361 | cltsrv_log_file, TEST_LOG_NOTICE,do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("main(0x%p): notifying server(0x%p) to stop\n", PR_GetCurrentThread (), server->thread); } while (0) | |||
1362 | ("main(0x%p): notifying server(0x%p) to stop\n",do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("main(0x%p): notifying server(0x%p) to stop\n", PR_GetCurrentThread (), server->thread); } while (0) | |||
1363 | PR_GetCurrentThread(), server->thread))do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("main(0x%p): notifying server(0x%p) to stop\n", PR_GetCurrentThread (), server->thread); } while (0); | |||
1364 | ||||
1365 | PR_Lock(server->ml); | |||
1366 | server->state = cs_stop; | |||
1367 | PR_Interrupt(server->thread); | |||
1368 | while (cs_exit != server->state) { | |||
1369 | PR_WaitCondVar(server->stateChange, PR_INTERVAL_NO_TIMEOUT0xffffffffUL); | |||
1370 | } | |||
1371 | PR_Unlock(server->ml); | |||
1372 | ||||
1373 | TEST_LOG(do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("main(0x%p): joining server(0x%p)\n", PR_GetCurrentThread() , server->thread); } while (0) | |||
1374 | cltsrv_log_file, TEST_LOG_NOTICE,do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("main(0x%p): joining server(0x%p)\n", PR_GetCurrentThread() , server->thread); } while (0) | |||
1375 | ("main(0x%p): joining server(0x%p)\n",do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("main(0x%p): joining server(0x%p)\n", PR_GetCurrentThread() , server->thread); } while (0) | |||
1376 | PR_GetCurrentThread(), server->thread))do { if (debug_mode || (TEST_LOG_NOTICE <= verbosity)) printf ("main(0x%p): joining server(0x%p)\n", PR_GetCurrentThread() , server->thread); } while (0); | |||
1377 | joinStatus = JoinThread(server->thread); | |||
1378 | TEST_ASSERT(PR_SUCCESS == joinStatus)((PR_SUCCESS == joinStatus)?((void)0):_MY_Assert("PR_SUCCESS == joinStatus" ,"../../../pr/tests/provider.c",1378)); | |||
1379 | ||||
1380 | PR_DestroyCondVar(server->stateChange); | |||
1381 | PR_DestroyCondVar(server->pool.exiting); | |||
1382 | PR_DestroyCondVar(server->pool.acceptComplete); | |||
1383 | PR_DestroyLock(server->ml); | |||
1384 | PR_DELETE(server){ PR_Free(server); (server) = ((void*)0); }; | |||
1385 | } | |||
1386 | ||||
1387 | TEST_LOG(do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("main(0x%p): test complete\n", PR_GetCurrentThread()); } while (0) | |||
1388 | cltsrv_log_file, TEST_LOG_ALWAYS,do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("main(0x%p): test complete\n", PR_GetCurrentThread()); } while (0) | |||
1389 | ("main(0x%p): test complete\n", PR_GetCurrentThread()))do { if (debug_mode || (TEST_LOG_ALWAYS <= verbosity)) printf ("main(0x%p): test complete\n", PR_GetCurrentThread()); } while (0); | |||
1390 | ||||
1391 | if (thread_provider == thread_win32) { | |||
1392 | thread_type = "\nWin32 Thread Statistics\n"; | |||
1393 | } | |||
1394 | else if (thread_provider == thread_pthread) { | |||
1395 | thread_type = "\npthread Statistics\n"; | |||
1396 | } | |||
1397 | else if (thread_provider == thread_sproc) { | |||
1398 | thread_type = "\nsproc Statistics\n"; | |||
1399 | } | |||
1400 | else { | |||
1401 | PR_ASSERT(thread_provider == thread_nspr)((thread_provider == thread_nspr)?((void)0):PR_Assert("thread_provider == thread_nspr" ,"../../../pr/tests/provider.c",1401)); | |||
1402 | thread_type = "\nPRThread Statistics\nn"; | |||
1403 | } | |||
1404 | ||||
1405 | PT_FPrintStats(debug_out, thread_type); | |||
1406 | ||||
1407 | TimeOfDayMessage("Test exiting at", PR_GetCurrentThread()); | |||
1408 | PR_Cleanup(); | |||
1409 | return 0; | |||
1410 | } /* main */ | |||
1411 | ||||
1412 | /* cltsrv.c */ |