| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 #pragma once | 7 #pragma once |
| 8 | 8 |
| 9 #include <cstring> | 9 #include <cstring> |
| 10 #include <deque> | 10 #include <deque> |
| (...skipping 574 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 585 public: | 585 public: |
| 586 explicit MockClientSocket(net::NetLog* net_log); | 586 explicit MockClientSocket(net::NetLog* net_log); |
| 587 | 587 |
| 588 // Socket implementation. | 588 // Socket implementation. |
| 589 virtual int Read(net::IOBuffer* buf, int buf_len, | 589 virtual int Read(net::IOBuffer* buf, int buf_len, |
| 590 net::OldCompletionCallback* callback) = 0; | 590 net::OldCompletionCallback* callback) = 0; |
| 591 virtual int Read(net::IOBuffer* buf, int buf_len, | 591 virtual int Read(net::IOBuffer* buf, int buf_len, |
| 592 const net::CompletionCallback& callback) = 0; | 592 const net::CompletionCallback& callback) = 0; |
| 593 virtual int Write(net::IOBuffer* buf, int buf_len, | 593 virtual int Write(net::IOBuffer* buf, int buf_len, |
| 594 net::OldCompletionCallback* callback) = 0; | 594 net::OldCompletionCallback* callback) = 0; |
| 595 virtual int Write(net::IOBuffer* buf, int buf_len, |
| 596 const net::CompletionCallback& callback) = 0; |
| 595 virtual bool SetReceiveBufferSize(int32 size) OVERRIDE; | 597 virtual bool SetReceiveBufferSize(int32 size) OVERRIDE; |
| 596 virtual bool SetSendBufferSize(int32 size) OVERRIDE; | 598 virtual bool SetSendBufferSize(int32 size) OVERRIDE; |
| 597 | 599 |
| 598 // StreamSocket implementation. | 600 // StreamSocket implementation. |
| 599 virtual int Connect(net::OldCompletionCallback* callback) = 0; | 601 virtual int Connect(net::OldCompletionCallback* callback) = 0; |
| 600 virtual int Connect(const net::CompletionCallback& callback) = 0; | 602 virtual int Connect(const net::CompletionCallback& callback) = 0; |
| 601 virtual void Disconnect() OVERRIDE; | 603 virtual void Disconnect() OVERRIDE; |
| 602 virtual bool IsConnected() const OVERRIDE; | 604 virtual bool IsConnected() const OVERRIDE; |
| 603 virtual bool IsConnectedAndIdle() const OVERRIDE; | 605 virtual bool IsConnectedAndIdle() const OVERRIDE; |
| 604 virtual int GetPeerAddress(AddressList* address) const OVERRIDE; | 606 virtual int GetPeerAddress(AddressList* address) const OVERRIDE; |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 641 | 643 |
| 642 net::AddressList addresses() const { return addresses_; } | 644 net::AddressList addresses() const { return addresses_; } |
| 643 | 645 |
| 644 // Socket implementation. | 646 // Socket implementation. |
| 645 virtual int Read(net::IOBuffer* buf, int buf_len, | 647 virtual int Read(net::IOBuffer* buf, int buf_len, |
| 646 net::OldCompletionCallback* callback) OVERRIDE; | 648 net::OldCompletionCallback* callback) OVERRIDE; |
| 647 virtual int Read(net::IOBuffer* buf, int buf_len, | 649 virtual int Read(net::IOBuffer* buf, int buf_len, |
| 648 const net::CompletionCallback& callback) OVERRIDE; | 650 const net::CompletionCallback& callback) OVERRIDE; |
| 649 virtual int Write(net::IOBuffer* buf, int buf_len, | 651 virtual int Write(net::IOBuffer* buf, int buf_len, |
| 650 net::OldCompletionCallback* callback) OVERRIDE; | 652 net::OldCompletionCallback* callback) OVERRIDE; |
| 653 virtual int Write(net::IOBuffer* buf, int buf_len, |
| 654 const net::CompletionCallback& callback) OVERRIDE; |
| 651 | 655 |
| 652 // StreamSocket implementation. | 656 // StreamSocket implementation. |
| 653 virtual int Connect(net::OldCompletionCallback* callback) OVERRIDE; | 657 virtual int Connect(net::OldCompletionCallback* callback) OVERRIDE; |
| 654 virtual int Connect(const net::CompletionCallback& callback) OVERRIDE; | 658 virtual int Connect(const net::CompletionCallback& callback) OVERRIDE; |
| 655 virtual void Disconnect() OVERRIDE; | 659 virtual void Disconnect() OVERRIDE; |
| 656 virtual bool IsConnected() const OVERRIDE; | 660 virtual bool IsConnected() const OVERRIDE; |
| 657 virtual bool IsConnectedAndIdle() const OVERRIDE; | 661 virtual bool IsConnectedAndIdle() const OVERRIDE; |
| 658 virtual int GetPeerAddress(AddressList* address) const OVERRIDE; | 662 virtual int GetPeerAddress(AddressList* address) const OVERRIDE; |
| 659 virtual bool WasEverUsed() const OVERRIDE; | 663 virtual bool WasEverUsed() const OVERRIDE; |
| 660 virtual bool UsingTCPFastOpen() const OVERRIDE; | 664 virtual bool UsingTCPFastOpen() const OVERRIDE; |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 696 net::DeterministicSocketData* data); | 700 net::DeterministicSocketData* data); |
| 697 virtual ~DeterministicMockTCPClientSocket(); | 701 virtual ~DeterministicMockTCPClientSocket(); |
| 698 | 702 |
| 699 bool write_pending() const { return write_pending_; } | 703 bool write_pending() const { return write_pending_; } |
| 700 bool read_pending() const { return read_pending_; } | 704 bool read_pending() const { return read_pending_; } |
| 701 | 705 |
| 702 void CompleteWrite(); | 706 void CompleteWrite(); |
| 703 int CompleteRead(); | 707 int CompleteRead(); |
| 704 | 708 |
| 705 // Socket implementation. | 709 // Socket implementation. |
| 706 virtual int Write(net::IOBuffer* buf, int buf_len, | |
| 707 net::OldCompletionCallback* callback) OVERRIDE; | |
| 708 virtual int Read(net::IOBuffer* buf, int buf_len, | 710 virtual int Read(net::IOBuffer* buf, int buf_len, |
| 709 net::OldCompletionCallback* callback) OVERRIDE; | 711 net::OldCompletionCallback* callback) OVERRIDE; |
| 710 virtual int Read(net::IOBuffer* buf, int buf_len, | 712 virtual int Read(net::IOBuffer* buf, int buf_len, |
| 711 const net::CompletionCallback& callback) OVERRIDE; | 713 const net::CompletionCallback& callback) OVERRIDE; |
| 714 virtual int Write(net::IOBuffer* buf, int buf_len, |
| 715 net::OldCompletionCallback* callback) OVERRIDE; |
| 716 virtual int Write(net::IOBuffer* buf, int buf_len, |
| 717 const net::CompletionCallback& callback) OVERRIDE; |
| 712 | 718 |
| 713 // StreamSocket implementation. | 719 // StreamSocket implementation. |
| 714 virtual int Connect(net::OldCompletionCallback* callback) OVERRIDE; | 720 virtual int Connect(net::OldCompletionCallback* callback) OVERRIDE; |
| 715 virtual int Connect(const net::CompletionCallback& callback) OVERRIDE; | 721 virtual int Connect(const net::CompletionCallback& callback) OVERRIDE; |
| 716 virtual void Disconnect() OVERRIDE; | 722 virtual void Disconnect() OVERRIDE; |
| 717 virtual bool IsConnected() const OVERRIDE; | 723 virtual bool IsConnected() const OVERRIDE; |
| 718 virtual bool IsConnectedAndIdle() const OVERRIDE; | 724 virtual bool IsConnectedAndIdle() const OVERRIDE; |
| 719 virtual bool WasEverUsed() const OVERRIDE; | 725 virtual bool WasEverUsed() const OVERRIDE; |
| 720 virtual bool UsingTCPFastOpen() const OVERRIDE; | 726 virtual bool UsingTCPFastOpen() const OVERRIDE; |
| 721 virtual int64 NumBytesRead() const OVERRIDE; | 727 virtual int64 NumBytesRead() const OVERRIDE; |
| 722 virtual base::TimeDelta GetConnectTimeMicros() const OVERRIDE; | 728 virtual base::TimeDelta GetConnectTimeMicros() const OVERRIDE; |
| 723 | 729 |
| 724 // AsyncSocket: | 730 // AsyncSocket: |
| 725 virtual void OnReadComplete(const MockRead& data) OVERRIDE; | 731 virtual void OnReadComplete(const MockRead& data) OVERRIDE; |
| 726 | 732 |
| 727 private: | 733 private: |
| 728 bool write_pending_; | 734 bool write_pending_; |
| 729 net::OldCompletionCallback* write_callback_; | 735 net::OldCompletionCallback* old_write_callback_; |
| 736 net::CompletionCallback write_callback_; |
| 730 int write_result_; | 737 int write_result_; |
| 731 | 738 |
| 732 net::MockRead read_data_; | 739 net::MockRead read_data_; |
| 733 | 740 |
| 734 net::IOBuffer* read_buf_; | 741 net::IOBuffer* read_buf_; |
| 735 int read_buf_len_; | 742 int read_buf_len_; |
| 736 bool read_pending_; | 743 bool read_pending_; |
| 737 net::OldCompletionCallback* old_read_callback_; | 744 net::OldCompletionCallback* old_read_callback_; |
| 738 net::CompletionCallback read_callback_; | 745 net::CompletionCallback read_callback_; |
| 739 net::DeterministicSocketData* data_; | 746 net::DeterministicSocketData* data_; |
| (...skipping 10 matching lines...) Expand all Loading... |
| 750 net::SSLSocketDataProvider* socket); | 757 net::SSLSocketDataProvider* socket); |
| 751 virtual ~MockSSLClientSocket(); | 758 virtual ~MockSSLClientSocket(); |
| 752 | 759 |
| 753 // Socket implementation. | 760 // Socket implementation. |
| 754 virtual int Read(net::IOBuffer* buf, int buf_len, | 761 virtual int Read(net::IOBuffer* buf, int buf_len, |
| 755 net::OldCompletionCallback* callback) OVERRIDE; | 762 net::OldCompletionCallback* callback) OVERRIDE; |
| 756 virtual int Read(net::IOBuffer* buf, int buf_len, | 763 virtual int Read(net::IOBuffer* buf, int buf_len, |
| 757 const net::CompletionCallback& callback) OVERRIDE; | 764 const net::CompletionCallback& callback) OVERRIDE; |
| 758 virtual int Write(net::IOBuffer* buf, int buf_len, | 765 virtual int Write(net::IOBuffer* buf, int buf_len, |
| 759 net::OldCompletionCallback* callback) OVERRIDE; | 766 net::OldCompletionCallback* callback) OVERRIDE; |
| 767 virtual int Write(net::IOBuffer* buf, int buf_len, |
| 768 const net::CompletionCallback& callback) OVERRIDE; |
| 760 | 769 |
| 761 // StreamSocket implementation. | 770 // StreamSocket implementation. |
| 762 virtual int Connect(net::OldCompletionCallback* callback) OVERRIDE; | 771 virtual int Connect(net::OldCompletionCallback* callback) OVERRIDE; |
| 763 virtual int Connect(const net::CompletionCallback& callback) OVERRIDE; | 772 virtual int Connect(const net::CompletionCallback& callback) OVERRIDE; |
| 764 virtual void Disconnect() OVERRIDE; | 773 virtual void Disconnect() OVERRIDE; |
| 765 virtual bool IsConnected() const OVERRIDE; | 774 virtual bool IsConnected() const OVERRIDE; |
| 766 virtual bool WasEverUsed() const OVERRIDE; | 775 virtual bool WasEverUsed() const OVERRIDE; |
| 767 virtual bool UsingTCPFastOpen() const OVERRIDE; | 776 virtual bool UsingTCPFastOpen() const OVERRIDE; |
| 768 virtual int64 NumBytesRead() const OVERRIDE; | 777 virtual int64 NumBytesRead() const OVERRIDE; |
| 769 virtual base::TimeDelta GetConnectTimeMicros() const OVERRIDE; | 778 virtual base::TimeDelta GetConnectTimeMicros() const OVERRIDE; |
| (...skipping 27 matching lines...) Expand all Loading... |
| 797 MockUDPClientSocket(SocketDataProvider* data, net::NetLog* net_log); | 806 MockUDPClientSocket(SocketDataProvider* data, net::NetLog* net_log); |
| 798 virtual ~MockUDPClientSocket(); | 807 virtual ~MockUDPClientSocket(); |
| 799 | 808 |
| 800 // Socket implementation. | 809 // Socket implementation. |
| 801 virtual int Read(net::IOBuffer* buf, int buf_len, | 810 virtual int Read(net::IOBuffer* buf, int buf_len, |
| 802 net::OldCompletionCallback* callback) OVERRIDE; | 811 net::OldCompletionCallback* callback) OVERRIDE; |
| 803 virtual int Read(net::IOBuffer* buf, int buf_len, | 812 virtual int Read(net::IOBuffer* buf, int buf_len, |
| 804 const net::CompletionCallback& callback) OVERRIDE; | 813 const net::CompletionCallback& callback) OVERRIDE; |
| 805 virtual int Write(net::IOBuffer* buf, int buf_len, | 814 virtual int Write(net::IOBuffer* buf, int buf_len, |
| 806 net::OldCompletionCallback* callback) OVERRIDE; | 815 net::OldCompletionCallback* callback) OVERRIDE; |
| 816 virtual int Write(net::IOBuffer* buf, int buf_len, |
| 817 const net::CompletionCallback& callback) OVERRIDE; |
| 807 virtual bool SetReceiveBufferSize(int32 size) OVERRIDE; | 818 virtual bool SetReceiveBufferSize(int32 size) OVERRIDE; |
| 808 virtual bool SetSendBufferSize(int32 size) OVERRIDE; | 819 virtual bool SetSendBufferSize(int32 size) OVERRIDE; |
| 809 | 820 |
| 810 // DatagramSocket implementation. | 821 // DatagramSocket implementation. |
| 811 virtual void Close() OVERRIDE; | 822 virtual void Close() OVERRIDE; |
| 812 virtual int GetPeerAddress(IPEndPoint* address) const OVERRIDE; | 823 virtual int GetPeerAddress(IPEndPoint* address) const OVERRIDE; |
| 813 virtual int GetLocalAddress(IPEndPoint* address) const OVERRIDE; | 824 virtual int GetLocalAddress(IPEndPoint* address) const OVERRIDE; |
| 814 virtual const BoundNetLog& NetLog() const OVERRIDE; | 825 virtual const BoundNetLog& NetLog() const OVERRIDE; |
| 815 | 826 |
| 816 // DatagramClientSocket implementation. | 827 // DatagramClientSocket implementation. |
| (...skipping 244 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1061 | 1072 |
| 1062 extern const char kSOCKS5OkRequest[]; | 1073 extern const char kSOCKS5OkRequest[]; |
| 1063 extern const int kSOCKS5OkRequestLength; | 1074 extern const int kSOCKS5OkRequestLength; |
| 1064 | 1075 |
| 1065 extern const char kSOCKS5OkResponse[]; | 1076 extern const char kSOCKS5OkResponse[]; |
| 1066 extern const int kSOCKS5OkResponseLength; | 1077 extern const int kSOCKS5OkResponseLength; |
| 1067 | 1078 |
| 1068 } // namespace net | 1079 } // namespace net |
| 1069 | 1080 |
| 1070 #endif // NET_SOCKET_SOCKET_TEST_UTIL_H_ | 1081 #endif // NET_SOCKET_SOCKET_TEST_UTIL_H_ |
| OLD | NEW |