Mailing List Archive

Le 28/08/2022 à 20:46, jim@apache.org a écrit :
> Author: jim
> Date: Sun Aug 28 18:46:21 2022
> New Revision: 1903744
>
> URL: http://svn.apache.org/viewvc?rev=1903744&view=rev
> Log:
> Allow for HTTP/1.1 or HTTP/1.0 protocol health checks
>
> Modified:
> httpd/httpd/trunk/docs/manual/mod/mod_proxy_hcheck.xml
> httpd/httpd/trunk/modules/proxy/mod_proxy.c
> httpd/httpd/trunk/modules/proxy/mod_proxy.h
> httpd/httpd/trunk/modules/proxy/mod_proxy_hcheck.c
>
> Modified: httpd/httpd/trunk/docs/manual/mod/mod_proxy_hcheck.xml
> URL: http://svn.apache.org/viewvc/httpd/httpd/trunk/docs/manual/mod/mod_proxy_hcheck.xml?rev=1903744&r1=1903743&r2=1903744&view=diff
> ==============================================================================
> --- httpd/httpd/trunk/docs/manual/mod/mod_proxy_hcheck.xml (original)
> +++ httpd/httpd/trunk/docs/manual/mod/mod_proxy_hcheck.xml Sun Aug 28 18:46:21 2022
> @@ -60,9 +60,12 @@
> <tr><th>Method</th><th>Description</th><th>Note</th></tr>
> <tr><td>None</td><td>No dynamic health checking done</td><td></td></tr>
> <tr><td>TCP</td><td>Check that a socket to the backend can be created: e.g. "are you up"</td><td></td></tr>
> - <tr><td>OPTIONS</td><td>Send an <code>HTTP OPTIONS</code> request to the backend</td><td>*</td></tr>
> - <tr><td>HEAD</td><td>Send an <code>HTTP HEAD</code> request to the backend</td><td>*</td></tr>
> - <tr><td>GET</td><td>Send an <code>HTTP GET</code> request to the backend</td><td>*</td></tr>
> + <tr><td>OPTIONS</td><td>Send a <code>HTTP OPTIONS</code> request to the backend via <code>HTTP/1.0</code></td><td>*</td></tr>
> + <tr><td>HEAD</td><td>Send a <code>HTTP HEAD</code> request to the backend via <code>HTTP/1.0</code></td><td>*</td></tr>
> + <tr><td>GET</td><td>Send a <code>HTTP GET</code> request to the backend via <code>HTTP/1.0</code></td><td>*</td></tr>
> + <tr><td>OPTIONS11</td><td>Send a <code>HTTP OPTIONS</code> request to the backend via <code>HTTP/1.1</code></td><td>*</td></tr>
> + <tr><td>HEAD11</td><td>Send a <code>HTTP HEAD</code> request to the backend via <code>HTTP/1.1</code></td><td>*</td></tr>
> + <tr><td>GET11</td><td>Send a <code>HTTP GET</code> request to the backend via <code>HTTP/1.1</code></td><td>*</td></tr>
> <!--
> <tr><td>CPING</td><td><strong>AJP only</strong> Do <code>CPING/CPONG</code> check</td><td></td></tr>
> <tr><td>PROVIDER</td><td>Name of <code>provider</code> to be used to check health</td><td></td></tr>
>
> Modified: httpd/httpd/trunk/modules/proxy/mod_proxy.c
> URL: http://svn.apache.org/viewvc/httpd/httpd/trunk/modules/proxy/mod_proxy.c?rev=1903744&r1=1903743&r2=1903744&view=diff
> ==============================================================================
> --- httpd/httpd/trunk/modules/proxy/mod_proxy.c (original)
> +++ httpd/httpd/trunk/modules/proxy/mod_proxy.c Sun Aug 28 18:46:21 2022
> @@ -52,6 +52,9 @@ proxy_hcmethods_t PROXY_DECLARE_DATA pro
> {GET, "GET", 1},
> {CPING, "CPING", 0},
> {PROVIDER, "PROVIDER", 0},
> + {OPTIONS11, "OPTIONS11", 1},
> + {HEAD11, "HEAD11", 1},
> + {GET11, "GET11", 1},
> {EOT, NULL, 1}
> };
>
>
> Modified: httpd/httpd/trunk/modules/proxy/mod_proxy.h
> URL: http://svn.apache.org/viewvc/httpd/httpd/trunk/modules/proxy/mod_proxy.h?rev=1903744&r1=1903743&r2=1903744&view=diff
> ==============================================================================
> --- httpd/httpd/trunk/modules/proxy/mod_proxy.h (original)
> +++ httpd/httpd/trunk/modules/proxy/mod_proxy.h Sun Aug 28 18:46:21 2022
> @@ -77,7 +77,7 @@ enum enctype {
> };
>
> typedef enum {
> - NONE, TCP, OPTIONS, HEAD, GET, CPING, PROVIDER, EOT
> + NONE, TCP, OPTIONS, HEAD, GET, CPING, PROVIDER, OPTIONS11, HEAD11, GET11, EOT
> } hcmethod_t;
>
> typedef struct {
>
> Modified: httpd/httpd/trunk/modules/proxy/mod_proxy_hcheck.c
> URL: http://svn.apache.org/viewvc/httpd/httpd/trunk/modules/proxy/mod_proxy_hcheck.c?rev=1903744&r1=1903743&r2=1903744&view=diff
> ==============================================================================
> --- httpd/httpd/trunk/modules/proxy/mod_proxy_hcheck.c (original)
> +++ httpd/httpd/trunk/modules/proxy/mod_proxy_hcheck.c Sun Aug 28 18:46:21 2022
> @@ -65,6 +65,7 @@ typedef struct {
> const char *method; /* Method string for the HTTP/AJP request */
> const char *req; /* pre-formatted HTTP/AJP request */
> proxy_worker *w; /* Pointer to the actual worker */
> + const char *protocol; /* HTTP 1.0 or 1.1? */
> } wctx_t;
>
> typedef struct {
> @@ -342,7 +343,8 @@ static const char *set_hc_tpsize (cmd_pa
> */
> static request_rec *create_request_rec(apr_pool_t *p, server_rec *s,
> proxy_balancer *balancer,
> - const char *method)
> + const char *method,
> + const char *protocol)
> {
> request_rec *r;
>
> @@ -400,10 +402,12 @@ static request_rec *create_request_rec(a
> else {
> r->header_only = 0;
> }
> -
> r->protocol = "HTTP/1.0";
> r->proto_num = HTTP_VERSION(1, 0);
> -
> + if ( protocol && (protocol[7] == '1') ) {
> + r->protocol = "HTTP/1.1";
> + r->proto_num = HTTP_VERSION(1, 1);
> + }
> r->hostname = NULL;
>
> return r;
> @@ -427,28 +431,39 @@ static void create_hcheck_req(wctx_t *wc
> {
> char *req = NULL;
> const char *method = NULL;
> + const char *protocol = NULL;
> +
> + /* TODO: Fold into switch/case below? This seems more obvious */
> + if ( (hc->s->method == OPTIONS11) || (hc->s->method == HEAD11) || (hc->s->method == GET11) ) {
> + protocol = "HTTP/1.1";
> + } else {
> + protocol = "HTTP/1.0";
> + }
> switch (hc->s->method) {
> case OPTIONS:
> + case OPTIONS11:
> method = "OPTIONS";
> req = apr_psprintf(p,
> - "OPTIONS * HTTP/1.0\r\n"
> + "OPTIONS * %s\r\n"
> "Host: %s:%d\r\n"
> - "\r\n",
> + "\r\n", protocol,
> hc->s->hostname_ex, (int)hc->s->port);
> break;
>
> case HEAD:
> + case HEAD11:
> method = "HEAD";
> /* fallthru */
> case GET:
> + case GET11:
> if (!method) { /* did we fall thru? If not, we are GET */
> method = "GET";
> }
> req = apr_psprintf(p,
> - "%s %s%s%s HTTP/1.0\r\n"
> + "%s %s%s%s %s\r\n"
> "Host: %s:%d\r\n"
> "\r\n",
> - method,
> + method, protocol,

I don't think that 'protocol' is at the right place.
Shouldn't it be...

> (wctx->path ? wctx->path : ""),
> (wctx->path && *hc->s->hcuri ? "/" : "" ),
> (*hc->s->hcuri ? hc->s->hcuri : ""),

there?

CJ


> @@ -460,6 +475,7 @@ static void create_hcheck_req(wctx_t *wc
> }
> wctx->req = req;
> wctx->method = method;
> + wctx->protocol = protocol;
> }
>
> static proxy_worker *hc_get_hcworker(sctx_t *ctx, proxy_worker *worker,
> @@ -639,7 +655,7 @@ static apr_status_t hc_check_cping(baton
> if ((status = ap_proxy_connect_backend("HCCPING", backend, hc, ctx->s)) != OK) {
> return backend_cleanup("HCCPING", backend, ctx->s, status);
> }
> - r = create_request_rec(ptemp, ctx->s, baton->balancer, "CPING");
> + r = create_request_rec(ptemp, ctx->s, baton->balancer, "CPING", NULL);
> if ((status = ap_proxy_connection_create_ex("HCCPING", backend, r)) != OK) {
> return backend_cleanup("HCCPING", backend, ctx->s, status);
> }
> @@ -826,7 +842,7 @@ static apr_status_t hc_check_http(baton_
> return backend_cleanup("HCOH", backend, ctx->s, status);
> }
>
> - r = create_request_rec(ptemp, ctx->s, baton->balancer, wctx->method);
> + r = create_request_rec(ptemp, ctx->s, baton->balancer, wctx->method, wctx->protocol);
> if ((status = ap_proxy_connection_create_ex("HCOH", backend, r)) != OK) {
> return backend_cleanup("HCOH", backend, ctx->s, status);
> }
>
>
>