| 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 247 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 258 // Returns true if |data| is valid data for the next write. In order | 258 // Returns true if |data| is valid data for the next write. In order |
| 259 // to support short writes, the next write may be longer than |data| | 259 // to support short writes, the next write may be longer than |data| |
| 260 // in which case this method will still return true. | 260 // in which case this method will still return true. |
| 261 bool VerifyWriteData(const std::string& data); | 261 bool VerifyWriteData(const std::string& data); |
| 262 | 262 |
| 263 size_t read_index() const { return read_index_; } | 263 size_t read_index() const { return read_index_; } |
| 264 size_t write_index() const { return write_index_; } | 264 size_t write_index() const { return write_index_; } |
| 265 size_t read_count() const { return read_count_; } | 265 size_t read_count() const { return read_count_; } |
| 266 size_t write_count() const { return write_count_; } | 266 size_t write_count() const { return write_count_; } |
| 267 | 267 |
| 268 bool at_read_eof() const { return read_index_ >= read_count_; } | 268 bool AllReadDataConsumed() const { return read_index_ >= read_count_; } |
| 269 bool at_write_eof() const { return write_index_ >= write_count_; } | 269 bool AllWriteDataConsumed() const { return write_index_ >= write_count_; } |
| 270 | 270 |
| 271 private: | 271 private: |
| 272 MockRead* reads_; | 272 MockRead* reads_; |
| 273 size_t read_index_; | 273 size_t read_index_; |
| 274 size_t read_count_; | 274 size_t read_count_; |
| 275 MockWrite* writes_; | 275 MockWrite* writes_; |
| 276 size_t write_index_; | 276 size_t write_index_; |
| 277 size_t write_count_; | 277 size_t write_count_; |
| 278 | 278 |
| 279 DISALLOW_COPY_AND_ASSIGN(StaticSocketDataHelper); | 279 DISALLOW_COPY_AND_ASSIGN(StaticSocketDataHelper); |
| (...skipping 17 matching lines...) Expand all Loading... |
| 297 MockWriteResult OnWrite(const std::string& data) override; | 297 MockWriteResult OnWrite(const std::string& data) override; |
| 298 void Reset() override; | 298 void Reset() override; |
| 299 bool AllReadDataConsumed() const override; | 299 bool AllReadDataConsumed() const override; |
| 300 bool AllWriteDataConsumed() const override; | 300 bool AllWriteDataConsumed() const override; |
| 301 | 301 |
| 302 size_t read_index() const { return helper_.read_index(); } | 302 size_t read_index() const { return helper_.read_index(); } |
| 303 size_t write_index() const { return helper_.write_index(); } | 303 size_t write_index() const { return helper_.write_index(); } |
| 304 size_t read_count() const { return helper_.read_count(); } | 304 size_t read_count() const { return helper_.read_count(); } |
| 305 size_t write_count() const { return helper_.write_count(); } | 305 size_t write_count() const { return helper_.write_count(); } |
| 306 | 306 |
| 307 bool at_read_eof() const { return helper_.at_read_eof(); } | |
| 308 bool at_write_eof() const { return helper_.at_write_eof(); } | |
| 309 | |
| 310 protected: | 307 protected: |
| 311 StaticSocketDataHelper* helper() { return &helper_; } | 308 StaticSocketDataHelper* helper() { return &helper_; } |
| 312 | 309 |
| 313 private: | 310 private: |
| 314 StaticSocketDataHelper helper_; | 311 StaticSocketDataHelper helper_; |
| 315 | 312 |
| 316 DISALLOW_COPY_AND_ASSIGN(StaticSocketDataProvider); | 313 DISALLOW_COPY_AND_ASSIGN(StaticSocketDataProvider); |
| 317 }; | 314 }; |
| 318 | 315 |
| 319 // SocketDataProvider which can make decisions about next mock reads based on | 316 // SocketDataProvider which can make decisions about next mock reads based on |
| (...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 396 | 393 |
| 397 ~SequencedSocketData() override; | 394 ~SequencedSocketData() override; |
| 398 | 395 |
| 399 // SocketDataProviderBase implementation. | 396 // SocketDataProviderBase implementation. |
| 400 MockRead OnRead() override; | 397 MockRead OnRead() override; |
| 401 MockWriteResult OnWrite(const std::string& data) override; | 398 MockWriteResult OnWrite(const std::string& data) override; |
| 402 void Reset() override; | 399 void Reset() override; |
| 403 bool AllReadDataConsumed() const override; | 400 bool AllReadDataConsumed() const override; |
| 404 bool AllWriteDataConsumed() const override; | 401 bool AllWriteDataConsumed() const override; |
| 405 | 402 |
| 406 // Returns true if all data has been read. | |
| 407 bool at_read_eof() const; | |
| 408 | |
| 409 // Returns true if all data has been written. | |
| 410 bool at_write_eof() const; | |
| 411 | |
| 412 bool IsReadPaused(); | 403 bool IsReadPaused(); |
| 413 void CompleteRead(); | 404 void CompleteRead(); |
| 414 | 405 |
| 415 private: | 406 private: |
| 416 // Defines the state for the read or write path. | 407 // Defines the state for the read or write path. |
| 417 enum IoState { | 408 enum IoState { |
| 418 IDLE, // No async operation is in progress. | 409 IDLE, // No async operation is in progress. |
| 419 PENDING, // An async operation in waiting for another opteration to | 410 PENDING, // An async operation in waiting for another opteration to |
| 420 // complete. | 411 // complete. |
| 421 COMPLETING, // A task has been posted to complet an async operation. | 412 COMPLETING, // A task has been posted to complet an async operation. |
| (...skipping 871 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1293 | 1284 |
| 1294 extern const char kSOCKS5OkRequest[]; | 1285 extern const char kSOCKS5OkRequest[]; |
| 1295 extern const int kSOCKS5OkRequestLength; | 1286 extern const int kSOCKS5OkRequestLength; |
| 1296 | 1287 |
| 1297 extern const char kSOCKS5OkResponse[]; | 1288 extern const char kSOCKS5OkResponse[]; |
| 1298 extern const int kSOCKS5OkResponseLength; | 1289 extern const int kSOCKS5OkResponseLength; |
| 1299 | 1290 |
| 1300 } // namespace net | 1291 } // namespace net |
| 1301 | 1292 |
| 1302 #endif // NET_SOCKET_SOCKET_TEST_UTIL_H_ | 1293 #endif // NET_SOCKET_SOCKET_TEST_UTIL_H_ |
| OLD | NEW |