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

Debug: log local_node_index_ and local_store_ in store_stripe Phase 1

parent bd193286

src/client.cpp

+4 −0
Original line number Diff line number Diff line
@@ -394,10 +394,14 @@ void client::store_stripe(uint64_t group_id, uint32_t stripe_index, 


    // Phase 1: store local blocks + send to remote nodes in parallel

    {

        std::cerr << "[PARITY] store_stripe: local_node_index_=" << local_node_index_

                  << " local_store_=" << (local_store_ ? "yes" : "no") << std::endl;

        // Local node first (no thread needed)

        for (size_t i = 0; i < n; i++) {

            if (static_cast<int>(i) == local_node_index_ && local_store_) {

                std::cerr << "[PARITY] store_stripe: calling local send_to_node(" << i << ")" << std::endl;

                send_to_node(i);

                std::cerr << "[PARITY] store_stripe: local send_to_node(" << i << ") done" << std::endl;

            }

        }

        std::cerr << "[PARITY] store_stripe: Phase 1 launching " << n << " async tasks" << std::endl;