wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Make pqOfQueues a min heap in the proper way

This commit is contained in:
sfc-gh-tclinkenbeard 2022-10-13 10:07:45 -07:00
parent 79f0e3fcaa
commit 27b11797ff
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
fdbserver/GrvProxyTransactionTagThrottler.actor.cpp
View File

@ -90,8 +90,7 @@ void GrvProxyTransactionTagThrottler::releaseTransactions(double elapsed,
uint32_t* numReleased;
// Sequence number of the first queued request
int64_t nextSeqNo;
// Reverse order because std::priority_queue is a max heap
bool operator<(TagQueueHandle const& rhs) const { return nextSeqNo > rhs.nextSeqNo; }
bool operator>(TagQueueHandle const& rhs) const { return nextSeqNo > rhs.nextSeqNo; }
explicit TagQueueHandle(TagQueue& queue, uint32_t& numReleased) : queue(&queue), numReleased(&numReleased) {
ASSERT(!this->queue->requests.empty());
nextSeqNo = this->queue->requests.front().sequenceNumber;
@ -100,7 +99,7 @@ void GrvProxyTransactionTagThrottler::releaseTransactions(double elapsed,
// Priority queue of queues for each tag, ordered by the sequence number of the
// next request to process in each queue
std::priority_queue<TagQueueHandle> pqOfQueues;
std::priority_queue<TagQueueHandle, std::vector<TagQueueHandle>, std::greater<TagQueueHandle>> pqOfQueues;
// Track transactions released for each tag
std::vector<std::pair<TransactionTag, uint32_t>> transactionsReleased;