go/worker/common/committee: Remove unused node hooks

oasisprotocol · Nov 6, 2023 · 3d36519 · 3d36519
1 parent c439226
commit 3d36519
Show file tree

Hide file tree

Showing 5 changed files with 0 additions and 52 deletions.
diff --git a/go/worker/client/committee/node.go b/go/worker/client/committee/node.go
@@ -77,17 +77,6 @@ func (n *Node) Initialized() <-chan struct{} {
 	return n.initCh
 }
 
-// HandlePeerTx is guarded by CrossNode.
-func (n *Node) HandlePeerTx(context.Context, []byte) error {
-	// Nothing to do here.
-	return nil
-}
-
-// HandleEpochTransitionLocked is guarded by CrossNode.
-func (n *Node) HandleEpochTransitionLocked(*committee.EpochSnapshot) {
-	// Nothing to do here.
-}
-
 // HandleNewBlockEarlyLocked is guarded by CrossNode.
 func (n *Node) HandleNewBlockEarlyLocked(*runtime.BlockInfo) {
 	// Nothing to do here.

diff --git a/go/worker/common/committee/node.go b/go/worker/common/committee/node.go
@@ -127,11 +127,6 @@ var (
 // NodeHooks defines a worker's duties at common events.
 // These are called from the runtime's common node's worker.
 type NodeHooks interface {
-	// HandlePeerTx handles a transaction received from a (non-local) peer.
-	HandlePeerTx(ctx context.Context, tx []byte) error
-
-	// Guarded by CrossNode.
-	HandleEpochTransitionLocked(*EpochSnapshot)
 	// Guarded by CrossNode.
 	HandleNewBlockEarlyLocked(*runtime.BlockInfo)
 	// Guarded by CrossNode.
@@ -365,9 +360,6 @@ func (n *Node) handleEpochTransitionLocked(height int64) {
 	}
 
 	epochNumber.With(n.getMetricLabels()).Set(float64(epoch.epochNumber))
-	for _, hooks := range n.hooks {
-		hooks.HandleEpochTransitionLocked(epoch)
-	}
 }
 
 // Guarded by n.CrossNode.
@@ -377,11 +369,6 @@ func (n *Node) handleSuspendLocked(int64) {
 	// Suspend group.
 	n.Group.Suspend()
 
-	epoch := n.Group.GetEpochSnapshot()
-	for _, hooks := range n.hooks {
-		hooks.HandleEpochTransitionLocked(epoch)
-	}
-
 	// If the runtime has been suspended, we need to switch to checking the latest registry
 	// descriptor instead of the active one as otherwise we may miss deployment updates and never
 	// register, keeping the runtime suspended.

diff --git a/go/worker/common/committee/p2p.go b/go/worker/common/committee/p2p.go
@@ -52,12 +52,6 @@ func (h *txMsgHandler) HandleMessage(ctx context.Context, _ signature.PublicKey,
 		}
 	}
 
-	// Dispatch to any transaction handlers.
-	for _, hooks := range h.n.hooks {
-		if err := hooks.HandlePeerTx(ctx, tx); err != nil {
-			return err
-		}
-	}
 	return nil
 }
 

diff --git a/go/worker/compute/executor/committee/hooks.go b/go/worker/compute/executor/committee/hooks.go
@@ -9,18 +9,6 @@ import (
 // Ensure Node implements NodeHooks.
 var _ committee.NodeHooks = (*Node)(nil)
 
-// HandlePeerTx implements NodeHooks.
-func (n *Node) HandlePeerTx(context.Context, []byte) error {
-	// Nothing to do here.
-	return nil
-}
-
-// HandleEpochTransitionLocked implements NodeHooks.
-// Guarded by n.commonNode.CrossNode.
-func (n *Node) HandleEpochTransitionLocked(*committee.EpochSnapshot) {
-	// Nothing to do here.
-}
-
 // HandleNewBlockEarlyLocked implements NodeHooks.
 // Guarded by n.commonNode.CrossNode.
 func (n *Node) HandleNewBlockEarlyLocked(*runtime.BlockInfo) {

diff --git a/go/worker/storage/committee/node.go b/go/worker/storage/committee/node.go
@@ -337,16 +337,6 @@ func (n *Node) GetLocalStorage() storageApi.LocalBackend {
 
 // NodeHooks implementation.
 
-func (n *Node) HandlePeerTx(context.Context, []byte) error {
-	// Nothing to do here.
-	return nil
-}
-
-// HandleEpochTransitionLocked is guarded by CrossNode.
-func (n *Node) HandleEpochTransitionLocked(*committee.EpochSnapshot) {
-	// Nothing to do here.
-}
-
 // HandleNewBlockEarlyLocked is guarded by CrossNode.
 func (n *Node) HandleNewBlockEarlyLocked(*runtime.BlockInfo) {
 	// Nothing to do here.