Added basic HTTP request processing in router.

- request to connection mapping in engine;
- requests queue in connection;
- engine port creation;
- connected ports hash for each process;
- engine port data messages processing (app responses);

1 files changed, 26 insertions, 0 deletions

diff --git a/src/nxt_process.c b/src/nxt_process.c
index ce16cf7f..33af310d 100644
--- a/src/nxt_process.c
+++ b/src/nxt_process.c
@@ -540,3 +540,29 @@ nxt_process_port_new(nxt_process_t *process)
     return port;
 }
 
+
+void
+nxt_process_connected_port_add(nxt_process_t *process, nxt_port_t *port)
+{
+    /* TODO lock ports */
+
+    nxt_port_hash_add(&process->connected_ports, process->mem_pool, port);
+}
+
+void
+nxt_process_connected_port_remove(nxt_process_t *process, nxt_port_t *port)
+{
+    /* TODO lock ports */
+
+    nxt_port_hash_remove(&process->connected_ports, process->mem_pool, port);
+}
+
+nxt_port_t *
+nxt_process_connected_port_find(nxt_process_t *process, nxt_pid_t pid,
+    nxt_port_id_t port_id)
+{
+    /* TODO lock ports */
+
+    return nxt_port_hash_find(&process->connected_ports, pid, port_id);
+}
+