Home
last modified time | relevance | path

Searched refs:obj (Results 26 – 50 of 77) sorted by relevance

1234

/unit/src/
H A Dnxt_h1proto_websocket.c20 static void nxt_h1p_conn_ws_frame_header_read(nxt_task_t *task, void *obj,
28 static void nxt_h1p_conn_ws_error(nxt_task_t *task, void *obj, void *data);
161 nxt_h1p_conn_ws_keepalive(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_keepalive() argument
172 timer = obj; in nxt_h1p_conn_ws_keepalive()
227 c = obj; in nxt_h1p_conn_ws_frame_header_read()
442 nxt_h1p_conn_ws_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_error() argument
496 nxt_h1p_conn_ws_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_timeout() argument
503 timer = obj; in nxt_h1p_conn_ws_timeout()
550 c = obj; in nxt_h1p_conn_ws_frame_payload_read()
646 nxt_h1p_conn_ws_pong(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_pong() argument
[all …]
H A Dnxt_http_return.c27 static void nxt_http_return_send_ready(nxt_task_t *task, void *obj, void *data);
28 static void nxt_http_return_send_error(nxt_task_t *task, void *obj, void *data);
177 nxt_http_return_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_return_send_ready() argument
184 r = obj; in nxt_http_return_send_ready()
220 nxt_http_return_send_error(nxt_task_t *task, void *obj, void *data) in nxt_http_return_send_error() argument
224 r = obj; in nxt_http_return_send_error()
H A Dnxt_isolation.c225 nxt_conf_value_t *obj; in nxt_isolation_set_cgroup() local
231 if (obj == NULL) { in nxt_isolation_set_cgroup()
235 obj = nxt_conf_get_object_member(obj, &path, NULL); in nxt_isolation_set_cgroup()
236 if (obj == NULL) { in nxt_isolation_set_cgroup()
261 nxt_conf_value_t *obj; in nxt_isolation_set_namespaces() local
266 if (obj != NULL) { in nxt_isolation_set_namespaces()
324 nxt_conf_value_t *obj; in nxt_isolation_credential_map() local
497 nxt_conf_value_t *obj; in nxt_isolation_set_rootfs() local
502 if (obj != NULL) { in nxt_isolation_set_rootfs()
1111 nxt_conf_value_t *obj; in nxt_isolation_set_new_privs() local
[all …]
H A Dnxt_log_moderation.c10 static void nxt_log_moderate_timer_handler(nxt_task_t *task, void *obj,
74 nxt_log_moderate_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_log_moderate_timer_handler() argument
81 ev = obj; in nxt_log_moderate_timer_handler()
H A Dnxt_thread_pool.c11 static void nxt_thread_pool_exit(nxt_task_t *task, void *obj, void *data);
133 void *obj, *data; in nxt_thread_pool_loop() local
149 handler = nxt_locked_work_queue_pop(&tp->work_queue, &task, &obj, in nxt_thread_pool_loop()
157 handler(task, obj, data); in nxt_thread_pool_loop()
267 nxt_thread_pool_exit(nxt_task_t *task, void *obj, void *data) in nxt_thread_pool_exit() argument
274 tp = obj; in nxt_thread_pool_exit()
H A Dnxt_conn.h232 void nxt_conn_sys_socket(nxt_task_t *task, void *obj, void *data);
233 void nxt_conn_io_connect(nxt_task_t *task, void *obj, void *data);
235 void nxt_conn_connect_test(nxt_task_t *task, void *obj, void *data);
236 void nxt_conn_connect_error(nxt_task_t *task, void *obj, void *data);
240 void nxt_conn_io_accept(nxt_task_t *task, void *obj, void *data);
248 void nxt_conn_io_read(nxt_task_t *task, void *obj, void *data);
253 void nxt_conn_io_write(nxt_task_t *task, void *obj, void *data);
H A Dnxt_router_access_log.c29 static void nxt_router_access_log_write_ready(nxt_task_t *task, void *obj,
31 static void nxt_router_access_log_write_error(nxt_task_t *task, void *obj,
37 static void nxt_router_access_log_reopen_completion(nxt_task_t *task, void *obj,
203 nxt_router_access_log_write_ready(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_write_ready() argument
208 r = obj; in nxt_router_access_log_write_ready()
218 nxt_router_access_log_write_error(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_write_error() argument
425 nxt_router_access_log_reopen_completion(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_reopen_completion() argument
430 b = obj; in nxt_router_access_log_reopen_completion()
H A Dnxt_controller.c299 certs = obj; in nxt_controller_cert_cleanup()
720 c = obj; in nxt_controller_conn_init()
782 c = obj; in nxt_controller_conn_read()
864 c = obj; in nxt_controller_conn_read_error()
878 timer = obj; in nxt_controller_conn_read_timeout()
912 c = obj; in nxt_controller_conn_body_read()
949 c = obj; in nxt_controller_conn_write()
971 c = obj; in nxt_controller_conn_write_error()
985 timer = obj; in nxt_controller_conn_write_timeout()
1009 c = obj; in nxt_controller_conn_close()
[all …]
H A Dnxt_timer.h76 #define nxt_timer_data(obj, type, timer) \ argument
77 nxt_container_of(obj, type, timer)
H A Dnxt_epoll_engine.c85 static void nxt_epoll_conn_io_accept4(nxt_task_t *task, void *obj,
94 static void nxt_epoll_edge_conn_connected(nxt_task_t *task, void *obj,
650 nxt_epoll_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_error_handler() argument
654 ev = obj; in nxt_epoll_error_handler()
722 nxt_epoll_signalfd_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_signalfd_handler() argument
729 ev = obj; in nxt_epoll_signalfd_handler()
809 nxt_epoll_eventfd_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_eventfd_handler() argument
1008 nxt_epoll_conn_io_accept4(nxt_task_t *task, void *obj, void *data) in nxt_epoll_conn_io_accept4() argument
1016 lev = obj; in nxt_epoll_conn_io_accept4()
1065 c = obj; in nxt_epoll_edge_conn_io_connect()
[all …]
H A Dnxt_http_error.c78 nxt_http_request_send_error_body(nxt_task_t *task, void *obj, void *data) in nxt_http_request_send_error_body() argument
83 r = obj; in nxt_http_request_send_error_body()
H A Dnxt_cyassl.c28 static void nxt_cyassl_conn_handshake(nxt_thread_t *thr, void *obj, void *data);
29 static void nxt_cyassl_conn_io_read(nxt_thread_t *thr, void *obj, void *data);
30 static void nxt_cyassl_conn_io_shutdown(nxt_thread_t *thr, void *obj,
295 nxt_cyassl_conn_handshake(nxt_thread_t *thr, void *obj, void *data) in nxt_cyassl_conn_handshake() argument
303 c = obj; in nxt_cyassl_conn_handshake()
339 nxt_cyassl_conn_io_read(nxt_thread_t *thr, void *obj, void *data) in nxt_cyassl_conn_io_read() argument
349 c = obj; in nxt_cyassl_conn_io_read()
450 nxt_cyassl_conn_io_shutdown(nxt_thread_t *thr, void *obj, void *data) in nxt_cyassl_conn_io_shutdown() argument
456 c = obj; in nxt_cyassl_conn_io_shutdown()
H A Dnxt_gnutls.c45 static void nxt_gnutls_conn_handshake(nxt_thread_t *thr, void *obj, void *data);
46 static void nxt_gnutls_conn_io_read(nxt_thread_t *thr, void *obj, void *data);
51 static void nxt_gnutls_conn_io_shutdown(nxt_thread_t *thr, void *obj,
426 nxt_gnutls_conn_handshake(nxt_thread_t *thr, void *obj, void *data) in nxt_gnutls_conn_handshake() argument
433 c = obj; in nxt_gnutls_conn_handshake()
469 nxt_gnutls_conn_io_read(nxt_thread_t *thr, void *obj, void *data) in nxt_gnutls_conn_io_read() argument
478 c = obj; in nxt_gnutls_conn_io_read()
571 nxt_gnutls_conn_io_shutdown(nxt_thread_t *thr, void *obj, void *data) in nxt_gnutls_conn_io_shutdown() argument
580 c = obj; in nxt_gnutls_conn_io_shutdown()
H A Dnxt_fiber.c12 static void nxt_fiber_switch_handler(nxt_task_t *task, void *obj, void *data);
14 static void nxt_fiber_timer_handler(nxt_task_t *task, void *obj, void *data);
331 nxt_fiber_switch_handler(nxt_task_t *task, void *obj, void *data) in nxt_fiber_switch_handler() argument
335 fib = obj; in nxt_fiber_switch_handler()
413 nxt_fiber_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_fiber_timer_handler() argument
418 ev = obj; in nxt_fiber_timer_handler()
H A Dnxt_http_request.c12 static void nxt_http_request_start(nxt_task_t *task, void *obj, void *data);
21 static void nxt_http_request_ready(nxt_task_t *task, void *obj, void *data);
26 static void nxt_http_request_done(nxt_task_t *task, void *obj, void *data);
308 nxt_http_request_start(nxt_task_t *task, void *obj, void *data) in nxt_http_request_start() argument
314 r = obj; in nxt_http_request_start()
544 nxt_http_request_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_request_ready() argument
549 r = obj; in nxt_http_request_ready()
760 b = obj; in nxt_http_request_mem_buf_completion()
787 nxt_http_request_done(nxt_task_t *task, void *obj, void *data) in nxt_http_request_done() argument
805 r = obj; in nxt_http_request_error_handler()
[all …]
H A Dnxt_http_chunk_parse.c23 static void nxt_http_chunk_buf_completion(nxt_task_t *task, void *obj,
249 nxt_http_chunk_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_http_chunk_buf_completion() argument
254 b = obj; in nxt_http_chunk_buf_completion()
H A Dnxt_source.h38 NXT_EXPORT void nxt_source_filter_handler(nxt_task_t *task, void *obj,
H A Dnxt_http_static.c50 static void nxt_http_static_send_ready(nxt_task_t *task, void *obj, void *data);
59 static void nxt_http_static_body_handler(nxt_task_t *task, void *obj,
61 static void nxt_http_static_buf_completion(nxt_task_t *task, void *obj,
302 nxt_http_static_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_static_send_ready() argument
322 r = obj; in nxt_http_static_send_ready()
666 nxt_http_static_send_error(nxt_task_t *task, void *obj, void *data) in nxt_http_static_send_error() argument
670 r = obj; in nxt_http_static_send_error()
793 nxt_http_static_body_handler(nxt_task_t *task, void *obj, void *data) in nxt_http_static_body_handler() argument
802 r = obj; in nxt_http_static_body_handler()
855 nxt_http_static_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_http_static_buf_completion() argument
[all …]
H A Dnxt_port_socket.c23 static void nxt_port_write_handler(nxt_task_t *task, void *obj, void *data);
32 static void nxt_port_queue_read_handler(nxt_task_t *task, void *obj,
367 nxt_port_write_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_write_handler() argument
381 port = nxt_container_of(obj, nxt_port_t, socket); in nxt_port_write_handler()
731 nxt_port_read_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_read_handler() argument
741 port = msg.port = nxt_container_of(obj, nxt_port_t, socket); in nxt_port_read_handler()
824 port = nxt_container_of(obj, nxt_port_t, socket); in nxt_port_queue_read_handler()
1336 nxt_port_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_error_handler() argument
1344 nxt_debug(task, "port error handler %p", obj); in nxt_port_error_handler()
1347 port = nxt_container_of(obj, nxt_port_t, socket); in nxt_port_error_handler()
[all …]
/unit/src/python/
H A Dnxt_python_asgi.c100 if (PyFunction_Check(obj)) { in nxt_python_asgi_get_func()
101 Py_INCREF(obj); in nxt_python_asgi_get_func()
102 return obj; in nxt_python_asgi_get_func()
105 if (PyMethod_Check(obj)) { in nxt_python_asgi_get_func()
106 obj = PyMethod_GET_FUNCTION(obj); in nxt_python_asgi_get_func()
108 Py_INCREF(obj); in nxt_python_asgi_get_func()
109 return obj; in nxt_python_asgi_get_func()
126 Py_INCREF(obj); in nxt_python_asgi_get_func()
129 obj = NULL; in nxt_python_asgi_get_func()
133 obj = NULL; in nxt_python_asgi_get_func()
[all …]
H A Dnxt_python_wsgi.c186 PyObject *obj; in nxt_python_wsgi_init() local
188 obj = NULL; in nxt_python_wsgi_init()
202 nxt_py_environ_ptyp = obj; in nxt_python_wsgi_init()
203 obj = NULL; in nxt_python_wsgi_init()
213 Py_XDECREF(obj); in nxt_python_wsgi_init()
493 Py_DECREF(obj); in nxt_python_create_environ()
510 Py_DECREF(obj); in nxt_python_create_environ()
511 obj = NULL; in nxt_python_create_environ()
567 Py_XDECREF(obj); in nxt_python_create_environ()
1181 PyObject *content, *obj; in nxt_py_input_read() local
[all …]
/unit/src/nodejs/unit-http/
H A Dunit.cpp209 delete obj; in destroy()
249 Unit *obj; in create_server() local
268 unit_init.data = obj; in create_server()
304 Unit *obj; in request_handler_cb() local
347 Unit *obj; in websocket_handler_cb() local
390 Unit *obj; in close_handler_cb() local
394 obj->close_handler(req); in close_handler_cb()
439 Unit *obj; in shm_ack_handler_cb() local
474 Unit *obj; in add_port() local
537 Unit *obj; in quit_cb() local
[all …]
H A Dwebsocket_request.js195 var obj = { class in AnonymousFunctiondeff99b60300
199 array.splice(index, 1, obj);
201 var obj = { class in AnonymousFunctiondeff99b60200
205 array.splice(index, 1, obj);
/unit/src/java/javax/websocket/
H A DRemoteEndpoint.java93 Future<Void> sendObject(Object obj); in sendObject() argument
104 void sendObject(Object obj, SendHandler completion); in sendObject() argument
/unit/src/test/
H A Dnxt_clone_test.c561 nxt_conf_value_t *array, *obj, *value; in nxt_clone_test_parse_map() local
588 obj = nxt_conf_get_array_element(array, i); in nxt_clone_test_parse_map()
590 value = nxt_conf_get_object_member(obj, &host_name, NULL); in nxt_clone_test_parse_map()
593 value = nxt_conf_get_object_member(obj, &cont_name, NULL); in nxt_clone_test_parse_map()
596 value = nxt_conf_get_object_member(obj, &size_name, NULL); in nxt_clone_test_parse_map()

1234