Skip to content

Commit 8466010

Browse files
committed
chore: add time printing
Signed-off-by: Roman Gershman <[email protected]>
1 parent 47793e2 commit 8466010

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

src/server/snapshot.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -176,7 +176,7 @@ void SliceSnapshot::IterateBucketsFb(bool send_full_sync_cut) {
176176
cursor = next;
177177

178178
// If we do not flush the data, and have not preempted,
179-
// we may need to yield to other fibers to avoid grabbind the CPU for too long.
179+
// we may need to yield to other fibers to avoid grabbing CPU for too long.
180180
if (!PushSerialized(false)) {
181181
if (ThisFiber::GetRunningTimeCycles() > kCyclesPerJiffy) {
182182
ThisFiber::Yield();

tests/dragonfly/replication_test.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -167,6 +167,7 @@ async def check_all_replicas_finished(c_replicas, c_master, timeout=20):
167167
start = time.time()
168168
while (time.time() - start) < timeout:
169169
if not waiting_for:
170+
logging.debug("All replicas finished after %s seconds", time.time() - start)
170171
return
171172
await asyncio.sleep(0.2)
172173
m_offset = await c_master.execute_command("DFLY REPLICAOFFSET")
@@ -2714,7 +2715,7 @@ async def test_replication_timeout_on_full_sync_heartbeat_expiry(
27142715

27152716
await asyncio.sleep(1) # replica will start resync
27162717

2717-
await check_all_replicas_finished([c_replica], c_master)
2718+
await check_all_replicas_finished([c_replica], c_master, 60)
27182719
await assert_replica_reconnections(replica, 0)
27192720

27202721

0 commit comments

Comments
 (0)