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 // TODO(ukai): code is similar with http_network_transaction.cc. We should | 5 // TODO(ukai): code is similar with http_network_transaction.cc. We should |
6 // think about ways to share code, if possible. | 6 // think about ways to share code, if possible. |
7 | 7 |
8 #include "net/socket_stream/socket_stream.h" | 8 #include "net/socket_stream/socket_stream.h" |
9 | 9 |
10 #include <set> | 10 #include <set> |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
49 void SocketStream::ResponseHeaders::Realloc(size_t new_size) { | 49 void SocketStream::ResponseHeaders::Realloc(size_t new_size) { |
50 headers_.reset(static_cast<char*>(realloc(headers_.release(), new_size))); | 50 headers_.reset(static_cast<char*>(realloc(headers_.release(), new_size))); |
51 } | 51 } |
52 | 52 |
53 SocketStream::ResponseHeaders::~ResponseHeaders() { data_ = NULL; } | 53 SocketStream::ResponseHeaders::~ResponseHeaders() { data_ = NULL; } |
54 | 54 |
55 SocketStream::SocketStream(const GURL& url, Delegate* delegate) | 55 SocketStream::SocketStream(const GURL& url, Delegate* delegate) |
56 : delegate_(delegate), | 56 : delegate_(delegate), |
57 url_(url), | 57 url_(url), |
58 max_pending_send_allowed_(kMaxPendingSendAllowed), | 58 max_pending_send_allowed_(kMaxPendingSendAllowed), |
| 59 context_(NULL), |
59 next_state_(STATE_NONE), | 60 next_state_(STATE_NONE), |
60 host_resolver_(NULL), | 61 host_resolver_(NULL), |
61 cert_verifier_(NULL), | 62 cert_verifier_(NULL), |
62 server_bound_cert_service_(NULL), | 63 server_bound_cert_service_(NULL), |
63 http_auth_handler_factory_(NULL), | 64 http_auth_handler_factory_(NULL), |
64 factory_(ClientSocketFactory::GetDefaultFactory()), | 65 factory_(ClientSocketFactory::GetDefaultFactory()), |
65 proxy_mode_(kDirectConnection), | 66 proxy_mode_(kDirectConnection), |
66 proxy_url_(url), | 67 proxy_url_(url), |
67 pac_request_(NULL), | 68 pac_request_(NULL), |
68 // Unretained() is required; without it, Bind() creates a circular | 69 // Unretained() is required; without it, Bind() creates a circular |
(...skipping 25 matching lines...) Expand all Loading... |
94 } | 95 } |
95 | 96 |
96 void SocketStream::SetUserData(const void* key, UserData* data) { | 97 void SocketStream::SetUserData(const void* key, UserData* data) { |
97 user_data_[key] = linked_ptr<UserData>(data); | 98 user_data_[key] = linked_ptr<UserData>(data); |
98 } | 99 } |
99 | 100 |
100 bool SocketStream::is_secure() const { | 101 bool SocketStream::is_secure() const { |
101 return url_.SchemeIs("wss"); | 102 return url_.SchemeIs("wss"); |
102 } | 103 } |
103 | 104 |
104 void SocketStream::set_context(URLRequestContext* context) { | 105 void SocketStream::set_context(const URLRequestContext* context) { |
105 scoped_refptr<URLRequestContext> prev_context = context_; | 106 const URLRequestContext* prev_context = context_; |
106 | 107 |
107 context_ = context; | 108 context_ = context; |
108 | 109 |
109 if (prev_context != context) { | 110 if (prev_context != context) { |
110 if (prev_context && pac_request_) { | 111 if (prev_context && pac_request_) { |
111 prev_context->proxy_service()->CancelPacRequest(pac_request_); | 112 prev_context->proxy_service()->CancelPacRequest(pac_request_); |
112 pac_request_ = NULL; | 113 pac_request_ = NULL; |
113 } | 114 } |
114 | 115 |
115 net_log_.EndEvent(NetLog::TYPE_REQUEST_ALIVE, NULL); | 116 net_log_.EndEvent(NetLog::TYPE_REQUEST_ALIVE, NULL); |
(...skipping 1100 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1216 | 1217 |
1217 SSLConfigService* SocketStream::ssl_config_service() const { | 1218 SSLConfigService* SocketStream::ssl_config_service() const { |
1218 return context_->ssl_config_service(); | 1219 return context_->ssl_config_service(); |
1219 } | 1220 } |
1220 | 1221 |
1221 ProxyService* SocketStream::proxy_service() const { | 1222 ProxyService* SocketStream::proxy_service() const { |
1222 return context_->proxy_service(); | 1223 return context_->proxy_service(); |
1223 } | 1224 } |
1224 | 1225 |
1225 } // namespace net | 1226 } // namespace net |
OLD | NEW |