X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fstoresession.cpp;h=3d7b058a87034b6c02cc4109347e798b94702b40;hp=cb643682d57023462e38cc8dbd228bcd2182a353;hb=72486b789078f024e4f3404f81118c03b03e2b70;hpb=b8f1cdeba7cf6c2b749ff60102ce4e260fa1309e diff --git a/pv/storesession.cpp b/pv/storesession.cpp index cb643682..3d7b058a 100644 --- a/pv/storesession.cpp +++ b/pv/storesession.cpp @@ -145,6 +145,7 @@ bool StoreSession::start() uint64_t end_sample; if (sample_range_.first == sample_range_.second) { + // No sample range specified, save everything we have start_sample_ = 0; sample_count_ = any_segment->get_sample_count(); } else { @@ -159,6 +160,12 @@ bool StoreSession::start() } } + // Make sure the sample range is valid + if (start_sample_ > any_segment->get_sample_count()) { + error_ = tr("Can't save range without sample data."); + return false; + } + // Begin storing try { const auto context = session_.device_manager().context(); @@ -175,7 +182,7 @@ bool StoreSession::start() {{ConfigKey::SAMPLERATE, Glib::Variant::create( any_segment->samplerate())}}); output_->receive(meta); - } catch (Error error) { + } catch (Error& error) { error_ = tr("Error while saving: ") + error.what(); return false; } @@ -240,8 +247,8 @@ void StoreSession::store_proc(vector< shared_ptr > achannel_li shared_ptr achannel = (achannel_list.at(i))->channel(); shared_ptr asegment = asegment_list.at(i); - const float *adata = - asegment->get_samples(start_sample_, start_sample_ + packet_len); + float *adata = new float[packet_len]; + asegment->get_samples(start_sample_, start_sample_ + packet_len, adata); auto analog = context->create_analog_packet( vector >{achannel}, @@ -257,11 +264,11 @@ void StoreSession::store_proc(vector< shared_ptr > achannel_li } if (lsegment) { - const uint8_t* ldata = - lsegment->get_samples(start_sample_, start_sample_ + packet_len); + const size_t data_size = packet_len * lunit_size; + uint8_t* ldata = new uint8_t[data_size]; + lsegment->get_samples(start_sample_, start_sample_ + packet_len, ldata); - const size_t length = packet_len * lunit_size; - auto logic = context->create_logic_packet((void*)ldata, length, lunit_size); + auto logic = context->create_logic_packet((void*)ldata, data_size, lunit_size); const string ldata_str = output_->receive(logic); if (output_stream_.is_open()) @@ -269,7 +276,7 @@ void StoreSession::store_proc(vector< shared_ptr > achannel_li delete[] ldata; } - } catch (Error error) { + } catch (Error& error) { error_ = tr("Error while saving: ") + error.what(); break; }