| 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 275 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 286 DynamicSocketDataProvider(); | 286 DynamicSocketDataProvider(); |
| 287 ~DynamicSocketDataProvider() override; | 287 ~DynamicSocketDataProvider() override; |
| 288 | 288 |
| 289 int short_read_limit() const { return short_read_limit_; } | 289 int short_read_limit() const { return short_read_limit_; } |
| 290 void set_short_read_limit(int limit) { short_read_limit_ = limit; } | 290 void set_short_read_limit(int limit) { short_read_limit_ = limit; } |
| 291 | 291 |
| 292 void allow_unconsumed_reads(bool allow) { allow_unconsumed_reads_ = allow; } | 292 void allow_unconsumed_reads(bool allow) { allow_unconsumed_reads_ = allow; } |
| 293 | 293 |
| 294 // SocketDataProvider implementation. | 294 // SocketDataProvider implementation. |
| 295 MockRead GetNextRead() override; | 295 MockRead GetNextRead() override; |
| 296 virtual MockWriteResult OnWrite(const std::string& data) = 0; | 296 MockWriteResult OnWrite(const std::string& data) override = 0; |
| 297 void Reset() override; | 297 void Reset() override; |
| 298 | 298 |
| 299 protected: | 299 protected: |
| 300 // The next time there is a read from this socket, it will return |data|. | 300 // The next time there is a read from this socket, it will return |data|. |
| 301 // Before calling SimulateRead next time, the previous data must be consumed. | 301 // Before calling SimulateRead next time, the previous data must be consumed. |
| 302 void SimulateRead(const char* data, size_t length); | 302 void SimulateRead(const char* data, size_t length); |
| 303 void SimulateRead(const char* data) { SimulateRead(data, std::strlen(data)); } | 303 void SimulateRead(const char* data) { SimulateRead(data, std::strlen(data)); } |
| 304 | 304 |
| 305 private: | 305 private: |
| 306 std::deque<MockRead> reads_; | 306 std::deque<MockRead> reads_; |
| (...skipping 368 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 675 class MockClientSocket : public SSLClientSocket { | 675 class MockClientSocket : public SSLClientSocket { |
| 676 public: | 676 public: |
| 677 // Value returned by GetTLSUniqueChannelBinding(). | 677 // Value returned by GetTLSUniqueChannelBinding(). |
| 678 static const char kTlsUnique[]; | 678 static const char kTlsUnique[]; |
| 679 | 679 |
| 680 // The BoundNetLog is needed to test LoadTimingInfo, which uses NetLog IDs as | 680 // The BoundNetLog is needed to test LoadTimingInfo, which uses NetLog IDs as |
| 681 // unique socket IDs. | 681 // unique socket IDs. |
| 682 explicit MockClientSocket(const BoundNetLog& net_log); | 682 explicit MockClientSocket(const BoundNetLog& net_log); |
| 683 | 683 |
| 684 // Socket implementation. | 684 // Socket implementation. |
| 685 virtual int Read(IOBuffer* buf, | 685 int Read(IOBuffer* buf, |
| 686 int buf_len, | 686 int buf_len, |
| 687 const CompletionCallback& callback) = 0; | 687 const CompletionCallback& callback) override = 0; |
| 688 virtual int Write(IOBuffer* buf, | 688 int Write(IOBuffer* buf, |
| 689 int buf_len, | 689 int buf_len, |
| 690 const CompletionCallback& callback) = 0; | 690 const CompletionCallback& callback) override = 0; |
| 691 int SetReceiveBufferSize(int32 size) override; | 691 int SetReceiveBufferSize(int32 size) override; |
| 692 int SetSendBufferSize(int32 size) override; | 692 int SetSendBufferSize(int32 size) override; |
| 693 | 693 |
| 694 // StreamSocket implementation. | 694 // StreamSocket implementation. |
| 695 virtual int Connect(const CompletionCallback& callback) = 0; | 695 int Connect(const CompletionCallback& callback) override = 0; |
| 696 void Disconnect() override; | 696 void Disconnect() override; |
| 697 bool IsConnected() const override; | 697 bool IsConnected() const override; |
| 698 bool IsConnectedAndIdle() const override; | 698 bool IsConnectedAndIdle() const override; |
| 699 int GetPeerAddress(IPEndPoint* address) const override; | 699 int GetPeerAddress(IPEndPoint* address) const override; |
| 700 int GetLocalAddress(IPEndPoint* address) const override; | 700 int GetLocalAddress(IPEndPoint* address) const override; |
| 701 const BoundNetLog& NetLog() const override; | 701 const BoundNetLog& NetLog() const override; |
| 702 void SetSubresourceSpeculation() override {} | 702 void SetSubresourceSpeculation() override {} |
| 703 void SetOmniboxSpeculation() override {} | 703 void SetOmniboxSpeculation() override {} |
| 704 | 704 |
| 705 // SSLClientSocket implementation. | 705 // SSLClientSocket implementation. |
| (...skipping 621 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1327 | 1327 |
| 1328 extern const char kSOCKS5OkRequest[]; | 1328 extern const char kSOCKS5OkRequest[]; |
| 1329 extern const int kSOCKS5OkRequestLength; | 1329 extern const int kSOCKS5OkRequestLength; |
| 1330 | 1330 |
| 1331 extern const char kSOCKS5OkResponse[]; | 1331 extern const char kSOCKS5OkResponse[]; |
| 1332 extern const int kSOCKS5OkResponseLength; | 1332 extern const int kSOCKS5OkResponseLength; |
| 1333 | 1333 |
| 1334 } // namespace net | 1334 } // namespace net |
| 1335 | 1335 |
| 1336 #endif // NET_SOCKET_SOCKET_TEST_UTIL_H_ | 1336 #endif // NET_SOCKET_SOCKET_TEST_UTIL_H_ |
| OLD | NEW |