Use the new MessagesToSign API

Signed-off-by: Jakub Sztandera <[email protected]>

chain/lf3/f3.go

@@ -118,13 +118,9 @@ func (fff *F3) runSigningLoop(ctx context.Context) {
 	}
 
 	leaseMngr := new(leaseManager)
-	// create channel for some buffer so we don't get dropped under high load
-	msgCh := make(chan *gpbft.MessageBuilder, 4)
-	// SubscribeForMessagesToSign will close the channel if it fills up
-	// so using the closer is not necessary, we can just drop it on the floor
-	_ = fff.inner.SubscribeForMessagesToSign(msgCh)
+	// MessagesToSign is never closed
+	msgCh := fff.inner.MessagesToSign()
 
-loop:
 	for ctx.Err() == nil {
 		select {
 		case <-ctx.Done():
@@ -133,14 +129,7 @@ loop:
 			// resultCh has only one user and is buffered
 			l.resultCh <- leaseMngr.UpsertDefensive(l.minerID, l.newExpiration, l.oldExpiration)
 			close(l.resultCh)
-		case mb, ok := <-msgCh:
-			if !ok {
-				// we got dropped, resubscribe
-				msgCh = make(chan *gpbft.MessageBuilder, cap(msgCh))
-				_ = fff.inner.SubscribeForMessagesToSign(msgCh)
-				continue loop
-			}
-
+		case mb := <-msgCh:
 			for _, minerID := range leaseMngr.Active() {
 				err := participateOnce(ctx, mb, minerID)
 				if err != nil {