Home
last modified time | relevance | path

Searched refs:obj (Results 1 – 25 of 77) sorted by path

1234

/unit/src/java/javax/websocket/
H A DRemoteEndpoint.java93 Future<Void> sendObject(Object obj); in sendObject() argument
104 void sendObject(Object obj, SendHandler completion); in sendObject() argument
/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 Dhttp_server.js184 function writeHead(statusCode, reason, obj) { argument
201 obj = reason;
206 if (obj) {
208 var keys = Object.keys(obj);
214 this.setHeader(k, obj[k]);
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 …]
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 …]
H A Dwebsocket_request.js195 var obj = { class in AnonymousFunctiondeff99b60300
199 array.splice(index, 1, obj);
201 var obj = { class in AnonymousFunctiondeff99b60200
205 array.splice(index, 1, obj);
/unit/src/
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_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_buf.h224 NXT_EXPORT nxt_int_t nxt_buf_ts_handle(nxt_task_t *task, void *obj, void *data);
264 nxt_buf_dummy_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_dummy_completion() argument
H A Dnxt_cert.c51 static void nxt_cert_buf_completion(nxt_task_t *task, void *obj, void *data);
1109 nxt_cert_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_cert_buf_completion() argument
1114 b = obj; in nxt_cert_buf_completion()
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_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_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_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_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_read.c38 nxt_conn_io_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_read() argument
46 c = obj; in nxt_conn_io_read()
H A Dnxt_conn_write.c10 static void nxt_conn_write_timer_handler(nxt_task_t *task, void *obj,
17 nxt_conn_io_write(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_write() argument
25 c = obj; in nxt_conn_io_write()
147 nxt_conn_write_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_write_timer_handler() argument
152 timer = obj; in nxt_conn_write_timer_handler()
H A Dnxt_controller.c299 certs = obj; in nxt_controller_cert_cleanup()
720 c = obj; in nxt_controller_conn_init()
782 c = obj; in nxt_controller_conn_read()
864 c = obj; in nxt_controller_conn_read_error()
878 timer = obj; in nxt_controller_conn_read_timeout()
912 c = obj; in nxt_controller_conn_body_read()
949 c = obj; in nxt_controller_conn_write()
971 c = obj; in nxt_controller_conn_write_error()
985 timer = obj; in nxt_controller_conn_write_timeout()
1009 c = obj; in nxt_controller_conn_close()
[all …]
H A Dnxt_cyassl.c28 static void nxt_cyassl_conn_handshake(nxt_thread_t *thr, void *obj, void *data);
29 static void nxt_cyassl_conn_io_read(nxt_thread_t *thr, void *obj, void *data);
30 static void nxt_cyassl_conn_io_shutdown(nxt_thread_t *thr, void *obj,
295 nxt_cyassl_conn_handshake(nxt_thread_t *thr, void *obj, void *data) in nxt_cyassl_conn_handshake() argument
303 c = obj; in nxt_cyassl_conn_handshake()
339 nxt_cyassl_conn_io_read(nxt_thread_t *thr, void *obj, void *data) in nxt_cyassl_conn_io_read() argument
349 c = obj; in nxt_cyassl_conn_io_read()
450 nxt_cyassl_conn_io_shutdown(nxt_thread_t *thr, void *obj, void *data) in nxt_cyassl_conn_io_shutdown() argument
456 c = obj; in nxt_cyassl_conn_io_shutdown()
H A Dnxt_epoll_engine.c85 static void nxt_epoll_conn_io_accept4(nxt_task_t *task, void *obj,
94 static void nxt_epoll_edge_conn_connected(nxt_task_t *task, void *obj,
650 nxt_epoll_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_error_handler() argument
654 ev = obj; in nxt_epoll_error_handler()
722 nxt_epoll_signalfd_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_signalfd_handler() argument
729 ev = obj; in nxt_epoll_signalfd_handler()
809 nxt_epoll_eventfd_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_eventfd_handler() argument
1008 nxt_epoll_conn_io_accept4(nxt_task_t *task, void *obj, void *data) in nxt_epoll_conn_io_accept4() argument
1016 lev = obj; in nxt_epoll_conn_io_accept4()
1065 c = obj; in nxt_epoll_edge_conn_io_connect()
[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_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_engine.h518 void nxt_event_engine_buf_mem_completion(nxt_task_t *task, void *obj,

1234