1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
/* -*- 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/. */
/*
* This test exercises the code that allocates and frees the syspoll_list
* array of PRThread in the pthreads version. This test is intended to be
* run under Purify to verify that there is no memory leak.
*/
#include "nspr.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#define POLL_DESC_COUNT 256 /* This should be greater than the
* STACK_POLL_DESC_COUNT macro in
* ptio.c to cause syspoll_list to
* be created. */
static PRPollDesc pd[POLL_DESC_COUNT];
static void Test(void)
{
int i;
PRInt32 rv;
PRIntervalTime timeout;
timeout = PR_MillisecondsToInterval(10);
/* cause syspoll_list to grow */
for (i = 1; i <= POLL_DESC_COUNT; i++) {
rv = PR_Poll(pd, i, timeout);
if (rv != 0) {
fprintf(stderr,
"PR_Poll should time out but returns %d (%d, %d)\n",
(int) rv, (int) PR_GetError(), (int) PR_GetOSError());
exit(1);
}
}
/* syspoll_list should be large enough for all these */
for (i = POLL_DESC_COUNT; i >= 1; i--) {
rv = PR_Poll(pd, i, timeout);
if (rv != 0) {
fprintf(stderr, "PR_Poll should time out but returns %d\n",
(int) rv);
exit(1);
}
}
}
static void ThreadFunc(void *arg)
{
Test();
}
int main(int argc, char **argv)
{
int i;
PRThread *thread;
PRFileDesc *sock;
PRNetAddr addr;
memset(&addr, 0, sizeof(addr));
addr.inet.family = PR_AF_INET;
addr.inet.port = PR_htons(0);
addr.inet.ip = PR_htonl(PR_INADDR_ANY);
for (i = 0; i < POLL_DESC_COUNT; i++) {
sock = PR_NewTCPSocket();
if (sock == NULL) {
fprintf(stderr, "PR_NewTCPSocket failed (%d, %d)\n",
(int) PR_GetError(), (int) PR_GetOSError());
fprintf(stderr, "Ensure the per process file descriptor limit "
"is greater than %d.", POLL_DESC_COUNT);
exit(1);
}
if (PR_Bind(sock, &addr) == PR_FAILURE) {
fprintf(stderr, "PR_Bind failed (%d, %d)\n",
(int) PR_GetError(), (int) PR_GetOSError());
exit(1);
}
if (PR_Listen(sock, 5) == PR_FAILURE) {
fprintf(stderr, "PR_Listen failed (%d, %d)\n",
(int) PR_GetError(), (int) PR_GetOSError());
exit(1);
}
pd[i].fd = sock;
pd[i].in_flags = PR_POLL_READ;
}
/* first run the test on the primordial thread */
Test();
/* then run the test on all three kinds of threads */
thread = PR_CreateThread(PR_USER_THREAD, ThreadFunc, NULL,
PR_PRIORITY_NORMAL, PR_LOCAL_THREAD, PR_JOINABLE_THREAD, 0);
if (NULL == thread) {
fprintf(stderr, "PR_CreateThread failed\n");
exit(1);
}
if (PR_JoinThread(thread) == PR_FAILURE) {
fprintf(stderr, "PR_JoinThread failed\n");
exit(1);
}
thread = PR_CreateThread(PR_USER_THREAD, ThreadFunc, NULL,
PR_PRIORITY_NORMAL, PR_GLOBAL_THREAD, PR_JOINABLE_THREAD, 0);
if (NULL == thread) {
fprintf(stderr, "PR_CreateThread failed\n");
exit(1);
}
if (PR_JoinThread(thread) == PR_FAILURE) {
fprintf(stderr, "PR_JoinThread failed\n");
exit(1);
}
thread = PR_CreateThread(PR_USER_THREAD, ThreadFunc, NULL,
PR_PRIORITY_NORMAL, PR_GLOBAL_BOUND_THREAD, PR_JOINABLE_THREAD, 0);
if (NULL == thread) {
fprintf(stderr, "PR_CreateThread failed\n");
exit(1);
}
if (PR_JoinThread(thread) == PR_FAILURE) {
fprintf(stderr, "PR_JoinThread failed\n");
exit(1);
}
for (i = 0; i < POLL_DESC_COUNT; i++) {
if (PR_Close(pd[i].fd) == PR_FAILURE) {
fprintf(stderr, "PR_Close failed\n");
exit(1);
}
}
PR_Cleanup();
printf("PASS\n");
return 0;
}
|
