Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(409)

Unified Diff: webrtc/p2p/client/basicportallocator.cc

Issue 2019423006: Adding more detail to MessageQueue::Dispatch logging. (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: Created 4 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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.

Powered by Google App Engine
This is Rietveld 408576698