OLD | NEW |
1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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 | 8 |
9 #include "base/basictypes.h" | 9 #include "base/basictypes.h" |
10 #include "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
11 #include "base/message_loop.h" | 11 #include "base/message_loop.h" |
12 #include "base/time.h" | 12 #include "base/time.h" |
13 #include "net/base/address_family.h" | 13 #include "net/base/address_family.h" |
14 #include "net/base/host_resolver_proc.h" | 14 #include "net/base/host_resolver_proc.h" |
15 #include "net/base/ssl_info.h" | 15 #include "net/base/ssl_info.h" |
16 #include "net/socket/socket.h" | 16 #include "net/socket/socket.h" |
17 #include "testing/gtest/include/gtest/gtest.h" | 17 #include "testing/gtest/include/gtest/gtest.h" |
18 | 18 |
19 namespace net { | 19 namespace net { |
20 | 20 |
21 MockClientSocket::MockClientSocket() | 21 MockClientSocket::MockClientSocket(net::NetLog* net_log) |
22 : ALLOW_THIS_IN_INITIALIZER_LIST(method_factory_(this)), | 22 : ALLOW_THIS_IN_INITIALIZER_LIST(method_factory_(this)), |
23 connected_(false) { | 23 connected_(false), |
| 24 net_log_(NetLog::Source(), net_log) { |
24 } | 25 } |
25 | 26 |
26 void MockClientSocket::GetSSLInfo(net::SSLInfo* ssl_info) { | 27 void MockClientSocket::GetSSLInfo(net::SSLInfo* ssl_info) { |
27 NOTREACHED(); | 28 NOTREACHED(); |
28 } | 29 } |
29 | 30 |
30 void MockClientSocket::GetSSLCertRequestInfo( | 31 void MockClientSocket::GetSSLCertRequestInfo( |
31 net::SSLCertRequestInfo* cert_request_info) { | 32 net::SSLCertRequestInfo* cert_request_info) { |
32 NOTREACHED(); | 33 NOTREACHED(); |
33 } | 34 } |
(...skipping 28 matching lines...) Expand all Loading... |
62 &MockClientSocket::RunCallback, callback, result)); | 63 &MockClientSocket::RunCallback, callback, result)); |
63 } | 64 } |
64 | 65 |
65 void MockClientSocket::RunCallback(net::CompletionCallback* callback, | 66 void MockClientSocket::RunCallback(net::CompletionCallback* callback, |
66 int result) { | 67 int result) { |
67 if (callback) | 68 if (callback) |
68 callback->Run(result); | 69 callback->Run(result); |
69 } | 70 } |
70 | 71 |
71 MockTCPClientSocket::MockTCPClientSocket(const net::AddressList& addresses, | 72 MockTCPClientSocket::MockTCPClientSocket(const net::AddressList& addresses, |
| 73 net::NetLog* net_log, |
72 net::SocketDataProvider* data) | 74 net::SocketDataProvider* data) |
73 : addresses_(addresses), | 75 : MockClientSocket(net_log), |
| 76 addresses_(addresses), |
74 data_(data), | 77 data_(data), |
75 read_offset_(0), | 78 read_offset_(0), |
76 read_data_(false, net::ERR_UNEXPECTED), | 79 read_data_(false, net::ERR_UNEXPECTED), |
77 need_read_data_(true), | 80 need_read_data_(true), |
78 peer_closed_connection_(false), | 81 peer_closed_connection_(false), |
79 pending_buf_(NULL), | 82 pending_buf_(NULL), |
80 pending_buf_len_(0), | 83 pending_buf_len_(0), |
81 pending_callback_(NULL) { | 84 pending_callback_(NULL) { |
82 DCHECK(data_); | 85 DCHECK(data_); |
83 data_->Reset(); | 86 data_->Reset(); |
84 } | 87 } |
85 | 88 |
86 int MockTCPClientSocket::Connect(net::CompletionCallback* callback, | 89 int MockTCPClientSocket::Connect(net::CompletionCallback* callback) { |
87 const BoundNetLog& net_log) { | |
88 if (connected_) | 90 if (connected_) |
89 return net::OK; | 91 return net::OK; |
90 connected_ = true; | 92 connected_ = true; |
91 if (data_->connect_data().async) { | 93 if (data_->connect_data().async) { |
92 RunCallbackAsync(callback, data_->connect_data().result); | 94 RunCallbackAsync(callback, data_->connect_data().result); |
93 return net::ERR_IO_PENDING; | 95 return net::ERR_IO_PENDING; |
94 } | 96 } |
95 return data_->connect_data().result; | 97 return data_->connect_data().result; |
96 } | 98 } |
97 | 99 |
(...skipping 139 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
237 MockSSLClientSocket* ssl_client_socket_; | 239 MockSSLClientSocket* ssl_client_socket_; |
238 net::CompletionCallback* user_callback_; | 240 net::CompletionCallback* user_callback_; |
239 int rv_; | 241 int rv_; |
240 }; | 242 }; |
241 | 243 |
242 MockSSLClientSocket::MockSSLClientSocket( | 244 MockSSLClientSocket::MockSSLClientSocket( |
243 net::ClientSocket* transport_socket, | 245 net::ClientSocket* transport_socket, |
244 const std::string& hostname, | 246 const std::string& hostname, |
245 const net::SSLConfig& ssl_config, | 247 const net::SSLConfig& ssl_config, |
246 net::SSLSocketDataProvider* data) | 248 net::SSLSocketDataProvider* data) |
247 : transport_(transport_socket), | 249 : MockClientSocket(transport_socket->NetLog().net_log()), |
| 250 transport_(transport_socket), |
248 data_(data) { | 251 data_(data) { |
249 DCHECK(data_); | 252 DCHECK(data_); |
250 } | 253 } |
251 | 254 |
252 MockSSLClientSocket::~MockSSLClientSocket() { | 255 MockSSLClientSocket::~MockSSLClientSocket() { |
253 Disconnect(); | 256 Disconnect(); |
254 } | 257 } |
255 | 258 |
256 void MockSSLClientSocket::GetSSLInfo(net::SSLInfo* ssl_info) { | 259 void MockSSLClientSocket::GetSSLInfo(net::SSLInfo* ssl_info) { |
257 ssl_info->Reset(); | 260 ssl_info->Reset(); |
258 } | 261 } |
259 | 262 |
260 int MockSSLClientSocket::Connect(net::CompletionCallback* callback, | 263 int MockSSLClientSocket::Connect(net::CompletionCallback* callback) { |
261 const BoundNetLog& net_log) { | |
262 ConnectCallback* connect_callback = new ConnectCallback( | 264 ConnectCallback* connect_callback = new ConnectCallback( |
263 this, callback, data_->connect.result); | 265 this, callback, data_->connect.result); |
264 int rv = transport_->Connect(connect_callback, net_log); | 266 int rv = transport_->Connect(connect_callback); |
265 if (rv == net::OK) { | 267 if (rv == net::OK) { |
266 delete connect_callback; | 268 delete connect_callback; |
267 if (data_->connect.async) { | 269 if (data_->connect.async) { |
268 RunCallbackAsync(callback, data_->connect.result); | 270 RunCallbackAsync(callback, data_->connect.result); |
269 return net::ERR_IO_PENDING; | 271 return net::ERR_IO_PENDING; |
270 } | 272 } |
271 if (data_->connect.result == net::OK) | 273 if (data_->connect.result == net::OK) |
272 connected_ = true; | 274 connected_ = true; |
273 return data_->connect.result; | 275 return data_->connect.result; |
274 } | 276 } |
(...skipping 130 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
405 return tcp_client_sockets_[index]; | 407 return tcp_client_sockets_[index]; |
406 } | 408 } |
407 | 409 |
408 MockSSLClientSocket* MockClientSocketFactory::GetMockSSLClientSocket( | 410 MockSSLClientSocket* MockClientSocketFactory::GetMockSSLClientSocket( |
409 size_t index) const { | 411 size_t index) const { |
410 DCHECK_LT(index, ssl_client_sockets_.size()); | 412 DCHECK_LT(index, ssl_client_sockets_.size()); |
411 return ssl_client_sockets_[index]; | 413 return ssl_client_sockets_[index]; |
412 } | 414 } |
413 | 415 |
414 ClientSocket* MockClientSocketFactory::CreateTCPClientSocket( | 416 ClientSocket* MockClientSocketFactory::CreateTCPClientSocket( |
415 const AddressList& addresses) { | 417 const AddressList& addresses, net::NetLog* net_log) { |
416 SocketDataProvider* data_provider = mock_data_.GetNext(); | 418 SocketDataProvider* data_provider = mock_data_.GetNext(); |
417 MockTCPClientSocket* socket = | 419 MockTCPClientSocket* socket = |
418 new MockTCPClientSocket(addresses, data_provider); | 420 new MockTCPClientSocket(addresses, net_log, data_provider); |
419 data_provider->set_socket(socket); | 421 data_provider->set_socket(socket); |
420 tcp_client_sockets_.push_back(socket); | 422 tcp_client_sockets_.push_back(socket); |
421 return socket; | 423 return socket; |
422 } | 424 } |
423 | 425 |
424 SSLClientSocket* MockClientSocketFactory::CreateSSLClientSocket( | 426 SSLClientSocket* MockClientSocketFactory::CreateSSLClientSocket( |
425 ClientSocket* transport_socket, | 427 ClientSocket* transport_socket, |
426 const std::string& hostname, | 428 const std::string& hostname, |
427 const SSLConfig& ssl_config) { | 429 const SSLConfig& ssl_config) { |
428 MockSSLClientSocket* socket = | 430 MockSSLClientSocket* socket = |
(...skipping 79 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
508 | 510 |
509 const char kSOCKS5OkRequest[] = | 511 const char kSOCKS5OkRequest[] = |
510 { 0x05, 0x01, 0x00, 0x03, 0x04, 'h', 'o', 's', 't', 0x00, 0x50 }; | 512 { 0x05, 0x01, 0x00, 0x03, 0x04, 'h', 'o', 's', 't', 0x00, 0x50 }; |
511 const int kSOCKS5OkRequestLength = arraysize(kSOCKS5OkRequest); | 513 const int kSOCKS5OkRequestLength = arraysize(kSOCKS5OkRequest); |
512 | 514 |
513 const char kSOCKS5OkResponse[] = | 515 const char kSOCKS5OkResponse[] = |
514 { 0x05, 0x00, 0x00, 0x01, 127, 0, 0, 1, 0x00, 0x50 }; | 516 { 0x05, 0x00, 0x00, 0x01, 127, 0, 0, 1, 0x00, 0x50 }; |
515 const int kSOCKS5OkResponseLength = arraysize(kSOCKS5OkResponse); | 517 const int kSOCKS5OkResponseLength = arraysize(kSOCKS5OkResponse); |
516 | 518 |
517 } // namespace net | 519 } // namespace net |
OLD | NEW |