OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2010 Google Inc. All rights reserved. | 2 * Copyright (C) 2010 Google Inc. All rights reserved. |
3 * | 3 * |
4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions | 5 * modification, are permitted provided that the following conditions |
6 * are met: | 6 * are met: |
7 * | 7 * |
8 * 1. Redistributions of source code must retain the above copyright | 8 * 1. Redistributions of source code must retain the above copyright |
9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
10 * 2. Redistributions in binary form must reproduce the above copyright | 10 * 2. Redistributions in binary form must reproduce the above copyright |
(...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
71 PassRefPtr<IDBObjectStoreBackendInterface> objectStore(const String& name); | 71 PassRefPtr<IDBObjectStoreBackendInterface> objectStore(const String& name); |
72 IDBTransactionCoordinator* transactionCoordinator() const { return m_transac
tionCoordinator.get(); } | 72 IDBTransactionCoordinator* transactionCoordinator() const { return m_transac
tionCoordinator.get(); } |
73 void transactionStarted(PassRefPtr<IDBTransactionBackendInterface>); | 73 void transactionStarted(PassRefPtr<IDBTransactionBackendInterface>); |
74 void transactionFinished(PassRefPtr<IDBTransactionBackendInterface>); | 74 void transactionFinished(PassRefPtr<IDBTransactionBackendInterface>); |
75 | 75 |
76 private: | 76 private: |
77 IDBDatabaseBackendImpl(const String& name, IDBBackingStore* database, IDBTra
nsactionCoordinator*, IDBFactoryBackendImpl*, const String& uniqueIdentifier); | 77 IDBDatabaseBackendImpl(const String& name, IDBBackingStore* database, IDBTra
nsactionCoordinator*, IDBFactoryBackendImpl*, const String& uniqueIdentifier); |
78 | 78 |
79 bool openInternal(); | 79 bool openInternal(); |
80 void loadObjectStores(); | 80 void loadObjectStores(); |
| 81 int32_t connectionCount(); |
81 void processPendingCalls(); | 82 void processPendingCalls(); |
82 | 83 |
83 static void createObjectStoreInternal(ScriptExecutionContext*, PassRefPtr<ID
BDatabaseBackendImpl>, PassRefPtr<IDBObjectStoreBackendImpl>, PassRefPtr<IDBTran
sactionBackendInterface>); | 84 static void createObjectStoreInternal(ScriptExecutionContext*, PassRefPtr<ID
BDatabaseBackendImpl>, PassRefPtr<IDBObjectStoreBackendImpl>, PassRefPtr<IDBTran
sactionBackendInterface>); |
84 static void deleteObjectStoreInternal(ScriptExecutionContext*, PassRefPtr<ID
BDatabaseBackendImpl>, PassRefPtr<IDBObjectStoreBackendImpl>, PassRefPtr<IDBTran
sactionBackendInterface>); | 85 static void deleteObjectStoreInternal(ScriptExecutionContext*, PassRefPtr<ID
BDatabaseBackendImpl>, PassRefPtr<IDBObjectStoreBackendImpl>, PassRefPtr<IDBTran
sactionBackendInterface>); |
85 static void setVersionInternal(ScriptExecutionContext*, PassRefPtr<IDBDataba
seBackendImpl>, const String& version, PassRefPtr<IDBCallbacks>, PassRefPtr<IDBT
ransactionBackendInterface>); | 86 static void setVersionInternal(ScriptExecutionContext*, PassRefPtr<IDBDataba
seBackendImpl>, const String& version, PassRefPtr<IDBCallbacks>, PassRefPtr<IDBT
ransactionBackendInterface>); |
86 | 87 |
87 // These are used as setVersion transaction abort tasks. | 88 // These are used as setVersion transaction abort tasks. |
88 static void removeObjectStoreFromMap(ScriptExecutionContext*, PassRefPtr<IDB
DatabaseBackendImpl>, PassRefPtr<IDBObjectStoreBackendImpl>); | 89 static void removeObjectStoreFromMap(ScriptExecutionContext*, PassRefPtr<IDB
DatabaseBackendImpl>, PassRefPtr<IDBObjectStoreBackendImpl>); |
89 static void addObjectStoreToMap(ScriptExecutionContext*, PassRefPtr<IDBDatab
aseBackendImpl>, PassRefPtr<IDBObjectStoreBackendImpl>); | 90 static void addObjectStoreToMap(ScriptExecutionContext*, PassRefPtr<IDBDatab
aseBackendImpl>, PassRefPtr<IDBObjectStoreBackendImpl>); |
90 static void resetVersion(ScriptExecutionContext*, PassRefPtr<IDBDatabaseBack
endImpl>, const String& version); | 91 static void resetVersion(ScriptExecutionContext*, PassRefPtr<IDBDatabaseBack
endImpl>, const String& version); |
(...skipping 18 matching lines...) Expand all Loading... |
109 | 110 |
110 class PendingSetVersionCall; | 111 class PendingSetVersionCall; |
111 Deque<RefPtr<PendingSetVersionCall> > m_pendingSetVersionCalls; | 112 Deque<RefPtr<PendingSetVersionCall> > m_pendingSetVersionCalls; |
112 | 113 |
113 class PendingOpenCall; | 114 class PendingOpenCall; |
114 Deque<RefPtr<PendingOpenCall> > m_pendingOpenCalls; | 115 Deque<RefPtr<PendingOpenCall> > m_pendingOpenCalls; |
115 | 116 |
116 class PendingDeleteCall; | 117 class PendingDeleteCall; |
117 Deque<RefPtr<PendingDeleteCall> > m_pendingDeleteCalls; | 118 Deque<RefPtr<PendingDeleteCall> > m_pendingDeleteCalls; |
118 | 119 |
| 120 // FIXME: Eliminate the limbo state between openConnection() and registerFro
ntendCallbacks() |
| 121 // that this counter tracks. |
| 122 int32_t m_pendingConnectionCount; |
| 123 |
119 typedef ListHashSet<RefPtr<IDBDatabaseCallbacks> > DatabaseCallbacksSet; | 124 typedef ListHashSet<RefPtr<IDBDatabaseCallbacks> > DatabaseCallbacksSet; |
120 DatabaseCallbacksSet m_databaseCallbacksSet; | 125 DatabaseCallbacksSet m_databaseCallbacksSet; |
121 }; | 126 }; |
122 | 127 |
123 } // namespace WebCore | 128 } // namespace WebCore |
124 | 129 |
125 #endif | 130 #endif |
126 | 131 |
127 #endif // IDBDatabaseBackendImpl_h | 132 #endif // IDBDatabaseBackendImpl_h |
OLD | NEW |