go/worker/compute/executor/committee: Process all runtime blocks

go/worker/compute/executor/committee/hooks.go

@@ -1,8 +1,6 @@
 package committee
 
 import (
-	"context"
-
 	"github.com/oasisprotocol/oasis-core/go/common/crash"
 	runtime "github.com/oasisprotocol/oasis-core/go/runtime/api"
 	"github.com/oasisprotocol/oasis-core/go/worker/common/committee"
@@ -35,12 +33,13 @@ func (n *Node) HandleNewBlockEarlyLocked(*runtime.BlockInfo) {
 // HandleNewBlockLocked implements NodeHooks.
 // Guarded by n.commonNode.CrossNode.
 func (n *Node) HandleNewBlockLocked(bi *runtime.BlockInfo) {
-	// Drop blocks if the worker falls behind.
+	// Stop sending blocks if the worker has stopped.
 	select {
-	case <-n.blockInfoCh:
+	case <-n.stopCh:
+		return
 	default:
 	}
 
-	// Non-blocking send.
+	// Don't skip any blocks, as the round worker must finalize the final round.
 	n.blockInfoCh <- bi
 }