mirrors/dragonflydb-dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2024-12-14 11:58:02 +00:00
Code Activity

fix cluster: migration traverse bug (#4279)

Browse source 
Signed-off-by: adi_holden <adi@dragonflydb.io>
This commit is contained in:
adiholden 2024-12-09 13:22:02 +02:00 committed by GitHub
parent 51e16b2ceb
commit d2f479b5da
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -209,7 +209,7 @@ void RestoreStreamer::Run() {
do { do {
if (fiber_cancelled_) if (fiber_cancelled_)
return; return;
cursor = pt->Traverse(cursor, [&](PrimeTable::bucket_iterator it) { cursor = pt->TraverseBuckets(cursor, [&](PrimeTable::bucket_iterator it) {
if (fiber_cancelled_) // Could be cancelled any time as Traverse may preempt if (fiber_cancelled_) // Could be cancelled any time as Traverse may preempt
return; return;