| 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_http_stream.h" | 5 #include "net/spdy/spdy_http_stream.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <list> | 8 #include <list> |
| 9 #include <string> | 9 #include <string> |
| 10 | 10 |
| (...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 134 user_buffer_len_ = buf_len; | 134 user_buffer_len_ = buf_len; |
| 135 return ERR_IO_PENDING; | 135 return ERR_IO_PENDING; |
| 136 } | 136 } |
| 137 | 137 |
| 138 void SpdyHttpStream::Close(bool not_reusable) { | 138 void SpdyHttpStream::Close(bool not_reusable) { |
| 139 // Note: the not_reusable flag has no meaning for SPDY streams. | 139 // Note: the not_reusable flag has no meaning for SPDY streams. |
| 140 | 140 |
| 141 Cancel(); | 141 Cancel(); |
| 142 } | 142 } |
| 143 | 143 |
| 144 HttpStream* SpdyHttpStream::RenewStreamForAuth() { |
| 145 return NULL; |
| 146 } |
| 147 |
| 148 bool SpdyHttpStream::IsResponseBodyComplete() const { |
| 149 if (!stream_) |
| 150 return false; |
| 151 return stream_->closed(); |
| 152 } |
| 153 |
| 154 bool SpdyHttpStream::CanFindEndOfResponse() const { |
| 155 return true; |
| 156 } |
| 157 |
| 158 bool SpdyHttpStream::IsMoreDataBuffered() const { |
| 159 return false; |
| 160 } |
| 161 |
| 162 bool SpdyHttpStream::IsConnectionReused() const { |
| 163 return spdy_session_->IsReused(); |
| 164 } |
| 165 |
| 166 void SpdyHttpStream::SetConnectionReused() { |
| 167 // SPDY doesn't need an indicator here. |
| 168 } |
| 169 |
| 144 int SpdyHttpStream::SendRequest(const HttpRequestHeaders& request_headers, | 170 int SpdyHttpStream::SendRequest(const HttpRequestHeaders& request_headers, |
| 145 UploadDataStream* request_body, | 171 UploadDataStream* request_body, |
| 146 HttpResponseInfo* response, | 172 HttpResponseInfo* response, |
| 147 CompletionCallback* callback) { | 173 CompletionCallback* callback) { |
| 148 base::Time request_time = base::Time::Now(); | 174 base::Time request_time = base::Time::Now(); |
| 149 CHECK(stream_.get()); | 175 CHECK(stream_.get()); |
| 150 | 176 |
| 151 stream_->SetDelegate(this); | 177 stream_->SetDelegate(this); |
| 152 | 178 |
| 153 linked_ptr<spdy::SpdyHeaderBlock> headers(new spdy::SpdyHeaderBlock); | 179 linked_ptr<spdy::SpdyHeaderBlock> headers(new spdy::SpdyHeaderBlock); |
| (...skipping 236 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 390 stream_->GetSSLInfo(ssl_info, &using_npn); | 416 stream_->GetSSLInfo(ssl_info, &using_npn); |
| 391 } | 417 } |
| 392 | 418 |
| 393 void SpdyHttpStream::GetSSLCertRequestInfo( | 419 void SpdyHttpStream::GetSSLCertRequestInfo( |
| 394 SSLCertRequestInfo* cert_request_info) { | 420 SSLCertRequestInfo* cert_request_info) { |
| 395 DCHECK(stream_); | 421 DCHECK(stream_); |
| 396 stream_->GetSSLCertRequestInfo(cert_request_info); | 422 stream_->GetSSLCertRequestInfo(cert_request_info); |
| 397 } | 423 } |
| 398 | 424 |
| 399 } // namespace net | 425 } // namespace net |
| OLD | NEW |