Index: webrtc/p2p/base/p2ptransportchannel.cc |
diff --git a/webrtc/p2p/base/p2ptransportchannel.cc b/webrtc/p2p/base/p2ptransportchannel.cc |
index fc721312331233ad7db90f42164913fd5606bbb3..9d598f57f3d7902d7c12ac55f8eee22bbda80edc 100644 |
--- a/webrtc/p2p/base/p2ptransportchannel.cc |
+++ b/webrtc/p2p/base/p2ptransportchannel.cc |
@@ -435,6 +435,7 @@ void P2PTransportChannel::OnPortReady(PortAllocatorSession *session, |
port->SignalDestroyed.connect(this, &P2PTransportChannel::OnPortDestroyed); |
port->SignalRoleConflict.connect( |
this, &P2PTransportChannel::OnRoleConflict); |
+ port->SignalSentPacket.connect(this, &P2PTransportChannel::OnSentPacket); |
// Attempt to create a connection from this new port to all of the remote |
// candidates that we were given so far. |
@@ -1356,6 +1357,13 @@ void P2PTransportChannel::OnReadPacket(Connection* connection, |
} |
} |
+void P2PTransportChannel::OnSentPacket(PortInterface* port, |
+ const rtc::SentPacket& sent_packet) { |
+ ASSERT(worker_thread_ == rtc::Thread::Current()); |
+ |
+ SignalSentPacket(this, sent_packet); |
+} |
+ |
void P2PTransportChannel::OnReadyToSend(Connection* connection) { |
if (connection == best_connection_ && writable()) { |
SignalReadyToSend(this); |