Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(216)

Side by Side Diff: net/spdy/spdy_http_stream.cc

Issue 6134003: Prototype of chunked transfer encoded POST. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: . Created 9 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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 246 matching lines...) Expand 10 before | Expand all | Expand 10 after
257 CHECK(request_body_stream_.get()); 257 CHECK(request_body_stream_.get());
258 int buf_len = static_cast<int>(request_body_stream_->buf_len()); 258 int buf_len = static_cast<int>(request_body_stream_->buf_len());
259 if (!buf_len) 259 if (!buf_len)
260 return OK; 260 return OK;
261 return stream_->WriteStreamData(request_body_stream_->buf(), buf_len, 261 return stream_->WriteStreamData(request_body_stream_->buf(), buf_len,
262 spdy::DATA_FLAG_FIN); 262 spdy::DATA_FLAG_FIN);
263 } 263 }
264 264
265 bool SpdyHttpStream::OnSendBodyComplete(int status) { 265 bool SpdyHttpStream::OnSendBodyComplete(int status) {
266 CHECK(request_body_stream_.get()); 266 CHECK(request_body_stream_.get());
267 request_body_stream_->DidConsume(status); 267 request_body_stream_->ConsumeAndFillBuffer(status);
268 return request_body_stream_->eof(); 268 return request_body_stream_->eof();
269 } 269 }
270 270
271 int SpdyHttpStream::OnResponseReceived(const spdy::SpdyHeaderBlock& response, 271 int SpdyHttpStream::OnResponseReceived(const spdy::SpdyHeaderBlock& response,
272 base::Time response_time, 272 base::Time response_time,
273 int status) { 273 int status) {
274 if (!response_info_) { 274 if (!response_info_) {
275 DCHECK(stream_->pushed()); 275 DCHECK(stream_->pushed());
276 push_response_info_.reset(new HttpResponseInfo); 276 push_response_info_.reset(new HttpResponseInfo);
277 response_info_ = push_response_info_.get(); 277 response_info_ = push_response_info_.get();
(...skipping 149 matching lines...) Expand 10 before | Expand all | Expand 10 after
427 stream_->GetSSLInfo(ssl_info, &using_npn); 427 stream_->GetSSLInfo(ssl_info, &using_npn);
428 } 428 }
429 429
430 void SpdyHttpStream::GetSSLCertRequestInfo( 430 void SpdyHttpStream::GetSSLCertRequestInfo(
431 SSLCertRequestInfo* cert_request_info) { 431 SSLCertRequestInfo* cert_request_info) {
432 DCHECK(stream_); 432 DCHECK(stream_);
433 stream_->GetSSLCertRequestInfo(cert_request_info); 433 stream_->GetSSLCertRequestInfo(cert_request_info);
434 } 434 }
435 435
436 } // namespace net 436 } // namespace net
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698