Index: webrtc/p2p/client/basicportallocator.cc |
diff --git a/webrtc/p2p/client/basicportallocator.cc b/webrtc/p2p/client/basicportallocator.cc |
index 143b036183777875730387f85736ed71ad90e3db..09b809852c4a60a7c0fc6a1c9e92afb8dfeb73ff 100644 |
--- a/webrtc/p2p/client/basicportallocator.cc |
+++ b/webrtc/p2p/client/basicportallocator.cc |
@@ -185,16 +185,16 @@ void BasicPortAllocatorSession::StartGettingPorts() { |
} |
running_ = true; |
- network_thread_->Post(this, MSG_CONFIG_START); |
+ network_thread_->Post(FROM_HERE, this, MSG_CONFIG_START); |
if (flags() & PORTALLOCATOR_ENABLE_SHAKER) |
- network_thread_->PostDelayed(ShakeDelay(), this, MSG_SHAKE); |
+ network_thread_->PostDelayed(FROM_HERE, ShakeDelay(), this, MSG_SHAKE); |
} |
void BasicPortAllocatorSession::StopGettingPorts() { |
ASSERT(rtc::Thread::Current() == network_thread_); |
running_ = false; |
- network_thread_->Post(this, MSG_CONFIG_STOP); |
+ network_thread_->Post(FROM_HERE, this, MSG_CONFIG_STOP); |
ClearGettingPorts(); |
} |
@@ -312,7 +312,7 @@ void BasicPortAllocatorSession::GetPortConfigurations() { |
} |
void BasicPortAllocatorSession::ConfigReady(PortConfiguration* config) { |
- network_thread_->Post(this, MSG_CONFIG_READY, config); |
+ network_thread_->Post(FROM_HERE, this, MSG_CONFIG_READY, config); |
} |
// Adds a configuration to the list. |
@@ -357,7 +357,7 @@ void BasicPortAllocatorSession::OnConfigStop() { |
void BasicPortAllocatorSession::AllocatePorts() { |
ASSERT(rtc::Thread::Current() == network_thread_); |
- network_thread_->Post(this, MSG_ALLOCATE); |
+ network_thread_->Post(FROM_HERE, this, MSG_ALLOCATE); |
} |
void BasicPortAllocatorSession::OnAllocate() { |
@@ -454,7 +454,7 @@ void BasicPortAllocatorSession::DoAllocate() { |
} |
} |
if (done_signal_needed) { |
- network_thread_->Post(this, MSG_SEQUENCEOBJECTS_CREATED); |
+ network_thread_->Post(FROM_HERE, this, MSG_SEQUENCEOBJECTS_CREATED); |
} |
} |
@@ -740,7 +740,7 @@ void BasicPortAllocatorSession::OnShake() { |
connections[i]->Destroy(); |
if (running_ || (ports.size() > 0) || (connections.size() > 0)) |
- network_thread_->PostDelayed(ShakeDelay(), this, MSG_SHAKE); |
+ network_thread_->PostDelayed(FROM_HERE, ShakeDelay(), this, MSG_SHAKE); |
} |
BasicPortAllocatorSession::PortData* BasicPortAllocatorSession::FindPort( |
@@ -838,7 +838,7 @@ void AllocationSequence::DisableEquivalentPhases(rtc::Network* network, |
void AllocationSequence::Start() { |
state_ = kRunning; |
- session_->network_thread()->Post(this, MSG_ALLOCATION_PHASE); |
+ session_->network_thread()->Post(FROM_HERE, this, MSG_ALLOCATION_PHASE); |
} |
void AllocationSequence::Stop() { |
@@ -888,9 +888,9 @@ void AllocationSequence::OnMessage(rtc::Message* msg) { |
if (state() == kRunning) { |
++phase_; |
- session_->network_thread()->PostDelayed( |
- session_->allocator()->step_delay(), |
- this, MSG_ALLOCATION_PHASE); |
+ session_->network_thread()->PostDelayed(FROM_HERE, |
+ session_->allocator()->step_delay(), |
+ this, MSG_ALLOCATION_PHASE); |
} else { |
// If all phases in AllocationSequence are completed, no allocation |
// steps needed further. Canceling pending signal. |