diff --git a/store/core/rpcpool.go b/store/core/rpcpool.go index 270b647..910f3d0 100644 --- a/store/core/rpcpool.go +++ b/store/core/rpcpool.go @@ -56,10 +56,11 @@ func NewCoreRPCClientPool(ctx context.Context, config *types.Config) (*ClientPoo } rpcClient := rpc.GetRPCClient() c.rpcClients = append(c.rpcClients, &clientWithStatus{client: rpcClient, addr: addr}) - // update client status synchronously - c.updateClientsStatus(ctx, config.GlobalConnectionTimeout) } + // init client status + c.updateClientsStatus(ctx, config.GlobalConnectionTimeout) + allFailed := true for _, rpc := range c.rpcClients { if rpc.alive {