diff --git a/x/ccv/consumer/keeper/genesis.go b/x/ccv/consumer/keeper/genesis.go index a4cd8f10e1..e06c5c4ab7 100644 --- a/x/ccv/consumer/keeper/genesis.go +++ b/x/ccv/consumer/keeper/genesis.go @@ -140,7 +140,7 @@ func (k Keeper) ExportGenesis(ctx sdk.Context) (genesis *consumertypes.GenesisSt ValidatorConsensusAddress: addr, } outstandingDowntimes = append(outstandingDowntimes, od) - return false + return true }) genesis = types.NewRestartGenesisState( diff --git a/x/ccv/provider/keeper/grpc_query.go b/x/ccv/provider/keeper/grpc_query.go index 4f67959c39..bd2479581c 100644 --- a/x/ccv/provider/keeper/grpc_query.go +++ b/x/ccv/provider/keeper/grpc_query.go @@ -43,7 +43,7 @@ func (k Keeper) QueryConsumerChains(goCtx context.Context, req *types.QueryConsu ChainId: chainID, ClientId: clientID, }) - return false + return true } k.IterateConsumerChains(ctx, cb) diff --git a/x/ccv/provider/keeper/hooks.go b/x/ccv/provider/keeper/hooks.go index 2d772caa8d..b89b9eaabf 100644 --- a/x/ccv/provider/keeper/hooks.go +++ b/x/ccv/provider/keeper/hooks.go @@ -27,7 +27,7 @@ func (h Hooks) AfterUnbondingInitiated(ctx sdk.Context, ID uint64) { h.k.IterateConsumerChains(ctx, func(ctx sdk.Context, chainID, clientID string) (stop bool) { consumerChainIDS = append(consumerChainIDS, chainID) - return false + return true }) if len(consumerChainIDS) == 0 { // Do not put the unbonding op on hold if there are no consumer chains diff --git a/x/ccv/provider/keeper/relay.go b/x/ccv/provider/keeper/relay.go index 9c6bd12398..2b7d0debf6 100644 --- a/x/ccv/provider/keeper/relay.go +++ b/x/ccv/provider/keeper/relay.go @@ -172,7 +172,7 @@ func (k Keeper) sendValidatorUpdates(ctx sdk.Context) { k.AppendPendingVSC(ctx, chainID, packetData) } } - return false // do not stop the iteration + return true // do not stop the iteration }) k.IncrementValidatorSetUpdateId(ctx) } @@ -354,7 +354,7 @@ func (k Keeper) EndBlockCCR(ctx sdk.Context) { return false }) // continue to iterate through all consumers - return true + return false }) // remove consumers that timed out for _, chainID := range chainIdsToRemove {