X-Git-Url: https://mop.ddnsfree.com/gitweb/?a=blobdiff_plain;f=mod_proxy_fdpass.c;h=29b89db33d70ef81dbaab63f61b04067446aabf9;hb=bda74adb82f402ef88087d8bc9e2bcd3e6fb13b8;hp=0e2ba33381a566f99a3a91fd022402aa10811f13;hpb=f8ca106eac1ff4d5392cc3625aeadda2cf91ea4f;p=mod-proxy-fdpass.git diff --git a/mod_proxy_fdpass.c b/mod_proxy_fdpass.c index 0e2ba33..29b89db 100644 --- a/mod_proxy_fdpass.c +++ b/mod_proxy_fdpass.c @@ -34,15 +34,17 @@ module AP_MODULE_DECLARE_DATA proxy_fdpass_module; +#define MOP_DEBUG 0 + static int proxy_fdpass_canon(request_rec *r, char *url) { const char *path; - { + if (MOP_DEBUG == 1) { int mop_fd; char mop_bf[512]; - mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT); + mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644); sprintf(mop_bf, "proxy_http_canon: start\n"); write(mop_fd, mop_bf, strlen(mop_bf)); close(mop_fd); @@ -181,15 +183,14 @@ static apr_status_t send_socket(apr_pool_t *p, char b = '\0', *buf; ANCIL_FD_BUFFER(2) ancil_buf; - { + if (MOP_DEBUG == 1) { int mop_fd; char mop_bf[512]; - mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, S_IRWXU | S_IRWXG | S_IRWXO); + mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644); sprintf(mop_bf, "send_socket: start\n"); write(mop_fd, mop_bf, strlen(mop_bf)); close(mop_fd); - } rv = apr_os_sock_get(&rawsock, outbound); @@ -207,16 +208,15 @@ static apr_status_t send_socket(apr_pool_t *p, return rv; } - { + if (MOP_DEBUG == 1) { int mop_fd; char mop_bf[512]; - mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, S_IRWXU | S_IRWXG | S_IRWXO); + mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644); write(mop_fd, "XX", 2); write(mop_fd, &srawsock, sizeof(apr_os_sock_t)); write(mop_fd, "XX", 2); close(mop_fd); - } memset(&msg, 0, sizeof(msg)); @@ -241,15 +241,14 @@ static apr_status_t send_socket(apr_pool_t *p, rv = sendmsg(srawsock, &msg, 0); - { + if (MOP_DEBUG == 1) { int mop_fd; char mop_bf[512]; - mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, S_IRWXU | S_IRWXG | S_IRWXO); + mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644); sprintf(mop_bf, "SENT BYTES: %d\n", rv); write(mop_fd, mop_bf, strlen(mop_bf)); close(mop_fd); - } if (rv == -1) { @@ -287,9 +286,8 @@ int util_read(request_rec *r, const char **rbuf) int rsize, len_read, rpos=0; long length = r->remaining; *rbuf = (char *)apr_pcalloc(r->pool, length +1); - - while ((len_read = ap_get_client_block(r, argsbuffer, -sizeof(argsbuffer))) > 0) { + if ((len_read = ap_get_client_block(r, argsbuffer, + sizeof(argsbuffer))) > 0) { if ((rpos + len_read) > length) { rsize = length - rpos; } else { @@ -308,14 +306,31 @@ sizeof(argsbuffer))) > 0) { int read_post(request_rec *r, const char **data) { const char *type; + char *p, s_type[256]; int rc = OK; + s_type[255] = '\0'; + if (MOP_DEBUG == 1) { + int mop_fd; + char mop_bf[512]; + + mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644); + sprintf(mop_bf, "read_post: start: numb: %d %d head_in: [%s]\n", r->method_number, M_POST, apr_table_get(r->headers_in, "Content-Type")); + write(mop_fd, mop_bf, strlen(mop_bf)); + close(mop_fd); + } + + if (r->method_number != M_POST) { return rc; } type = apr_table_get(r->headers_in, "Content-Type"); - if (strcasecmp(type, DEFAULT_ENCTYPE) != 0) { + strncpy(s_type, type, 255); + if (p = strchr(s_type, ';')) { + *p = '\0'; + } + if (strcasecmp(s_type, DEFAULT_ENCTYPE) != 0) { return DECLINED; } @@ -323,6 +338,16 @@ int read_post(request_rec *r, const char **data) return rc; } + if (MOP_DEBUG == 1) { + int mop_fd; + char mop_bf[512]; + + mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644); + sprintf(mop_bf, "read_post: finish\n"); + write(mop_fd, mop_bf, strlen(mop_bf)); + close(mop_fd); + } + return OK; } @@ -343,23 +368,9 @@ static int proxy_fdpass_handler(request_rec *r, proxy_worker *worker, apr_size_t wrlen; const char *post_data = NULL; - if ((headers_out = calloc(CTRL_BUFF_MAX_SZ, 1)) != NULL) { - sprintf(headers_out, "The-Request:%s\n", r->the_request); - apr_table_do(headers_builder, headers_out, r->headers_in, NULL); - } - read_post(r, &post_data); - - { - int mop_fd; - char mop_bf[512]; - - mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, S_IRWXU | S_IRWXG | S_IRWXO); - sprintf(mop_bf, "proxy_fdpass_handler: start\n"); - write(mop_fd, mop_bf, strlen(mop_bf)); - write(mop_fd, headers_out, strlen(headers_out)); - close(mop_fd); + ap_filter_t *f; + ap_filter_rec_t *fg; - } if (strncasecmp(url, "fd://", 5) == 0) { url += 5; } @@ -376,6 +387,40 @@ static int proxy_fdpass_handler(request_rec *r, proxy_worker *worker, return HTTP_INTERNAL_SERVER_ERROR; } + fg = ap_get_output_filter_handle("HTTP_HEADER"); + + + ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, + "proxy: FD: filter fg: %lx func %lx", fg, ap_http_header_filter); + + + for (f = r->output_filters ; f != NULL ; f = f->next) { + ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, + "proxy: FD: filter loop: %lx", f->frec); + if (f->frec == fg) { + ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r, + "proxy: FD: filter found, remove it"); + ap_remove_output_filter(f); + break; + } + } + + if ((headers_out = calloc(CTRL_BUFF_MAX_SZ, 1)) != NULL) { + sprintf(headers_out, "The-Request:%s\n", r->the_request); + apr_table_do(headers_builder, headers_out, r->headers_in, NULL); + } + read_post(r, &post_data); + + if (MOP_DEBUG == 1) { + int mop_fd; + char mop_bf[512]; + + mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644); + sprintf(mop_bf, "proxy_fdpass_handler: start\n"); + write(mop_fd, mop_bf, strlen(mop_bf)); + write(mop_fd, headers_out, strlen(headers_out)); + close(mop_fd); + } /* create a couple of sockets and pass one to the client for headers and so on */ if (socketpair(AF_UNIX, SOCK_STREAM, 0, ctrlrawsock)) { ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r, @@ -481,8 +526,7 @@ static int standard_flush(request_rec *r) r->connection->keepalive = AP_CONN_CLOSE; /* MOP NOTE: set here the content type */ - // ap_set_content_type(r, apr_pstrdup(p, "text/plain")); - + // ap_set_content_type(r, apr_pstrdup(p, NO_CONTENT_TYPE)); bb = apr_brigade_create(r->pool, r->connection->bucket_alloc); e = apr_bucket_flush_create(r->connection->bucket_alloc);