Home
last modified time | relevance | path

Searched refs:obj (Results 1 – 25 of 77) 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'], 'app relative to rootfs'
31 obj = self.getjson(url='/?file=/bin/sh')['body']
32 assert not obj['FileExists'], 'file should not exists'
H A Dtest_python_application.py759 obj = self.getjson()['body']
760 assert obj['UID'] == nobody_uid, 'nobody uid'
761 assert obj['GID'] == group_id, 'nobody gid'
765 obj = self.getjson()['body']
771 obj = self.getjson()['body']
777 obj = self.getjson()['body']
783 obj = self.getjson()['body']
784 assert obj['UID'] == 0, 'root uid user=root'
785 assert obj['GID'] == 0, 'root gid user=root'
798 obj = self.getjson()['body']
[all …]
/unit/src/
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_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_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()
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 …]
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_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_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()
363 timer = obj; in nxt_conn_listen_timer_handler()
379 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_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()
555 c = obj; in nxt_h1p_conn_request_header_parse()
1035 c = obj; in nxt_h1p_conn_request_body_read()
1729 c = obj; in nxt_h1p_conn_sent()
1748 c = obj; in nxt_h1p_conn_close()
1763 c = obj; in nxt_h1p_conn_error()
1865 c = obj; in nxt_h1p_idle_close()
[all …]
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,
137 nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_trampoline() argument
142 job = obj; in nxt_job_thread_trampoline()
183 nxt_job_thread_return_handler(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_return_handler() argument
188 job = obj; in nxt_job_thread_return_handler()
H A Dnxt_kqueue_engine.c529 ev = obj; in nxt_kqueue_fd_error_handler()
553 ev = obj; in nxt_kqueue_file_error_handler()
745 ev = obj; in nxt_kqueue_poll()
777 ev = obj; in nxt_kqueue_poll()
808 fev = obj; in nxt_kqueue_poll()
815 sigev = obj; in nxt_kqueue_poll()
859 c = obj; in nxt_kqueue_conn_io_connect()
898 c = obj; in nxt_kqueue_conn_connected()
918 lev = obj; in nxt_kqueue_listen_handler()
938 lev = obj; in nxt_kqueue_conn_io_accept()
[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/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 …]
/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