1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
// 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
|
