chore: fixeS

Signed-off-by: Roman Gershman <[email protected]>

Author: romange

src/server/snapshot.cc

@@ -154,6 +154,8 @@ void SliceSnapshot::IterateBucketsFb(bool send_full_sync_cut) {
     stats_.keys_total += db_slice_->DbSize(db_indx);
   }
 
+  const uint64_t kCyclesPerYield = base::CycleClock::Frequency() >> 16;  // ~15usec.
+
   for (DbIndex db_indx = 0; db_indx < db_array_.size(); ++db_indx) {
     if (!cntx_->IsRunning())
       return;
@@ -164,6 +166,7 @@ void SliceSnapshot::IterateBucketsFb(bool send_full_sync_cut) {
     PrimeTable* pt = &db_array_[db_indx]->prime;
     VLOG(1) << "Start traversing " << pt->size() << " items for index " << db_indx;
 
+    uint64_t start_cycles = base::CycleClock::Now();
     do {
       if (!cntx_->IsRunning()) {
         return;
@@ -172,7 +175,11 @@ void SliceSnapshot::IterateBucketsFb(bool send_full_sync_cut) {
       PrimeTable::Cursor next = pt->TraverseBuckets(
           cursor, [this, &db_indx](auto it) { return BucketSaveCb(db_indx, it); });
       cursor = next;
-      ThisFiber::Yield();
+      uint64_t now = base::CycleClock::Now();
+      if (now > start_cycles + kCyclesPerYield) {
+        ThisFiber::Yield();
+        start_cycles = base::CycleClock::Now();
+      }
 
       PushSerialized(false);
     } while (cursor);