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 <utility> | 8 #include <utility> |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
(...skipping 17 matching lines...) Expand all Loading... |
28 #include "net/socket/websocket_endpoint_lock_manager.h" | 28 #include "net/socket/websocket_endpoint_lock_manager.h" |
29 #include "net/ssl/ssl_cert_request_info.h" | 29 #include "net/ssl/ssl_cert_request_info.h" |
30 #include "net/ssl/ssl_connection_status_flags.h" | 30 #include "net/ssl/ssl_connection_status_flags.h" |
31 #include "net/ssl/ssl_failure_state.h" | 31 #include "net/ssl/ssl_failure_state.h" |
32 #include "net/ssl/ssl_info.h" | 32 #include "net/ssl/ssl_info.h" |
33 #include "testing/gtest/include/gtest/gtest.h" | 33 #include "testing/gtest/include/gtest/gtest.h" |
34 | 34 |
35 #define NET_TRACE(level, s) VLOG(level) << s << __FUNCTION__ << "() " | 35 #define NET_TRACE(level, s) VLOG(level) << s << __FUNCTION__ << "() " |
36 | 36 |
37 namespace net { | 37 namespace net { |
38 | |
39 namespace { | 38 namespace { |
40 | 39 |
41 inline char AsciifyHigh(char x) { | 40 inline char AsciifyHigh(char x) { |
42 char nybble = static_cast<char>((x >> 4) & 0x0F); | 41 char nybble = static_cast<char>((x >> 4) & 0x0F); |
43 return nybble + ((nybble < 0x0A) ? '0' : 'A' - 10); | 42 return nybble + ((nybble < 0x0A) ? '0' : 'A' - 10); |
44 } | 43 } |
45 | 44 |
46 inline char AsciifyLow(char x) { | 45 inline char AsciifyLow(char x) { |
47 char nybble = static_cast<char>((x >> 0) & 0x0F); | 46 char nybble = static_cast<char>((x >> 0) & 0x0F); |
48 return nybble + ((nybble < 0x0A) ? '0' : 'A' - 10); | 47 return nybble + ((nybble < 0x0A) ? '0' : 'A' - 10); |
(...skipping 1189 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1238 } | 1237 } |
1239 | 1238 |
1240 MockUDPClientSocket::MockUDPClientSocket(SocketDataProvider* data, | 1239 MockUDPClientSocket::MockUDPClientSocket(SocketDataProvider* data, |
1241 net::NetLog* net_log) | 1240 net::NetLog* net_log) |
1242 : connected_(false), | 1241 : connected_(false), |
1243 data_(data), | 1242 data_(data), |
1244 read_offset_(0), | 1243 read_offset_(0), |
1245 read_data_(SYNCHRONOUS, ERR_UNEXPECTED), | 1244 read_data_(SYNCHRONOUS, ERR_UNEXPECTED), |
1246 need_read_data_(true), | 1245 need_read_data_(true), |
1247 source_port_(123), | 1246 source_port_(123), |
| 1247 network_(NetworkChangeNotifier::kInvalidNetworkHandle), |
1248 pending_read_buf_(NULL), | 1248 pending_read_buf_(NULL), |
1249 pending_read_buf_len_(0), | 1249 pending_read_buf_len_(0), |
1250 net_log_(BoundNetLog::Make(net_log, NetLog::SOURCE_NONE)), | 1250 net_log_(BoundNetLog::Make(net_log, NetLog::SOURCE_NONE)), |
1251 weak_factory_(this) { | 1251 weak_factory_(this) { |
1252 DCHECK(data_); | 1252 DCHECK(data_); |
1253 data_->Initialize(this); | 1253 data_->Initialize(this); |
1254 peer_addr_ = data->connect_data().peer_addr; | 1254 peer_addr_ = data->connect_data().peer_addr; |
1255 } | 1255 } |
1256 | 1256 |
1257 MockUDPClientSocket::~MockUDPClientSocket() { | 1257 MockUDPClientSocket::~MockUDPClientSocket() { |
(...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1336 *address = IPEndPoint(ip, source_port_); | 1336 *address = IPEndPoint(ip, source_port_); |
1337 return OK; | 1337 return OK; |
1338 } | 1338 } |
1339 | 1339 |
1340 const BoundNetLog& MockUDPClientSocket::NetLog() const { | 1340 const BoundNetLog& MockUDPClientSocket::NetLog() const { |
1341 return net_log_; | 1341 return net_log_; |
1342 } | 1342 } |
1343 | 1343 |
1344 int MockUDPClientSocket::BindToNetwork( | 1344 int MockUDPClientSocket::BindToNetwork( |
1345 NetworkChangeNotifier::NetworkHandle network) { | 1345 NetworkChangeNotifier::NetworkHandle network) { |
1346 return ERR_NOT_IMPLEMENTED; | 1346 network_ = network; |
| 1347 return OK; |
1347 } | 1348 } |
1348 | 1349 |
1349 int MockUDPClientSocket::BindToDefaultNetwork() { | 1350 int MockUDPClientSocket::BindToDefaultNetwork() { |
1350 return ERR_NOT_IMPLEMENTED; | 1351 network_ = kDefaultNetworkForTests; |
| 1352 return OK; |
1351 } | 1353 } |
1352 | 1354 |
1353 NetworkChangeNotifier::NetworkHandle MockUDPClientSocket::GetBoundNetwork() | 1355 NetworkChangeNotifier::NetworkHandle MockUDPClientSocket::GetBoundNetwork() |
1354 const { | 1356 const { |
1355 return NetworkChangeNotifier::kInvalidNetworkHandle; | 1357 return network_; |
1356 } | 1358 } |
1357 | 1359 |
1358 int MockUDPClientSocket::Connect(const IPEndPoint& address) { | 1360 int MockUDPClientSocket::Connect(const IPEndPoint& address) { |
1359 if (!data_) | 1361 if (!data_) |
1360 return ERR_UNEXPECTED; | 1362 return ERR_UNEXPECTED; |
1361 connected_ = true; | 1363 connected_ = true; |
1362 peer_addr_ = address; | 1364 peer_addr_ = address; |
1363 return data_->connect_data().result; | 1365 return data_->connect_data().result; |
1364 } | 1366 } |
1365 | 1367 |
(...skipping 329 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1695 } | 1697 } |
1696 | 1698 |
1697 int64_t CountWriteBytes(const MockWrite writes[], size_t writes_size) { | 1699 int64_t CountWriteBytes(const MockWrite writes[], size_t writes_size) { |
1698 int64_t total = 0; | 1700 int64_t total = 0; |
1699 for (const MockWrite* write = writes; write != writes + writes_size; ++write) | 1701 for (const MockWrite* write = writes; write != writes + writes_size; ++write) |
1700 total += write->data_len; | 1702 total += write->data_len; |
1701 return total; | 1703 return total; |
1702 } | 1704 } |
1703 | 1705 |
1704 } // namespace net | 1706 } // namespace net |
OLD | NEW |