Home
last modified time | relevance | path

Searched defs:data (Results 1 – 25 of 127) sorted by relevance

123456

/unit/src/
H A Dnxt_conn_proxy.c205 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 Dnxt_signal_handlers.c32 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 Dnxt_stream_source.c92 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 Dnxt_conn_close.c75 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 Dnxt_h1proto.c212 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 Dnxt_djb_hash.c11 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 Dnxt_websocket.c55 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 Dnxt_conn_connect.c14 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 Dnxt_http_proxy.c203 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 Dnxt_murmur_hash.c11 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 Dnxt_queue.c54 nxt_int_t (*cmp)(const void *data, const nxt_queue_link_t *, in nxt_queue_sort()
H A Dnxt_conf_validation.c480 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 Dnxt_conn_accept.c124 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 Dnxt_job.c60 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 Dnxt_thread.c70 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 Dnxt_stream_module.c18 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 Dnxt_http_response.c46 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 Dnxt_controller.c288 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 Dnxt_buf_filter.c33 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 Dnxt_event_engine.c238 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 Dnxt_http_websocket.c29 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 Dnxt_jni_OutputStream.c86 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 DRemoteEndpoint.java73 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 Dnxt_unit_websocket_chat.c53 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 DWsRemoteEndpointAsync.java58 public Future<Void> sendBinary(ByteBuffer data) { in sendBinary()
64 public void sendBinary(ByteBuffer data, SendHandler completion) { in sendBinary()

123456