Home
last modified time | relevance | path

Searched refs:obj (Results 1 – 25 of 81) sorted by relevance

1234

/unit/test/
H A Dtest_go_isolation.py36 obj = self.getjson()['body']
39 if ns.upper() in obj['NS']:
50 obj = self.getjson()['body']
57 obj = self.getjson()['body']
71 obj = self.getjson()['body']
83 obj = self.getjson()['body']
99 obj = self.getjson()['body']
112 obj = self.getjson()['body']
119 obj = self.getjson()['body']
353 "/ /tmp" not in obj['Mounts'] and "tmpfs" not in obj['Mounts']
[all …]
H A Dtest_go_isolation_rootfs.py27 obj = self.getjson(url='/?file=/go/app')['body']
29 assert obj['FileExists'] == True, 'app relative to rootfs'
31 obj = self.getjson(url='/?file=/bin/sh')['body']
32 assert obj['FileExists'] == False, 'file should not exists'
H A Dtest_python_application.py691 obj = self.getjson()['body']
693 assert obj['GID'] == group_id, 'nobody gid'
697 obj = self.getjson()['body']
703 obj = self.getjson()['body']
704 assert obj['UID'] == nobody_uid, (
712 obj = self.getjson()['body']
719 obj = self.getjson()['body']
720 assert obj['UID'] == 0, 'root uid user=root'
721 assert obj['GID'] == 0, 'root gid user=root'
734 obj = self.getjson()['body']
[all …]
/unit/src/
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_stream_source.c10 static void nxt_stream_source_connected(nxt_task_t *task, void *obj,
12 static void nxt_stream_source_write_ready(nxt_task_t *task, void *obj,
97 c = obj; in nxt_stream_source_connected()
157 c = obj; in nxt_stream_source_write_ready()
174 c = obj; in nxt_stream_source_read_ready()
248 c = obj; in nxt_stream_source_read_done()
348 b = obj; in nxt_stream_source_buf_completion()
406 c = obj; in nxt_stream_source_refused()
423 c = obj; in nxt_stream_source_closed()
453 ev = obj; in nxt_stream_source_error()
[all …]
H A Dnxt_conn_proxy.c150 client = obj; in nxt_conn_proxy_client_buffer_alloc()
210 client = obj; in nxt_conn_proxy_peer_connect()
248 peer = obj; in nxt_conn_proxy_connected()
299 peer = obj; in nxt_conn_proxy_peer_read()
367 peer = obj; in nxt_conn_proxy_peer_read_ready()
558 peer = obj; in nxt_conn_proxy_peer_write_ready()
737 c = obj; in nxt_conn_proxy_error()
752 timer = obj; in nxt_conn_proxy_read_timeout()
795 peer = obj; in nxt_conn_proxy_refused()
896 c = obj; in nxt_conn_proxy_read_error()
[all …]
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()
138 nxt_conn_close_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_timer_handler() argument
143 timer = obj; in nxt_conn_close_timer_handler()
[all …]
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_http_proxy.c203 nxt_http_proxy_header_send(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_send() argument
208 r = obj; in nxt_http_proxy_header_send()
225 nxt_http_proxy_header_sent(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_sent() argument
230 r = obj; in nxt_http_proxy_header_sent()
247 nxt_http_proxy_header_read(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_read() argument
253 r = obj; in nxt_http_proxy_header_read()
293 nxt_http_proxy_send_body(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_send_body() argument
299 r = obj; in nxt_http_proxy_send_body()
346 b = obj; in nxt_http_proxy_buf_mem_completion()
376 nxt_http_proxy_error(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_error() argument
[all …]
H A Dnxt_conn_connect.c14 nxt_conn_sys_socket(nxt_task_t *task, void *obj, void *data) in nxt_conn_sys_socket() argument
19 c = obj; in nxt_conn_sys_socket()
35 nxt_conn_io_connect(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_connect() argument
42 c = obj; in nxt_conn_io_connect()
122 nxt_conn_connect_test(nxt_task_t *task, void *obj, void *data) in nxt_conn_connect_test() argument
127 c = obj; in nxt_conn_connect_test()
149 nxt_conn_connect_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_connect_error() argument
156 c = obj; in nxt_conn_connect_error()
H A Dnxt_http_websocket.c15 static void nxt_http_websocket_client(nxt_task_t *task, void *obj, void *data);
16 static void nxt_http_websocket_error_handler(nxt_task_t *task, void *obj,
29 nxt_http_websocket_client(nxt_task_t *task, void *obj, void *data) in nxt_http_websocket_client() argument
39 r = obj; in nxt_http_websocket_client()
127 nxt_http_websocket_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_http_websocket_error_handler() argument
134 r = obj; in nxt_http_websocket_error_handler()
154 nxt_http_request_close_handler(task, obj, data); in nxt_http_websocket_error_handler()
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);
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()
1854 c = obj; in nxt_h1p_idle_close()
[all …]
H A Dnxt_buf.c10 static void nxt_buf_completion(nxt_task_t *task, void *obj, void *data);
11 static void nxt_buf_ts_completion(nxt_task_t *task, void *obj, void *data);
88 ts->work.obj = b; in nxt_buf_mem_ts_alloc()
198 nxt_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_completion() argument
203 b = obj; in nxt_buf_completion()
241 nxt_buf_ts_handle(nxt_task_t *task, void *obj, void *data) in nxt_buf_ts_handle() argument
246 b = obj; in nxt_buf_ts_handle()
258 ts->work.obj = obj; in nxt_buf_ts_handle()
271 nxt_buf_ts_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_ts_completion() argument
276 b = obj; in nxt_buf_ts_completion()
[all …]
H A Dnxt_stream_module.c13 static void nxt_stream_connection_close(nxt_task_t *task, void *obj,
18 nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data) in nxt_stream_connection_init() argument
24 c = obj; in nxt_stream_connection_init()
122 nxt_stream_connection_close(nxt_task_t *task, void *obj, void *data) in nxt_stream_connection_close() argument
126 p = obj; in nxt_stream_connection_close()
H A Dnxt_conn_accept.c23 static void nxt_conn_listen_handler(nxt_task_t *task, void *obj,
29 static void nxt_conn_accept_close_idle_handler(nxt_task_t *task, void *obj,
31 static void nxt_conn_listen_event_error(nxt_task_t *task, void *obj,
33 static void nxt_conn_listen_timer_handler(nxt_task_t *task, void *obj,
124 nxt_conn_listen_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_listen_handler() argument
128 lev = obj; in nxt_conn_listen_handler()
136 nxt_conn_io_accept(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_accept() argument
144 lev = obj; in nxt_conn_io_accept()
358 timer = obj; in nxt_conn_listen_timer_handler()
374 nxt_conn_listen_event_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_listen_event_error() argument
[all …]
H A Dnxt_event_engine.c29 static void nxt_event_engine_signal_pipe(nxt_task_t *task, void *obj,
31 static void nxt_event_engine_post_handler(nxt_task_t *task, void *obj,
38 nxt_task_t **task, void **obj, void **data);
242 pipe = obj; in nxt_event_engine_signal_pipe_close()
297 ev = obj; in nxt_event_engine_signal_pipe()
366 signo = (uintptr_t) obj; in nxt_event_engine_signal_handler()
467 void **obj, void **data) in nxt_event_engine_queue_pop() argument
504 return nxt_work_queue_pop(wq, task, obj, data); in nxt_event_engine_queue_pop()
511 void *obj, *data; in nxt_event_engine_start() local
542 handler(task, obj, data); in nxt_event_engine_start()
[all …]
H A Dnxt_event_conn_job_sendfile.c19 static void nxt_event_conn_job_sendfile_start(nxt_task_t *task, void *obj,
21 static void nxt_event_conn_job_sendfile_handler(nxt_task_t *task, void *obj,
23 static void nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj,
40 nxt_event_conn_job_sendfile_start(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_start() argument
47 c = obj; in nxt_event_conn_job_sendfile_start()
96 nxt_event_conn_job_sendfile_handler(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_handler() argument
104 jbs = obj; in nxt_event_conn_job_sendfile_handler()
163 nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_return() argument
171 jbs = obj; in nxt_event_conn_job_sendfile_return()
H A Dnxt_job.c10 static void nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data);
11 static void nxt_job_thread_return_handler(nxt_task_t *task, void *obj,
135 nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_trampoline() argument
140 job = obj; in nxt_job_thread_trampoline()
181 nxt_job_thread_return_handler(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_return_handler() argument
186 job = obj; in nxt_job_thread_return_handler()
/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/python/
H A Dnxt_python.c158 obj = NULL; in nxt_python_start()
171 obj = NULL; in nxt_python_start()
194 Py_CLEAR(obj); in nxt_python_start()
309 Py_XDECREF(obj); in nxt_python_start()
330 module = obj = NULL; in nxt_python_set_target()
376 target->application = obj; in nxt_python_set_target()
377 obj = NULL; in nxt_python_set_target()
386 Py_XDECREF(obj); in nxt_python_set_target()
631 PyObject *obj; in nxt_python_init_strings() local
654 PyObject *obj; in nxt_python_done_strings() local
[all …]
/unit/src/java/nginx/unit/websocket/
H A DWsRemoteEndpointAsync.java70 public Future<Void> sendObject(Object obj) { in sendObject() argument
71 return base.sendObjectByFuture(obj); in sendObject()
76 public void sendObject(Object obj, SendHandler completion) { in sendObject() argument
77 base.sendObjectByCompletion(obj, completion); in sendObject()
H A DWsRemoteEndpointImplBase.java472 if (obj instanceof Long) { in getBlockingSendTimeout()
473 userTimeout = (Long) obj; in getBlockingSendTimeout()
533 if (obj == null) { in sendObject()
541 Encoder encoder = findEncoder(obj); in sendObject()
543 String msg = obj.toString(); in sendObject()
568 throw new EncodeException(obj, sm.getString( in sendObject()
576 sendObjectByCompletion(obj, f2sh); in sendObjectByFuture()
584 if (obj == null) { in sendObjectByCompletion()
596 Encoder encoder = findEncoder(obj); in sendObjectByCompletion()
598 String msg = obj.toString(); in sendObjectByCompletion()
[all …]
/unit/src/java/nginx/unit/websocket/server/
H A DWsContextListener.java46 Object obj = sc.getAttribute(Constants.SERVER_CONTAINER_SERVLET_CONTEXT_ATTRIBUTE); in contextDestroyed() local
47 if (obj instanceof WsServerContainer) { in contextDestroyed()
48 ((WsServerContainer) obj).destroy(); in contextDestroyed()
/unit/src/nodejs/unit-http/
H A Dnxt_napi.h254 get_element(napi_value obj, uint32_t i) in get_element()
259 status = napi_get_element(env_, obj, i, &res); in get_element()
269 get_named_property(napi_value obj, const char *name) in get_named_property()
344 get_request_info(napi_value obj) in get_request_info()
346 return (nxt_unit_request_info_t *) unwrap(obj); in get_request_info()
351 get_value_bool(napi_value obj) in get_value_bool()
356 status = napi_get_value_bool(env_, obj, &res); in get_value_bool()
381 get_value_uint32(napi_value obj) in get_value_uint32()
555 status = napi_set_element(env_, obj, i, val); in set_element()
589 set_named_property(obj, name, str); in set_named_property()
[all …]

1234