version 1.8, 2005/02/22 00:07:14
|
version 1.10, 2005/02/22 02:28:50
|
|
|
void ProcessConnection(SOCKET ConnectedSocket) | void ProcessConnection(SOCKET ConnectedSocket) |
{ | { |
// this will handle all connections to the server, it's in its own function to allow for multithreading | // this will handle all connections to the server, it's in its own function to allow for multithreading |
close(ConnectedSocket); |
int bClosed; |
|
bClosed = close(ConnectedSocket); |
|
//ok(bClosed,"Error closing socket"); |
} | } |
| |
void BlockingServer(int *port) | void BlockingServer(int *port) |
{ | { |
SOCKET sock; |
HANDLE* ServerThreads; |
|
DWORD* ServerThreadIDs; |
|
int ThreadIndex = 0; |
|
|
|
SOCKET sock, ConnectedSocket; |
SOCKADDR_IN server; | SOCKADDR_IN server; |
StartNetworkApp(SOCK_STREAM, &sock, &server); | StartNetworkApp(SOCK_STREAM, &sock, &server); |
*port = server.sin_port; | *port = server.sin_port; |
| |
Handle* ServerThreads; |
ServerThreads = malloc(sizeof(HANDLE) * NUM_CLIENTS); |
ServerThreads = malloc(sizeof(Handle) * NUM_CLIENTS); |
memset(ServerThreads, 0, sizeof(HANDLE) * NUM_CLIENTS); |
memset(ServerThreads, 0, sizeof(Handle) * NUM_CLIENTS) |
|
| |
DWORD* ServerThreadIDs; |
|
ServerThreadIDs = malloc(sizeof(DWORD) * NUM_CLIENTS); | ServerThreadIDs = malloc(sizeof(DWORD) * NUM_CLIENTS); |
memset(ServerThreadIDs, 0, sizeof(DWORD) * NUM_CLIENTS); | memset(ServerThreadIDs, 0, sizeof(DWORD) * NUM_CLIENTS); |
| |
int ThreadIndex = 0; |
|
|
|
//SOCKADDR_IN RemoteAddress; | //SOCKADDR_IN RemoteAddress; |
| |
// condition for how long we want the test to run goes here | // condition for how long we want the test to run goes here |
{ | { |
ok(listen(sock, 5) != SOCKET_ERROR, "error listening on socket"); | ok(listen(sock, 5) != SOCKET_ERROR, "error listening on socket"); |
ok(INVALID_SOCK != (ConnectedSocket = accept(sock)), "error accepting socket"); // this can be modified to include the address of the remote socket |
//ok(INVALID_SOCKET != (ConnectedSocket = accept(sock)), "error accepting socket"); // this can be modified to include the address of the remote socket |
ServerThreads[ThreadIndex] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) &ProcessConnection, ConnectedSocket, 0, &ServerThreadIDs[ThreadIndex]); |
ServerThreads[ThreadIndex] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) &ProcessConnection, &ConnectedSocket, 0, &ServerThreadIDs[ThreadIndex]); |
// the line above needs to be cleaned up, it currently copies the connected socket into the called function | // the line above needs to be cleaned up, it currently copies the connected socket into the called function |
// and will then overwrite the local variable. I'm thinking maybe it needs an array of sockets to handle this | // and will then overwrite the local variable. I'm thinking maybe it needs an array of sockets to handle this |
// and then it can pass the address of the socket. | // and then it can pass the address of the socket. |
|
|
| |
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"); |
} | } |
| |