| 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);
|
|
|