Index: net/websockets/websocket_job.cc |
=================================================================== |
--- net/websockets/websocket_job.cc (revision 256594) |
+++ net/websockets/websocket_job.cc (working copy) |
@@ -36,9 +36,10 @@ |
}; |
net::SocketStreamJob* WebSocketJobFactory( |
- const GURL& url, net::SocketStream::Delegate* delegate) { |
+ const GURL& url, net::SocketStream::Delegate* delegate, |
+ net::URLRequestContext* context, net::CookieStore* cookie_store) { |
net::WebSocketJob* job = new net::WebSocketJob(delegate); |
- job->InitSocketStream(new net::SocketStream(url, job)); |
+ job->InitSocketStream(new net::SocketStream(url, job, context, cookie_store)); |
return job; |
} |
@@ -370,11 +371,11 @@ |
if (socket_.get() && delegate_ && state_ == CONNECTING) { |
handshake_request_->RemoveHeaders(kCookieHeaders, |
arraysize(kCookieHeaders)); |
- if (allow && socket_->context()->cookie_store()) { |
+ if (allow && socket_->cookie_store()) { |
// Add cookies, including HttpOnly cookies. |
CookieOptions cookie_options; |
cookie_options.set_include_httponly(); |
- socket_->context()->cookie_store()->GetCookiesWithOptionsAsync( |
+ socket_->cookie_store()->GetCookiesWithOptionsAsync( |
GetURLForCookies(), cookie_options, |
base::Bind(&WebSocketJob::LoadCookieCallback, |
weak_ptr_factory_.GetWeakPtr())); |
@@ -505,7 +506,7 @@ |
callback_pending_ = false; |
save_next_cookie_running_ = true; |
- if (socket_->context()->cookie_store()) { |
+ if (socket_->cookie_store()) { |
GURL url_for_cookies = GetURLForCookies(); |
CookieOptions options; |
@@ -526,7 +527,7 @@ |
continue; |
callback_pending_ = true; |
- socket_->context()->cookie_store()->SetCookieWithOptionsAsync( |
+ socket_->cookie_store()->SetCookieWithOptionsAsync( |
url_for_cookies, cookie, options, |
base::Bind(&WebSocketJob::OnCookieSaved, |
weak_ptr_factory_.GetWeakPtr())); |