Index: content/browser/renderer_host/p2p/socket_host_udp.cc |
diff --git a/content/browser/renderer_host/p2p/socket_host_udp.cc b/content/browser/renderer_host/p2p/socket_host_udp.cc |
index 3833b62d03b1b19536896498f75e7ff90ba60f40..8d38e0f66d7ecd6a0be319886d9ba847d31c47cf 100644 |
--- a/content/browser/renderer_host/p2p/socket_host_udp.cc |
+++ b/content/browser/renderer_host/p2p/socket_host_udp.cc |
@@ -75,6 +75,7 @@ P2PSocketHostUdp::P2PSocketHostUdp(IPC::Sender* message_sender, |
send_pending_(false), |
last_dscp_(net::DSCP_CS0), |
throttler_(throttler) { |
+ protocol_type_ = P2PSocketHost::UDP; |
} |
P2PSocketHostUdp::~P2PSocketHostUdp() { |
@@ -213,6 +214,9 @@ void P2PSocketHostUdp::Send(const net::IPEndPoint& to, |
if (send_pending_) { |
send_queue_.push_back(PendingPacket(to, data, options, packet_id)); |
+ if (send_queue_.size() > send_queue_length_max_) { |
+ send_queue_length_max_ = send_queue_.size(); |
+ } |
} else { |
// TODO(mallinath: Remove unnecessary memcpy in this case. |
PendingPacket packet(to, data, options, packet_id); |