From: Jim Jagielski Date: Thu, 13 Jan 2011 15:59:05 +0000 (+0000) Subject: Builds and passes tests as prefork... good save state X-Git-Tag: 2.3.11~224 X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=fab3678ad3d745693182ad5af18bd583645030b1;p=apache Builds and passes tests as prefork... good save state git-svn-id: https://svn.apache.org/repos/asf/httpd/httpd/trunk@1058625 13f79535-47bb-0310-9956-ffa450edef68 --- diff --git a/modules/proxy/mod_proxy.c b/modules/proxy/mod_proxy.c index bd6c6aea62..c84cd9a59f 100644 --- a/modules/proxy/mod_proxy.c +++ b/modules/proxy/mod_proxy.c @@ -1442,7 +1442,7 @@ static const char * arr = apr_table_elts(params); elts = (const apr_table_entry_t *)arr->elts; /* Distinguish the balancer from worker */ - if (ap_proxy_valid_balancer_name(r)) { + if (ap_proxy_valid_balancer_name(r, 9)) { proxy_balancer *balancer = ap_proxy_get_balancer(cmd->pool, conf, r); if (!balancer) { const char *err = ap_proxy_define_balancer(cmd->pool, &balancer, conf, r); @@ -1947,7 +1947,7 @@ static const char * name = ap_getword_conf(cmd->temp_pool, &arg); } - if (ap_proxy_valid_balancer_name(name)) { + if (ap_proxy_valid_balancer_name(name, 9)) { balancer = ap_proxy_get_balancer(cmd->pool, conf, name); if (!balancer) { if (in_proxy_section) { @@ -2096,7 +2096,7 @@ static const char *proxysection(cmd_parms *cmd, void *mconfig, const char *arg) return apr_pstrcat(cmd->pool, thiscmd->name, "> arguments are not supported for non url.", NULL); - if (ap_proxy_valid_balancer_name((char*)conf->p)) { + if (ap_proxy_valid_balancer_name((char *)conf->p, 9)) { balancer = ap_proxy_get_balancer(cmd->pool, sconf, conf->p); if (!balancer) { err = ap_proxy_define_balancer(cmd->pool, &balancer, @@ -2372,16 +2372,22 @@ static void child_init(apr_pool_t *p, server_rec *s) void *sconf = s->module_config; proxy_server_conf *conf; proxy_worker *worker; + int i; conf = (proxy_server_conf *)ap_get_module_config(sconf, &proxy_module); /* * NOTE: non-balancer members don't use shm at all... * after all, why should they? */ + worker = (proxy_worker *)conf->workers->elts; + for (i = 0; i < conf->workers->nelts; i++, worker++) { + ap_proxy_initialize_worker(worker, s, conf->pool); + } /* Create and initialize forward worker if defined */ if (conf->req_set && conf->req) { - ap_proxy_define_worker(p, &worker, NULL, NULL, "http://www.apache.org"); - conf->forward = worker; + proxy_worker *forward; + ap_proxy_define_worker(p, &forward, NULL, NULL, "http://www.apache.org"); + conf->forward = forward; PROXY_STRNCPY(conf->forward->s->name, "proxy:forward"); PROXY_STRNCPY(conf->forward->s->hostname, "*"); PROXY_STRNCPY(conf->forward->s->scheme, "*"); @@ -2391,6 +2397,7 @@ static void child_init(apr_pool_t *p, server_rec *s) conf->forward->s->status |= PROXY_WORKER_IGNORE_ERRORS; /* Disable address cache for generic forward worker */ conf->forward->s->is_address_reusable = 0; + ap_proxy_initialize_worker(conf->forward, s, conf->pool); } if (!reverse) { ap_proxy_define_worker(p, &reverse, NULL, NULL, "http://www.apache.org"); @@ -2405,6 +2412,7 @@ static void child_init(apr_pool_t *p, server_rec *s) reverse->s->is_address_reusable = 0; } conf->reverse = reverse; + ap_proxy_initialize_worker(conf->reverse, s, conf->pool); s = s->next; } } diff --git a/modules/proxy/mod_proxy.h b/modules/proxy/mod_proxy.h index 7965b65b82..d75628605a 100644 --- a/modules/proxy/mod_proxy.h +++ b/modules/proxy/mod_proxy.h @@ -58,6 +58,7 @@ #include "http_connection.h" #include "util_filter.h" #include "util_ebcdic.h" +#include "util_md5.h" #include "ap_provider.h" #include "ap_slotmem.h" @@ -157,7 +158,7 @@ typedef struct { status_full } proxy_status; /* Status display options */ apr_sockaddr_t *source_address; - apr_global_mutex_t *mutex; /* global lock for updating lb params */ + apr_global_mutex_t *mutex; /* global lock (needed??) */ int req_set:1; int viaopt_set:1; @@ -342,6 +343,7 @@ struct proxy_worker { proxy_worker_shared *s; /* Shared data */ proxy_balancer *balancer; /* which balancer am I in? */ apr_thread_mutex_t *mutex; /* Thread lock for updating address cache */ + int local_status; /* status of per-process worker */ void *context; /* general purpose storage */ }; @@ -357,6 +359,7 @@ struct proxy_balancer { int growth; /* number of post-config workers can added */ int max_workers; /* maximum number of allowed workers */ const char *name; /* name of the load balancer */ + const char *sname; /* filesystem safe balancer name */ apr_interval_time_t timeout; /* Timeout for waiting on free connection */ const char *lbprovider; /* name of the lbmethod provider to use */ proxy_balancer_method *lbmethod; @@ -371,6 +374,7 @@ struct proxy_balancer { int max_attempts_set:1; void *context; /* general purpose storage */ apr_time_t updated; /* timestamp of last update */ + apr_global_mutex_t *mutex; /* global lock for updating lb params */ }; struct proxy_balancer_method { @@ -560,9 +564,10 @@ PROXY_DECLARE(apr_status_t) ap_proxy_initialize_worker(proxy_worker *worker, /** * Verifies valid balancer name (eg: balancer://foo) * @param name name to test - * @return ptr to start of name or NULL if not valid + * @param i number of chars to test; 0 for all. + * @return true/false */ -PROXY_DECLARE(char *) ap_proxy_valid_balancer_name(char *name); +PROXY_DECLARE(int) ap_proxy_valid_balancer_name(char *name, int i); /** diff --git a/modules/proxy/mod_proxy_balancer.c b/modules/proxy/mod_proxy_balancer.c index 982ccf2092..f367795420 100644 --- a/modules/proxy/mod_proxy_balancer.c +++ b/modules/proxy/mod_proxy_balancer.c @@ -62,6 +62,7 @@ static int proxy_balancer_canon(request_rec *r, char *url) const char *err; apr_port_t port = 0; + /* TODO: offset of BALANCER_PREFIX ?? */ if (strncasecmp(url, "balancer:", 9) == 0) { url += 9; } @@ -98,7 +99,7 @@ static int proxy_balancer_canon(request_rec *r, char *url) if (path == NULL) return HTTP_BAD_REQUEST; - r->filename = apr_pstrcat(r->pool, "proxy:balancer://", host, + r->filename = apr_pstrcat(r->pool, "proxy:", BALANCER_PREFIX, host, "/", path, (search) ? "?" : "", (search) ? search : "", NULL); r->path_info = apr_pstrcat(r->pool, "/", path, NULL); @@ -117,6 +118,8 @@ static void init_balancer_members(proxy_server_conf *conf, server_rec *s, for (i = 0; i < balancer->workers->nelts; i++) { int worker_is_initialized; proxy_worker *worker = *workers; + ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, + "Looking at %s -> %s initialized?", balancer->name, worker->s->name); worker_is_initialized = PROXY_WORKER_IS_INITIALIZED(worker); if (!worker_is_initialized) { ap_proxy_initialize_worker(worker, s, conf->pool); @@ -324,10 +327,8 @@ static proxy_worker *find_best_worker(proxy_balancer *balancer, { proxy_worker *candidate = NULL; apr_status_t rv; - proxy_server_conf *conf = (proxy_server_conf *) - ap_get_module_config(r->server->module_config, &proxy_module); - if ((rv = PROXY_GLOBAL_LOCK(conf)) != APR_SUCCESS) { + if ((rv = PROXY_GLOBAL_LOCK(balancer)) != APR_SUCCESS) { ap_log_error(APLOG_MARK, APLOG_ERR, rv, r->server, "proxy: BALANCER: (%s). Lock failed for find_best_worker()", balancer->name); return NULL; @@ -343,7 +344,7 @@ static proxy_worker *find_best_worker(proxy_balancer *balancer, return NULL; */ - if ((rv = PROXY_GLOBAL_UNLOCK(conf)) != APR_SUCCESS) { + if ((rv = PROXY_GLOBAL_UNLOCK(balancer)) != APR_SUCCESS) { ap_log_error(APLOG_MARK, APLOG_ERR, rv, r->server, "proxy: BALANCER: (%s). Unlock failed for find_best_worker()", balancer->name); } @@ -465,7 +466,7 @@ static int proxy_balancer_pre_request(proxy_worker **worker, /* Step 2: Lock the LoadBalancer * XXX: perhaps we need the process lock here */ - if ((rv = PROXY_GLOBAL_LOCK(conf)) != APR_SUCCESS) { + if ((rv = PROXY_GLOBAL_LOCK(*balancer)) != APR_SUCCESS) { ap_log_error(APLOG_MARK, APLOG_ERR, rv, r->server, "proxy: BALANCER: (%s). Lock failed for pre_request", (*balancer)->name); @@ -531,7 +532,7 @@ static int proxy_balancer_pre_request(proxy_worker **worker, ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, "proxy: BALANCER: (%s). All workers are in error state for route (%s)", (*balancer)->name, route); - if ((rv = PROXY_GLOBAL_UNLOCK(conf)) != APR_SUCCESS) { + if ((rv = PROXY_GLOBAL_UNLOCK(*balancer)) != APR_SUCCESS) { ap_log_error(APLOG_MARK, APLOG_ERR, rv, r->server, "proxy: BALANCER: (%s). Unlock failed for pre_request", (*balancer)->name); @@ -540,7 +541,7 @@ static int proxy_balancer_pre_request(proxy_worker **worker, } } - if ((rv = PROXY_GLOBAL_UNLOCK(conf)) != APR_SUCCESS) { + if ((rv = PROXY_GLOBAL_UNLOCK(*balancer)) != APR_SUCCESS) { ap_log_error(APLOG_MARK, APLOG_ERR, rv, r->server, "proxy: BALANCER: (%s). Unlock failed for pre_request", (*balancer)->name); @@ -616,7 +617,7 @@ static int proxy_balancer_post_request(proxy_worker *worker, apr_status_t rv; - if ((rv = PROXY_GLOBAL_LOCK(conf)) != APR_SUCCESS) { + if ((rv = PROXY_GLOBAL_LOCK(balancer)) != APR_SUCCESS) { ap_log_error(APLOG_MARK, APLOG_ERR, rv, r->server, "proxy: BALANCER: (%s). Lock failed for post_request", balancer->name); @@ -638,7 +639,7 @@ static int proxy_balancer_post_request(proxy_worker *worker, } } - if ((rv = PROXY_GLOBAL_UNLOCK(conf)) != APR_SUCCESS) { + if ((rv = PROXY_GLOBAL_UNLOCK(balancer)) != APR_SUCCESS) { ap_log_error(APLOG_MARK, APLOG_ERR, rv, r->server, "proxy: BALANCER: (%s). Unlock failed for post_request", balancer->name); @@ -676,12 +677,18 @@ static void recalc_factors(proxy_balancer *balancer) static apr_status_t lock_remove(void *data) { + int i; + proxy_balancer *balancer; server_rec *s = data; void *sconf = s->module_config; proxy_server_conf *conf = (proxy_server_conf *) ap_get_module_config(sconf, &proxy_module); - if (conf->mutex) { - apr_global_mutex_destroy(conf->mutex); - conf->mutex = NULL; + + balancer = (proxy_balancer *)conf->balancers->elts; + for (i = 0; i < conf->balancers->nelts; i++, balancer++) { + if (balancer->mutex) { + apr_global_mutex_destroy(balancer->mutex); + balancer->mutex = NULL; + } } return(0); } @@ -692,7 +699,6 @@ static int balancer_post_config(apr_pool_t *pconf, apr_pool_t *plog, { apr_uuid_t uuid; void *data; - apr_status_t rv; void *sconf = s->module_config; proxy_server_conf *conf = (proxy_server_conf *) ap_get_module_config(sconf, &proxy_module); const char *userdata_key = "mod_proxy_balancer_init"; @@ -709,19 +715,7 @@ static int balancer_post_config(apr_pool_t *pconf, apr_pool_t *plog, * the process. */ apr_uuid_get(&uuid); apr_uuid_format(balancer_nonce, &uuid); - - /* Create global mutex */ - rv = ap_global_mutex_create(&conf->mutex, NULL, balancer_mutex_type, NULL, - s, pconf, 0); - if (rv != APR_SUCCESS || !conf->mutex) { - ap_log_error(APLOG_MARK, APLOG_EMERG, rv, s, - "mutex creation of %s failed", balancer_mutex_type); - return HTTP_INTERNAL_SERVER_ERROR; - } - - apr_pool_cleanup_register(pconf, (void *)s, lock_remove, - apr_pool_cleanup_null); - + /* * Get worker slotmem setup @@ -739,23 +733,39 @@ static int balancer_post_config(apr_pool_t *pconf, apr_pool_t *plog, while (s) { int i,j; apr_status_t rv; + proxy_balancer *balancer; sconf = s->module_config; conf = (proxy_server_conf *)ap_get_module_config(sconf, &proxy_module); /* Initialize shared scoreboard data */ - proxy_balancer *balancer = (proxy_balancer *)conf->balancers->elts; + balancer = (proxy_balancer *)conf->balancers->elts; for (i = 0; i < conf->balancers->nelts; i++, balancer++) { proxy_worker **workers; proxy_worker *worker; ap_slotmem_instance_t *new = NULL; balancer->max_workers = balancer->workers->nelts + balancer->growth; - - ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, "Doing create: %s, %d, %d", - balancer->name, (int)sizeof(proxy_worker_shared), + balancer->sname = ap_md5(pconf, (const unsigned char *)balancer->name); + + /* Create global mutex */ + rv = ap_global_mutex_create(&(balancer->mutex), NULL, balancer_mutex_type, + balancer->sname, s, pconf, 0); + if (rv != APR_SUCCESS || !balancer->mutex) { + ap_log_error(APLOG_MARK, APLOG_EMERG, rv, s, + "mutex creation of %s : %s failed", balancer_mutex_type, + balancer->sname); + return HTTP_INTERNAL_SERVER_ERROR; + } + + apr_pool_cleanup_register(pconf, (void *)s, lock_remove, + apr_pool_cleanup_null); + + ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, "Doing create: %s (%s), %d, %d", + balancer->name, balancer->sname, + (int)sizeof(proxy_worker_shared), (int)balancer->max_workers); - rv = storage->create(&new, balancer->name, sizeof(proxy_worker_shared), + rv = storage->create(&new, balancer->sname, sizeof(proxy_worker_shared), balancer->max_workers, AP_SLOTMEM_TYPE_PREGRAB, pconf); if (rv != APR_SUCCESS) { ap_log_error(APLOG_MARK, APLOG_EMERG, rv, s, "slotmem_create failed"); @@ -778,7 +788,6 @@ static int balancer_post_config(apr_pool_t *pconf, apr_pool_t *plog, ap_log_error(APLOG_MARK, APLOG_EMERG, rv, s, "slotmem_dptr failed"); return !OK; } - ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, "Doing share: %x %pp %pp %pp %pp %d", worker->hash, worker->balancer, (char *)worker->context, worker->s, shm, (int)index); if ((rv = ap_proxy_share_worker(worker, shm, index)) != APR_SUCCESS) { ap_log_error(APLOG_MARK, APLOG_EMERG, rv, s, "Cannot share worker"); return !OK; @@ -851,7 +860,7 @@ static int balancer_handler(request_rec *r) if ((name = apr_table_get(params, "b"))) bsel = ap_proxy_get_balancer(r->pool, conf, - apr_pstrcat(r->pool, "balancer://", name, NULL)); + apr_pstrcat(r->pool, BALANCER_PREFIX, name, NULL)); if ((name = apr_table_get(params, "w"))) { wsel = ap_proxy_get_worker(r->pool, bsel, conf, name); } @@ -974,7 +983,7 @@ static int balancer_handler(request_rec *r) char fbuf[50]; worker = *workers; ap_rvputs(r, "\nuri, "?b=", - balancer->name + sizeof("balancer://") - 1, "&w=", + balancer->name + sizeof(BALANCER_PREFIX) - 1, "&w=", ap_escape_uri(r->pool, worker->s->name), "&nonce=", balancer_nonce, "\">", NULL); @@ -1038,7 +1047,7 @@ static int balancer_handler(request_rec *r) ap_rvputs(r, "\npool, wsel->s->name), "\">\n", NULL); ap_rvputs(r, "name + sizeof("balancer://") - 1, + ap_rvputs(r, "value=\"", bsel->name + sizeof(BALANCER_PREFIX) - 1, "\">\n", NULL); ap_rvputs(r, "\n", NULL); @@ -1059,29 +1068,36 @@ static void balancer_child_init(apr_pool_t *p, server_rec *s) void *sconf = s->module_config; proxy_server_conf *conf = (proxy_server_conf *)ap_get_module_config(sconf, &proxy_module); apr_status_t rv; - - if (!conf->mutex) { - ap_log_error(APLOG_MARK, APLOG_INFO, 0, s, - "no mutex %s", balancer_mutex_type); - return; - } - /* Re-open the mutex for the child. */ - rv = apr_global_mutex_child_init(&conf->mutex, - apr_global_mutex_lockfile(conf->mutex), - p); - if (rv != APR_SUCCESS) { - ap_log_error(APLOG_MARK, APLOG_CRIT, rv, s, - "Failed to reopen mutex %s in child", - balancer_mutex_type); - exit(1); /* Ugly, but what else? */ - } - - /* Initialize shared scoreboard data */ + balancer = (proxy_balancer *)conf->balancers->elts; for (i = 0; i < conf->balancers->nelts; i++) { apr_size_t size; unsigned int num; - storage->attach(&(balancer->slot), balancer->name, &size, &num, p); + + /* + * for each balancer we need to init the global + * mutex and then attach to the shared worker shm + */ + if (!balancer->mutex) { + ap_log_error(APLOG_MARK, APLOG_INFO, 0, s, + "no mutex %s: %s", balancer->name, + balancer_mutex_type); + return; + } + + /* Re-open the mutex for the child. */ + rv = apr_global_mutex_child_init(&(balancer->mutex), + apr_global_mutex_lockfile(balancer->mutex), + p); + if (rv != APR_SUCCESS) { + ap_log_error(APLOG_MARK, APLOG_CRIT, rv, s, + "Failed to reopen mutex %: %s in child", + balancer->name, balancer_mutex_type); + exit(1); /* Ugly, but what else? */ + } + + /* now attach */ + storage->attach(&(balancer->slot), balancer->sname, &size, &num, p); if (!balancer->slot) { ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_EMERG, 0, s, "slotmem_attach failed"); exit(1); /* Ugly, but what else? */ diff --git a/modules/proxy/proxy_util.c b/modules/proxy/proxy_util.c index 42b2c613b0..1fbb525e13 100644 --- a/modules/proxy/proxy_util.c +++ b/modules/proxy/proxy_util.c @@ -1092,7 +1092,6 @@ PROXY_DECLARE(const char *) ap_proxy_location_reverse_map(request_rec *r, ap_get_module_config(r->server->module_config, &proxy_module); proxy_balancer *balancer; const char *real = ent[i].real; - const char *bname; /* * First check if mapping against a balancer and see * if we have such a entity. If so, then we need to @@ -1100,11 +1099,11 @@ PROXY_DECLARE(const char *) ap_proxy_location_reverse_map(request_rec *r, * or may not be the right one... basically, we need * to find which member actually handled this request. */ - bname = ap_proxy_valid_balancer_name((char *)real); - if (bname && (balancer = ap_proxy_get_balancer(r->pool, sconf, real))) { + if (ap_proxy_valid_balancer_name((char *)real, 0) && + (balancer = ap_proxy_get_balancer(r->pool, sconf, real))) { int n, l3 = 0; proxy_worker **worker = (proxy_worker **)balancer->workers->elts; - const char *urlpart = ap_strchr_c(bname, '/'); + const char *urlpart = ap_strchr_c(real, '/'); if (urlpart) { if (!urlpart[1]) urlpart = NULL; @@ -1290,16 +1289,13 @@ PROXY_DECLARE(const char *) ap_proxy_cookie_reverse_map(request_rec *r, */ /* - * verifies that the balancer name conforms to standards. If - * so, returns ptr to the actual name (BALANCER_PREFIX removed), - * otherwise NULL + * verifies that the balancer name conforms to standards. */ -PROXY_DECLARE(char *) ap_proxy_valid_balancer_name(char *name) +PROXY_DECLARE(int) ap_proxy_valid_balancer_name(char *name, int i) { - if (strncasecmp(name, BALANCER_PREFIX, sizeof(BALANCER_PREFIX)-1) == 0) - return (name + sizeof(BALANCER_PREFIX)-1); - else - return NULL; + if (!i) + i = sizeof(BALANCER_PREFIX)-1; + return (!strncasecmp(name, BALANCER_PREFIX, i)); } @@ -1308,19 +1304,20 @@ PROXY_DECLARE(proxy_balancer *) ap_proxy_get_balancer(apr_pool_t *p, const char *url) { proxy_balancer *balancer; - char *name, *q, *uri = apr_pstrdup(p, url); + char *c, *uri = apr_pstrdup(p, url); int i; - - if (!(name = ap_proxy_valid_balancer_name(uri))) - return NULL; - + + c = strchr(uri, ':'); + if (c == NULL || c[1] != '/' || c[2] != '/' || c[3] == '\0') { + return NULL; + } /* remove path from uri */ - if ((q = strchr(name, '/'))) - *q = '\0'; - + if ((c = strchr(c + 3, '/'))) { + *c = '\0'; + } balancer = (proxy_balancer *)conf->balancers->elts; for (i = 0; i < conf->balancers->nelts; i++) { - if (strcasecmp(balancer->name, name) == 0) { + if (strcasecmp(balancer->name, uri) == 0) { return balancer; } balancer++; @@ -1333,20 +1330,19 @@ PROXY_DECLARE(char *) ap_proxy_define_balancer(apr_pool_t *p, proxy_server_conf *conf, const char *url) { - char *name, *q, *uri = apr_pstrdup(p, url); + char *c, *q, *uri = apr_pstrdup(p, url); proxy_balancer_method *lbmethod; /* We should never get here without a valid BALANCER_PREFIX... */ - name = ap_proxy_valid_balancer_name(uri); - if (!name) - return apr_pstrcat(p, "Bad syntax for a balancer name ", uri, NULL); - + c = strchr(uri, ':'); + if (c == NULL || c[1] != '/' || c[2] != '/' || c[3] == '\0') + return "Bad syntax for a balancer name"; /* remove path from uri */ - if ((q = strchr(name, '/'))) + if ((q = strchr(c + 3, '/'))) *q = '\0'; - ap_str_tolower(name); + ap_str_tolower(uri); *balancer = apr_array_push(conf->balancers); memset(*balancer, 0, sizeof(proxy_balancer)); @@ -1359,10 +1355,11 @@ PROXY_DECLARE(char *) ap_proxy_define_balancer(apr_pool_t *p, return "Can't find 'byrequests' lb method"; } - (*balancer)->name = name; + (*balancer)->name = uri; (*balancer)->lbmethod = lbmethod; (*balancer)->workers = apr_array_make(p, 5, sizeof(proxy_worker *)); (*balancer)->updated = apr_time_now(); + (*balancer)->mutex = NULL; return NULL; } @@ -1741,96 +1738,111 @@ PROXY_DECLARE(apr_status_t) ap_proxy_share_worker(proxy_worker *worker, proxy_wo PROXY_DECLARE(apr_status_t) ap_proxy_initialize_worker(proxy_worker *worker, server_rec *s, apr_pool_t *p) { - apr_status_t rv; + apr_status_t rv = APR_SUCCESS; int mpm_threads; if (worker->s->status & PROXY_WORKER_INITIALIZED) { /* The worker is already initialized */ - return APR_SUCCESS; - } - - /* Set default parameters */ - if (!worker->s->retry_set) { - worker->s->retry = apr_time_from_sec(PROXY_WORKER_DEFAULT_RETRY); - } - /* By default address is reusable unless DisableReuse is set */ - if (worker->s->disablereuse) { - worker->s->is_address_reusable = 0; + ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, + "worker %s shared already initialized", worker->s->name); } else { - worker->s->is_address_reusable = 1; - } - - if (worker->cp == NULL) - init_conn_pool(p, worker); - if (worker->cp == NULL) { ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, - "can not create connection pool"); - return APR_EGENERAL; - } - - if (worker->mutex == NULL) { - rv = apr_thread_mutex_create(&(worker->mutex), APR_THREAD_MUTEX_DEFAULT, p); - if (rv != APR_SUCCESS) { - ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, - "can not create thread mutex"); - return rv; + "initializing worker %s shared", worker->s->name); + /* Set default parameters */ + if (!worker->s->retry_set) { + worker->s->retry = apr_time_from_sec(PROXY_WORKER_DEFAULT_RETRY); } - } - - ap_mpm_query(AP_MPMQ_MAX_THREADS, &mpm_threads); - if (mpm_threads > 1) { - /* Set hard max to no more then mpm_threads */ - if (worker->s->hmax == 0 || worker->s->hmax > mpm_threads) { - worker->s->hmax = mpm_threads; + /* By default address is reusable unless DisableReuse is set */ + if (worker->s->disablereuse) { + worker->s->is_address_reusable = 0; } - if (worker->s->smax == -1 || worker->s->smax > worker->s->hmax) { - worker->s->smax = worker->s->hmax; + else { + worker->s->is_address_reusable = 1; } - /* Set min to be lower then smax */ - if (worker->s->min > worker->s->smax) { - worker->s->min = worker->s->smax; + + ap_mpm_query(AP_MPMQ_MAX_THREADS, &mpm_threads); + if (mpm_threads > 1) { + /* Set hard max to no more then mpm_threads */ + if (worker->s->hmax == 0 || worker->s->hmax > mpm_threads) { + worker->s->hmax = mpm_threads; + } + if (worker->s->smax == -1 || worker->s->smax > worker->s->hmax) { + worker->s->smax = worker->s->hmax; + } + /* Set min to be lower then smax */ + if (worker->s->min > worker->s->smax) { + worker->s->min = worker->s->smax; + } + } + else { + /* This will supress the apr_reslist creation */ + worker->s->min = worker->s->smax = worker->s->hmax = 0; } } - else { - /* This will supress the apr_reslist creation */ - worker->s->min = worker->s->smax = worker->s->hmax = 0; - } - if (worker->s->hmax) { - rv = apr_reslist_create(&(worker->cp->res), - worker->s->min, worker->s->smax, - worker->s->hmax, worker->s->ttl, - connection_constructor, connection_destructor, - worker, worker->cp->pool); - - apr_pool_cleanup_register(worker->cp->pool, (void *)worker, - conn_pool_cleanup, - apr_pool_cleanup_null); + /* What if local is init'ed and shm isn't?? Even possible? */ + if (worker->local_status & PROXY_WORKER_INITIALIZED) { + ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, + "worker %s local already initialized", worker->s->name); + } + else { ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, - "proxy: initialized worker in child %" APR_PID_T_FMT " for (%s) min=%d max=%d smax=%d", - getpid(), worker->s->hostname, worker->s->min, - worker->s->hmax, worker->s->smax); + "initializing worker %s local", worker->s->name); + /* Now init local worker data */ + if (worker->cp == NULL) + init_conn_pool(p, worker); + if (worker->cp == NULL) { + ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, + "can not create connection pool"); + return APR_EGENERAL; + } - /* Set the acquire timeout */ - if (rv == APR_SUCCESS && worker->s->acquire_set) { - apr_reslist_timeout_set(worker->cp->res, worker->s->acquire); + if (worker->mutex == NULL) { + rv = apr_thread_mutex_create(&(worker->mutex), APR_THREAD_MUTEX_DEFAULT, p); + if (rv != APR_SUCCESS) { + ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, + "can not create thread mutex"); + return rv; + } } - } - else - { - void *conn; + if (worker->s->hmax) { + rv = apr_reslist_create(&(worker->cp->res), + worker->s->min, worker->s->smax, + worker->s->hmax, worker->s->ttl, + connection_constructor, connection_destructor, + worker, worker->cp->pool); - rv = connection_constructor(&conn, worker, worker->cp->pool); - worker->cp->conn = conn; + apr_pool_cleanup_register(worker->cp->pool, (void *)worker, + conn_pool_cleanup, + apr_pool_cleanup_null); - ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, - "proxy: initialized single connection worker in child %" APR_PID_T_FMT " for (%s)", - getpid(), worker->s->hostname); + ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, + "proxy: initialized pool in child %" APR_PID_T_FMT " for (%s) min=%d max=%d smax=%d", + getpid(), worker->s->hostname, worker->s->min, + worker->s->hmax, worker->s->smax); + + /* Set the acquire timeout */ + if (rv == APR_SUCCESS && worker->s->acquire_set) { + apr_reslist_timeout_set(worker->cp->res, worker->s->acquire); + } + + } + else { + void *conn; + + rv = connection_constructor(&conn, worker, worker->cp->pool); + worker->cp->conn = conn; + + ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, + "proxy: initialized single connection worker in child %" APR_PID_T_FMT " for (%s)", + getpid(), worker->s->hostname); + } } if (rv == APR_SUCCESS) { worker->s->status |= (PROXY_WORKER_INITIALIZED); + worker->local_status |= (PROXY_WORKER_INITIALIZED); } return rv; } @@ -2046,8 +2058,7 @@ PROXY_DECLARE(int) ap_proxy_acquire_connection(const char *proxy_function, if (worker->s->hmax && worker->cp->res) { rv = apr_reslist_acquire(worker->cp->res, (void **)conn); } - else - { + else { /* create the new connection if the previous was destroyed */ if (!worker->cp->conn) { connection_constructor((void **)conn, worker, worker->cp->pool); @@ -2769,7 +2780,8 @@ ap_proxy_hashfunc(const char *str, proxy_hash_t method) if (method == PROXY_HASHFUNC_APR) { apr_ssize_t slen = strlen(str); return apr_hashfunc_default(str, &slen); - } else if (method == PROXY_HASHFUNC_FNV) { + } + else if (method == PROXY_HASHFUNC_FNV) { /* FNV model */ unsigned int hash; const unsigned int fnv_prime = 0x811C9DC5; @@ -2778,7 +2790,8 @@ ap_proxy_hashfunc(const char *str, proxy_hash_t method) hash ^= (*str); } return hash; - } else { /* method == PROXY_HASHFUNC_DEFAULT */ + } + else { /* method == PROXY_HASHFUNC_DEFAULT */ /* SDBM model */ unsigned int hash; for (hash = 0; *str; str++) {