X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fdata%2Fdecoderstack.cpp;h=b8eff67ffd02d0dc5ab018806b056b0c9849cf67;hp=5b58761f9c1c3464121299c3c6259a907015a10a;hb=064a7f42c7a107eae88c946718fe4141b52f8e0c;hpb=bfc9f61ebfb8d9c14c2786b34373816758d52e9f diff --git a/pv/data/decoderstack.cpp b/pv/data/decoderstack.cpp index 5b58761f..b8eff67f 100644 --- a/pv/data/decoderstack.cpp +++ b/pv/data/decoderstack.cpp @@ -173,12 +173,13 @@ void DecoderStack::decode_proc(shared_ptr data) const shared_ptr &snapshot = snapshots.front(); const int64_t sample_count = snapshot->get_sample_count() - 1; + const unsigned int chunk_sample_count = + DecodeChunkLength / snapshot->unit_size(); // Create the session srd_session_new(&session); assert(session); - // Create the decoders BOOST_FOREACH(const shared_ptr &dec, _stack) { @@ -209,12 +210,12 @@ void DecoderStack::decode_proc(shared_ptr data) for (int64_t i = 0; !boost::this_thread::interruption_requested() && i < sample_count; - i += DecodeChunkLength) + i += chunk_sample_count) { lock_guard decode_lock(_global_decode_mutex); const int64_t chunk_end = min( - i + DecodeChunkLength, sample_count); + i + chunk_sample_count, sample_count); snapshot->get_samples(chunk, i, chunk_end); if (srd_session_send(session, i, i + sample_count,