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