External Go app request processing.

1 files changed, 30 insertions, 0 deletions

diff --git a/src/nginext/nxt_go_process.h b/src/nginext/nxt_go_process.h
new file mode 100644
index 00000000..5e31fa6e
--- /dev/null
+++ b/src/nginext/nxt_go_process.h
@@ -0,0 +1,30 @@
+
+/*
+ * Copyright (C) Max Romanov
+ * Copyright (C) NGINX, Inc.
+ */
+
+#ifndef _NXT_GO_PROCESS_H_INCLUDED_
+#define _NXT_GO_PROCESS_H_INCLUDED_
+
+
+#include <nxt_main.h>
+#include "nxt_go_mutex.h"
+
+typedef struct nxt_go_process_s nxt_go_process_t;
+
+struct nxt_go_process_s {
+    nxt_pid_t       pid;
+    nxt_go_mutex_t  incoming_mutex;
+    nxt_array_t     incoming;  /* of nxt_port_mmap_t */
+    nxt_go_mutex_t  outgoing_mutex;
+    nxt_array_t     outgoing;  /* of nxt_port_mmap_t */
+};
+
+nxt_go_process_t *nxt_go_get_process(nxt_pid_t pid);
+
+void nxt_go_new_incoming_mmap(nxt_pid_t pid, nxt_fd_t fd);
+
+
+#endif /* _NXT_GO_PROCESS_H_INCLUDED_ */
+