Index: webrtc/p2p/base/relayport.cc |
diff --git a/webrtc/p2p/base/relayport.cc b/webrtc/p2p/base/relayport.cc |
index ccddab0e98485507af0c576f67021cb8ceaa6232..88adcf2f88508d5a80020c6e47cd43557a062e06 100644 |
--- a/webrtc/p2p/base/relayport.cc |
+++ b/webrtc/p2p/base/relayport.cc |
@@ -144,6 +144,10 @@ class RelayEntry : public rtc::MessageHandler, |
const char* data, size_t size, |
const rtc::SocketAddress& remote_addr, |
const rtc::PacketTime& packet_time); |
+ |
+ void OnSentPacket(rtc::AsyncPacketSocket* socket, |
+ const rtc::SentPacket& sent_packet); |
+ |
// Called when the socket is currently able to send. |
void OnReadyToSend(rtc::AsyncPacketSocket* socket); |
@@ -508,6 +512,7 @@ void RelayEntry::Connect() { |
// Otherwise, create the new connection and configure any socket options. |
socket->SignalReadPacket.connect(this, &RelayEntry::OnReadPacket); |
+ socket->SignalSentPacket.connect(this, &RelayEntry::OnSentPacket); |
socket->SignalReadyToSend.connect(this, &RelayEntry::OnReadyToSend); |
current_connection_ = new RelayConnection(ra, socket, port()->thread()); |
for (size_t i = 0; i < port_->options().size(); ++i) { |
@@ -747,6 +752,11 @@ void RelayEntry::OnReadPacket( |
PROTO_UDP, packet_time); |
} |
+void RelayEntry::OnSentPacket(rtc::AsyncPacketSocket* socket, |
+ const rtc::SentPacket& sent_packet) { |
+ port_->OnSentPacket(sent_packet); |
+} |
+ |
void RelayEntry::OnReadyToSend(rtc::AsyncPacketSocket* socket) { |
if (connected()) { |
port_->OnReadyToSend(); |