version 1.8, 2005/02/22 00:07:14
|
version 1.9, 2005/02/22 02:19:39
|
|
|
| |
static void test_ClientServerBlocking_1(void) | static void test_ClientServerBlocking_1(void) |
{ | { |
|
int ThreadIndex = 0; |
int serverPort = 0; // I think the server port would work better as a #DEFINE rather than a variable that gets passed around everywhere | int serverPort = 0; // I think the server port would work better as a #DEFINE rather than a variable that gets passed around everywhere |
HANDLE Thread1, Thread2; |
HANDLE ServerThread; |
DWORD ThreadId1, ThreadId2; |
DWORD ServerThreadId; |
Thread1 = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) &BlockingClient, &serverPort, 0, &ThreadId1); |
DWORD *ClientThreadIds; |
Thread2 = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) &BlockingServer, &serverPort, 0, &ThreadId2); |
HANDLE *ClientThreads; |
|
|
|
ServerThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) &BlockingClient, &serverPort, 0, &ServerThreadId); |
|
|
|
ClientThreads = malloc(sizeof(Handle) * NUM_CLIENTS); |
|
memset(ClientThreads, 0, sizeof(Handle) * NUM_CLIENTS) |
|
|
|
ClientThreadIds = malloc(sizeof(DWORD) * NUM_CLIENTS); |
|
memset(ClientThreadIds, 0, sizeof(DWORD) * NUM_CLIENTS); |
|
|
|
for(ThreadIndex = 0; ThreadIndex < NUM_CLIENTS; ThreadIndex++) { |
|
ClientThreads[ThreadIndex] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) &BlockingServer, &serverPort, 0, &ClientThreadIds[ThreadIndex]); |
|
} |
|
|
trace("test_ClientServerBlocking_1 done\n"); | trace("test_ClientServerBlocking_1 done\n"); |
} | } |
| |