149 static void dtio_wakeup(struct dt_io_thread* dtio)  in dtio_wakeup()
306 	struct dt_io_thread* dtio = calloc(1, sizeof(*dtio));  in dt_io_thread_create()  local
313 void dt_io_thread_delete(struct dt_io_thread* dtio)  in dt_io_thread_delete()
337 int dt_io_thread_apply_cfg(struct dt_io_thread* dtio, struct config_file *cfg)  in dt_io_thread_apply_cfg()
454 int dt_io_thread_register_queue(struct dt_io_thread* dtio,  in dt_io_thread_register_queue()
469 void dt_io_thread_unregister_queue(struct dt_io_thread* dtio,  in dt_io_thread_unregister_queue()
517 static int dtio_find_in_queue(struct dt_io_thread* dtio,  in dtio_find_in_queue()
533 static int dtio_find_msg(struct dt_io_thread* dtio)  in dtio_find_msg()
566 	struct dt_io_thread* dtio = (struct dt_io_thread*)arg;  in dtio_reconnect_timeout_cb()  local
582 static void dtio_reconnect_enable(struct dt_io_thread* dtio)  in dtio_reconnect_enable()
615 static void dtio_reconnect_del(struct dt_io_thread* dtio)  in dtio_reconnect_del()
625 static void dtio_reconnect_clear(struct dt_io_thread* dtio)  in dtio_reconnect_clear()
632 static void dtio_reconnect_slow(struct dt_io_thread* dtio, int msec)  in dtio_reconnect_slow()
640 static void dtio_cur_msg_free(struct dt_io_thread* dtio)  in dtio_cur_msg_free()
664 static void dtio_del_output_event(struct dt_io_thread* dtio)  in dtio_del_output_event()
674 static void dtio_close_fd(struct dt_io_thread* dtio)  in dtio_close_fd()
681 static void dtio_close_output(struct dt_io_thread* dtio)  in dtio_close_output()
712 static int dtio_check_nb_connect(struct dt_io_thread* dtio)  in dtio_check_nb_connect()
764 static int dtio_write_ssl(struct dt_io_thread* dtio, uint8_t* buf,  in dtio_write_ssl()
807 static int dtio_write_buf(struct dt_io_thread* dtio, uint8_t* buf,  in dtio_write_buf()
841 static int dtio_write_with_writev(struct dt_io_thread* dtio)  in dtio_write_with_writev()
888 static int dtio_write_more_of_len(struct dt_io_thread* dtio)  in dtio_write_more_of_len()
921 static int dtio_write_more_of_data(struct dt_io_thread* dtio)  in dtio_write_more_of_data()
946 static int dtio_write_more(struct dt_io_thread* dtio)  in dtio_write_more()
961 static ssize_t receive_bytes(struct dt_io_thread* dtio, void* buf, size_t len) {  in receive_bytes()
1005 static int ssl_read_bytes(struct dt_io_thread* dtio, void* buf, size_t len)  in ssl_read_bytes()
1049 static int dtio_check_close(struct dt_io_thread* dtio)  in dtio_check_close()
1077 static int dtio_read_accept_frame(struct dt_io_thread* dtio)  in dtio_read_accept_frame()
1215 static int dtio_add_output_event_read(struct dt_io_thread* dtio)  in dtio_add_output_event_read()
1239 static int dtio_add_output_event_write(struct dt_io_thread* dtio)  in dtio_add_output_event_write()
1263 static void dtio_sleep(struct dt_io_thread* dtio)  in dtio_sleep()
1279 static int dtio_enable_brief_read(struct dt_io_thread* dtio)  in dtio_enable_brief_read()
1297 static int dtio_disable_brief_read(struct dt_io_thread* dtio)  in dtio_disable_brief_read()
1315 static int dtio_enable_brief_write(struct dt_io_thread* dtio)  in dtio_enable_brief_write()
1324 static int dtio_disable_brief_write(struct dt_io_thread* dtio)  in dtio_disable_brief_write()
1333 static int dtio_ssl_check_peer(struct dt_io_thread* dtio)  in dtio_ssl_check_peer()
1394 static int dtio_ssl_handshake(struct dt_io_thread* dtio,  in dtio_ssl_handshake()
1487 	struct dt_io_thread* dtio = (struct dt_io_thread*)arg;  in dtio_output_cb()  local
1581 	struct dt_io_thread* dtio = (struct dt_io_thread*)arg;  in dtio_cmd_cb()  local
1628 static void dtio_setup_base(struct dt_io_thread* dtio, time_t* secs,  in dtio_setup_base()
1640 static void dtio_setup_cmd(struct dt_io_thread* dtio)  in dtio_setup_cmd()
1656 static void dtio_setup_reconnect(struct dt_io_thread* dtio)  in dtio_setup_reconnect()
1677 	struct dt_io_thread* dtio;  member
1701 	struct dt_io_thread* dtio = info->dtio;  in dtio_control_stop_send()  local
1737 	struct dt_io_thread* dtio = info->dtio;  in dtio_stop_ev_cb()  local
1802 static void dtio_control_stop_flush(struct dt_io_thread* dtio)  in dtio_control_stop_flush()
1893 static void dtio_desetup(struct dt_io_thread* dtio)  in dtio_desetup()
1915 static int dtio_control_start_send(struct dt_io_thread* dtio)  in dtio_control_start_send()
1934 static int dtio_control_ready_send(struct dt_io_thread* dtio)  in dtio_control_ready_send()
1953 static int dtio_open_output_local(struct dt_io_thread* dtio)  in dtio_open_output_local()
1993 static int dtio_open_output_tcp(struct dt_io_thread* dtio)  in dtio_open_output_tcp()
2041 static int dtio_setup_ssl(struct dt_io_thread* dtio)  in dtio_setup_ssl()
2056 static void dtio_open_output(struct dt_io_thread* dtio)  in dtio_open_output()
2117 static void dtio_setup_on_base(struct dt_io_thread* dtio)  in dtio_setup_on_base()
2130 	struct dt_io_thread* dtio = (struct dt_io_thread*)arg;  in dnstap_io()  local
2153 int dt_io_thread_start(struct dt_io_thread* dtio, void* event_base_nothr,  in dt_io_thread_start()
2183 void dt_io_thread_stop(struct dt_io_thread* dtio)  in dt_io_thread_stop()