d7c4ac29f948f72f8451e80f300a78e1d48f5d42
[WebKit-https.git] / Source / WebCore / Modules / indexeddb / server / UniqueIDBDatabaseConnection.cpp
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. AND ITS CONTRIBUTORS ``AS IS''
14  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
15  * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
16  * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS
17  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
18  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
19  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
20  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
21  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
22  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
23  * THE POSSIBILITY OF SUCH DAMAGE.
24  */
25
26 #include "config.h"
27 #include "UniqueIDBDatabaseConnection.h"
28
29 #if ENABLE(INDEXED_DATABASE)
30
31 #include "IDBConnectionToClient.h"
32 #include "IDBTransactionInfo.h"
33 #include "Logging.h"
34
35 namespace WebCore {
36 namespace IDBServer {
37
38 static uint64_t nextDatabaseConnectionIdentifier()
39 {
40     static uint64_t nextIdentifier = 0;
41     return ++nextIdentifier;
42 }
43
44 Ref<UniqueIDBDatabaseConnection> UniqueIDBDatabaseConnection::create(UniqueIDBDatabase& database, IDBConnectionToClient& connection)
45 {
46     return adoptRef(*new UniqueIDBDatabaseConnection(database, connection));
47 }
48
49 UniqueIDBDatabaseConnection::UniqueIDBDatabaseConnection(UniqueIDBDatabase& database, IDBConnectionToClient& connection)
50     : m_identifier(nextDatabaseConnectionIdentifier())
51     , m_database(database)
52     , m_connectionToClient(connection)
53 {
54 }
55
56 void UniqueIDBDatabaseConnection::fireVersionChangeEvent(uint64_t requestedVersion)
57 {
58     ASSERT(!m_closePending);
59     m_connectionToClient.fireVersionChangeEvent(*this, requestedVersion);
60 }
61
62 UniqueIDBDatabaseTransaction& UniqueIDBDatabaseConnection::createVersionChangeTransaction(uint64_t newVersion)
63 {
64     LOG(IndexedDB, "UniqueIDBDatabaseConnection::createVersionChangeTransaction");
65     ASSERT(!m_closePending);
66
67     IDBTransactionInfo info = IDBTransactionInfo::versionChange(m_connectionToClient, newVersion);
68
69     Ref<UniqueIDBDatabaseTransaction> transaction = UniqueIDBDatabaseTransaction::create(*this, info);
70     m_transactionMap.set(transaction->info().identifier(), &transaction.get());
71
72     return transaction.get();
73 }
74
75 void UniqueIDBDatabaseConnection::didCommitTransaction(UniqueIDBDatabaseTransaction& transaction, const IDBError& error)
76 {
77     LOG(IndexedDB, "UniqueIDBDatabaseConnection::didCommitTransaction");
78
79     auto transactionIdentifier = transaction.info().identifier();
80
81     ASSERT(m_transactionMap.contains(transactionIdentifier));
82     m_transactionMap.remove(transactionIdentifier);
83
84     m_connectionToClient.didCommitTransaction(transactionIdentifier, error);
85 }
86
87 } // namespace IDBServer
88 } // namespace WebCore
89
90 #endif // ENABLE(INDEXED_DATABASE)