Index: remoting/protocol/chromium_socket_factory.cc |
diff --git a/remoting/protocol/chromium_socket_factory.cc b/remoting/protocol/chromium_socket_factory.cc |
index 6f9dfeb12a66f0cab431661528b235afdc248431..773657d54888445a2d022fc4875dbe091130ea39 100644 |
--- a/remoting/protocol/chromium_socket_factory.cc |
+++ b/remoting/protocol/chromium_socket_factory.cc |
@@ -10,12 +10,14 @@ |
#include "base/logging.h" |
#include "base/macros.h" |
#include "base/memory/scoped_ptr.h" |
+#include "base/time/time.h" |
#include "jingle/glue/utils.h" |
#include "net/base/io_buffer.h" |
#include "net/base/ip_endpoint.h" |
#include "net/base/net_errors.h" |
#include "net/udp/udp_server_socket.h" |
#include "remoting/protocol/socket_util.h" |
+#include "third_party/libjingle/source/talk/media/base/rtputils.h" |
#include "third_party/webrtc/base/asyncpacketsocket.h" |
#include "third_party/webrtc/base/nethelpers.h" |
@@ -194,7 +196,12 @@ int UdpPacketSocket::SendTo(const void* data, size_t data_size, |
return EWOULDBLOCK; |
} |
- send_queue_.push_back(PendingPacket(data, data_size, endpoint)); |
+ PendingPacket packet(data, data_size, endpoint); |
+ cricket::ApplyPacketOptions( |
+ reinterpret_cast<uint8_t*>(packet.data->data()), data_size, |
+ options.packet_time_params, |
+ (base::TimeTicks::Now() - base::TimeTicks()).InMilliseconds()); |
+ send_queue_.push_back(packet); |
send_queue_size_ += data_size; |
DoSend(); |