Chromium Blob hacking

webkit/browser/fileapi/file_system_operation_runner.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 "webkit/browser/fileapi/file_system_operation_runner.h"
 
 #include "base/bind.h"
 #include "net/url_request/url_request_context.h"
+#include "webkit/browser/blob/blob_url_request_job_factory.h"
 #include "webkit/browser/fileapi/file_observers.h"
 #include "webkit/browser/fileapi/file_stream_writer.h"
 #include "webkit/browser/fileapi/file_system_context.h"
 #include "webkit/browser/fileapi/file_system_operation_impl.h"
 #include "webkit/browser/fileapi/file_writer_delegate.h"
 #include "webkit/common/blob/shareable_file_reference.h"
 
 namespace fileapi {
 
 typedef FileSystemOperationRunner::OperationID OperationID;
@@ skipping 181 matching lines @@
   operation->Remove(
       url, recursive,
       base::Bind(&FileSystemOperationRunner::DidFinish, AsWeakPtr(),
                  id, callback));
   return id;
 }
 
 OperationID FileSystemOperationRunner::Write(
     const net::URLRequestContext* url_request_context,
     const FileSystemURL& url,
-    const GURL& blob_url,
+    scoped_ptr<webkit_blob::BlobDataHandle> blob,
     int64 offset,
     const WriteCallback& callback) {
   base::PlatformFileError error = base::PLATFORM_FILE_OK;
   FileSystemOperation* operation =
       file_system_context_->CreateFileSystemOperation(url, &error);
   if (!operation) {
     callback.Run(error, 0, true);
     return kErrorOperationID;
   }
 
   scoped_ptr<FileStreamWriter> writer(
       file_system_context_->CreateFileStreamWriter(url, offset));
   if (!writer) {
     // Write is not supported.
     callback.Run(base::PLATFORM_FILE_ERROR_SECURITY, 0, true);
     return kErrorOperationID;
   }
 
-  DCHECK(blob_url.is_valid());
   scoped_ptr<FileWriterDelegate> writer_delegate(
       new FileWriterDelegate(writer.Pass()));
-  scoped_ptr<net::URLRequest> blob_request(url_request_context->CreateRequest(
-      blob_url, writer_delegate.get()));
+
+  scoped_ptr<net::URLRequest> blob_request(
+      webkit_blob::BlobProtocolHandler::CreateBlobRequest(
+          blob.Pass(),
+          url_request_context,
+          writer_delegate.get()));
 
   OperationID id = operations_.Add(operation);
   PrepareForWrite(id, url);
   operation->Write(
       url, writer_delegate.Pass(), blob_request.Pass(),
       base::Bind(&FileSystemOperationRunner::DidWrite, AsWeakPtr(),
                  id, callback));
   return id;
 }
 
@@ skipping 296 matching lines @@
             &FileUpdateObserver::OnEndUpdate, MakeTuple(*iter));
       }
     }
     write_target_urls_.erase(found);
   }
   DCHECK(operations_.Lookup(id));
   operations_.Remove(id);
 }
 
 }  // namespace fileapi