mirror/ternfs-XTXMarkets
1
0
Fork 0
mirror of https://github.com/XTXMarkets/ternfs.git synced 2026-01-06 11:00:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

logsdb: log state at flush to have consistent view

Browse Source
This commit is contained in:
Miroslav Crnic
2024-03-19 12:44:56 +00:00
parent 5ce2efb88b
commit a4c091c7b2
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
cpp/core/LogsDB.cpp
View File

@@ -1555,6 +1555,10 @@ public:
_infoLoggedTime = eggsNow();
}
~LogsDBImpl() {
close();
}
void close() {
LOG_INFO(_env,"closing LogsDB, leaderToken(%s), lastReleased(%s), lastRead(%s)",_metadata.getLeaderToken(), _metadata.getLastReleased(), _catchupReader.lastRead());
}
@@ -1576,6 +1580,7 @@ public:
void flush(bool sync) {
ROCKS_DB_CHECKED(_db->FlushWAL(sync));
_maybeLogStatus();
}
void processIncomingMessages(std::vector<LogsDBRequest>& requests, std::vector<LogsDBResponse>& responses) {
@@ -1657,7 +1662,6 @@ public:
_appender.maybeMoveRelease();
_catchupReader.maybeCatchUp();
_reqResp.resendTimedOutRequests();
_maybeLogStatus();
}
void getOutgoingMessages(std::vector<LogsDBRequest*>& requests, std::vector<LogsDBResponse>& responses) {