diff --git a/services/bidcollect/data-api-poller.go b/services/bidcollect/data-api-poller.go index e07f0e1..fea2aa1 100644 --- a/services/bidcollect/data-api-poller.go +++ b/services/bidcollect/data-api-poller.go @@ -47,7 +47,7 @@ func (poller *DataAPIPoller) Start() { tNextSlot := common.SlotToTime(nextSlot) untilNextSlot := tNextSlot.Sub(t) - poller.Log.Infof("[data-api poller] waiting until start of next slot (%d, %s from now)", nextSlot, untilNextSlot.String()) + poller.Log.Infof("[data-api poller] waiting until start of next slot (%d - %s from now)", nextSlot, untilNextSlot.String()) time.Sleep(untilNextSlot) // then run polling loop @@ -59,7 +59,7 @@ func (poller *DataAPIPoller) Start() { tNextSlot := common.SlotToTime(nextSlot) untilNextSlot := tNextSlot.Sub(t) - poller.Log.Infof("[data-api poller] current slot: %d / next slot: %d (%s), waitTime: %s", slot, nextSlot, tNextSlot.String(), untilNextSlot.String()) + poller.Log.Infof("[data-api poller] scheduling polling for upcoming slot: %d (%s - in %s)", nextSlot, tNextSlot.String(), untilNextSlot.String()) // Schedule polling at t-4, t-2, t=0, t=2 go poller.pollRelaysForBids(nextSlot, -4*time.Second) diff --git a/services/bidcollect/getheader-poller.go b/services/bidcollect/getheader-poller.go index c9da027..07b90bb 100644 --- a/services/bidcollect/getheader-poller.go +++ b/services/bidcollect/getheader-poller.go @@ -121,7 +121,6 @@ func (poller *GetHeaderPoller) Start() { if nextProposerPubkey == "" { poller.log.WithField("duties", duties).Error("no proposerPubkey for next slot") } else { - go poller.pollRelaysForBids(-2*time.Second, nextSlot, block.Data.Message.Body.ExecutionPayload.BlockHash.String(), duties[nextSlot]) go poller.pollRelaysForBids(0*time.Second, nextSlot, block.Data.Message.Body.ExecutionPayload.BlockHash.String(), duties[nextSlot]) go poller.pollRelaysForBids(1500*time.Millisecond, nextSlot, block.Data.Message.Body.ExecutionPayload.BlockHash.String(), duties[nextSlot]) }