Lines Matching refs:Transaction
135 WorkItem(WorkItemOperation operation, Transaction* trans, ActiveEntry** entry)
140 WorkItem(WorkItemOperation operation, Transaction* trans,
149 // Calls back the transaction with the result of the operation.
174 bool Matches(Transaction* trans) const { return trans == trans_; }
179 Transaction* trans_;
187 // This class encapsulates a transaction whose only purpose is to write metadata
191 explicit MetadataWriter(HttpCache::Transaction* trans)
208 scoped_ptr<HttpCache::Transaction> transaction_;
381 HttpCache::Transaction* trans =
382 new HttpCache::Transaction(priority, this, NULL);
432 trans->reset(new HttpCache::Transaction(priority, this, delegate));
483 int HttpCache::GetBackendForTransaction(Transaction* trans) {
549 int HttpCache::DoomEntry(const std::string& key, Transaction* trans) {
550 // Need to abandon the ActiveEntry, but any transaction attached to the entry
574 int HttpCache::AsyncDoomEntry(const std::string& key, Transaction* trans) {
708 Transaction* trans) {
739 Transaction* trans) {
775 int HttpCache::AddTransactionToEntry(ActiveEntry* entry, Transaction* trans) {
784 // NOTE: If the transaction can only write, then the entry should not be in
792 if (trans->mode() & Transaction::WRITE) {
793 // transaction needs exclusive access to the entry
801 // transaction needs read access to the entry
806 // AddTransactionToEntry to add their transaction to the pending queue, which
814 void HttpCache::DoneWithEntry(ActiveEntry* entry, Transaction* trans,
816 // If we already posted a task to move on to the next transaction and this was
861 // ERR_CACHE_RACE causes the transaction to restart the whole process.
868 void HttpCache::DoneReadingFromEntry(ActiveEntry* entry, Transaction* trans) {
882 DCHECK(entry->writer->mode() == Transaction::READ_WRITE);
885 Transaction* trans = entry->writer;
894 const Transaction* trans) {
897 // If this is really a pending transaction, and it is not part of
902 Transaction* writer = i->second->writer;
906 void HttpCache::RemovePendingTransaction(Transaction* trans) {
935 DCHECK(found) << "Pending transaction not found";
939 Transaction* trans) {
952 Transaction* trans) {
995 // Promote next transaction from the pending queue.
996 Transaction* next = entry->pending_queue.front();
997 if ((next->mode() & Transaction::WRITE) && !entry->readers.empty())
1028 // The writer transaction is gone.
