diff --git a/cmd/rpc/slots/slot.go b/cmd/rpc/slots/slot.go index 40e56dc..6c596c1 100644 --- a/cmd/rpc/slots/slot.go +++ b/cmd/rpc/slots/slot.go @@ -142,10 +142,6 @@ func watchSlotUpdates(ctx context.Context, node *envv1.RPCNode, highest *sync.Ma ts := m.Timestamp.Time() delay := time.Since(ts) - if *flagType != "" && string(m.Type) != *flagType { - continue - } - sched.Update(m.Slot) var first time.Time @@ -170,6 +166,10 @@ func watchSlotUpdates(ctx context.Context, node *envv1.RPCNode, highest *sync.Ma prop = -1 } + if *flagType != "" && string(m.Type) != *flagType { + continue + } + klog.Infof("%s: slot=%d type=%s delay=%dms prop=%dms parent=%d stats=%v leader=%s", node.Name, m.Slot, m.Type, delay.Milliseconds(), prop, m.Parent, m.Stats, sched.Get(m.Slot)) }