mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-11 18:35:46 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

bug server: fix lns mismatch in replication

Browse source 
Signed-off-by: adi_holden <adi@dragonflydb.io>
This commit is contained in:
adi_holden 2025-04-22 14:14:58 +03:00
parent c995ffc35a
commit 7402730f71
2 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
src/server/journal/streamer.cc
View file

@ -69,9 +69,10 @@ void JournalStreamer::Start(util::FiberSocketBase* dest, bool send_lsn) {
return;
}
DCHECK_GT(item.lsn, last_lsn_writen_);
Write(item.data);
time_t now = time(nullptr);
last_lsn_writen_ = item.lsn;
// TODO: to chain it to the previous Write call.
if (send_lsn && now - last_lsn_time_ > 3) {
last_lsn_time_ = now;

1
src/server/journal/streamer.h
View file

@ -68,6 +68,7 @@ class JournalStreamer {
size_t in_flight_bytes_ = 0, total_sent_ = 0;
time_t last_lsn_time_ = 0;
LSN last_lsn_writen_ = 0;
util::fb2::EventCount waker_;
uint32_t journal_cb_id_{0};
};