Chromium Code Reviews| Index: webrtc/base/messagequeue.cc |
| diff --git a/webrtc/base/messagequeue.cc b/webrtc/base/messagequeue.cc |
| index 61aa61192bbad69d87ddf5e79aab3a5af3ce290f..61c36e2ca045eaff3324318b0e76418edee77ba8 100644 |
| --- a/webrtc/base/messagequeue.cc |
| +++ b/webrtc/base/messagequeue.cc |
| @@ -27,7 +27,7 @@ typedef rtc::PhysicalSocketServer DefaultSocketServer; |
| namespace rtc { |
| -const uint32_t kMaxMsgLatency = 150; // 150 ms |
| +const int kMaxMsgLatency = 150; // 150 ms |
|
pthatcher1
2016/04/11 20:56:59
Why not uint64_t?
honghaiz3
2016/04/18 23:39:03
According to style guide, we should not use uintXX
|
| //------------------------------------------------------------------ |
| // MessageQueueManager |
| @@ -226,8 +226,8 @@ bool MessageQueue::Get(Message *pmsg, int cmsWait, bool process_io) { |
| int cmsTotal = cmsWait; |
| int cmsElapsed = 0; |
| - uint32_t msStart = Time(); |
| - uint32_t msCurrent = msStart; |
| + int64_t msStart = Time(); |
| + int64_t msCurrent = msStart; |
| while (true) { |
| // Check for sent messages |
| ReceiveSends(); |
| @@ -246,7 +246,7 @@ bool MessageQueue::Get(Message *pmsg, int cmsWait, bool process_io) { |
| if (first_pass) { |
| first_pass = false; |
| while (!dmsgq_.empty()) { |
| - if (TimeIsLater(msCurrent, dmsgq_.top().msTrigger_)) { |
| + if (msCurrent < dmsgq_.top().msTrigger_) { |
| cmsDelayNext = TimeDiff(dmsgq_.top().msTrigger_, msCurrent); |
| break; |
| } |
| @@ -349,7 +349,7 @@ void MessageQueue::PostDelayed(int cmsDelay, |
| return DoDelayPost(cmsDelay, TimeAfter(cmsDelay), phandler, id, pdata); |
| } |
| -void MessageQueue::PostAt(uint32_t tstamp, |
| +void MessageQueue::PostAt(int64_t tstamp, |
| MessageHandler* phandler, |
| uint32_t id, |
| MessageData* pdata) { |
| @@ -357,7 +357,7 @@ void MessageQueue::PostAt(uint32_t tstamp, |
| } |
| void MessageQueue::DoDelayPost(int cmsDelay, |
| - uint32_t tstamp, |
| + int64_t tstamp, |
| MessageHandler* phandler, |
| uint32_t id, |
| MessageData* pdata) { |