Lines Matching defs:worker
26 proxy_worker *worker, server_rec *s) = NULL;
32 * worker. We normalize that traffic by each workers' weight. So assuming
35 * worker a b c
38 * the scheduler will allow worker c to handle 3 times the
51 proxy_worker **worker;
75 worker = (proxy_worker **)balancer->workers->elts;
76 for (i = 0; i < balancer->workers->nelts; i++, worker++) {
78 if ((*worker)->s->lbset > max_lbset)
79 max_lbset = (*worker)->s->lbset;
82 ((*worker)->s->lbset != cur_lbset) ||
83 (checking_standby ? !PROXY_WORKER_IS_STANDBY(*worker) : PROXY_WORKER_IS_STANDBY(*worker)) ||
84 (PROXY_WORKER_IS_DRAINING(*worker))
89 /* If the worker is in error state run
90 * retry on that worker. It will be marked as
92 * The worker might still be unusable, but we try
95 if (!PROXY_WORKER_IS_USABLE(*worker))
96 ap_proxy_retry_worker_fn("BALANCER", *worker, r->server);
100 if (PROXY_WORKER_IS_USABLE(*worker)) {
101 mytraffic = ((*worker)->s->transferred/(*worker)->s->lbfactor) +
102 ((*worker)->s->read/(*worker)->s->lbfactor);
104 mycandidate = *worker;
116 "proxy: bytraffic selected worker \"%s\" : busy %" APR_SIZE_T_FMT,
127 proxy_worker **worker;
128 worker = (proxy_worker **)balancer->workers->elts;
129 for (i = 0; i < balancer->workers->nelts; i++, worker++) {
130 (*worker)->s->lbstatus = 0;
131 (*worker)->s->busy = 0;
132 (*worker)->s->transferred = 0;
133 (*worker)->s->read = 0;