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
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
|
// Copyright (c) 2011 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.
#ifndef CONTENT_RENDERER_INDEXED_DB_DISPATCHER_H_
#define CONTENT_RENDERER_INDEXED_DB_DISPATCHER_H_
#pragma once
#include "base/id_map.h"
#include "base/nullable_string16.h"
#include "ipc/ipc_channel.h"
#include "third_party/WebKit/Source/WebKit/chromium/public/WebExceptionCode.h"
#include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBCallbacks.h"
#include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBDatabase.h"
#include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBObjectStore.h"
#include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBTransactionCallbacks.h"
class IndexedDBKey;
class SerializedScriptValue;
namespace WebKit {
class WebDOMStringList;
class WebFrame;
class WebIDBKeyRange;
class WebIDBTransaction;
}
// Handle the indexed db related communication for this entire renderer.
class IndexedDBDispatcher : public IPC::Channel::Listener {
public:
IndexedDBDispatcher();
virtual ~IndexedDBDispatcher();
// IPC::Channel::Listener implementation.
virtual bool OnMessageReceived(const IPC::Message& msg);
void RequestIDBFactoryGetDatabaseNames(
WebKit::WebIDBCallbacks* callbacks,
const string16& origin,
WebKit::WebFrame* web_frame);
void RequestIDBFactoryOpen(
const string16& name,
WebKit::WebIDBCallbacks* callbacks,
const string16& origin,
WebKit::WebFrame* web_frame);
void RequestIDBFactoryDeleteDatabase(
const string16& name,
WebKit::WebIDBCallbacks* callbacks,
const string16& origin,
WebKit::WebFrame* web_frame);
void RequestIDBCursorUpdate(
const SerializedScriptValue& value,
WebKit::WebIDBCallbacks* callbacks_ptr,
int32 idb_cursor_id,
WebKit::WebExceptionCode* ec);
void RequestIDBCursorContinue(
const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks_ptr,
int32 idb_cursor_id,
WebKit::WebExceptionCode* ec);
void RequestIDBCursorDelete(
WebKit::WebIDBCallbacks* callbacks_ptr,
int32 idb_cursor_id,
WebKit::WebExceptionCode* ec);
void RequestIDBDatabaseClose(
int32 idb_database_id);
void RequestIDBDatabaseOpen(
WebKit::WebIDBDatabaseCallbacks* callbacks_ptr,
int32 idb_database_id);
void RequestIDBDatabaseSetVersion(
const string16& version,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_database_id,
WebKit::WebExceptionCode* ec);
void RequestIDBIndexOpenObjectCursor(
const WebKit::WebIDBKeyRange& idb_key_range,
unsigned short direction,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_index_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBIndexOpenKeyCursor(
const WebKit::WebIDBKeyRange& idb_key_range,
unsigned short direction,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_index_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBIndexGetObject(const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_index_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBIndexGetKey(const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_index_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBObjectStoreGet(const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBObjectStorePut(const SerializedScriptValue& value,
const IndexedDBKey& key,
WebKit::WebIDBObjectStore::PutMode putMode,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBObjectStoreDelete(
const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBObjectStoreClear(
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBObjectStoreOpenCursor(
const WebKit::WebIDBKeyRange& idb_key_range,
unsigned short direction,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RegisterWebIDBTransactionCallbacks(
WebKit::WebIDBTransactionCallbacks* callbacks,
int32 id);
static int32 TransactionId(const WebKit::WebIDBTransaction& transaction);
private:
// IDBCallback message handlers.
void OnSuccessNull(int32 response_id);
void OnSuccessIDBDatabase(int32 response_id, int32 object_id);
void OnSuccessIndexedDBKey(int32 response_id, const IndexedDBKey& key);
void OnSuccessIDBTransaction(int32 response_id, int32 object_id);
void OnSuccessOpenCursor(int32 response_id, int32 object_id,
const IndexedDBKey& key,
const IndexedDBKey& primary_key,
const SerializedScriptValue& value);
void OnSuccessStringList(int32 response_id,
const std::vector<string16>& value);
void OnSuccessSerializedScriptValue(int32 response_id,
const SerializedScriptValue& value);
void OnError(int32 response_id, int code, const string16& message);
void OnBlocked(int32 response_id);
void OnAbort(int32 transaction_id);
void OnComplete(int32 transaction_id);
void OnVersionChange(int32 database_id, const string16& newVersion);
// Careful! WebIDBCallbacks wraps non-threadsafe data types. It must be
// destroyed and used on the same thread it was created on.
IDMap<WebKit::WebIDBCallbacks, IDMapOwnPointer> pending_callbacks_;
IDMap<WebKit::WebIDBTransactionCallbacks, IDMapOwnPointer>
pending_transaction_callbacks_;
IDMap<WebKit::WebIDBDatabaseCallbacks, IDMapOwnPointer>
pending_database_callbacks_;
DISALLOW_COPY_AND_ASSIGN(IndexedDBDispatcher);
};
#endif // CONTENT_RENDERER_INDEXED_DB_DISPATCHER_H_
|
