| Index: webrtc/p2p/base/p2ptransportchannel.cc
|
| diff --git a/webrtc/p2p/base/p2ptransportchannel.cc b/webrtc/p2p/base/p2ptransportchannel.cc
|
| index 1b7cb58756e0dc11bcc5abf63621c6787ef7380a..7e07598cac884a2b1f9114a1c0809dd2a7add628 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);
|
|
|