Added absOffset for logging

levenlabs · May 6, 2016 · 2054f15 · 2054f15
1 parent dccd235
commit 2054f15
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/transaction/incoming.go b/transaction/incoming.go
@@ -170,8 +170,9 @@ func handleIncomingReport(t *tx, rep *lproto.Report) (*lproto.TxMsg_Report, *lpr
 			} else {
 				fin.Offset = offset
 				kv["offset"] = offset
-				llog.Info("slave offset", kv)
-				if config.Threshold < math.Abs(offset) {
+				absOff := math.Abs(offset)
+				llog.Info("slave offset", kv, llog.KV{"absOffset": absOff})
+				if config.Threshold < absOff {
 					llog.Warn("slave offset is over threshold", kv)
 				}
 			}