Index: webrtc/p2p/base/tcpport.cc |
diff --git a/webrtc/p2p/base/tcpport.cc b/webrtc/p2p/base/tcpport.cc |
index 23afc2f031fed6d88de4118869840c7975db5196..6a64174f00d8dc512c9485e608f50d7a2b1e9903 100644 |
--- a/webrtc/p2p/base/tcpport.cc |
+++ b/webrtc/p2p/base/tcpport.cc |
@@ -258,6 +258,7 @@ void TCPPort::OnNewConnection(rtc::AsyncPacketSocket* socket, |
incoming.socket = new_socket; |
incoming.socket->SignalReadPacket.connect(this, &TCPPort::OnReadPacket); |
incoming.socket->SignalReadyToSend.connect(this, &TCPPort::OnReadyToSend); |
+ incoming.socket->SignalSentPacket.connect(this, &TCPPort::OnSentPacket); |
LOG_J(LS_VERBOSE, this) << "Accepted connection from " |
<< incoming.addr.ToSensitiveString(); |
@@ -286,6 +287,12 @@ void TCPPort::OnReadPacket(rtc::AsyncPacketSocket* socket, |
Port::OnReadPacket(data, size, remote_addr, PROTO_TCP); |
} |
+void TCPPort::OnSentPacket(rtc::AsyncPacketSocket* socket, |
+ const rtc::SentPacket& sent_packet) { |
+ ASSERT(socket == socket_); |
+ PortInterface::SignalSentPacket(sent_packet); |
+} |
+ |
void TCPPort::OnReadyToSend(rtc::AsyncPacketSocket* socket) { |
Port::OnReadyToSend(); |
} |