Searched refs:cur_msg (Results 1 – 2 of 2) sorted by relevance
523 dtio->cur_msg = buf; in dtio_find_in_queue()642 free(dtio->cur_msg); in dtio_cur_msg_free()643 dtio->cur_msg = NULL; in dtio_cur_msg_free()699 if(dtio->cur_msg) { in dtio_close_output()848 iov[1].iov_base = dtio->cur_msg; in dtio_write_with_writev()927 ((uint8_t*)dtio->cur_msg)+dtio->cur_msg_done, in dtio_write_more_of_data()1533 if(!dtio->cur_msg) { in dtio_output_cb()1553 if(!dtio->cur_msg) in dtio_output_cb()1775 if(dtio->cur_msg) { in dtio_stop_ev_cb()1917 log_assert(dtio->cur_msg == NULL && dtio->cur_msg_len == 0); in dtio_control_start_send()[all …]
165 void* cur_msg; member