#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>
+#include <time.h>
+#include <stdlib.h>
#ifndef CMSG_DATA
#error This module only works on unix platforms with the correct OS support
module AP_MODULE_DECLARE_DATA proxy_fdpass2_module;
-#define MOP_DEBUG 1
+#define ALTOUT_USOCK_N 10
+#define ALTOUT_DEBUG 1
+#define ALTOUT_DBG_FILE "/home/log/fdpass2.log"
static int proxy_fdpass2_canon(request_rec *r, char *url)
{
const char *path;
+ char sfx[16];
- if (MOP_DEBUG == 1) {
+#if ALTOUT_DEBUG > 1
+ {
int mop_fd;
char mop_bf[512];
- mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644);
+ mop_fd = open(ALTOUT_DBG_FILE, O_WRONLY | O_APPEND | O_CREAT, 0644);
sprintf(mop_bf, "proxy_http_canon: start [%p]\n", r->headers_in);
write(mop_fd, mop_bf, strlen(mop_bf));
close(mop_fd);
-
}
+#endif
if (strncasecmp(url, "fd://", 5) == 0) {
url += 5;
else {
return DECLINED;
}
-
+
path = ap_server_root_relative(r->pool, url);
- r->filename = apr_pstrcat(r->pool, "proxy:fd://", path, NULL);
+ sprintf(sfx, "%d.sock", rand() % ALTOUT_USOCK_N);
+ r->filename = apr_pstrcat(r->pool, "proxy:fd://", path, sfx, NULL);
/* ap_log_rerror(APLOG_MARK, APLOG_DEBUG, 0, r,
"proxy: FD: set r->filename to %s", r->filename); */
return rv;
}
}
-
+
if (rv == -1 && errno != EISCONN) {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"proxy: FD: socket_connect_un preexit %d", errno);
char b = '\0', *buf;
ANCIL_FD_BUFFER(2) ancil_buf;
- if (MOP_DEBUG == 1) {
+#if ALTOUT_DEBUG > 1
+ {
int mop_fd;
char mop_bf[512];
- mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644);
+ mop_fd = open(ALTOUT_DBG_FILE, 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);
}
-
+#endif
+
rv = apr_os_sock_get(&rawsock, outbound);
if (rv != APR_SUCCESS) {
return rv;
if (rv != APR_SUCCESS) {
return rv;
}
-
- if (MOP_DEBUG == 1) {
+
+#if ALTOUT_DEBUG > 1
+ {
int mop_fd;
char mop_bf[512];
- mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644);
+ mop_fd = open(ALTOUT_DBG_FILE, 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);
}
+#endif
memset(&msg, 0, sizeof(msg));
rv = sendmsg(srawsock, &msg, 0);
- if (MOP_DEBUG == 1) {
+#if ALTOUT_DEBUG > 1
+ {
int mop_fd;
char mop_bf[512];
- mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644);
+ mop_fd = open(ALTOUT_DBG_FILE, 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);
}
+#endif
if (rv == -1) {
return errno;
}
-
return APR_SUCCESS;
}
s = (char *)rec;
- if (MOP_DEBUG == 1) {
+#if ALTOUT_DEBUG > 1
+ {
int mop_fd;
char mop_bf[512];
- mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644);
+ mop_fd = open(ALTOUT_DBG_FILE, O_WRONLY | O_APPEND | O_CREAT, 0644);
sprintf(mop_bf, "HEADERS_BUILDER: [%s:%s]\n", key, value);
write(mop_fd, mop_bf, strlen(mop_bf));
close(mop_fd);
}
-
+#endif
// TODO: verify length
// sprintf(s, "%s%s:%s\n", s, key, value);
int rc = OK;
s_type[255] = '\0';
- if (MOP_DEBUG == 1) {
+#if ALTOUT_DEBUG > 1
+ {
int mop_fd;
char mop_bf[512];
- mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644);
+ mop_fd = open(ALTOUT_DBG_FILE, 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);
}
+#endif
if (r->method_number != M_POST) {
return rc;
}
- if (MOP_DEBUG == 1) {
+#if ALTOUT_DEBUG > 1
+ {
int mop_fd;
char mop_bf[512];
- mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644);
+ mop_fd = open(ALTOUT_DBG_FILE, 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);
}
+#endif
return OK;
}
rv = get_socket_from_path(r, r->pool, url, &sock);
+#if ALTOUT_DEBUG > 0
+ time_t t_cur;
+ int t_rnd;
+ t_cur = time();
+ t_rnd = rand();
+#endif
+
+#if ALTOUT_DEBUG > 0
+ {
+ int mop_fd;
+ char mop_bf[512];
+
+ mop_fd = open(ALTOUT_DBG_FILE, O_WRONLY | O_APPEND | O_CREAT, 0644);
+ sprintf(mop_bf, "%lld: (%d) proxy_fdpass2_handler: start\n", t_cur, t_rnd);
+ write(mop_fd, mop_bf, strlen(mop_bf));
+ close(mop_fd);
+ }
+#endif
+
if (rv != APR_SUCCESS) {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"proxy: FD: Failed to connect to '%s' %d xxx",
}
read_post(r, &post_data);
- if (MOP_DEBUG == 1) {
+#if ALTOUT_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_fdpass2_handler: start\n");
+ mop_fd = open(ALTOUT_DBG_FILE, O_WRONLY | O_APPEND | O_CREAT, 0644);
+ sprintf(mop_bf, "proxy_fdpass2_handler: headers\n");
write(mop_fd, mop_bf, strlen(mop_bf));
write(mop_fd, headers_out, strlen(headers_out));
close(mop_fd);
}
+#endif
+
/* 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,
{
int status;
/* const char *flush_method = worker->flusher ? worker->flusher : "flush"; */
- const char *flush_method = "flush";
+ const char *flush_method = "flush";
proxy_fdpass2_flush *flush = ap_lookup_provider(PROXY_FDPASS_FLUSHER,
flush_method, "0");
wrlen = strlen(headers_out);
rv = apr_socket_send(ctrlsock, headers_out, &wrlen);
- if (MOP_DEBUG == 1) {
+#if ALTOUT_DEBUG > 1
+ {
int mop_fd;
char mop_bf[512];
- mop_fd = open("/tmp/apache_mop.log", O_WRONLY | O_APPEND | O_CREAT, 0644);
+ mop_fd = open(ALTOUT_DBG_FILE, O_WRONLY | O_APPEND | O_CREAT, 0644);
write(mop_fd, "HEADERS_OUT\n", 12);
write(mop_fd, headers_out, wrlen);
close(mop_fd);
}
-
+#endif
if (rv != APR_SUCCESS) {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
{
apr_socket_t *dummy;
- /* Create a dummy unconnected socket, and set it as the one we were
- * connected to, so that when the core closes it, it doesn't close
+ /* Create a dummy unconnected socket, and set it as the one we were
+ * connected to, so that when the core closes it, it doesn't close
* the tcp connection to the client.
*/
rv = apr_socket_create(&dummy, APR_INET, SOCK_STREAM, APR_PROTO_TCP,
}
ap_set_module_config(r->connection->conn_config, &core_module, dummy);
}
-
-
+
+#if ALTOUT_DEBUG > 0
+ {
+ int mop_fd;
+ char mop_bf[512];
+
+ mop_fd = open(ALTOUT_DBG_FILE, O_WRONLY | O_APPEND | O_CREAT, 0644);
+ sprintf(mop_bf, "%lld: (%d) proxy_fdpass2_handler: end\n", t_cur, t_rnd);
+ write(mop_fd, mop_bf, strlen(mop_bf));
+ close(mop_fd);
+ }
+#endif
+
return OK;
}
// 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);
-
+
APR_BRIGADE_INSERT_TAIL(bb, e);
status = ap_pass_brigade(r->output_filters, bb);