checking error on route.Route

stellar · Sep 26, 2024 · 22ed801 · 22ed801
1 parent 3b174b8
commit 22ed801
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/internal/tss/channels/error_jitter_channel.go b/internal/tss/channels/error_jitter_channel.go
@@ -79,7 +79,10 @@ func (p *errorJitterPool) Receive(payload tss.Payload) {
 	if i == p.MaxRetries {
 		// Retry limit reached, route the payload to the router so it can re-route it to this pool and keep re-trying
 		// NOTE: Is this a good idea? Infinite tries per transaction ?
-		p.Router.Route(payload)
+		err := p.Router.Route(payload)
+		if err != nil {
+			log.Errorf("%s: Unable to route payload: %e", ErrorJitterChannelName, err)
+		}
 	}
 }
 

diff --git a/internal/tss/channels/error_non_jitter_channel.go b/internal/tss/channels/error_non_jitter_channel.go
@@ -75,7 +75,11 @@ func (p *errorNonJitterPool) Receive(payload tss.Payload) {
 	if i == p.MaxRetries {
 		// Retry limit reached, route the payload to the router so it can re-route it to this pool and keep re-trying
 		// NOTE: Is this a good idea?
-		p.Router.Route(payload)
+		err := p.Router.Route(payload)
+		if err != nil {
+			log.Errorf("%s: Unable to route payload: %e", ErrorNonJitterChannelName, err)
+			return
+		}
 	}
 }