Searched defs:threads (Results 1 - 19 of 19) sorted by relevance

/vbox/src/libs/xpcom18a4/nsprpub/pr/tests/
H A Dcleanup.c59 PR_fprintf(err, "\t-G Use global threads only (default: local)\n");
60 PR_fprintf(err, "\t-t n Number of threads involved (default: 1)\n");
74 PRIntn concurrency = 1, child_sleep = 10, main_sleep = 5, threads = 1; local
85 case 'G': /* local vs global threads */
97 case 't': /* number of threads to create */
98 threads = atoi(opt->value);
114 PR_fprintf(err, "\tNumber of threads: %d\n", threads);
121 while (threads-- > 0)
H A Dioconthr.c82 PRThread **threads; local
88 threads = (PRThread **) PR_MALLOC(num_threads * sizeof(PRThread *));
89 PR_ASSERT(threads != NULL);
96 threads[index] = PR_CreateThread(
99 if (NULL == threads[index]) {
105 /* Let the threads block in PR_Recv */
108 printf("Interrupting the threads\n");
112 if (PR_Interrupt(threads[index]) == PR_FAILURE) {
118 if (PR_JoinThread(threads[index]) == PR_FAILURE) {
130 fprintf(stderr, "Interrupting threads too
[all...]
H A Dconcur.c76 ** for Win16 threads
95 PRThread **threads; local
108 case 'G': /* GLOBAL threads */
136 threads = (PRThread**) PR_CALLOC(sizeof(PRThread*) * range);
144 threads[cpus - 1] = PR_CreateThread(
161 rc = PR_JoinThread(threads[cnt]);
180 PR_DELETE(threads);
H A Drwlocktest.c42 * Several threads are created to access and modify data arrays using
47 * Each one of the threads acquires a read lock to verify that the sum of
83 PRThread **threads; local
122 threads = (PRThread**) PR_CALLOC(sizeof(PRThread*) * thread_cnt);
148 * create LOCAL and GLOBAL threads alternately
155 threads[cnt] = PR_CreateThread(PR_USER_THREAD,
161 if (threads[cnt] == NULL) {
168 threads[cnt]);
172 rc = PR_JoinThread(threads[cnt]);
177 PR_DELETE(threads);
[all...]
H A Dstack.c43 * Two stacks are created and threads add data items (each containing
97 PRThread **threads; local
145 threads = (PRThread**) PR_CALLOC(sizeof(PRThread*) * thread_cnt);
166 threads[cnt] = PR_CreateThread(PR_USER_THREAD,
172 if (threads[cnt] == NULL) {
179 threads[cnt]);
183 rc = PR_JoinThread(threads[cnt]);
220 PR_DELETE(threads);
H A Dcvar2.c43 ** Description: Simple test creates several local and global threads;
99 /* Thread that gets notified; many threads share the same condvar */
126 /* Thread that gets notified; no other threads use the same condvar */
215 /* Create the threads */
234 /* Notify the threads */
244 /* Wait for threads to finish */
253 /* Join all the threads */
285 /* Create the threads */
303 /* Notify the threads */
313 printf("wait for threads t
877 PRThread *threads[3]; local
924 PRInt32 threads, default_threads = DEFAULT_THREADS; local
[all...]
H A Dthruput.c81 PRUint32 threads; member in struct:Shared
169 PR_fprintf(err, "%u streams @ %u Kbytes/sec\n", shared->threads, rate);
195 shared->threads += 1;
200 if (shared->threads == initial_streams)
256 PR_fprintf(err, "%u streams @ %u Kbytes/sec\n", shared->threads, rate);
295 shared->threads += 1;
314 PR_fprintf(err, "\t-G Use GLOBAL threads (default: LOCAL)\n");
339 case 'G': /* Globular threads */
383 PR_fprintf(err, " **Concurrency > 1 and GLOBAL threads!?!?\n");
396 "All threads wil
[all...]
H A Dtmoacc.c204 PRIntn threads = DEFAULT_THREADS; local
227 case 'G': /* use global threads */
233 case 't': /* number of threads doing accept */
234 threads = atoi(opt->value);
247 if (0 == threads) threads = DEFAULT_THREADS;
269 rv = PR_Listen(shared->listenSock, threads + backlog);
272 thread = (PRThread**)PR_CALLOC(threads * sizeof(PRThread*));
273 for (index = 0; index < threads; ++index)
286 for (index = 0; index < threads;
[all...]
H A Dtmocon.c282 * -t <n> number of threads sending (default = 1)
283 * -G use global threads (default = local)
294 PRIntn index, threads = DEFAULT_THREADS; local
347 case 't': /* number of threads sending */
348 threads = atoi(opt->value);
366 if (0 == threads) threads = DEFAULT_THREADS;
373 thread = (PRThread**)PR_CALLOC(threads * sizeof(PRThread*));
375 for (index = 0; index < threads; ++index)
380 for (index = 0; index < threads;
[all...]
H A Dy2ktmo.c50 * timeout values for these threads will span over the rollover
54 * the threads will time out at or after time (D + 5). The
55 * timeout values for the threads are spaced one second apart.
471 PRThread **threads; local
514 threads = PR_Malloc(
516 if (threads == NULL) {
526 threads[idx] = PR_CreateThread(PR_USER_THREAD, threadFuncs[j],
529 if (threads[idx] == NULL) {
538 if (PR_JoinThread(threads[idx]) == PR_FAILURE) {
543 PR_Free(threads);
[all...]
H A Dranfile.c255 ** argv[2] - the number of threads to toss into the batch
257 ** default values: loops = 2, threads = 10, limit = 57
268 ** 3) For [0..'threads') repeat [1..2]
270 ** 5) Collect the threads, accumulating the results
275 ** Random File: Using loops = 2, threads = 10, limit = 57
285 int limit = 0, loops = 0, threads = 0, times; local
303 case 'G': /* global threads */
312 case 't': /* number of threads */
313 threads = atoi(opt->value);
341 if (threads
[all...]
/vbox/src/libs/xpcom18a4/ipc/ipcd/extensions/lock/test/
H A DTestIPCLocks.cpp38 // This test program spawns N copies of itself, and each copy spawns M threads.
168 PRThread *threads[10] = {0}; local
173 threads[i] = PR_CreateThread(PR_USER_THREAD,
182 for (i=0; threads[i]; ++i)
184 PR_JoinThread(threads[i]);
185 threads[i] = nsnull;
190 LOG("joined with all threads; exiting DoTest\n");
/vbox/src/libs/xpcom18a4/xpcom/tests/
H A DTestThreads.cpp61 // worker threads run
169 static int Stress(int loops, int threads) argument
176 nsIThread** array = new nsIThread*[threads];
181 for (k = 0; k < threads; k++) {
190 for (k = threads-1; k >= 0; k--) {
206 static int StressNSPR(int loops, int threads) argument
213 PRThread** array = new PRThread*[threads];
216 for (k = 0; k < threads; k++) {
226 for (k = 0; k < threads; k++) {
230 for (k = threads
250 int threads; local
262 int threads; local
[all...]
/vbox/src/libs/xpcom18a4/nsprpub/lib/msgc/tests/
H A Dgc1.c64 static PRInt32 threads, waiting, iterations; variable
163 threads = 10;
177 case 't': /* number of threads */
178 threads = atoi(opt->value);
189 fprintf(stderr, "t is %ld, i is %ld\n", (long) threads, (long) iterations);
201 /* Spin all of the allocator threads and then wait for them to exit */
206 for (i = 0; i < threads; i++) {
214 while (waiting != threads) {
222 totalIterations = iterations * threads;
240 if (debug_mode) printf("%40s: %6.2f usec\n", "GC allocation", d / (iterations * threads));
[all...]
H A Dthrashgc.c182 fprintf(stderr, "Usage: %s [-t threads] [-l loops]\n", progname);
184 printf("Usage: %s [-t threads] [-l loops]\n", progname);
191 int threads = 0; local
201 threads = atoi(argv[++i]);
202 if (threads < 0) threads = 0;
203 if (threads > 10000) threads = 10000;
216 threads = 50;
219 for (i = 0; i < threads;
[all...]
/vbox/src/libs/xpcom18a4/xpcom/proxy/tests/
H A Dproxytests.cpp491 static PRThread** threads = (PRThread**) calloc(sizeof(PRThread*), numberOfThreads); local
518 threads[spawn] = PR_CreateThread(PR_USER_THREAD,
535 printf("Wait for threads.\n");
540 rv = PR_JoinThread(threads[i]);
/vbox/src/libs/xpcom18a4/nsprpub/pr/src/cplus/tests/
H A Dranfile.cpp287 ** argv[2] - the number of threads to toss into the batch
289 ** default values: max_virtual_procs = 2, threads = 10, limit = 57
300 ** 3) For [0..'threads') repeat [1..2]
302 ** 5) Collect the threads, accumulating the results
307 ** Random File: Using max_virtual_procs = 2, threads = 10, limit = 57
318 PRIntn active, poll, limit = 0, max_virtual_procs = 0, threads = 0, virtual_procs; local
332 case 'G': /* global threads */
341 case 't': /* number of threads */
342 threads = atoi(opt->value);
360 if (threads
[all...]
/vbox/src/VBox/Devices/Graphics/shaderlib/wine/include/wine/
H A Dserver_protocol.h2169 int threads; member in struct:next_process_reply
/vbox/src/VBox/Additions/WINNT/Graphics/Wine/include/wine/
H A Dserver_protocol.h1991 int threads; member in struct:next_process_reply

Completed in 177 milliseconds