Support sending BlobData to browser process. Also support sending UploadData...

webkit/blob/blob_storage_controller.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 "webkit/blob/blob_storage_controller.h"
+
+#include "base/logging.h"
+#include "googleurl/src/gurl.h"
+#include "webkit/blob/blob_data.h"
+
+namespace webkit_blob {
+
+BlobStorageController::BlobStorageController() {
+}
+
+BlobStorageController::~BlobStorageController() {
+}
+
+void BlobStorageController::AppendStorageItems(
+    BlobData* target_blob_data, BlobData* src_blob_data,
+    uint64 offset, uint64 length) {
+  DCHECK(target_blob_data && src_blob_data &&
+         length != static_cast<uint64>(-1));
+
+  std::vector<BlobData::Item>::const_iterator iter =
+      src_blob_data->items().begin();
+  if (offset) {
+    for (; iter != src_blob_data->items().end(); ++iter) {
+      if (offset >= iter->length())
+        offset -= iter->length();
+      else
+        break;
+    }
+  }
+
+  for (; iter != src_blob_data->items().end() && length > 0; ++iter) {
+    uint64 current_length = iter->length() - offset;
+    uint64 new_length = current_length > length ? length : current_length;
+    if (iter->type() == BlobData::TYPE_DATA) {
+      target_blob_data->AppendData(iter->data(),
+                                   static_cast<uint32>(iter->offset() + offset),
+                                   static_cast<uint32>(new_length));
+    } else {
+      DCHECK(iter->type() == BlobData::TYPE_FILE);
+      target_blob_data->AppendFile(iter->file_path(),
+                                   iter->offset() + offset,
+                                   new_length,
+                                   iter->expected_modification_time());
+    }
+    length -= new_length;
+    offset = 0;
+  }
+}
+
+void BlobStorageController::RegisterBlobUrl(
+    const GURL& url, const BlobData* blob_data) {
+  scoped_refptr<BlobData> target_blob_data = new BlobData();
+  target_blob_data->set_content_type(blob_data->content_type());
+  target_blob_data->set_content_disposition(blob_data->content_disposition());
+
+  // The blob data is stored in the "canonical" way. That is, it only contains a
+  // list of Data and File items.
+  // 1) The Data item is denoted by the raw data and the range.
+  // 2) The File item is denoted by the file path, the range and the expected
+  //    modification time.
+  // All the Blob items in the passing blob data are resolved and expanded into
+  // a set of Data and File items.
+
+  for (std::vector<BlobData::Item>::const_iterator iter =
+           blob_data->items().begin();
+       iter != blob_data->items().end(); ++iter) {
+    switch (iter->type()) {
+      case BlobData::TYPE_DATA:
+        target_blob_data->AppendData(iter->data());
+        break;
+      case BlobData::TYPE_FILE:
+        target_blob_data->AppendFile(iter->file_path(),
+                                     iter->offset(),
+                                     iter->length(),
+                                     iter->expected_modification_time());
+        break;
+      case BlobData::TYPE_BLOB: {
+        scoped_refptr<BlobData> src_blob_data =
+            blob_map_[iter->blob_url().spec()];
+        DCHECK(src_blob_data.get());
+        if (src_blob_data.get())
+          AppendStorageItems(target_blob_data.get(),
+                             src_blob_data.get(),
+                             iter->offset(),
+                             iter->length());
+        break;
+      }
+    }
+  }
+
+  blob_map_[url.spec()] = target_blob_data;
+}
+
+void BlobStorageController::RegisterBlobUrlFrom(
+    const GURL& url, const GURL& src_url) {
+  BlobData* blob_data = GetBlobDataFromUrl(src_url);
+  if (!blob_data)
+    return;
+
+  blob_map_[url.spec()] = blob_data;
+}
+
+void BlobStorageController::UnregisterBlobUrl(const GURL& url) {
+  blob_map_.erase(url.spec());
+}
+
+BlobData* BlobStorageController::GetBlobDataFromUrl(const GURL& url) {
+  return (blob_map_.find(url.spec()) == blob_map_.end()) ?
+      NULL : blob_map_[url.spec()].get();
+}
+
+}  // namespace webkit_blob