diff options
Diffstat (limited to 'net/socket')
-rw-r--r-- | net/socket/client_socket_pool_base.cc | 10 | ||||
-rw-r--r-- | net/socket/client_socket_pool_base.h | 5 | ||||
-rw-r--r-- | net/socket/ssl_client_socket_pool.cc | 5 | ||||
-rw-r--r-- | net/socket/ssl_client_socket_pool.h | 4 | ||||
-rw-r--r-- | net/socket/tcp_client_socket_libevent.cc | 13 | ||||
-rw-r--r-- | net/socket/tcp_client_socket_libevent.h | 13 |
6 files changed, 33 insertions, 17 deletions
diff --git a/net/socket/client_socket_pool_base.cc b/net/socket/client_socket_pool_base.cc index 8c11782..6092081 100644 --- a/net/socket/client_socket_pool_base.cc +++ b/net/socket/client_socket_pool_base.cc @@ -198,6 +198,16 @@ ClientSocketPoolBaseHelper::~ClientSocketPoolBaseHelper() { NetworkChangeNotifier::RemoveIPAddressObserver(this); } +ClientSocketPoolBaseHelper::CallbackResultPair::CallbackResultPair() + : result(OK) { +} + +ClientSocketPoolBaseHelper::CallbackResultPair::CallbackResultPair( + const CompletionCallback& callback_in, int result_in) + : callback(callback_in), + result(result_in) { +} + ClientSocketPoolBaseHelper::CallbackResultPair::~CallbackResultPair() {} // InsertRequestIntoQueue inserts the request into the queue based on diff --git a/net/socket/client_socket_pool_base.h b/net/socket/client_socket_pool_base.h index 834835a..e35ab29 100644 --- a/net/socket/client_socket_pool_base.h +++ b/net/socket/client_socket_pool_base.h @@ -442,9 +442,8 @@ class NET_EXPORT_PRIVATE ClientSocketPoolBaseHelper typedef std::set<ConnectJob*> ConnectJobSet; struct CallbackResultPair { - CallbackResultPair() : result(OK) {} - CallbackResultPair(const CompletionCallback& callback_in, int result_in) - : callback(callback_in), result(result_in) {} + CallbackResultPair(); + CallbackResultPair(const CompletionCallback& callback_in, int result_in); ~CallbackResultPair(); CompletionCallback callback; diff --git a/net/socket/ssl_client_socket_pool.cc b/net/socket/ssl_client_socket_pool.cc index 842da86..21ebf97 100644 --- a/net/socket/ssl_client_socket_pool.cc +++ b/net/socket/ssl_client_socket_pool.cc @@ -491,6 +491,11 @@ ConnectJob* SSLClientSocketPool::SSLConnectJobFactory::NewConnectJob( context_, delegate, net_log_); } +base::TimeDelta +SSLClientSocketPool::SSLConnectJobFactory::ConnectionTimeout() const { + return timeout_; +} + int SSLClientSocketPool::RequestSocket(const std::string& group_name, const void* socket_params, RequestPriority priority, diff --git a/net/socket/ssl_client_socket_pool.h b/net/socket/ssl_client_socket_pool.h index 4948cf5..8802afc 100644 --- a/net/socket/ssl_client_socket_pool.h +++ b/net/socket/ssl_client_socket_pool.h @@ -265,9 +265,7 @@ class NET_EXPORT_PRIVATE SSLClientSocketPool const PoolBase::Request& request, ConnectJob::Delegate* delegate) const OVERRIDE; - virtual base::TimeDelta ConnectionTimeout() const OVERRIDE { - return timeout_; - } + virtual base::TimeDelta ConnectionTimeout() const OVERRIDE; private: TransportClientSocketPool* const transport_pool_; diff --git a/net/socket/tcp_client_socket_libevent.cc b/net/socket/tcp_client_socket_libevent.cc index a3727ff..bd31cbe 100644 --- a/net/socket/tcp_client_socket_libevent.cc +++ b/net/socket/tcp_client_socket_libevent.cc @@ -579,6 +579,19 @@ bool TCPClientSocketLibevent::SetNoDelay(bool no_delay) { return SetTCPNoDelay(socket, no_delay); } +void TCPClientSocketLibevent::ReadWatcher::OnFileCanReadWithoutBlocking(int) { + if (!socket_->read_callback_.is_null()) + socket_->DidCompleteRead(); +} + +void TCPClientSocketLibevent::WriteWatcher::OnFileCanWriteWithoutBlocking(int) { + if (socket_->waiting_connect()) { + socket_->DidCompleteConnect(); + } else if (!socket_->write_callback_.is_null()) { + socket_->DidCompleteWrite(); + } +} + void TCPClientSocketLibevent::LogConnectCompletion(int net_error) { if (net_error == OK) UpdateConnectionTypeHistograms(CONNECTION_ANY); diff --git a/net/socket/tcp_client_socket_libevent.h b/net/socket/tcp_client_socket_libevent.h index 8ddb61b..0a27c4c 100644 --- a/net/socket/tcp_client_socket_libevent.h +++ b/net/socket/tcp_client_socket_libevent.h @@ -88,10 +88,7 @@ class NET_EXPORT_PRIVATE TCPClientSocketLibevent : public StreamSocket, // MessageLoopForIO::Watcher methods - virtual void OnFileCanReadWithoutBlocking(int /* fd */) OVERRIDE { - if (!socket_->read_callback_.is_null()) - socket_->DidCompleteRead(); - } + virtual void OnFileCanReadWithoutBlocking(int /* fd */) OVERRIDE; virtual void OnFileCanWriteWithoutBlocking(int /* fd */) OVERRIDE {} @@ -107,13 +104,7 @@ class NET_EXPORT_PRIVATE TCPClientSocketLibevent : public StreamSocket, // MessageLoopForIO::Watcher implementation. virtual void OnFileCanReadWithoutBlocking(int /* fd */) OVERRIDE {} - virtual void OnFileCanWriteWithoutBlocking(int /* fd */) OVERRIDE { - if (socket_->waiting_connect()) { - socket_->DidCompleteConnect(); - } else if (!socket_->write_callback_.is_null()) { - socket_->DidCompleteWrite(); - } - } + virtual void OnFileCanWriteWithoutBlocking(int /* fd */) OVERRIDE; private: TCPClientSocketLibevent* const socket_; |