/unit/src/ruby/ |
H A D | nxt_ruby_stream_io.c | 92 nxt_ruby_stream_io_gets(VALUE obj) in nxt_ruby_stream_io_gets() 126 nxt_ruby_stream_io_each(VALUE obj) in nxt_ruby_stream_io_each() 149 nxt_ruby_stream_io_read(VALUE obj, VALUE args) in nxt_ruby_stream_io_read() 196 nxt_ruby_stream_io_rewind(VALUE obj) in nxt_ruby_stream_io_rewind() 203 nxt_ruby_stream_io_puts(VALUE obj, VALUE args) in nxt_ruby_stream_io_puts() 220 nxt_ruby_stream_io_write(VALUE obj, VALUE args) in nxt_ruby_stream_io_write() 259 nxt_ruby_stream_io_flush(VALUE obj) in nxt_ruby_stream_io_flush() 266 nxt_ruby_stream_io_close(VALUE obj) in nxt_ruby_stream_io_close()
|
/unit/src/ |
H A D | nxt_signal_handlers.c | 32 nxt_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_handler() 47 nxt_signal_sigterm_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_sigterm_handler() 59 nxt_signal_sigquit_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_sigquit_handler()
|
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_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() 142 nxt_conn_close_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_timer_handler() 171 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_h1proto.c | 212 nxt_http_conn_init(nxt_task_t *task, void *obj, void *data) in nxt_http_conn_init() 309 nxt_http_conn_test(nxt_task_t *task, void *obj, void *data) in nxt_http_conn_test() 1724 nxt_h1p_conn_sent(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_sent() 1744 nxt_h1p_conn_close(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_close() 1759 nxt_h1p_conn_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_error() 1861 nxt_h1p_idle_close(nxt_task_t *task, void *obj, void *data) in nxt_h1p_idle_close() 1876 nxt_h1p_idle_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_idle_timeout() 2115 nxt_h1p_conn_free(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_free() 2723 nxt_h1p_peer_closed(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_closed() 2750 nxt_h1p_peer_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_error() [all …]
|
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() 272 nxt_conn_accept_close_idle_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_accept_close_idle_handler() 357 nxt_conn_listen_timer_handler(nxt_task_t *task, void *obj, void *data) 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()
|
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_http_websocket.c | 29 nxt_http_websocket_client(nxt_task_t *task, void *obj, void *data) 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()
|
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_http_proxy.c | 203 nxt_http_proxy_header_send(nxt_task_t *task, void *obj, void *data) 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() 247 nxt_http_proxy_header_read(nxt_task_t *task, void *obj, void *data) 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() 340 nxt_http_proxy_buf_mem_completion(nxt_task_t *task, void *obj, void *data) 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()
|
H A D | nxt_kqueue_engine.c | 525 nxt_kqueue_fd_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_fd_error_handler() 549 nxt_kqueue_file_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_file_error_handler() 666 void *obj, *data; in nxt_kqueue_poll() local 852 nxt_kqueue_conn_io_connect(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_conn_io_connect() 894 nxt_kqueue_conn_connected(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_conn_connected() 914 nxt_kqueue_listen_handler(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_listen_handler() 930 nxt_kqueue_conn_io_accept(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_conn_io_accept() 974 nxt_kqueue_conn_io_read(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_conn_io_read()
|
H A D | nxt_h1proto_websocket.c | 161 nxt_h1p_conn_ws_keepalive(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_keepalive() 217 nxt_h1p_conn_ws_frame_header_read(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_frame_header_read() 442 nxt_h1p_conn_ws_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_error() 496 nxt_h1p_conn_ws_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_timeout() 542 nxt_h1p_conn_ws_frame_payload_read(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_frame_payload_read() 633 nxt_h1p_conn_ws_error_sent(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_error_sent() 646 nxt_h1p_conn_ws_pong(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_pong()
|
H A D | nxt_work_queue.c | 161 nxt_task_t *task, void *obj, void *data) 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() 251 void **obj, void **data) in nxt_locked_work_queue_pop()
|
H A D | nxt_job.c | 137 nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data) 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()
|
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_http_error.c | 78 nxt_http_request_send_error_body(nxt_task_t *task, void *obj, void *data) in nxt_http_request_send_error_body()
|
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_log_moderation.c | 74 nxt_log_moderate_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_log_moderate_timer_handler()
|
H A D | nxt_thread_pool.c | 133 void *obj, *data; in nxt_thread_pool_loop() local 267 nxt_thread_pool_exit(nxt_task_t *task, void *obj, void *data) in nxt_thread_pool_exit()
|
H A D | nxt_http_return.c | 177 nxt_http_return_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_return_send_ready() 220 nxt_http_return_send_error(nxt_task_t *task, void *obj, void *data) in nxt_http_return_send_error()
|
/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()
|
/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/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/python/ |
H A D | nxt_python.c | 152 PyObject *obj; in nxt_python_start() local 404 PyObject *module, *obj; in nxt_python_set_target() local 760 PyObject *obj; in nxt_python_init_strings() local 783 PyObject *obj; in nxt_python_done_strings() local
|