From 234843f0f1c8e06ba47c1e160583d6e03da4d2d7 Mon Sep 17 00:00:00 2001 From: Peter Nose Date: Mon, 6 Nov 2023 10:37:19 +0100 Subject: [PATCH] go/worker/compute/executor/committee: Process all runtime blocks --- go/worker/compute/executor/committee/hooks.go | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/go/worker/compute/executor/committee/hooks.go b/go/worker/compute/executor/committee/hooks.go index 017f67e4463..601115a3cda 100644 --- a/go/worker/compute/executor/committee/hooks.go +++ b/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,6 @@ 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. - select { - case <-n.blockInfoCh: - default: - } - - // Non-blocking send. + // Don't skip any blocks, as the round worker must finalize the final round. n.blockInfoCh <- bi }