[Tarantool-patches] [PATCH] applier: fix upstream.lag calculations

Serge Petrenko sergepetrenko at tarantool.org
Fri Aug 13 17:25:46 MSK 2021

upstream.lag is the delta between the moment when a row was written to
master's journal and the moment when it was received by the replica.
It's an important metric to check whether the replica has fallen too far
behind master.

Not all the rows coming from master have a valid time of creation. For
example, RAFT system messages don't have one, and we can't assign
correct time to them: these messages do not originate from the journal,
and assigning current time to them would lead to jumps in upstream.lag

Stop updating upstream.lag for rows which don't have creation time

This also fixes the flaky replication/errinj.test.lua

 src/box/applier.cc | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/box/applier.cc b/src/box/applier.cc
index 902d0bc72..9256078e1 100644
--- a/src/box/applier.cc
+++ b/src/box/applier.cc
@@ -664,7 +664,8 @@ applier_read_tx_row(struct applier *applier, double timeout)
 	coio_read_xrow_timeout_xc(coio, ibuf, row, timeout);
-	applier->lag = ev_now(loop()) - row->tm;
+	if (row->tm > 0)
+		applier->lag = ev_now(loop()) - row->tm;
 	applier->last_row_time = ev_monotonic_now(loop());
 	return tx_row;
2.30.1 (Apple Git-130)

More information about the Tarantool-patches mailing list