summaryrefslogtreecommitdiffstats
path: root/remoting/protocol/chromium_socket_factory.cc
diff options
context:
space:
mode:
Diffstat (limited to 'remoting/protocol/chromium_socket_factory.cc')
-rw-r--r--remoting/protocol/chromium_socket_factory.cc9
1 files changed, 8 insertions, 1 deletions
diff --git a/remoting/protocol/chromium_socket_factory.cc b/remoting/protocol/chromium_socket_factory.cc
index 6f9dfeb..773657d 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();