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

Side by Side Diff: third_party/WebKit/Source/modules/webdatabase/SQLTransactionCoordinator.cpp

Issue 1477023003: Refactor the Heap into ThreadHeap to prepare for per thread heaps Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 11 months 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 /* 1 /*
2 * Copyright (C) 2009 Google Inc. All rights reserved. 2 * Copyright (C) 2009 Google Inc. All rights reserved.
3 * Copyright (C) 2013 Apple Inc. All rights reserved. 3 * Copyright (C) 2013 Apple Inc. All rights reserved.
4 * 4 *
5 * Redistribution and use in source and binary forms, with or without 5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are 6 * modification, are permitted provided that the following conditions are
7 * met: 7 * met:
8 * 8 *
9 * * Redistributions of source code must retain the above copyright 9 * * Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer. 10 * notice, this list of conditions and the following disclaimer.
(...skipping 28 matching lines...) Expand all
39 static String getDatabaseIdentifier(SQLTransactionBackend* transaction) 39 static String getDatabaseIdentifier(SQLTransactionBackend* transaction)
40 { 40 {
41 Database* database = transaction->database(); 41 Database* database = transaction->database();
42 ASSERT(database); 42 ASSERT(database);
43 return database->stringIdentifier(); 43 return database->stringIdentifier();
44 } 44 }
45 45
46 SQLTransactionCoordinator::SQLTransactionCoordinator() 46 SQLTransactionCoordinator::SQLTransactionCoordinator()
47 : m_isShuttingDown(false) 47 : m_isShuttingDown(false)
48 { 48 {
49 ASSERT(isMainThread());
49 } 50 }
50 51
51 DEFINE_TRACE(SQLTransactionCoordinator) 52 DEFINE_TRACE(SQLTransactionCoordinator)
52 { 53 {
53 visitor->trace(m_coordinationInfoMap);
54 } 54 }
55 55
56 void SQLTransactionCoordinator::processPendingTransactions(CoordinationInfo& inf o) 56 void SQLTransactionCoordinator::processPendingTransactions(CoordinationInfo& inf o)
57 { 57 {
58 if (info.activeWriteTransaction || info.pendingTransactions.isEmpty()) 58 if (info.activeWriteTransaction || info.pendingTransactions.isEmpty())
59 return; 59 return;
60 60
61 SQLTransactionBackend* firstPendingTransaction = info.pendingTransactions.fi rst(); 61 SQLTransactionBackend* firstPendingTransaction = info.pendingTransactions.fi rst();
62 if (firstPendingTransaction->isReadOnly()) { 62 if (firstPendingTransaction->isReadOnly()) {
63 do { 63 do {
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after
123 // Notify all transactions in progress that the database thread is shutting down 123 // Notify all transactions in progress that the database thread is shutting down
124 for (CoordinationInfoHeapMap::iterator coordinationInfoIterator = m_coordina tionInfoMap.begin(); 124 for (CoordinationInfoHeapMap::iterator coordinationInfoIterator = m_coordina tionInfoMap.begin();
125 coordinationInfoIterator != m_coordinationInfoMap.end(); ++coordination InfoIterator) { 125 coordinationInfoIterator != m_coordinationInfoMap.end(); ++coordination InfoIterator) {
126 CoordinationInfo& info = coordinationInfoIterator->value; 126 CoordinationInfo& info = coordinationInfoIterator->value;
127 127
128 // Clean up transactions that have reached "lockAcquired": 128 // Clean up transactions that have reached "lockAcquired":
129 // Transaction phase 4 cleanup. See comment on "What happens if a 129 // Transaction phase 4 cleanup. See comment on "What happens if a
130 // transaction is interrupted?" at the top of SQLTransactionBackend.cpp. 130 // transaction is interrupted?" at the top of SQLTransactionBackend.cpp.
131 if (info.activeWriteTransaction) 131 if (info.activeWriteTransaction)
132 info.activeWriteTransaction->notifyDatabaseThreadIsShuttingDown(); 132 info.activeWriteTransaction->notifyDatabaseThreadIsShuttingDown();
133 for (HeapHashSet<Member<SQLTransactionBackend>>::iterator activeReadTran sactionsIterator = 133 for (auto& it : info.activeReadTransactions) {
134 info.activeReadTransactions.begin(); 134 it->notifyDatabaseThreadIsShuttingDown();
135 activeReadTransactionsIterator != info.activeReadTransactions.end() ;
136 ++activeReadTransactionsIterator) {
137 (*activeReadTransactionsIterator)->notifyDatabaseThreadIsShuttingDow n();
138 } 135 }
139 136
140 // Clean up transactions that have NOT reached "lockAcquired": 137 // Clean up transactions that have NOT reached "lockAcquired":
141 // Transaction phase 3 cleanup. See comment on "What happens if a 138 // Transaction phase 3 cleanup. See comment on "What happens if a
142 // transaction is interrupted?" at the top of SQLTransactionBackend.cpp. 139 // transaction is interrupted?" at the top of SQLTransactionBackend.cpp.
143 while (!info.pendingTransactions.isEmpty()) { 140 while (!info.pendingTransactions.isEmpty()) {
144 SQLTransactionBackend* transaction = info.pendingTransactions.takeFi rst(); 141 SQLTransactionBackend* transaction = info.pendingTransactions.takeFi rst();
145 transaction->notifyDatabaseThreadIsShuttingDown(); 142 transaction->notifyDatabaseThreadIsShuttingDown();
146 } 143 }
147 } 144 }
148 145
149 // Clean up all pending transactions for all databases 146 // Clean up all pending transactions for all databases
150 m_coordinationInfoMap.clear(); 147 m_coordinationInfoMap.clear();
151 } 148 }
152 149
153 } // namespace blink 150 } // namespace blink
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698