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
118
119
120
121
122
123
124
125
126
127
|
// 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 "content/child/webblobregistry_impl.h"
#include "base/memory/ref_counted.h"
#include "base/message_loop.h"
#include "base/shared_memory.h"
#include "content/common/child_thread.h"
#include "content/common/fileapi/webblob_messages.h"
#include "content/common/thread_safe_sender.h"
#include "third_party/WebKit/public/platform/WebBlobData.h"
#include "third_party/WebKit/public/platform/WebString.h"
#include "third_party/WebKit/public/platform/WebURL.h"
#include "webkit/base/file_path_string_conversions.h"
#include "webkit/common/blob/blob_data.h"
using WebKit::WebBlobData;
using WebKit::WebString;
using WebKit::WebURL;
namespace content {
WebBlobRegistryImpl::WebBlobRegistryImpl(ThreadSafeSender* sender)
: sender_(sender) {
}
WebBlobRegistryImpl::~WebBlobRegistryImpl() {
}
void WebBlobRegistryImpl::registerBlobURL(
const WebURL& url, WebBlobData& data) {
DCHECK(ChildThread::current()->message_loop() ==
base::MessageLoop::current());
const size_t kLargeThresholdBytes = 250 * 1024;
const size_t kMaxSharedMemoryBytes = 10 * 1024 * 1024;
sender_->Send(new BlobHostMsg_StartBuildingBlob(url));
size_t i = 0;
WebBlobData::Item data_item;
while (data.itemAt(i++, data_item)) {
webkit_blob::BlobData::Item item;
switch (data_item.type) {
case WebBlobData::Item::TypeData: {
// WebBlobData does not allow partial data items.
DCHECK(!data_item.offset && data_item.length == -1);
if (data_item.data.size() == 0)
break;
if (data_item.data.size() < kLargeThresholdBytes) {
item.SetToBytes(data_item.data.data(), data_item.data.size());
sender_->Send(new BlobHostMsg_AppendBlobDataItem(url, item));
} else {
// We handle larger amounts of data via SharedMemory instead of
// writing it directly to the IPC channel.
size_t data_size = data_item.data.size();
const char* data_ptr = data_item.data.data();
size_t shared_memory_size = std::min(
data_size, kMaxSharedMemoryBytes);
scoped_ptr<base::SharedMemory> shared_memory(
ChildThread::AllocateSharedMemory(shared_memory_size,
sender_.get()));
CHECK(shared_memory.get());
while (data_size) {
size_t chunk_size = std::min(data_size, shared_memory_size);
memcpy(shared_memory->memory(), data_ptr, chunk_size);
sender_->Send(new BlobHostMsg_SyncAppendSharedMemory(
url, shared_memory->handle(), chunk_size));
data_size -= chunk_size;
data_ptr += chunk_size;
}
}
break;
}
case WebBlobData::Item::TypeFile:
if (data_item.length) {
item.SetToFilePathRange(
webkit_base::WebStringToFilePath(data_item.filePath),
static_cast<uint64>(data_item.offset),
static_cast<uint64>(data_item.length),
base::Time::FromDoubleT(data_item.expectedModificationTime));
sender_->Send(new BlobHostMsg_AppendBlobDataItem(url, item));
}
break;
case WebBlobData::Item::TypeBlob:
if (data_item.length) {
item.SetToBlobUrlRange(
data_item.blobURL,
static_cast<uint64>(data_item.offset),
static_cast<uint64>(data_item.length));
sender_->Send(new BlobHostMsg_AppendBlobDataItem(url, item));
}
break;
case WebBlobData::Item::TypeURL:
if (data_item.length) {
// We only support filesystem URL as of now.
DCHECK(GURL(data_item.url).SchemeIsFileSystem());
item.SetToFileSystemUrlRange(
data_item.url,
static_cast<uint64>(data_item.offset),
static_cast<uint64>(data_item.length),
base::Time::FromDoubleT(data_item.expectedModificationTime));
sender_->Send(new BlobHostMsg_AppendBlobDataItem(url, item));
}
break;
default:
NOTREACHED();
}
}
sender_->Send(new BlobHostMsg_FinishBuildingBlob(
url, data.contentType().utf8().data()));
}
void WebBlobRegistryImpl::registerBlobURL(
const WebURL& url, const WebURL& src_url) {
DCHECK(ChildThread::current()->message_loop() ==
base::MessageLoop::current());
sender_->Send(new BlobHostMsg_CloneBlob(url, src_url));
}
void WebBlobRegistryImpl::unregisterBlobURL(const WebURL& url) {
DCHECK(ChildThread::current()->message_loop() ==
base::MessageLoop::current());
sender_->Send(new BlobHostMsg_RemoveBlob(url));
}
} // namespace content
|
