diff options
Diffstat (limited to 'third_party/libwebrtc/rtc_base/test_echo_server.h')
-rw-r--r-- | third_party/libwebrtc/rtc_base/test_echo_server.h | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/third_party/libwebrtc/rtc_base/test_echo_server.h b/third_party/libwebrtc/rtc_base/test_echo_server.h index 82817624a5..d99ed72f00 100644 --- a/third_party/libwebrtc/rtc_base/test_echo_server.h +++ b/third_party/libwebrtc/rtc_base/test_echo_server.h @@ -21,6 +21,7 @@ #include "absl/memory/memory.h" #include "rtc_base/async_packet_socket.h" #include "rtc_base/async_tcp_socket.h" +#include "rtc_base/network/received_packet.h" #include "rtc_base/socket.h" #include "rtc_base/socket_address.h" #include "rtc_base/third_party/sigslot/sigslot.h" @@ -45,19 +46,17 @@ class TestEchoServer : public sigslot::has_slots<> { Socket* raw_socket = socket->Accept(nullptr); if (raw_socket) { AsyncTCPSocket* packet_socket = new AsyncTCPSocket(raw_socket); - packet_socket->SignalReadPacket.connect(this, &TestEchoServer::OnPacket); + packet_socket->RegisterReceivedPacketCallback( + [&](rtc::AsyncPacketSocket* socket, + const rtc::ReceivedPacket& packet) { OnPacket(socket, packet); }); packet_socket->SubscribeCloseEvent( this, [this](AsyncPacketSocket* s, int err) { OnClose(s, err); }); client_sockets_.push_back(packet_socket); } } - void OnPacket(AsyncPacketSocket* socket, - const char* buf, - size_t size, - const SocketAddress& remote_addr, - const int64_t& /* packet_time_us */) { + void OnPacket(AsyncPacketSocket* socket, const rtc::ReceivedPacket& packet) { rtc::PacketOptions options; - socket->Send(buf, size, options); + socket->Send(packet.payload().data(), packet.payload().size(), options); } void OnClose(AsyncPacketSocket* socket, int err) { ClientList::iterator it = absl::c_find(client_sockets_, socket); |