Prototype of chunked transfer encoded POST.

net/url_request/url_request.cc

 // Copyright (c) 2010 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "net/url_request/url_request.h"
 
 #include "base/compiler_specific.h"
 #include "base/message_loop.h"
 #include "base/metrics/stats_counters.h"
 #include "base/singleton.h"
@@ skipping 84 matching lines @@
 // URLRequest
 
 URLRequest::URLRequest(const GURL& url, Delegate* delegate)
     : url_(url),
       original_url_(url),
       method_("GET"),
       load_flags_(net::LOAD_NORMAL),
       delegate_(delegate),
       is_pending_(false),
       enable_profiling_(false),
+      chunked_transfer_upload_(false),
       redirect_limit_(kMaxRedirects),
       final_upload_progress_(0),
       priority_(net::LOWEST) {
   SIMPLE_STATS_COUNTER("URLRequestCount");
 
   // Sanity check out environment.
   DCHECK(MessageLoop::current()) <<
       "The current MessageLoop must exist";
   DCHECK_EQ(MessageLoop::TYPE_IO, MessageLoop::current()->type()) <<
       "The current MessageLoop must be TYPE_IO";
@@ skipping 38 matching lines @@
     uint64 offset,
     uint64 length,
     const base::Time& expected_modification_time) {
   DCHECK(file_path.value().length() > 0 && length > 0);
   if (!upload_)
     upload_ = new UploadData();
   upload_->AppendFileRange(file_path, offset, length,
                            expected_modification_time);
 }
 
+void URLRequest::AppendChunkToUpload(const char* bytes, int bytes_len) {
+  DCHECK(bytes_len > 0);
+  DCHECK(upload_);
+  upload_->AppendChunk(bytes, bytes_len);
+}
+
+void URLRequest::MarkEndOfChunks() {
+  DCHECK(upload_);
+  upload_->AppendChunk(NULL, 0);
+}
+
 void URLRequest::set_upload(net::UploadData* upload) {
   upload_ = upload;
 }
 
 // Get the upload data directly.
 net::UploadData* URLRequest::get_upload() {
   return upload_.get();
 }
 
 bool URLRequest::has_upload() const {
@@ skipping 136 matching lines @@
     GURL::Replacements referrer_mods;
     referrer_mods.ClearUsername();
     referrer_mods.ClearPassword();
     ret = ret.ReplaceComponents(referrer_mods);
   }
 
   return ret;
 }
 
 void URLRequest::Start() {
+  if (chunked_transfer_upload_) {
+    DCHECK(!upload_);
+    upload_ = new UploadData();
+    upload_->set_is_chunked(true);
+  }
+
   StartJob(URLRequestJobManager::GetInstance()->CreateJob(this));
 }
 
 ///////////////////////////////////////////////////////////////////////////////
 
 void URLRequest::StartJob(URLRequestJob* job) {
   DCHECK(!is_pending_);
   DCHECK(!job_);
 
   net_log_.BeginEvent(
@@ skipping 267 matching lines @@
   if (found != user_data_.end())
     return found->second.get();
   return NULL;
 }
 
 void URLRequest::SetUserData(const void* key, UserData* data) {
   user_data_[key] = linked_ptr<UserData>(data);
 }
 
 }  // namespace net