Adding more detail to MessageQueue::Dispatch logging.

webrtc/p2p/base/turnport.cc

 /*
  *  Copyright 2012 The WebRTC Project Authors. All rights reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 724 matching lines @@
              "",  // TCP canddiate type, empty for turn candidates.
              RELAY_PORT_TYPE,
              GetRelayPreference(server_address_.proto, server_address_.secure),
              server_priority_, true);
 }
 
 void TurnPort::OnAllocateError() {
   // We will send SignalPortError asynchronously as this can be sent during
   // port initialization. This way it will not be blocking other port
   // creation.
-  thread()->Post(this, MSG_ALLOCATE_ERROR);
+  thread()->Post(FROM_HERE, this, MSG_ALLOCATE_ERROR);
 }
 
 void TurnPort::OnTurnRefreshError() {
   // Need to Close the port asynchronously because otherwise, the refresh
   // request may be deleted twice: once at the end of the message processing
   // and the other in Close().
-  thread()->Post(this, MSG_REFRESH_ERROR);
+  thread()->Post(FROM_HERE, this, MSG_REFRESH_ERROR);
 }
 
 void TurnPort::Close() {
   if (!ready()) {
     OnAllocateError();
   }
   request_manager_.Clear();
   // Stop the port from creating new connections.
   state_ = STATE_DISCONNECTED;
   // Delete all existing connections; stop sending data.
@@ skipping 262 matching lines @@
   TurnEntry* entry = FindEntry(remote_address);
   ASSERT(entry != NULL);
   ScheduleEntryDestruction(entry);
 }
 
 void TurnPort::ScheduleEntryDestruction(TurnEntry* entry) {
   ASSERT(entry->destruction_timestamp() == 0);
   int64_t timestamp = rtc::TimeMillis();
   entry->set_destruction_timestamp(timestamp);
   invoker_.AsyncInvokeDelayed<void>(
-      thread(),
+      FROM_HERE, thread(),
       rtc::Bind(&TurnPort::DestroyEntryIfNotCancelled, this, entry, timestamp),
       TURN_PERMISSION_TIMEOUT);
 }
 
 void TurnPort::CancelEntryDestruction(TurnEntry* entry) {
   ASSERT(entry->destruction_timestamp() != 0);
   entry->set_destruction_timestamp(0);
 }
 
 bool TurnPort::SetEntryChannelId(const rtc::SocketAddress& address,
@@ skipping 79 matching lines @@
   switch (error_code->code()) {
     case STUN_ERROR_UNAUTHORIZED:       // Unauthrorized.
       OnAuthChallenge(response, error_code->code());
       break;
     case STUN_ERROR_TRY_ALTERNATE:
       OnTryAlternate(response, error_code->code());
       break;
     case STUN_ERROR_ALLOCATION_MISMATCH:
       // We must handle this error async because trying to delete the socket in
       // OnErrorResponse will cause a deadlock on the socket.
-      port_->thread()->Post(port_, TurnPort::MSG_ALLOCATE_MISMATCH);
+      port_->thread()->Post(FROM_HERE, port_, TurnPort::MSG_ALLOCATE_MISMATCH);
       break;
     default:
       LOG_J(LS_WARNING, port_) << "Received TURN allocate error response"
                                << ", id=" << rtc::hex_encode(id())
                                << ", code=" << error_code->code()
                                << ", rtt=" << Elapsed();
       port_->OnAllocateError();
   }
 }
 
@@ skipping 68 matching lines @@
       response->GetByteString(STUN_ATTR_NONCE);
   if (nonce_attr) {
     LOG_J(LS_INFO, port_) << "Applying STUN_ATTR_NONCE attribute in "
                           << "try alternate error response.";
     port_->set_nonce(nonce_attr->GetString());
   }
 
   // For TCP, we can't close the original Tcp socket during handling a 300 as
   // we're still inside that socket's event handler. Doing so will cause
   // deadlock.
-  port_->thread()->Post(port_, TurnPort::MSG_TRY_ALTERNATE_SERVER);
+  port_->thread()->Post(FROM_HERE, port_, TurnPort::MSG_TRY_ALTERNATE_SERVER);
 }
 
 TurnRefreshRequest::TurnRefreshRequest(TurnPort* port)
     : StunRequest(new TurnMessage()),
       port_(port),
       lifetime_(-1) {
 }
 
 void TurnRefreshRequest::Prepare(StunMessage* request) {
   // Create the request as indicated in RFC 5766, Section 7.1.
@@ skipping 295 matching lines @@
   } else {
     state_ = STATE_UNBOUND;
     port_->DestroyConnection(ext_addr_);
   }
 }
 void TurnEntry::OnChannelBindTimeout() {
   state_ = STATE_UNBOUND;
   port_->DestroyConnection(ext_addr_);
 }
 }  // namespace cricket