Searched refs:cur_msg (Results 1 – 2 of 2) sorted by relevance
526 dtio->cur_msg = buf; in dtio_find_in_queue()645 free(dtio->cur_msg); in dtio_cur_msg_free()646 dtio->cur_msg = NULL; in dtio_cur_msg_free()702 if(dtio->cur_msg) { in dtio_close_output()851 iov[1].iov_base = dtio->cur_msg; in dtio_write_with_writev()930 ((uint8_t*)dtio->cur_msg)+dtio->cur_msg_done, in dtio_write_more_of_data()1536 if(!dtio->cur_msg) { in dtio_output_cb()1556 if(!dtio->cur_msg) in dtio_output_cb()1778 if(dtio->cur_msg) { in dtio_stop_ev_cb()1920 log_assert(dtio->cur_msg == NULL && dtio->cur_msg_len == 0); in dtio_control_start_send()[all …]
171 void* cur_msg; member