| Index: webrtc/p2p/client/socketmonitor.cc
|
| diff --git a/webrtc/p2p/client/socketmonitor.cc b/webrtc/p2p/client/socketmonitor.cc
|
| index 7975514d7e21d314a802eb2f03492cb705b59213..7d553b93f62f22c3f49520f4c237e7ef0c23c024 100644
|
| --- a/webrtc/p2p/client/socketmonitor.cc
|
| +++ b/webrtc/p2p/client/socketmonitor.cc
|
| @@ -22,16 +22,16 @@ enum {
|
| };
|
|
|
| ConnectionMonitor::ConnectionMonitor(ConnectionStatsGetter* stats_getter,
|
| - rtc::Thread* worker_thread,
|
| + rtc::Thread* network_thread,
|
| rtc::Thread* monitoring_thread) {
|
| stats_getter_ = stats_getter;
|
| - worker_thread_ = worker_thread;
|
| + network_thread_ = network_thread;
|
| monitoring_thread_ = monitoring_thread;
|
| monitoring_ = false;
|
| }
|
|
|
| ConnectionMonitor::~ConnectionMonitor() {
|
| - worker_thread_->Clear(this);
|
| + network_thread_->Clear(this);
|
| monitoring_thread_->Clear(this);
|
| }
|
|
|
| @@ -39,18 +39,18 @@ void ConnectionMonitor::Start(int milliseconds) {
|
| rate_ = milliseconds;
|
| if (rate_ < 250)
|
| rate_ = 250;
|
| - worker_thread_->Post(RTC_FROM_HERE, this, MSG_MONITOR_START);
|
| + network_thread_->Post(RTC_FROM_HERE, this, MSG_MONITOR_START);
|
| }
|
|
|
| void ConnectionMonitor::Stop() {
|
| - worker_thread_->Post(RTC_FROM_HERE, this, MSG_MONITOR_STOP);
|
| + network_thread_->Post(RTC_FROM_HERE, this, MSG_MONITOR_STOP);
|
| }
|
|
|
| void ConnectionMonitor::OnMessage(rtc::Message *message) {
|
| rtc::CritScope cs(&crit_);
|
| switch (message->message_id) {
|
| case MSG_MONITOR_START:
|
| - ASSERT(rtc::Thread::Current() == worker_thread_);
|
| + ASSERT(rtc::Thread::Current() == network_thread_);
|
| if (!monitoring_) {
|
| monitoring_ = true;
|
| PollConnectionStats_w();
|
| @@ -58,15 +58,15 @@ void ConnectionMonitor::OnMessage(rtc::Message *message) {
|
| break;
|
|
|
| case MSG_MONITOR_STOP:
|
| - ASSERT(rtc::Thread::Current() == worker_thread_);
|
| + ASSERT(rtc::Thread::Current() == network_thread_);
|
| if (monitoring_) {
|
| monitoring_ = false;
|
| - worker_thread_->Clear(this);
|
| + network_thread_->Clear(this);
|
| }
|
| break;
|
|
|
| case MSG_MONITOR_POLL:
|
| - ASSERT(rtc::Thread::Current() == worker_thread_);
|
| + ASSERT(rtc::Thread::Current() == network_thread_);
|
| PollConnectionStats_w();
|
| break;
|
|
|
| @@ -82,7 +82,7 @@ void ConnectionMonitor::OnMessage(rtc::Message *message) {
|
| }
|
|
|
| void ConnectionMonitor::PollConnectionStats_w() {
|
| - ASSERT(rtc::Thread::Current() == worker_thread_);
|
| + ASSERT(rtc::Thread::Current() == network_thread_);
|
| rtc::CritScope cs(&crit_);
|
|
|
| // Gather connection infos
|
| @@ -90,7 +90,7 @@ void ConnectionMonitor::PollConnectionStats_w() {
|
|
|
| // Signal the monitoring thread, start another poll timer
|
| monitoring_thread_->Post(RTC_FROM_HERE, this, MSG_MONITOR_SIGNAL);
|
| - worker_thread_->PostDelayed(RTC_FROM_HERE, rate_, this, MSG_MONITOR_POLL);
|
| + network_thread_->PostDelayed(RTC_FROM_HERE, rate_, this, MSG_MONITOR_POLL);
|
| }
|
|
|
| } // namespace cricket
|
|
|