87 static void dtio_open_output(struct dt_io_thread* dtio);
89 static int dtio_add_output_event_write(struct dt_io_thread* dtio);
91 static void dtio_reconnect_enable(struct dt_io_thread* dtio);
95 static int dtio_control_start_send(struct dt_io_thread* dtio);
98 static int dtio_enable_brief_read(struct dt_io_thread* dtio);
100 static int dtio_enable_brief_write(struct dt_io_thread* dtio);
149 static void dtio_wakeup(struct dt_io_thread* dtio)  in dtio_wakeup()
298 struct dt_io_thread* dt_io_thread_create(void)  in dt_io_thread_create()
300 	struct dt_io_thread* dtio = calloc(1, sizeof(*dtio));  in dt_io_thread_create()
307 void dt_io_thread_delete(struct dt_io_thread* dtio)  in dt_io_thread_delete()
331 int dt_io_thread_apply_cfg(struct dt_io_thread* dtio, struct config_file *cfg)  in dt_io_thread_apply_cfg()
448 int dt_io_thread_register_queue(struct dt_io_thread* dtio,  in dt_io_thread_register_queue()
463 void dt_io_thread_unregister_queue(struct dt_io_thread* dtio,  in dt_io_thread_unregister_queue()
511 static int dtio_find_in_queue(struct dt_io_thread* dtio,  in dtio_find_in_queue()
527 static int dtio_find_msg(struct dt_io_thread* dtio)  in dtio_find_msg()
560 	struct dt_io_thread* dtio = (struct dt_io_thread*)arg;  in dtio_reconnect_timeout_cb()
576 static void dtio_reconnect_enable(struct dt_io_thread* dtio)  in dtio_reconnect_enable()
609 static void dtio_reconnect_del(struct dt_io_thread* dtio)  in dtio_reconnect_del()
619 static void dtio_reconnect_clear(struct dt_io_thread* dtio)  in dtio_reconnect_clear()
626 static void dtio_reconnect_slow(struct dt_io_thread* dtio, int msec)  in dtio_reconnect_slow()
634 static void dtio_cur_msg_free(struct dt_io_thread* dtio)  in dtio_cur_msg_free()
658 static void dtio_del_output_event(struct dt_io_thread* dtio)  in dtio_del_output_event()
668 static void dtio_close_fd(struct dt_io_thread* dtio)  in dtio_close_fd()
675 static void dtio_close_output(struct dt_io_thread* dtio)  in dtio_close_output()
706 static int dtio_check_nb_connect(struct dt_io_thread* dtio)  in dtio_check_nb_connect()
758 static int dtio_write_ssl(struct dt_io_thread* dtio, uint8_t* buf,  in dtio_write_ssl()
801 static int dtio_write_buf(struct dt_io_thread* dtio, uint8_t* buf,  in dtio_write_buf()
835 static int dtio_write_with_writev(struct dt_io_thread* dtio)  in dtio_write_with_writev()
882 static int dtio_write_more_of_len(struct dt_io_thread* dtio)  in dtio_write_more_of_len()
915 static int dtio_write_more_of_data(struct dt_io_thread* dtio)  in dtio_write_more_of_data()
940 static int dtio_write_more(struct dt_io_thread* dtio)  in dtio_write_more()
955 static ssize_t receive_bytes(struct dt_io_thread* dtio, void* buf, size_t len) {  in receive_bytes()
999 static int ssl_read_bytes(struct dt_io_thread* dtio, void* buf, size_t len)  in ssl_read_bytes()
1043 static int dtio_check_close(struct dt_io_thread* dtio)  in dtio_check_close()
1071 static int dtio_read_accept_frame(struct dt_io_thread* dtio)  in dtio_read_accept_frame()
1209 static int dtio_add_output_event_read(struct dt_io_thread* dtio)  in dtio_add_output_event_read()
1233 static int dtio_add_output_event_write(struct dt_io_thread* dtio)  in dtio_add_output_event_write()
1257 static void dtio_sleep(struct dt_io_thread* dtio)  in dtio_sleep()
1266 static int dtio_enable_brief_read(struct dt_io_thread* dtio)  in dtio_enable_brief_read()
1284 static int dtio_disable_brief_read(struct dt_io_thread* dtio)  in dtio_disable_brief_read()
1302 static int dtio_enable_brief_write(struct dt_io_thread* dtio)  in dtio_enable_brief_write()
1311 static int dtio_disable_brief_write(struct dt_io_thread* dtio)  in dtio_disable_brief_write()
1320 static int dtio_ssl_check_peer(struct dt_io_thread* dtio)  in dtio_ssl_check_peer()
1373 static int dtio_ssl_handshake(struct dt_io_thread* dtio,  in dtio_ssl_handshake()
1466 	struct dt_io_thread* dtio = (struct dt_io_thread*)arg;  in dtio_output_cb()
1544 	struct dt_io_thread* dtio = (struct dt_io_thread*)arg;  in dtio_cmd_cb()
1591 static void dtio_setup_base(struct dt_io_thread* dtio, time_t* secs,  in dtio_setup_base()
1603 static void dtio_setup_cmd(struct dt_io_thread* dtio)  in dtio_setup_cmd()
1619 static void dtio_setup_reconnect(struct dt_io_thread* dtio)  in dtio_setup_reconnect()
1640 	struct dt_io_thread* dtio;
1664 	struct dt_io_thread* dtio = info->dtio;  in dtio_control_stop_send()
1700 	struct dt_io_thread* dtio = info->dtio;  in dtio_stop_ev_cb()
1765 static void dtio_control_stop_flush(struct dt_io_thread* dtio)  in dtio_control_stop_flush()
1856 static void dtio_desetup(struct dt_io_thread* dtio)  in dtio_desetup()
1878 static int dtio_control_start_send(struct dt_io_thread* dtio)  in dtio_control_start_send()
1897 static int dtio_control_ready_send(struct dt_io_thread* dtio)  in dtio_control_ready_send()
1916 static int dtio_open_output_local(struct dt_io_thread* dtio)  in dtio_open_output_local()
1956 static int dtio_open_output_tcp(struct dt_io_thread* dtio)  in dtio_open_output_tcp()
2004 static int dtio_setup_ssl(struct dt_io_thread* dtio)  in dtio_setup_ssl()
2019 static void dtio_open_output(struct dt_io_thread* dtio)  in dtio_open_output()
2080 static void dtio_setup_on_base(struct dt_io_thread* dtio)  in dtio_setup_on_base()
2093 	struct dt_io_thread* dtio = (struct dt_io_thread*)arg;  in dnstap_io()
2116 int dt_io_thread_start(struct dt_io_thread* dtio, void* event_base_nothr,  in dt_io_thread_start()
2146 void dt_io_thread_stop(struct dt_io_thread* dtio)  in dt_io_thread_stop()