X-Git-Url: http://sigrok.org/gitweb/?a=blobdiff_plain;f=bindings%2Fcxx%2Fclasses.cpp;h=0d306a97848b444a04751a279a48188ea77cf913;hb=a755b0e122105d934c4e7b97435420eda6df6e8e;hp=af3b484038d882755d835f430a306d9d88732586;hpb=7649683c2a5ee9fd859227fcd4cb875b9f47a2b1;p=libsigrok.git diff --git a/bindings/cxx/classes.cpp b/bindings/cxx/classes.cpp index af3b4840..0d306a97 100644 --- a/bindings/cxx/classes.cpp +++ b/bindings/cxx/classes.cpp @@ -19,6 +19,8 @@ #include "libsigrok/libsigrok.hpp" +#include + namespace sigrok { @@ -328,13 +330,13 @@ void Configurable::config_set(const ConfigKey *key, Glib::VariantBase value) key->get_id(), value.gobj())); } -Glib::VariantBase Configurable::config_list(const ConfigKey *key) +Glib::VariantContainerBase Configurable::config_list(const ConfigKey *key) { GVariant *data; check(sr_config_list( config_driver, config_sdi, config_channel_group, key->get_id(), &data)); - return Glib::VariantBase(data); + return Glib::VariantContainerBase(data); } Device::Device(struct sr_dev_inst *structure) : @@ -344,14 +346,36 @@ Device::Device(struct sr_dev_inst *structure) : for (GSList *entry = structure->channels; entry; entry = entry->next) { auto channel = (struct sr_channel *) entry->data; - channels.push_back(new Channel(channel)); + channels[channel] = new Channel(channel); + } + + for (GSList *entry = structure->channel_groups; entry; entry = entry->next) + { + auto group = (struct sr_channel_group *) entry->data; + channel_groups[group->name] = new ChannelGroup(this, group); } } Device::~Device() { - for (auto channel : channels) - delete channel; + for (auto entry : channels) + delete entry.second; + for (auto entry : channel_groups) + delete entry.second; +} + +string Device::get_description() +{ + ostringstream s; + + vector parts = + {get_vendor(), get_model(), get_version()}; + + for (string part : parts) + if (part.length() > 0) + s << part; + + return s.str(); } string Device::get_vendor() @@ -372,9 +396,29 @@ string Device::get_version() vector> Device::get_channels() { vector> result; - for (auto channel : channels) + for (auto entry : channels) result.push_back(static_pointer_cast( - channel->get_shared_pointer(this))); + entry.second->get_shared_pointer(this))); + return result; +} + +shared_ptr Device::get_channel(struct sr_channel *ptr) +{ + return static_pointer_cast( + channels[ptr]->get_shared_pointer(this)); +} + +map> +Device::get_channel_groups() +{ + map> result; + for (auto entry: channel_groups) + { + auto name = entry.first; + auto channel_group = entry.second; + result[name] = static_pointer_cast( + channel_group->get_shared_pointer(this)); + } return result; } @@ -392,17 +436,10 @@ HardwareDevice::HardwareDevice(Driver *driver, struct sr_dev_inst *structure) : Device(structure), driver(driver) { - for (GSList *entry = structure->channel_groups; entry; entry = entry->next) - { - auto group = (struct sr_channel_group *) entry->data; - channel_groups[group->name] = new ChannelGroup(this, group); - } } HardwareDevice::~HardwareDevice() { - for (auto entry : channel_groups) - delete entry.second; } shared_ptr HardwareDevice::get_driver() @@ -410,20 +447,6 @@ shared_ptr HardwareDevice::get_driver() return static_pointer_cast(driver->get_shared_pointer(parent)); } -map> -HardwareDevice::get_channel_groups() -{ - map> result; - for (auto entry: channel_groups) - { - auto name = entry.first; - auto channel_group = entry.second; - result[name] = static_pointer_cast( - channel_group->get_shared_pointer(this)); - } - return result; -} - Channel::Channel(struct sr_channel *structure) : StructureWrapper(structure), type(ChannelType::get(structure->type)) @@ -459,18 +482,18 @@ void Channel::set_enabled(bool value) check(sr_dev_channel_enable(parent->structure, structure->index, value)); } -ChannelGroup::ChannelGroup(HardwareDevice *device, +unsigned int Channel::get_index() +{ + return structure->index; +} + +ChannelGroup::ChannelGroup(Device *device, struct sr_channel_group *structure) : - StructureWrapper(structure), + StructureWrapper(structure), Configurable(device->structure->driver, device->structure, structure) { for (GSList *entry = structure->channels; entry; entry = entry->next) - { - auto channel = (struct sr_channel *) entry->data; - for (auto device_channel : device->channels) - if (channel == device_channel->structure) - channels.push_back(device_channel); - } + channels.push_back(device->channels[(struct sr_channel *)entry->data]); } ChannelGroup::~ChannelGroup() @@ -599,7 +622,7 @@ void DatafeedCallbackData::run(const struct sr_dev_inst *sdi, const struct sr_datafeed_packet *pkt) { auto device = session->devices[sdi]; - auto packet = shared_ptr(new Packet(pkt), Packet::Deleter()); + auto packet = shared_ptr(new Packet(device, pkt), Packet::Deleter()); callback(device, packet); } @@ -727,7 +750,7 @@ void Session::begin_save(string filename) save_samplerate = 0; } -void Session::append(shared_ptr device, shared_ptr packet) +void Session::append(shared_ptr packet) { if (!saving) throw Error(SR_ERR); @@ -754,8 +777,9 @@ void Session::append(shared_ptr device, shared_ptr packet) { GVariant *samplerate; - check(sr_config_get(device->structure->driver, - device->structure, NULL, SR_CONF_SAMPLERATE, &samplerate)); + check(sr_config_get(packet->device->structure->driver, + packet->device->structure, NULL, SR_CONF_SAMPLERATE, + &samplerate)); save_samplerate = g_variant_get_uint64(samplerate); @@ -766,7 +790,7 @@ void Session::append(shared_ptr device, shared_ptr packet) { vector> save_channels; - for (auto channel : device->get_channels()) + for (auto channel : packet->device->get_channels()) if (channel->structure->enabled && channel->structure->type == SR_CHANNEL_LOGIC) save_channels.push_back(channel); @@ -799,6 +823,12 @@ void Session::append(shared_ptr device, shared_ptr packet) } } +void Session::append(void *data, size_t length, unsigned int unit_size) +{ + check(sr_session_append(structure, save_filename.c_str(), + (uint8_t *) data, unit_size, length)); +} + static void datafeed_callback(const struct sr_dev_inst *sdi, const struct sr_datafeed_packet *pkt, void *cb_data) { @@ -892,11 +922,23 @@ void Session::set_trigger(shared_ptr trigger) this->trigger = trigger; } -Packet::Packet(const struct sr_datafeed_packet *structure) : - structure(structure) +Packet::Packet(shared_ptr device, + const struct sr_datafeed_packet *structure) : + structure(structure), + device(device) { switch (structure->type) { + case SR_DF_HEADER: + payload = new Header( + static_cast( + structure->payload)); + break; + case SR_DF_META: + payload = new Meta( + static_cast( + structure->payload)); + break; case SR_DF_LOGIC: payload = new Logic( static_cast( @@ -907,15 +949,13 @@ Packet::Packet(const struct sr_datafeed_packet *structure) : static_cast( structure->payload)); break; - default: - payload = NULL; - break; } } Packet::~Packet() { - delete payload; + if (payload) + delete payload; } const PacketType *Packet::get_type() @@ -923,9 +963,9 @@ const PacketType *Packet::get_type() return PacketType::get(structure->type); } -PacketPayload *Packet::get_payload() +shared_ptr Packet::get_payload() { - return payload; + return payload->get_shared_pointer(this); } PacketPayload::PacketPayload() @@ -936,28 +976,77 @@ PacketPayload::~PacketPayload() { } -Logic::Logic(const struct sr_datafeed_logic *structure) : PacketPayload(), - structure(structure), - data(static_cast(structure->data), - static_cast(structure->data) + structure->length) {} +Header::Header(const struct sr_datafeed_header *structure) : + PacketPayload(), + StructureWrapper(structure) +{ +} + +Header::~Header() +{ +} + +int Header::get_feed_version() +{ + return structure->feed_version; +} + +Glib::TimeVal Header::get_start_time() +{ + return Glib::TimeVal( + structure->starttime.tv_sec, + structure->starttime.tv_usec); +} + +Meta::Meta(const struct sr_datafeed_meta *structure) : + PacketPayload(), + StructureWrapper(structure) +{ +} + +Meta::~Meta() +{ +} + +map Meta::get_config() +{ + map result; + for (auto l = structure->config; l; l = l->next) + { + auto config = (struct sr_config *) l->data; + result[ConfigKey::get(config->key)] = Glib::VariantBase(config->data); + } + return result; +} + +Logic::Logic(const struct sr_datafeed_logic *structure) : + PacketPayload(), + StructureWrapper(structure) +{ +} Logic::~Logic() { } -void *Logic::get_data() +void *Logic::get_data_pointer() { return structure->data; } -size_t Logic::get_data_size() +size_t Logic::get_data_length() { return structure->length; } +unsigned int Logic::get_unit_size() +{ + return structure->unitsize; +} + Analog::Analog(const struct sr_datafeed_analog *structure) : PacketPayload(), - structure(structure) + StructureWrapper(structure) { } @@ -965,19 +1054,23 @@ Analog::~Analog() { } -void *Analog::get_data() +float *Analog::get_data_pointer() { return structure->data; } -size_t Analog::get_data_size() +unsigned int Analog::get_num_samples() { - return structure->num_samples * sizeof(float); + return structure->num_samples; } -unsigned int Analog::get_num_samples() +vector> Analog::get_channels() { - return structure->num_samples; + vector> result; + for (auto l = structure->channels; l; l = l->next) + result.push_back(parent->device->get_channel( + (struct sr_channel *)l->data)); + return result; } const Quantity *Analog::get_mq()