| Index: content/child/indexed_db/webidbdatabase_impl.cc
|
| diff --git a/content/child/indexed_db/webidbdatabase_impl.cc b/content/child/indexed_db/webidbdatabase_impl.cc
|
| index 28408b7c32facfd6d381f350e2f39ef57d4cb5a9..c9e7414677b4a3407ca7c2ca89d2695e212f6adb 100644
|
| --- a/content/child/indexed_db/webidbdatabase_impl.cc
|
| +++ b/content/child/indexed_db/webidbdatabase_impl.cc
|
| @@ -106,7 +106,17 @@ void WebIDBDatabaseImpl::observe(blink::IDBObserver* observer,
|
| long long transaction_id) {
|
| IndexedDBDispatcher* dispatcher =
|
| IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get());
|
| - dispatcher->AddIDBObserver(ipc_database_id_, transaction_id, observer);
|
| + int32_t observer_id =
|
| + dispatcher->AddIDBObserver(ipc_database_id_, transaction_id, observer);
|
| + observers_id_.push_back(observer_id);
|
| +}
|
| +
|
| +void WebIDBDatabaseImpl::unobserve(blink::IDBObserver* observer) {
|
| + IndexedDBDispatcher* dispatcher =
|
| + IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get());
|
| + std::vector<int32_t> remove_observers =
|
| + dispatcher->RemoveIDBObserver(ipc_database_id_, observer);
|
| + // TODO(palakj): Remove id from observes_id_
|
| }
|
|
|
| void WebIDBDatabaseImpl::get(long long transaction_id,
|
|
|