File tree Expand file tree Collapse file tree 1 file changed +0
-15
lines changed
Expand file tree Collapse file tree 1 file changed +0
-15
lines changed Original file line number Diff line number Diff line change @@ -175,21 +175,6 @@ func (e *Engine) SubmitCollectionGuarantee(msg *messages.SubmitCollectionGuarant
175175 e .notifier .Notify ()
176176}
177177
178- // process processes events for the pusher engine on the collection node.
179- func (e * Engine ) process (originID flow.Identifier , event interface {}) error {
180- switch ev := event .(type ) {
181- case * messages.SubmitCollectionGuarantee :
182- e .engMetrics .MessageReceived (metrics .EngineCollectionProvider , metrics .MessageSubmitGuarantee )
183- defer e .engMetrics .MessageHandled (metrics .EngineCollectionProvider , metrics .MessageSubmitGuarantee )
184- if originID != e .me .NodeID () {
185- return fmt .Errorf ("invalid remote request to submit collection guarantee (from=%x)" , originID )
186- }
187- return e .publishCollectionGuarantee (& ev .Guarantee )
188- default :
189- return fmt .Errorf ("invalid event type (%T)" , event )
190- }
191- }
192-
193178// publishCollectionGuarantee publishes the collection guarantee to all consensus nodes.
194179func (e * Engine ) publishCollectionGuarantee (guarantee * flow.CollectionGuarantee ) error {
195180 consensusNodes , err := e .state .Final ().Identities (filter.HasRole [flow.Identity ](flow .RoleConsensus ))
You can’t perform that action at this time.
0 commit comments