OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "net/quic/quic_default_packet_writer.h" | 5 #include "net/quic/quic_default_packet_writer.h" |
6 | 6 |
7 #include "base/location.h" | 7 #include "base/location.h" |
8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 #include "base/metrics/histogram.h" |
9 #include "base/metrics/sparse_histogram.h" | 10 #include "base/metrics/sparse_histogram.h" |
10 #include "net/base/io_buffer.h" | 11 #include "net/base/io_buffer.h" |
11 #include "net/base/net_errors.h" | 12 #include "net/base/net_errors.h" |
12 | 13 |
13 namespace net { | 14 namespace net { |
14 | 15 |
15 QuicDefaultPacketWriter::QuicDefaultPacketWriter() : weak_factory_(this) { | 16 QuicDefaultPacketWriter::QuicDefaultPacketWriter() : weak_factory_(this) { |
16 } | 17 } |
17 | 18 |
18 QuicDefaultPacketWriter::QuicDefaultPacketWriter(DatagramClientSocket* socket) | 19 QuicDefaultPacketWriter::QuicDefaultPacketWriter(DatagramClientSocket* socket) |
19 : socket_(socket), | 20 : socket_(socket), |
20 write_blocked_(false), | 21 write_blocked_(false), |
21 weak_factory_(this) { | 22 weak_factory_(this) { |
22 } | 23 } |
23 | 24 |
24 QuicDefaultPacketWriter::~QuicDefaultPacketWriter() {} | 25 QuicDefaultPacketWriter::~QuicDefaultPacketWriter() {} |
25 | 26 |
26 WriteResult QuicDefaultPacketWriter::WritePacket( | 27 WriteResult QuicDefaultPacketWriter::WritePacket( |
27 const char* buffer, size_t buf_len, | 28 const char* buffer, |
| 29 size_t buf_len, |
28 const net::IPAddressNumber& self_address, | 30 const net::IPAddressNumber& self_address, |
29 const net::IPEndPoint& peer_address) { | 31 const net::IPEndPoint& peer_address) { |
30 scoped_refptr<StringIOBuffer> buf( | 32 scoped_refptr<StringIOBuffer> buf( |
31 new StringIOBuffer(std::string(buffer, buf_len))); | 33 new StringIOBuffer(std::string(buffer, buf_len))); |
32 DCHECK(!IsWriteBlocked()); | 34 DCHECK(!IsWriteBlocked()); |
| 35 base::TimeTicks now = base::TimeTicks::Now(); |
33 int rv = socket_->Write(buf.get(), | 36 int rv = socket_->Write(buf.get(), |
34 buf_len, | 37 buf_len, |
35 base::Bind(&QuicDefaultPacketWriter::OnWriteComplete, | 38 base::Bind(&QuicDefaultPacketWriter::OnWriteComplete, |
36 weak_factory_.GetWeakPtr())); | 39 weak_factory_.GetWeakPtr())); |
37 WriteStatus status = WRITE_STATUS_OK; | 40 WriteStatus status = WRITE_STATUS_OK; |
38 if (rv < 0) { | 41 if (rv < 0) { |
39 if (rv != ERR_IO_PENDING) { | 42 if (rv != ERR_IO_PENDING) { |
40 UMA_HISTOGRAM_SPARSE_SLOWLY("Net.QuicSession.WriteError", -rv); | 43 UMA_HISTOGRAM_SPARSE_SLOWLY("Net.QuicSession.WriteError", -rv); |
41 status = WRITE_STATUS_ERROR; | 44 status = WRITE_STATUS_ERROR; |
42 } else { | 45 } else { |
43 status = WRITE_STATUS_BLOCKED; | 46 status = WRITE_STATUS_BLOCKED; |
44 write_blocked_ = true; | 47 write_blocked_ = true; |
45 } | 48 } |
46 } | 49 } |
47 | 50 |
| 51 base::TimeDelta delta = base::TimeTicks::Now() - now; |
| 52 if (status == WRITE_STATUS_OK) { |
| 53 UMA_HISTOGRAM_TIMES("Net.QuicSession.PacketWriteTime.Synchronous", delta); |
| 54 } else if (status == WRITE_STATUS_BLOCKED) { |
| 55 UMA_HISTOGRAM_TIMES("Net.QuicSession.PacketWriteTime.Asynchronous", delta); |
| 56 } |
| 57 |
48 return WriteResult(status, rv); | 58 return WriteResult(status, rv); |
49 } | 59 } |
50 | 60 |
51 bool QuicDefaultPacketWriter::IsWriteBlockedDataBuffered() const { | 61 bool QuicDefaultPacketWriter::IsWriteBlockedDataBuffered() const { |
52 // Chrome sockets' Write() methods buffer the data until the Write is | 62 // Chrome sockets' Write() methods buffer the data until the Write is |
53 // permitted. | 63 // permitted. |
54 return true; | 64 return true; |
55 } | 65 } |
56 | 66 |
57 bool QuicDefaultPacketWriter::IsWriteBlocked() const { | 67 bool QuicDefaultPacketWriter::IsWriteBlocked() const { |
58 return write_blocked_; | 68 return write_blocked_; |
59 } | 69 } |
60 | 70 |
61 void QuicDefaultPacketWriter::SetWritable() { | 71 void QuicDefaultPacketWriter::SetWritable() { |
62 write_blocked_ = false; | 72 write_blocked_ = false; |
63 } | 73 } |
64 | 74 |
65 void QuicDefaultPacketWriter::OnWriteComplete(int rv) { | 75 void QuicDefaultPacketWriter::OnWriteComplete(int rv) { |
66 DCHECK_NE(rv, ERR_IO_PENDING); | 76 DCHECK_NE(rv, ERR_IO_PENDING); |
67 write_blocked_ = false; | 77 write_blocked_ = false; |
68 if (rv < 0) { | 78 if (rv < 0) { |
69 connection_->OnWriteError(rv); | 79 connection_->OnWriteError(rv); |
70 } | 80 } |
71 connection_->OnCanWrite(); | 81 connection_->OnCanWrite(); |
72 } | 82 } |
73 | 83 |
74 } // namespace net | 84 } // namespace net |
OLD | NEW |