diff --git a/src/event/ngx_event_connect.c b/src/event/ngx_event_connect.c
index be47c0a..c1b30cb 100644
--- a/src/event/ngx_event_connect.c
+++ b/src/event/ngx_event_connect.c
@@ -3,7 +3,7 @@
 
 /* AF_INET only */
 
-int ngx_event_connect_peer(ngx_peer_connecttion_t *pc)
+int ngx_event_connect_peer(ngx_peer_connection_t *pc)
 {
     time_t               now;
     ngx_peer_r          *peer;
@@ -29,6 +29,7 @@
     }
 
     pc->cached = 0;
+    pc->connection = NULL;
 
     if (pc->peers->number > 1) {
 
diff --git a/src/event/ngx_event_connect.h b/src/event/ngx_event_connect.h
index 714ef6f..6626e2e 100644
--- a/src/event/ngx_event_connect.h
+++ b/src/event/ngx_event_connect.h
@@ -40,6 +40,8 @@
 
     int                rcvbuf;
 
+    ngx_log_t         *log;
+
     unsigned           cached:1;
 } ngx_peer_connection_t;
 
diff --git a/src/http/modules/proxy/ngx_http_proxy_handler.c b/src/http/modules/proxy/ngx_http_proxy_handler.c
new file mode 100644
index 0000000..baecb25
--- /dev/null
+++ b/src/http/modules/proxy/ngx_http_proxy_handler.c
@@ -0,0 +1,139 @@
+
+#include <ngx_config.h>
+#include <ngx_core.h>
+#include <ngx_event.h>
+/* STUB */ #include <ngx_event_connect.h>
+#include <ngx_http.h>
+#include <ngx_http_proxy_handler.h>
+
+
+
+static ngx_command_t ngx_http_proxy_commands[] = {
+    ngx_null_command
+};
+
+
+ngx_http_module_t  ngx_http_proxy_module_ctx = {
+    NULL,                                  /* create main configuration */
+    NULL,                                  /* init main configuration */
+
+    NULL,                                  /* create server configuration */
+    NULL,                                  /* merge server configuration */
+
+#if 0
+    ngx_http_proxy_create_conf,            /* create location configration */
+    ngx_http_proxy_merge_conf              /* merge location configration */
+#endif
+
+    NULL,
+    NULL
+};
+
+
+ngx_module_t  ngx_http_proxy_module = {
+    NGX_MODULE,
+    &ngx_http_proxy_module_ctx,            /* module context */
+    ngx_http_proxy_commands,               /* module directives */
+    NGX_HTTP_MODULE,                       /* module type */
+    NULL,                                  /* init module */
+    NULL                                   /* init child */
+};
+
+
+#if 0
+static
+#endif
+
+int ngx_http_proxy_handler(ngx_http_request_t *r)
+{
+    int                     rc;
+    ngx_http_proxy_ctx_t   *p;
+    ngx_peer_connection_t  *pc;
+
+
+    ngx_http_create_ctx(r, p, ngx_http_proxy_module,
+                        sizeof(ngx_http_proxy_ctx_t),
+                        NGX_HTTP_INTERNAL_SERVER_ERROR);
+
+
+    p->action = "connecting to upstream";
+    p->request = r;
+
+
+#if 0
+    pc->peers = lcf->peers;
+#endif
+
+    p->upstream.log = r->connection->log;
+
+    do {
+        rc = ngx_event_connect_peer(&p->upstream);
+
+        if (rc == NGX_ERROR) {
+            return NGX_HTTP_INTERNAL_SERVER_ERROR;
+        }
+
+        if (rc == NGX_OK) {
+            send_proxy_request(p);
+            return NGX_OK;
+        }
+
+        if (rc == NGX_AGAIN && p->upstream.connection) {
+            return NGX_OK;
+        }
+
+    } while (p->upstream.tries);
+
+    return NGX_HTTP_BAD_GATEWAY;
+}
+
+
+#if 0
+
+ngx_http_proxy_connect()
+    do {
+        ngx_event_connect_peer()
+        if error
+            return error
+        if ok
+            return ok
+        if again
+            return again
+
+        /* next */
+    while (tries)
+}
+
+
+ngx_http_proxy_send_request(ngx_event_t *wev)
+    for ( ;; ) {
+       send
+       if ok
+          ???
+       if again
+          return
+       if error
+          close
+          ngx_http_proxy_connect()
+          if ok
+              continue
+          if error
+              return
+          if again
+              return
+    }
+
+#endif
+
+
+static size_t ngx_http_proxy_log_error(void *data, char *buf, size_t len)
+{
+    ngx_http_proxy_ctx_t *p = data;
+
+    return ngx_snprintf(buf, len,
+            " while %s, upstream: %s, client: %s, URL: %s",
+            p->action,
+            p->upstream.peers->peers[p->upstream.cur_peer].addr_port_text.data,
+            p->request->connection->addr_text.data,
+            p->request->unparsed_uri.data);
+}
diff --git a/src/http/modules/proxy/ngx_http_proxy_handler.h b/src/http/modules/proxy/ngx_http_proxy_handler.h
new file mode 100644
index 0000000..7f85417
--- /dev/null
+++ b/src/http/modules/proxy/ngx_http_proxy_handler.h
@@ -0,0 +1,23 @@
+#ifndef _NGX_HTTP_PROXY_HANDLER_H_INCLUDED_
+#define _NGX_HTTP_PROXY_HANDLER_H_INCLUDED_
+
+
+#include <ngx_config.h>
+#include <ngx_core.h>
+#include <ngx_event.h>
+#include <ngx_http.h>
+
+
+typedef struct ngx_http_proxy_ctx_s  ngx_http_proxy_ctx_t;
+
+struct ngx_http_proxy_ctx_s {
+    ngx_peer_connection_t   upstream;
+    ngx_peer_t             *peer;
+
+    ngx_http_request_t     *request;
+
+    char                   *action;
+};
+
+
+#endif /* _NGX_HTTP_PROXY_HANDLER_H_INCLUDED_ */