/unit/src/ |
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() 783 nxt_conn_proxy_timeout_value(nxt_conn_t *c, uintptr_t data) in nxt_conn_proxy_timeout_value() 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_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_stream_source.c | 92 nxt_stream_source_connected(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_connected() 153 nxt_stream_source_write_ready(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_write_ready() 166 nxt_stream_source_read_ready(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_read_ready() 241 nxt_stream_source_read_done(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_read_done() 342 nxt_stream_source_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_buf_completion() 396 nxt_stream_source_refused(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_refused() 417 nxt_stream_source_closed(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_closed() 443 nxt_stream_source_error(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_error() 473 nxt_source_filter_handler(nxt_task_t *task, void *obj, void *data) in nxt_source_filter_handler()
|
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_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() 1198 nxt_work_handler_t body_handler, void *data) in nxt_h1p_request_header_send() 1714 nxt_h1p_conn_sent(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_sent() 1734 nxt_h1p_conn_close(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_close() 1749 nxt_h1p_conn_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_error() 1764 nxt_h1p_conn_timer_value(nxt_conn_t *c, uintptr_t data) in nxt_h1p_conn_timer_value() 2104 nxt_h1p_conn_free(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_free() 2804 nxt_h1p_peer_timer_value(nxt_conn_t *c, uintptr_t data) in nxt_h1p_peer_timer_value() 2848 nxt_h1p_peer_free(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_free() [all …]
|
H A D | nxt_djb_hash.c | 11 nxt_djb_hash(const void *data, size_t len) in nxt_djb_hash() 29 nxt_djb_hash_lowcase(const void *data, size_t len) in nxt_djb_hash_lowcase()
|
H A D | nxt_websocket.c | 55 nxt_websocket_frame_header_size(const void *data) in nxt_websocket_frame_header_size() 81 nxt_websocket_frame_payload_len(const void *data) in nxt_websocket_frame_payload_len() 100 nxt_websocket_frame_init(void *data, uint64_t payload_len) in nxt_websocket_frame_init()
|
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_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() 393 nxt_http_proxy_date(void *ctx, nxt_http_field_t *field, uintptr_t data) in nxt_http_proxy_date() 407 uintptr_t data) in nxt_http_proxy_content_length() 427 nxt_http_proxy_skip(void *ctx, nxt_http_field_t *field, uintptr_t data) in nxt_http_proxy_skip()
|
H A D | nxt_murmur_hash.c | 11 nxt_murmur_hash2(const void *data, size_t len) in nxt_murmur_hash2() 60 nxt_murmur_hash2_uint32(const void *data) in nxt_murmur_hash2_uint32()
|
H A D | nxt_queue.c | 54 nxt_int_t (*cmp)(const void *data, const nxt_queue_link_t *, in nxt_queue_sort()
|
H A D | nxt_conf_validation.c | 480 void *data) in nxt_conf_vldt_tls_timeout() 500 void *data) in nxt_conf_vldt_ticket_key() 1301 void *data) in nxt_conf_vldt_unsupported() 1332 void *data) in nxt_conf_vldt_mtypes() 1450 void *data) in nxt_conf_vldt_action() 1497 void *data) in nxt_conf_vldt_pass() 1616 void *data) in nxt_conf_vldt_return() 1633 void *data) in nxt_conf_vldt_share() 1697 void *data) in nxt_conf_vldt_proxy() 1721 void *data) in nxt_conf_vldt_python() [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() 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_job.c | 60 nxt_job_destroy(nxt_task_t *task, void *data) in nxt_job_destroy() 135 nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_trampoline() 181 nxt_job_thread_return_handler(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_return_handler()
|
H A D | nxt_thread.c | 70 nxt_thread_key_dtor(void *data) in nxt_thread_key_dtor() 102 nxt_thread_trampoline(void *data) in nxt_thread_trampoline() 170 nxt_thread_time_cleanup(void *data) in nxt_thread_time_cleanup()
|
H A D | nxt_stream_module.c | 18 nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data) in nxt_stream_connection_init() 122 nxt_stream_connection_close(nxt_task_t *task, void *obj, void *data) in nxt_stream_connection_close()
|
H A D | nxt_http_response.c | 46 uintptr_t data) in nxt_http_response_status() 69 nxt_http_response_skip(void *ctx, nxt_http_field_t *field, uintptr_t data) in nxt_http_response_skip()
|
H A D | nxt_controller.c | 288 nxt_controller_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_controller_start() 505 void *data) in nxt_controller_conf_init_handler() 556 nxt_port_rpc_handler_t handler, void *data) in nxt_controller_conf_send() 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() 812 nxt_controller_conn_timeout_value(nxt_conn_t *c, uintptr_t data) in nxt_controller_conn_timeout_value() 981 nxt_controller_conn_free(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_free() 997 uintptr_t data) in nxt_controller_request_content_length() 1637 void *data) in nxt_controller_process_cert_save() 1715 void *data) in nxt_controller_conf_handler() [all …]
|
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_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()
|
/unit/src/java/ |
H A D | nxt_jni_OutputStream.c | 86 nxt_java_request_data_t *data; in nxt_java_OutputStream_writeByte() local 108 nxt_java_request_data_t *data; in nxt_java_OutputStream_flush_buf() local 152 nxt_java_request_data_t *data; in nxt_java_OutputStream_req_buf() local 183 nxt_java_request_data_t *data; in nxt_java_OutputStream_write() local 221 nxt_java_request_data_t *data; in nxt_java_OutputStream_flush() local
|
/unit/src/java/javax/websocket/ |
H A D | RemoteEndpoint.java | 73 Future<Void> sendBinary(ByteBuffer data); in sendBinary() 84 void sendBinary(ByteBuffer data, SendHandler completion); in sendBinary() 126 void sendBinary(ByteBuffer data) throws IOException; in sendBinary() 170 void sendObject(Object data) throws IOException, EncodeException; in sendObject()
|
/unit/src/test/ |
H A D | nxt_unit_websocket_chat.c | 53 ws_chat_request_data_t *data; in ws_chat_request_handler() local 144 ws_chat_request_data_t *data; in ws_chat_broadcast() local 165 ws_chat_request_data_t *data; in ws_chat_websocket_handler() local 190 ws_chat_request_data_t *data; in ws_chat_close_handler() local
|
/unit/src/java/nginx/unit/websocket/ |
H A D | WsRemoteEndpointAsync.java | 58 public Future<Void> sendBinary(ByteBuffer data) { in sendBinary() 64 public void sendBinary(ByteBuffer data, SendHandler completion) { in sendBinary()
|