summaryrefslogtreecommitdiffstats
path: root/nsprpub/pr/tests/io_timeoutu.c
diff options
context:
space:
mode:
Diffstat (limited to 'nsprpub/pr/tests/io_timeoutu.c')
-rw-r--r--nsprpub/pr/tests/io_timeoutu.c136
1 files changed, 82 insertions, 54 deletions
diff --git a/nsprpub/pr/tests/io_timeoutu.c b/nsprpub/pr/tests/io_timeoutu.c
index 7b3ba7c92..b6d9ccfa3 100644
--- a/nsprpub/pr/tests/io_timeoutu.c
+++ b/nsprpub/pr/tests/io_timeoutu.c
@@ -10,12 +10,12 @@
**
** Modification History:
** 19-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 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.
+** have been handled with an if (debug_mode) statement.
** 04-June-97 AGarcia removed the Test_Result function. Regress tool has been updated to
-** recognize the return code from tha main program.
+** recognize the return code from tha main program.
***********************************************************************/
/***********************************************************************
** Includes
@@ -40,7 +40,7 @@ typedef struct threadInfo {
PRIntn failed_already=0;
PRIntn debug_mode;
-void
+void
thread_main(void *_info)
{
threadInfo *info = (threadInfo *)_info;
@@ -49,61 +49,77 @@ thread_main(void *_info)
PRFileDesc *listenSock = NULL;
PRFileDesc *clientSock;
PRStatus rv;
-
- if (debug_mode) printf("thread %d is alive\n", info->id);
+
+ if (debug_mode) {
+ printf("thread %d is alive\n", info->id);
+ }
listenSock = PR_NewTCPSocket();
if (!listenSock) {
- if (debug_mode) printf("unable to create listen socket\n");
+ if (debug_mode) {
+ printf("unable to create listen socket\n");
+ }
goto dead;
}
-
+
listenAddr.inet.family = AF_INET;
listenAddr.inet.port = PR_htons(BASE_PORT + info->id);
listenAddr.inet.ip = PR_htonl(INADDR_ANY);
rv = PR_Bind(listenSock, &listenAddr);
if (rv == PR_FAILURE) {
- if (debug_mode) printf("unable to bind\n");
+ if (debug_mode) {
+ printf("unable to bind\n");
+ }
goto dead;
}
rv = PR_Listen(listenSock, 4);
if (rv == PR_FAILURE) {
- if (debug_mode) printf("unable to listen\n");
+ if (debug_mode) {
+ printf("unable to listen\n");
+ }
goto dead;
}
- if (debug_mode) printf("thread %d going into accept for %d seconds\n",
- info->id, info->accept_timeout + info->id);
+ if (debug_mode) printf("thread %d going into accept for %d seconds\n",
+ info->id, info->accept_timeout + info->id);
clientSock = PR_Accept(
- listenSock, &clientAddr, PR_SecondsToInterval(
- info->accept_timeout + info->id));
+ listenSock, &clientAddr, PR_SecondsToInterval(
+ info->accept_timeout + info->id));
if (clientSock == NULL) {
- if (PR_GetError() == PR_IO_TIMEOUT_ERROR)
+ if (PR_GetError() == PR_IO_TIMEOUT_ERROR)
if (debug_mode) {
- printf("PR_Accept() timeout worked!\n");
+ printf("PR_Accept() timeout worked!\n");
printf("TEST FAILED! PR_Accept() returned error %d\n",
- }
- PR_GetError());
- else failed_already=1;
+ }
+ PR_GetError());
+ else {
+ failed_already=1;
+ }
} else {
- if (debug_mode) printf ("TEST FAILED! PR_Accept() succeeded?\n");
- else failed_already=1;
- PR_Close(clientSock);
+ if (debug_mode) {
+ printf ("TEST FAILED! PR_Accept() succeeded?\n");
+ }
+ else {
+ failed_already=1;
+ }
+ PR_Close(clientSock);
}
dead:
if (listenSock) {
- PR_Close(listenSock);
+ PR_Close(listenSock);
}
PR_Lock(info->dead_lock);
(*info->alive)--;
PR_NotifyCondVar(info->dead_cv);
PR_Unlock(info->dead_lock);
- if (debug_mode) printf("thread %d is dead\n", info->id);
+ if (debug_mode) {
+ printf("thread %d is dead\n", info->id);
+ }
}
void
@@ -115,12 +131,14 @@ thread_test(PRInt32 scope, PRInt32 num_threads)
PRCondVar *dead_cv;
PRInt32 alive;
- if (debug_mode) printf("IO Timeout test started with %d threads\n", num_threads);
+ if (debug_mode) {
+ printf("IO Timeout test started with %d threads\n", num_threads);
+ }
dead_lock = PR_NewLock();
dead_cv = PR_NewCondVar(dead_lock);
alive = num_threads;
-
+
for (index = 0; index < num_threads; index++) {
threadInfo *info = (threadInfo *)malloc(sizeof(threadInfo));
@@ -129,7 +147,7 @@ thread_test(PRInt32 scope, PRInt32 num_threads)
info->dead_cv = dead_cv;
info->alive = &alive;
info->accept_timeout = DEFAULT_ACCEPT_TIMEOUT;
-
+
thr = PR_CreateThread( PR_USER_THREAD,
thread_main,
(void *)info,
@@ -147,7 +165,9 @@ thread_test(PRInt32 scope, PRInt32 num_threads)
PR_Lock(dead_lock);
while(alive) {
- if (debug_mode) printf("main loop awake; alive = %d\n", alive);
+ if (debug_mode) {
+ printf("main loop awake; alive = %d\n", alive);
+ }
PR_WaitCondVar(dead_cv, PR_INTERVAL_NO_TIMEOUT);
}
PR_Unlock(dead_lock);
@@ -157,46 +177,54 @@ int main(int argc, char **argv)
{
PRInt32 num_threads;
- /* 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)))
+ /* 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;
+ if (PL_OPT_BAD == os) {
+ continue;
+ }
switch (opt->option)
{
- case 'd': /* debug mode */
- debug_mode = 1;
- break;
- default:
- break;
+ case 'd': /* debug mode */
+ debug_mode = 1;
+ break;
+ default:
+ break;
}
}
- PL_DestroyOptState(opt);
+ PL_DestroyOptState(opt);
+
+ /* main test */
- /* main test */
-
- if (argc > 2)
+ if (argc > 2) {
num_threads = atoi(argv[2]);
- else
+ }
+ else {
num_threads = NUM_THREADS;
+ }
PR_Init(PR_USER_THREAD, PR_PRIORITY_LOW, 0);
PR_STDIO_INIT();
- if (debug_mode) printf("user level test\n");
+ if (debug_mode) {
+ printf("user level test\n");
+ }
thread_test(PR_LOCAL_THREAD, num_threads);
- PR_Cleanup();
- if(failed_already)
+ PR_Cleanup();
+ if(failed_already) {
return 1;
- else
+ }
+ else {
return 0;
-
+ }
+
}
generated by cgit v1.2.3 (git 2.25.1) at 2024-12-28 06:22:40 +0000