Searched refs:cur_msg (Results 1 – 2 of 2) sorted by relevance
517 dtio->cur_msg = buf; in dtio_find_in_queue()636 free(dtio->cur_msg); in dtio_cur_msg_free()637 dtio->cur_msg = NULL; in dtio_cur_msg_free()693 if(dtio->cur_msg) { in dtio_close_output()842 iov[1].iov_base = dtio->cur_msg; in dtio_write_with_writev()921 ((uint8_t*)dtio->cur_msg)+dtio->cur_msg_done, in dtio_write_more_of_data()1510 if(!dtio->cur_msg) { in dtio_output_cb()1738 if(dtio->cur_msg) { in dtio_stop_ev_cb()1880 log_assert(dtio->cur_msg == NULL && dtio->cur_msg_len == 0); in dtio_control_start_send()1883 if(!dtio->cur_msg) { in dtio_control_start_send()[all …]
165 void* cur_msg; member