From 276ca727079fcca75384528a424e714165321589 Mon Sep 17 00:00:00 2001 From: phuoc Date: Fri, 30 Aug 2024 15:59:27 +0700 Subject: [PATCH] increment query clock for new query --- serf/serf.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/serf/serf.go b/serf/serf.go index a260c8738..7f59f5ba5 100644 --- a/serf/serf.go +++ b/serf/serf.go @@ -559,10 +559,11 @@ func (s *Serf) Query(name string, payload []byte, params *QueryParam) (*QueryRes if params.RequestAck { flags |= queryFlagAck } - + lTime := s.queryClock.Time() + s.queryClock.Increment() // Create a message q := messageQuery{ - LTime: s.queryClock.Time(), + LTime: lTime, ID: uint32(rand.Int31()), Addr: local.Addr, Port: local.Port,