Commit 65d7575b authored by jan.koester's avatar jan.koester
Browse files

test

parent 658b83ba

src/cluster.cpp

+5 −0
Changes for src/cluster.cpp: 5 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -267,6 +267,9 @@ namespace authdb { 
            // Track the mapping so we can retrieve later

            std::lock_guard<std::mutex> ilock(index_mutex_);

            session_index_[sgid] = {pgid, data.size()};

        } catch (const netplus::NetException &e) {

            // Log but don't fail - local session still valid

            std::cerr << "Cluster push failed: " << e.what() << std::endl;

        } catch (const std::exception &e) {

            // Log but don't fail - local session still valid

            std::cerr << "Cluster push failed: " << e.what() << std::endl;
@@ -491,6 +494,8 @@ namespace authdb { 


            std::lock_guard<std::mutex> olock(ops_mutex_);

            pending_ops_.push_back({pgid, data.size()});

        } catch (const netplus::NetException &e) {

            std::cerr << "Cluster replicate failed: " << e.what() << std::endl;

        } catch (const std::exception &e) {

            std::cerr << "Cluster replicate failed: " << e.what() << std::endl;

        }