X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fdata%2Fdecode%2Fdecoder.cpp;h=e2db774283496c6d3d1d58dfa068317433050b56;hp=05adf250717549f27c74e1c2225578ea5de3da6c;hb=8dbbc7f0b9ea59d0f0d62225772f8a56eee125f5;hpb=615f6d25e4144ca6db2d60fe52deacef117c2151 diff --git a/pv/data/decode/decoder.cpp b/pv/data/decode/decoder.cpp index 05adf250..e2db7742 100644 --- a/pv/data/decode/decoder.cpp +++ b/pv/data/decode/decoder.cpp @@ -18,68 +18,105 @@ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */ +#include + +#include #include #include "decoder.h" #include -using namespace boost; -using namespace std; +using std::set; +using std::map; +using std::shared_ptr; +using std::string; namespace pv { namespace data { namespace decode { Decoder::Decoder(const srd_decoder *const dec) : - _decoder(dec) + decoder_(dec), + shown_(true) { } Decoder::~Decoder() { - for (map::const_iterator i = _options.begin(); - i != _options.end(); i++) + for (auto i = options_.begin(); i != options_.end(); i++) g_variant_unref((*i).second); } const srd_decoder* Decoder::decoder() const { - return _decoder; + return decoder_; } -const map >& -Decoder::probes() const +bool Decoder::shown() const { - return _probes; + return shown_; } -void Decoder::set_probes(std::map > probes) +void Decoder::show(bool show) { - _probes = probes; + shown_ = show; +} + +const map >& +Decoder::channels() const +{ + return channels_; +} + +void Decoder::set_channels(std::map > channels) +{ + channels_ = channels; } const std::map& Decoder::options() const { - return _options; + return options_; } void Decoder::set_option(const char *id, GVariant *value) { assert(value); g_variant_ref(value); - _options[id] = value; + options_[id] = value; +} + +bool Decoder::have_required_channels() const +{ + for (GSList *l = decoder_->channels; l; l = l->next) { + const srd_channel *const pdch = (const srd_channel*)l->data; + assert(pdch); + if (channels_.find(pdch) == channels_.end()) + return false; + } + + return true; +} + +set< shared_ptr > Decoder::get_data() +{ + set< shared_ptr > data; + for(auto i = channels_.cbegin(); i != channels_.cend(); i++) { + shared_ptr signal((*i).second); + assert(signal); + data.insert(signal->logic_data()); + } + + return data; } -srd_decoder_inst* Decoder::create_decoder_inst( - srd_session *const session) const +srd_decoder_inst* Decoder::create_decoder_inst(srd_session *session, int unit_size) const { GHashTable *const opt_hash = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, (GDestroyNotify)g_variant_unref); - for (map::const_iterator i = _options.begin(); - i != _options.end(); i++) + for (auto i = options_.cbegin(); i != options_.cend(); i++) { GVariant *const value = (*i).second; g_variant_ref(value); @@ -88,28 +125,26 @@ srd_decoder_inst* Decoder::create_decoder_inst( } srd_decoder_inst *const decoder_inst = srd_inst_new( - session, _decoder->id, opt_hash); + session, decoder_->id, opt_hash); g_hash_table_destroy(opt_hash); if(!decoder_inst) return NULL; - // Setup the probes - GHashTable *const probes = g_hash_table_new_full(g_str_hash, + // Setup the channels + GHashTable *const channels = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, (GDestroyNotify)g_variant_unref); - for(map >:: - const_iterator i = _probes.begin(); - i != _probes.end(); i++) + for(auto i = channels_.cbegin(); i != channels_.cend(); i++) { shared_ptr signal((*i).second); GVariant *const gvar = g_variant_new_int32( - signal->probe()->index); + signal->channel()->index()); g_variant_ref_sink(gvar); - g_hash_table_insert(probes, (*i).first->id, gvar); + g_hash_table_insert(channels, (*i).first->id, gvar); } - srd_inst_probe_set_all(decoder_inst, probes); + srd_inst_channel_set_all(decoder_inst, channels, unit_size); return decoder_inst; }