| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 #ifndef NET_SOCKET_SOCKET_TEST_UTIL_H_ | 5 #ifndef NET_SOCKET_SOCKET_TEST_UTIL_H_ |
| 6 #define NET_SOCKET_SOCKET_TEST_UTIL_H_ | 6 #define NET_SOCKET_SOCKET_TEST_UTIL_H_ |
| 7 | 7 |
| 8 #include <cstring> | 8 #include <cstring> |
| 9 #include <deque> | 9 #include <deque> |
| 10 #include <string> | 10 #include <string> |
| (...skipping 647 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 658 const CompletionCallback& callback) OVERRIDE; | 658 const CompletionCallback& callback) OVERRIDE; |
| 659 | 659 |
| 660 // StreamSocket implementation. | 660 // StreamSocket implementation. |
| 661 virtual int Connect(const CompletionCallback& callback) OVERRIDE; | 661 virtual int Connect(const CompletionCallback& callback) OVERRIDE; |
| 662 virtual void Disconnect() OVERRIDE; | 662 virtual void Disconnect() OVERRIDE; |
| 663 virtual bool IsConnected() const OVERRIDE; | 663 virtual bool IsConnected() const OVERRIDE; |
| 664 virtual bool IsConnectedAndIdle() const OVERRIDE; | 664 virtual bool IsConnectedAndIdle() const OVERRIDE; |
| 665 virtual int GetPeerAddress(IPEndPoint* address) const OVERRIDE; | 665 virtual int GetPeerAddress(IPEndPoint* address) const OVERRIDE; |
| 666 virtual bool WasEverUsed() const OVERRIDE; | 666 virtual bool WasEverUsed() const OVERRIDE; |
| 667 virtual bool UsingTCPFastOpen() const OVERRIDE; | 667 virtual bool UsingTCPFastOpen() const OVERRIDE; |
| 668 virtual int64 NumBytesRead() const OVERRIDE; | |
| 669 virtual base::TimeDelta GetConnectTimeMicros() const OVERRIDE; | |
| 670 virtual bool WasNpnNegotiated() const OVERRIDE; | 668 virtual bool WasNpnNegotiated() const OVERRIDE; |
| 671 virtual bool GetSSLInfo(SSLInfo* ssl_info) OVERRIDE; | 669 virtual bool GetSSLInfo(SSLInfo* ssl_info) OVERRIDE; |
| 672 | 670 |
| 673 // AsyncSocket: | 671 // AsyncSocket: |
| 674 virtual void OnReadComplete(const MockRead& data) OVERRIDE; | 672 virtual void OnReadComplete(const MockRead& data) OVERRIDE; |
| 675 | 673 |
| 676 private: | 674 private: |
| 677 int CompleteRead(); | 675 int CompleteRead(); |
| 678 | 676 |
| 679 AddressList addresses_; | 677 AddressList addresses_; |
| 680 | 678 |
| 681 SocketDataProvider* data_; | 679 SocketDataProvider* data_; |
| 682 int read_offset_; | 680 int read_offset_; |
| 683 int num_bytes_read_; | |
| 684 MockRead read_data_; | 681 MockRead read_data_; |
| 685 bool need_read_data_; | 682 bool need_read_data_; |
| 686 | 683 |
| 687 // True if the peer has closed the connection. This allows us to simulate | 684 // True if the peer has closed the connection. This allows us to simulate |
| 688 // the recv(..., MSG_PEEK) call in the IsConnectedAndIdle method of the real | 685 // the recv(..., MSG_PEEK) call in the IsConnectedAndIdle method of the real |
| 689 // TCPClientSocket. | 686 // TCPClientSocket. |
| 690 bool peer_closed_connection_; | 687 bool peer_closed_connection_; |
| 691 | 688 |
| 692 // While an asynchronous IO is pending, we save our user-buffer state. | 689 // While an asynchronous IO is pending, we save our user-buffer state. |
| 693 IOBuffer* pending_buf_; | 690 IOBuffer* pending_buf_; |
| (...skipping 24 matching lines...) Expand all Loading... |
| 718 virtual int Read(IOBuffer* buf, int buf_len, | 715 virtual int Read(IOBuffer* buf, int buf_len, |
| 719 const CompletionCallback& callback) OVERRIDE; | 716 const CompletionCallback& callback) OVERRIDE; |
| 720 | 717 |
| 721 // StreamSocket implementation. | 718 // StreamSocket implementation. |
| 722 virtual int Connect(const CompletionCallback& callback) OVERRIDE; | 719 virtual int Connect(const CompletionCallback& callback) OVERRIDE; |
| 723 virtual void Disconnect() OVERRIDE; | 720 virtual void Disconnect() OVERRIDE; |
| 724 virtual bool IsConnected() const OVERRIDE; | 721 virtual bool IsConnected() const OVERRIDE; |
| 725 virtual bool IsConnectedAndIdle() const OVERRIDE; | 722 virtual bool IsConnectedAndIdle() const OVERRIDE; |
| 726 virtual bool WasEverUsed() const OVERRIDE; | 723 virtual bool WasEverUsed() const OVERRIDE; |
| 727 virtual bool UsingTCPFastOpen() const OVERRIDE; | 724 virtual bool UsingTCPFastOpen() const OVERRIDE; |
| 728 virtual int64 NumBytesRead() const OVERRIDE; | |
| 729 virtual base::TimeDelta GetConnectTimeMicros() const OVERRIDE; | |
| 730 virtual bool WasNpnNegotiated() const OVERRIDE; | 725 virtual bool WasNpnNegotiated() const OVERRIDE; |
| 731 virtual bool GetSSLInfo(SSLInfo* ssl_info) OVERRIDE; | 726 virtual bool GetSSLInfo(SSLInfo* ssl_info) OVERRIDE; |
| 732 | 727 |
| 733 // AsyncSocket: | 728 // AsyncSocket: |
| 734 virtual void OnReadComplete(const MockRead& data) OVERRIDE; | 729 virtual void OnReadComplete(const MockRead& data) OVERRIDE; |
| 735 | 730 |
| 736 private: | 731 private: |
| 737 bool write_pending_; | 732 bool write_pending_; |
| 738 CompletionCallback write_callback_; | 733 CompletionCallback write_callback_; |
| 739 int write_result_; | 734 int write_result_; |
| (...skipping 22 matching lines...) Expand all Loading... |
| 762 const CompletionCallback& callback) OVERRIDE; | 757 const CompletionCallback& callback) OVERRIDE; |
| 763 virtual int Write(IOBuffer* buf, int buf_len, | 758 virtual int Write(IOBuffer* buf, int buf_len, |
| 764 const CompletionCallback& callback) OVERRIDE; | 759 const CompletionCallback& callback) OVERRIDE; |
| 765 | 760 |
| 766 // StreamSocket implementation. | 761 // StreamSocket implementation. |
| 767 virtual int Connect(const CompletionCallback& callback) OVERRIDE; | 762 virtual int Connect(const CompletionCallback& callback) OVERRIDE; |
| 768 virtual void Disconnect() OVERRIDE; | 763 virtual void Disconnect() OVERRIDE; |
| 769 virtual bool IsConnected() const OVERRIDE; | 764 virtual bool IsConnected() const OVERRIDE; |
| 770 virtual bool WasEverUsed() const OVERRIDE; | 765 virtual bool WasEverUsed() const OVERRIDE; |
| 771 virtual bool UsingTCPFastOpen() const OVERRIDE; | 766 virtual bool UsingTCPFastOpen() const OVERRIDE; |
| 772 virtual int64 NumBytesRead() const OVERRIDE; | |
| 773 virtual int GetPeerAddress(IPEndPoint* address) const OVERRIDE; | 767 virtual int GetPeerAddress(IPEndPoint* address) const OVERRIDE; |
| 774 virtual base::TimeDelta GetConnectTimeMicros() const OVERRIDE; | |
| 775 virtual bool WasNpnNegotiated() const OVERRIDE; | 768 virtual bool WasNpnNegotiated() const OVERRIDE; |
| 776 virtual bool GetSSLInfo(SSLInfo* ssl_info) OVERRIDE; | 769 virtual bool GetSSLInfo(SSLInfo* ssl_info) OVERRIDE; |
| 777 | 770 |
| 778 // SSLClientSocket implementation. | 771 // SSLClientSocket implementation. |
| 779 virtual void GetSSLCertRequestInfo( | 772 virtual void GetSSLCertRequestInfo( |
| 780 SSLCertRequestInfo* cert_request_info) OVERRIDE; | 773 SSLCertRequestInfo* cert_request_info) OVERRIDE; |
| 781 virtual NextProtoStatus GetNextProto(std::string* proto, | 774 virtual NextProtoStatus GetNextProto(std::string* proto, |
| 782 std::string* server_protos) OVERRIDE; | 775 std::string* server_protos) OVERRIDE; |
| 783 virtual bool set_was_npn_negotiated(bool negotiated) OVERRIDE; | 776 virtual bool set_was_npn_negotiated(bool negotiated) OVERRIDE; |
| 784 virtual void set_protocol_negotiated( | 777 virtual void set_protocol_negotiated( |
| (...skipping 289 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1074 | 1067 |
| 1075 extern const char kSOCKS5OkRequest[]; | 1068 extern const char kSOCKS5OkRequest[]; |
| 1076 extern const int kSOCKS5OkRequestLength; | 1069 extern const int kSOCKS5OkRequestLength; |
| 1077 | 1070 |
| 1078 extern const char kSOCKS5OkResponse[]; | 1071 extern const char kSOCKS5OkResponse[]; |
| 1079 extern const int kSOCKS5OkResponseLength; | 1072 extern const int kSOCKS5OkResponseLength; |
| 1080 | 1073 |
| 1081 } // namespace net | 1074 } // namespace net |
| 1082 | 1075 |
| 1083 #endif // NET_SOCKET_SOCKET_TEST_UTIL_H_ | 1076 #endif // NET_SOCKET_SOCKET_TEST_UTIL_H_ |
| OLD | NEW |