Home
last modified time | relevance | path

Searched refs:obj (Results 1 – 25 of 84) 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.js171 function writeHead(statusCode, reason, obj) { argument
188 obj = reason;
193 if (obj) {
195 var keys = Object.keys(obj);
201 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_buf_filter.c15 static void nxt_buf_filter_file_job_completion(nxt_task_t *task, void *obj,
17 static void nxt_buf_filter_buf_completion(nxt_task_t *task, void *obj,
19 static void nxt_buf_filter_file_read_error(nxt_task_t *task, void *obj,
33 nxt_buf_filter(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter() argument
39 f = obj; in nxt_buf_filter()
332 nxt_buf_filter_file_job_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter_file_job_completion() argument
340 jbf = obj; in nxt_buf_filter_file_job_completion()
400 nxt_buf_filter_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter_buf_completion() argument
406 b = obj; in nxt_buf_filter_buf_completion()
441 nxt_buf_filter_file_read_error(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter_file_read_error() argument
H A Dnxt_buf_filter.h111 NXT_EXPORT void nxt_buf_filter(nxt_task_t *task, void *obj, void *data);
H A Dnxt_cache.c23 static void nxt_cache_wait_handler(nxt_thread_t *thr, void *obj, void *data);
24 static void nxt_cache_timeout_handler(nxt_thread_t *thr, void *obj, void *data);
25 static void nxt_cache_wake_handler(nxt_thread_t *thr, void *obj, void *data);
343 nxt_cache_wait_handler(nxt_thread_t *thr, void *obj, void *data) in nxt_cache_wait_handler() argument
348 cq = obj; in nxt_cache_wait_handler()
365 nxt_cache_timeout_handler(nxt_thread_t *thr, void *obj, void *data) in nxt_cache_timeout_handler() argument
370 ev = obj; in nxt_cache_timeout_handler()
379 nxt_cache_wake_handler(nxt_thread_t *thr, void *obj, void *data) in nxt_cache_wake_handler() argument
386 qw = obj; in nxt_cache_wake_handler()
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.c282 certs = obj; in nxt_controller_cert_cleanup()
695 c = obj; in nxt_controller_conn_init()
757 c = obj; in nxt_controller_conn_read()
839 c = obj; in nxt_controller_conn_read_error()
853 timer = obj; in nxt_controller_conn_read_timeout()
887 c = obj; in nxt_controller_conn_body_read()
924 c = obj; in nxt_controller_conn_write()
946 c = obj; in nxt_controller_conn_write_error()
960 timer = obj; in nxt_controller_conn_write_timeout()
984 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 …]

1234