Commit d8ee28e8 authored by jan.koester's avatar jan.koester
Browse files

test

parent 245b4244

src/cluster.cpp

+5 −3
Original line number Diff line number Diff line
@@ -496,12 +496,14 @@ namespace authdb { 
    void Cluster::health_monitor_loop() {

        size_t k = cfg_.data_blocks;

        size_t n = cfg_.data_blocks + cfg_.parity_blocks;

        bool first_run = true;

        while (running_) {

            {

            if (!first_run) {

                std::unique_lock<std::mutex> lk(monitor_mutex_);

                monitor_cv_.wait_for(lk, std::chrono::seconds(10),

                                     [this]{ return !running_.load(); });

            }

            first_run = false;

            if (!running_ || !pclient_) continue;

            try {

                std::unique_lock<std::timed_mutex> lock(client_mutex_, std::try_to_lock);
@@ -549,9 +551,9 @@ namespace authdb { 


        try {

            std::cerr << "[CLUSTER] pushSession: acquiring lock" << std::endl;

            std::unique_lock<std::timed_mutex> lock(client_mutex_, std::chrono::seconds(5));

            std::unique_lock<std::timed_mutex> lock(client_mutex_, std::chrono::seconds(1));

            if (!lock.owns_lock()) {

                std::cerr << "[CLUSTER] pushSession: lock timeout (5s)" << std::endl;

                std::cerr << "[CLUSTER] pushSession: lock timeout (1s)" << std::endl;

                return;

            }

            auto t1 = std::chrono::steady_clock::now();