Home
last modified time | relevance | path

Searched refs:type (Results 101 – 125 of 129) sorted by path

123456

/unit/src/
H A Dnxt_runtime.c82 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 Dnxt_runtime.h50 nxt_process_type_t type; member
117 nxt_pid_t pid, nxt_port_id_t id, nxt_process_type_t type);
H A Dnxt_script.c501 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 Dnxt_service.c102 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 Dnxt_service.h12 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 Dnxt_sockaddr.c39 sa->type = ls->sockaddr->type; in nxt_sockaddr_cache_alloc()
363 if (sa1->type != sa2->type) { in nxt_sockaddr_cmp()
H A Dnxt_sockaddr.h24 uint8_t type; member
H A Dnxt_socket.c15 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 Dnxt_socket.h95 nxt_uint_t type, nxt_uint_t protocol, nxt_uint_t flags);
H A Dnxt_thread.h33 #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 Dnxt_timer.h76 #define nxt_timer_data(obj, type, timer) \ argument
77 nxt_container_of(obj, type, timer)
H A Dnxt_tstr.c29 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 Dnxt_unit.c1054 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 Dnxt_upstream.h47 } type; member
H A Dnxt_upstream_round_robin.c102 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 Dnxt_vector.c23 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 Dnxt_vector.h27 nxt_vector_type_t type:8; member
/unit/src/python/
H A Dnxt_python_asgi.c644 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 Dnxt_python_asgi.h47 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 Dnxt_python_asgi_http.c256 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 Dnxt_python_asgi_lifespan.c64 .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 Dnxt_python_asgi_websocket.c205 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 DCargo.toml8 crate-type = ["cdylib"]
/unit/src/wasm/
H A Dnxt_wasm.c309 .type = nxt_string("wasm"),
/unit/test/
H A Dconftest.py58 type=str,
63 type=int,

123456