mirror of
https://github.com/mozilla/gecko-dev.git
synced 2024-12-26 18:31:29 +00:00
323 lines
8.5 KiB
C
323 lines
8.5 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: select2.c
|
|
**
|
|
** Description: Measure PR_Select and Empty_Select performance.
|
|
**
|
|
** Modification History:
|
|
** 20-May-97 AGarcia- Converted the test to accomodate the debug_mode flag.
|
|
** The debug mode will print all of the printfs associated with this test.
|
|
** The regress mode will be the default mode. Since the regress tool limits
|
|
** the output to a one line status:PASS or FAIL,all of the printf statements
|
|
** have been handled with an if (debug_mode) statement.
|
|
***********************************************************************/
|
|
|
|
/***********************************************************************
|
|
** Includes
|
|
***********************************************************************/
|
|
/* Used to get the command line option */
|
|
#include "plgetopt.h"
|
|
#include "prttools.h"
|
|
#include "primpl.h"
|
|
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#if defined(OS2)
|
|
#include <sys/time.h>
|
|
#endif
|
|
|
|
#define PORT 8000
|
|
#define DEFAULT_COUNT 10
|
|
PRInt32 count;
|
|
|
|
|
|
/***********************************************************************
|
|
** PRIVATE FUNCTION: Test_Result
|
|
** DESCRIPTION: Used in conjunction with the regress tool, prints out the
|
|
** status of the test case.
|
|
** INPUTS: PASS/FAIL
|
|
** OUTPUTS: None
|
|
** RETURN: None
|
|
** SIDE EFFECTS:
|
|
**
|
|
** RESTRICTIONS:
|
|
** None
|
|
** MEMORY: NA
|
|
** ALGORITHM: Determine what the status is and print accordingly.
|
|
**
|
|
***********************************************************************/
|
|
|
|
|
|
static void Test_Result (int result)
|
|
{
|
|
switch (result)
|
|
{
|
|
case PASS:
|
|
printf ("PASS\n");
|
|
break;
|
|
case FAIL:
|
|
printf ("FAIL\n");
|
|
break;
|
|
default:
|
|
printf ("NOSTATUS\n");
|
|
break;
|
|
}
|
|
}
|
|
|
|
static void EmptyPRSelect(void)
|
|
{
|
|
PRInt32 index = count;
|
|
PRInt32 rv;
|
|
|
|
for (; index--;)
|
|
rv = PR_Select(0, NULL, NULL, NULL, PR_INTERVAL_NO_WAIT);
|
|
}
|
|
|
|
static void EmptyNativeSelect(void)
|
|
{
|
|
PRInt32 rv;
|
|
PRInt32 index = count;
|
|
struct timeval timeout;
|
|
|
|
timeout.tv_sec = timeout.tv_usec = 0;
|
|
for (; index--;)
|
|
rv = select(0, NULL, NULL, NULL, &timeout);
|
|
}
|
|
|
|
static void PRSelectTest(void)
|
|
{
|
|
PRFileDesc *listenSocket;
|
|
PRNetAddr serverAddr;
|
|
|
|
if ( (listenSocket = PR_NewTCPSocket()) == NULL) {
|
|
if (debug_mode) printf("\tServer error creating listen socket\n");
|
|
return;
|
|
}
|
|
|
|
memset(&serverAddr, 0, sizeof(PRNetAddr));
|
|
serverAddr.inet.family = AF_INET;
|
|
serverAddr.inet.port = PR_htons(PORT);
|
|
serverAddr.inet.ip = PR_htonl(INADDR_ANY);
|
|
|
|
if ( PR_Bind(listenSocket, &serverAddr) == PR_FAILURE) {
|
|
if (debug_mode) printf("\tServer error binding to server address\n");
|
|
PR_Close(listenSocket);
|
|
return;
|
|
}
|
|
|
|
if ( PR_Listen(listenSocket, 128) == PR_FAILURE) {
|
|
if (debug_mode) printf("\tServer error listening to server socket\n");
|
|
PR_Close(listenSocket);
|
|
return;
|
|
}
|
|
if (debug_mode) printf("Listening on port %d\n", PORT);
|
|
|
|
{
|
|
PRFileDesc *newSock;
|
|
PRNetAddr rAddr;
|
|
PRInt32 loops = 0;
|
|
PR_fd_set rdset;
|
|
PRInt32 rv;
|
|
PRInt32 bytesRead;
|
|
char buf[11];
|
|
|
|
loops++;
|
|
|
|
if (debug_mode) printf("Going into accept\n");
|
|
|
|
newSock = PR_Accept(listenSocket,
|
|
&rAddr,
|
|
PR_INTERVAL_NO_TIMEOUT);
|
|
|
|
if (newSock) {
|
|
if (debug_mode) printf("Got connection!\n");
|
|
} else {
|
|
if (debug_mode) printf("PR_Accept failed: error code %d\n", PR_GetError());
|
|
else Test_Result (FAIL);
|
|
}
|
|
|
|
PR_FD_ZERO(&rdset);
|
|
PR_FD_SET(newSock, &rdset);
|
|
|
|
if (debug_mode) printf("Going into select \n");
|
|
|
|
rv = PR_Select(0, &rdset, 0, 0, PR_INTERVAL_NO_TIMEOUT);
|
|
|
|
if (debug_mode) printf("return from select is %d\n", rv);
|
|
|
|
if (PR_FD_ISSET(newSock, &rdset)) {
|
|
if (debug_mode) printf("I can't believe it- the socket is ready okay!\n");
|
|
} else {
|
|
if (debug_mode) printf("Damn; the select test failed...\n");
|
|
else Test_Result (FAIL);
|
|
}
|
|
|
|
strcpy(buf, "XXXXXXXXXX");
|
|
bytesRead = PR_Recv(newSock, buf, 10, 0, PR_INTERVAL_NO_TIMEOUT);
|
|
buf[10] = '\0';
|
|
|
|
if (debug_mode) printf("Recv completed with %d bytes, %s\n", bytesRead, buf);
|
|
|
|
PR_Close(newSock);
|
|
}
|
|
|
|
}
|
|
|
|
#if defined(XP_UNIX)
|
|
|
|
static void NativeSelectTest(void)
|
|
{
|
|
PRFileDesc *listenSocket;
|
|
PRNetAddr serverAddr;
|
|
|
|
if ( (listenSocket = PR_NewTCPSocket()) == NULL) {
|
|
if (debug_mode) printf("\tServer error creating listen socket\n");
|
|
return;
|
|
}
|
|
|
|
memset(&serverAddr, 0, sizeof(PRNetAddr));
|
|
serverAddr.inet.family = AF_INET;
|
|
serverAddr.inet.port = PR_htons(PORT);
|
|
serverAddr.inet.ip = PR_htonl(INADDR_ANY);
|
|
|
|
if ( PR_Bind(listenSocket, &serverAddr) == PR_FAILURE) {
|
|
if (debug_mode) printf("\tServer error binding to server address\n");
|
|
PR_Close(listenSocket);
|
|
return;
|
|
}
|
|
|
|
if ( PR_Listen(listenSocket, 128) == PR_FAILURE) {
|
|
if (debug_mode) printf("\tServer error listening to server socket\n");
|
|
PR_Close(listenSocket);
|
|
return;
|
|
}
|
|
if (debug_mode) printf("Listening on port %d\n", PORT);
|
|
|
|
{
|
|
PRIntn osfd;
|
|
char buf[11];
|
|
fd_set rdset;
|
|
PRNetAddr rAddr;
|
|
PRFileDesc *newSock;
|
|
struct timeval timeout;
|
|
PRInt32 bytesRead, rv, loops = 0;
|
|
|
|
loops++;
|
|
|
|
if (debug_mode) printf("Going into accept\n");
|
|
|
|
newSock = PR_Accept(listenSocket, &rAddr, PR_INTERVAL_NO_TIMEOUT);
|
|
|
|
if (newSock) {
|
|
if (debug_mode) printf("Got connection!\n");
|
|
} else {
|
|
if (debug_mode) printf("PR_Accept failed: error code %d\n", PR_GetError());
|
|
else Test_Result (FAIL);
|
|
}
|
|
|
|
osfd = PR_FileDesc2NativeHandle(newSock);
|
|
FD_ZERO(&rdset);
|
|
FD_SET(osfd, &rdset);
|
|
|
|
if (debug_mode) printf("Going into select \n");
|
|
|
|
|
|
timeout.tv_sec = 2; timeout.tv_usec = 0;
|
|
rv = select(osfd + 1, &rdset, NULL, NULL, &timeout);
|
|
|
|
if (debug_mode) printf("return from select is %d\n", rv);
|
|
|
|
if (FD_ISSET(osfd, &rdset)) {
|
|
if (debug_mode)
|
|
printf("I can't believe it- the socket is ready okay!\n");
|
|
} else {
|
|
if (debug_mode) printf("Damn; the select test failed...\n");
|
|
else Test_Result (FAIL);
|
|
}
|
|
|
|
strcpy(buf, "XXXXXXXXXX");
|
|
bytesRead = PR_Recv(newSock, buf, 10, 0, PR_INTERVAL_NO_TIMEOUT);
|
|
buf[10] = '\0';
|
|
|
|
if (debug_mode) printf("Recv completed with %d bytes, %s\n", bytesRead, buf);
|
|
|
|
PR_Close(newSock);
|
|
}
|
|
|
|
} /* NativeSelectTest */
|
|
|
|
#endif /* defined(XP_UNIX) */
|
|
|
|
/************************************************************************/
|
|
|
|
static void Measure(void (*func)(void), const char *msg)
|
|
{
|
|
PRIntervalTime start, stop;
|
|
double d;
|
|
PRInt32 tot;
|
|
|
|
start = PR_IntervalNow();
|
|
(*func)();
|
|
stop = PR_IntervalNow();
|
|
|
|
d = (double)PR_IntervalToMicroseconds(stop - start);
|
|
tot = PR_IntervalToMilliseconds(stop-start);
|
|
|
|
if (debug_mode) printf("%40s: %6.2f usec avg, %d msec total\n", msg, d / count, tot);
|
|
}
|
|
|
|
int main(int argc, char **argv)
|
|
{
|
|
|
|
/* The command line argument: -d is used to determine if the test is being run
|
|
in debug mode. The regress tool requires only one line output:PASS or FAIL.
|
|
All of the printfs associated with this test has been handled with a if (debug_mode)
|
|
test.
|
|
Usage: test_name -d
|
|
*/
|
|
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_mode = 1;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
PL_DestroyOptState(opt);
|
|
|
|
/* main test */
|
|
|
|
PR_Init(PR_USER_THREAD, PR_PRIORITY_NORMAL, 0);
|
|
PR_STDIO_INIT();
|
|
|
|
if (argc > 2) {
|
|
count = atoi(argv[2]);
|
|
} else {
|
|
count = DEFAULT_COUNT;
|
|
}
|
|
|
|
#if defined(XP_UNIX)
|
|
Measure(NativeSelectTest, "time to call 1 element select()");
|
|
#endif
|
|
Measure(EmptyPRSelect, "time to call Empty PR_select()");
|
|
Measure(EmptyNativeSelect, "time to call Empty select()");
|
|
Measure(PRSelectTest, "time to call 1 element PR_select()");
|
|
|
|
if (!debug_mode) Test_Result (NOSTATUS);
|
|
PR_Cleanup();
|
|
|
|
|
|
}
|