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

test

parent 2107ddaf

debian/changelog

+7 −0
Original line number Diff line number Diff line 
libparitypp (20260405+22) unstable; urgency=medium



  * Add diagnostic stderr logging to client::store and store_stripe for

    debugging import hangs (stripe progress, failure diagnostics)



 -- Jan Koester <jan.koester@tuxist.de>  Sun, 05 Apr 2026 00:00:00 +0000



libparitypp (20260405+21) unstable; urgency=medium



  * Replace per-socket waitRead polling loop in store_stripe Phase 2 with

src/client.cpp

+8 −0
Original line number Diff line number Diff line
@@ -460,6 +460,7 @@ void client::store_stripe(uint64_t group_id, uint32_t stripe_index, 
    }



    if (failed > m_) {

        std::cerr << "[PARITY] store_stripe FAILED: " << diag << "\n";

        throw std::runtime_error("store_stripe: too many node failures ("

                                 + std::to_string(failed) + " > " + std::to_string(m_)

                                 + "): " + diag);
@@ -533,6 +534,9 @@ void client::store(uint64_t group_id, const uint8_t* data, size_t data_len) { 
    size_t framed_len = 8 + data_len;

    uint32_t stripe_idx = 0;

    size_t offset = 0;

    uint32_t total_stripes = static_cast<uint32_t>((framed_len + STRIPE_SIZE - 1) / STRIPE_SIZE);

    std::cerr << "[PARITY] store gid=" << group_id << " data_len=" << data_len

              << " stripes=" << total_stripes << "\n";



    while (offset < framed_len) {

        std::vector<uint8_t> stripe(STRIPE_SIZE, 0);
@@ -554,9 +558,13 @@ void client::store(uint64_t group_id, const uint8_t* data, size_t data_len) { 
        }



        store_stripe(group_id, stripe_idx, stripe.data(), STRIPE_SIZE);

        if (stripe_idx % 100 == 0 || stripe_idx + 1 == total_stripes) {

            std::cerr << "[PARITY]   stripe " << (stripe_idx+1) << "/" << total_stripes << "\n";

        }

        ++stripe_idx;

        offset += STRIPE_SIZE;

    }

    std::cerr << "[PARITY] store gid=" << group_id << " complete\n";

}



void client::store(uint64_t group_id, const std::vector<uint8_t>& data) {