| /unit/src/java/javax/websocket/ |
| H A D | RemoteEndpoint.java | 93 Future<Void> sendObject(Object obj); in sendObject()
104 void sendObject(Object obj, SendHandler completion); in sendObject()
|
| /unit/src/java/nginx/unit/websocket/ |
| H A D | WsRemoteEndpointAsync.java | 70 public Future<Void> sendObject(Object obj) { in sendObject()
76 public void sendObject(Object obj, SendHandler completion) { in sendObject()
|
| H A D | WsRemoteEndpointImplBase.java | 470 Object obj = wsSession.getUserProperties().get(Constants.BLOCKING_SEND_TIMEOUT_PROPERTY); in getBlockingSendTimeout() local
532 public void sendObject(Object obj) throws IOException, EncodeException { in sendObject()
574 public Future<Void> sendObjectByFuture(Object obj) { in sendObjectByFuture()
582 public void sendObjectByCompletion(Object obj, SendHandler completion) { in sendObjectByCompletion()
666 private Encoder findEncoder(Object obj) { in findEncoder()
|
| /unit/src/java/nginx/unit/websocket/server/ |
| H A D | WsContextListener.java | 46 Object obj = sc.getAttribute(Constants.SERVER_CONTAINER_SERVLET_CONTEXT_ATTRIBUTE); in contextDestroyed() local
|
| /unit/src/nodejs/unit-http/ |
| H A D | http_server.js | 171 function writeHead(statusCode, reason, obj) { argument
|
| H A D | unit.cpp | 207 Unit *obj = reinterpret_cast<Unit *>(nativeObject); in destroy() local
249 Unit *obj; in create_server() local
304 Unit *obj; in request_handler_cb() local
347 Unit *obj; in websocket_handler_cb() local
390 Unit *obj; in close_handler_cb() local
439 Unit *obj; in shm_ack_handler_cb() local
474 Unit *obj; in add_port() local
537 Unit *obj; in quit_cb() local
|
| H A D | websocket_request.js | 195 var obj = { class in AnonymousFunctiondeff99b60300
201 var obj = { class in AnonymousFunctiondeff99b60200
|
| /unit/src/ |
| H A D | nxt_application.c | 479 nxt_discovery_completion_handler(nxt_task_t *task, void *obj, void *data) in nxt_discovery_completion_handler()
727 nxt_proto_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_proto_signal_handler()
735 nxt_proto_sigterm_handler(nxt_task_t *task, void *obj, void *data) in nxt_proto_sigterm_handler()
751 nxt_proto_sigchld_handler(nxt_task_t *task, void *obj, void *data) in nxt_proto_sigchld_handler()
|
| H A D | nxt_buf.c | 198 nxt_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_completion()
241 nxt_buf_ts_handle(nxt_task_t *task, void *obj, void *data) in nxt_buf_ts_handle()
271 nxt_buf_ts_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_ts_completion()
|
| H A D | nxt_buf.h | 264 nxt_buf_dummy_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_dummy_completion()
|
| H A D | nxt_buf_filter.c | 33 nxt_buf_filter(nxt_task_t *task, void *obj, void *data) 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()
400 nxt_buf_filter_buf_completion(nxt_task_t *task, void *obj, void *data) 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()
|
| H A D | nxt_cache.c | 343 nxt_cache_wait_handler(nxt_thread_t *thr, void *obj, void *data) in nxt_cache_wait_handler()
365 nxt_cache_timeout_handler(nxt_thread_t *thr, void *obj, void *data) in nxt_cache_timeout_handler()
379 nxt_cache_wake_handler(nxt_thread_t *thr, void *obj, void *data) in nxt_cache_wake_handler()
|
| H A D | nxt_cert.c | 1109 nxt_cert_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_cert_buf_completion()
|
| H A D | nxt_conn_accept.c | 124 nxt_conn_listen_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_listen_handler()
136 nxt_conn_io_accept(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_accept()
267 nxt_conn_accept_close_idle_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_accept_close_idle_handler()
352 nxt_conn_listen_timer_handler(nxt_task_t *task, void *obj, void *data) 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()
|
| H A D | nxt_conn_close.c | 75 nxt_conn_shutdown_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_shutdown_handler()
95 nxt_conn_close_handler(nxt_task_t *task, void *obj, void *data) 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()
161 nxt_conn_close_error_ignore(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_error_ignore()
|
| H A D | nxt_conn_connect.c | 14 nxt_conn_sys_socket(nxt_task_t *task, void *obj, void *data) in nxt_conn_sys_socket()
35 nxt_conn_io_connect(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_connect()
122 nxt_conn_connect_test(nxt_task_t *task, void *obj, void *data) in nxt_conn_connect_test()
149 nxt_conn_connect_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_connect_error()
|
| H A D | nxt_conn_proxy.c | 205 nxt_conn_proxy_peer_connect(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_peer_connect()
243 nxt_conn_proxy_connected(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_connected()
293 nxt_conn_proxy_peer_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_peer_read()
491 nxt_conn_proxy_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_read()
702 nxt_conn_proxy_close(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_close()
732 nxt_conn_proxy_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_error()
747 nxt_conn_proxy_read_timeout(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_read_timeout()
790 nxt_conn_proxy_refused(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_refused()
891 nxt_conn_proxy_read_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_read_error()
906 nxt_conn_proxy_write_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_write_error()
[all …]
|
| H A D | nxt_conn_read.c | 38 nxt_conn_io_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_read()
|
| H A D | nxt_conn_write.c | 17 nxt_conn_io_write(nxt_task_t *task, void *obj, void *data) 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()
|
| H A D | nxt_controller.c | 268 nxt_controller_cert_cleanup(nxt_task_t *task, void *obj, void *data) in nxt_controller_cert_cleanup()
672 nxt_controller_conn_init(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_init()
733 nxt_controller_conn_read(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_read()
819 nxt_controller_conn_read_error(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_read_error()
832 nxt_controller_conn_read_timeout(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_read_timeout()
864 nxt_controller_conn_body_read(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_body_read()
903 nxt_controller_conn_write(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_write()
926 nxt_controller_conn_write_error(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_write_error()
939 nxt_controller_conn_write_timeout(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_write_timeout()
964 nxt_controller_conn_close(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_close()
[all …]
|
| H A D | nxt_cyassl.c | 295 nxt_cyassl_conn_handshake(nxt_thread_t *thr, void *obj, void *data) 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()
450 nxt_cyassl_conn_io_shutdown(nxt_thread_t *thr, void *obj, void *data) in nxt_cyassl_conn_io_shutdown()
|
| H A D | nxt_epoll_engine.c | 650 nxt_epoll_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_error_handler()
722 nxt_epoll_signalfd_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_signalfd_handler()
809 nxt_epoll_eventfd_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_eventfd_handler()
1008 nxt_epoll_conn_io_accept4(nxt_task_t *task, void *obj, void *data) in nxt_epoll_conn_io_accept4()
1058 nxt_epoll_edge_conn_io_connect(nxt_task_t *task, void *obj, void *data) in nxt_epoll_edge_conn_io_connect()
1130 nxt_epoll_edge_conn_connected(nxt_task_t *task, void *obj, void *data) in nxt_epoll_edge_conn_connected()
|
| H A D | nxt_event_conn_job_sendfile.c | 40 nxt_event_conn_job_sendfile_start(nxt_task_t *task, void *obj, void *data) 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()
163 nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_return()
|
| H A D | nxt_event_engine.c | 238 nxt_event_engine_signal_pipe_close(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_pipe_close()
289 nxt_event_engine_signal_pipe(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_pipe()
330 nxt_event_engine_post_handler(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_post_handler()
344 nxt_event_engine_signal_pipe_error(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_pipe_error()
361 nxt_event_engine_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_handler()
467 void **obj, void **data) in nxt_event_engine_queue_pop()
511 void *obj, *data; in nxt_event_engine_start() local
721 nxt_event_engine_buf_mem_completion(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_buf_mem_completion()
|
| H A D | nxt_eventport_engine.c | 363 nxt_eventport_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_eventport_error_handler()
|