From a1bf14673eb05429c594c800f8cc5c8a3fddccf8 Mon Sep 17 00:00:00 2001 From: Cassandra Heart Date: Sat, 8 Mar 2025 00:23:53 -0600 Subject: [PATCH] filter unavailable from marking peer as done for sync --- .../intrinsics/token/token_execution_engine.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/node/execution/intrinsics/token/token_execution_engine.go b/node/execution/intrinsics/token/token_execution_engine.go index 9c075cf..107987f 100644 --- a/node/execution/intrinsics/token/token_execution_engine.go +++ b/node/execution/intrinsics/token/token_execution_engine.go @@ -706,7 +706,7 @@ func (e *TokenExecutionEngine) hyperSync(totalCoins int) { if err != nil { e.logger.Error("could not open stream", zap.Error(err)) e.syncController.SyncStatus[peer.ID(peerId).String()] = &rpc.SyncInfo{ - Unreachable: false, + Unreachable: true, LastSynced: gotime.Now(), } return @@ -728,9 +728,11 @@ func (e *TokenExecutionEngine) hyperSync(totalCoins int) { ) if err != nil { e.logger.Error("error while synchronizing", zap.Error(err)) - e.syncController.SyncStatus[peer.ID(peerId).String()] = &rpc.SyncInfo{ - Unreachable: false, - LastSynced: gotime.Now(), + if !strings.Contains(err.Error(), "unavailable") { + e.syncController.SyncStatus[peer.ID(peerId).String()] = &rpc.SyncInfo{ + Unreachable: false, + LastSynced: gotime.Now(), + } } continue }