Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1461)

Side by Side Diff: content/child/indexed_db/indexed_db_dispatcher.h

Issue 2480293004: Mandate unique_ptr for base::IDMap in IDMapOwnPointer mode. (Closed)
Patch Set: Rebase on some ScreenOrientation changes, update that stuff to use unique_ptr (the change I was sca… Created 4 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2013 The Chromium Authors. All rights reserved. 1 // Copyright 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ 5 #ifndef CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_
6 #define CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ 6 #define CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_
7 7
8 #include <stddef.h> 8 #include <stddef.h>
9 #include <stdint.h> 9 #include <stdint.h>
10 10
11 #include <map> 11 #include <map>
12 #include <memory>
12 #include <string> 13 #include <string>
14 #include <utility>
13 #include <vector> 15 #include <vector>
14 16
15 #include "base/gtest_prod_util.h" 17 #include "base/gtest_prod_util.h"
16 #include "base/id_map.h" 18 #include "base/id_map.h"
17 #include "base/macros.h" 19 #include "base/macros.h"
18 #include "base/memory/ref_counted.h" 20 #include "base/memory/ref_counted.h"
19 #include "base/strings/nullable_string16.h" 21 #include "base/strings/nullable_string16.h"
20 #include "content/child/indexed_db/indexed_db_callbacks_impl.h" 22 #include "content/child/indexed_db/indexed_db_callbacks_impl.h"
21 #include "content/child/indexed_db/indexed_db_database_callbacks_impl.h" 23 #include "content/child/indexed_db/indexed_db_database_callbacks_impl.h"
22 #include "content/common/content_export.h" 24 #include "content/common/content_export.h"
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after
75 77
76 // This method is virtual so it can be overridden in unit tests. 78 // This method is virtual so it can be overridden in unit tests.
77 virtual bool Send(IPC::Message* msg); 79 virtual bool Send(IPC::Message* msg);
78 80
79 int32_t RegisterObserver(std::unique_ptr<blink::WebIDBObserver> observer); 81 int32_t RegisterObserver(std::unique_ptr<blink::WebIDBObserver> observer);
80 82
81 // Removes observers from our local map observers_. 83 // Removes observers from our local map observers_.
82 void RemoveObservers(const std::vector<int32_t>& observer_ids_to_remove); 84 void RemoveObservers(const std::vector<int32_t>& observer_ids_to_remove);
83 85
84 // This method is virtual so it can be overridden in unit tests. 86 // This method is virtual so it can be overridden in unit tests.
85 virtual void RequestIDBCursorAdvance(unsigned long count, 87 virtual void RequestIDBCursorAdvance(
86 blink::WebIDBCallbacks* callbacks_ptr, 88 unsigned long count,
87 int32_t ipc_cursor_id, 89 std::unique_ptr<blink::WebIDBCallbacks> callbacks_ptr,
88 int64_t transaction_id); 90 int32_t ipc_cursor_id,
91 int64_t transaction_id);
89 92
90 // This method is virtual so it can be overridden in unit tests. 93 // This method is virtual so it can be overridden in unit tests.
91 virtual void RequestIDBCursorContinue(const IndexedDBKey& key, 94 virtual void RequestIDBCursorContinue(
92 const IndexedDBKey& primary_key, 95 const IndexedDBKey& key,
93 blink::WebIDBCallbacks* callbacks_ptr, 96 const IndexedDBKey& primary_key,
94 int32_t ipc_cursor_id, 97 std::unique_ptr<blink::WebIDBCallbacks> callbacks_ptr,
95 int64_t transaction_id); 98 int32_t ipc_cursor_id,
99 int64_t transaction_id);
96 100
97 // This method is virtual so it can be overridden in unit tests. 101 // This method is virtual so it can be overridden in unit tests.
98 virtual void RequestIDBCursorPrefetch(int n, 102 virtual void RequestIDBCursorPrefetch(
99 blink::WebIDBCallbacks* callbacks_ptr, 103 int n,
100 int32_t ipc_cursor_id); 104 std::unique_ptr<blink::WebIDBCallbacks> callbacks_ptr,
105 int32_t ipc_cursor_id);
101 106
102 // This method is virtual so it can be overridden in unit tests. 107 // This method is virtual so it can be overridden in unit tests.
103 virtual void RequestIDBCursorPrefetchReset(int used_prefetches, 108 virtual void RequestIDBCursorPrefetchReset(int used_prefetches,
104 int unused_prefetches, 109 int unused_prefetches,
105 int32_t ipc_cursor_id); 110 int32_t ipc_cursor_id);
106 111
107 void RegisterCursor(int32_t ipc_cursor_id, WebIDBCursorImpl* cursor); 112 void RegisterCursor(int32_t ipc_cursor_id, WebIDBCursorImpl* cursor);
108 113
109 virtual void CursorDestroyed(int32_t ipc_cursor_id); 114 virtual void CursorDestroyed(int32_t ipc_cursor_id);
110 115
(...skipping 12 matching lines...) Expand all
123 void UnregisterMojoOwnedDatabaseCallbacks( 128 void UnregisterMojoOwnedDatabaseCallbacks(
124 blink::WebIDBDatabaseCallbacks* callback_state); 129 blink::WebIDBDatabaseCallbacks* callback_state);
125 130
126 private: 131 private:
127 FRIEND_TEST_ALL_PREFIXES(IndexedDBDispatcherTest, CursorReset); 132 FRIEND_TEST_ALL_PREFIXES(IndexedDBDispatcherTest, CursorReset);
128 FRIEND_TEST_ALL_PREFIXES(IndexedDBDispatcherTest, CursorTransactionId); 133 FRIEND_TEST_ALL_PREFIXES(IndexedDBDispatcherTest, CursorTransactionId);
129 134
130 static int32_t CurrentWorkerId() { return WorkerThread::GetCurrentId(); } 135 static int32_t CurrentWorkerId() { return WorkerThread::GetCurrentId(); }
131 136
132 template <typename T> 137 template <typename T>
133 void init_params(T* params, blink::WebIDBCallbacks* callbacks_ptr) { 138 void init_params(T* params,
134 std::unique_ptr<blink::WebIDBCallbacks> callbacks(callbacks_ptr); 139 std::unique_ptr<blink::WebIDBCallbacks> callbacks_ptr) {
135 params->ipc_thread_id = CurrentWorkerId(); 140 params->ipc_thread_id = CurrentWorkerId();
136 params->ipc_callbacks_id = pending_callbacks_.Add(callbacks.release()); 141 params->ipc_callbacks_id = pending_callbacks_.Add(std::move(callbacks_ptr));
137 } 142 }
138 143
139 // IDBCallback message handlers. 144 // IDBCallback message handlers.
140 void OnSuccessCursorContinue( 145 void OnSuccessCursorContinue(
141 const IndexedDBMsg_CallbacksSuccessCursorContinue_Params& p); 146 const IndexedDBMsg_CallbacksSuccessCursorContinue_Params& p);
142 void OnSuccessCursorPrefetch( 147 void OnSuccessCursorPrefetch(
143 const IndexedDBMsg_CallbacksSuccessCursorPrefetch_Params& p); 148 const IndexedDBMsg_CallbacksSuccessCursorPrefetch_Params& p);
144 void OnSuccessValue(const IndexedDBMsg_CallbacksSuccessValue_Params& p); 149 void OnSuccessValue(const IndexedDBMsg_CallbacksSuccessValue_Params& p);
145 void OnSuccessInteger(int32_t ipc_thread_id, 150 void OnSuccessInteger(int32_t ipc_thread_id,
146 int32_t ipc_callbacks_id, 151 int32_t ipc_callbacks_id,
(...skipping 29 matching lines...) Expand all
176 181
177 // Map from cursor id to WebIDBCursorImpl. 182 // Map from cursor id to WebIDBCursorImpl.
178 std::map<int32_t, WebIDBCursorImpl*> cursors_; 183 std::map<int32_t, WebIDBCursorImpl*> cursors_;
179 184
180 DISALLOW_COPY_AND_ASSIGN(IndexedDBDispatcher); 185 DISALLOW_COPY_AND_ASSIGN(IndexedDBDispatcher);
181 }; 186 };
182 187
183 } // namespace content 188 } // namespace content
184 189
185 #endif // CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ 190 #endif // CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698