X-Git-Url: http://git.code-monkey.de/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fsigsession.cpp;h=87ba9afa5d484eace490524d5d9247a0ab5061ef;hp=80830214877148f38a6100c06dc43bbc56c0a134;hb=2b81ae4682ade4109ffa442794de36ceb32045eb;hpb=4e7f5ba834f5bafd9fb5c7a6edb30748b2f93c59 diff --git a/pv/sigsession.cpp b/pv/sigsession.cpp index 8083021..87ba9af 100644 --- a/pv/sigsession.cpp +++ b/pv/sigsession.cpp @@ -82,7 +82,7 @@ using Glib::VariantBase; using Glib::Variant; namespace pv { -SigSession::SigSession(DeviceManager &device_manager) : +Session::Session(DeviceManager &device_manager) : device_manager_(device_manager), session_(device_manager.context()->create_session()), capture_state_(Stopped) @@ -90,33 +90,33 @@ SigSession::SigSession(DeviceManager &device_manager) : set_default_device(); } -SigSession::~SigSession() +Session::~Session() { // Stop and join to the thread stop_capture(); } -DeviceManager& SigSession::device_manager() +DeviceManager& Session::device_manager() { return device_manager_; } -const DeviceManager& SigSession::device_manager() const +const DeviceManager& Session::device_manager() const { return device_manager_; } -const shared_ptr& SigSession::session() const +const shared_ptr& Session::session() const { return session_; } -shared_ptr SigSession::device() const +shared_ptr Session::device() const { return device_; } -void SigSession::set_device(shared_ptr device) +void Session::set_device(shared_ptr device) { // Ensure we are not capturing before setting the device stop_capture(); @@ -157,7 +157,7 @@ void SigSession::set_device(shared_ptr device) device_selected(); } -void SigSession::set_file(const string &name) +void Session::set_file(const string &name) { session_ = device_manager_.context()->load_session(name); device_ = session_->devices()[0]; @@ -171,7 +171,7 @@ void SigSession::set_file(const string &name) device_selected(); } -void SigSession::set_default_device() +void Session::set_default_device() { shared_ptr default_device; const list< shared_ptr > &devices = @@ -192,13 +192,13 @@ void SigSession::set_default_device() } } -SigSession::capture_state SigSession::get_capture_state() const +Session::capture_state Session::get_capture_state() const { lock_guard lock(sampling_mutex_); return capture_state_; } -void SigSession::start_capture(function error_handler) +void Session::start_capture(function error_handler) { stop_capture(); @@ -220,11 +220,11 @@ void SigSession::start_capture(function error_handler) // Begin the session sampling_thread_ = std::thread( - &SigSession::sample_thread_proc, this, device_, + &Session::sample_thread_proc, this, device_, error_handler); } -void SigSession::stop_capture() +void Session::stop_capture() { if (get_capture_state() != Stopped) session_->stop(); @@ -234,7 +234,7 @@ void SigSession::stop_capture() sampling_thread_.join(); } -set< shared_ptr > SigSession::get_data() const +set< shared_ptr > Session::get_data() const { shared_lock lock(signals_mutex_); set< shared_ptr > data; @@ -246,18 +246,18 @@ set< shared_ptr > SigSession::get_data() const return data; } -boost::shared_mutex& SigSession::signals_mutex() const +boost::shared_mutex& Session::signals_mutex() const { return signals_mutex_; } -const vector< shared_ptr >& SigSession::signals() const +const vector< shared_ptr >& Session::signals() const { return signals_; } #ifdef ENABLE_DECODE -bool SigSession::add_decoder(srd_decoder *const dec) +bool Session::add_decoder(srd_decoder *const dec) { map > channels; shared_ptr decoder_stack; @@ -313,13 +313,13 @@ bool SigSession::add_decoder(srd_decoder *const dec) return true; } -vector< shared_ptr > SigSession::get_decode_signals() const +vector< shared_ptr > Session::get_decode_signals() const { shared_lock lock(signals_mutex_); return decode_traces_; } -void SigSession::remove_decode_signal(view::DecodeTrace *signal) +void Session::remove_decode_signal(view::DecodeTrace *signal) { for (auto i = decode_traces_.begin(); i != decode_traces_.end(); i++) if ((*i).get() == signal) @@ -331,7 +331,7 @@ void SigSession::remove_decode_signal(view::DecodeTrace *signal) } #endif -void SigSession::set_capture_state(capture_state state) +void Session::set_capture_state(capture_state state) { lock_guard lock(sampling_mutex_); const bool changed = capture_state_ != state; @@ -340,7 +340,7 @@ void SigSession::set_capture_state(capture_state state) capture_state_changed(state); } -void SigSession::update_signals(shared_ptr device) +void Session::update_signals(shared_ptr device) { assert(device); assert(capture_state_ == Stopped); @@ -407,7 +407,7 @@ void SigSession::update_signals(shared_ptr device) signals_changed(); } -shared_ptr SigSession::signal_from_channel( +shared_ptr Session::signal_from_channel( shared_ptr channel) const { lock_guard lock(signals_mutex_); @@ -419,7 +419,7 @@ shared_ptr SigSession::signal_from_channel( return shared_ptr(); } -void SigSession::read_sample_rate(shared_ptr device) +void Session::read_sample_rate(shared_ptr device) { const auto keys = device_->config_keys(ConfigKey::DEVICE_OPTIONS); const auto iter = keys.find(ConfigKey::SAMPLERATE); @@ -436,7 +436,7 @@ void SigSession::read_sample_rate(shared_ptr device) } } -void SigSession::sample_thread_proc(shared_ptr device, +void Session::sample_thread_proc(shared_ptr device, function error_handler) { assert(device); @@ -465,12 +465,12 @@ void SigSession::sample_thread_proc(shared_ptr device, } } -void SigSession::feed_in_header(shared_ptr device) +void Session::feed_in_header(shared_ptr device) { read_sample_rate(device); } -void SigSession::feed_in_meta(shared_ptr device, +void Session::feed_in_meta(shared_ptr device, shared_ptr meta) { (void)device; @@ -489,13 +489,13 @@ void SigSession::feed_in_meta(shared_ptr device, signals_changed(); } -void SigSession::feed_in_frame_begin() +void Session::feed_in_frame_begin() { if (cur_logic_snapshot_ || !cur_analog_snapshots_.empty()) frame_began(); } -void SigSession::feed_in_logic(shared_ptr logic) +void Session::feed_in_logic(shared_ptr logic) { lock_guard lock(data_mutex_); @@ -540,7 +540,7 @@ void SigSession::feed_in_logic(shared_ptr logic) data_received(); } -void SigSession::feed_in_analog(shared_ptr analog) +void Session::feed_in_analog(shared_ptr analog) { lock_guard lock(data_mutex_); @@ -608,7 +608,7 @@ void SigSession::feed_in_analog(shared_ptr analog) data_received(); } -void SigSession::data_feed_in(shared_ptr device, shared_ptr packet) +void Session::data_feed_in(shared_ptr device, shared_ptr packet) { assert(device); assert(packet);