version 1.3, 2005/02/06 23:13:24
|
version 1.4, 2005/02/20 22:33:10
|
|
|
* 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 <stdio.h> | #include <stdio.h> |
| |
#include <windows.h> | #include <windows.h> |
#include <msvcrt/process.h> |
#include <winsock.h> |
#include <winsock2.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 5 |
//#include <winerror.h> |
|
|
struct TestParams { |
|
int sock; |
|
int type; |
|
int serverPort; |
|
int clientPort[NUM_CLIENTS]; |
|
}; |
|
|
|
struct ClientParams { |
|
struct TestParams *test; |
|
int clientNum; // 1...NUM_CLIENTS |
|
}; |
|
|
|
static void test_Startup(void); |
|
void BlockingClient(); |
|
void BlockingServer(); |
|
static void test_ClientServerBlocking_1(void); |
|
static void test_Startup(void); |
|
|
|
void BlockingClient() |
|
{ |
|
SOCKET sock; |
|
SOCKADDR_IN client; |
|
|
|
sock = socket(AF_INET, SOCK_DGRAM, 0); |
|
if (sock == INVALID_SOCKET) { |
|
ok( 0 , "Error in socket()"); |
|
WSACleanup(); |
|
exit(0); |
|
} |
|
trace("socket() ok\n"); |
|
|
|
client.sin_family = AF_INET; |
|
client.sin_addr.s_addr = INADDR_ANY; |
|
client.sin_port = htons(0); |
|
|
|
bind(sock, (const SOCKADDR *) &client, sizeof(client)); |
|
|
|
|
| |
static void test_NamedPipe_2(void) |
|
{ |
|
// something simple |
|
printf("Hello, World\n"); |
|
//while(1) | //while(1) |
printf("Main Thread\n"); |
{ |
//ok(SetEvent( alarm_event ), "SetEvent\n"); |
printf("Thread 1\n"); |
//CloseHandle( alarm_event ); |
} |
//trace("test_NamedPipe_2 returning\n"); |
|
} | } |
| |
static void test_Initialization(void) |
void BlockingServer() |
{ | { |
// initialize application |
trace("blocking server\n"); |
WSADATA mywsadata; |
|
int wsastartup_result = WSAStartup(MAKEWORD(2,2), &mywsadata); |
|
ok((wsastartup_result != NO_ERROR), "Error in WSAStartup()"); |
|
|
|
} | } |
| |
void SampleThread1() |
static void test_ClientServerBlocking_1(void) |
{ | { |
while(1) |
HANDLE Thread1, Thread2; |
{ |
DWORD ThreadId1, ThreadId2; |
printf("Thread 1\n"); |
Thread1 = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) &BlockingClient, NULL, 0, &ThreadId1); |
} |
Thread2 = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) &BlockingServer, NULL, 0, &ThreadId2); |
|
//trace("In test_ClientServerBlocking_1\n"); |
} | } |
| |
void SampleThread2() |
static void test_Startup(void) |
{ | { |
while(1) |
// initialize application |
|
WSADATA wsaData; |
|
int wsastartup_result = WSAStartup(MAKEWORD(1,1), &wsaData); |
|
if ( (LOBYTE(wsaData.wVersion) != 1) && (HIBYTE(wsaData.wVersion) != 1) ) |
{ | { |
printf("Thread 2\n"); |
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) |
{ | { |
//_beginthread( SampleThread1, 0, NULL ); |
trace("test 1 of 2:\n"); |
//_beginthread( SampleThread2, 0, NULL ); |
test_Startup(); |
trace("simple test:\n"); |
trace("test 2 of 2:\n"); |
test_Initialization(); |
test_ClientServerBlocking_1(); |
//test_DisconnectNamedPipe(); |
|
//trace("test 2 of 4:\n"); |
|
//test_CreateNamedPipe_instances_must_match(); |
|
//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"); |
} | } |