/unit/src/ |
H A D | nxt_h1proto_websocket.c | 20 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 D | nxt_http_return.c | 27 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 D | nxt_isolation.c | 225 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 D | nxt_log_moderation.c | 10 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 D | nxt_thread_pool.c | 11 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 D | nxt_conn.h | 232 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 D | nxt_router_access_log.c | 29 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 D | nxt_controller.c | 299 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 D | nxt_timer.h | 76 #define nxt_timer_data(obj, type, timer) \ argument 77 nxt_container_of(obj, type, timer)
|
H A D | nxt_epoll_engine.c | 85 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 D | nxt_http_error.c | 78 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 D | nxt_cyassl.c | 28 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 D | nxt_gnutls.c | 45 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 D | nxt_fiber.c | 12 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 D | nxt_http_request.c | 12 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 D | nxt_http_chunk_parse.c | 23 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 D | nxt_source.h | 38 NXT_EXPORT void nxt_source_filter_handler(nxt_task_t *task, void *obj,
|
H A D | nxt_http_static.c | 50 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 D | nxt_port_socket.c | 23 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 D | nxt_python_asgi.c | 100 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 D | nxt_python_wsgi.c | 186 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 D | unit.cpp | 209 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 D | websocket_request.js | 195 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 D | RemoteEndpoint.java | 93 Future<Void> sendObject(Object obj); in sendObject() argument 104 void sendObject(Object obj, SendHandler completion); in sendObject() argument
|
/unit/src/test/ |
H A D | nxt_clone_test.c | 561 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()
|