Index: net/http/http_proxy_client_socket.cc |
=================================================================== |
--- net/http/http_proxy_client_socket.cc (revision 108933) |
+++ net/http/http_proxy_client_socket.cc (working copy) |
@@ -68,7 +68,7 @@ |
DCHECK(!user_callback_); |
int rv = PrepareForAuthRestart(); |
- if (rv != OK) |
+ if (rv != OK || next_state_ == STATE_NONE) |
return rv; |
rv = DoLoop(OK); |
@@ -77,6 +77,11 @@ |
return rv; |
} |
+const |
+scoped_refptr<HttpAuthController>& HttpProxyClientSocket::auth_controller() { |
+ return auth_; |
+} |
+ |
const HttpResponseInfo* HttpProxyClientSocket::GetConnectResponseInfo() const { |
return response_.headers ? &response_ : NULL; |
} |
@@ -251,10 +256,7 @@ |
next_state_ = STATE_GENERATE_AUTH_TOKEN; |
transport_->set_is_reused(true); |
} else { |
- // This assumes that the underlying transport socket is a TCP socket, |
- // since only TCP sockets are restartable. |
- next_state_ = STATE_TCP_RESTART; |
- transport_->socket()->Disconnect(); |
+ next_state_ = STATE_NONE; |
} |
// Reset the other member variables. |
@@ -347,13 +349,6 @@ |
case STATE_DRAIN_BODY_COMPLETE: |
rv = DoDrainBodyComplete(rv); |
break; |
- case STATE_TCP_RESTART: |
- DCHECK_EQ(OK, rv); |
- rv = DoTCPRestart(); |
- break; |
- case STATE_TCP_RESTART_COMPLETE: |
- rv = DoTCPRestartComplete(rv); |
- break; |
case STATE_DONE: |
break; |
default: |
@@ -488,17 +483,4 @@ |
return OK; |
} |
-int HttpProxyClientSocket::DoTCPRestart() { |
- next_state_ = STATE_TCP_RESTART_COMPLETE; |
- return transport_->socket()->Connect(&io_callback_); |
-} |
- |
-int HttpProxyClientSocket::DoTCPRestartComplete(int result) { |
- if (result != OK) |
- return result; |
- |
- next_state_ = STATE_GENERATE_AUTH_TOKEN; |
- return result; |
-} |
- |
} // namespace net |