Searched refs:msgProcessTime (Results 1 – 3 of 3) sorted by relevance
53 …TimeUs msgProcessTime = (delayUs > INT64_MAX - nowUs) ? INT64_MAX : (nowUs + static_cast<int64_t>(… in SendAsyncMsg() local54 if (m_msgQueue.find(msgProcessTime) != m_msgQueue.end()) { in SendAsyncMsg()56 msgProcessTime++; in SendAsyncMsg()58 m_msgQueue[msgProcessTime] = MsgInfo {type, ASYNC_MSG_ID, msg}; in SendAsyncMsg()
54 TimeUs msgProcessTime = (delayUs > INT64_MAX - nowUs) ? INT64_MAX : (nowUs + delayUs); in SendAsyncMsg() local55 if (m_msgQueue.find(msgProcessTime) != m_msgQueue.end()) { in SendAsyncMsg()57 msgProcessTime++; in SendAsyncMsg()59 m_msgQueue[msgProcessTime] = MsgInfo {type, ASYNC_MSG_ID, msg}; in SendAsyncMsg()
267 int64_t msgProcessTime = msgQueue_.begin()->first; in UpdateTop() local270 if (msgProcessTime <= nowUs || msgProcessTime <= jobProcessTime) { in UpdateTop()271 topProcessUs_ = msgProcessTime; in UpdateTop()