| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright 2005 The WebRTC project authors. All Rights Reserved. | 2 * Copyright 2005 The WebRTC project authors. All Rights Reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| (...skipping 19 matching lines...) Expand all Loading... |
| 30 MediaMonitor::~MediaMonitor() { | 30 MediaMonitor::~MediaMonitor() { |
| 31 monitoring_ = false; | 31 monitoring_ = false; |
| 32 monitor_thread_->Clear(this); | 32 monitor_thread_->Clear(this); |
| 33 worker_thread_->Clear(this); | 33 worker_thread_->Clear(this); |
| 34 } | 34 } |
| 35 | 35 |
| 36 void MediaMonitor::Start(uint32_t milliseconds) { | 36 void MediaMonitor::Start(uint32_t milliseconds) { |
| 37 rate_ = milliseconds; | 37 rate_ = milliseconds; |
| 38 if (rate_ < 100) | 38 if (rate_ < 100) |
| 39 rate_ = 100; | 39 rate_ = 100; |
| 40 worker_thread_->Post(this, MSG_MONITOR_START); | 40 worker_thread_->Post(RTC_FROM_HERE, this, MSG_MONITOR_START); |
| 41 } | 41 } |
| 42 | 42 |
| 43 void MediaMonitor::Stop() { | 43 void MediaMonitor::Stop() { |
| 44 worker_thread_->Post(this, MSG_MONITOR_STOP); | 44 worker_thread_->Post(RTC_FROM_HERE, this, MSG_MONITOR_STOP); |
| 45 rate_ = 0; | 45 rate_ = 0; |
| 46 } | 46 } |
| 47 | 47 |
| 48 void MediaMonitor::OnMessage(rtc::Message* message) { | 48 void MediaMonitor::OnMessage(rtc::Message* message) { |
| 49 rtc::CritScope cs(&crit_); | 49 rtc::CritScope cs(&crit_); |
| 50 | 50 |
| 51 switch (message->message_id) { | 51 switch (message->message_id) { |
| 52 case MSG_MONITOR_START: | 52 case MSG_MONITOR_START: |
| 53 ASSERT(rtc::Thread::Current() == worker_thread_); | 53 ASSERT(rtc::Thread::Current() == worker_thread_); |
| 54 if (!monitoring_) { | 54 if (!monitoring_) { |
| (...skipping 22 matching lines...) Expand all Loading... |
| 77 } | 77 } |
| 78 } | 78 } |
| 79 | 79 |
| 80 void MediaMonitor::PollMediaChannel() { | 80 void MediaMonitor::PollMediaChannel() { |
| 81 rtc::CritScope cs(&crit_); | 81 rtc::CritScope cs(&crit_); |
| 82 ASSERT(rtc::Thread::Current() == worker_thread_); | 82 ASSERT(rtc::Thread::Current() == worker_thread_); |
| 83 | 83 |
| 84 GetStats(); | 84 GetStats(); |
| 85 | 85 |
| 86 // Signal the monitoring thread, start another poll timer | 86 // Signal the monitoring thread, start another poll timer |
| 87 monitor_thread_->Post(this, MSG_MONITOR_SIGNAL); | 87 monitor_thread_->Post(RTC_FROM_HERE, this, MSG_MONITOR_SIGNAL); |
| 88 worker_thread_->PostDelayed(rate_, this, MSG_MONITOR_POLL); | 88 worker_thread_->PostDelayed(RTC_FROM_HERE, rate_, this, MSG_MONITOR_POLL); |
| 89 } | 89 } |
| 90 | 90 |
| 91 } // namespace cricket | 91 } // namespace cricket |
| OLD | NEW |