Searched refs:workers (Results 1 - 25 of 33) sorted by relevance

12

/macosx-10.10.1/apache-793/httpd/modules/proxy/examples/
H A Dmod_lbmethod_rr.c73 worker = (proxy_worker **)balancer->workers->elts;
75 for (i = 0; i < balancer->workers->nelts; i++, worker++) {
96 if (ctx->index >= balancer->workers->nelts) {
/macosx-10.10.1/apache-793/httpd/modules/proxy/balancers/
H A Dmod_lbmethod_bybusyness.c61 worker = (proxy_worker **)balancer->workers->elts;
62 for (i = 0; i < balancer->workers->nelts; i++, worker++) {
85 /* Take into calculation only the workers that are
126 worker = (proxy_worker **)balancer->workers->elts;
127 for (i = 0; i < balancer->workers->nelts; i++, worker++) {
H A Dmod_lbmethod_byrequests.c40 * total work quota we distributed to all workers. Thus the sum of all
43 * If some workers are disabled, the others will
103 worker = (proxy_worker **)balancer->workers->elts;
104 for (i = 0; i < balancer->workers->nelts; i++, worker++) {
125 /* Take into calculation only the workers that are
155 worker = (proxy_worker **)balancer->workers->elts;
156 for (i = 0; i < balancer->workers->nelts; i++, worker++) {
H A Dmod_lbmethod_bytraffic.c32 * worker. We normalize that traffic by each workers' weight. So assuming
75 worker = (proxy_worker **)balancer->workers->elts;
76 for (i = 0; i < balancer->workers->nelts; i++, worker++) {
97 /* Take into calculation only the workers that are
128 worker = (proxy_worker **)balancer->workers->elts;
129 for (i = 0; i < balancer->workers->nelts; i++, worker++) {
/macosx-10.10.1/bind9-45.101/bind9/bin/tests/
H A Drwlock_test.c96 isc_thread_t workers[100]; local
106 printf("%d workers\n", nworkers);
116 &workers[i]) ==
120 &workers[i]) ==
125 (void)isc_thread_join(workers[i], NULL);
H A Dtimer_test.c101 unsigned int workers; local
106 workers = atoi(argv[1]);
108 workers = 2;
109 printf("%d workers\n", workers);
112 RUNTIME_CHECK(isc_taskmgr_create(mctx1, workers, 0, &manager) ==
H A Dshutdown_test.c170 unsigned int workers; local
178 workers = atoi(argv[1]);
180 workers = 2;
181 printf("%d workers\n", workers);
187 RUNTIME_CHECK(isc_taskmgr_create(mctx, workers, 0, &task_manager) ==
H A Dtask_test.c67 unsigned int workers; local
73 workers = atoi(argv[1]);
75 workers = 2;
76 printf("%d workers\n", workers);
80 RUNTIME_CHECK(isc_taskmgr_create(mctx, workers, 0, &manager) ==
H A Dbyaddr_test.c81 unsigned int workers = 2; local
113 workers = (unsigned int)atoi(isc_commandline_argument);
119 printf("%u workers\n", workers);
125 RUNTIME_CHECK(isc_taskmgr_create(mctx, workers, 0, &taskmgr)
H A Dsock_test.c256 unsigned int workers; local
266 workers = atoi(argv[1]);
268 workers = 2;
269 printf("%d workers\n", workers);
286 RUNTIME_CHECK(isc_taskmgr_create(mctx, workers, 0, &manager) ==
H A Dbyname_test.c203 unsigned int workers = 2; local
231 workers = (unsigned int)atoi(isc_commandline_argument);
239 printf("%u workers\n", workers);
245 RUNTIME_CHECK(isc_taskmgr_create(mctx, workers, 0, &taskmgr) ==
/macosx-10.10.1/apache-793/httpd/modules/proxy/
H A Dmod_proxy_balancer.c113 proxy_worker **workers; local
115 workers = (proxy_worker **)balancer->workers->elts;
117 for (i = 0; i < balancer->workers->nelts; i++) {
119 proxy_worker *worker = *workers;
127 ++workers;
131 * workers.
133 if (!balancer->s->max_attempts_set && balancer->workers->nelts > 1) {
134 balancer->s->max_attempts = balancer->workers->nelts - 1;
211 proxy_worker **workers; local
499 proxy_worker **workers; local
524 proxy_worker **workers; local
678 proxy_worker **workers; local
812 proxy_worker **workers; local
989 proxy_worker **workers = NULL; local
[all...]
H A Dmod_proxy_balancer.c.orig113 proxy_worker **workers;
115 workers = (proxy_worker **)balancer->workers->elts;
117 for (i = 0; i < balancer->workers->nelts; i++) {
119 proxy_worker *worker = *workers;
127 ++workers;
131 * workers.
133 if (!balancer->s->max_attempts_set && balancer->workers->nelts > 1) {
134 balancer->s->max_attempts = balancer->workers->nelts - 1;
211 proxy_worker **workers;
[all...]
H A Dproxy_util.c885 proxy_worker **worker = (proxy_worker **)balancer->workers->elts;
898 for (n = 0; n < balancer->workers->nelts; n++) {
1173 (*balancer)->workers = apr_array_make(p, 5, sizeof(proxy_worker *));
1561 proxy_worker **workers = (proxy_worker **)balancer->workers->elts; local
1562 for (i = 0; i < balancer->workers->nelts; i++, workers++) {
1563 worker = *workers;
1574 worker = (proxy_worker *)conf->workers->elts;
1575 for (i = 0; i < conf->workers
2916 proxy_worker **workers; local
[all...]
/macosx-10.10.1/bind9-45.101/bind9/bin/tests/tasks/
H A Dt_tasks.c101 unsigned int workers; local
116 workers = 2;
119 workers = atoi(p);
120 if (workers < 1) {
121 t_info("Bad config value for ISC_TASK_WORKERS, %d\n", workers);
131 isc_result = isc_taskmgr_create(mctx, workers, 0, &manager);
487 unsigned int workers; local
496 workers = 2;
499 workers = atoi(p);
500 if (workers <
674 unsigned int workers; local
905 unsigned int workers; local
1110 unsigned int workers; local
1435 unsigned int workers; local
1862 unsigned int workers; local
2262 unsigned int workers; local
[all...]
/macosx-10.10.1/bind9-45.101/bind9/lib/isc/include/isc/
H A Dtask.h620 unsigned int workers, unsigned int default_quantum,
623 isc_taskmgr_create(isc_mem_t *mctx, unsigned int workers,
631 *\li 'workers' in the number of worker threads to create. In general,
633 * The 'workers' value is advisory only. An attempt will be made to
634 * create 'workers' threads, but if at least one thread creation
645 *\li workers > 0
711 (*isc_taskmgrcreatefunc_t)(isc_mem_t *mctx, unsigned int workers,
/macosx-10.10.1/bind9-45.101/bind9/lib/isc/
H A Dtask_api.c57 unsigned int workers, unsigned int default_quantum,
65 result = (*taskmgr_createfunc)(mctx, workers, default_quantum,
77 isc_taskmgr_create(isc_mem_t *mctx, unsigned int workers, argument
85 result = (*taskmgr_createfunc)(mctx, workers, default_quantum,
56 isc_taskmgr_createinctx(isc_mem_t *mctx, isc_appctx_t *actx, unsigned int workers, unsigned int default_quantum, isc_taskmgr_t **managerp) argument
H A Dtask.c141 unsigned int workers; member in struct:isc__taskmgr
220 isc__taskmgr_create(isc_mem_t *mctx, unsigned int workers,
1192 isc__taskmgr_create(isc_mem_t *mctx, unsigned int workers, argument
1203 REQUIRE(workers > 0);
1233 manager->workers = 0;
1235 workers * sizeof(isc_thread_t));
1271 * Start workers.
1273 for (i = 0; i < workers; i++) {
1275 &manager->threads[manager->workers]) ==
1277 manager->workers
[all...]
/macosx-10.10.1/ruby-106/ruby/lib/test/
H A Dunit.rb440 status_line = @workers.map(&:to_s).join(" ")
452 @workers.delete(worker)
454 @ios = @workers.map(&:io)
467 @workers << worker
475 @workers.delete worker
480 return if @workers.empty?
481 @workers.reject! do |worker|
492 return if @workers.empty?
494 timeout(0.2 * @workers.size) do
498 @workers
[all...]
/macosx-10.10.1/BerkeleyDB-21/db/test/scr016/src/com/sleepycat/db/test/
H A DRepmgrElectionTest.java56 Vector<RepmgrElectionTest> workers = new Vector<RepmgrElectionTest>(NUM_WORKER_THREADS);
61 workers.add(worker);
/macosx-10.10.1/ruby-106/ruby/test/thread/
H A Dtest_queue.rb19 workers = (1..num_threads).map {
35 workers.each { |t| t.join }
/macosx-10.10.1/ntp-92/lib/isc/include/isc/
H A Dtask.h543 isc_taskmgr_create(isc_mem_t *mctx, unsigned int workers,
550 *\li 'workers' in the number of worker threads to create. In general,
552 * The 'workers' value is advisory only. An attempt will be made to
553 * create 'workers' threads, but if at least one thread creation
564 *\li workers > 0
/macosx-10.10.1/ntp-92/lib/isc/
H A Dtask.c112 unsigned int workers; member in struct:isc_taskmgr
1031 isc_taskmgr_create(isc_mem_t *mctx, unsigned int workers, argument
1042 REQUIRE(workers > 0);
1048 UNUSED(workers);
1067 manager->workers = 0;
1069 workers * sizeof(isc_thread_t));
1105 * Start workers.
1107 for (i = 0; i < workers; i++) {
1109 &manager->threads[manager->workers]) ==
1111 manager->workers
[all...]
/macosx-10.10.1/mDNSResponder-561.1.1/mDNSWindows/
H A DPoll.c74 GenLinkedList workers; member in struct:Poll_struct
290 InitLinkedList( &gPoll.workers, offsetof( Worker, next ) );
326 for ( worker = gPoll.workers.Head; worker; worker = worker->next )
361 AddToTail( &gPoll.workers, worker );
396 dlog( kDebugLevelChatty, DEBUG_NAME "starting workers\n" );
398 worker = gPoll.workers.Head;
439 dlog( kDebugLevelChatty, DEBUG_NAME "stopping workers\n" );
445 // Wait For 5 seconds for all the workers to wake up
455 for ( worker = gPoll.workers.Head; worker; worker = worker->next )
476 RemoveFromList( &gPoll.workers, worke
[all...]
/macosx-10.10.1/bind9-45.101/bind9/bin/tests/timers/
H A Dt_timers.c194 unsigned int workers; local
201 workers = 2;
204 workers = atoi(p);
235 isc_result = isc_taskmgr_create(mctx, workers, 0, &tmgr);
885 unsigned int workers; local
896 workers = 2;
899 workers = atoi(p);
927 isc_result = isc_taskmgr_create(mctx, workers, 0, &tmgr);

Completed in 225 milliseconds

12