mirror/ternfs-XTXMarkets
1
0
Fork 0
mirror of https://github.com/XTXMarkets/ternfs.git synced 2026-02-04 09:20:00 -06:00
Code Issues Packages Projects Releases Wiki Activity

gcmigrate: support sharding

Browse Source
This commit is contained in:
Miroslav Crnic
2024-06-20 15:19:16 +00:00
parent 6cf8a01272
commit 99aa882575
2 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cpp/shard/Shard.cpp
View File

@@ -856,6 +856,7 @@ public:
_outgoingLogEntries.clear();
_replicaInfo = _shared.replicas;
uint32_t pulled = _shared.writerRequestsQueue.pull(_requests, _maxWritesAtOnce, _logsDB.getNextTimeout());
auto start = eggsNow();
if (likely(pulled > 0)) {
LOG_DEBUG(_env, "pulled %s requests from write queue", pulled);
_shared.pulledWriteRequests = _shared.pulledWriteRequests*0.95 + ((double)pulled)*0.05;
@@ -883,6 +884,7 @@ public:
}
}
logsDBStep();
auto loopTime = eggsNow() - start;
}
};