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

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

Issue 1909813002: Enable per thread heap for database thread (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 6 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 32 matching lines...) Expand 10 before | Expand all | Expand 10 after
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 } 49 }
50 50
51 DEFINE_TRACE(SQLTransactionCoordinator) 51 DEFINE_TRACE(SQLTransactionCoordinator)
52 { 52 {
53 visitor->trace(m_coordinationInfoMap);
54 } 53 }
55 54
56 void SQLTransactionCoordinator::processPendingTransactions(CoordinationInfo& inf o) 55 void SQLTransactionCoordinator::processPendingTransactions(CoordinationInfo& inf o)
57 { 56 {
58 if (info.activeWriteTransaction || info.pendingTransactions.isEmpty()) 57 if (info.activeWriteTransaction || info.pendingTransactions.isEmpty())
59 return; 58 return;
60 59
61 SQLTransactionBackend* firstPendingTransaction = info.pendingTransactions.fi rst(); 60 SQLTransactionBackend* firstPendingTransaction = info.pendingTransactions.fi rst();
62 if (firstPendingTransaction->isReadOnly()) { 61 if (firstPendingTransaction->isReadOnly()) {
63 do { 62 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 122 // Notify all transactions in progress that the database thread is shutting down
124 for (CoordinationInfoHeapMap::iterator coordinationInfoIterator = m_coordina tionInfoMap.begin(); 123 for (CoordinationInfoHeapMap::iterator coordinationInfoIterator = m_coordina tionInfoMap.begin();
125 coordinationInfoIterator != m_coordinationInfoMap.end(); ++coordination InfoIterator) { 124 coordinationInfoIterator != m_coordinationInfoMap.end(); ++coordination InfoIterator) {
126 CoordinationInfo& info = coordinationInfoIterator->value; 125 CoordinationInfo& info = coordinationInfoIterator->value;
127 126
128 // Clean up transactions that have reached "lockAcquired": 127 // Clean up transactions that have reached "lockAcquired":
129 // Transaction phase 4 cleanup. See comment on "What happens if a 128 // Transaction phase 4 cleanup. See comment on "What happens if a
130 // transaction is interrupted?" at the top of SQLTransactionBackend.cpp. 129 // transaction is interrupted?" at the top of SQLTransactionBackend.cpp.
131 if (info.activeWriteTransaction) 130 if (info.activeWriteTransaction)
132 info.activeWriteTransaction->notifyDatabaseThreadIsShuttingDown(); 131 info.activeWriteTransaction->notifyDatabaseThreadIsShuttingDown();
133 for (HeapHashSet<Member<SQLTransactionBackend>>::iterator activeReadTran sactionsIterator = 132 for (auto& it : info.activeReadTransactions) {
134 info.activeReadTransactions.begin(); 133 it->notifyDatabaseThreadIsShuttingDown();
135 activeReadTransactionsIterator != info.activeReadTransactions.end() ;
136 ++activeReadTransactionsIterator) {
137 (*activeReadTransactionsIterator)->notifyDatabaseThreadIsShuttingDow n();
138 } 134 }
139 135
140 // Clean up transactions that have NOT reached "lockAcquired": 136 // Clean up transactions that have NOT reached "lockAcquired":
141 // Transaction phase 3 cleanup. See comment on "What happens if a 137 // Transaction phase 3 cleanup. See comment on "What happens if a
142 // transaction is interrupted?" at the top of SQLTransactionBackend.cpp. 138 // transaction is interrupted?" at the top of SQLTransactionBackend.cpp.
143 while (!info.pendingTransactions.isEmpty()) { 139 while (!info.pendingTransactions.isEmpty()) {
144 SQLTransactionBackend* transaction = info.pendingTransactions.takeFi rst(); 140 SQLTransactionBackend* transaction = info.pendingTransactions.takeFi rst();
145 transaction->notifyDatabaseThreadIsShuttingDown(); 141 transaction->notifyDatabaseThreadIsShuttingDown();
146 } 142 }
147 } 143 }
148 144
149 // Clean up all pending transactions for all databases 145 // Clean up all pending transactions for all databases
150 m_coordinationInfoMap.clear(); 146 m_coordinationInfoMap.clear();
151 } 147 }
152 148
153 } // namespace blink 149 } // namespace blink
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698