Lines Matching refs:cur_ts

98 		struct timespec cur_ts;  in HandleSignal()  local
100 clock_gettime(CLOCK_REALTIME, &cur_ts); in HandleSignal()
102 if (sigint_cnt[core] > 0 && cur_ts.tv_sec == sigint_ts[core].tv_sec) { in HandleSignal()
287 PrintNetworkStats(mtcp_manager_t mtcp, uint32_t cur_ts) in PrintNetworkStats() argument
311 if (TS_TO_MSEC(cur_ts - mtcp->p_nstat_ts) < SEC_TO_MSEC(TIMEOUT)) { in PrintNetworkStats()
315 mtcp->p_nstat_ts = cur_ts; in PrintNetworkStats()
517 FlushEpollEvents(mtcp_manager_t mtcp, uint32_t cur_ts) in FlushEpollEvents() argument
546 ep->usr_queue->num_events, cur_ts, mtcp->ts_last_event); in FlushEpollEvents()
547 mtcp->ts_last_event = cur_ts; in FlushEpollEvents()
555 HandleApplicationCalls(mtcp_manager_t mtcp, uint32_t cur_ts) in HandleApplicationCalls() argument
576 AddtoControlList(mtcp, stream, cur_ts); in HandleApplicationCalls()
588 EnqueueACK(mtcp, stream, cur_ts, ACK_OPT_AGGREGATE); in HandleApplicationCalls()
658 AddtoControlList(mtcp, stream, cur_ts); in HandleApplicationCalls()
686 AddtoControlList(mtcp, stream, cur_ts); in HandleApplicationCalls()
723 AddtoControlList(mtcp, stream, cur_ts); in HandleApplicationCalls()
749 AddtoControlList(mtcp, stream, cur_ts); in HandleApplicationCalls()
765 WritePacketsToChunks(mtcp_manager_t mtcp, uint32_t cur_ts) in WritePacketsToChunks() argument
774 WriteTCPControlList(mtcp, mtcp->g_sender, cur_ts, thresh); in WritePacketsToChunks()
776 WriteTCPACKList(mtcp, mtcp->g_sender, cur_ts, thresh); in WritePacketsToChunks()
778 WriteTCPDataList(mtcp, mtcp->g_sender, cur_ts, thresh); in WritePacketsToChunks()
783 WriteTCPControlList(mtcp, mtcp->n_sender[i], cur_ts, thresh); in WritePacketsToChunks()
785 WriteTCPACKList(mtcp, mtcp->n_sender[i], cur_ts, thresh); in WritePacketsToChunks()
787 WriteTCPDataList(mtcp, mtcp->n_sender[i], cur_ts, thresh); in WritePacketsToChunks()
858 struct timeval cur_ts = {0}; in RunMainLoop() local
867 gettimeofday(&cur_ts, NULL); in RunMainLoop()
872 prev_ts = cur_ts; in RunMainLoop()
887 gettimeofday(&cur_ts, NULL); in RunMainLoop()
890 UpdateStatCounter(&mtcp->rtstat.round, TimeDiffUs(&cur_ts, &prev_ts)); in RunMainLoop()
891 prev_ts = cur_ts; in RunMainLoop()
894 ts = TIMEVAL_TO_TS(&cur_ts); in RunMainLoop()
895 mtcp->cur_ts = ts; in RunMainLoop()
915 TimeDiffUs(&processing_ts, &cur_ts)); in RunMainLoop()
922 if (TIMEVAL_LT(&cur_ts, &walk->exp)) in RunMainLoop()