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

Reorder process of queues in TagQueue::runEpoch

This commit is contained in:
sfc-gh-tclinkenbeard 2022-10-04 15:23:22 -07:00
parent 0203c93a44
commit c29213eec2
1 changed files with 21 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
fdbserver/TagQueue.actor.cpp
View File

@ -64,26 +64,6 @@ void TagQueue::runEpoch(double elapsed,
SpannedDeque<GetReadVersionRequest>& outImmediatePriority) {
startEpoch();
Deque<DelayedRequest> newDelayedRequests;
while (!newRequests.empty()) {
auto const& req = newRequests.front();
if (canStart(req)) {
for (const auto& [tag, count] : req.tags) {
releasedInEpoch[tag] += count;
}
if (req.priority == TransactionPriority::BATCH) {
outBatchPriority.push_back(req);
} else if (req.priority == TransactionPriority::DEFAULT) {
outDefaultPriority.push_back(req);
} else if (req.priority == TransactionPriority::IMMEDIATE) {
outImmediatePriority.push_back(req);
} else {
ASSERT(false);
}
} else {
newDelayedRequests.emplace_back(req);
}
newRequests.pop_front();
}
while (!delayedRequests.empty()) {
auto const& delayedReq = delayedRequests.front();
@ -107,6 +87,27 @@ void TagQueue::runEpoch(double elapsed,
delayedRequests.pop_front();
}
while (!newRequests.empty()) {
auto const& req = newRequests.front();
if (canStart(req)) {
for (const auto& [tag, count] : req.tags) {
releasedInEpoch[tag] += count;
}
if (req.priority == TransactionPriority::BATCH) {
outBatchPriority.push_back(req);
} else if (req.priority == TransactionPriority::DEFAULT) {
outDefaultPriority.push_back(req);
} else if (req.priority == TransactionPriority::IMMEDIATE) {
outImmediatePriority.push_back(req);
} else {
ASSERT(false);
}
} else {
newDelayedRequests.emplace_back(req);
}
newRequests.pop_front();
}
delayedRequests = std::move(newDelayedRequests);
endEpoch(elapsed);
}