Lines Matching refs:pending_queue
122 WorkItemList pending_queue;
378 entry->pending_queue.clear();
407 STLDeleteElements(&pending_op->pending_queue);
510 pending_op->pending_queue.push_back(item.release());
514 DCHECK(pending_op->pending_queue.empty());
540 pending_op->pending_queue.push_back(item);
612 pending_op->pending_queue.push_back(item);
616 DCHECK(pending_op->pending_queue.empty());
635 DCHECK(entry->pending_queue.empty());
663 DCHECK(entry->pending_queue.empty());
719 DCHECK(pending_op->pending_queue.empty());
735 pending_op->pending_queue.push_back(item);
739 DCHECK(pending_op->pending_queue.empty());
761 pending_op->pending_queue.push_back(item);
765 DCHECK(pending_op->pending_queue.empty());
802 entry->pending_queue.push_back(trans);
811 entry->pending_queue.push_back(trans);
822 if (!entry->writer && !entry->pending_queue.empty())
863 TransactionList pending_queue;
864 pending_queue.swap(entry->pending_queue);
871 while (!pending_queue.empty()) {
873 pending_queue.front()->io_callback()->Run(ERR_CACHE_RACE);
874 pending_queue.pop_front();
951 TransactionList& pending_queue = entry->pending_queue;
954 find(pending_queue.begin(), pending_queue.end(), trans);
955 if (j == pending_queue.end())
958 pending_queue.erase(j);
969 WorkItemList& pending_queue = pending_op->pending_queue;
971 WorkItemList::iterator it = pending_queue.begin();
972 for (; it != pending_queue.end(); ++it) {
975 pending_queue.erase(it);
1001 if (entry->pending_queue.empty()) {
1008 Transaction* next = entry->pending_queue.front();
1012 entry->pending_queue.erase(entry->pending_queue.begin());
1061 pending_items.swap(pending_op->pending_queue);
1127 if (!pending_op->pending_queue.empty()) {
1128 WorkItem* pending_item = pending_op->pending_queue.front();
1129 pending_op->pending_queue.pop_front();
