|
Packit |
90a5c9 |
/* Licensed to the Apache Software Foundation (ASF) under one or more
|
|
Packit |
90a5c9 |
* contributor license agreements. See the NOTICE file distributed with
|
|
Packit |
90a5c9 |
* this work for additional information regarding copyright ownership.
|
|
Packit |
90a5c9 |
* The ASF licenses this file to You under the Apache License, Version 2.0
|
|
Packit |
90a5c9 |
* (the "License"); you may not use this file except in compliance with
|
|
Packit |
90a5c9 |
* the License. You may obtain a copy of the License at
|
|
Packit |
90a5c9 |
*
|
|
Packit |
90a5c9 |
* http://www.apache.org/licenses/LICENSE-2.0
|
|
Packit |
90a5c9 |
*
|
|
Packit |
90a5c9 |
* Unless required by applicable law or agreed to in writing, software
|
|
Packit |
90a5c9 |
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
Packit |
90a5c9 |
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
Packit |
90a5c9 |
* See the License for the specific language governing permissions and
|
|
Packit |
90a5c9 |
* limitations under the License.
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
#include "ajp_header.h"
|
|
Packit |
90a5c9 |
#include "ajp.h"
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
APLOG_USE_MODULE(proxy_ajp);
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
static const char *response_trans_headers[] = {
|
|
Packit |
90a5c9 |
"Content-Type",
|
|
Packit |
90a5c9 |
"Content-Language",
|
|
Packit |
90a5c9 |
"Content-Length",
|
|
Packit |
90a5c9 |
"Date",
|
|
Packit |
90a5c9 |
"Last-Modified",
|
|
Packit |
90a5c9 |
"Location",
|
|
Packit |
90a5c9 |
"Set-Cookie",
|
|
Packit |
90a5c9 |
"Set-Cookie2",
|
|
Packit |
90a5c9 |
"Servlet-Engine",
|
|
Packit |
90a5c9 |
"Status",
|
|
Packit |
90a5c9 |
"WWW-Authenticate"
|
|
Packit |
90a5c9 |
};
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
static const char *long_res_header_for_sc(int sc)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
const char *rc = NULL;
|
|
Packit |
90a5c9 |
sc = sc & 0X00FF;
|
|
Packit |
90a5c9 |
if (sc <= SC_RES_HEADERS_NUM && sc > 0) {
|
|
Packit |
90a5c9 |
rc = response_trans_headers[sc - 1];
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
#define UNKNOWN_METHOD (-1)
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
static int sc_for_req_header(const char *header_name)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
char header[16];
|
|
Packit |
90a5c9 |
apr_size_t len = strlen(header_name);
|
|
Packit |
90a5c9 |
const char *p = header_name;
|
|
Packit |
90a5c9 |
int i = 0;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/* ACCEPT-LANGUAGE is the longest header
|
|
Packit |
90a5c9 |
* that is of interest.
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
if (len < 4 || len > 15)
|
|
Packit |
90a5c9 |
return UNKNOWN_METHOD;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
while (*p)
|
|
Packit |
90a5c9 |
header[i++] = apr_toupper(*p++);
|
|
Packit |
90a5c9 |
header[i] = '\0';
|
|
Packit |
90a5c9 |
p = &header[1];
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
switch (header[0]) {
|
|
Packit |
90a5c9 |
case 'A':
|
|
Packit |
90a5c9 |
if (memcmp(p, "CCEPT", 5) == 0) {
|
|
Packit |
90a5c9 |
if (!header[6])
|
|
Packit |
90a5c9 |
return SC_ACCEPT;
|
|
Packit |
90a5c9 |
else if (header[6] == '-') {
|
|
Packit |
90a5c9 |
p += 6;
|
|
Packit |
90a5c9 |
if (strcmp(p, "CHARSET") == 0)
|
|
Packit |
90a5c9 |
return SC_ACCEPT_CHARSET;
|
|
Packit |
90a5c9 |
else if (strcmp(p, "ENCODING") == 0)
|
|
Packit |
90a5c9 |
return SC_ACCEPT_ENCODING;
|
|
Packit |
90a5c9 |
else if (strcmp(p, "LANGUAGE") == 0)
|
|
Packit |
90a5c9 |
return SC_ACCEPT_LANGUAGE;
|
|
Packit |
90a5c9 |
else
|
|
Packit |
90a5c9 |
return UNKNOWN_METHOD;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
else
|
|
Packit |
90a5c9 |
return UNKNOWN_METHOD;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
else if (strcmp(p, "UTHORIZATION") == 0)
|
|
Packit |
90a5c9 |
return SC_AUTHORIZATION;
|
|
Packit |
90a5c9 |
else
|
|
Packit |
90a5c9 |
return UNKNOWN_METHOD;
|
|
Packit |
90a5c9 |
break;
|
|
Packit |
90a5c9 |
case 'C':
|
|
Packit |
90a5c9 |
if (strcmp(p, "OOKIE2") == 0)
|
|
Packit |
90a5c9 |
return SC_COOKIE2;
|
|
Packit |
90a5c9 |
else if (strcmp(p, "OOKIE") == 0)
|
|
Packit |
90a5c9 |
return SC_COOKIE;
|
|
Packit |
90a5c9 |
else if (strcmp(p, "ONNECTION") == 0)
|
|
Packit |
90a5c9 |
return SC_CONNECTION;
|
|
Packit |
90a5c9 |
else if (strcmp(p, "ONTENT-TYPE") == 0)
|
|
Packit |
90a5c9 |
return SC_CONTENT_TYPE;
|
|
Packit |
90a5c9 |
else if (strcmp(p, "ONTENT-LENGTH") == 0)
|
|
Packit |
90a5c9 |
return SC_CONTENT_LENGTH;
|
|
Packit |
90a5c9 |
else
|
|
Packit |
90a5c9 |
return UNKNOWN_METHOD;
|
|
Packit |
90a5c9 |
break;
|
|
Packit |
90a5c9 |
case 'H':
|
|
Packit |
90a5c9 |
if (strcmp(p, "OST") == 0)
|
|
Packit |
90a5c9 |
return SC_HOST;
|
|
Packit |
90a5c9 |
else
|
|
Packit |
90a5c9 |
return UNKNOWN_METHOD;
|
|
Packit |
90a5c9 |
break;
|
|
Packit |
90a5c9 |
case 'P':
|
|
Packit |
90a5c9 |
if (strcmp(p, "RAGMA") == 0)
|
|
Packit |
90a5c9 |
return SC_PRAGMA;
|
|
Packit |
90a5c9 |
else
|
|
Packit |
90a5c9 |
return UNKNOWN_METHOD;
|
|
Packit |
90a5c9 |
break;
|
|
Packit |
90a5c9 |
case 'R':
|
|
Packit |
90a5c9 |
if (strcmp(p, "EFERER") == 0)
|
|
Packit |
90a5c9 |
return SC_REFERER;
|
|
Packit |
90a5c9 |
else
|
|
Packit |
90a5c9 |
return UNKNOWN_METHOD;
|
|
Packit |
90a5c9 |
break;
|
|
Packit |
90a5c9 |
case 'U':
|
|
Packit |
90a5c9 |
if (strcmp(p, "SER-AGENT") == 0)
|
|
Packit |
90a5c9 |
return SC_USER_AGENT;
|
|
Packit |
90a5c9 |
else
|
|
Packit |
90a5c9 |
return UNKNOWN_METHOD;
|
|
Packit |
90a5c9 |
break;
|
|
Packit |
90a5c9 |
default:
|
|
Packit |
90a5c9 |
return UNKNOWN_METHOD;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/* NOTREACHED */
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/* Apache method number to SC methods transform table */
|
|
Packit |
90a5c9 |
static const unsigned char sc_for_req_method_table[] = {
|
|
Packit |
90a5c9 |
SC_M_GET,
|
|
Packit |
90a5c9 |
SC_M_PUT,
|
|
Packit |
90a5c9 |
SC_M_POST,
|
|
Packit |
90a5c9 |
SC_M_DELETE,
|
|
Packit |
90a5c9 |
0, /* M_CONNECT */
|
|
Packit |
90a5c9 |
SC_M_OPTIONS,
|
|
Packit |
90a5c9 |
SC_M_TRACE,
|
|
Packit |
90a5c9 |
0, /* M_PATCH */
|
|
Packit |
90a5c9 |
SC_M_PROPFIND,
|
|
Packit |
90a5c9 |
SC_M_PROPPATCH,
|
|
Packit |
90a5c9 |
SC_M_MKCOL,
|
|
Packit |
90a5c9 |
SC_M_COPY,
|
|
Packit |
90a5c9 |
SC_M_MOVE,
|
|
Packit |
90a5c9 |
SC_M_LOCK,
|
|
Packit |
90a5c9 |
SC_M_UNLOCK,
|
|
Packit |
90a5c9 |
SC_M_VERSION_CONTROL,
|
|
Packit |
90a5c9 |
SC_M_CHECKOUT,
|
|
Packit |
90a5c9 |
SC_M_UNCHECKOUT,
|
|
Packit |
90a5c9 |
SC_M_CHECKIN,
|
|
Packit |
90a5c9 |
SC_M_UPDATE,
|
|
Packit |
90a5c9 |
SC_M_LABEL,
|
|
Packit |
90a5c9 |
SC_M_REPORT,
|
|
Packit |
90a5c9 |
SC_M_MKWORKSPACE,
|
|
Packit |
90a5c9 |
SC_M_MKACTIVITY,
|
|
Packit |
90a5c9 |
SC_M_BASELINE_CONTROL,
|
|
Packit |
90a5c9 |
SC_M_MERGE,
|
|
Packit |
90a5c9 |
0 /* M_INVALID */
|
|
Packit |
90a5c9 |
};
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
static int sc_for_req_method_by_id(request_rec *r)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
int method_id = r->method_number;
|
|
Packit |
90a5c9 |
if (method_id < 0 || method_id > M_INVALID) {
|
|
Packit |
90a5c9 |
return UNKNOWN_METHOD;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
else if (r->header_only) {
|
|
Packit |
90a5c9 |
return SC_M_HEAD;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
else {
|
|
Packit |
90a5c9 |
return sc_for_req_method_table[method_id] ?
|
|
Packit |
90a5c9 |
sc_for_req_method_table[method_id] : UNKNOWN_METHOD;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/*
|
|
Packit |
90a5c9 |
* Message structure
|
|
Packit |
90a5c9 |
*
|
|
Packit |
90a5c9 |
*
|
|
Packit |
90a5c9 |
AJPV13_REQUEST/AJPV14_REQUEST=
|
|
Packit |
90a5c9 |
request_prefix (1) (byte)
|
|
Packit |
90a5c9 |
method (byte)
|
|
Packit |
90a5c9 |
protocol (string)
|
|
Packit |
90a5c9 |
req_uri (string)
|
|
Packit |
90a5c9 |
remote_addr (string)
|
|
Packit |
90a5c9 |
remote_host (string)
|
|
Packit |
90a5c9 |
server_name (string)
|
|
Packit |
90a5c9 |
server_port (short)
|
|
Packit |
90a5c9 |
is_ssl (boolean)
|
|
Packit |
90a5c9 |
num_headers (short)
|
|
Packit |
90a5c9 |
num_headers*(req_header_name header_value)
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
?context (byte)(string)
|
|
Packit |
90a5c9 |
?servlet_path (byte)(string)
|
|
Packit |
90a5c9 |
?remote_user (byte)(string)
|
|
Packit |
90a5c9 |
?auth_type (byte)(string)
|
|
Packit |
90a5c9 |
?query_string (byte)(string)
|
|
Packit |
90a5c9 |
?jvm_route (byte)(string)
|
|
Packit |
90a5c9 |
?ssl_cert (byte)(string)
|
|
Packit |
90a5c9 |
?ssl_cipher (byte)(string)
|
|
Packit |
90a5c9 |
?ssl_session (byte)(string)
|
|
Packit |
90a5c9 |
?ssl_key_size (byte)(int) via JkOptions +ForwardKeySize
|
|
Packit |
90a5c9 |
request_terminator (byte)
|
|
Packit |
90a5c9 |
?body content_length*(var binary)
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
static apr_status_t ajp_marshal_into_msgb(ajp_msg_t *msg,
|
|
Packit |
90a5c9 |
request_rec *r,
|
|
Packit |
90a5c9 |
apr_uri_t *uri)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
int method;
|
|
Packit |
90a5c9 |
apr_uint32_t i, num_headers = 0;
|
|
Packit |
90a5c9 |
apr_byte_t is_ssl;
|
|
Packit |
90a5c9 |
char *remote_host;
|
|
Packit |
90a5c9 |
const char *session_route, *envvar;
|
|
Packit |
90a5c9 |
const apr_array_header_t *arr = apr_table_elts(r->subprocess_env);
|
|
Packit |
90a5c9 |
const apr_table_entry_t *elts = (const apr_table_entry_t *)arr->elts;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_TRACE8, 0, r, "Into ajp_marshal_into_msgb");
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if ((method = sc_for_req_method_by_id(r)) == UNKNOWN_METHOD) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_TRACE8, 0, r, APLOGNO(02437)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb - Sending unknown method %s as request attribute",
|
|
Packit |
90a5c9 |
r->method);
|
|
Packit |
90a5c9 |
method = SC_M_JK_STORED;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
is_ssl = (apr_byte_t) ap_proxy_conn_is_https(r->connection);
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if (r->headers_in && apr_table_elts(r->headers_in)) {
|
|
Packit |
90a5c9 |
const apr_array_header_t *t = apr_table_elts(r->headers_in);
|
|
Packit |
90a5c9 |
num_headers = t->nelts;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
remote_host = (char *)ap_get_useragent_host(r, REMOTE_HOST, NULL);
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
ajp_msg_reset(msg);
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, CMD_AJP13_FORWARD_REQUEST) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_uint8(msg, (apr_byte_t) method) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, r->protocol) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, uri->path) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, r->useragent_ip) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, remote_host) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, ap_get_server_name(r)) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_uint16(msg, (apr_uint16_t)r->connection->local_addr->port) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_uint8(msg, is_ssl) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_uint16(msg, (apr_uint16_t) num_headers)) {
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00968)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the message beginning");
|
|
Packit |
90a5c9 |
return APR_EGENERAL;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
for (i = 0 ; i < num_headers ; i++) {
|
|
Packit |
90a5c9 |
int sc;
|
|
Packit |
90a5c9 |
const apr_array_header_t *t = apr_table_elts(r->headers_in);
|
|
Packit |
90a5c9 |
const apr_table_entry_t *elts = (apr_table_entry_t *)t->elts;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if ((sc = sc_for_req_header(elts[i].key)) != UNKNOWN_METHOD) {
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint16(msg, (apr_uint16_t)sc)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00969)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the header name");
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
else {
|
|
Packit |
90a5c9 |
if (ajp_msg_append_string(msg, elts[i].key)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00970)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the header name");
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if (ajp_msg_append_string(msg, elts[i].val)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00971)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the header value");
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_TRACE5, 0, r,
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: Header[%d] [%s] = [%s]",
|
|
Packit |
90a5c9 |
i, elts[i].key, elts[i].val);
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/* XXXX need to figure out how to do this
|
|
Packit |
90a5c9 |
if (s->secret) {
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_SECRET) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, s->secret)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(03228)
|
|
Packit |
90a5c9 |
"Error ajp_marshal_into_msgb - "
|
|
Packit |
90a5c9 |
"Error appending secret");
|
|
Packit |
90a5c9 |
return APR_EGENERAL;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if (r->user) {
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_REMOTE_USER) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, r->user)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00972)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the remote user");
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
if (r->ap_auth_type) {
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_AUTH_TYPE) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, r->ap_auth_type)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00973)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the auth type");
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
/* XXXX ebcdic (args converted?) */
|
|
Packit |
90a5c9 |
if (uri->query) {
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_QUERY_STRING) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, uri->query)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00974)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the query string");
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
if ((session_route = apr_table_get(r->notes, "session-route"))) {
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_JVM_ROUTE) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, session_route)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00975)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the jvm route");
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
/* XXX: Is the subprocess_env a right place?
|
|
Packit |
90a5c9 |
* <Location /examples>
|
|
Packit |
90a5c9 |
* ProxyPass ajp://remote:8009/servlets-examples
|
|
Packit |
90a5c9 |
* SetEnv SSL_SESSION_ID CUSTOM_SSL_SESSION_ID
|
|
Packit |
90a5c9 |
* </Location>
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
/*
|
|
Packit |
90a5c9 |
* Only lookup SSL variables if we are currently running HTTPS.
|
|
Packit |
90a5c9 |
* Furthermore ensure that only variables get set in the AJP message
|
|
Packit |
90a5c9 |
* that are not NULL and not empty.
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
if (is_ssl) {
|
|
Packit |
90a5c9 |
if ((envvar = ap_proxy_ssl_val(r->pool, r->server, r->connection, r,
|
|
Packit |
90a5c9 |
AJP13_SSL_CLIENT_CERT_INDICATOR))
|
|
Packit |
90a5c9 |
&& envvar[0]) {
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_SSL_CERT)
|
|
Packit |
90a5c9 |
|| ajp_msg_append_string(msg, envvar)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00976)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the SSL certificates");
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if ((envvar = ap_proxy_ssl_val(r->pool, r->server, r->connection, r,
|
|
Packit |
90a5c9 |
AJP13_SSL_CIPHER_INDICATOR))
|
|
Packit |
90a5c9 |
&& envvar[0]) {
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_SSL_CIPHER)
|
|
Packit |
90a5c9 |
|| ajp_msg_append_string(msg, envvar)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00977)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the SSL ciphers");
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if ((envvar = ap_proxy_ssl_val(r->pool, r->server, r->connection, r,
|
|
Packit |
90a5c9 |
AJP13_SSL_SESSION_INDICATOR))
|
|
Packit |
90a5c9 |
&& envvar[0]) {
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_SSL_SESSION)
|
|
Packit |
90a5c9 |
|| ajp_msg_append_string(msg, envvar)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00978)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the SSL session");
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/* ssl_key_size is required by Servlet 2.3 API */
|
|
Packit |
90a5c9 |
if ((envvar = ap_proxy_ssl_val(r->pool, r->server, r->connection, r,
|
|
Packit |
90a5c9 |
AJP13_SSL_KEY_SIZE_INDICATOR))
|
|
Packit |
90a5c9 |
&& envvar[0]) {
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_SSL_KEY_SIZE)
|
|
Packit |
90a5c9 |
|| ajp_msg_append_uint16(msg, (unsigned short) atoi(envvar))) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00979)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the SSL key size");
|
|
Packit |
90a5c9 |
return APR_EGENERAL;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
/* If the method was unrecognized, encode it as an attribute */
|
|
Packit |
90a5c9 |
if (method == SC_M_JK_STORED) {
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_STORED_METHOD)
|
|
Packit |
90a5c9 |
|| ajp_msg_append_string(msg, r->method)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(02438)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the method '%s' as request attribute",
|
|
Packit |
90a5c9 |
r->method);
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
/* Forward the SSL protocol name.
|
|
Packit |
90a5c9 |
* Modern Tomcat versions know how to retrieve
|
|
Packit |
90a5c9 |
* the protocol name from this attribute.
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
if (is_ssl) {
|
|
Packit |
90a5c9 |
if ((envvar = ap_proxy_ssl_val(r->pool, r->server, r->connection, r,
|
|
Packit |
90a5c9 |
AJP13_SSL_PROTOCOL_INDICATOR))
|
|
Packit |
90a5c9 |
&& envvar[0]) {
|
|
Packit |
90a5c9 |
const char *key = SC_A_SSL_PROTOCOL;
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_REQ_ATTRIBUTE) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, key) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, envvar)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(02830)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending attribute %s=%s",
|
|
Packit |
90a5c9 |
key, envvar);
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
/* Forward the remote port information, which was forgotten
|
|
Packit |
90a5c9 |
* from the builtin data of the AJP 13 protocol.
|
|
Packit |
90a5c9 |
* Since the servlet spec allows to retrieve it via getRemotePort(),
|
|
Packit |
90a5c9 |
* we provide the port to the Tomcat connector as a request
|
|
Packit |
90a5c9 |
* attribute. Modern Tomcat versions know how to retrieve
|
|
Packit |
90a5c9 |
* the remote port from this attribute.
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
const char *key = SC_A_REQ_REMOTE_PORT;
|
|
Packit |
90a5c9 |
char *val = apr_itoa(r->pool, r->useragent_addr->port);
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_REQ_ATTRIBUTE) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, key) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, val)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00980)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending attribute %s=%s",
|
|
Packit |
90a5c9 |
key, val);
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
/* Forward the local ip address information, which was forgotten
|
|
Packit |
90a5c9 |
* from the builtin data of the AJP 13 protocol.
|
|
Packit |
90a5c9 |
* Since the servlet spec allows to retrieve it via getLocalAddr(),
|
|
Packit |
90a5c9 |
* we provide the address to the Tomcat connector as a request
|
|
Packit |
90a5c9 |
* attribute. Modern Tomcat versions know how to retrieve
|
|
Packit |
90a5c9 |
* the local address from this attribute.
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
const char *key = SC_A_REQ_LOCAL_ADDR;
|
|
Packit |
90a5c9 |
char *val = r->connection->local_ip;
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_REQ_ATTRIBUTE) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, key) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, val)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(02646)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending attribute %s=%s",
|
|
Packit |
90a5c9 |
key, val);
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
/* Use the environment vars prefixed with AJP_
|
|
Packit |
90a5c9 |
* and pass it to the header striping that prefix.
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
for (i = 0; i < (apr_uint32_t)arr->nelts; i++) {
|
|
Packit |
90a5c9 |
if (!strncmp(elts[i].key, "AJP_", 4)) {
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_REQ_ATTRIBUTE) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, elts[i].key + 4) ||
|
|
Packit |
90a5c9 |
ajp_msg_append_string(msg, elts[i].val)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00981)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending attribute %s=%s",
|
|
Packit |
90a5c9 |
elts[i].key, elts[i].val);
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if (ajp_msg_append_uint8(msg, SC_A_ARE_DONE)) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00982)
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: "
|
|
Packit |
90a5c9 |
"Error appending the message end");
|
|
Packit |
90a5c9 |
return AJP_EOVERFLOW;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_TRACE8, 0, r,
|
|
Packit |
90a5c9 |
"ajp_marshal_into_msgb: Done");
|
|
Packit |
90a5c9 |
return APR_SUCCESS;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/*
|
|
Packit |
90a5c9 |
AJPV13_RESPONSE/AJPV14_RESPONSE:=
|
|
Packit |
90a5c9 |
response_prefix (2)
|
|
Packit |
90a5c9 |
status (short)
|
|
Packit |
90a5c9 |
status_msg (short)
|
|
Packit |
90a5c9 |
num_headers (short)
|
|
Packit |
90a5c9 |
num_headers*(res_header_name header_value)
|
|
Packit |
90a5c9 |
*body_chunk
|
|
Packit |
90a5c9 |
terminator boolean
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
req_header_name :=
|
|
Packit |
90a5c9 |
sc_req_header_name | (string)
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
res_header_name :=
|
|
Packit |
90a5c9 |
sc_res_header_name | (string)
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
header_value :=
|
|
Packit |
90a5c9 |
(string)
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
body_chunk :=
|
|
Packit |
90a5c9 |
length (short)
|
|
Packit |
90a5c9 |
body length*(var binary)
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
static int addit_dammit(void *v, const char *key, const char *val)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
apr_table_addn(v, key, val);
|
|
Packit |
90a5c9 |
return 1;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
static apr_status_t ajp_unmarshal_response(ajp_msg_t *msg,
|
|
Packit |
90a5c9 |
request_rec *r,
|
|
Packit |
90a5c9 |
proxy_dir_conf *dconf)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
apr_uint16_t status;
|
|
Packit |
90a5c9 |
apr_status_t rc;
|
|
Packit |
90a5c9 |
const char *ptr;
|
|
Packit |
90a5c9 |
apr_uint16_t num_headers;
|
|
Packit |
90a5c9 |
int i;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
rc = ajp_msg_get_uint16(msg, &status);
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00983)
|
|
Packit |
90a5c9 |
"ajp_unmarshal_response: Null status");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
r->status = status;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
rc = ajp_msg_get_string(msg, &ptr);
|
|
Packit |
90a5c9 |
if (rc == APR_SUCCESS) {
|
|
Packit |
90a5c9 |
#if APR_CHARSET_EBCDIC /* copy only if we have to */
|
|
Packit |
90a5c9 |
ptr = apr_pstrdup(r->pool, ptr);
|
|
Packit |
90a5c9 |
ap_xlate_proto_from_ascii(ptr, strlen(ptr));
|
|
Packit |
90a5c9 |
#endif
|
|
Packit |
90a5c9 |
r->status_line = apr_psprintf(r->pool, "%d %s", status, ptr);
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
else {
|
|
Packit |
90a5c9 |
r->status_line = NULL;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_TRACE4, 0, r,
|
|
Packit |
90a5c9 |
"ajp_unmarshal_response: status = %d", status);
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
rc = ajp_msg_get_uint16(msg, &num_headers);
|
|
Packit |
90a5c9 |
if (rc == APR_SUCCESS) {
|
|
Packit |
90a5c9 |
apr_table_t *save_table;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/* First, tuck away all already existing cookies */
|
|
Packit |
90a5c9 |
/*
|
|
Packit |
90a5c9 |
* Could optimize here, but just in case we want to
|
|
Packit |
90a5c9 |
* also save other headers, keep this logic.
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
save_table = apr_table_make(r->pool, num_headers + 2);
|
|
Packit |
90a5c9 |
apr_table_do(addit_dammit, save_table, r->headers_out,
|
|
Packit |
90a5c9 |
"Set-Cookie", NULL);
|
|
Packit |
90a5c9 |
r->headers_out = save_table;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
else {
|
|
Packit |
90a5c9 |
r->headers_out = NULL;
|
|
Packit |
90a5c9 |
num_headers = 0;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_TRACE4, 0, r,
|
|
Packit |
90a5c9 |
"ajp_unmarshal_response: Number of headers is = %d",
|
|
Packit |
90a5c9 |
num_headers);
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
for (i = 0; i < (int)num_headers; i++) {
|
|
Packit |
90a5c9 |
apr_uint16_t name;
|
|
Packit |
90a5c9 |
const char *stringname;
|
|
Packit |
90a5c9 |
const char *value;
|
|
Packit |
90a5c9 |
rc = ajp_msg_peek_uint16(msg, &name);
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if ((name & 0XFF00) == 0XA000) {
|
|
Packit |
90a5c9 |
ajp_msg_get_uint16(msg, &name);
|
|
Packit |
90a5c9 |
stringname = long_res_header_for_sc(name);
|
|
Packit |
90a5c9 |
if (stringname == NULL) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00984)
|
|
Packit |
90a5c9 |
"ajp_unmarshal_response: "
|
|
Packit |
90a5c9 |
"No such sc (%08x)",
|
|
Packit |
90a5c9 |
name);
|
|
Packit |
90a5c9 |
return AJP_EBAD_HEADER;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
else {
|
|
Packit |
90a5c9 |
name = 0;
|
|
Packit |
90a5c9 |
rc = ajp_msg_get_string(msg, &stringname);
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00985)
|
|
Packit |
90a5c9 |
"ajp_unmarshal_response: "
|
|
Packit |
90a5c9 |
"Null header name");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
ap_xlate_proto_from_ascii(stringname, strlen(stringname));
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
rc = ajp_msg_get_string(msg, &value);
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00986)
|
|
Packit |
90a5c9 |
"ajp_unmarshal_response: "
|
|
Packit |
90a5c9 |
"Null header value");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/* Set-Cookie need additional processing */
|
|
Packit |
90a5c9 |
if (!strcasecmp(stringname, "Set-Cookie")) {
|
|
Packit |
90a5c9 |
value = ap_proxy_cookie_reverse_map(r, dconf, value);
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
/* Location, Content-Location, URI and Destination need additional
|
|
Packit |
90a5c9 |
* processing */
|
|
Packit |
90a5c9 |
else if (!strcasecmp(stringname, "Location")
|
|
Packit |
90a5c9 |
|| !strcasecmp(stringname, "Content-Location")
|
|
Packit |
90a5c9 |
|| !strcasecmp(stringname, "URI")
|
|
Packit |
90a5c9 |
|| !strcasecmp(stringname, "Destination"))
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
value = ap_proxy_location_reverse_map(r, dconf, value);
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
ap_xlate_proto_from_ascii(value, strlen(value));
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_TRACE5, 0, r,
|
|
Packit |
90a5c9 |
"ajp_unmarshal_response: Header[%d] [%s] = [%s]",
|
|
Packit |
90a5c9 |
i, stringname, value);
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
apr_table_add(r->headers_out, stringname, value);
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/* Content-type needs an additional handling */
|
|
Packit |
90a5c9 |
if (strcasecmp(stringname, "Content-Type") == 0) {
|
|
Packit |
90a5c9 |
/* add corresponding filter */
|
|
Packit |
90a5c9 |
ap_set_content_type(r, apr_pstrdup(r->pool, value));
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_TRACE5, 0, r,
|
|
Packit |
90a5c9 |
"ajp_unmarshal_response: ap_set_content_type to '%s'", value);
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
return APR_SUCCESS;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/*
|
|
Packit |
90a5c9 |
* Build the ajp header message and send it
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
apr_status_t ajp_send_header(apr_socket_t *sock,
|
|
Packit |
90a5c9 |
request_rec *r,
|
|
Packit |
90a5c9 |
apr_size_t buffsize,
|
|
Packit |
90a5c9 |
apr_uri_t *uri)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
ajp_msg_t *msg;
|
|
Packit |
90a5c9 |
apr_status_t rc;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
rc = ajp_msg_create(r->pool, buffsize, &msg;;
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00987)
|
|
Packit |
90a5c9 |
"ajp_send_header: ajp_msg_create failed");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
rc = ajp_marshal_into_msgb(msg, r, uri);
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00988)
|
|
Packit |
90a5c9 |
"ajp_send_header: ajp_marshal_into_msgb failed");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
rc = ajp_ilink_send(sock, msg);
|
|
Packit |
90a5c9 |
ajp_msg_log(r, msg, "ajp_send_header: ajp_ilink_send packet dump");
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00989)
|
|
Packit |
90a5c9 |
"ajp_send_header: ajp_ilink_send failed");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
return APR_SUCCESS;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/*
|
|
Packit |
90a5c9 |
* Read the ajp message and return the type of the message.
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
apr_status_t ajp_read_header(apr_socket_t *sock,
|
|
Packit |
90a5c9 |
request_rec *r,
|
|
Packit |
90a5c9 |
apr_size_t buffsize,
|
|
Packit |
90a5c9 |
ajp_msg_t **msg)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
apr_byte_t result;
|
|
Packit |
90a5c9 |
apr_status_t rc;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if (*msg) {
|
|
Packit |
90a5c9 |
rc = ajp_msg_reuse(*msg);
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00990)
|
|
Packit |
90a5c9 |
"ajp_read_header: ajp_msg_reuse failed");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
else {
|
|
Packit |
90a5c9 |
rc = ajp_msg_create(r->pool, buffsize, msg);
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00991)
|
|
Packit |
90a5c9 |
"ajp_read_header: ajp_msg_create failed");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
ajp_msg_reset(*msg);
|
|
Packit |
90a5c9 |
rc = ajp_ilink_receive(sock, *msg);
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00992)
|
|
Packit |
90a5c9 |
"ajp_read_header: ajp_ilink_receive failed");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
ajp_msg_log(r, *msg, "ajp_read_header: ajp_ilink_receive packet dump");
|
|
Packit |
90a5c9 |
rc = ajp_msg_peek_uint8(*msg, &result);
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00993)
|
|
Packit |
90a5c9 |
"ajp_read_header: ajp_msg_peek_uint8 failed");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_TRACE1, 0, r,
|
|
Packit |
90a5c9 |
"ajp_read_header: ajp_ilink_received %s (0x%02x)",
|
|
Packit |
90a5c9 |
ajp_type_str(result), result);
|
|
Packit |
90a5c9 |
return APR_SUCCESS;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/* parse the msg to read the type */
|
|
Packit |
90a5c9 |
int ajp_parse_type(request_rec *r, ajp_msg_t *msg)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
apr_byte_t result;
|
|
Packit |
90a5c9 |
ajp_msg_peek_uint8(msg, &result);
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_TRACE6, 0, r,
|
|
Packit |
90a5c9 |
"ajp_parse_type: got %s (0x%02x)",
|
|
Packit |
90a5c9 |
ajp_type_str(result), result);
|
|
Packit |
90a5c9 |
return (int) result;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/* parse the header */
|
|
Packit |
90a5c9 |
apr_status_t ajp_parse_header(request_rec *r, proxy_dir_conf *conf,
|
|
Packit |
90a5c9 |
ajp_msg_t *msg)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
apr_byte_t result;
|
|
Packit |
90a5c9 |
apr_status_t rc;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
rc = ajp_msg_get_uint8(msg, &result);
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00994)
|
|
Packit |
90a5c9 |
"ajp_parse_headers: ajp_msg_get_byte failed");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
if (result != CMD_AJP13_SEND_HEADERS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00995)
|
|
Packit |
90a5c9 |
"ajp_parse_headers: wrong type %s (0x%02x) expecting %s (0x%02x)",
|
|
Packit |
90a5c9 |
ajp_type_str(result), result,
|
|
Packit |
90a5c9 |
ajp_type_str(CMD_AJP13_SEND_HEADERS), CMD_AJP13_SEND_HEADERS);
|
|
Packit |
90a5c9 |
return AJP_EBAD_HEADER;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
return ajp_unmarshal_response(msg, r, conf);
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/* parse the body and return data address and length */
|
|
Packit |
90a5c9 |
apr_status_t ajp_parse_data(request_rec *r, ajp_msg_t *msg,
|
|
Packit |
90a5c9 |
apr_uint16_t *len, char **ptr)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
apr_byte_t result;
|
|
Packit |
90a5c9 |
apr_status_t rc;
|
|
Packit |
90a5c9 |
apr_uint16_t expected_len;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
rc = ajp_msg_get_uint8(msg, &result);
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00996)
|
|
Packit |
90a5c9 |
"ajp_parse_data: ajp_msg_get_byte failed");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
if (result != CMD_AJP13_SEND_BODY_CHUNK) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00997)
|
|
Packit |
90a5c9 |
"ajp_parse_data: wrong type %s (0x%02x) expecting %s (0x%02x)",
|
|
Packit |
90a5c9 |
ajp_type_str(result), result,
|
|
Packit |
90a5c9 |
ajp_type_str(CMD_AJP13_SEND_BODY_CHUNK), CMD_AJP13_SEND_BODY_CHUNK);
|
|
Packit |
90a5c9 |
return AJP_EBAD_HEADER;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
rc = ajp_msg_get_uint16(msg, len);
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
/*
|
|
Packit |
90a5c9 |
* msg->len contains the complete length of the message including all
|
|
Packit |
90a5c9 |
* headers. So the expected length for a CMD_AJP13_SEND_BODY_CHUNK is
|
|
Packit |
90a5c9 |
* msg->len minus the sum of
|
|
Packit |
90a5c9 |
* AJP_HEADER_LEN : The length of the header to every AJP message.
|
|
Packit |
90a5c9 |
* AJP_HEADER_SZ_LEN : The header giving the size of the chunk.
|
|
Packit |
90a5c9 |
* 1 : The CMD_AJP13_SEND_BODY_CHUNK indicator byte (0x03).
|
|
Packit |
90a5c9 |
* 1 : The last byte of this message always seems to be
|
|
Packit |
90a5c9 |
* 0x00 and is not part of the chunk.
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
expected_len = msg->len - (AJP_HEADER_LEN + AJP_HEADER_SZ_LEN + 1 + 1);
|
|
Packit |
90a5c9 |
if (*len != expected_len) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00998)
|
|
Packit |
90a5c9 |
"ajp_parse_data: Wrong chunk length. Length of chunk is %i,"
|
|
Packit |
90a5c9 |
" expected length is %i.", *len, expected_len);
|
|
Packit |
90a5c9 |
return AJP_EBAD_HEADER;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
*ptr = (char *)&(msg->buf[msg->pos]);
|
|
Packit |
90a5c9 |
return APR_SUCCESS;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/* Check the reuse flag in CMD_AJP13_END_RESPONSE */
|
|
Packit |
90a5c9 |
apr_status_t ajp_parse_reuse(request_rec *r, ajp_msg_t *msg,
|
|
Packit |
90a5c9 |
apr_byte_t *reuse)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
apr_byte_t result;
|
|
Packit |
90a5c9 |
apr_status_t rc;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
rc = ajp_msg_get_uint8(msg, &result);
|
|
Packit |
90a5c9 |
if (rc != APR_SUCCESS) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(00999)
|
|
Packit |
90a5c9 |
"ajp_parse_reuse: ajp_msg_get_byte failed");
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
if (result != CMD_AJP13_END_RESPONSE) {
|
|
Packit |
90a5c9 |
ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, APLOGNO(01000)
|
|
Packit |
90a5c9 |
"ajp_parse_reuse: wrong type %s (0x%02x) expecting %s (0x%02x)",
|
|
Packit |
90a5c9 |
ajp_type_str(result), result,
|
|
Packit |
90a5c9 |
ajp_type_str(CMD_AJP13_END_RESPONSE), CMD_AJP13_END_RESPONSE);
|
|
Packit |
90a5c9 |
return AJP_EBAD_HEADER;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
return ajp_msg_get_uint8(msg, reuse);
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/*
|
|
Packit |
90a5c9 |
* Allocate a msg to send data
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
apr_status_t ajp_alloc_data_msg(apr_pool_t *pool, char **ptr, apr_size_t *len,
|
|
Packit |
90a5c9 |
ajp_msg_t **msg)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
apr_status_t rc;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
if ((rc = ajp_msg_create(pool, *len, msg)) != APR_SUCCESS)
|
|
Packit |
90a5c9 |
return rc;
|
|
Packit |
90a5c9 |
ajp_msg_reset(*msg);
|
|
Packit |
90a5c9 |
*ptr = (char *)&((*msg)->buf[6]);
|
|
Packit |
90a5c9 |
*len = *len - 6;
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
return APR_SUCCESS;
|
|
Packit |
90a5c9 |
}
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
/*
|
|
Packit |
90a5c9 |
* Send the data message
|
|
Packit |
90a5c9 |
*/
|
|
Packit |
90a5c9 |
apr_status_t ajp_send_data_msg(apr_socket_t *sock,
|
|
Packit |
90a5c9 |
ajp_msg_t *msg, apr_size_t len)
|
|
Packit |
90a5c9 |
{
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
msg->buf[4] = (apr_byte_t)((len >> 8) & 0xFF);
|
|
Packit |
90a5c9 |
msg->buf[5] = (apr_byte_t)(len & 0xFF);
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
msg->len += len + 2; /* + 1 XXXX where is '\0' */
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
return ajp_ilink_send(sock, msg);
|
|
Packit |
90a5c9 |
|
|
Packit |
90a5c9 |
}
|