Index: content/browser/renderer_host/p2p/socket_host_tcp.cc |
diff --git a/content/browser/renderer_host/p2p/socket_host_tcp.cc b/content/browser/renderer_host/p2p/socket_host_tcp.cc |
index 1ee1627b5d72d9f1175415c1db67b61052b5aa25..05db881fe23b8fc386b536a586ebaeeaefa3f488 100644 |
--- a/content/browser/renderer_host/p2p/socket_host_tcp.cc |
+++ b/content/browser/renderer_host/p2p/socket_host_tcp.cc |
@@ -54,6 +54,7 @@ P2PSocketHostTcpBase::P2PSocketHostTcpBase( |
connected_(false), |
type_(type), |
url_context_(url_context) { |
+ protocol_type_ = P2PSocketHost::TCP; |
} |
P2PSocketHostTcpBase::~P2PSocketHostTcpBase() { |
@@ -361,8 +362,11 @@ void P2PSocketHostTcpBase::Send(const net::IPEndPoint& to, |
void P2PSocketHostTcpBase::WriteOrQueue( |
scoped_refptr<net::DrainableIOBuffer>& buffer) { |
+ IncrementTotalSentPackets(); |
if (write_buffer_.get()) { |
write_queue_.push(buffer); |
+ IncrementDelayedPackets(); |
+ IncrementDelayedBytes(buffer->size()); |
return; |
} |
@@ -400,6 +404,8 @@ void P2PSocketHostTcpBase::HandleWriteResult(int result) { |
} else { |
write_buffer_ = write_queue_.front(); |
write_queue_.pop(); |
+ // Update how many bytes are still waiting to be sent. |
+ DecrementDelayedBytes(write_buffer_->size()); |
} |
} |
} else if (result == net::ERR_IO_PENDING) { |