Lines Matching refs:curr_ms
154 utime64_t curr_ms = 0; in mt_multi_open() local
195 curr_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_open()
196 if (curr_ms > end_ms) in mt_multi_open()
216 mt_multi_netfd_poll(wait_list, KQ_EVENT_WRITE, end_ms - curr_ms); in mt_multi_open()
230 utime64_t curr_ms = 0; in mt_multi_sendto() local
277 curr_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_sendto()
278 if (curr_ms > end_ms) in mt_multi_sendto()
298 mt_multi_netfd_poll(wait_list, KQ_EVENT_WRITE, end_ms - curr_ms); in mt_multi_sendto()
313 utime64_t curr_ms = 0; in mt_multi_recvfrom() local
361 curr_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_recvfrom()
362 if (curr_ms > end_ms) in mt_multi_recvfrom()
364 MTLOG_DEBUG("Recv data timeout, curr %llu, start: %llu", curr_ms, start_ms); in mt_multi_recvfrom()
374 mt_multi_netfd_poll(wait_list, KQ_EVENT_READ, end_ms - curr_ms); in mt_multi_recvfrom()
386 utime64_t curr_ms = 0; in mt_multi_sendrcv_ex() local
404 curr_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_sendrcv_ex()
405 rc = mt_multi_sendto(req_list, timeout - (curr_ms - start_ms)); in mt_multi_sendrcv_ex()
413 curr_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_sendrcv_ex()
414 rc = mt_multi_recvfrom(req_list, timeout - (curr_ms - start_ms)); in mt_multi_sendrcv_ex()