Home
last modified time | relevance | path

Searched refs:obj (Results 1 – 25 of 84) sorted by last modified time

1234

/unit/src/
H A Dnxt_router.h243 void nxt_router_conf_apply(nxt_task_t *task, void *obj, void *data);
H A Dnxt_runtime.h138 void nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data);
H A Dnxt_router_access_log.c28 static void nxt_router_access_log_write_ready(nxt_task_t *task, void *obj,
30 static void nxt_router_access_log_write_error(nxt_task_t *task, void *obj,
36 static void nxt_router_access_log_reopen_completion(nxt_task_t *task, void *obj,
178 nxt_router_access_log_write_ready(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_write_ready() argument
183 r = obj; in nxt_router_access_log_write_ready()
193 nxt_router_access_log_write_error(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_write_error() argument
400 nxt_router_access_log_reopen_completion(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_reopen_completion() argument
405 b = obj; in nxt_router_access_log_reopen_completion()
H A Dnxt_router.c1154 tmcf = obj; in nxt_router_conf_apply()
1249 job = obj; in nxt_router_conf_wait()
3512 job = obj; in nxt_router_listen_socket_create()
3574 job = obj; in nxt_router_listen_socket_update()
3656 timer = obj; in nxt_router_listen_socket_close()
4179 r = obj; in nxt_http_request_send_body()
4687 app = obj; in nxt_router_adjust_idle_timer()
4775 timer = obj; in nxt_router_app_idle_timeout()
4790 timer = obj; in nxt_router_app_joint_release_handler()
5003 r = obj; in nxt_router_http_request_error()
[all …]
H A Dnxt_main.h29 typedef void (*nxt_work_handler_t)(nxt_task_t *task, void *obj, void *data);
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,
301 nxt_http_static_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_static_send_ready() argument
321 r = obj; in nxt_http_static_send_ready()
665 nxt_http_static_send_error(nxt_task_t *task, void *obj, void *data) in nxt_http_static_send_error() argument
669 r = obj; in nxt_http_static_send_error()
787 nxt_http_static_body_handler(nxt_task_t *task, void *obj, void *data) in nxt_http_static_body_handler() argument
796 r = obj; in nxt_http_static_body_handler()
849 nxt_http_static_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_http_static_buf_completion() 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_http_route.c196 static void nxt_http_pass_query_ready(nxt_task_t *task, void *obj, void *data);
197 static void nxt_http_pass_query_error(nxt_task_t *task, void *obj, void *data);
1337 nxt_http_pass_query_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_pass_query_ready() argument
1345 r = obj; in nxt_http_pass_query_ready()
1366 nxt_http_pass_query_error(nxt_task_t *task, void *obj, void *data) in nxt_http_pass_query_error() argument
1370 r = obj; in nxt_http_pass_query_error()
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);
306 nxt_http_request_start(nxt_task_t *task, void *obj, void *data) in nxt_http_request_start() argument
312 r = obj; in nxt_http_request_start()
542 nxt_http_request_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_request_ready() argument
547 r = obj; in nxt_http_request_ready()
739 b = obj; in nxt_http_request_mem_buf_completion()
766 nxt_http_request_done(nxt_task_t *task, void *obj, void *data) in nxt_http_request_done() argument
784 r = obj; in nxt_http_request_error_handler()
[all …]
H A Dnxt_http.h316 void nxt_http_conn_init(nxt_task_t *task, void *obj, void *data);
330 void nxt_http_request_error_handler(nxt_task_t *task, void *obj, void *data);
331 void nxt_http_request_close_handler(nxt_task_t *task, void *obj, void *data);
H A Dnxt_main_process.c38 static void nxt_main_process_sigterm_handler(nxt_task_t *task, void *obj,
40 static void nxt_main_process_sigquit_handler(nxt_task_t *task, void *obj,
42 static void nxt_main_process_sigusr1_handler(nxt_task_t *task, void *obj,
44 static void nxt_main_process_sigchld_handler(nxt_task_t *task, void *obj,
46 static void nxt_main_process_signal_handler(nxt_task_t *task, void *obj,
747 (int) (uintptr_t) obj, data); in nxt_main_process_sigterm_handler()
761 (int) (uintptr_t) obj, data); in nxt_main_process_sigquit_handler()
783 (int) (uintptr_t) obj, data, "log files rotation"); in nxt_main_process_sigusr1_handler()
883 (int) (uintptr_t) obj, data); in nxt_main_process_sigchld_handler()
997 nxt_main_process_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_main_process_signal_handler() argument
[all …]
H A Dnxt_openssl.c92 static void nxt_openssl_conn_handshake(nxt_task_t *task, void *obj, void *data);
97 static void nxt_openssl_conn_io_shutdown(nxt_task_t *task, void *obj,
101 static void nxt_openssl_conn_io_shutdown_timeout(nxt_task_t *task, void *obj,
1238 nxt_openssl_conn_handshake(nxt_task_t *task, void *obj, void *data) argument
1249 c = obj;
1423 nxt_openssl_conn_io_shutdown(nxt_task_t *task, void *obj, void *data) argument
1434 c = obj;
1610 nxt_openssl_conn_io_shutdown_timeout(nxt_task_t *task, void *obj, void *data) argument
1615 timer = obj;
H A Dnxt_controller.c282 certs = obj; in nxt_controller_cert_cleanup()
695 c = obj; in nxt_controller_conn_init()
757 c = obj; in nxt_controller_conn_read()
839 c = obj; in nxt_controller_conn_read_error()
853 timer = obj; in nxt_controller_conn_read_timeout()
887 c = obj; in nxt_controller_conn_body_read()
924 c = obj; in nxt_controller_conn_write()
946 c = obj; in nxt_controller_conn_write_error()
960 timer = obj; in nxt_controller_conn_write_timeout()
984 c = obj; in nxt_controller_conn_close()
[all …]
H A Dnxt_h1proto.c220 c = obj; in nxt_http_conn_init()
318 c = obj; in nxt_http_conn_test()
449 c = obj; in nxt_h1p_conn_proto_init()
476 c = obj; in nxt_h1p_conn_request_init()
554 c = obj; in nxt_h1p_conn_request_header_parse()
1025 c = obj; in nxt_h1p_conn_request_body_read()
1719 c = obj; in nxt_h1p_conn_sent()
1738 c = obj; in nxt_h1p_conn_close()
1753 c = obj; in nxt_h1p_conn_error()
1855 c = obj; in nxt_h1p_idle_close()
[all …]
H A Dnxt_application.c46 static void nxt_discovery_completion_handler(nxt_task_t *task, void *obj,
66 static void nxt_proto_signal_handler(nxt_task_t *task, void *obj, void *data);
67 static void nxt_proto_sigterm_handler(nxt_task_t *task, void *obj, void *data);
486 nxt_discovery_completion_handler(nxt_task_t *task, void *obj, void *data) in nxt_discovery_completion_handler() argument
491 b = obj; in nxt_discovery_completion_handler()
740 nxt_proto_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_proto_signal_handler() argument
743 (int) (uintptr_t) obj, data); in nxt_proto_signal_handler()
748 nxt_proto_sigterm_handler(nxt_task_t *task, void *obj, void *data) in nxt_proto_sigterm_handler() argument
751 (int) (uintptr_t) obj, data); in nxt_proto_sigterm_handler()
764 nxt_proto_sigchld_handler(nxt_task_t *task, void *obj, void *data) in nxt_proto_sigchld_handler() argument
[all …]
H A Dnxt_port.c23 nxt_port_mp_cleanup(nxt_task_t *task, void *obj, void *data) in nxt_port_mp_cleanup() argument
28 port = obj; in nxt_port_mp_cleanup()
555 nxt_port_post_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_post_handler() argument
561 pw = obj; in nxt_port_post_handler()
595 pw->work.obj = pw; in nxt_port_post()
H A Dnxt_runtime.c22 static void nxt_runtime_start(nxt_task_t *task, void *obj, void *data);
26 static void nxt_runtime_exit(nxt_task_t *task, void *obj, void *data);
40 static void nxt_runtime_thread_pool_exit(nxt_task_t *task, void *obj,
340 nxt_runtime_start(nxt_task_t *task, void *obj, void *data) in nxt_runtime_start() argument
344 rt = obj; in nxt_runtime_start()
543 nxt_runtime_exit(nxt_task_t *task, void *obj, void *data) in nxt_runtime_exit() argument
550 rt = obj; in nxt_runtime_exit()
713 nxt_runtime_thread_pool_exit(nxt_task_t *task, void *obj, void *data) in nxt_runtime_thread_pool_exit() argument
720 tp = obj; in nxt_runtime_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_conn_close.c10 static void nxt_conn_shutdown_handler(nxt_task_t *task, void *obj, void *data);
11 static void nxt_conn_close_handler(nxt_task_t *task, void *obj, void *data);
12 static void nxt_conn_close_timer_handler(nxt_task_t *task, void *obj,
14 static void nxt_conn_close_error_ignore(nxt_task_t *task, void *obj,
75 nxt_conn_shutdown_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_shutdown_handler() argument
80 c = obj; in nxt_conn_shutdown_handler()
95 nxt_conn_close_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_handler() argument
101 c = obj; in nxt_conn_close_handler()
142 nxt_conn_close_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_timer_handler() argument
148 timer = obj; in nxt_conn_close_timer_handler()
[all …]
/unit/src/python/
H A Dnxt_python_wsgi.c183 PyObject *obj; in nxt_python_wsgi_init() local
185 obj = NULL; in nxt_python_wsgi_init()
199 nxt_py_environ_ptyp = obj; in nxt_python_wsgi_init()
200 obj = NULL; in nxt_python_wsgi_init()
210 Py_XDECREF(obj); in nxt_python_wsgi_init()
488 Py_DECREF(obj); in nxt_python_create_environ()
505 Py_DECREF(obj); in nxt_python_create_environ()
506 obj = NULL; in nxt_python_create_environ()
562 Py_XDECREF(obj); in nxt_python_create_environ()
1131 PyObject *content, *obj; in nxt_py_input_read() local
[all …]
H A Dnxt_python.c73 PyObject *obj; in nxt_python_start() local
157 obj = NULL; in nxt_python_start()
170 obj = NULL; in nxt_python_start()
193 Py_CLEAR(obj); in nxt_python_start()
308 Py_XDECREF(obj); in nxt_python_start()
328 module = obj = NULL; in nxt_python_set_target()
375 obj = NULL; in nxt_python_set_target()
384 Py_XDECREF(obj); in nxt_python_set_target()
629 PyObject *obj; in nxt_python_init_strings() local
652 PyObject *obj; in nxt_python_done_strings() local
[all …]
H A Dnxt_python_asgi.c97 if (PyFunction_Check(obj)) { in nxt_python_asgi_get_func()
98 Py_INCREF(obj); in nxt_python_asgi_get_func()
99 return obj; in nxt_python_asgi_get_func()
102 if (PyMethod_Check(obj)) { in nxt_python_asgi_get_func()
103 obj = PyMethod_GET_FUNCTION(obj); in nxt_python_asgi_get_func()
105 Py_INCREF(obj); in nxt_python_asgi_get_func()
106 return obj; in nxt_python_asgi_get_func()
123 Py_INCREF(obj); in nxt_python_asgi_get_func()
126 obj = NULL; in nxt_python_asgi_get_func()
130 obj = NULL; in nxt_python_asgi_get_func()
[all …]
/unit/src/perl/
H A Dnxt_perl_psgi.c50 static SV *nxt_perl_psgi_call_method(PerlInterpreter *my_perl, SV *obj,
255 SV *obj; in XS() local
295 obj = sv_bless(newRV_noinc((SV *) newHV()), in XS()
297 ST(0) = obj; in XS()
368 nxt_perl_psgi_call_method(PerlInterpreter *my_perl, SV *obj, const char *method, in nxt_perl_psgi_call_method() argument
379 XPUSHs(obj); in nxt_perl_psgi_call_method()
/unit/test/
H A Dtest_python_application.py655 obj = self.getjson()['body']
657 assert obj['GID'] == group_id, 'nobody gid'
661 obj = self.getjson()['body']
667 obj = self.getjson()['body']
668 assert obj['UID'] == nobody_uid, (
676 obj = self.getjson()['body']
683 obj = self.getjson()['body']
684 assert obj['UID'] == 0, 'root uid user=root'
685 assert obj['GID'] == 0, 'root gid user=root'
698 obj = self.getjson()['body']
[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 …]

1234