X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fstoresession.cpp;h=bf214554250ac6ddf23185aa61bc448bcbf24e09;hp=92f64f5ba12a328b56bad5728ec8db14c3000b82;hb=ad83f8faadeded7902eb3e25b608f45674b86fa0;hpb=e93f553816d1938ab1917dff497a36acec4257e3 diff --git a/pv/storesession.cpp b/pv/storesession.cpp index 92f64f5b..bf214554 100644 --- a/pv/storesession.cpp +++ b/pv/storesession.cpp @@ -22,9 +22,11 @@ #include "storesession.hpp" +#include #include #include #include +#include #include #include @@ -45,6 +47,7 @@ using std::set; using std::shared_ptr; using std::string; using std::thread; +using std::unordered_set; using std::vector; using Glib::VariantBase; @@ -92,7 +95,8 @@ bool StoreSession::start() session_.get_data(); shared_lock lock(session_.signals_mutex()); - const vector< shared_ptr > &sigs(session_.signals()); + const unordered_set< shared_ptr > &sigs( + session_.signals()); // Check we have logic data if (data_set.empty() || sigs.empty()) { @@ -128,22 +132,15 @@ bool StoreSession::start() // Begin storing try { - auto context = session_.session()->context(); - auto device = session_.device(); + const auto context = session_.device_manager().context(); + auto device = session_.device()->device(); map options = options_; - // If the output has the capability to write files, use it. - // Otherwise, open the output stream. - const auto opt_list = output_format_->options(); - if (opt_list.find("filename") != opt_list.end()) - options["filename"] = - Glib::Variant::create(file_name_); - else - output_stream_.open(file_name_, ios_base::binary | - ios_base::trunc | ios_base::out); - - output_ = output_format_->create_output(device, options); + output_stream_.open(file_name_, ios_base::binary | + ios_base::trunc | ios_base::out); + + output_ = output_format_->create_output(file_name_, device, options); auto meta = context->create_meta_packet( {{ConfigKey::SAMPLERATE, Glib::Variant::create( segment->samplerate())}}); @@ -204,7 +201,7 @@ void StoreSession::store_proc(shared_ptr segment) size_t length = end_sample - start_sample; try { - auto context = session_.session()->context(); + const auto context = session_.device_manager().context(); auto logic = context->create_logic_packet(data, length, unit_size); const string data = output_->receive(logic); if (output_stream_.is_open())