2 * This file is part of the libsigrokflow project.
4 * Copyright (C) 2018 Martin Ling <martin-sigrok@earth.li>
5 * Copyright (C) 2018 Uwe Hermann <uwe@hermann-uwe.de>
7 * This program is free software: you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation, either version 3 of the License, or
10 * (at your option) any later version.
12 * This program is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 * GNU General Public License for more details.
17 * You should have received a copy of the GNU General Public License
18 * along with this program. If not, see <http://www.gnu.org/licenses/>.
23 #include <libsigrokflow/libsigrokflow.hpp>
29 using namespace std::placeholders;
31 Sink::Sink(GstBaseSink *gobj) :
36 Device::Device(GstElement *gobj) :
41 CaptureDevice::CaptureDevice(GstElement *gobj) :
46 #ifdef HAVE_LIBSIGROKCXX
47 void LegacyOutput::class_init(Gst::ElementClass<LegacyOutput> *klass)
49 klass->set_metadata("sigrok legacy output",
50 "Sink", "Wrapper for outputs using legacy libsigrok APIs",
53 klass->add_pad_template(Gst::PadTemplate::create(
57 Gst::Caps::create_any()));
60 bool LegacyOutput::register_element(Glib::RefPtr<Gst::Plugin> plugin)
62 Gst::ElementFactory::register_element(plugin, "sigrok_legacy_output",
63 0, Gst::register_mm_type<LegacyOutput>(
64 "sigrok_legacy_output"));
69 LegacyOutput::LegacyOutput(GstBaseSink *gobj) :
70 Glib::ObjectBase(typeid(LegacyOutput)),
75 Glib::RefPtr<LegacyOutput>LegacyOutput::create(
76 shared_ptr<sigrok::OutputFormat> libsigrok_output_format,
77 shared_ptr<sigrok::Device> libsigrok_device,
78 map<string, Glib::VariantBase> options)
80 auto element = Gst::ElementFactory::create_element("sigrok_legacy_output");
82 throw runtime_error("Failed to create element - plugin not registered?");
83 auto output = Glib::RefPtr<LegacyOutput>::cast_static(element);
84 output->libsigrok_output_format_ = libsigrok_output_format;
85 output->libsigrok_device_ = libsigrok_device;
86 output->options_ = options;
91 bool LegacyOutput::start_vfunc()
93 libsigrok_output_ = libsigrok_output_format_->create_output(
94 libsigrok_device_, options_);
99 Gst::FlowReturn LegacyOutput::render_vfunc(const Glib::RefPtr<Gst::Buffer> &buffer)
102 buffer->map(info, Gst::MAP_READ);
103 auto context = libsigrok_output_format_->parent();
104 auto packet = context->create_logic_packet(
105 info.get_data(), info.get_size(), 2);
106 auto result = libsigrok_output_->receive(packet);
113 bool LegacyOutput::stop_vfunc()
115 auto context = libsigrok_output_format_->parent();
116 auto end_packet = context->create_end_packet();
117 auto result = libsigrok_output_->receive(end_packet);
124 #ifdef HAVE_LIBSIGROKDECODE
125 void LegacyDecoder::class_init(Gst::ElementClass<LegacyDecoder> *klass)
127 klass->set_metadata("sigrok legacy decoder",
128 "Sink", "Wrapper for protocol decoders using legacy libsigrokdecode APIs",
131 klass->add_pad_template(Gst::PadTemplate::create(
135 Gst::Caps::create_any()));
138 bool LegacyDecoder::register_element(Glib::RefPtr<Gst::Plugin> plugin)
140 Gst::ElementFactory::register_element(plugin, "sigrok_legacy_decoder",
141 0, Gst::register_mm_type<LegacyDecoder>(
142 "sigrok_legacy_decoder"));
147 LegacyDecoder::LegacyDecoder(GstBaseSink *gobj) :
148 Glib::ObjectBase(typeid(LegacyDecoder)),
153 Glib::RefPtr<LegacyDecoder>LegacyDecoder::create(
154 struct srd_session *libsigrokdecode_session, uint64_t unitsize)
156 auto element = Gst::ElementFactory::create_element("sigrok_legacy_decoder");
158 throw runtime_error("Failed to create element - plugin not registered?");
159 auto decoder = Glib::RefPtr<LegacyDecoder>::cast_static(element);
160 decoder->session_ = libsigrokdecode_session;
161 decoder->unitsite_ = unitsize;
166 struct srd_session *LegacyDecoder::libsigrokdecode_session()
171 Gst::FlowReturn LegacyDecoder::render_vfunc(const Glib::RefPtr<Gst::Buffer> &buffer)
174 buffer->map(info, Gst::MAP_READ);
175 uint64_t num_samples = info.get_size() / unitsite_;
176 srd_session_send(session_, abs_ss_, abs_ss_ + num_samples,
177 info.get_data(), info.get_size(), unitsite_);
178 abs_ss_ += num_samples;
184 bool LegacyDecoder::start_vfunc()
187 srd_session_start(session_);
192 bool LegacyDecoder::stop_vfunc()
194 srd_session_terminate_reset(session_);