Skip to content

Commit

Permalink
Add ap_proxy_worker_get_name() deprecating ap_proxy_worker_name()
Browse files Browse the repository at this point in the history
  • Loading branch information
@ylavic
ylavic committed Sep 20, 2023
1 parent b975293 commit aa79132
Show file tree
Hide file tree
Showing 5 changed files with 37 additions and 22 deletions.
3 changes: 2 additions & 1 deletion include/ap_mmn.h
View file
Original file line number Diff line number Diff line change
Expand Up @@ -720,14 +720,15 @@
* 20211221.14 (2.5.1-dev) Add request_rec->final_resp_passed bit
* 20211221.15 (2.5.1-dev) Add ap_get_pollfd_from_conn()
* 20211221.16 (2.5.1-dev) Add ap_proxy_determine_address()
* 20211221.17 (2.5.1-dev) Add ap_proxy_worker_get_name()
*/

#define MODULE_MAGIC_COOKIE 0x41503235UL /* "AP25" */

#ifndef MODULE_MAGIC_NUMBER_MAJOR
#define MODULE_MAGIC_NUMBER_MAJOR 20211221
#endif
#define MODULE_MAGIC_NUMBER_MINOR 16 /* 0...n */
#define MODULE_MAGIC_NUMBER_MINOR 17 /* 0...n */

/**
* Determine if the server's current MODULE_MAGIC_NUMBER is at least a
Expand Down
10 changes: 5 additions & 5 deletions modules/proxy/mod_proxy.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2241,14 +2241,14 @@ static const char *
reuse = 1;
ap_log_error(APLOG_MARK, APLOG_INFO, 0, cmd->server, APLOGNO(01145)
"Sharing worker '%s' instead of creating new worker '%s'",
ap_proxy_worker_name(NULL, worker), new->real);
ap_proxy_worker_get_name(worker), new->real);
}

for (i = 0; i < arr->nelts; i++) {
if (reuse) {
ap_log_error(APLOG_MARK, APLOG_WARNING, 0, cmd->server, APLOGNO(01146)
"Ignoring parameter '%s=%s' for worker '%s' because of worker sharing",
elts[i].key, elts[i].val, ap_proxy_worker_name(NULL, worker));
elts[i].key, elts[i].val, ap_proxy_worker_get_name(worker));
} else {
const char *err = set_worker_param(cmd->pool, s, worker, elts[i].key,
elts[i].val);
Expand Down Expand Up @@ -2793,13 +2793,13 @@ static const char *add_member(cmd_parms *cmd, void *dummy, const char *arg)
return apr_pstrcat(cmd->temp_pool, "BalancerMember ", err, NULL);
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, cmd->server, APLOGNO(01148)
"Defined worker '%s' for balancer '%s'",
ap_proxy_worker_name(NULL, worker), balancer->s->name);
ap_proxy_worker_get_name(worker), balancer->s->name);
PROXY_COPY_CONF_PARAMS(worker, conf);
} else {
reuse = 1;
ap_log_error(APLOG_MARK, APLOG_INFO, 0, cmd->server, APLOGNO(01149)
"Sharing worker '%s' instead of creating new worker '%s'",
ap_proxy_worker_name(NULL, worker), name);
ap_proxy_worker_get_name(worker), name);
}
if (!worker->section_config) {
worker->section_config = balancer->section_config;
Expand All @@ -2811,7 +2811,7 @@ static const char *add_member(cmd_parms *cmd, void *dummy, const char *arg)
if (reuse) {
ap_log_error(APLOG_MARK, APLOG_WARNING, 0, cmd->server, APLOGNO(01150)
"Ignoring parameter '%s=%s' for worker '%s' because of worker sharing",
elts[i].key, elts[i].val, ap_proxy_worker_name(NULL, worker));
elts[i].key, elts[i].val, ap_proxy_worker_get_name(worker));
} else {
err = set_worker_param(cmd->pool, cmd->server, worker, elts[i].key,
elts[i].val);
Expand Down
10 changes: 9 additions & 1 deletion modules/proxy/mod_proxy.h
View file
Original file line number Diff line number Diff line change
Expand Up @@ -767,13 +767,21 @@ typedef __declspec(dllimport) const char *
* Return the user-land, UDS aware worker name
* @param unused memory pool unused
* @param worker the worker
* @return name
* @return the name
* @note Even though the returned name is non constant char*, the string
* it points to is shared and should *not* be modified by the caller!
* @deprecated Replaced by ap_proxy_worker_get_name()
*/
PROXY_DECLARE(char *) ap_proxy_worker_name(apr_pool_t *unused,
proxy_worker *worker);

/**
* Return the user-land, UDS aware worker name
* @param worker the worker
* @return the name
*/
PROXY_DECLARE(const char *) ap_proxy_worker_get_name(const proxy_worker *worker);

/**
* Return whether a worker upgrade configuration matches Upgrade header
* @param p memory pool used for displaying worker name
Expand Down
12 changes: 6 additions & 6 deletions modules/proxy/mod_proxy_balancer.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -153,7 +153,7 @@ static void init_balancer_members(proxy_balancer *balancer,
proxy_worker *worker = *workers;
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, APLOGNO(01158)
"Looking at %s -> %s initialized?", balancer->s->name,
ap_proxy_worker_name(NULL, worker));
ap_proxy_worker_get_name(worker));
worker_is_initialized = PROXY_WORKER_IS_INITIALIZED(worker);
if (!worker_is_initialized) {
ap_proxy_initialize_worker(worker, s, p);
Expand Down Expand Up @@ -696,7 +696,7 @@ static int proxy_balancer_post_request(proxy_worker *worker,
"%s: Forcing worker (%s) into error state "
"due to status code %d matching 'failonstatus' "
"balancer parameter",
balancer->s->name, ap_proxy_worker_name(NULL, worker),
balancer->s->name, ap_proxy_worker_get_name(worker),
val);
worker->s->status |= PROXY_WORKER_IN_ERROR;
worker->s->error_time = apr_time_now();
Expand All @@ -711,7 +711,7 @@ static int proxy_balancer_post_request(proxy_worker *worker,
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(02460)
"%s: Forcing worker (%s) into error state "
"due to timeout and 'failontimeout' parameter being set",
balancer->s->name, ap_proxy_worker_name(NULL, worker));
balancer->s->name, ap_proxy_worker_get_name(worker));
worker->s->status |= PROXY_WORKER_IN_ERROR;
worker->s->error_time = apr_time_now();

Expand Down Expand Up @@ -1494,7 +1494,7 @@ static void balancer_display_page(request_rec *r, proxy_server_conf *conf,
worker = *workers;
/* Start proxy_worker */
ap_rputs(" <httpd:worker>\n", r);
ap_rvputs(r, " <httpd:name>", ap_proxy_worker_name(NULL, worker),
ap_rvputs(r, " <httpd:name>", ap_proxy_worker_get_name(worker),
"</httpd:name>\n", NULL);
ap_rvputs(r, " <httpd:scheme>", worker->s->scheme,
"</httpd:scheme>\n", NULL);
Expand Down Expand Up @@ -1735,7 +1735,7 @@ static void balancer_display_page(request_rec *r, proxy_server_conf *conf,
ap_escape_uri(r->pool, worker->s->name),
"&amp;nonce=", balancer->s->nonce,
"\">", NULL);
ap_rvputs(r, (*worker->s->uds_path ? "<i>" : ""), ap_proxy_worker_name(NULL, worker),
ap_rvputs(r, (*worker->s->uds_path ? "<i>" : ""), ap_proxy_worker_get_name(worker),
(*worker->s->uds_path ? "</i>" : ""), "</a></td>", NULL);
ap_rvputs(r, "<td>", ap_escape_html(r->pool, worker->s->route),
NULL);
Expand Down Expand Up @@ -1772,7 +1772,7 @@ static void balancer_display_page(request_rec *r, proxy_server_conf *conf,
}
if (wsel && bsel) {
ap_rputs("<h3>Edit worker settings for ", r);
ap_rvputs(r, (*wsel->s->uds_path?"<i>":""), ap_proxy_worker_name(NULL, wsel), (*wsel->s->uds_path?"</i>":""), "</h3>\n", NULL);
ap_rvputs(r, (*wsel->s->uds_path?"<i>":""), ap_proxy_worker_get_name(wsel), (*wsel->s->uds_path?"</i>":""), "</h3>\n", NULL);
ap_rputs("<form method='POST' enctype='application/x-www-form-urlencoded' action=\"", r);
ap_rvputs(r, ap_escape_uri(r->pool, action), "\">\n", NULL);
ap_rputs("<table><tr><td>Load factor:</td><td><input name='w_lf' id='w_lf' type=text ", r);
Expand Down
24 changes: 15 additions & 9 deletions modules/proxy/proxy_util.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1652,7 +1652,7 @@ static void connection_cleanup(void *theconn)
ap_log_perror(APLOG_MARK, APLOG_ERR, 0, conn->pool, APLOGNO(00923)
"Pooled connection 0x%pp for worker %s has been"
" already returned to the connection pool.", conn,
ap_proxy_worker_name(NULL, worker));
ap_proxy_worker_get_name(worker));
return;
}

Expand Down Expand Up @@ -1765,11 +1765,17 @@ static apr_status_t connection_destructor(void *resource, void *params,
* WORKER related...
*/

PROXY_DECLARE(const char *) ap_proxy_worker_get_name(const proxy_worker *worker)
{
return worker->uds_name ? worker->uds_name : worker->s->name;
}

/* Deprecated/legacy */
PROXY_DECLARE(char *) ap_proxy_worker_name(apr_pool_t *unused,
proxy_worker *worker)
{
(void)unused;
return worker->uds_name ? (char *)worker->uds_name : worker->s->name;
return (char *)ap_proxy_worker_get_name(worker);
}

PROXY_DECLARE(int) ap_proxy_worker_can_upgrade(apr_pool_t *p,
Expand Down Expand Up @@ -2225,7 +2231,7 @@ PROXY_DECLARE(apr_status_t) ap_proxy_share_worker(proxy_worker *worker, proxy_wo
apr_pool_tag(pool, "proxy_worker_name");
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, ap_server_conf, APLOGNO(02338)
"%s shm[%d] (0x%pp) for worker: %s", action, i, (void *)shm,
ap_proxy_worker_name(NULL, worker));
ap_proxy_worker_get_name(worker));
if (pool) {
apr_pool_destroy(pool);
}
Expand All @@ -2243,12 +2249,12 @@ PROXY_DECLARE(apr_status_t) ap_proxy_initialize_worker(proxy_worker *worker, ser
/* The worker is already initialized */
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, APLOGNO(00924)
"worker %s shared already initialized",
ap_proxy_worker_name(NULL, worker));
ap_proxy_worker_get_name(worker));
}
else {
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, APLOGNO(00925)
"initializing worker %s shared",
ap_proxy_worker_name(NULL, worker));
ap_proxy_worker_get_name(worker));
/* Set default parameters */
if (!worker->s->retry_set) {
worker->s->retry = apr_time_from_sec(PROXY_WORKER_DEFAULT_RETRY);
Expand All @@ -2267,7 +2273,7 @@ PROXY_DECLARE(apr_status_t) ap_proxy_initialize_worker(proxy_worker *worker, ser
if (worker->s->disablereuse_set) {
ap_log_error(APLOG_MARK, APLOG_WARNING, 0, s, APLOGNO(10400)
"enablereuse/disablereuse ignored for worker %s",
ap_proxy_worker_name(NULL, worker));
ap_proxy_worker_get_name(worker));
}
worker->s->disablereuse = 1;
}
Expand Down Expand Up @@ -2311,15 +2317,15 @@ PROXY_DECLARE(apr_status_t) ap_proxy_initialize_worker(proxy_worker *worker, ser
if (worker->local_status & PROXY_WORKER_INITIALIZED) {
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, APLOGNO(00926)
"worker %s local already initialized",
ap_proxy_worker_name(NULL, worker));
ap_proxy_worker_get_name(worker));
}
else {
apr_global_mutex_lock(proxy_mutex);
/* Check again after we got the lock if we are still uninitialized */
if (!(AP_VOLATILIZE_T(unsigned int, worker->local_status) & PROXY_WORKER_INITIALIZED)) {
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, APLOGNO(00927)
"initializing worker %s local",
ap_proxy_worker_name(NULL, worker));
ap_proxy_worker_get_name(worker));
/* Now init local worker data */
#if APR_HAS_THREADS
if (worker->tmutex == NULL) {
Expand Down Expand Up @@ -4200,7 +4206,7 @@ PROXY_DECLARE(apr_status_t) ap_proxy_sync_balancer(proxy_balancer *b, server_rec
found = 1;
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, APLOGNO(02402)
"re-grabbing shm[%d] (0x%pp) for worker: %s", i, (void *)shm,
ap_proxy_worker_name(NULL, worker));
ap_proxy_worker_get_name(worker));
break;
}
}
Expand Down

0 comments on commit aa79132

Please sign in to comment.