test

    return ok_count;

}

void client::mark_node_dead(size_t node_index) {

    std::lock_guard<std::mutex> guard(mutex_);

    if (node_index < connections_.size()) {

        connections_[node_index].socket.reset();

        connections_[node_index].connected = false;

        connections_[node_index].dead_until =

            std::chrono::steady_clock::now() + std::chrono::seconds(10);

    }

}

} // namespace paritypp