| Index: net/websockets/websocket_stream.cc
|
| diff --git a/net/websockets/websocket_stream.cc b/net/websockets/websocket_stream.cc
|
| index 36b0ad4e5c95352afcf3a80e5af147a0dd7f8b3c..86dce7d4a6ba42cfa33d94fdaf2bbe00fc3dc0f6 100644
|
| --- a/net/websockets/websocket_stream.cc
|
| +++ b/net/websockets/websocket_stream.cc
|
| @@ -84,7 +84,8 @@ class StreamRequestImpl : public WebSocketStreamRequest {
|
| scoped_ptr<WebSocketStream::ConnectDelegate> connect_delegate,
|
| scoped_ptr<WebSocketHandshakeStreamCreateHelper> create_helper)
|
| : delegate_(new Delegate(this)),
|
| - url_request_(url, DEFAULT_PRIORITY, delegate_.get(), context),
|
| + url_request_(context->CreateRequest(url, DEFAULT_PRIORITY,
|
| + delegate_.get(), NULL)),
|
| connect_delegate_(connect_delegate.Pass()),
|
| create_helper_(create_helper.release()) {
|
| create_helper_->set_failure_message(&failure_message_);
|
| @@ -94,15 +95,15 @@ class StreamRequestImpl : public WebSocketStreamRequest {
|
| headers.SetHeader(HttpRequestHeaders::kOrigin, origin.string());
|
| headers.SetHeader(websockets::kSecWebSocketVersion,
|
| websockets::kSupportedVersion);
|
| - url_request_.SetExtraRequestHeaders(headers);
|
| + url_request_->SetExtraRequestHeaders(headers);
|
|
|
| // This passes the ownership of |create_helper_| to |url_request_|.
|
| - url_request_.SetUserData(
|
| + url_request_->SetUserData(
|
| WebSocketHandshakeStreamBase::CreateHelper::DataKey(),
|
| create_helper_);
|
| - url_request_.SetLoadFlags(LOAD_DISABLE_CACHE |
|
| - LOAD_BYPASS_CACHE |
|
| - LOAD_DO_NOT_PROMPT_FOR_LOGIN);
|
| + url_request_->SetLoadFlags(LOAD_DISABLE_CACHE |
|
| + LOAD_BYPASS_CACHE |
|
| + LOAD_DO_NOT_PROMPT_FOR_LOGIN);
|
| }
|
|
|
| // Destroying this object destroys the URLRequest, which cancels the request
|
| @@ -110,7 +111,7 @@ class StreamRequestImpl : public WebSocketStreamRequest {
|
| virtual ~StreamRequestImpl() {}
|
|
|
| void Start() {
|
| - url_request_.Start();
|
| + url_request_->Start();
|
| }
|
|
|
| void PerformUpgrade() {
|
| @@ -119,7 +120,7 @@ class StreamRequestImpl : public WebSocketStreamRequest {
|
|
|
| void ReportFailure() {
|
| if (failure_message_.empty()) {
|
| - switch (url_request_.status().status()) {
|
| + switch (url_request_->status().status()) {
|
| case URLRequestStatus::SUCCESS:
|
| case URLRequestStatus::IO_PENDING:
|
| break;
|
| @@ -129,7 +130,7 @@ class StreamRequestImpl : public WebSocketStreamRequest {
|
| case URLRequestStatus::FAILED:
|
| failure_message_ =
|
| std::string("Error in connection establishment: ") +
|
| - ErrorToString(url_request_.status().error());
|
| + ErrorToString(url_request_->status().error());
|
| break;
|
| }
|
| }
|
| @@ -147,7 +148,7 @@ class StreamRequestImpl : public WebSocketStreamRequest {
|
|
|
| // Deleting the StreamRequestImpl object deletes this URLRequest object,
|
| // cancelling the whole connection.
|
| - URLRequest url_request_;
|
| + scoped_ptr<URLRequest> url_request_;
|
|
|
| scoped_ptr<WebSocketStream::ConnectDelegate> connect_delegate_;
|
|
|
|
|