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 707 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
718 new MockUDPClientSocket(data_provider, net_log)); | 718 new MockUDPClientSocket(data_provider, net_log)); |
719 if (bind_type == DatagramSocket::RANDOM_BIND) | 719 if (bind_type == DatagramSocket::RANDOM_BIND) |
720 socket->set_source_port( | 720 socket->set_source_port( |
721 static_cast<uint16_t>(rand_int_cb.Run(1025, 65535))); | 721 static_cast<uint16_t>(rand_int_cb.Run(1025, 65535))); |
722 udp_client_socket_ports_.push_back(socket->source_port()); | 722 udp_client_socket_ports_.push_back(socket->source_port()); |
723 return std::move(socket); | 723 return std::move(socket); |
724 } | 724 } |
725 | 725 |
726 scoped_ptr<StreamSocket> MockClientSocketFactory::CreateTransportClientSocket( | 726 scoped_ptr<StreamSocket> MockClientSocketFactory::CreateTransportClientSocket( |
727 const AddressList& addresses, | 727 const AddressList& addresses, |
| 728 scoped_ptr<SocketPerformanceWatcher> socket_performance_watcher, |
728 NetLog* net_log, | 729 NetLog* net_log, |
729 const NetLog::Source& source) { | 730 const NetLog::Source& source) { |
730 SocketDataProvider* data_provider = mock_data_.GetNext(); | 731 SocketDataProvider* data_provider = mock_data_.GetNext(); |
731 scoped_ptr<MockTCPClientSocket> socket( | 732 scoped_ptr<MockTCPClientSocket> socket( |
732 new MockTCPClientSocket(addresses, net_log, data_provider)); | 733 new MockTCPClientSocket(addresses, net_log, data_provider)); |
733 return std::move(socket); | 734 return std::move(socket); |
734 } | 735 } |
735 | 736 |
736 scoped_ptr<SSLClientSocket> MockClientSocketFactory::CreateSSLClientSocket( | 737 scoped_ptr<SSLClientSocket> MockClientSocketFactory::CreateSSLClientSocket( |
737 scoped_ptr<ClientSocketHandle> transport_socket, | 738 scoped_ptr<ClientSocketHandle> transport_socket, |
(...skipping 853 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1591 } | 1592 } |
1592 | 1593 |
1593 MockTransportClientSocketPool::MockTransportClientSocketPool( | 1594 MockTransportClientSocketPool::MockTransportClientSocketPool( |
1594 int max_sockets, | 1595 int max_sockets, |
1595 int max_sockets_per_group, | 1596 int max_sockets_per_group, |
1596 ClientSocketFactory* socket_factory) | 1597 ClientSocketFactory* socket_factory) |
1597 : TransportClientSocketPool(max_sockets, | 1598 : TransportClientSocketPool(max_sockets, |
1598 max_sockets_per_group, | 1599 max_sockets_per_group, |
1599 NULL, | 1600 NULL, |
1600 NULL, | 1601 NULL, |
| 1602 NULL, |
1601 NULL), | 1603 NULL), |
1602 client_socket_factory_(socket_factory), | 1604 client_socket_factory_(socket_factory), |
1603 last_request_priority_(DEFAULT_PRIORITY), | 1605 last_request_priority_(DEFAULT_PRIORITY), |
1604 release_count_(0), | 1606 release_count_(0), |
1605 cancel_count_(0) { | 1607 cancel_count_(0) {} |
1606 } | |
1607 | 1608 |
1608 MockTransportClientSocketPool::~MockTransportClientSocketPool() {} | 1609 MockTransportClientSocketPool::~MockTransportClientSocketPool() {} |
1609 | 1610 |
1610 int MockTransportClientSocketPool::RequestSocket( | 1611 int MockTransportClientSocketPool::RequestSocket( |
1611 const std::string& group_name, | 1612 const std::string& group_name, |
1612 const void* socket_params, | 1613 const void* socket_params, |
1613 RequestPriority priority, | 1614 RequestPriority priority, |
1614 RespectLimits respect_limits, | 1615 RespectLimits respect_limits, |
1615 ClientSocketHandle* handle, | 1616 ClientSocketHandle* handle, |
1616 const CompletionCallback& callback, | 1617 const CompletionCallback& callback, |
1617 const BoundNetLog& net_log) { | 1618 const BoundNetLog& net_log) { |
1618 last_request_priority_ = priority; | 1619 last_request_priority_ = priority; |
1619 scoped_ptr<StreamSocket> socket = | 1620 scoped_ptr<StreamSocket> socket = |
1620 client_socket_factory_->CreateTransportClientSocket( | 1621 client_socket_factory_->CreateTransportClientSocket( |
1621 AddressList(), net_log.net_log(), NetLog::Source()); | 1622 AddressList(), NULL, net_log.net_log(), NetLog::Source()); |
1622 MockConnectJob* job = new MockConnectJob(std::move(socket), handle, callback); | 1623 MockConnectJob* job = new MockConnectJob(std::move(socket), handle, callback); |
1623 job_list_.push_back(make_scoped_ptr(job)); | 1624 job_list_.push_back(make_scoped_ptr(job)); |
1624 handle->set_pool_id(1); | 1625 handle->set_pool_id(1); |
1625 return job->Connect(); | 1626 return job->Connect(); |
1626 } | 1627 } |
1627 | 1628 |
1628 void MockTransportClientSocketPool::CancelRequest(const std::string& group_name, | 1629 void MockTransportClientSocketPool::CancelRequest(const std::string& group_name, |
1629 ClientSocketHandle* handle) { | 1630 ClientSocketHandle* handle) { |
1630 for (scoped_ptr<MockConnectJob>& it : job_list_) { | 1631 for (scoped_ptr<MockConnectJob>& it : job_list_) { |
1631 if (it->CancelHandle(handle)) { | 1632 if (it->CancelHandle(handle)) { |
(...skipping 12 matching lines...) Expand all Loading... |
1644 } | 1645 } |
1645 | 1646 |
1646 MockSOCKSClientSocketPool::MockSOCKSClientSocketPool( | 1647 MockSOCKSClientSocketPool::MockSOCKSClientSocketPool( |
1647 int max_sockets, | 1648 int max_sockets, |
1648 int max_sockets_per_group, | 1649 int max_sockets_per_group, |
1649 TransportClientSocketPool* transport_pool) | 1650 TransportClientSocketPool* transport_pool) |
1650 : SOCKSClientSocketPool(max_sockets, | 1651 : SOCKSClientSocketPool(max_sockets, |
1651 max_sockets_per_group, | 1652 max_sockets_per_group, |
1652 NULL, | 1653 NULL, |
1653 transport_pool, | 1654 transport_pool, |
| 1655 NULL, |
1654 NULL), | 1656 NULL), |
1655 transport_pool_(transport_pool) { | 1657 transport_pool_(transport_pool) {} |
1656 } | |
1657 | 1658 |
1658 MockSOCKSClientSocketPool::~MockSOCKSClientSocketPool() {} | 1659 MockSOCKSClientSocketPool::~MockSOCKSClientSocketPool() {} |
1659 | 1660 |
1660 int MockSOCKSClientSocketPool::RequestSocket(const std::string& group_name, | 1661 int MockSOCKSClientSocketPool::RequestSocket(const std::string& group_name, |
1661 const void* socket_params, | 1662 const void* socket_params, |
1662 RequestPriority priority, | 1663 RequestPriority priority, |
1663 RespectLimits respect_limits, | 1664 RespectLimits respect_limits, |
1664 ClientSocketHandle* handle, | 1665 ClientSocketHandle* handle, |
1665 const CompletionCallback& callback, | 1666 const CompletionCallback& callback, |
1666 const BoundNetLog& net_log) { | 1667 const BoundNetLog& net_log) { |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1718 } | 1719 } |
1719 | 1720 |
1720 int64_t CountWriteBytes(const MockWrite writes[], size_t writes_size) { | 1721 int64_t CountWriteBytes(const MockWrite writes[], size_t writes_size) { |
1721 int64_t total = 0; | 1722 int64_t total = 0; |
1722 for (const MockWrite* write = writes; write != writes + writes_size; ++write) | 1723 for (const MockWrite* write = writes; write != writes + writes_size; ++write) |
1723 total += write->data_len; | 1724 total += write->data_len; |
1724 return total; | 1725 return total; |
1725 } | 1726 } |
1726 | 1727 |
1727 } // namespace net | 1728 } // namespace net |
OLD | NEW |