| /src/external/bsd/jemalloc/dist/msvc/test_threads/ |
| test_threads.cpp | 31 vector<thread> workers; local
41 workers.emplace_back([tid=i]() {
76 for (thread& t : workers) {
|
| /src/external/bsd/jemalloc.old/dist/msvc/test_threads/ |
| test_threads.cpp | 30 vector<thread> workers; local
40 workers.emplace_back([tid=i]() {
75 for (thread& t : workers) {
|
| /src/external/bsd/zstd/dist/programs/ |
| zstdcli_trace.c | 48 * workers
56 fprintf(g_traceFile, "Algorithm, Version, Method, Mode, Level, Workers, Dictionary Size, Uncompressed Size, Compressed Size, Duration Nanos, Compression Ratio, Speed MB/s\n");
83 int workers = 0; local
88 ZSTD_CCtxParams_getParameter(trace->params, ZSTD_c_nbWorkers, &workers);
99 * workers
113 workers,
|
| /src/external/mpl/bind/dist/tests/libtest/ |
| isc.c | 42 unsigned int workers = 0; variable
61 workers = atoi(env_workers);
63 workers = isc_os_ncpus();
66 if (workers < 2) {
67 workers = 2;
70 INSIST(workers != 0);
96 isc_loopmgr_create(mctx, workers, &loopmgr);
|
| /src/external/mit/libuv/dist/docs/code/multi-echo-server/ |
| main.c | 13 } *workers; variable in typeref:struct:child_worker
42 struct child_worker *worker = &workers[round_robin_counter];
65 // launch same number of workers as number of CPUs
73 workers = calloc(cpu_count, sizeof(struct child_worker));
75 struct child_worker *worker = &workers[cpu_count];
|
| /src/sys/external/bsd/compiler_rt/dist/lib/asan/tests/ |
| asan_mac_test.cc | 176 pthread_t workers[kNumWorkers], forker; local
178 PTHREAD_CREATE(&workers[i], 0, MallocIntrospectionLockWorker, 0);
182 PTHREAD_JOIN(workers[i], 0);
|
| /src/usr.sbin/nfsd/ |
| nfsd.c | 428 pthread_t *workers; local
521 workers = calloc(nfsdcnt, sizeof(*workers));
522 if (workers == NULL) {
530 error = pthread_create(&workers[i], NULL, worker, NULL);
564 pthread_join(workers[i], NULL);
|
| /src/external/bsd/unbound/dist/daemon/ |
| daemon.h | 2 * daemon/daemon.h - collection of workers that handles requests.
39 * The daemon consists of global settings and a number of workers.
115 struct worker** workers; member in struct:daemon
168 * changes for workers */
198 * Fork workers and start service.
212 * Delete workers, close listening ports.
|
| /src/external/mpl/bind/dist/bin/tests/ |
| test_client.c | 65 static int workers; variable
128 workers = val;
186 workers = isc_os_ncpus();
195 { "workers", required_argument, NULL, 'w' },
286 printf(" to %s, %d workers\n", buf, workers);
291 isc_managers_create(&mctx, workers, &loopmgr, &netmgr);
|
| test_server.c | 45 static int workers; variable
108 workers = val;
121 workers = isc_os_ncpus();
130 { "workers", required_argument, NULL, 'w' },
166 printf("Will listen at %s://%s, %d workers\n", protocols[protocol], buf,
167 workers);
172 isc_managers_create(&mctx, workers, &loopmgr, &netmgr);
|
| /src/sbin/dump/ |
| tape.c | 86 * sends writeheader()'s and lists of daddr's to the workers via pipes.
87 * The following structure defines the instruction packets sent to workers.
95 #define WORKERS 3 /* 1 worker writing, 1 reading, 1 for slack */
107 } workers[WORKERS+1]; variable in typeref:struct:worker
141 for (i = 0; i <= WORKERS; i++) {
144 workers[i].tblock = (char (*)[TP_BSIZE])
146 workers[i].req = (struct req *)workers[i].tblock - ntrec - 1;
148 wp = &workers[0]
[all...] |
| /src/crypto/external/apache2/openssl/dist/test/ |
| lhash_test.c | 499 static thread_t *workers; variable
519 TEST_info("using %d workers\n", num_workers);
522 free(workers);
524 workers = calloc(num_workers, sizeof(*workers));
525 return worker_exits != NULL && workers != NULL;
705 if (!run_thread(&workers[i], do_mt_hash_work))
711 wait_for_thread(workers[i]);
715 * Now that the workers are done, check for any error
741 free(workers);
[all...] |
| /src/external/bsd/ntp/dist/libntp/lib/isc/ |
| task.c | 143 unsigned int workers; member in struct:isc__taskmgr
226 isc__taskmgr_create(isc_mem_t *mctx, unsigned int workers,
1323 isc__taskmgr_create(isc_mem_t *mctx, unsigned int workers,
1334 REQUIRE(workers > 0);
1366 manager->workers = 0;
1368 workers * sizeof(isc_thread_t));
1413 * Start workers.
1415 for (i = 0; i < workers; i++) {
1417 &manager->threads[manager->workers]) ==
1419 manager->workers++
[all...] |
| /src/external/gpl3/gcc.old/dist/libgomp/plugin/ |
| plugin-nvptx.c | 852 int workers = gomp_openacc_dims[GOMP_DIM_WORKER]; local
876 if (workers == 0)
881 workers = blocks / actual_vectors;
882 workers = MAX (workers, 1);
886 workers = MIN (workers, 15);
894 case GOMP_DIM_WORKER: dims[i] = workers; break;
938 " gangs=%u, workers=%u, vectors=%u\n",
|
| /src/external/gpl3/gcc/dist/libgomp/plugin/ |
| plugin-nvptx.c | 869 int workers = gomp_openacc_dims[GOMP_DIM_WORKER]; local
893 if (workers == 0)
898 workers = blocks / actual_vectors;
899 workers = MAX (workers, 1);
903 workers = MIN (workers, 15);
911 case GOMP_DIM_WORKER: dims[i] = workers; break;
955 " gangs=%u, workers=%u, vectors=%u\n",
|
| /src/external/mpl/bind/dist/lib/isc/netmgr/ |
| netmgr-int.h | 338 isc__networker_t *workers; member in struct:isc_nm
1394 * Broadcast "stop" event for a listener socket across all workers and
|
| /src/external/mpl/dhcp/bind/dist/lib/isc/netmgr/ |
| netmgr-int.h | 662 isc__networker_t *workers; member in struct:isc_nm
681 * A worker is actively waiting for other workers, for example to
|
| /src/external/mpl/bind/dist/lib/dns/ |
| zone.c | 649 uint32_t workers; member in struct:dns_zonemgr
19257 .workers = isc_loopmgr_nloops(loopmgr),
19283 zmgr->mctxpool = isc_mem_cget(zmgr->mctx, zmgr->workers,
19285 for (size_t i = 0; i < zmgr->workers; i++) {
19323 tid = isc_random_uniform(zmgr->workers);
19469 for (size_t i = 0; i < zmgr->workers; i++) {
19497 isc_mem_cput(zmgr->mctx, zmgr->mctxpool, zmgr->workers,
|
