/unit/src/ |
H A D | nxt_runtime.c | 82 lang->type = NXT_APP_EXTERNAL; in nxt_runtime_create() 155 nxt_int_t type; in nxt_runtime_inherited_listen_sockets() local 203 if (nxt_slow_path(type == -1)) { in nxt_runtime_inherited_listen_sockets() 207 ls->sockaddr->type = (uint16_t) type; in nxt_runtime_inherited_listen_sockets() 271 ls->sockaddr->type = SOCK_STREAM; in nxt_runtime_systemd_listen_sockets() 453 if (rt->type == NXT_PROCESS_MAIN) { in nxt_runtime_quit() 505 if (init->type == NXT_PROCESS_APP in nxt_runtime_stop_app_processes() 559 if (rt->type == NXT_PROCESS_MAIN) { in nxt_runtime_exit() 934 sa->type = SOCK_STREAM; in nxt_runtime_conf_init() 1256 ls->sockaddr->type = sa->type; in nxt_runtime_listen_socket_add() [all …]
|
H A D | nxt_runtime.h | 50 nxt_process_type_t type; member 117 nxt_pid_t pid, nxt_port_id_t id, nxt_process_type_t type);
|
H A D | nxt_script.c | 501 recv_port = rt->port_by_type[rt->type]; in nxt_script_store_get() 549 nxt_port_msg_type_t type; in nxt_script_store_get_handler() local 560 if (nxt_slow_path(port->type != NXT_PROCESS_CONTROLLER in nxt_script_store_get_handler() 561 && port->type != NXT_PROCESS_ROUTER)) in nxt_script_store_get_handler() 571 type = NXT_PORT_MSG_RPC_ERROR; in nxt_script_store_get_handler() 597 type = NXT_PORT_MSG_RPC_READY_LAST | NXT_PORT_MSG_CLOSE_FD; in nxt_script_store_get_handler() 602 (void) nxt_port_socket_write(task, port, type, file.fd, in nxt_script_store_get_handler()
|
H A D | nxt_service.c | 102 if (nxt_strcmp(s->type, service->type) != 0) { in nxt_service_add() 111 service->type, service->name); in nxt_service_add() 131 nxt_service_get(nxt_array_t *services, const char *type, const char *name) in nxt_service_get() argument 146 if (nxt_strcmp(s->type, type) == 0) { in nxt_service_get() 162 type, (name != NULL) ? ":" : "", name); in nxt_service_get()
|
H A D | nxt_service.h | 12 const char *type; member 19 ((s)->type == NULL) 25 NXT_EXPORT const void *nxt_service_get(nxt_array_t *services, const char *type,
|
H A D | nxt_sockaddr.c | 39 sa->type = ls->sockaddr->type; in nxt_sockaddr_cache_alloc() 363 if (sa1->type != sa2->type) { in nxt_sockaddr_cmp()
|
H A D | nxt_sockaddr.h | 24 uint8_t type; member
|
H A D | nxt_socket.c | 15 nxt_socket_create(nxt_task_t *task, nxt_uint_t domain, nxt_uint_t type, in nxt_socket_create() argument 23 type |= SOCK_NONBLOCK; in nxt_socket_create() 28 s = socket(domain, type, protocol); in nxt_socket_create() 32 domain, type, protocol, nxt_socket_errno); in nxt_socket_create()
|
H A D | nxt_socket.h | 95 nxt_uint_t type, nxt_uint_t protocol, nxt_uint_t flags);
|
H A D | nxt_thread.h | 33 #define nxt_thread_extern_data(type, tsd) \ argument 34 NXT_EXPORT extern __thread type tsd 36 #define nxt_thread_declare_data(type, tsd) \ argument 37 __thread type tsd 66 #define nxt_thread_extern_data(type, tsd) \ argument 69 #define nxt_thread_declare_data(type, tsd) \ argument 70 nxt_thread_specific_data_t tsd = { { (nxt_atomic_int_t) -1, sizeof(type) } }
|
H A D | nxt_timer.h | 76 #define nxt_timer_data(obj, type, timer) \ argument 77 nxt_container_of(obj, type, timer)
|
H A D | nxt_tstr.c | 29 nxt_tstr_type_t type; member 119 tstr->type = NXT_TSTR_JS; in nxt_tstr_compile() 134 tstr->type = NXT_TSTR_VAR; in nxt_tstr_compile() 142 tstr->type = NXT_TSTR_CONST; in nxt_tstr_compile() 208 return (tstr->type == NXT_TSTR_CONST); in nxt_tstr_is_const() 264 if (tstr->type == NXT_TSTR_VAR) { in nxt_tstr_query()
|
H A D | nxt_unit.c | 1054 switch (port_msg->type) { in nxt_unit_process_msg() 2657 m.msg.type = _NXT_PORT_MSG_DATA; in nxt_unit_mmap_buf_send() 3629 msg.type = _NXT_PORT_MSG_OOSM; in nxt_unit_send_oosm() 3913 msg.type = _NXT_PORT_MSG_MMAP; in nxt_unit_send_mmap() 4108 msg.type = _NXT_PORT_MSG_RPC_READY; in nxt_unit_awake_ctx() 4328 m.msg.type = _NXT_PORT_MSG_GET_MMAP; in nxt_unit_get_mmap() 4397 msg.type = _NXT_PORT_MSG_SHM_ACK; in nxt_unit_send_shm_ack() 5362 m.msg.type = _NXT_PORT_MSG_NEW_PORT; in nxt_unit_send_port() 5370 m.new_port.type = NXT_PROCESS_APP; in nxt_unit_send_port() 5843 m.msg.type = _NXT_PORT_MSG_QUIT; in nxt_unit_quit() [all …]
|
H A D | nxt_upstream.h | 47 } type; member
|
H A D | nxt_upstream_round_robin.c | 102 sa->type = SOCK_STREAM; in nxt_upstream_round_robin_create() 116 upstream->type.round_robin = urr; in nxt_upstream_round_robin_create() 141 urrcf = upstream->type.round_robin; in nxt_upstream_round_robin_joint_create() 151 u->type.round_robin = urr; in nxt_upstream_round_robin_joint_create() 175 round_robin = us->upstream->type.round_robin; in nxt_upstream_round_robin_server_get()
|
H A D | nxt_vector.c | 23 vector->type = NXT_VECTOR_EMBEDDED; in nxt_vector_create() 40 vector->type = NXT_VECTOR_INITED; in nxt_vector_init() 51 switch (vector->type) { in nxt_vector_destroy() 107 if (vector->type == NXT_VECTOR_EMBEDDED) { in nxt_vector_add() 108 vector->type = NXT_VECTOR_DESCRETE; in nxt_vector_add()
|
H A D | nxt_vector.h | 27 nxt_vector_type_t type:8; member
|
/unit/src/python/ |
H A D | nxt_python_asgi.c | 644 PyObject *scope, *v, *type, *scheme; in nxt_py_asgi_create_http_scope() local 667 type = nxt_py_websocket_str; in nxt_py_asgi_create_http_scope() 671 type = nxt_py_http_str; in nxt_py_asgi_create_http_scope() 675 scope = nxt_py_asgi_new_scope(req, type, nxt_py_2_1_str); in nxt_py_asgi_create_http_scope() 1401 nxt_py_asgi_new_msg(nxt_unit_request_info_t *req, PyObject *type) in nxt_py_asgi_new_msg() argument 1414 if (nxt_slow_path(PyDict_SetItem(msg, nxt_py_type_str, type) == -1)) { in nxt_py_asgi_new_msg() 1428 nxt_py_asgi_new_scope(nxt_unit_request_info_t *req, PyObject *type, in nxt_py_asgi_new_scope() argument 1442 if (nxt_slow_path(PyDict_SetItem(scope, nxt_py_type_str, type) == -1)) { in nxt_py_asgi_new_scope()
|
H A D | nxt_python_asgi.h | 47 PyObject *nxt_py_asgi_new_msg(nxt_unit_request_info_t *req, PyObject *type); 48 PyObject *nxt_py_asgi_new_scope(nxt_unit_request_info_t *req, PyObject *type,
|
H A D | nxt_python_asgi_http.c | 256 PyObject *type; in nxt_py_asgi_http_send() local 266 type = PyDict_GetItem(dict, nxt_py_type_str); in nxt_py_asgi_http_send() 267 if (nxt_slow_path(type == NULL || !PyUnicode_Check(type))) { in nxt_py_asgi_http_send() 273 type_str = PyUnicode_AsUTF8AndSize(type, &type_len); in nxt_py_asgi_http_send() 285 "but got '%U'", type); in nxt_py_asgi_http_send() 294 "but got '%U'", type); in nxt_py_asgi_http_send()
|
H A D | nxt_python_asgi_lifespan.c | 64 .type = T_OBJECT_EX, 449 PyObject *type, *msg; in nxt_py_asgi_lifespan_send() local 465 type = PyDict_GetItem(dict, nxt_py_type_str); in nxt_py_asgi_lifespan_send() 466 if (nxt_slow_path(type == NULL || !PyUnicode_Check(type))) { in nxt_py_asgi_lifespan_send() 473 type_str = PyUnicode_AsUTF8AndSize(type, &type_len); in nxt_py_asgi_lifespan_send()
|
H A D | nxt_python_asgi_websocket.c | 205 PyObject *type; in nxt_py_asgi_websocket_send() local 216 type = PyDict_GetItem(dict, nxt_py_type_str); in nxt_py_asgi_websocket_send() 217 if (nxt_slow_path(type == NULL || !PyUnicode_Check(type))) { in nxt_py_asgi_websocket_send() 224 type_str = PyUnicode_AsUTF8AndSize(type, &type_len); in nxt_py_asgi_websocket_send() 249 return PyErr_Format(PyExc_AssertionError, "unexpected 'type': '%U'", type); in nxt_py_asgi_websocket_send() 737 PyObject *msg, *data, *type, *data_key; in nxt_py_asgi_websocket_pop_msg() local 775 type = nxt_py_websocket_receive_str; in nxt_py_asgi_websocket_pop_msg() 840 type = nxt_py_websocket_disconnect_str; in nxt_py_asgi_websocket_pop_msg() 900 msg = nxt_py_asgi_new_msg(ws->req, type); in nxt_py_asgi_websocket_pop_msg()
|
/unit/src/wasm-wasi-component/ |
H A D | Cargo.toml | 8 crate-type = ["cdylib"]
|
/unit/src/wasm/ |
H A D | nxt_wasm.c | 309 .type = nxt_string("wasm"),
|
/unit/test/ |
H A D | conftest.py | 58 type=str, 63 type=int,
|