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