Searched refs:nxt_unit_port_t (Results 1 – 8 of 8) sorted by relevance
| /unit/src/ |
| H A D | nxt_unit.h | 99 nxt_unit_port_t *response_port;
136 int (*add_port)(nxt_unit_ctx_t *, nxt_unit_port_t *port);
140 nxt_unit_port_t *port);
152 ssize_t (*port_send)(nxt_unit_ctx_t *, nxt_unit_port_t *port,
157 ssize_t (*port_recv)(nxt_unit_ctx_t *, nxt_unit_port_t *port,
175 nxt_unit_port_t ready_port;
177 nxt_unit_port_t router_port;
178 nxt_unit_port_t read_port;
231 int nxt_unit_process_port_msg(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port);
|
| H A D | nxt_unit_typedefs.h | 13 typedef struct nxt_unit_port_s nxt_unit_port_t; typedef
|
| H A D | nxt_unit.c | 57 nxt_unit_port_t *router_port, nxt_unit_port_t *read_port,
108 nxt_unit_port_t *port, int n);
147 nxt_unit_port_t *port);
190 nxt_unit_port_t *port);
383 nxt_unit_port_t port;
844 nxt_unit_read_env(nxt_unit_port_t *ready_port, nxt_unit_port_t *router_port, in nxt_unit_read_env()
5271 static nxt_unit_port_t *
5430 static nxt_unit_port_t *
5674 static nxt_unit_port_t *
5677 nxt_unit_port_t *port; in nxt_unit_remove_port_unsafe()
[all …]
|
| /unit/go/ |
| H A D | nxt_cgo_lib.c | 13 static ssize_t nxt_cgo_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
15 static ssize_t nxt_cgo_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
51 nxt_cgo_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_cgo_port_send()
60 nxt_cgo_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_cgo_port_recv()
|
| H A D | port.go | 97 func nxt_go_add_port(ctx *C.nxt_unit_ctx_t, p *C.nxt_unit_port_t) C.int { argument
127 p *C.nxt_unit_port_t) { argument
|
| /unit/src/nodejs/unit-http/ |
| H A D | unit.h | 43 static int add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port);
45 nxt_unit_port_t *port);
|
| H A D | unit.cpp | 20 port_data_t(nxt_unit_ctx_t *c, nxt_unit_port_t *p);
33 nxt_unit_port_t *port;
50 port_data_t::port_data_t(nxt_unit_ctx_t *c, nxt_unit_port_t *p) : in port_data_t()
471 Unit::add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in add_port()
522 Unit::remove_port(nxt_unit_t *unit, nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in remove_port()
|
| /unit/src/python/ |
| H A D | nxt_python_asgi.c | 28 nxt_unit_port_t *port);
41 static int nxt_py_asgi_add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port);
42 static int nxt_py_asgi_add_reader(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port);
44 nxt_unit_port_t *port);
415 nxt_py_asgi_remove_reader(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_remove_reader()
1002 nxt_py_asgi_add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_port()
1026 nxt_py_asgi_add_reader(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_reader()
1091 nxt_unit_port_t *port) in nxt_py_asgi_remove_port()
1163 nxt_unit_port_t *port; in nxt_py_asgi_port_read()
|