Home
last modified time | relevance | path

Searched refs:nxt_unit_port_t (Results 1 – 8 of 8) sorted by relevance

/unit/src/
H A Dnxt_unit.h99 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 Dnxt_unit_typedefs.h13 typedef struct nxt_unit_port_s nxt_unit_port_t; typedef
H A Dnxt_unit.c57 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()
5272 static nxt_unit_port_t *
5431 static nxt_unit_port_t *
5675 static nxt_unit_port_t *
5678 nxt_unit_port_t *port; in nxt_unit_remove_port_unsafe()
[all …]
/unit/go/
H A Dnxt_cgo_lib.c13 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 Dport.go97 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 Dunit.h43 static int add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port);
45 nxt_unit_port_t *port);
H A Dunit.cpp20 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 Dnxt_python_asgi.c28 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()