зеркало из https://github.com/mozilla/gecko-dev.git
2287 строки
70 KiB
C
2287 строки
70 KiB
C
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
|
|
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
|
|
/***********************************************************************
|
|
**
|
|
** Name: socket.c
|
|
**
|
|
** Description: Test socket functionality.
|
|
**
|
|
** Modification History:
|
|
*/
|
|
#include "primpl.h"
|
|
|
|
#include "plgetopt.h"
|
|
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
#include <errno.h>
|
|
#ifdef XP_UNIX
|
|
#include <sys/mman.h>
|
|
#endif
|
|
#if defined(_PR_PTHREADS)
|
|
#include <pthread.h>
|
|
#endif
|
|
|
|
#ifdef WIN32
|
|
#include <process.h>
|
|
#endif
|
|
|
|
static int _debug_on = 0;
|
|
static int test_cancelio = 0;
|
|
|
|
#include "obsolete/prsem.h"
|
|
|
|
#ifdef XP_PC
|
|
#define mode_t int
|
|
#endif
|
|
|
|
#define DPRINTF(arg) if (_debug_on) printf arg
|
|
|
|
#ifdef XP_PC
|
|
char *TEST_DIR = "prdir";
|
|
char *SMALL_FILE_NAME = "prsmallf";
|
|
char *LARGE_FILE_NAME = "prlargef";
|
|
#else
|
|
char *TEST_DIR = "./tmp-prsocket_test_dir";
|
|
char *SMALL_FILE_NAME = "./tmp-prsocket_test_dir/small_file";
|
|
char *LARGE_FILE_NAME = "./tmp-prsocket_test_dir/large_file";
|
|
#endif
|
|
#define SMALL_FILE_SIZE (3 * 1024) /* 3 KB */
|
|
#define SMALL_FILE_OFFSET_1 (512)
|
|
#define SMALL_FILE_LEN_1 (1 * 1024) /* 1 KB */
|
|
#define SMALL_FILE_OFFSET_2 (75)
|
|
#define SMALL_FILE_LEN_2 (758)
|
|
#define SMALL_FILE_OFFSET_3 (1024)
|
|
#define SMALL_FILE_LEN_3 (SMALL_FILE_SIZE - SMALL_FILE_OFFSET_3)
|
|
#define SMALL_FILE_HEADER_SIZE (64) /* 64 bytes */
|
|
#define SMALL_FILE_TRAILER_SIZE (128) /* 128 bytes */
|
|
|
|
#define LARGE_FILE_SIZE (3 * 1024 * 1024) /* 3 MB */
|
|
#define LARGE_FILE_OFFSET_1 (0)
|
|
#define LARGE_FILE_LEN_1 (2 * 1024 * 1024) /* 2 MB */
|
|
#define LARGE_FILE_OFFSET_2 (64)
|
|
#define LARGE_FILE_LEN_2 (1 * 1024 * 1024 + 75)
|
|
#define LARGE_FILE_OFFSET_3 (2 * 1024 * 1024 - 128)
|
|
#define LARGE_FILE_LEN_3 (LARGE_FILE_SIZE - LARGE_FILE_OFFSET_3)
|
|
#define LARGE_FILE_OFFSET_4 PR_GetPageSize()
|
|
#define LARGE_FILE_LEN_4 769
|
|
#define LARGE_FILE_HEADER_SIZE (512)
|
|
#define LARGE_FILE_TRAILER_SIZE (64)
|
|
|
|
#define BUF_DATA_SIZE (2 * 1024)
|
|
#define TCP_MESG_SIZE 1024
|
|
/*
|
|
* set UDP datagram size small enough that datagrams sent to a port on the
|
|
* local host will not be lost
|
|
*/
|
|
#define UDP_DGRAM_SIZE 128
|
|
#define NUM_TCP_CLIENTS 5 /* for a listen queue depth of 5 */
|
|
#define NUM_UDP_CLIENTS 10
|
|
|
|
#define NUM_TRANSMITFILE_CLIENTS 4
|
|
|
|
#define NUM_TCP_CONNECTIONS_PER_CLIENT 5
|
|
#define NUM_TCP_MESGS_PER_CONNECTION 10
|
|
#define NUM_UDP_DATAGRAMS_PER_CLIENT 5
|
|
#define TCP_SERVER_PORT 10000
|
|
#define UDP_SERVER_PORT TCP_SERVER_PORT
|
|
#define SERVER_MAX_BIND_COUNT 100
|
|
|
|
#ifdef WINCE
|
|
#define perror(s)
|
|
#endif
|
|
|
|
static PRInt32 num_tcp_clients = NUM_TCP_CLIENTS;
|
|
static PRInt32 num_udp_clients = NUM_UDP_CLIENTS;
|
|
static PRInt32 num_transmitfile_clients = NUM_TRANSMITFILE_CLIENTS;
|
|
static PRInt32 num_tcp_connections_per_client = NUM_TCP_CONNECTIONS_PER_CLIENT;
|
|
static PRInt32 tcp_mesg_size = TCP_MESG_SIZE;
|
|
static PRInt32 num_tcp_mesgs_per_connection = NUM_TCP_MESGS_PER_CONNECTION;
|
|
static PRInt32 num_udp_datagrams_per_client = NUM_UDP_DATAGRAMS_PER_CLIENT;
|
|
static PRInt32 udp_datagram_size = UDP_DGRAM_SIZE;
|
|
|
|
static PRInt32 thread_count;
|
|
PRUint16 server_domain = PR_AF_INET, client_domain = PR_AF_INET;
|
|
|
|
/* an I/O layer that uses the emulated senfile method */
|
|
static PRDescIdentity emuSendFileIdentity;
|
|
static PRIOMethods emuSendFileMethods;
|
|
|
|
int failed_already=0;
|
|
typedef struct buffer {
|
|
char data[BUF_DATA_SIZE];
|
|
} buffer;
|
|
|
|
PRNetAddr tcp_server_addr, udp_server_addr;
|
|
|
|
typedef struct Serve_Client_Param {
|
|
PRFileDesc *sockfd; /* socket to read from/write to */
|
|
PRInt32 datalen; /* bytes of data transfered in each read/write */
|
|
} Serve_Client_Param;
|
|
|
|
typedef struct Server_Param {
|
|
PRSemaphore *addr_sem; /* sem to post on, after setting up the address */
|
|
PRMonitor *exit_mon; /* monitor to signal on exit */
|
|
PRInt32 *exit_counter; /* counter to decrement, before exit */
|
|
PRInt32 datalen; /* bytes of data transfered in each read/write */
|
|
} Server_Param;
|
|
|
|
|
|
typedef struct Client_Param {
|
|
PRNetAddr server_addr;
|
|
PRMonitor *exit_mon; /* monitor to signal on exit */
|
|
PRInt32 *exit_counter; /* counter to decrement, before exit */
|
|
PRInt32 datalen;
|
|
PRInt32 udp_connect; /* if set clients connect udp sockets */
|
|
} Client_Param;
|
|
|
|
/* the sendfile method in emuSendFileMethods */
|
|
static PRInt32 PR_CALLBACK
|
|
emu_SendFile(PRFileDesc *sd, PRSendFileData *sfd,
|
|
PRTransmitFileFlags flags, PRIntervalTime timeout)
|
|
{
|
|
return PR_EmulateSendFile(sd, sfd, flags, timeout);
|
|
}
|
|
|
|
/* the transmitfile method in emuSendFileMethods */
|
|
static PRInt32 PR_CALLBACK
|
|
emu_TransmitFile(PRFileDesc *sd, PRFileDesc *fd, const void *headers,
|
|
PRInt32 hlen, PRTransmitFileFlags flags, PRIntervalTime timeout)
|
|
{
|
|
PRSendFileData sfd;
|
|
|
|
sfd.fd = fd;
|
|
sfd.file_offset = 0;
|
|
sfd.file_nbytes = 0;
|
|
sfd.header = headers;
|
|
sfd.hlen = hlen;
|
|
sfd.trailer = NULL;
|
|
sfd.tlen = 0;
|
|
return emu_SendFile(sd, &sfd, flags, timeout);
|
|
}
|
|
|
|
/*
|
|
* readn
|
|
* read data from sockfd into buf
|
|
*/
|
|
static PRInt32
|
|
readn(PRFileDesc *sockfd, char *buf, int len)
|
|
{
|
|
int rem;
|
|
int bytes;
|
|
int offset = 0;
|
|
int err;
|
|
PRIntervalTime timeout = PR_INTERVAL_NO_TIMEOUT;
|
|
|
|
if (test_cancelio) {
|
|
timeout = PR_SecondsToInterval(2);
|
|
}
|
|
|
|
for (rem=len; rem; offset += bytes, rem -= bytes) {
|
|
DPRINTF(("thread = 0x%lx: calling PR_Recv, bytes = %d\n",
|
|
PR_GetCurrentThread(), rem));
|
|
retry:
|
|
bytes = PR_Recv(sockfd, buf + offset, rem, 0,
|
|
timeout);
|
|
DPRINTF(("thread = 0x%lx: returning from PR_Recv, bytes = %d\n",
|
|
PR_GetCurrentThread(), bytes));
|
|
if (bytes < 0) {
|
|
#ifdef WINNT
|
|
printf("PR_Recv: error = %d oserr = %d\n",(err = PR_GetError()),
|
|
PR_GetOSError());
|
|
if ((test_cancelio) && (err == PR_IO_TIMEOUT_ERROR)) {
|
|
if (PR_NT_CancelIo(sockfd) != PR_SUCCESS) {
|
|
printf("PR_NT_CancelIO: error = %d\n",PR_GetError());
|
|
}
|
|
timeout = PR_INTERVAL_NO_TIMEOUT;
|
|
goto retry;
|
|
}
|
|
#endif
|
|
return -1;
|
|
}
|
|
}
|
|
return len;
|
|
}
|
|
|
|
/*
|
|
* writen
|
|
* write data from buf to sockfd
|
|
*/
|
|
static PRInt32
|
|
writen(PRFileDesc *sockfd, char *buf, int len)
|
|
{
|
|
int rem;
|
|
int bytes;
|
|
int offset = 0;
|
|
|
|
for (rem=len; rem; offset += bytes, rem -= bytes) {
|
|
DPRINTF(("thread = 0x%lx: calling PR_Send, bytes = %d\n",
|
|
PR_GetCurrentThread(), rem));
|
|
bytes = PR_Send(sockfd, buf + offset, rem, 0,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
DPRINTF(("thread = 0x%lx: returning from PR_Send, bytes = %d\n",
|
|
PR_GetCurrentThread(), bytes));
|
|
if (bytes <= 0) {
|
|
return -1;
|
|
}
|
|
}
|
|
return len;
|
|
}
|
|
|
|
/*
|
|
* Serve_Client
|
|
* Thread, started by the server, for serving a client connection.
|
|
* Reads data from socket and writes it back, unmodified, and
|
|
* closes the socket
|
|
*/
|
|
static void PR_CALLBACK
|
|
Serve_Client(void *arg)
|
|
{
|
|
Serve_Client_Param *scp = (Serve_Client_Param *) arg;
|
|
PRFileDesc *sockfd;
|
|
buffer *in_buf;
|
|
PRInt32 bytes, j;
|
|
|
|
sockfd = scp->sockfd;
|
|
bytes = scp->datalen;
|
|
in_buf = PR_NEW(buffer);
|
|
if (in_buf == NULL) {
|
|
fprintf(stderr,"prsocket_test: failed to alloc buffer struct\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
|
|
|
|
for (j = 0; j < num_tcp_mesgs_per_connection; j++) {
|
|
/*
|
|
* Read data from client and send it back to the client unmodified
|
|
*/
|
|
if (readn(sockfd, in_buf->data, bytes) < bytes) {
|
|
fprintf(stderr,"prsocket_test: ERROR - Serve_Client:readn\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
/* Shutdown only RCV will cause error on Symbian OS */
|
|
/*
|
|
* shutdown reads, after the last read
|
|
*/
|
|
if (j == num_tcp_mesgs_per_connection - 1)
|
|
if (PR_Shutdown(sockfd, PR_SHUTDOWN_RCV) < 0) {
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_Shutdown\n");
|
|
}
|
|
DPRINTF(("Serve_Client [0x%lx]: inbuf[0] = 0x%lx\n",PR_GetCurrentThread(),
|
|
(*((int *) in_buf->data))));
|
|
if (writen(sockfd, in_buf->data, bytes) < bytes) {
|
|
fprintf(stderr,"prsocket_test: ERROR - Serve_Client:writen\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
}
|
|
/*
|
|
* shutdown reads and writes
|
|
*/
|
|
if (PR_Shutdown(sockfd, PR_SHUTDOWN_BOTH) < 0) {
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_Shutdown\n");
|
|
failed_already=1;
|
|
}
|
|
|
|
exit:
|
|
PR_Close(sockfd);
|
|
if (in_buf) {
|
|
PR_DELETE(in_buf);
|
|
}
|
|
}
|
|
|
|
PRThread* create_new_thread(PRThreadType type,
|
|
void (*start)(void *arg),
|
|
void *arg,
|
|
PRThreadPriority priority,
|
|
PRThreadScope scope,
|
|
PRThreadState state,
|
|
PRUint32 stackSize, PRInt32 index)
|
|
{
|
|
PRInt32 native_thread = 0;
|
|
|
|
PR_ASSERT(state == PR_UNJOINABLE_THREAD);
|
|
#if defined(_PR_PTHREADS) || defined(WIN32)
|
|
switch(index % 4) {
|
|
case 0:
|
|
scope = (PR_LOCAL_THREAD);
|
|
break;
|
|
case 1:
|
|
scope = (PR_GLOBAL_THREAD);
|
|
break;
|
|
case 2:
|
|
scope = (PR_GLOBAL_BOUND_THREAD);
|
|
break;
|
|
case 3:
|
|
native_thread = 1;
|
|
break;
|
|
default:
|
|
PR_NOT_REACHED("Invalid scope");
|
|
break;
|
|
}
|
|
if (native_thread) {
|
|
#if defined(_PR_PTHREADS)
|
|
pthread_t tid;
|
|
if (!pthread_create(&tid, NULL, (void * (*)(void *)) start, arg)) {
|
|
return((PRThread *) tid);
|
|
}
|
|
else {
|
|
return (NULL);
|
|
}
|
|
#else
|
|
HANDLE thandle;
|
|
unsigned tid;
|
|
|
|
thandle = (HANDLE) _beginthreadex(
|
|
NULL,
|
|
stackSize,
|
|
(unsigned (__stdcall *)(void *))start,
|
|
arg,
|
|
STACK_SIZE_PARAM_IS_A_RESERVATION,
|
|
&tid);
|
|
return((PRThread *) thandle);
|
|
#endif
|
|
} else {
|
|
return(PR_CreateThread(type,start,arg,priority,scope,state,stackSize));
|
|
}
|
|
#else
|
|
return(PR_CreateThread(type,start,arg,priority,scope,state,stackSize));
|
|
#endif
|
|
}
|
|
|
|
/*
|
|
* TCP Server
|
|
* Server Thread
|
|
* Bind an address to a socket and listen for incoming connections
|
|
* Start a Serve_Client thread for each incoming connection.
|
|
*/
|
|
static void PR_CALLBACK
|
|
TCP_Server(void *arg)
|
|
{
|
|
PRThread *t;
|
|
Server_Param *sp = (Server_Param *) arg;
|
|
Serve_Client_Param *scp;
|
|
PRFileDesc *sockfd, *newsockfd;
|
|
PRNetAddr netaddr;
|
|
PRInt32 i;
|
|
/*
|
|
* Create a tcp socket
|
|
*/
|
|
if ((sockfd = PR_OpenTCPSocket(server_domain)) == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NewTCPSocket failed\n");
|
|
goto exit;
|
|
}
|
|
memset(&netaddr, 0, sizeof(netaddr));
|
|
|
|
if (PR_SetNetAddr(PR_IpAddrAny, server_domain, TCP_SERVER_PORT,
|
|
&netaddr) == PR_FAILURE) {
|
|
fprintf(stderr,"prsocket_test: PR_SetNetAddr failed\n");
|
|
goto exit;
|
|
}
|
|
/*
|
|
* try a few times to bind server's address, if addresses are in
|
|
* use
|
|
*/
|
|
i = 0;
|
|
|
|
while (PR_Bind(sockfd, &netaddr) < 0) {
|
|
if (PR_GetError() == PR_ADDRESS_IN_USE_ERROR) {
|
|
netaddr.inet.port += 2;
|
|
if (i++ < SERVER_MAX_BIND_COUNT) {
|
|
continue;
|
|
}
|
|
}
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_Bind failed\n");
|
|
perror("PR_Bind");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
|
|
if (PR_Listen(sockfd, 32) < 0) {
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_Listen failed\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
|
|
if (PR_GetSockName(sockfd, &netaddr) < 0) {
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_GetSockName failed\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
|
|
DPRINTF(("TCP_Server: PR_BIND netaddr.inet.ip = 0x%lx, netaddr.inet.port = %d\n",
|
|
netaddr.inet.ip, netaddr.inet.port));
|
|
if (PR_SetNetAddr(PR_IpAddrLoopback, client_domain,
|
|
PR_ntohs(PR_NetAddrInetPort(&netaddr)),
|
|
&tcp_server_addr) == PR_FAILURE) {
|
|
fprintf(stderr,"prsocket_test: PR_SetNetAddr failed\n");
|
|
goto exit;
|
|
}
|
|
if ((client_domain == PR_AF_INET6) && (server_domain == PR_AF_INET))
|
|
PR_ConvertIPv4AddrToIPv6(PR_htonl(INADDR_LOOPBACK),
|
|
&tcp_server_addr.ipv6.ip);
|
|
|
|
/*
|
|
* Wake up parent thread because server address is bound and made
|
|
* available in the global variable 'tcp_server_addr'
|
|
*/
|
|
PR_PostSem(sp->addr_sem);
|
|
|
|
for (i = 0; i < (num_tcp_clients * num_tcp_connections_per_client); i++) {
|
|
/* test both null and non-null 'addr' argument to PR_Accept */
|
|
PRNetAddr *addrp = (i%2 ? &netaddr: NULL);
|
|
|
|
DPRINTF(("TCP_Server: Accepting connection\n"));
|
|
if ((newsockfd = PR_Accept(sockfd, addrp,
|
|
PR_INTERVAL_NO_TIMEOUT)) == NULL) {
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_Accept failed\n");
|
|
goto exit;
|
|
}
|
|
DPRINTF(("TCP_Server: Accepted connection\n"));
|
|
scp = PR_NEW(Serve_Client_Param);
|
|
if (scp == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NEW failed\n");
|
|
goto exit;
|
|
}
|
|
|
|
/*
|
|
* Start a Serve_Client thread for each incoming connection
|
|
*/
|
|
scp->sockfd = newsockfd;
|
|
scp->datalen = sp->datalen;
|
|
|
|
t = create_new_thread(PR_USER_THREAD,
|
|
Serve_Client, (void *)scp,
|
|
PR_PRIORITY_NORMAL,
|
|
PR_LOCAL_THREAD,
|
|
PR_UNJOINABLE_THREAD,
|
|
0, i);
|
|
if (t == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_CreateThread failed\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
DPRINTF(("TCP_Server: Created Serve_Client = 0x%lx\n", t));
|
|
}
|
|
|
|
exit:
|
|
if (sockfd) {
|
|
PR_Close(sockfd);
|
|
}
|
|
|
|
/*
|
|
* Decrement exit_counter and notify parent thread
|
|
*/
|
|
|
|
PR_EnterMonitor(sp->exit_mon);
|
|
--(*sp->exit_counter);
|
|
PR_Notify(sp->exit_mon);
|
|
PR_ExitMonitor(sp->exit_mon);
|
|
DPRINTF(("TCP_Server [0x%lx] exiting\n", PR_GetCurrentThread()));
|
|
}
|
|
|
|
/*
|
|
* UDP Server
|
|
* Server Thread
|
|
* Bind an address to a socket, read data from clients and send data
|
|
* back to clients
|
|
*/
|
|
static void PR_CALLBACK
|
|
UDP_Server(void *arg)
|
|
{
|
|
Server_Param *sp = (Server_Param *) arg;
|
|
PRFileDesc *sockfd;
|
|
buffer *in_buf;
|
|
PRNetAddr netaddr;
|
|
PRInt32 bytes, i, rv = 0;
|
|
|
|
|
|
bytes = sp->datalen;
|
|
/*
|
|
* Create a udp socket
|
|
*/
|
|
if ((sockfd = PR_OpenUDPSocket(server_domain)) == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NewUDPSocket failed\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
memset(&netaddr, 0, sizeof(netaddr));
|
|
if (PR_SetNetAddr(PR_IpAddrAny, server_domain, UDP_SERVER_PORT,
|
|
&netaddr) == PR_FAILURE) {
|
|
fprintf(stderr,"prsocket_test: PR_SetNetAddr failed\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
/*
|
|
* try a few times to bind server's address, if addresses are in
|
|
* use
|
|
*/
|
|
i = 0;
|
|
while (PR_Bind(sockfd, &netaddr) < 0) {
|
|
if (PR_GetError() == PR_ADDRESS_IN_USE_ERROR) {
|
|
netaddr.inet.port += 2;
|
|
if (i++ < SERVER_MAX_BIND_COUNT) {
|
|
continue;
|
|
}
|
|
}
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_Bind failed\n");
|
|
perror("PR_Bind");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
|
|
if (PR_GetSockName(sockfd, &netaddr) < 0) {
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_GetSockName failed\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
|
|
DPRINTF(("PR_Bind: UDP Server netaddr.inet.ip = 0x%lx, netaddr.inet.port = %d\n",
|
|
netaddr.inet.ip, netaddr.inet.port));
|
|
/*
|
|
* We can't use the IP address returned by PR_GetSockName in
|
|
* netaddr.inet.ip because netaddr.inet.ip is returned
|
|
* as 0 (= PR_INADDR_ANY).
|
|
*/
|
|
|
|
if (PR_SetNetAddr(PR_IpAddrLoopback, client_domain,
|
|
PR_ntohs(PR_NetAddrInetPort(&netaddr)),
|
|
&udp_server_addr) == PR_FAILURE) {
|
|
fprintf(stderr,"prsocket_test: PR_SetNetAddr failed\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if ((client_domain == PR_AF_INET6) && (server_domain == PR_AF_INET))
|
|
PR_ConvertIPv4AddrToIPv6(PR_htonl(INADDR_LOOPBACK),
|
|
&udp_server_addr.ipv6.ip);
|
|
|
|
/*
|
|
* Wake up parent thread because server address is bound and made
|
|
* available in the global variable 'udp_server_addr'
|
|
*/
|
|
PR_PostSem(sp->addr_sem);
|
|
|
|
bytes = sp->datalen;
|
|
in_buf = PR_NEW(buffer);
|
|
if (in_buf == NULL) {
|
|
fprintf(stderr,"prsocket_test: failed to alloc buffer struct\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
/*
|
|
* Receive datagrams from clients and send them back, unmodified, to the
|
|
* clients
|
|
*/
|
|
memset(&netaddr, 0, sizeof(netaddr));
|
|
for (i = 0; i < (num_udp_clients * num_udp_datagrams_per_client); i++) {
|
|
DPRINTF(("UDP_Server: calling PR_RecvFrom client - ip = 0x%lx, port = %d bytes = %d inbuf = 0x%lx, inbuf[0] = 0x%lx\n",
|
|
netaddr.inet.ip, netaddr.inet.port, bytes, in_buf->data,
|
|
in_buf->data[0]));
|
|
|
|
rv = PR_RecvFrom(sockfd, in_buf->data, bytes, 0, &netaddr,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
DPRINTF(("UDP_Server: PR_RecvFrom client - ip = 0x%lx, port = %d bytes = %d inbuf = 0x%lx, inbuf[0] = 0x%lx\n",
|
|
netaddr.inet.ip, netaddr.inet.port, rv, in_buf->data,
|
|
in_buf->data[0]));
|
|
if (rv != bytes) {
|
|
return;
|
|
}
|
|
rv = PR_SendTo(sockfd, in_buf->data, bytes, 0, &netaddr,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
if (rv != bytes) {
|
|
return;
|
|
}
|
|
}
|
|
|
|
PR_DELETE(in_buf);
|
|
PR_Close(sockfd);
|
|
|
|
/*
|
|
* Decrement exit_counter and notify parent thread
|
|
*/
|
|
PR_EnterMonitor(sp->exit_mon);
|
|
--(*sp->exit_counter);
|
|
PR_Notify(sp->exit_mon);
|
|
PR_ExitMonitor(sp->exit_mon);
|
|
DPRINTF(("UDP_Server [0x%x] exiting\n", PR_GetCurrentThread()));
|
|
}
|
|
|
|
/*
|
|
* TCP_Client
|
|
* Client Thread
|
|
* Connect to the server at the address specified in the argument.
|
|
* Fill in a buffer, write data to server, read it back and check
|
|
* for data corruption.
|
|
* Close the socket for server connection
|
|
*/
|
|
static void PR_CALLBACK
|
|
TCP_Client(void *arg)
|
|
{
|
|
Client_Param *cp = (Client_Param *) arg;
|
|
PRFileDesc *sockfd;
|
|
buffer *in_buf, *out_buf;
|
|
union PRNetAddr netaddr;
|
|
PRInt32 bytes, i, j;
|
|
|
|
|
|
bytes = cp->datalen;
|
|
out_buf = PR_NEW(buffer);
|
|
if (out_buf == NULL) {
|
|
fprintf(stderr,"prsocket_test: failed to alloc buffer struct\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
in_buf = PR_NEW(buffer);
|
|
if (in_buf == NULL) {
|
|
fprintf(stderr,"prsocket_test: failed to alloc buffer struct\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
netaddr = cp->server_addr;
|
|
|
|
for (i = 0; i < num_tcp_connections_per_client; i++) {
|
|
if ((sockfd = PR_OpenTCPSocket(client_domain)) == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_OpenTCPSocket failed\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (PR_Connect(sockfd, &netaddr,PR_INTERVAL_NO_TIMEOUT) < 0) {
|
|
fprintf(stderr, "PR_Connect failed: (%ld, %ld)\n",
|
|
PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
for (j = 0; j < num_tcp_mesgs_per_connection; j++) {
|
|
/*
|
|
* fill in random data
|
|
*/
|
|
memset(out_buf->data, ((PRInt32) (&netaddr)) + i + j, bytes);
|
|
/*
|
|
* write to server
|
|
*/
|
|
#ifdef WINNT
|
|
if (test_cancelio && (j == 0)) {
|
|
PR_Sleep(PR_SecondsToInterval(12));
|
|
}
|
|
#endif
|
|
if (writen(sockfd, out_buf->data, bytes) < bytes) {
|
|
fprintf(stderr,"prsocket_test: ERROR - TCP_Client:writen\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
DPRINTF(("TCP Client [0x%lx]: out_buf = 0x%lx out_buf[0] = 0x%lx\n",
|
|
PR_GetCurrentThread(), out_buf, (*((int *) out_buf->data))));
|
|
if (readn(sockfd, in_buf->data, bytes) < bytes) {
|
|
fprintf(stderr,"prsocket_test: ERROR - TCP_Client:readn\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
/*
|
|
* verify the data read
|
|
*/
|
|
if (memcmp(in_buf->data, out_buf->data, bytes) != 0) {
|
|
fprintf(stderr,"prsocket_test: ERROR - data corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
}
|
|
/*
|
|
* shutdown reads and writes
|
|
*/
|
|
if (PR_Shutdown(sockfd, PR_SHUTDOWN_BOTH) < 0) {
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_Shutdown\n");
|
|
failed_already=1;
|
|
}
|
|
PR_Close(sockfd);
|
|
}
|
|
|
|
PR_DELETE(out_buf);
|
|
PR_DELETE(in_buf);
|
|
|
|
/*
|
|
* Decrement exit_counter and notify parent thread
|
|
*/
|
|
|
|
PR_EnterMonitor(cp->exit_mon);
|
|
--(*cp->exit_counter);
|
|
PR_Notify(cp->exit_mon);
|
|
PR_ExitMonitor(cp->exit_mon);
|
|
DPRINTF(("TCP_Client [0x%x] exiting\n", PR_GetCurrentThread()));
|
|
}
|
|
|
|
/*
|
|
* UDP_Client
|
|
* Client Thread
|
|
* Create a socket and bind an address
|
|
* Communicate with the server at the address specified in the argument.
|
|
* Fill in a buffer, write data to server, read it back and check
|
|
* for data corruption.
|
|
* Close the socket
|
|
*/
|
|
static void PR_CALLBACK
|
|
UDP_Client(void *arg)
|
|
{
|
|
Client_Param *cp = (Client_Param *) arg;
|
|
PRFileDesc *sockfd;
|
|
buffer *in_buf, *out_buf;
|
|
union PRNetAddr netaddr;
|
|
PRInt32 bytes, i, rv;
|
|
|
|
|
|
bytes = cp->datalen;
|
|
out_buf = PR_NEW(buffer);
|
|
if (out_buf == NULL) {
|
|
fprintf(stderr,"prsocket_test: failed to alloc buffer struct\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
in_buf = PR_NEW(buffer);
|
|
if (in_buf == NULL) {
|
|
fprintf(stderr,"prsocket_test: failed to alloc buffer struct\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if ((sockfd = PR_OpenUDPSocket(client_domain)) == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_OpenUDPSocket failed\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
|
|
/*
|
|
* bind an address for the client, let the system chose the port
|
|
* number
|
|
*/
|
|
memset(&netaddr, 0, sizeof(netaddr));
|
|
if (PR_SetNetAddr(PR_IpAddrAny, client_domain, 0,
|
|
&netaddr) == PR_FAILURE) {
|
|
fprintf(stderr,"prsocket_test: PR_SetNetAddr failed\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (PR_Bind(sockfd, &netaddr) < 0) {
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_Bind failed\n");
|
|
perror("PR_Bind");
|
|
return;
|
|
}
|
|
|
|
if (PR_GetSockName(sockfd, &netaddr) < 0) {
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_GetSockName failed\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
|
|
DPRINTF(("PR_Bind: UDP Client netaddr.inet.ip = 0x%lx, netaddr.inet.port = %d\n",
|
|
netaddr.inet.ip, netaddr.inet.port));
|
|
|
|
netaddr = cp->server_addr;
|
|
|
|
if (cp->udp_connect) {
|
|
if (PR_Connect(sockfd, &netaddr,PR_INTERVAL_NO_TIMEOUT) < 0) {
|
|
fprintf(stderr,"prsocket_test: PR_Connect failed\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
}
|
|
|
|
for (i = 0; i < num_udp_datagrams_per_client; i++) {
|
|
/*
|
|
* fill in random data
|
|
*/
|
|
DPRINTF(("UDP_Client [0x%lx]: out_buf = 0x%lx bytes = 0x%lx\n",
|
|
PR_GetCurrentThread(), out_buf->data, bytes));
|
|
memset(out_buf->data, ((PRInt32) (&netaddr)) + i, bytes);
|
|
/*
|
|
* write to server
|
|
*/
|
|
if (cp->udp_connect)
|
|
rv = PR_Send(sockfd, out_buf->data, bytes, 0,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
else
|
|
rv = PR_SendTo(sockfd, out_buf->data, bytes, 0, &netaddr,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
if (rv != bytes) {
|
|
return;
|
|
}
|
|
DPRINTF(("UDP_Client [0x%lx]: out_buf = 0x%lx out_buf[0] = 0x%lx\n",
|
|
PR_GetCurrentThread(), out_buf, (*((int *) out_buf->data))));
|
|
if (cp->udp_connect)
|
|
rv = PR_Recv(sockfd, in_buf->data, bytes, 0,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
else
|
|
rv = PR_RecvFrom(sockfd, in_buf->data, bytes, 0, &netaddr,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
if (rv != bytes) {
|
|
return;
|
|
}
|
|
DPRINTF(("UDP_Client [0x%lx]: in_buf = 0x%lx in_buf[0] = 0x%lx\n",
|
|
PR_GetCurrentThread(), in_buf, (*((int *) in_buf->data))));
|
|
/*
|
|
* verify the data read
|
|
*/
|
|
if (memcmp(in_buf->data, out_buf->data, bytes) != 0) {
|
|
fprintf(stderr,"prsocket_test: ERROR - UDP data corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
}
|
|
PR_Close(sockfd);
|
|
|
|
PR_DELETE(in_buf);
|
|
PR_DELETE(out_buf);
|
|
|
|
/*
|
|
* Decrement exit_counter and notify parent thread
|
|
*/
|
|
|
|
PR_EnterMonitor(cp->exit_mon);
|
|
--(*cp->exit_counter);
|
|
PR_Notify(cp->exit_mon);
|
|
PR_ExitMonitor(cp->exit_mon);
|
|
PR_DELETE(cp);
|
|
DPRINTF(("UDP_Client [0x%x] exiting\n", PR_GetCurrentThread()));
|
|
}
|
|
|
|
/*
|
|
* TCP_Socket_Client_Server_Test - concurrent server test
|
|
*
|
|
* One server and several clients are started
|
|
* Each client connects to the server and sends a chunk of data
|
|
* For each connection, server starts another thread to read the data
|
|
* from the client and send it back to the client, unmodified.
|
|
* Each client checks that data received from server is same as the
|
|
* data it sent to the server.
|
|
*
|
|
*/
|
|
|
|
static PRInt32
|
|
TCP_Socket_Client_Server_Test(void)
|
|
{
|
|
int i;
|
|
PRThread *t;
|
|
PRSemaphore *server_sem;
|
|
Server_Param *sparamp;
|
|
Client_Param *cparamp;
|
|
PRMonitor *mon2;
|
|
PRInt32 datalen;
|
|
|
|
|
|
datalen = tcp_mesg_size;
|
|
thread_count = 0;
|
|
/*
|
|
* start the server thread
|
|
*/
|
|
sparamp = PR_NEW(Server_Param);
|
|
if (sparamp == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NEW failed\n");
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
server_sem = PR_NewSem(0);
|
|
if (server_sem == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NewSem failed\n");
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
mon2 = PR_NewMonitor();
|
|
if (mon2 == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NewMonitor failed\n");
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
PR_EnterMonitor(mon2);
|
|
|
|
sparamp->addr_sem = server_sem;
|
|
sparamp->exit_mon = mon2;
|
|
sparamp->exit_counter = &thread_count;
|
|
sparamp->datalen = datalen;
|
|
t = PR_CreateThread(PR_USER_THREAD,
|
|
TCP_Server, (void *)sparamp,
|
|
PR_PRIORITY_NORMAL,
|
|
PR_LOCAL_THREAD,
|
|
PR_UNJOINABLE_THREAD,
|
|
0);
|
|
if (t == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_CreateThread failed\n");
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
DPRINTF(("Created TCP server = 0x%lx\n", t));
|
|
thread_count++;
|
|
|
|
/*
|
|
* wait till the server address is setup
|
|
*/
|
|
PR_WaitSem(server_sem);
|
|
|
|
/*
|
|
* Now start a bunch of client threads
|
|
*/
|
|
|
|
cparamp = PR_NEW(Client_Param);
|
|
if (cparamp == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NEW failed\n");
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
cparamp->server_addr = tcp_server_addr;
|
|
cparamp->exit_mon = mon2;
|
|
cparamp->exit_counter = &thread_count;
|
|
cparamp->datalen = datalen;
|
|
for (i = 0; i < num_tcp_clients; i++) {
|
|
t = create_new_thread(PR_USER_THREAD,
|
|
TCP_Client, (void *) cparamp,
|
|
PR_PRIORITY_NORMAL,
|
|
PR_LOCAL_THREAD,
|
|
PR_UNJOINABLE_THREAD,
|
|
0, i);
|
|
if (t == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_CreateThread failed\n");
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
DPRINTF(("Created TCP client = 0x%lx\n", t));
|
|
thread_count++;
|
|
}
|
|
/* Wait for server and client threads to exit */
|
|
while (thread_count) {
|
|
PR_Wait(mon2, PR_INTERVAL_NO_TIMEOUT);
|
|
DPRINTF(("TCP Server - thread_count = %d\n", thread_count));
|
|
}
|
|
PR_ExitMonitor(mon2);
|
|
printf("%30s","TCP_Socket_Client_Server_Test:");
|
|
printf("%2ld Server %2ld Clients %2ld connections_per_client\n",1l,
|
|
num_tcp_clients, num_tcp_connections_per_client);
|
|
printf("%30s %2ld messages_per_connection %4ld bytes_per_message\n",":",
|
|
num_tcp_mesgs_per_connection, tcp_mesg_size);
|
|
|
|
return 0;
|
|
}
|
|
|
|
/*
|
|
* UDP_Socket_Client_Server_Test - iterative server test
|
|
*
|
|
* One server and several clients are started
|
|
* Each client connects to the server and sends a chunk of data
|
|
* For each connection, server starts another thread to read the data
|
|
* from the client and send it back to the client, unmodified.
|
|
* Each client checks that data received from server is same as the
|
|
* data it sent to the server.
|
|
*
|
|
*/
|
|
|
|
static PRInt32
|
|
UDP_Socket_Client_Server_Test(void)
|
|
{
|
|
int i;
|
|
PRThread *t;
|
|
PRSemaphore *server_sem;
|
|
Server_Param *sparamp;
|
|
Client_Param *cparamp;
|
|
PRMonitor *mon2;
|
|
PRInt32 datalen;
|
|
PRInt32 udp_connect = 1;
|
|
|
|
|
|
datalen = udp_datagram_size;
|
|
thread_count = 0;
|
|
/*
|
|
* start the server thread
|
|
*/
|
|
sparamp = PR_NEW(Server_Param);
|
|
if (sparamp == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NEW failed\n");
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
server_sem = PR_NewSem(0);
|
|
if (server_sem == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NewSem failed\n");
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
mon2 = PR_NewMonitor();
|
|
if (mon2 == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NewMonitor failed\n");
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
PR_EnterMonitor(mon2);
|
|
|
|
sparamp->addr_sem = server_sem;
|
|
sparamp->exit_mon = mon2;
|
|
sparamp->exit_counter = &thread_count;
|
|
sparamp->datalen = datalen;
|
|
DPRINTF(("Creating UDP server"));
|
|
t = PR_CreateThread(PR_USER_THREAD,
|
|
UDP_Server, (void *)sparamp,
|
|
PR_PRIORITY_NORMAL,
|
|
PR_LOCAL_THREAD,
|
|
PR_UNJOINABLE_THREAD,
|
|
0);
|
|
if (t == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_CreateThread failed\n");
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
thread_count++;
|
|
|
|
/*
|
|
* wait till the server address is setup
|
|
*/
|
|
PR_WaitSem(server_sem);
|
|
|
|
/*
|
|
* Now start a bunch of client threads
|
|
*/
|
|
|
|
for (i = 0; i < num_udp_clients; i++) {
|
|
cparamp = PR_NEW(Client_Param);
|
|
if (cparamp == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NEW failed\n");
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
cparamp->server_addr = udp_server_addr;
|
|
cparamp->exit_mon = mon2;
|
|
cparamp->exit_counter = &thread_count;
|
|
cparamp->datalen = datalen;
|
|
/*
|
|
* Cause every other client thread to connect udp sockets
|
|
*/
|
|
cparamp->udp_connect = udp_connect;
|
|
if (udp_connect) {
|
|
udp_connect = 0;
|
|
}
|
|
else {
|
|
udp_connect = 1;
|
|
}
|
|
DPRINTF(("Creating UDP client %d\n", i));
|
|
t = PR_CreateThread(PR_USER_THREAD,
|
|
UDP_Client, (void *) cparamp,
|
|
PR_PRIORITY_NORMAL,
|
|
PR_LOCAL_THREAD,
|
|
PR_UNJOINABLE_THREAD,
|
|
0);
|
|
if (t == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_CreateThread failed\n");
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
thread_count++;
|
|
}
|
|
/* Wait for server and client threads to exit */
|
|
while (thread_count) {
|
|
PR_Wait(mon2, PR_INTERVAL_NO_TIMEOUT);
|
|
DPRINTF(("UDP Server - thread_count = %d\n", thread_count));
|
|
}
|
|
PR_ExitMonitor(mon2);
|
|
printf("%30s","UDP_Socket_Client_Server_Test: ");
|
|
printf("%2ld Server %2ld Clients\n",1l, num_udp_clients);
|
|
printf("%30s %2ld datagrams_per_client %4ld bytes_per_datagram\n",":",
|
|
num_udp_datagrams_per_client, udp_datagram_size);
|
|
|
|
return 0;
|
|
}
|
|
|
|
static PRFileDesc *small_file_fd, *large_file_fd;
|
|
static void *small_file_addr, *small_file_header, *large_file_addr;
|
|
static void *small_file_trailer, *large_file_header, *large_file_trailer;
|
|
/*
|
|
* TransmitFile_Client
|
|
* Client Thread
|
|
*/
|
|
static void
|
|
TransmitFile_Client(void *arg)
|
|
{
|
|
PRFileDesc *sockfd;
|
|
union PRNetAddr netaddr;
|
|
char *small_buf, *large_buf;
|
|
Client_Param *cp = (Client_Param *) arg;
|
|
PRInt32 rlen;
|
|
|
|
small_buf = (char*)PR_Malloc(SMALL_FILE_SIZE + SMALL_FILE_HEADER_SIZE +
|
|
SMALL_FILE_TRAILER_SIZE);
|
|
if (small_buf == NULL) {
|
|
fprintf(stderr,"prsocket_test: failed to alloc buffer\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
large_buf = (char*)PR_Malloc(LARGE_FILE_SIZE + LARGE_FILE_HEADER_SIZE +
|
|
LARGE_FILE_TRAILER_SIZE);
|
|
if (large_buf == NULL) {
|
|
fprintf(stderr,"prsocket_test: failed to alloc buffer\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
netaddr.inet.family = cp->server_addr.inet.family;
|
|
netaddr.inet.port = cp->server_addr.inet.port;
|
|
netaddr.inet.ip = cp->server_addr.inet.ip;
|
|
|
|
if ((sockfd = PR_NewTCPSocket()) == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NewTCPSocket failed\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
|
|
if (PR_Connect(sockfd, &netaddr,PR_INTERVAL_NO_TIMEOUT) < 0) {
|
|
fprintf(stderr,"prsocket_test: PR_Connect failed\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
/*
|
|
* read the small file and verify the data
|
|
*/
|
|
if (readn(sockfd, small_buf, SMALL_FILE_SIZE + SMALL_FILE_HEADER_SIZE)
|
|
!= (SMALL_FILE_SIZE + SMALL_FILE_HEADER_SIZE)) {
|
|
fprintf(stderr,
|
|
"prsocket_test: TransmitFile_Client failed to receive file\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#if defined(XP_UNIX)
|
|
/* File transmission test can not be done because of large file's size */
|
|
if (memcmp(small_file_header, small_buf, SMALL_FILE_HEADER_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"prsocket_test: TransmitFile_Client ERROR - small file header data corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (memcmp(small_file_addr, small_buf + SMALL_FILE_HEADER_SIZE,
|
|
SMALL_FILE_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"prsocket_test: TransmitFile_Client ERROR - small file data corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#endif
|
|
/*
|
|
* read the large file and verify the data
|
|
*/
|
|
if (readn(sockfd, large_buf, LARGE_FILE_SIZE) != LARGE_FILE_SIZE) {
|
|
fprintf(stderr,
|
|
"prsocket_test: TransmitFile_Client failed to receive file\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#if defined(XP_UNIX)
|
|
if (memcmp(large_file_addr, large_buf, LARGE_FILE_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"prsocket_test: TransmitFile_Client ERROR - large file data corruption\n");
|
|
failed_already=1;
|
|
}
|
|
#endif
|
|
|
|
|
|
/*
|
|
* receive data from PR_SendFile
|
|
*/
|
|
/*
|
|
* case 1: small file with header and trailer
|
|
*/
|
|
rlen = SMALL_FILE_SIZE + SMALL_FILE_HEADER_SIZE +
|
|
SMALL_FILE_TRAILER_SIZE;
|
|
if (readn(sockfd, small_buf, rlen) != rlen) {
|
|
fprintf(stderr,
|
|
"prsocket_test: SendFile_Client failed to receive file\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#if defined(XP_UNIX)
|
|
if (memcmp(small_file_header, small_buf, SMALL_FILE_HEADER_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 1. ERROR - small file header corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (memcmp(small_file_addr, small_buf + SMALL_FILE_HEADER_SIZE,
|
|
SMALL_FILE_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 1. ERROR - small file data corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (memcmp(small_file_trailer,
|
|
small_buf + SMALL_FILE_HEADER_SIZE + SMALL_FILE_SIZE,
|
|
SMALL_FILE_TRAILER_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 1. ERROR - small file trailer corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#endif
|
|
/*
|
|
* case 2: partial large file at zero offset, file with header and trailer
|
|
*/
|
|
rlen = LARGE_FILE_LEN_1 + LARGE_FILE_HEADER_SIZE +
|
|
LARGE_FILE_TRAILER_SIZE;
|
|
if (readn(sockfd, large_buf, rlen) != rlen) {
|
|
fprintf(stderr,
|
|
"prsocket_test: SendFile_Client failed to receive file\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#if defined(XP_UNIX)
|
|
if (memcmp(large_file_header, large_buf, LARGE_FILE_HEADER_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 2. ERROR - large file header corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (memcmp(large_file_addr, large_buf + LARGE_FILE_HEADER_SIZE,
|
|
LARGE_FILE_LEN_1) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 2. ERROR - large file data corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (memcmp(large_file_trailer,
|
|
large_buf + LARGE_FILE_HEADER_SIZE + LARGE_FILE_LEN_1,
|
|
LARGE_FILE_TRAILER_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 2. ERROR - large file trailer corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#endif
|
|
/*
|
|
* case 3: partial small file at non-zero offset, with header
|
|
*/
|
|
rlen = SMALL_FILE_LEN_1 + SMALL_FILE_HEADER_SIZE;
|
|
if (readn(sockfd, small_buf, rlen) != rlen) {
|
|
fprintf(stderr,
|
|
"prsocket_test: SendFile_Client failed to receive file\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#if defined(XP_UNIX)
|
|
if (memcmp(small_file_header, small_buf, SMALL_FILE_HEADER_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 3. ERROR - small file header corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (memcmp((char *) small_file_addr + SMALL_FILE_OFFSET_1,
|
|
small_buf + SMALL_FILE_HEADER_SIZE, SMALL_FILE_LEN_1) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 3. ERROR - small file data corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#endif
|
|
/*
|
|
* case 4: partial small file at non-zero offset, with trailer
|
|
*/
|
|
rlen = SMALL_FILE_LEN_2 + SMALL_FILE_TRAILER_SIZE;
|
|
if (readn(sockfd, small_buf, rlen) != rlen) {
|
|
fprintf(stderr,
|
|
"prsocket_test: SendFile_Client failed to receive file\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#if defined(XP_UNIX)
|
|
if (memcmp((char *) small_file_addr + SMALL_FILE_OFFSET_2, small_buf,
|
|
SMALL_FILE_LEN_2) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 4. ERROR - small file data corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (memcmp(small_file_trailer, small_buf + SMALL_FILE_LEN_2,
|
|
SMALL_FILE_TRAILER_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 4. ERROR - small file trailer corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#endif
|
|
/*
|
|
* case 5: partial large file at non-zero offset, file with header
|
|
*/
|
|
rlen = LARGE_FILE_LEN_2 + LARGE_FILE_HEADER_SIZE;
|
|
if (readn(sockfd, large_buf, rlen) != rlen) {
|
|
fprintf(stderr,
|
|
"prsocket_test: SendFile_Client failed to receive file\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#if defined(XP_UNIX)
|
|
if (memcmp(large_file_header, large_buf, LARGE_FILE_HEADER_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 5. ERROR - large file header corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (memcmp((char *)large_file_addr + LARGE_FILE_OFFSET_2,
|
|
large_buf + LARGE_FILE_HEADER_SIZE,
|
|
LARGE_FILE_LEN_2) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 5. ERROR - large file data corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#endif
|
|
/*
|
|
* case 6: partial small file at non-zero offset, with header
|
|
*/
|
|
rlen = SMALL_FILE_LEN_3 + SMALL_FILE_HEADER_SIZE;
|
|
if (readn(sockfd, small_buf, rlen) != rlen) {
|
|
fprintf(stderr,
|
|
"prsocket_test: SendFile_Client failed to receive file\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#if defined(XP_UNIX)
|
|
if (memcmp(small_file_header, small_buf, SMALL_FILE_HEADER_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 6. ERROR - small file header corruption\n");
|
|
return;
|
|
}
|
|
if (memcmp((char *) small_file_addr + SMALL_FILE_OFFSET_3,
|
|
small_buf + SMALL_FILE_HEADER_SIZE, SMALL_FILE_LEN_3) != 0) {
|
|
#if 0
|
|
char *i, *j;
|
|
int k;
|
|
|
|
i = (char *) small_file_addr + SMALL_FILE_OFFSET_3;
|
|
j = small_buf + SMALL_FILE_HEADER_SIZE;
|
|
k = SMALL_FILE_LEN_3;
|
|
while (k-- > 0) {
|
|
if (*i++ != *j++)
|
|
printf("i = %d j = %d\n",
|
|
(int) (i - ((char *) small_file_addr + SMALL_FILE_OFFSET_3)),
|
|
(int) (j - (small_buf + SMALL_FILE_HEADER_SIZE)));
|
|
}
|
|
#endif
|
|
fprintf(stderr,
|
|
"SendFile 6. ERROR - small file data corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#endif
|
|
/*
|
|
* case 7: partial large file at non-zero offset, with header
|
|
*/
|
|
rlen = LARGE_FILE_LEN_3 + LARGE_FILE_HEADER_SIZE;
|
|
if (readn(sockfd, large_buf, rlen) != rlen) {
|
|
fprintf(stderr,
|
|
"prsocket_test: SendFile_Client failed to receive file\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#if defined(XP_UNIX)
|
|
if (memcmp(large_file_header, large_buf, LARGE_FILE_HEADER_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 7. ERROR - large file header corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (memcmp((char *)large_file_addr + LARGE_FILE_OFFSET_3,
|
|
large_buf + LARGE_FILE_HEADER_SIZE,
|
|
LARGE_FILE_LEN_3) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 7. ERROR - large file data corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#endif
|
|
/*
|
|
* case 8: partial large file at non-zero, page-aligned offset, with
|
|
* header and trailer
|
|
*/
|
|
rlen = LARGE_FILE_LEN_4 + LARGE_FILE_HEADER_SIZE +
|
|
LARGE_FILE_TRAILER_SIZE;
|
|
if (readn(sockfd, large_buf, rlen) != rlen) {
|
|
fprintf(stderr,
|
|
"prsocket_test: SendFile_Client failed to receive file\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#if defined(XP_UNIX)
|
|
if (memcmp(large_file_header, large_buf, LARGE_FILE_HEADER_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 2. ERROR - large file header corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (memcmp((char *)large_file_addr + LARGE_FILE_OFFSET_4,
|
|
large_buf + LARGE_FILE_HEADER_SIZE,
|
|
LARGE_FILE_LEN_4) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 2. ERROR - large file data corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
if (memcmp(large_file_trailer,
|
|
large_buf + LARGE_FILE_HEADER_SIZE + LARGE_FILE_LEN_4,
|
|
LARGE_FILE_TRAILER_SIZE) != 0) {
|
|
fprintf(stderr,
|
|
"SendFile 2. ERROR - large file trailer corruption\n");
|
|
failed_already=1;
|
|
return;
|
|
}
|
|
#endif
|
|
PR_DELETE(small_buf);
|
|
PR_DELETE(large_buf);
|
|
PR_Close(sockfd);
|
|
|
|
|
|
/*
|
|
* Decrement exit_counter and notify parent thread
|
|
*/
|
|
|
|
PR_EnterMonitor(cp->exit_mon);
|
|
--(*cp->exit_counter);
|
|
PR_Notify(cp->exit_mon);
|
|
PR_ExitMonitor(cp->exit_mon);
|
|
DPRINTF(("TransmitFile_Client [0x%lx] exiting\n", PR_GetCurrentThread()));
|
|
}
|
|
|
|
/*
|
|
* Serve_TransmitFile_Client
|
|
* Thread, started by the server, for serving a client connection.
|
|
* Trasmits a small file, with a header, and a large file, without
|
|
* a header
|
|
*/
|
|
static void
|
|
Serve_TransmitFile_Client(void *arg)
|
|
{
|
|
Serve_Client_Param *scp = (Serve_Client_Param *) arg;
|
|
PRFileDesc *sockfd;
|
|
PRInt32 bytes;
|
|
PRFileDesc *local_small_file_fd=NULL;
|
|
PRFileDesc *local_large_file_fd=NULL;
|
|
PRSendFileData sfd;
|
|
PRInt32 slen;
|
|
|
|
sockfd = scp->sockfd;
|
|
local_small_file_fd = PR_Open(SMALL_FILE_NAME, PR_RDONLY,0);
|
|
|
|
if (local_small_file_fd == NULL) {
|
|
fprintf(stderr,"prsocket_test failed to open file for transmitting %s\n",
|
|
SMALL_FILE_NAME);
|
|
failed_already=1;
|
|
goto done;
|
|
}
|
|
local_large_file_fd = PR_Open(LARGE_FILE_NAME, PR_RDONLY,0);
|
|
|
|
if (local_large_file_fd == NULL) {
|
|
fprintf(stderr,"prsocket_test failed to open file for transmitting %s\n",
|
|
LARGE_FILE_NAME);
|
|
failed_already=1;
|
|
goto done;
|
|
}
|
|
bytes = PR_TransmitFile(sockfd, local_small_file_fd, small_file_header,
|
|
SMALL_FILE_HEADER_SIZE, PR_TRANSMITFILE_KEEP_OPEN,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
if (bytes != (SMALL_FILE_SIZE+ SMALL_FILE_HEADER_SIZE)) {
|
|
fprintf(stderr,
|
|
"prsocet_test: PR_TransmitFile failed: (%ld, %ld)\n",
|
|
PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
}
|
|
bytes = PR_TransmitFile(sockfd, local_large_file_fd, NULL, 0,
|
|
PR_TRANSMITFILE_KEEP_OPEN, PR_INTERVAL_NO_TIMEOUT);
|
|
if (bytes != LARGE_FILE_SIZE) {
|
|
fprintf(stderr,
|
|
"prsocket_test: PR_TransmitFile failed: (%ld, %ld)\n",
|
|
PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
}
|
|
|
|
/*
|
|
* PR_SendFile test cases
|
|
*/
|
|
|
|
/*
|
|
* case 1: small file with header and trailer
|
|
*/
|
|
sfd.fd = local_small_file_fd;
|
|
sfd.file_offset = 0;
|
|
sfd.file_nbytes = 0;
|
|
sfd.header = small_file_header;
|
|
sfd.hlen = SMALL_FILE_HEADER_SIZE;
|
|
sfd.trailer = small_file_trailer;
|
|
sfd.tlen = SMALL_FILE_TRAILER_SIZE;
|
|
bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
slen = SMALL_FILE_SIZE+ SMALL_FILE_HEADER_SIZE +
|
|
SMALL_FILE_TRAILER_SIZE;
|
|
if (bytes != slen) {
|
|
fprintf(stderr,
|
|
"socket: Error - 1. PR_SendFile send_size = %d, bytes sent = %d\n",
|
|
slen, bytes);
|
|
fprintf(stderr,
|
|
"prsocket_test: PR_SendFile failed: (%ld, %ld)\n",
|
|
PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
}
|
|
|
|
/*
|
|
* case 2: partial large file at zero offset, file with header and trailer
|
|
*/
|
|
sfd.fd = local_large_file_fd;
|
|
sfd.file_offset = 0;
|
|
sfd.file_nbytes = LARGE_FILE_LEN_1;
|
|
sfd.header = large_file_header;
|
|
sfd.hlen = LARGE_FILE_HEADER_SIZE;
|
|
sfd.trailer = large_file_trailer;
|
|
sfd.tlen = LARGE_FILE_TRAILER_SIZE;
|
|
bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
slen = LARGE_FILE_LEN_1 + LARGE_FILE_HEADER_SIZE +
|
|
LARGE_FILE_TRAILER_SIZE;
|
|
if (bytes != slen) {
|
|
fprintf(stderr,
|
|
"socket: Error - 2. PR_SendFile send_size = %d, bytes sent = %d\n",
|
|
slen, bytes);
|
|
fprintf(stderr,
|
|
"prsocket_test: PR_SendFile failed: (%ld, %ld)\n",
|
|
PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
}
|
|
/*
|
|
* case 3: partial small file at non-zero offset, with header
|
|
*/
|
|
sfd.fd = local_small_file_fd;
|
|
sfd.file_offset = SMALL_FILE_OFFSET_1;
|
|
sfd.file_nbytes = SMALL_FILE_LEN_1;
|
|
sfd.header = small_file_header;
|
|
sfd.hlen = SMALL_FILE_HEADER_SIZE;
|
|
sfd.trailer = NULL;
|
|
sfd.tlen = 0;
|
|
bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
slen = SMALL_FILE_LEN_1 + SMALL_FILE_HEADER_SIZE;
|
|
if (bytes != slen) {
|
|
fprintf(stderr,
|
|
"socket: Error - 3. PR_SendFile send_size = %d, bytes sent = %d\n",
|
|
slen, bytes);
|
|
fprintf(stderr,
|
|
"prsocket_test: PR_SendFile failed: (%ld, %ld)\n",
|
|
PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
}
|
|
/*
|
|
* case 4: partial small file at non-zero offset, with trailer
|
|
*/
|
|
sfd.fd = local_small_file_fd;
|
|
sfd.file_offset = SMALL_FILE_OFFSET_2;
|
|
sfd.file_nbytes = SMALL_FILE_LEN_2;
|
|
sfd.header = NULL;
|
|
sfd.hlen = 0;
|
|
sfd.trailer = small_file_trailer;
|
|
sfd.tlen = SMALL_FILE_TRAILER_SIZE;
|
|
bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
slen = SMALL_FILE_LEN_2 + SMALL_FILE_TRAILER_SIZE;
|
|
if (bytes != slen) {
|
|
fprintf(stderr,
|
|
"socket: Error - 4. PR_SendFile send_size = %d, bytes sent = %d\n",
|
|
slen, bytes);
|
|
fprintf(stderr,
|
|
"prsocket_test: PR_SendFile failed: (%ld, %ld)\n",
|
|
PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
}
|
|
/*
|
|
* case 5: partial large file at non-zero offset, file with header
|
|
*/
|
|
sfd.fd = local_large_file_fd;
|
|
sfd.file_offset = LARGE_FILE_OFFSET_2;
|
|
sfd.file_nbytes = LARGE_FILE_LEN_2;
|
|
sfd.header = large_file_header;
|
|
sfd.hlen = LARGE_FILE_HEADER_SIZE;
|
|
sfd.trailer = NULL;
|
|
sfd.tlen = 0;
|
|
bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
slen = LARGE_FILE_LEN_2 + LARGE_FILE_HEADER_SIZE;
|
|
if (bytes != slen) {
|
|
fprintf(stderr,
|
|
"socket: Error - 5. PR_SendFile send_size = %d, bytes sent = %d\n",
|
|
slen, bytes);
|
|
fprintf(stderr,
|
|
"prsocket_test: PR_SendFile failed: (%ld, %ld)\n",
|
|
PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
}
|
|
/*
|
|
* case 6: partial small file from non-zero offset till end of file, with header
|
|
*/
|
|
sfd.fd = local_small_file_fd;
|
|
sfd.file_offset = SMALL_FILE_OFFSET_3;
|
|
sfd.file_nbytes = 0; /* data from offset to end-of-file */
|
|
sfd.header = small_file_header;
|
|
sfd.hlen = SMALL_FILE_HEADER_SIZE;
|
|
sfd.trailer = NULL;
|
|
sfd.tlen = 0;
|
|
bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
slen = SMALL_FILE_LEN_3 + SMALL_FILE_HEADER_SIZE;
|
|
if (bytes != slen) {
|
|
fprintf(stderr,
|
|
"socket: Error - 6. PR_SendFile send_size = %d, bytes sent = %d\n",
|
|
slen, bytes);
|
|
fprintf(stderr,
|
|
"prsocket_test: PR_SendFile failed: (%ld, %ld)\n",
|
|
PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
}
|
|
/*
|
|
* case 7: partial large file at non-zero offset till end-of-file, with header
|
|
*/
|
|
sfd.fd = local_large_file_fd;
|
|
sfd.file_offset = LARGE_FILE_OFFSET_3;
|
|
sfd.file_nbytes = 0; /* data until end-of-file */
|
|
sfd.header = large_file_header;
|
|
sfd.hlen = LARGE_FILE_HEADER_SIZE;
|
|
sfd.trailer = NULL;
|
|
sfd.tlen = 0;
|
|
bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_KEEP_OPEN,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
slen = LARGE_FILE_LEN_3 + LARGE_FILE_HEADER_SIZE;
|
|
if (bytes != slen) {
|
|
fprintf(stderr,
|
|
"socket: Error - 7. PR_SendFile send_size = %d, bytes sent = %d\n",
|
|
slen, bytes);
|
|
fprintf(stderr,
|
|
"prsocket_test: PR_SendFile failed: (%ld, %ld)\n",
|
|
PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
}
|
|
/*
|
|
* case 8: partial large file at non-zero page-aligned offset,
|
|
* with header and trailer
|
|
*/
|
|
sfd.fd = local_large_file_fd;
|
|
sfd.file_offset = LARGE_FILE_OFFSET_4;
|
|
sfd.file_nbytes = LARGE_FILE_LEN_4;
|
|
sfd.header = large_file_header;
|
|
sfd.hlen = LARGE_FILE_HEADER_SIZE;
|
|
sfd.trailer = large_file_trailer;
|
|
sfd.tlen = LARGE_FILE_TRAILER_SIZE;
|
|
bytes = PR_SendFile(sockfd, &sfd, PR_TRANSMITFILE_CLOSE_SOCKET,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
slen = LARGE_FILE_LEN_4 + LARGE_FILE_HEADER_SIZE +
|
|
LARGE_FILE_TRAILER_SIZE;
|
|
if (bytes != slen) {
|
|
fprintf(stderr,
|
|
"socket: Error - 2. PR_SendFile send_size = %d, bytes sent = %d\n",
|
|
slen, bytes);
|
|
fprintf(stderr,
|
|
"prsocket_test: PR_SendFile failed: (%ld, %ld)\n",
|
|
PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
}
|
|
done:
|
|
if (local_small_file_fd != NULL) {
|
|
PR_Close(local_small_file_fd);
|
|
}
|
|
if (local_large_file_fd != NULL) {
|
|
PR_Close(local_large_file_fd);
|
|
}
|
|
}
|
|
|
|
/*
|
|
* TransmitFile Server
|
|
* Server Thread
|
|
* Bind an address to a socket and listen for incoming connections
|
|
* Create worker threads to service clients
|
|
*/
|
|
static void
|
|
TransmitFile_Server(void *arg)
|
|
{
|
|
PRThread **t = NULL; /* an array of PRThread pointers */
|
|
Server_Param *sp = (Server_Param *) arg;
|
|
Serve_Client_Param *scp;
|
|
PRFileDesc *sockfd = NULL, *newsockfd;
|
|
PRNetAddr netaddr;
|
|
PRInt32 i;
|
|
|
|
t = (PRThread**)PR_MALLOC(num_transmitfile_clients * sizeof(PRThread *));
|
|
if (t == NULL) {
|
|
fprintf(stderr, "prsocket_test: run out of memory\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
/*
|
|
* Create a tcp socket
|
|
*/
|
|
if ((sockfd = PR_OpenTCPSocket(PR_AF_INET)) == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_OpenTCPSocket failed\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
memset(&netaddr, 0, sizeof(netaddr));
|
|
netaddr.inet.family = PR_AF_INET;
|
|
netaddr.inet.port = PR_htons(TCP_SERVER_PORT);
|
|
netaddr.inet.ip = PR_htonl(PR_INADDR_ANY);
|
|
/*
|
|
* try a few times to bind server's address, if addresses are in
|
|
* use
|
|
*/
|
|
i = 0;
|
|
while (PR_Bind(sockfd, &netaddr) < 0) {
|
|
if (PR_GetError() == PR_ADDRESS_IN_USE_ERROR) {
|
|
netaddr.inet.port += 2;
|
|
if (i++ < SERVER_MAX_BIND_COUNT) {
|
|
continue;
|
|
}
|
|
}
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_Bind failed\n");
|
|
failed_already=1;
|
|
perror("PR_Bind");
|
|
goto exit;
|
|
}
|
|
|
|
if (PR_Listen(sockfd, 32) < 0) {
|
|
fprintf(stderr,"prsocket_test: ERROR - PR_Listen failed\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
|
|
if (PR_GetSockName(sockfd, &netaddr) < 0) {
|
|
fprintf(stderr,
|
|
"prsocket_test: ERROR - PR_GetSockName failed\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
|
|
DPRINTF(("TCP_Server: PR_BIND netaddr.inet.ip = 0x%lx, netaddr.inet.port = %d\n",
|
|
netaddr.inet.ip, netaddr.inet.port));
|
|
tcp_server_addr.inet.family = netaddr.inet.family;
|
|
tcp_server_addr.inet.port = netaddr.inet.port;
|
|
tcp_server_addr.inet.ip = netaddr.inet.ip;
|
|
|
|
/*
|
|
* Wake up parent thread because server address is bound and made
|
|
* available in the global variable 'tcp_server_addr'
|
|
*/
|
|
PR_PostSem(sp->addr_sem);
|
|
|
|
for (i = 0; i < num_transmitfile_clients ; i++) {
|
|
/* test both null and non-null 'addr' argument to PR_Accept */
|
|
PRNetAddr *addrp = (i%2 ? &netaddr: NULL);
|
|
|
|
if ((newsockfd = PR_Accept(sockfd, addrp,
|
|
PR_INTERVAL_NO_TIMEOUT)) == NULL) {
|
|
fprintf(stderr,
|
|
"prsocket_test: ERROR - PR_Accept failed\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
/* test both regular and emulated PR_SendFile */
|
|
if (i%2) {
|
|
PRFileDesc *layer = PR_CreateIOLayerStub(
|
|
emuSendFileIdentity, &emuSendFileMethods);
|
|
if (layer == NULL) {
|
|
fprintf(stderr,
|
|
"prsocket_test: ERROR - PR_CreateIOLayerStub failed\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
if (PR_PushIOLayer(newsockfd, PR_TOP_IO_LAYER, layer)
|
|
== PR_FAILURE) {
|
|
fprintf(stderr,
|
|
"prsocket_test: ERROR - PR_PushIOLayer failed\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
}
|
|
scp = PR_NEW(Serve_Client_Param);
|
|
if (scp == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NEW failed\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
|
|
/*
|
|
* Start a Serve_Client thread for each incoming connection
|
|
*/
|
|
scp->sockfd = newsockfd;
|
|
scp->datalen = sp->datalen;
|
|
|
|
t[i] = PR_CreateThread(PR_USER_THREAD,
|
|
Serve_TransmitFile_Client, (void *)scp,
|
|
PR_PRIORITY_NORMAL,
|
|
PR_LOCAL_THREAD,
|
|
PR_JOINABLE_THREAD,
|
|
0);
|
|
if (t[i] == NULL) {
|
|
fprintf(stderr,
|
|
"prsocket_test: PR_CreateThread failed\n");
|
|
failed_already=1;
|
|
goto exit;
|
|
}
|
|
DPRINTF(("TransmitFile_Server: Created Serve_TransmitFile_Client = 0x%lx\n", t));
|
|
}
|
|
|
|
/*
|
|
* Wait for all the worker threads to end, so that we know
|
|
* they are no longer using the small and large file fd's.
|
|
*/
|
|
|
|
for (i = 0; i < num_transmitfile_clients; i++) {
|
|
PR_JoinThread(t[i]);
|
|
}
|
|
|
|
exit:
|
|
if (t) {
|
|
PR_DELETE(t);
|
|
}
|
|
if (sockfd) {
|
|
PR_Close(sockfd);
|
|
}
|
|
|
|
/*
|
|
* Decrement exit_counter and notify parent thread
|
|
*/
|
|
|
|
PR_EnterMonitor(sp->exit_mon);
|
|
--(*sp->exit_counter);
|
|
PR_Notify(sp->exit_mon);
|
|
PR_ExitMonitor(sp->exit_mon);
|
|
DPRINTF(("TransmitFile_Server [0x%lx] exiting\n", PR_GetCurrentThread()));
|
|
}
|
|
|
|
/*
|
|
* Socket_Misc_Test - test miscellaneous functions
|
|
*
|
|
*/
|
|
static PRInt32
|
|
Socket_Misc_Test(void)
|
|
{
|
|
PRIntn i, rv = 0, bytes, count, len;
|
|
PRThread *t;
|
|
PRSemaphore *server_sem;
|
|
Server_Param *sparamp;
|
|
Client_Param *cparamp;
|
|
PRMonitor *mon2;
|
|
PRInt32 datalen;
|
|
|
|
/*
|
|
* We deliberately pick a buffer size that is not a nice multiple
|
|
* of 1024.
|
|
*/
|
|
#define TRANSMITFILE_BUF_SIZE (4 * 1024 - 11)
|
|
|
|
typedef struct {
|
|
char data[TRANSMITFILE_BUF_SIZE];
|
|
} file_buf;
|
|
file_buf *buf = NULL;
|
|
|
|
/*
|
|
* create file(s) to be transmitted
|
|
*/
|
|
if ((PR_MkDir(TEST_DIR, 0777)) < 0) {
|
|
printf("prsocket_test failed to create dir %s\n",TEST_DIR);
|
|
failed_already=1;
|
|
return -1;
|
|
}
|
|
|
|
small_file_fd = PR_Open(SMALL_FILE_NAME, PR_RDWR | PR_CREATE_FILE,0777);
|
|
|
|
if (small_file_fd == NULL) {
|
|
fprintf(stderr,"prsocket_test failed to create/open file %s\n",
|
|
SMALL_FILE_NAME);
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
buf = PR_NEW(file_buf);
|
|
if (buf == NULL) {
|
|
fprintf(stderr,"prsocket_test failed to allocate buffer\n");
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
/*
|
|
* fill in random data
|
|
*/
|
|
for (i = 0; i < TRANSMITFILE_BUF_SIZE; i++) {
|
|
buf->data[i] = i;
|
|
}
|
|
count = 0;
|
|
do {
|
|
len = (SMALL_FILE_SIZE - count) > TRANSMITFILE_BUF_SIZE ?
|
|
TRANSMITFILE_BUF_SIZE : (SMALL_FILE_SIZE - count);
|
|
bytes = PR_Write(small_file_fd, buf->data, len);
|
|
if (bytes <= 0) {
|
|
fprintf(stderr,
|
|
"prsocket_test failed to write to file %s\n",
|
|
SMALL_FILE_NAME);
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
count += bytes;
|
|
} while (count < SMALL_FILE_SIZE);
|
|
#ifdef XP_UNIX
|
|
/*
|
|
* map the small file; used in checking for data corruption
|
|
*/
|
|
small_file_addr = mmap(0, SMALL_FILE_SIZE, PROT_READ,
|
|
MAP_SHARED, small_file_fd->secret->md.osfd, 0);
|
|
if (small_file_addr == (void *) -1) {
|
|
fprintf(stderr,"prsocket_test failed to mmap file %s\n",
|
|
SMALL_FILE_NAME);
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
#endif
|
|
/*
|
|
* header for small file
|
|
*/
|
|
small_file_header = PR_MALLOC(SMALL_FILE_HEADER_SIZE);
|
|
if (small_file_header == NULL) {
|
|
fprintf(stderr,"prsocket_test failed to malloc header file\n");
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
memset(small_file_header, (int) PR_IntervalNow(),
|
|
SMALL_FILE_HEADER_SIZE);
|
|
/*
|
|
* trailer for small file
|
|
*/
|
|
small_file_trailer = PR_MALLOC(SMALL_FILE_TRAILER_SIZE);
|
|
if (small_file_trailer == NULL) {
|
|
fprintf(stderr,"prsocket_test failed to malloc header trailer\n");
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
memset(small_file_trailer, (int) PR_IntervalNow(),
|
|
SMALL_FILE_TRAILER_SIZE);
|
|
/*
|
|
* setup large file
|
|
*/
|
|
large_file_fd = PR_Open(LARGE_FILE_NAME, PR_RDWR | PR_CREATE_FILE,0777);
|
|
|
|
if (large_file_fd == NULL) {
|
|
fprintf(stderr,"prsocket_test failed to create/open file %s\n",
|
|
LARGE_FILE_NAME);
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
/*
|
|
* fill in random data
|
|
*/
|
|
for (i = 0; i < TRANSMITFILE_BUF_SIZE; i++) {
|
|
buf->data[i] = i;
|
|
}
|
|
count = 0;
|
|
do {
|
|
len = (LARGE_FILE_SIZE - count) > TRANSMITFILE_BUF_SIZE ?
|
|
TRANSMITFILE_BUF_SIZE : (LARGE_FILE_SIZE - count);
|
|
bytes = PR_Write(large_file_fd, buf->data, len);
|
|
if (bytes <= 0) {
|
|
fprintf(stderr,
|
|
"prsocket_test failed to write to file %s: (%ld, %ld)\n",
|
|
LARGE_FILE_NAME,
|
|
PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
count += bytes;
|
|
} while (count < LARGE_FILE_SIZE);
|
|
#if defined(XP_UNIX)
|
|
/*
|
|
* map the large file; used in checking for data corruption
|
|
*/
|
|
large_file_addr = mmap(0, LARGE_FILE_SIZE, PROT_READ,
|
|
MAP_SHARED, large_file_fd->secret->md.osfd, 0);
|
|
if (large_file_addr == (void *) -1) {
|
|
fprintf(stderr,"prsocket_test failed to mmap file %s\n",
|
|
LARGE_FILE_NAME);
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
#endif
|
|
/*
|
|
* header for large file
|
|
*/
|
|
large_file_header = PR_MALLOC(LARGE_FILE_HEADER_SIZE);
|
|
if (large_file_header == NULL) {
|
|
fprintf(stderr,"prsocket_test failed to malloc header file\n");
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
memset(large_file_header, (int) PR_IntervalNow(),
|
|
LARGE_FILE_HEADER_SIZE);
|
|
/*
|
|
* trailer for large file
|
|
*/
|
|
large_file_trailer = PR_MALLOC(LARGE_FILE_TRAILER_SIZE);
|
|
if (large_file_trailer == NULL) {
|
|
fprintf(stderr,"prsocket_test failed to malloc header trailer\n");
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
memset(large_file_trailer, (int) PR_IntervalNow(),
|
|
LARGE_FILE_TRAILER_SIZE);
|
|
|
|
datalen = tcp_mesg_size;
|
|
thread_count = 0;
|
|
/*
|
|
* start the server thread
|
|
*/
|
|
sparamp = PR_NEW(Server_Param);
|
|
if (sparamp == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NEW failed\n");
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
server_sem = PR_NewSem(0);
|
|
if (server_sem == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NewSem failed\n");
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
mon2 = PR_NewMonitor();
|
|
if (mon2 == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NewMonitor failed\n");
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
PR_EnterMonitor(mon2);
|
|
|
|
sparamp->addr_sem = server_sem;
|
|
sparamp->exit_mon = mon2;
|
|
sparamp->exit_counter = &thread_count;
|
|
sparamp->datalen = datalen;
|
|
t = PR_CreateThread(PR_USER_THREAD,
|
|
TransmitFile_Server, (void *)sparamp,
|
|
PR_PRIORITY_NORMAL,
|
|
PR_LOCAL_THREAD,
|
|
PR_UNJOINABLE_THREAD,
|
|
0);
|
|
if (t == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_CreateThread failed\n");
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
DPRINTF(("Created TCP server = 0x%x\n", t));
|
|
thread_count++;
|
|
|
|
/*
|
|
* wait till the server address is setup
|
|
*/
|
|
PR_WaitSem(server_sem);
|
|
|
|
/*
|
|
* Now start a bunch of client threads
|
|
*/
|
|
|
|
cparamp = PR_NEW(Client_Param);
|
|
if (cparamp == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_NEW failed\n");
|
|
failed_already=1;
|
|
rv = -1;
|
|
goto done;
|
|
}
|
|
cparamp->server_addr = tcp_server_addr;
|
|
cparamp->server_addr.inet.ip = PR_htonl(PR_INADDR_LOOPBACK);
|
|
cparamp->exit_mon = mon2;
|
|
cparamp->exit_counter = &thread_count;
|
|
cparamp->datalen = datalen;
|
|
for (i = 0; i < num_transmitfile_clients; i++) {
|
|
t = create_new_thread(PR_USER_THREAD,
|
|
TransmitFile_Client, (void *) cparamp,
|
|
PR_PRIORITY_NORMAL,
|
|
PR_LOCAL_THREAD,
|
|
PR_UNJOINABLE_THREAD,
|
|
0, i);
|
|
if (t == NULL) {
|
|
fprintf(stderr,"prsocket_test: PR_CreateThread failed\n");
|
|
rv = -1;
|
|
failed_already=1;
|
|
goto done;
|
|
}
|
|
DPRINTF(("Created TransmitFile client = 0x%lx\n", t));
|
|
thread_count++;
|
|
}
|
|
/* Wait for server and client threads to exit */
|
|
while (thread_count) {
|
|
PR_Wait(mon2, PR_INTERVAL_NO_TIMEOUT);
|
|
DPRINTF(("Socket_Misc_Test - thread_count = %d\n", thread_count));
|
|
}
|
|
PR_ExitMonitor(mon2);
|
|
done:
|
|
if (buf) {
|
|
PR_DELETE(buf);
|
|
}
|
|
#if defined(XP_UNIX)
|
|
munmap((char*)small_file_addr, SMALL_FILE_SIZE);
|
|
munmap((char*)large_file_addr, LARGE_FILE_SIZE);
|
|
#endif
|
|
PR_Close(small_file_fd);
|
|
PR_Close(large_file_fd);
|
|
if ((PR_Delete(SMALL_FILE_NAME)) == PR_FAILURE) {
|
|
fprintf(stderr,"prsocket_test: failed to unlink file %s\n",
|
|
SMALL_FILE_NAME);
|
|
failed_already=1;
|
|
}
|
|
if ((PR_Delete(LARGE_FILE_NAME)) == PR_FAILURE) {
|
|
fprintf(stderr,"prsocket_test: failed to unlink file %s\n",
|
|
LARGE_FILE_NAME);
|
|
failed_already=1;
|
|
}
|
|
if ((PR_RmDir(TEST_DIR)) == PR_FAILURE) {
|
|
fprintf(stderr,"prsocket_test failed to rmdir %s: (%ld, %ld)\n",
|
|
TEST_DIR, PR_GetError(), PR_GetOSError());
|
|
failed_already=1;
|
|
}
|
|
|
|
printf("%-29s%s","Socket_Misc_Test",":");
|
|
printf("%2d Server %2d Clients\n",1, num_transmitfile_clients);
|
|
printf("%30s Sizes of Transmitted Files - %4d KB, %2d MB \n",":",
|
|
SMALL_FILE_SIZE/1024, LARGE_FILE_SIZE/(1024 * 1024));
|
|
|
|
|
|
return rv;
|
|
}
|
|
/************************************************************************/
|
|
|
|
/*
|
|
* Test Socket NSPR APIs
|
|
*/
|
|
|
|
int main(int argc, char **argv)
|
|
{
|
|
/*
|
|
* -d debug mode
|
|
*/
|
|
|
|
PLOptStatus os;
|
|
PLOptState *opt = PL_CreateOptState(argc, argv, "d");
|
|
while (PL_OPT_EOL != (os = PL_GetNextOpt(opt)))
|
|
{
|
|
if (PL_OPT_BAD == os) {
|
|
continue;
|
|
}
|
|
switch (opt->option)
|
|
{
|
|
case 'd': /* debug mode */
|
|
_debug_on = 1;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
PL_DestroyOptState(opt);
|
|
|
|
PR_Init(PR_USER_THREAD, PR_PRIORITY_NORMAL, 0);
|
|
PR_STDIO_INIT();
|
|
|
|
PR_SetConcurrency(4);
|
|
|
|
emuSendFileIdentity = PR_GetUniqueIdentity("Emulated SendFile");
|
|
emuSendFileMethods = *PR_GetDefaultIOMethods();
|
|
emuSendFileMethods.transmitfile = emu_TransmitFile;
|
|
emuSendFileMethods.sendfile = emu_SendFile;
|
|
|
|
/*
|
|
* run client-server test with TCP, Ipv4-Ipv4
|
|
*/
|
|
printf("TCP Client/Server Test - IPv4/Ipv4\n");
|
|
if (TCP_Socket_Client_Server_Test() < 0) {
|
|
printf("TCP_Socket_Client_Server_Test failed\n");
|
|
goto done;
|
|
} else {
|
|
printf("TCP_Socket_Client_Server_Test Passed\n");
|
|
}
|
|
/*
|
|
* client-server test, Ipv6-Ipv4
|
|
*/
|
|
client_domain = PR_AF_INET6;
|
|
printf("TCP Client/Server Test - IPv6/Ipv4\n");
|
|
if (TCP_Socket_Client_Server_Test() < 0) {
|
|
printf("TCP_Socket_Client_Server_Test failed\n");
|
|
goto done;
|
|
} else {
|
|
printf("TCP_Socket_Client_Server_Test Passed\n");
|
|
}
|
|
/*
|
|
* client-server test, Ipv4-Ipv6
|
|
*/
|
|
client_domain = PR_AF_INET;
|
|
server_domain = PR_AF_INET6;
|
|
printf("TCP Client/Server Test - IPv4/Ipv6\n");
|
|
if (TCP_Socket_Client_Server_Test() < 0) {
|
|
printf("TCP_Socket_Client_Server_Test failed\n");
|
|
goto done;
|
|
} else {
|
|
printf("TCP_Socket_Client_Server_Test Passed\n");
|
|
}
|
|
/*
|
|
* client-server test, Ipv6-Ipv6
|
|
*/
|
|
client_domain = PR_AF_INET6;
|
|
server_domain = PR_AF_INET6;
|
|
printf("TCP Client/Server Test - IPv6/Ipv6\n");
|
|
if (TCP_Socket_Client_Server_Test() < 0) {
|
|
printf("TCP_Socket_Client_Server_Test failed\n");
|
|
goto done;
|
|
} else {
|
|
printf("TCP_Socket_Client_Server_Test Passed\n");
|
|
}
|
|
test_cancelio = 0;
|
|
|
|
/*
|
|
* Misc socket tests - including transmitfile, etc.
|
|
*/
|
|
|
|
/* File transmission test can not be done in Symbian OS because of
|
|
* large file's size and the incomplete mmap() implementation. */
|
|
#if !defined(WIN16)
|
|
/*
|
|
** The 'transmit file' test does not run because
|
|
** transmit file is not implemented in NSPR yet.
|
|
**
|
|
*/
|
|
if (Socket_Misc_Test() < 0) {
|
|
printf("Socket_Misc_Test failed\n");
|
|
failed_already=1;
|
|
goto done;
|
|
} else {
|
|
printf("Socket_Misc_Test passed\n");
|
|
}
|
|
|
|
/*
|
|
* run client-server test with TCP again to test
|
|
* recycling used sockets from PR_TransmitFile().
|
|
*/
|
|
if (TCP_Socket_Client_Server_Test() < 0) {
|
|
printf("TCP_Socket_Client_Server_Test failed\n");
|
|
goto done;
|
|
} else {
|
|
printf("TCP_Socket_Client_Server_Test Passed\n");
|
|
}
|
|
#endif
|
|
|
|
done:
|
|
PR_Cleanup();
|
|
if (failed_already) {
|
|
return 1;
|
|
}
|
|
else {
|
|
return 0;
|
|
}
|
|
}
|