Home
last modified time | relevance | path

Searched refs:obj (Results 51 – 75 of 77) sorted by path

1234

/unit/src/
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 …]
H A Dnxt_router.c1187 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 Dnxt_router.h253 void nxt_router_conf_apply(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_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()
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 Dnxt_runtime.h143 void nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data);
H A Dnxt_script.c34 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 Dnxt_select_engine.c21 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 Dnxt_signal_handlers.c14 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 Dnxt_source.h38 NXT_EXPORT void nxt_source_filter_handler(nxt_task_t *task, void *obj,
H A Dnxt_status.c18 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 Dnxt_thread.c199 link->work.obj = (void *) (uintptr_t) thr->handle; in nxt_thread_exit()
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_timer.c27 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 Dnxt_timer.h76 #define nxt_timer_data(obj, type, timer) \ argument
77 nxt_container_of(obj, type, timer)
H A Dnxt_work_queue.c161 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 Dnxt_work_queue.h42 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 Dnxt_perl_psgi.c50 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 Dnxt_python.c152 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 Dnxt_python.h80 int nxt_python_asgi_check(PyObject *obj);
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/ruby/
H A Dnxt_ruby_stream_io.c13 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 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()
/unit/test/
H A Dtest_go_isolation.py32 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 …]

1234