| 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/socket/tcp_socket.h" | 5 #include "net/socket/tcp_socket.h" |
| 6 | 6 |
| 7 #include <errno.h> | 7 #include <errno.h> |
| 8 #include <netinet/tcp.h> | 8 #include <netinet/tcp.h> |
| 9 #include <sys/socket.h> | 9 #include <sys/socket.h> |
| 10 | 10 |
| 11 #include "base/bind.h" | 11 #include "base/bind.h" |
| 12 #include "base/files/file_path.h" |
| 13 #include "base/files/file_util.h" |
| 12 #include "base/logging.h" | 14 #include "base/logging.h" |
| 13 #include "base/metrics/histogram.h" | 15 #include "base/metrics/histogram.h" |
| 14 #include "base/metrics/stats_counters.h" | |
| 15 #include "base/posix/eintr_wrapper.h" | 16 #include "base/posix/eintr_wrapper.h" |
| 16 #include "base/task_runner_util.h" | 17 #include "base/task_runner_util.h" |
| 17 #include "base/threading/worker_pool.h" | 18 #include "base/threading/worker_pool.h" |
| 18 #include "net/base/address_list.h" | 19 #include "net/base/address_list.h" |
| 19 #include "net/base/connection_type_histograms.h" | 20 #include "net/base/connection_type_histograms.h" |
| 20 #include "net/base/io_buffer.h" | 21 #include "net/base/io_buffer.h" |
| 21 #include "net/base/ip_endpoint.h" | 22 #include "net/base/ip_endpoint.h" |
| 22 #include "net/base/net_errors.h" | 23 #include "net/base/net_errors.h" |
| 23 #include "net/base/net_util.h" | 24 #include "net/base/net_util.h" |
| 24 #include "net/base/network_activity_monitor.h" | 25 #include "net/base/network_activity_monitor.h" |
| (...skipping 506 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 531 if (rv == ERR_ADDRESS_UNREACHABLE && NetworkChangeNotifier::IsOffline()) | 532 if (rv == ERR_ADDRESS_UNREACHABLE && NetworkChangeNotifier::IsOffline()) |
| 532 rv = ERR_INTERNET_DISCONNECTED; | 533 rv = ERR_INTERNET_DISCONNECTED; |
| 533 | 534 |
| 534 if (!logging_multiple_connect_attempts_) | 535 if (!logging_multiple_connect_attempts_) |
| 535 LogConnectEnd(rv); | 536 LogConnectEnd(rv); |
| 536 | 537 |
| 537 return rv; | 538 return rv; |
| 538 } | 539 } |
| 539 | 540 |
| 540 void TCPSocketLibevent::LogConnectBegin(const AddressList& addresses) const { | 541 void TCPSocketLibevent::LogConnectBegin(const AddressList& addresses) const { |
| 541 base::StatsCounter connects("tcp.connect"); | |
| 542 connects.Increment(); | |
| 543 | |
| 544 net_log_.BeginEvent(NetLog::TYPE_TCP_CONNECT, | 542 net_log_.BeginEvent(NetLog::TYPE_TCP_CONNECT, |
| 545 addresses.CreateNetLogCallback()); | 543 addresses.CreateNetLogCallback()); |
| 546 } | 544 } |
| 547 | 545 |
| 548 void TCPSocketLibevent::LogConnectEnd(int net_error) const { | 546 void TCPSocketLibevent::LogConnectEnd(int net_error) const { |
| 549 if (net_error != OK) { | 547 if (net_error != OK) { |
| 550 net_log_.EndEventWithNetErrorCode(NetLog::TYPE_TCP_CONNECT, net_error); | 548 net_log_.EndEventWithNetErrorCode(NetLog::TYPE_TCP_CONNECT, net_error); |
| 551 return; | 549 return; |
| 552 } | 550 } |
| 553 | 551 |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 590 else | 588 else |
| 591 g_tcp_fastopen_has_failed = true; | 589 g_tcp_fastopen_has_failed = true; |
| 592 UpdateTCPFastOpenStatusAfterRead(); | 590 UpdateTCPFastOpenStatusAfterRead(); |
| 593 } | 591 } |
| 594 | 592 |
| 595 if (rv < 0) { | 593 if (rv < 0) { |
| 596 net_log_.AddEvent(NetLog::TYPE_SOCKET_READ_ERROR, | 594 net_log_.AddEvent(NetLog::TYPE_SOCKET_READ_ERROR, |
| 597 CreateNetLogSocketErrorCallback(rv, errno)); | 595 CreateNetLogSocketErrorCallback(rv, errno)); |
| 598 return rv; | 596 return rv; |
| 599 } | 597 } |
| 600 | |
| 601 base::StatsCounter read_bytes("tcp.read_bytes"); | |
| 602 read_bytes.Add(rv); | |
| 603 net_log_.AddByteTransferEvent(NetLog::TYPE_SOCKET_BYTES_RECEIVED, rv, | 598 net_log_.AddByteTransferEvent(NetLog::TYPE_SOCKET_BYTES_RECEIVED, rv, |
| 604 buf->data()); | 599 buf->data()); |
| 605 NetworkActivityMonitor::GetInstance()->IncrementBytesReceived(rv); | 600 NetworkActivityMonitor::GetInstance()->IncrementBytesReceived(rv); |
| 606 | 601 |
| 607 return rv; | 602 return rv; |
| 608 } | 603 } |
| 609 | 604 |
| 610 void TCPSocketLibevent::WriteCompleted(const scoped_refptr<IOBuffer>& buf, | 605 void TCPSocketLibevent::WriteCompleted(const scoped_refptr<IOBuffer>& buf, |
| 611 const CompletionCallback& callback, | 606 const CompletionCallback& callback, |
| 612 int rv) { | 607 int rv) { |
| (...skipping 11 matching lines...) Expand all Loading... |
| 624 // FastOpen is turned off on _any_ error. Implement optimizations, | 619 // FastOpen is turned off on _any_ error. Implement optimizations, |
| 625 // such as turning off TCP FastOpen on more specific errors, and | 620 // such as turning off TCP FastOpen on more specific errors, and |
| 626 // re-attempting TCP FastOpen after a certain amount of time has passed. | 621 // re-attempting TCP FastOpen after a certain amount of time has passed. |
| 627 tcp_fastopen_status_ = TCP_FASTOPEN_ERROR; | 622 tcp_fastopen_status_ = TCP_FASTOPEN_ERROR; |
| 628 g_tcp_fastopen_has_failed = true; | 623 g_tcp_fastopen_has_failed = true; |
| 629 } | 624 } |
| 630 net_log_.AddEvent(NetLog::TYPE_SOCKET_WRITE_ERROR, | 625 net_log_.AddEvent(NetLog::TYPE_SOCKET_WRITE_ERROR, |
| 631 CreateNetLogSocketErrorCallback(rv, errno)); | 626 CreateNetLogSocketErrorCallback(rv, errno)); |
| 632 return rv; | 627 return rv; |
| 633 } | 628 } |
| 634 | |
| 635 base::StatsCounter write_bytes("tcp.write_bytes"); | |
| 636 write_bytes.Add(rv); | |
| 637 net_log_.AddByteTransferEvent(NetLog::TYPE_SOCKET_BYTES_SENT, rv, | 629 net_log_.AddByteTransferEvent(NetLog::TYPE_SOCKET_BYTES_SENT, rv, |
| 638 buf->data()); | 630 buf->data()); |
| 639 NetworkActivityMonitor::GetInstance()->IncrementBytesSent(rv); | 631 NetworkActivityMonitor::GetInstance()->IncrementBytesSent(rv); |
| 640 return rv; | 632 return rv; |
| 641 } | 633 } |
| 642 | 634 |
| 643 int TCPSocketLibevent::TcpFastOpenWrite( | 635 int TCPSocketLibevent::TcpFastOpenWrite( |
| 644 IOBuffer* buf, | 636 IOBuffer* buf, |
| 645 int buf_len, | 637 int buf_len, |
| 646 const CompletionCallback& callback) { | 638 const CompletionCallback& callback) { |
| (...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 740 } | 732 } |
| 741 } else { | 733 } else { |
| 742 tcp_fastopen_status_ = | 734 tcp_fastopen_status_ = |
| 743 (tcp_fastopen_status_ == TCP_FASTOPEN_FAST_CONNECT_RETURN ? | 735 (tcp_fastopen_status_ == TCP_FASTOPEN_FAST_CONNECT_RETURN ? |
| 744 TCP_FASTOPEN_SYN_DATA_GETSOCKOPT_FAILED : | 736 TCP_FASTOPEN_SYN_DATA_GETSOCKOPT_FAILED : |
| 745 TCP_FASTOPEN_NO_SYN_DATA_GETSOCKOPT_FAILED); | 737 TCP_FASTOPEN_NO_SYN_DATA_GETSOCKOPT_FAILED); |
| 746 } | 738 } |
| 747 } | 739 } |
| 748 | 740 |
| 749 } // namespace net | 741 } // namespace net |
| OLD | NEW |