From f7b4bdfd892a0b479dc946896435a3ba7f9615dd Mon Sep 17 00:00:00 2001 From: Max Romanov Date: Fri, 12 May 2017 20:32:41 +0300 Subject: Using shared memory to send data via nxt_port. Usage: b = nxt_port_mmap_get_buf(task, port, size); b->mem.free = nxt_cpymem(b->mem.free, data, size); nxt_port_socket_write(task, port, NXT_PORT_MSG_DATA, -1, 0, b); --- src/nxt_main.h | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'src/nxt_main.h') diff --git a/src/nxt_main.h b/src/nxt_main.h index a1a01434..24ec4ca1 100644 --- a/src/nxt_main.h +++ b/src/nxt_main.h @@ -24,7 +24,9 @@ typedef struct nxt_port_recv_msg_s nxt_port_recv_msg_t; typedef void (*nxt_port_handler_t)(nxt_task_t *task, nxt_port_recv_msg_t *msg); typedef struct nxt_sig_event_s nxt_sig_event_t; typedef struct nxt_runtime_s nxt_runtime_t; +typedef uint16_t nxt_port_id_t; +#include #include typedef struct nxt_thread_s nxt_thread_t; @@ -45,7 +47,6 @@ typedef struct nxt_log_s nxt_log_t; #include -#include #include #include #include @@ -104,6 +105,7 @@ typedef struct nxt_thread_pool_s nxt_thread_pool_t; #include typedef struct nxt_buf_s nxt_buf_t; +typedef struct nxt_port_mmap_s nxt_port_mmap_t; #include #include #include @@ -129,6 +131,7 @@ nxt_thread_extern_data(nxt_thread_t, nxt_thread_context); #include #include +#include #if (NXT_THREADS) #include #endif -- cgit