Searched defs:worker (Results 1 - 17 of 17) sorted by relevance

/httpd/modules/proxy/balancers/
H A Dmod_lbmethod_bybusyness.c26 proxy_worker *worker, server_rec *s) = NULL;
32 proxy_worker **worker; local
60 worker = (proxy_worker **)balancer->workers->elts;
61 for (i = 0; i < balancer->workers->nelts; i++, worker++) {
63 if ((*worker)->s->lbset > max_lbset)
64 max_lbset = (*worker)->s->lbset;
67 ((*worker)->s->lbset != cur_lbset) ||
68 (checking_standby ? !PROXY_WORKER_IS_STANDBY(*worker) : PROXY_WORKER_IS_STANDBY(*worker)) ||
69 (PROXY_WORKER_IS_DRAINING(*worker))
124 proxy_worker **worker; local
[all...]
H A Dmod_lbmethod_byrequests.c26 proxy_worker *worker, server_rec *s) = NULL;
31 * lbfactor is "how much we expect this worker to work", or "the worker's
34 * lbstatus is "how urgent this worker has to work to fulfill its quota
37 * We distribute each worker's work quota to the worker, and then look
39 * worker is then selected for work, and its lbstatus reduced by the
48 * worker a b c d
57 * worker a b c d
63 * worker
79 proxy_worker **worker; local
155 proxy_worker **worker; local
[all...]
H A Dmod_lbmethod_bytraffic.c26 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; local
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)
127 proxy_worker **worker; local
[all...]
H A Dmod_lbmethod_heartbeat.c35 proxy_worker *worker, server_rec *s) = NULL;
56 proxy_worker *worker; member in struct:hb_server_t
265 proxy_worker **worker; local
302 worker = &APR_ARRAY_IDX(balancer->workers, i, proxy_worker *);
303 server = apr_hash_get(servers, (*worker)->s->hostname, APR_HASH_KEY_STRING);
307 "lb_heartbeat: No server for worker %s", (*worker)->s->name);
311 if (!PROXY_WORKER_IS_USABLE(*worker)) {
312 ap_proxy_retry_worker_fn("BALANCER", *worker, r->server);
315 if (PROXY_WORKER_IS_USABLE(*worker)) {
[all...]
/httpd/modules/proxy/examples/
H A Dmod_lbmethod_rr.c46 proxy_worker **worker; local
73 worker = (proxy_worker **)balancer->workers->elts;
75 for (i = 0; i < balancer->workers->nelts; i++, worker++) {
79 (checking_standby ? !PROXY_WORKER_IS_STANDBY(*worker) : PROXY_WORKER_IS_STANDBY(*worker)) ||
80 (PROXY_WORKER_IS_DRAINING(*worker))
84 if (!PROXY_WORKER_IS_USABLE(*worker))
85 ap_proxy_retry_worker("BALANCER", *worker, r->server);
86 if (PROXY_WORKER_IS_USABLE(*worker)) {
87 mycandidate = *worker;
[all...]
/httpd/modules/proxy/
H A Dmod_proxy_fdpass.c126 static int proxy_fdpass_handler(request_rec *r, proxy_worker *worker, argument
152 const char *flush_method = worker->s->flusher ? worker->s->flusher : "flush";
H A Dmod_proxy_connect.c194 static int proxy_connect_handler(request_rec *r, proxy_worker *worker, argument
H A Dmod_proxy_ajp.c215 conn->worker->cp->addr,
216 conn->worker->s->hostname);
222 * case we can dare to retry it with a different worker if we are
297 conn->worker->cp->addr,
298 conn->worker->s->hostname);
305 conn->worker->s->transferred += bufsiz;
337 conn->worker->cp->addr,
338 conn->worker->s->hostname);
342 * but doesn't affect the whole worker.
345 conn->worker
728 proxy_ajp_handler(request_rec *r, proxy_worker *worker, proxy_server_conf *conf, char *url, const char *proxyname, apr_port_t proxyport) argument
[all...]
H A Dmod_proxy_wstunnel.c332 proxy_worker *worker,
360 worker, conf, uri, url, server_portstr,
461 static int proxy_wstunnel_handler(request_rec *r, proxy_worker *worker, argument
500 status = ap_proxy_acquire_connection(scheme, &backend, worker,
517 status = ap_proxy_determine_connection(p, r, conf, worker, backend,
526 if (ap_proxy_connect_backend(scheme, backend, worker, r->server)) {
543 status = proxy_wstunnel_request(p, r, backend, worker, conf, uri, locurl,
330 proxy_wstunnel_request(apr_pool_t *p, request_rec *r, proxy_conn_rec *conn, proxy_worker *worker, proxy_server_conf *conf, apr_uri_t *uri, char *url, char *server_portstr, char *scheme) argument
H A Dmod_proxy_balancer.c32 proxy_worker *worker, server_rec *s) = NULL;
119 proxy_worker *worker = *workers; local
122 ap_proxy_worker_name(p, worker));
123 worker_is_initialized = PROXY_WORKER_IS_INITIALIZED(worker);
125 ap_proxy_initialize_worker(worker, s, p);
202 /* Find the worker that has the 'route' defined
217 proxy_worker *worker = *workers; local
218 if ( (checking_standby ? !PROXY_WORKER_IS_STANDBY(worker) : PROXY_WORKER_IS_STANDBY(worker)) )
220 if (*(worker
275 proxy_worker *worker = NULL; local
386 rewrite_url(request_rec *r, proxy_worker *worker, char **url) argument
411 proxy_worker **worker; local
444 proxy_worker *worker = worker_; local
453 proxy_balancer_pre_request(proxy_worker **worker, proxy_balancer **balancer, request_rec *r, proxy_server_conf *conf, char **url) argument
621 proxy_balancer_post_request(proxy_worker *worker, proxy_balancer *balancer, request_rec *r, proxy_server_conf *conf) argument
812 proxy_worker *worker; local
987 proxy_worker *worker, *wsel = NULL; local
[all...]
H A Dmod_proxy_fcgi.c136 /* Wrapper for apr_socket_sendv that handles updating the worker stats. */
175 conn->worker->s->transferred += written;
181 /* Wrapper for apr_socket_recv that handles updating the worker stats. */
189 conn->worker->s->read += *buflen;
448 if (conn->worker->s->io_buffer_size_set) {
449 iobuf_size = conn->worker->s->io_buffer_size;
860 static int proxy_fcgi_handler(request_rec *r, proxy_worker *worker, argument
889 status = ap_proxy_acquire_connection(FCGI_SCHEME, &backend, worker,
902 status = ap_proxy_determine_connection(p, r, conf, worker, backend,
916 if (worker
[all...]
H A Dmod_proxy_scgi.c244 conn->worker->s->transferred += written;
372 sock_data->counter = &conn->worker->s->read;
526 static int scgi_handler(request_rec *r, proxy_worker *worker, argument
543 status = ap_proxy_acquire_connection(PROXY_FUNCTION, &backend, worker,
551 status = ap_proxy_determine_connection(p, r, conf, worker, backend,
559 if (ap_proxy_connect_backend(PROXY_FUNCTION, backend, worker, r->server)) {
H A Dmod_proxy.c59 proxy_worker *worker,
71 worker->s->lbfactor = atoi(val);
72 if (worker->s->lbfactor < 1 || worker->s->lbfactor > 100)
76 /* If set it will give the retry timeout for the worker
83 worker->s->retry = apr_time_from_sec(ival);
84 worker->s->retry_set = 1;
93 worker->s->ttl = apr_time_from_sec(ival);
101 worker->s->min = ival;
109 worker
58 set_worker_param(apr_pool_t *p, proxy_worker *worker, const char *key, const char *val) argument
942 proxy_worker *worker = NULL; local
1758 proxy_worker *worker = ap_proxy_get_worker(cmd->temp_pool, NULL, conf, new->real); local
2197 proxy_worker *worker; local
2297 proxy_worker *worker = NULL; local
2395 proxy_worker *worker = NULL; local
2684 proxy_worker **worker = NULL; local
2804 proxy_worker *worker; local
[all...]
H A Dmod_proxy_ftp.c968 static int proxy_ftp_handler(request_rec *r, proxy_worker *worker, argument
1118 if (worker->s->is_address_reusable) {
1119 if (!worker->cp->addr) {
1120 if ((err = PROXY_THREAD_LOCK(worker->balancer)) != APR_SUCCESS) {
1125 connect_addr = worker->cp->addr;
1126 address_pool = worker->cp->pool;
1137 if (worker->s->is_address_reusable && !worker->cp->addr) {
1138 worker->cp->addr = connect_addr;
1139 if ((uerr = PROXY_THREAD_UNLOCK(worker
[all...]
H A Dmod_proxy_http.c731 proxy_conn_rec *p_conn, proxy_worker *worker,
762 worker, conf, uri, url, server_portstr,
1299 proxy_conn_rec **backend_ptr, proxy_worker *worker,
1331 do_100_continue = (worker->s->ping_timeout_set
1332 && (worker->s->ping_timeout >= 0)
1343 if (worker->s->ping_timeout != old_timeout) {
1345 rc = apr_socket_timeout_set(backend->sock, worker->s->ping_timeout);
1431 backend->worker->s->read += len;
1618 && (worker->s->ping_timeout != old_timeout)) {
1841 backend->worker
730 ap_proxy_http_prefetch(apr_pool_t *p, request_rec *r, proxy_conn_rec *p_conn, proxy_worker *worker, proxy_server_conf *conf, apr_uri_t *uri, char *url, char *server_portstr, apr_bucket_brigade *header_brigade, apr_bucket_brigade *input_brigade, char **old_cl_val, char **old_te_val, enum rb_methods *rb_method, int flushall) argument
1298 ap_proxy_http_process_response(apr_pool_t * p, request_rec *r, proxy_conn_rec **backend_ptr, proxy_worker *worker, proxy_server_conf *conf, char *server_portstr) argument
1978 proxy_http_handler(request_rec *r, proxy_worker *worker, proxy_server_conf *conf, char *url, const char *proxyname, apr_port_t proxyport) argument
[all...]
H A Dmod_proxy.h138 proxy_worker *forward; /* forward proxy worker */
139 proxy_worker *reverse; /* reverse "module-driven" proxy worker */
241 proxy_worker *worker; /* Connection pool this connection belongs to */ member in struct:__anon281
274 /* worker status bits */
286 /* worker status flags */
313 /* default worker retry timeout in seconds */
346 /* Runtime worker status informations. Shared in scoreboard */
354 char uds_path[PROXY_WORKER_MAX_NAME_SIZE]; /* path to worker's unix domain socket if applicable */
356 int retries; /* number of retries on this worker */
364 proxy_hashes hash; /* hash of worker nam
[all...]
H A Dproxy_util.c872 * find the particulars of the actual worker which may
879 proxy_worker **worker = (proxy_worker **)balancer->workers->elts; local
893 l2 = strlen((*worker)->s->name);
896 if ((*worker)->s->name[l2 - 1] == '/')
899 && strncasecmp((*worker)->s->name, url, l2) == 0
906 else if (l1 >= l2 && strncasecmp((*worker)->s->name, url, l2) == 0) {
915 worker++;
1273 * mutex and then attach to the shared worker shm
1318 proxy_worker *worker = (proxy_worker *)theworker; local
1319 if (worker
1325 init_conn_pool(apr_pool_t *p, proxy_worker *worker) argument
1349 proxy_worker *worker = conn->worker; local
1357 proxy_worker *worker = conn->worker; local
1455 proxy_worker *worker = (proxy_worker *)params; local
1502 ap_proxy_worker_name(apr_pool_t *p, proxy_worker *worker) argument
1556 proxy_worker *worker; local
1652 ap_proxy_define_worker(apr_pool_t *p, proxy_worker **worker, proxy_balancer *balancer, proxy_server_conf *conf, const char *url, int do_malloc) argument
1783 ap_proxy_define_match_worker(apr_pool_t *p, proxy_worker **worker, proxy_balancer *balancer, proxy_server_conf *conf, const char *url, int do_malloc) argument
1953 ap_proxy_retry_worker(const char *proxy_function, proxy_worker *worker, server_rec *s) argument
2012 ap_proxy_pre_request(proxy_worker **worker, proxy_balancer **balancer, request_rec *r, proxy_server_conf *conf, char **url) argument
2071 ap_proxy_post_request(proxy_worker *worker, proxy_balancer *balancer, request_rec *r, proxy_server_conf *conf) argument
2170 ap_proxy_acquire_connection(const char *proxy_function, proxy_conn_rec **conn, proxy_worker *worker, server_rec *s) argument
2234 ap_proxy_determine_connection(apr_pool_t *p, request_rec *r, proxy_server_conf *conf, proxy_worker *worker, proxy_conn_rec *conn, apr_uri_t *uri, char **url, const char *proxyname, apr_port_t proxyport, char *server_portstr, int server_portstr_size) argument
2695 ap_proxy_connect_backend(const char *proxy_function, proxy_conn_rec *conn, proxy_worker *worker, server_rec *s) argument
3191 proxy_worker *worker = *workers; local
3231 ap_proxy_find_workershm(ap_slotmem_provider_t *storage, ap_slotmem_instance_t *slot, proxy_worker *worker, unsigned int *index) argument
3330 ap_proxy_create_hdrbrgd(apr_pool_t *p, apr_bucket_brigade *header_brigade, request_rec *r, proxy_conn_rec *p_conn, proxy_worker *worker, proxy_server_conf *conf, apr_uri_t *uri, char *url, char *server_portstr, char **old_cl_val, char **old_te_val) argument
[all...]

Completed in 77 milliseconds