a28c362ae9c7d995f419bcfc7347dae82dd5590f
[WebKit-https.git] / Source / WebCore / Modules / indexeddb / server / MemoryBackingStoreTransaction.h
1 /*
2  * Copyright (C) 2015 Apple Inc. All rights reserved.
3  *
4  * Redistribution and use in source and binary forms, with or without
5  * modification, are permitted provided that the following conditions
6  * are met:
7  * 1. Redistributions of source code must retain the above copyright
8  *    notice, this list of conditions and the following disclaimer.
9  * 2. Redistributions in binary form must reproduce the above copyright
10  *    notice, this list of conditions and the following disclaimer in the
11  *    documentation and/or other materials provided with the distribution.
12  *
13  * THIS SOFTWARE IS PROVIDED BY APPLE INC. ``AS IS'' AND ANY
14  * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
15  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
16  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL APPLE INC. OR
17  * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
18  * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
19  * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
20  * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
21  * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
22  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
23  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
24  */
25
26 #ifndef MemoryBackingStoreTransaction_h
27 #define MemoryBackingStoreTransaction_h
28
29 #if ENABLE(INDEXED_DATABASE)
30
31 #include "IDBDatabaseInfo.h"
32 #include "IDBKeyData.h"
33 #include "IDBTransactionInfo.h"
34 #include "IndexValueStore.h"
35 #include "ThreadSafeDataBuffer.h"
36 #include <wtf/HashMap.h>
37 #include <wtf/HashSet.h>
38
39 namespace WebCore {
40 namespace IDBServer {
41
42 class MemoryIDBBackingStore;
43 class MemoryIndex;
44 class MemoryObjectStore;
45
46 typedef HashMap<IDBKeyData, ThreadSafeDataBuffer, IDBKeyDataHash, IDBKeyDataHashTraits> KeyValueMap;
47
48 class MemoryBackingStoreTransaction {
49     friend std::unique_ptr<MemoryBackingStoreTransaction> std::make_unique<MemoryBackingStoreTransaction>(WebCore::IDBServer::MemoryIDBBackingStore&, const WebCore::IDBTransactionInfo&);
50 public:
51     static std::unique_ptr<MemoryBackingStoreTransaction> create(MemoryIDBBackingStore&, const IDBTransactionInfo&);
52
53     ~MemoryBackingStoreTransaction();
54
55     bool isVersionChange() const { return m_info.mode() == IndexedDB::TransactionMode::VersionChange; }
56     bool isWriting() const { return m_info.mode() != IndexedDB::TransactionMode::ReadOnly; }
57     bool isAborting() const { return m_isAborting; }
58
59     const IDBDatabaseInfo& originalDatabaseInfo() const;
60
61     void addNewObjectStore(MemoryObjectStore&);
62     void addExistingObjectStore(MemoryObjectStore&);
63     
64     void recordValueChanged(MemoryObjectStore&, const IDBKeyData&, ThreadSafeDataBuffer*);
65     void objectStoreDeleted(std::unique_ptr<MemoryObjectStore>);
66     void objectStoreCleared(MemoryObjectStore&, std::unique_ptr<KeyValueMap>&&, std::unique_ptr<std::set<IDBKeyData>>&&);
67     void indexCleared(MemoryIndex&, std::unique_ptr<IndexValueStore>&&);
68
69     void addNewIndex(MemoryIndex&);
70     void addExistingIndex(MemoryIndex&);
71
72     void abort();
73     void commit();
74
75 private:
76     MemoryBackingStoreTransaction(MemoryIDBBackingStore&, const IDBTransactionInfo&);
77
78     void finish();
79
80     MemoryIDBBackingStore& m_backingStore;
81     IDBTransactionInfo m_info;
82
83     std::unique_ptr<IDBDatabaseInfo> m_originalDatabaseInfo;
84
85     bool m_inProgress { true };
86     bool m_isAborting { false };
87
88     HashSet<MemoryObjectStore*> m_objectStores;
89     HashSet<MemoryObjectStore*> m_versionChangeAddedObjectStores;
90     HashSet<MemoryIndex*> m_indexes;
91     HashSet<MemoryIndex*> m_versionChangeAddedIndexes;
92
93     HashMap<MemoryObjectStore*, uint64_t> m_originalKeyGenerators;
94     HashMap<String, std::unique_ptr<MemoryObjectStore>> m_deletedObjectStores;
95     HashMap<String, std::unique_ptr<MemoryIndex>> m_deletedIndexes;
96     HashMap<MemoryObjectStore*, std::unique_ptr<KeyValueMap>> m_originalValues;
97     HashMap<MemoryObjectStore*, std::unique_ptr<KeyValueMap>> m_clearedKeyValueMaps;
98     HashMap<MemoryObjectStore*, std::unique_ptr<std::set<IDBKeyData>>> m_clearedOrderedKeys;
99     HashMap<MemoryIndex*, std::unique_ptr<IndexValueStore>> m_clearedIndexValueStores;
100 };
101
102 } // namespace IDBServer
103 } // namespace WebCore
104
105 #endif // ENABLE(INDEXED_DATABASE)
106 #endif // MemoryBackingStoreTransaction_h