Implement UMA and internal data structure for tracking EWOULDBLOCK.

content/browser/renderer_host/p2p/socket_host_tcp.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/browser/renderer_host/p2p/socket_host_tcp.h"
 
 #include "base/sys_byteorder.h"
 #include "content/common/p2p_messages.h"
 #include "ipc/ipc_sender.h"
 #include "jingle/glue/fake_ssl_client_socket.h"
@@ skipping 36 matching lines @@
 P2PSocketHostTcpBase::P2PSocketHostTcpBase(
     IPC::Sender* message_sender,
     int socket_id,
     P2PSocketType type,
     net::URLRequestContextGetter* url_context)
     : P2PSocketHost(message_sender, socket_id),
       write_pending_(false),
       connected_(false),
       type_(type),
       url_context_(url_context) {
+  protocol_type_ = P2PSocketHost::TCP;
 }
 
 P2PSocketHostTcpBase::~P2PSocketHostTcpBase() {
   if (state_ == STATE_OPEN) {
     DCHECK(socket_.get());
     socket_.reset();
   }
 }
 
 bool P2PSocketHostTcpBase::InitAccepted(const net::IPEndPoint& remote_address,
@@ skipping 287 matching lines @@
       OnError();
       return;
     }
   }
 
   DoSend(to, data, options);
 }
 
 void P2PSocketHostTcpBase::WriteOrQueue(
     scoped_refptr<net::DrainableIOBuffer>& buffer) {
+  IncrementTotalSentPackets();
   if (write_buffer_.get()) {
     write_queue_.push(buffer);
+    IncrementDelayedPackets();
+    IncrementDelayedBytes(buffer->size());
     return;
   }
 
   write_buffer_ = buffer;
   DoWrite();
 }
 
 void P2PSocketHostTcpBase::DoWrite() {
   while (write_buffer_.get() && state_ == STATE_OPEN && !write_pending_) {
     int result = socket_->Write(
@@ skipping 17 matching lines @@
   DCHECK(write_buffer_.get());
   if (result >= 0) {
     write_buffer_->DidConsume(result);
     if (write_buffer_->BytesRemaining() == 0) {
       message_sender_->Send(new P2PMsg_OnSendComplete(id_));
       if (write_queue_.empty()) {
         write_buffer_ = NULL;
       } 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) {
     write_pending_ = true;
   } else {
     LOG(ERROR) << "Error when sending data in TCP socket: " << result;
     OnError();
   }
 }
 
@@ skipping 188 matching lines @@
   } else {
     packet_size += kTurnChannelDataHeaderSize;
     // Calculate any padding if present.
     if (packet_size % 4)
       *pad_bytes = 4 - packet_size % 4;
   }
   return packet_size;
 }
 
 }  // namespace content