| Index: jingle/notifier/base/proxy_resolving_client_socket.cc
|
| diff --git a/jingle/notifier/base/proxy_resolving_client_socket.cc b/jingle/notifier/base/proxy_resolving_client_socket.cc
|
| index 3d46ed6b3acfe79c326f0393ec138887a47406bc..6314bb28170028fafe8fe0d234b73ce3833b3094 100644
|
| --- a/jingle/notifier/base/proxy_resolving_client_socket.cc
|
| +++ b/jingle/notifier/base/proxy_resolving_client_socket.cc
|
| @@ -36,8 +36,7 @@ ProxyResolvingClientSocket::ProxyResolvingClientSocket(
|
| net::BoundNetLog::Make(
|
| request_context_getter->GetURLRequestContext()->net_log(),
|
| net::NetLog::SOURCE_SOCKET)),
|
| - ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)),
|
| - old_user_connect_callback_(NULL) {
|
| + ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)) {
|
| DCHECK(request_context_getter);
|
| net::URLRequestContext* request_context =
|
| request_context_getter->GetURLRequestContext();
|
| @@ -68,13 +67,6 @@ ProxyResolvingClientSocket::~ProxyResolvingClientSocket() {
|
| }
|
|
|
| int ProxyResolvingClientSocket::Read(net::IOBuffer* buf, int buf_len,
|
| - net::OldCompletionCallback* callback) {
|
| - if (transport_.get() && transport_->socket())
|
| - return transport_->socket()->Read(buf, buf_len, callback);
|
| - NOTREACHED();
|
| - return net::ERR_SOCKET_NOT_CONNECTED;
|
| -}
|
| -int ProxyResolvingClientSocket::Read(net::IOBuffer* buf, int buf_len,
|
| const net::CompletionCallback& callback) {
|
| if (transport_.get() && transport_->socket())
|
| return transport_->socket()->Read(buf, buf_len, callback);
|
| @@ -82,8 +74,10 @@ int ProxyResolvingClientSocket::Read(net::IOBuffer* buf, int buf_len,
|
| return net::ERR_SOCKET_NOT_CONNECTED;
|
| }
|
|
|
| -int ProxyResolvingClientSocket::Write(net::IOBuffer* buf, int buf_len,
|
| - net::OldCompletionCallback* callback) {
|
| +int ProxyResolvingClientSocket::Write(
|
| + net::IOBuffer* buf,
|
| + int buf_len,
|
| + const net::CompletionCallback& callback) {
|
| if (transport_.get() && transport_->socket())
|
| return transport_->socket()->Write(buf, buf_len, callback);
|
| NOTREACHED();
|
| @@ -104,36 +98,9 @@ bool ProxyResolvingClientSocket::SetSendBufferSize(int32 size) {
|
| return false;
|
| }
|
|
|
| -int ProxyResolvingClientSocket::Connect(net::OldCompletionCallback* callback) {
|
| - DCHECK(!old_user_connect_callback_ && user_connect_callback_.is_null());
|
| -
|
| - tried_direct_connect_fallback_ = false;
|
| -
|
| - // First we try and resolve the proxy.
|
| - GURL url("http://" + dest_host_port_pair_.ToString());
|
| - int status = network_session_->proxy_service()->ResolveProxy(
|
| - url,
|
| - &proxy_info_,
|
| - &proxy_resolve_callback_,
|
| - &pac_request_,
|
| - bound_net_log_);
|
| - if (status != net::ERR_IO_PENDING) {
|
| - // We defer execution of ProcessProxyResolveDone instead of calling it
|
| - // directly here for simplicity. From the caller's point of view,
|
| - // the connect always happens asynchronously.
|
| - MessageLoop* message_loop = MessageLoop::current();
|
| - CHECK(message_loop);
|
| - message_loop->PostTask(
|
| - FROM_HERE,
|
| - base::Bind(&ProxyResolvingClientSocket::ProcessProxyResolveDone,
|
| - weak_factory_.GetWeakPtr(), status));
|
| - }
|
| - old_user_connect_callback_ = callback;
|
| - return net::ERR_IO_PENDING;
|
| -}
|
| int ProxyResolvingClientSocket::Connect(
|
| const net::CompletionCallback& callback) {
|
| - DCHECK(!old_user_connect_callback_ && user_connect_callback_.is_null());
|
| + DCHECK(user_connect_callback_.is_null());
|
|
|
| tried_direct_connect_fallback_ = false;
|
|
|
| @@ -162,16 +129,9 @@ int ProxyResolvingClientSocket::Connect(
|
|
|
| void ProxyResolvingClientSocket::RunUserConnectCallback(int status) {
|
| DCHECK_LE(status, net::OK);
|
| - if (old_user_connect_callback_) {
|
| - net::OldCompletionCallback* user_connect_callback =
|
| - old_user_connect_callback_;
|
| - old_user_connect_callback_ = NULL;
|
| - user_connect_callback->Run(status);
|
| - } else {
|
| - net::CompletionCallback user_connect_callback = user_connect_callback_;
|
| - user_connect_callback_.Reset();
|
| - user_connect_callback.Run(status);
|
| - }
|
| + net::CompletionCallback user_connect_callback = user_connect_callback_;
|
| + user_connect_callback_.Reset();
|
| + user_connect_callback.Run(status);
|
| }
|
|
|
| // Always runs asynchronously.
|
| @@ -330,7 +290,6 @@ void ProxyResolvingClientSocket::Disconnect() {
|
| CloseTransportSocket();
|
| if (pac_request_)
|
| network_session_->proxy_service()->CancelPacRequest(pac_request_);
|
| - old_user_connect_callback_ = NULL;
|
| user_connect_callback_.Reset();
|
| }
|
|
|
|
|