OLD | NEW |
1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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/spdy/spdy_proxy_client_socket.h" | 5 #include "net/spdy/spdy_proxy_client_socket.h" |
6 | 6 |
7 #include <algorithm> // min | 7 #include <algorithm> // min |
8 | 8 |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/string_util.h" | 10 #include "base/string_util.h" |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
52 request_.extra_headers.SetHeader(HttpRequestHeaders::kUserAgent, | 52 request_.extra_headers.SetHeader(HttpRequestHeaders::kUserAgent, |
53 user_agent); | 53 user_agent); |
54 spdy_stream_->SetDelegate(this); | 54 spdy_stream_->SetDelegate(this); |
55 was_ever_used_ = spdy_stream_->WasEverUsed(); | 55 was_ever_used_ = spdy_stream_->WasEverUsed(); |
56 } | 56 } |
57 | 57 |
58 SpdyProxyClientSocket::~SpdyProxyClientSocket() { | 58 SpdyProxyClientSocket::~SpdyProxyClientSocket() { |
59 Disconnect(); | 59 Disconnect(); |
60 } | 60 } |
61 | 61 |
| 62 // In the event of a non-200 response to the CONNECT request, this |
| 63 // method may be called to return an HttpStream in order to read |
| 64 // the response body. |
| 65 HttpStream* SpdyProxyClientSocket::GetConnectResponseStream() { |
| 66 SpdyStream* stream = spdy_stream_; |
| 67 spdy_stream_ = NULL; |
| 68 return new SpdyHttpStream(stream); |
| 69 } |
| 70 |
62 // Sends a SYN_STREAM frame to the proxy with a CONNECT request | 71 // Sends a SYN_STREAM frame to the proxy with a CONNECT request |
63 // for the specified endpoint. Waits for the server to send back | 72 // for the specified endpoint. Waits for the server to send back |
64 // a SYN_REPLY frame. OK will be returned if the status is 200. | 73 // a SYN_REPLY frame. OK will be returned if the status is 200. |
65 // ERR_TUNNEL_CONNECTION_FAILED will be returned for any other status. | 74 // ERR_TUNNEL_CONNECTION_FAILED will be returned for any other status. |
66 // In any of these cases, Read() may be called to retrieve the HTTP | 75 // In any of these cases, Read() may be called to retrieve the HTTP |
67 // response body. Any other return values should be considered fatal. | 76 // response body. Any other return values should be considered fatal. |
68 // TODO(rch): handle 407 proxy auth requested correctly, perhaps | 77 // TODO(rch): handle 407 proxy auth requested correctly, perhaps |
69 // by creating a new stream for the subsequent request. | 78 // by creating a new stream for the subsequent request. |
70 // TODO(rch): create a more appropriate error code to disambiguate | 79 // TODO(rch): create a more appropriate error code to disambiguate |
71 // the HTTPS Proxy tunnel failure from an HTTP Proxy tunnel failure. | 80 // the HTTPS Proxy tunnel failure from an HTTP Proxy tunnel failure. |
(...skipping 276 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
348 | 357 |
349 next_state_ = STATE_OPEN; | 358 next_state_ = STATE_OPEN; |
350 if (net_log_.IsLoggingAllEvents()) { | 359 if (net_log_.IsLoggingAllEvents()) { |
351 net_log_.AddEvent( | 360 net_log_.AddEvent( |
352 NetLog::TYPE_HTTP_TRANSACTION_READ_TUNNEL_RESPONSE_HEADERS, | 361 NetLog::TYPE_HTTP_TRANSACTION_READ_TUNNEL_RESPONSE_HEADERS, |
353 make_scoped_refptr(new NetLogHttpResponseParameter(response_.headers))); | 362 make_scoped_refptr(new NetLogHttpResponseParameter(response_.headers))); |
354 } | 363 } |
355 | 364 |
356 if (response_.headers->response_code() == 200) | 365 if (response_.headers->response_code() == 200) |
357 return OK; | 366 return OK; |
| 367 else if (response_.headers->response_code() == 407) |
| 368 return ERR_TUNNEL_CONNECTION_FAILED; |
358 else | 369 else |
359 return ERR_TUNNEL_CONNECTION_FAILED; | 370 return ERR_HTTPS_PROXY_TUNNEL_CONNECTION_RESPONSE; |
360 } | 371 } |
361 | 372 |
362 // SpdyStream::Delegate methods: | 373 // SpdyStream::Delegate methods: |
363 // Called when SYN frame has been sent. | 374 // Called when SYN frame has been sent. |
364 // Returns true if no more data to be sent after SYN frame. | 375 // Returns true if no more data to be sent after SYN frame. |
365 bool SpdyProxyClientSocket::OnSendHeadersComplete(int status) { | 376 bool SpdyProxyClientSocket::OnSendHeadersComplete(int status) { |
366 DCHECK_EQ(next_state_, STATE_SEND_REQUEST_COMPLETE); | 377 DCHECK_EQ(next_state_, STATE_SEND_REQUEST_COMPLETE); |
367 | 378 |
368 OnIOComplete(status); | 379 OnIOComplete(status); |
369 | 380 |
(...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
462 read_callback->Run(status); | 473 read_callback->Run(status); |
463 } else if (read_callback_) { | 474 } else if (read_callback_) { |
464 // If we have a read_callback, the we need to make sure we call it back | 475 // If we have a read_callback, the we need to make sure we call it back |
465 OnDataReceived(NULL, 0); | 476 OnDataReceived(NULL, 0); |
466 } | 477 } |
467 if (write_callback) | 478 if (write_callback) |
468 write_callback->Run(ERR_CONNECTION_CLOSED); | 479 write_callback->Run(ERR_CONNECTION_CLOSED); |
469 } | 480 } |
470 | 481 |
471 } // namespace net | 482 } // namespace net |
OLD | NEW |