WaitForUntilLeast23NodeAlive

Gossip.cs

public async Task WaitForUntilLeast23NodeAlive(CancellationToken ctx)
        {
            async Task<bool> PongResponse(BoundPeer peer)
            {
                try
                {
                    var result = await _transport.SendMessageAsync(
                        peer,
                        new PingMsg(),
                        TimeSpan.FromSeconds(1),
                        ctx);
                    return result is PongMsg;
                }
                catch (CommunicationFailException)
                {
                    return false;
                }
            }

            while (true)
            {
                var tasks = new List<Task<bool>>();
                foreach (var boundPeer in _peers)
                {
                    tasks.Add(PongResponse(boundPeer));
                }

                var result = await Task.WhenAll(tasks);
                if (result.Count(x => x) + 1 >= (_peers.Count() + 1) * 2 / 3)
                {
                    break;
                }

                _logger.Debug(
                    "Bootstrapped validators are not reached +2/3 yet," +
                    " current: {BootstrappedValidatorCount}",
                    result.Count(x => x));
            }

            _logger.Debug(
                "Bootstrapped validators are reached +2/3");
        }