/unit/src/ |
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 …]
|
H A D | nxt_router.c | 1187 tmcf = obj; in nxt_router_conf_apply() 1301 job = obj; in nxt_router_conf_wait() 3675 job = obj; in nxt_router_listen_socket_create() 3737 job = obj; in nxt_router_listen_socket_update() 3819 timer = obj; in nxt_router_listen_socket_close() 4379 r = obj; in nxt_http_request_send_body() 4887 app = obj; in nxt_router_adjust_idle_timer() 4975 timer = obj; in nxt_router_app_idle_timeout() 4990 timer = obj; in nxt_router_app_joint_release_handler() 5203 r = obj; in nxt_router_http_request_error() [all …]
|
H A D | nxt_router.h | 253 void nxt_router_conf_apply(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_runtime.c | 22 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() 730 nxt_runtime_thread_pool_exit(nxt_task_t *task, void *obj, void *data) in nxt_runtime_thread_pool_exit() argument 737 tp = obj; in nxt_runtime_thread_pool_exit()
|
H A D | nxt_runtime.h | 143 void nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data);
|
H A D | nxt_script.c | 34 static void nxt_script_buf_completion(nxt_task_t *task, void *obj, void *data); 526 nxt_script_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_script_buf_completion() argument 531 b = obj; in nxt_script_buf_completion()
|
H A D | nxt_select_engine.c | 21 static void nxt_select_error_handler(nxt_task_t *task, void *obj, void *data); 182 nxt_select_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_select_error_handler() argument 186 ev = obj; in nxt_select_error_handler()
|
H A D | nxt_signal_handlers.c | 14 static void nxt_signal_handler(nxt_task_t *task, void *obj, void *data); 15 static void nxt_signal_sigterm_handler(nxt_task_t *task, void *obj, void *data); 16 static void nxt_signal_sigquit_handler(nxt_task_t *task, void *obj, void *data); 32 nxt_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_handler() argument 35 (int) (uintptr_t) obj, data); in nxt_signal_handler() 47 nxt_signal_sigterm_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_sigterm_handler() argument 50 (int) (uintptr_t) obj, data); in nxt_signal_sigterm_handler() 59 nxt_signal_sigquit_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_sigquit_handler() argument 62 (int) (uintptr_t) obj, data); in nxt_signal_sigquit_handler()
|
H A D | nxt_source.h | 38 NXT_EXPORT void nxt_source_filter_handler(nxt_task_t *task, void *obj,
|
H A D | nxt_status.c | 18 nxt_conf_value_t *status, *obj, *apps, *app_obj; in nxt_status_get() local 37 obj = nxt_conf_create_object(mp, 4); in nxt_status_get() 38 if (nxt_slow_path(obj == NULL)) { in nxt_status_get() 42 nxt_conf_set_member(status, &conns_str, obj, 0); in nxt_status_get() 51 obj = nxt_conf_create_object(mp, 1); in nxt_status_get() 52 if (nxt_slow_path(obj == NULL)) { in nxt_status_get() 56 nxt_conf_set_member(status, &reqs_str, obj, 1); in nxt_status_get() 83 obj = nxt_conf_create_object(mp, 3); in nxt_status_get() 84 if (nxt_slow_path(obj == NULL)) { in nxt_status_get() 94 obj = nxt_conf_create_object(mp, 1); in nxt_status_get() [all …]
|
H A D | nxt_thread.c | 199 link->work.obj = (void *) (uintptr_t) thr->handle; in nxt_thread_exit()
|
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_timer.c | 27 static void nxt_timer_handler(nxt_task_t *task, void *obj, void *data); 331 nxt_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_timer_handler() argument 335 timer = obj; in nxt_timer_handler()
|
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_work_queue.c | 161 nxt_task_t *task, void *obj, void *data) in nxt_work_queue_add() argument 176 work->obj = obj; in nxt_work_queue_add() 197 nxt_work_queue_pop(nxt_work_queue_t *wq, nxt_task_t **task, void **obj, in nxt_work_queue_pop() argument 214 *obj = work->obj; in nxt_work_queue_pop() 215 nxt_prefetch(*obj); in nxt_work_queue_pop() 251 void **obj, void **data) in nxt_locked_work_queue_pop() argument 265 *obj = work->obj; in nxt_locked_work_queue_pop() 266 nxt_prefetch(*obj); in nxt_locked_work_queue_pop() 307 work->obj, work->data); in nxt_locked_work_queue_move()
|
H A D | nxt_work_queue.h | 42 void *obj; member 90 nxt_work_handler_t handler, nxt_task_t *task, void *obj, void *data); 92 nxt_task_t **task, void **obj, void **data); 101 work->obj = _obj; \ 122 nxt_locked_work_queue_t *lwq, nxt_task_t **task, void **obj, void **data);
|
/unit/src/perl/ |
H A D | nxt_perl_psgi.c | 50 static SV *nxt_perl_psgi_call_method(PerlInterpreter *my_perl, SV *obj, 255 SV *obj; in XS() local 296 obj = sv_bless(newRV_noinc((SV *) newHV()), in XS() 298 ST(0) = obj; in XS() 369 nxt_perl_psgi_call_method(PerlInterpreter *my_perl, SV *obj, const char *method, in nxt_perl_psgi_call_method() argument 380 XPUSHs(obj); in nxt_perl_psgi_call_method()
|
/unit/src/python/ |
H A D | nxt_python.c | 152 PyObject *obj; in nxt_python_start() local 240 obj = NULL; in nxt_python_start() 253 obj = NULL; in nxt_python_start() 276 Py_CLEAR(obj); in nxt_python_start() 391 Py_XDECREF(obj); in nxt_python_start() 412 module = obj = NULL; in nxt_python_set_target() 464 obj = NULL; in nxt_python_set_target() 473 Py_XDECREF(obj); in nxt_python_set_target() 760 PyObject *obj; in nxt_python_init_strings() local 783 PyObject *obj; in nxt_python_done_strings() local [all …]
|
H A D | nxt_python.h | 80 int nxt_python_asgi_check(PyObject *obj);
|
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/ruby/ |
H A D | nxt_ruby_stream_io.c | 13 static VALUE nxt_ruby_stream_io_gets(VALUE obj); 14 static VALUE nxt_ruby_stream_io_each(VALUE obj); 16 static VALUE nxt_ruby_stream_io_rewind(VALUE obj); 20 static VALUE nxt_ruby_stream_io_flush(VALUE obj); 21 static VALUE nxt_ruby_stream_io_close(VALUE obj); 92 nxt_ruby_stream_io_gets(VALUE obj) in nxt_ruby_stream_io_gets() argument 126 nxt_ruby_stream_io_each(VALUE obj) in nxt_ruby_stream_io_each() argument 135 chunk = nxt_ruby_stream_io_gets(obj); in nxt_ruby_stream_io_each() 196 nxt_ruby_stream_io_rewind(VALUE obj) in nxt_ruby_stream_io_rewind() argument 259 nxt_ruby_stream_io_flush(VALUE obj) in nxt_ruby_stream_io_flush() argument [all …]
|
/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()
|
/unit/test/ |
H A D | test_go_isolation.py | 32 obj = client.getjson()['body'] 35 if ns.upper() in obj['NS']: 48 obj = client.getjson()['body'] 55 obj = client.getjson()['body'] 69 obj = client.getjson()['body'] 81 obj = client.getjson()['body'] 97 obj = client.getjson()['body'] 110 obj = client.getjson()['body'] 117 obj = client.getjson()['body'] 357 "/ /tmp" not in obj['Mounts'] and "tmpfs" not in obj['Mounts'] [all …]
|