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
|
// 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.
#ifndef CHROME_RENDERER_INDEXED_DB_DISPATCHER_H_
#define CHROME_RENDERER_INDEXED_DB_DISPATCHER_H_
#pragma once
#include "base/id_map.h"
#include "base/nullable_string16.h"
#include "ipc/ipc_message.h"
#include "third_party/WebKit/WebKit/chromium/public/WebIDBCallbacks.h"
#include "third_party/WebKit/WebKit/chromium/public/WebIDBDatabase.h"
#include "third_party/WebKit/WebKit/chromium/public/WebIDBTransactionCallbacks.h"
class IndexedDBKey;
class SerializedScriptValue;
namespace WebKit {
class WebFrame;
class WebIDBKeyRange;
}
// Handle the indexed db related communication for this entire renderer.
class IndexedDBDispatcher {
public:
IndexedDBDispatcher();
~IndexedDBDispatcher();
// Called to possibly handle the incoming IPC message. Returns true if
// handled.
bool OnMessageReceived(const IPC::Message& msg);
void RequestIDBFactoryOpen(
const string16& name, const string16& description,
WebKit::WebIDBCallbacks* callbacks, const string16& origin,
WebKit::WebFrame* web_frame);
void RequestIDBCursorUpdate(
const SerializedScriptValue& value,
WebKit::WebIDBCallbacks* callbacks_ptr,
int32 idb_cursor_id);
void RequestIDBCursorContinue(
const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks_ptr,
int32 idb_cursor_id);
void RequestIDBCursorRemove(
WebKit::WebIDBCallbacks* callbacks_ptr,
int32 idb_cursor_id);
void RequestIDBDatabaseCreateObjectStore(
const string16& name, const NullableString16& key_path,
bool auto_increment, WebKit::WebIDBCallbacks* callbacks,
int32 idb_database_id);
void RequestIDBDatabaseRemoveObjectStore(
const string16& name, WebKit::WebIDBCallbacks* callbacks,
int32 idb_database_id);
void RequestIDBDatabaseSetVersion(
const string16& version,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_database_id);
void RequestIDBIndexOpenObjectCursor(
const WebKit::WebIDBKeyRange& idb_key_range,
unsigned short direction,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_index_id,
int transaction_id);
void RequestIDBIndexOpenCursor(const WebKit::WebIDBKeyRange& idb_key_range,
unsigned short direction,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_index_id,
int transaction_id);
void RequestIDBIndexGetObject(const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_index_id,
int transaction_id);
void RequestIDBIndexGet(const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_index_id,
int transaction_id);
void RequestIDBObjectStoreGet(const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
int transaction_id);
void RequestIDBObjectStorePut(const SerializedScriptValue& value,
const IndexedDBKey& key,
bool add_only,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
int transaction_id);
void RequestIDBObjectStoreRemove(const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
int transaction_id);
void RequestIDBObjectStoreCreateIndex(
const string16& name, const NullableString16& key_path, bool unique,
WebKit::WebIDBCallbacks* callbacks, int32 idb_object_store_id);
void RequestIDBObjectStoreRemoveIndex(
const string16& name, WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id);
void RequestIDBObjectStoreOpenCursor(
const WebKit::WebIDBKeyRange& idb_key_range,
unsigned short direction,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
int transaction_id);
void RequestIDBTransactionSetCallbacks(
WebKit::WebIDBTransactionCallbacks* callbacks);
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 OnSuccessIDBObjectStore(int32 response_id, int32 object_id);
void OnSuccessIDBIndex(int32 response_id, int32 object_id);
void OnSuccessOpenCursor(int32 response_id, int32 object_id);
void OnSuccessSerializedScriptValue(int32 response_id,
const SerializedScriptValue& value);
void OnError(int32 response_id, int code, const string16& message);
void OnAbort(int transaction_id);
// 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_;
DISALLOW_COPY_AND_ASSIGN(IndexedDBDispatcher);
};
#endif // CHROME_RENDERER_INDEXED_DB_DISPATCHER_H_
|
