Chromium Blob hacking

chrome/browser/sync_file_system/local/canned_syncable_file_system.cc

 // Copyright 2013 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 "chrome/browser/sync_file_system/local/canned_syncable_file_system.h"
 
 #include <iterator>
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
@@ skipping 128 matching lines @@
   std::copy(entries.begin(), entries.end(), std::back_inserter(*entries_out));
 
   if (!has_more)
     callback.Run(error);
 }
 
 class WriteHelper {
  public:
   WriteHelper() : bytes_written_(0) {}
   WriteHelper(MockBlobURLRequestContext* request_context,
-              const GURL& blob_url,
+              const std::string& blob_id,
               const std::string& blob_data)
       : bytes_written_(0),
         request_context_(request_context),
-        blob_data_(new ScopedTextBlob(*request_context, blob_url, blob_data)) {}
+        blob_data_(new ScopedTextBlob(*request_context, blob_id, blob_data)) {}
 
   ~WriteHelper() {
     if (request_context_) {
       base::MessageLoop::current()->DeleteSoon(FROM_HERE,
                                                request_context_.release());
     }
   }
 
+  ScopedTextBlob* scoped_text_blob() const { return blob_data_.get(); }
+
   void DidWrite(const base::Callback<void(int64 result)>& completion_callback,
                 PlatformFileError error, int64 bytes, bool complete) {
     if (error == base::PLATFORM_FILE_OK) {
       bytes_written_ += bytes;
       if (!complete)
         return;
     }
     completion_callback.Run(error == base::PLATFORM_FILE_OK
                             ? bytes_written_ : static_cast<int64>(error));
   }
@@ skipping 268 matching lines @@
       io_task_runner_.get(),
       FROM_HERE,
       base::Bind(&CannedSyncableFileSystem::DoReadDirectory,
           base::Unretained(this),
           url,
           entries));
 }
 
 int64 CannedSyncableFileSystem::Write(
     net::URLRequestContext* url_request_context,
-    const FileSystemURL& url, const GURL& blob_url) {
+    const FileSystemURL& url,
+    scoped_ptr<webkit_blob::BlobDataHandle> blob_data_handle) {
   return RunOnThread<int64>(io_task_runner_.get(),
                             FROM_HERE,
                             base::Bind(&CannedSyncableFileSystem::DoWrite,
                                        base::Unretained(this),
                                        url_request_context,
                                        url,
-                                       blob_url));
+                                       base::Passed(&blob_data_handle)));
 }
 
 int64 CannedSyncableFileSystem::WriteString(
     const FileSystemURL& url, const std::string& data) {
   return RunOnThread<int64>(io_task_runner_.get(),
                             FROM_HERE,
                             base::Bind(&CannedSyncableFileSystem::DoWriteString,
                                        base::Unretained(this),
                                        url,
                                        data));
@@ skipping 150 matching lines @@
     const FileSystemURL& url,
     FileEntryList* entries,
     const StatusCallback& callback) {
   EXPECT_TRUE(is_filesystem_opened_);
   operation_runner()->ReadDirectory(
       url, base::Bind(&OnReadDirectory, entries, callback));
 }
 
 void CannedSyncableFileSystem::DoWrite(
     net::URLRequestContext* url_request_context,
-    const FileSystemURL& url, const GURL& blob_url,
+    const FileSystemURL& url,
+    scoped_ptr<webkit_blob::BlobDataHandle> blob_data_handle,
     const WriteCallback& callback) {
   EXPECT_TRUE(is_filesystem_opened_);
   WriteHelper* helper = new WriteHelper;
-  operation_runner()->Write(url_request_context, url, blob_url, 0,
+  operation_runner()->Write(url_request_context, url,
+                            blob_data_handle.Pass(), 0,
                             base::Bind(&WriteHelper::DidWrite,
                                        base::Owned(helper), callback));
 }
 
 void CannedSyncableFileSystem::DoWriteString(
     const FileSystemURL& url,
     const std::string& data,
     const WriteCallback& callback) {
   MockBlobURLRequestContext* url_request_context(
       new MockBlobURLRequestContext(file_system_context_.get()));
-  const GURL blob_url(std::string("blob:") + data);
-  WriteHelper* helper = new WriteHelper(url_request_context, blob_url, data);
-  operation_runner()->Write(url_request_context, url, blob_url, 0,
+  const std::string blob_id(std::string("blob:") + data);

[ericu, 2013/08/21 23:26:09]

What's this blob_id for?  Why are you putting the data in there?  That looks
wrong.

[michaeln, 2013/08/27 23:24:06]

Done.

+  WriteHelper* helper = new WriteHelper(url_request_context, blob_id, data);
+  operation_runner()->Write(url_request_context, url,
+                            helper->scoped_text_blob()->GetBlobDataHandle(), 0,
                             base::Bind(&WriteHelper::DidWrite,
                                        base::Owned(helper), callback));
 }
 
 void CannedSyncableFileSystem::DoGetUsageAndQuota(
     int64* usage,
     int64* quota,
     const quota::StatusCallback& callback) {
   quota_manager_->GetUsageAndQuota(
       origin_, storage_type(),
@@ skipping 13 matching lines @@
   sync_status_ = status;
   base::MessageLoop::current()->Quit();
 }
 
 void CannedSyncableFileSystem::InitializeSyncStatusObserver() {
   ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread());
   backend()->sync_context()->sync_status()->AddObserver(this);
 }
 
 }  // namespace sync_file_system