version 1.2, 2005/02/04 08:39:07
|
version 1.7, 2005/02/21 21:27:59
|
|
|
/* | /* |
* Unit tests for named pipe functions in Wine |
* Unit tests for 32-bit socket functions in Wine |
* | * |
* Copyright (c) 2002 Dan Kegel |
* Copyright (c) 2005 Thomas Kho, Fredy Garcia, Douglas Rosenberg |
* | * |
* This library is free software; you can redistribute it and/or | * This library is free software; you can redistribute it and/or |
* modify it under the terms of the GNU Lesser General Public | * modify it under the terms of the GNU Lesser General Public |
|
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA | * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA |
*/ | */ |
| |
#include <assert.h> |
|
#include <stdarg.h> |
|
#include <stdlib.h> |
|
#include <stdio.h> | #include <stdio.h> |
#include <time.h> |
|
| |
#include <windef.h> |
#include <windows.h> |
#include <winbase.h> |
|
#include <winsock.h> | #include <winsock.h> |
|
#include <wtypes.h> |
|
#include <winerror.h> |
| |
#ifndef STANDALONE | #ifndef STANDALONE |
#include "wine/test.h" | #include "wine/test.h" |
|
|
#define todo_wine | #define todo_wine |
#endif | #endif |
| |
#include <wtypes.h> |
#define NUM_CLIENTS 1 |
#include <winerror.h> |
// amount of data to transfer from each client to server |
|
#define TRANSFER_SIZE 1000000 |
|
|
|
int clientsDone = 0; |
|
|
|
struct TestParams { |
|
int serverSock; |
|
int serverType; |
|
int serverPort; |
|
int clientPort[NUM_CLIENTS]; |
|
}; |
|
|
|
struct ClientParams { |
|
struct TestParams *test; |
|
int clientNum; // 1...NUM_CLIENTS |
|
}; |
|
|
|
static void test_Startup(void); |
|
void BlockingClient(int *serverPort); |
|
void BlockingServer(int *port); |
|
static void test_ClientServerBlocking_1(void); |
|
static void test_Startup(void); |
| |
static void test_NamedPipe_2(void) |
// StartNetworkApp creates socket sock of type type and returns assigned port number in addr. |
|
void StartNetworkApp(int type, SOCKET *sock, SOCKADDR_IN *addr) |
{ | { |
// something simple |
SOCKADDR_IN tmpAddr; |
printf("Hello, Worldh\n"); |
int tmpAddrSize; |
//ok(SetEvent( alarm_event ), "SetEvent\n"); |
|
//CloseHandle( alarm_event ); |
*sock = socket(AF_INET, type, 0); |
//trace("test_NamedPipe_2 returning\n"); |
if (*sock == INVALID_SOCKET) { |
|
ok( 0 , "Error in socket()"); |
|
WSACleanup(); |
|
exit(0); |
|
} |
|
trace("socket() ok\n"); |
|
|
|
addr->sin_family = AF_INET; |
|
addr->sin_addr.s_addr = INADDR_ANY; |
|
addr->sin_port = htons(0); |
|
|
|
if( bind(*sock, (const SOCKADDR *) addr, sizeof(*addr)) ) { |
|
ok( 0 , "Error binding client to socket"); |
|
WSACleanup(); |
|
exit(0); |
} | } |
| |
|
// get port number |
|
tmpAddrSize = sizeof(tmpAddr); |
|
getsockname(*sock, (SOCKADDR *) &tmpAddr, &tmpAddrSize); |
|
addr->sin_port = tmpAddr.sin_port; |
|
} |
|
|
|
void BlockingClient(int *serverPort) |
|
{ |
|
SOCKET sock; |
|
SOCKADDR_IN client, server; |
|
HOSTENT *hp; |
|
StartNetworkApp(SOCK_STREAM, &sock, &client); |
|
|
|
hp = gethostbyname("localhost"); |
|
|
|
while(*serverPort == 0) ; |
|
|
|
// network code here |
|
server.sin_family = AF_INET; |
|
server.sin_addr = *(struct in_addr *) hp->h_addr; |
|
server.sin_port = *serverPort; |
|
|
|
trace("blocking client done\n"); |
|
clientsDone++; |
|
} |
|
|
|
void BlockingServer(int *port) |
|
{ |
|
SOCKET sock; |
|
SOCKADDR_IN server; |
|
StartNetworkApp(SOCK_STREAM, &sock, &server); |
|
*port = server.sin_port; |
|
|
|
// network code here |
|
|
|
trace("blocking server done\n"); |
|
} |
|
|
|
static void test_ClientServerBlocking_1(void) |
|
{ |
|
int serverPort = 0; |
|
HANDLE Thread1, Thread2; |
|
DWORD ThreadId1, ThreadId2; |
|
Thread1 = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) &BlockingClient, &serverPort, 0, &ThreadId1); |
|
Thread2 = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) &BlockingServer, &serverPort, 0, &ThreadId2); |
|
trace("test_ClientServerBlocking_1 done\n"); |
|
} |
|
|
|
static void test_Startup(void) |
|
{ |
|
// initialize application |
|
WSADATA wsaData; |
|
int wsastartup_result = WSAStartup(MAKEWORD(1,1), &wsaData); |
|
if ( (LOBYTE(wsaData.wVersion) != 1) && (HIBYTE(wsaData.wVersion) != 1) ) |
|
{ |
|
ok( 0 , "WSAStartup returns an incompatible sockets version"); |
|
WSACleanup(); |
|
exit(0); |
|
} |
|
|
|
ok((wsastartup_result == NO_ERROR), "Error in WSAStartup()"); |
|
} |
|
|
|
|
START_TEST(wsock32_main) | START_TEST(wsock32_main) |
{ | { |
trace("simple test:\n"); |
trace("test 1 of 2:\n"); |
//test_DisconnectNamedPipe(); |
test_Startup(); |
//trace("test 2 of 4:\n"); |
trace("test 2 of 2:\n"); |
//test_CreateNamedPipe_instances_must_match(); |
test_ClientServerBlocking_1(); |
//trace("test 3 of 4:\n"); |
|
test_NamedPipe_2(); |
|
//trace("test 4 of 4:\n"); |
|
//test_CreateNamedPipe(PIPE_TYPE_BYTE); |
|
//trace("all tests done\n"); |
|
//test_CreateNamedPipe(PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE); |
|
trace("all tests done\n"); | trace("all tests done\n"); |
|
while (clientsDone != NUM_CLIENTS) |
|
; |
} | } |