| 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 #include "net/socket/socket_test_util.h" | 5 #include "net/socket/socket_test_util.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/basictypes.h" | 10 #include "base/basictypes.h" |
| (...skipping 239 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 250 } | 250 } |
| 251 | 251 |
| 252 bool StaticSocketDataProvider::AllReadDataConsumed() const { | 252 bool StaticSocketDataProvider::AllReadDataConsumed() const { |
| 253 return helper_.at_read_eof(); | 253 return helper_.at_read_eof(); |
| 254 } | 254 } |
| 255 | 255 |
| 256 bool StaticSocketDataProvider::AllWriteDataConsumed() const { | 256 bool StaticSocketDataProvider::AllWriteDataConsumed() const { |
| 257 return helper_.at_write_eof(); | 257 return helper_.at_write_eof(); |
| 258 } | 258 } |
| 259 | 259 |
| 260 DynamicSocketDataProvider::DynamicSocketDataProvider() | |
| 261 : short_read_limit_(0), | |
| 262 allow_unconsumed_reads_(false) { | |
| 263 } | |
| 264 | |
| 265 DynamicSocketDataProvider::~DynamicSocketDataProvider() {} | |
| 266 | |
| 267 MockRead DynamicSocketDataProvider::OnRead() { | |
| 268 if (reads_.empty()) | |
| 269 return MockRead(SYNCHRONOUS, ERR_UNEXPECTED); | |
| 270 MockRead result = reads_.front(); | |
| 271 if (short_read_limit_ == 0 || result.data_len <= short_read_limit_) { | |
| 272 reads_.pop_front(); | |
| 273 } else { | |
| 274 result.data_len = short_read_limit_; | |
| 275 reads_.front().data += result.data_len; | |
| 276 reads_.front().data_len -= result.data_len; | |
| 277 } | |
| 278 return result; | |
| 279 } | |
| 280 | |
| 281 void DynamicSocketDataProvider::Reset() { | |
| 282 reads_.clear(); | |
| 283 } | |
| 284 | |
| 285 void DynamicSocketDataProvider::SimulateRead(const char* data, | |
| 286 const size_t length) { | |
| 287 if (!allow_unconsumed_reads_) { | |
| 288 EXPECT_TRUE(reads_.empty()) << "Unconsumed read: " << reads_.front().data; | |
| 289 } | |
| 290 reads_.push_back(MockRead(ASYNC, data, length)); | |
| 291 } | |
| 292 | |
| 293 SSLSocketDataProvider::SSLSocketDataProvider(IoMode mode, int result) | 260 SSLSocketDataProvider::SSLSocketDataProvider(IoMode mode, int result) |
| 294 : connect(mode, result), | 261 : connect(mode, result), |
| 295 next_proto_status(SSLClientSocket::kNextProtoUnsupported), | 262 next_proto_status(SSLClientSocket::kNextProtoUnsupported), |
| 296 client_cert_sent(false), | 263 client_cert_sent(false), |
| 297 cert_request_info(NULL), | 264 cert_request_info(NULL), |
| 298 channel_id_sent(false), | 265 channel_id_sent(false), |
| 299 connection_status(0) { | 266 connection_status(0) { |
| 300 SSLConnectionStatusSetVersion(SSL_CONNECTION_VERSION_TLS1_2, | 267 SSLConnectionStatusSetVersion(SSL_CONNECTION_VERSION_TLS1_2, |
| 301 &connection_status); | 268 &connection_status); |
| 302 // Set to TLS_ECDHE_ECDSA_WITH_CHACHA20_POLY1305 | 269 // Set to TLS_ECDHE_ECDSA_WITH_CHACHA20_POLY1305 |
| (...skipping 1847 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2150 | 2117 |
| 2151 const char kSOCKS5OkRequest[] = | 2118 const char kSOCKS5OkRequest[] = |
| 2152 { 0x05, 0x01, 0x00, 0x03, 0x04, 'h', 'o', 's', 't', 0x00, 0x50 }; | 2119 { 0x05, 0x01, 0x00, 0x03, 0x04, 'h', 'o', 's', 't', 0x00, 0x50 }; |
| 2153 const int kSOCKS5OkRequestLength = arraysize(kSOCKS5OkRequest); | 2120 const int kSOCKS5OkRequestLength = arraysize(kSOCKS5OkRequest); |
| 2154 | 2121 |
| 2155 const char kSOCKS5OkResponse[] = | 2122 const char kSOCKS5OkResponse[] = |
| 2156 { 0x05, 0x00, 0x00, 0x01, 127, 0, 0, 1, 0x00, 0x50 }; | 2123 { 0x05, 0x00, 0x00, 0x01, 127, 0, 0, 1, 0x00, 0x50 }; |
| 2157 const int kSOCKS5OkResponseLength = arraysize(kSOCKS5OkResponse); | 2124 const int kSOCKS5OkResponseLength = arraysize(kSOCKS5OkResponse); |
| 2158 | 2125 |
| 2159 } // namespace net | 2126 } // namespace net |
| OLD | NEW |