2 * This file is part of the libsigrokflow project.
4 * Copyright (C) 2018 Uwe Hermann <uwe@hermann-uwe.de>
6 * This program is free software: you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation, either version 3 of the License, or
9 * (at your option) any later version.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
16 * You should have received a copy of the GNU General Public License
17 * along with this program. If not, see <http://www.gnu.org/licenses/>.
21 #include <libsigrokflow/libsigrokflow.hpp>
29 using namespace std::placeholders;
35 auto src_template = Gst::PadTemplate::create("src",
38 Gst::Caps::create_any());
40 LegacyCaptureDevice::LegacyCaptureDevice(shared_ptr<sigrok::HardwareDevice> device) :
41 _device(device), _src_pad(Gst::Pad::create(src_template))
46 shared_ptr<sigrok::HardwareDevice> LegacyCaptureDevice::libsigrok_device()
51 Gst::StateChangeReturn LegacyCaptureDevice::change_state_vfunc(Gst::StateChange transition)
55 case Gst::STATE_CHANGE_READY_TO_PAUSED:
56 return Gst::StateChangeReturn::STATE_CHANGE_NO_PREROLL;
57 case Gst::STATE_CHANGE_PAUSED_TO_PLAYING:
59 _device->config_set(sigrok::ConfigKey::LIMIT_SAMPLES,
60 Glib::Variant<int>::create(10));
61 _task = Gst::Task::create(std::bind(&LegacyCaptureDevice::_run, this));
62 _task->set_lock(_mutex);
63 _src_pad->set_active(true);
65 return Gst::STATE_CHANGE_SUCCESS;
67 return Gst::STATE_CHANGE_SUCCESS;
71 void LegacyCaptureDevice::_datafeed_callback(
72 shared_ptr<sigrok::Device> device,
73 shared_ptr<sigrok::Packet> packet)
76 switch (packet->type()->id()) {
79 auto logic = static_pointer_cast<sigrok::Logic>(packet->payload());
80 auto mem = Gst::Memory::create(
81 Gst::MEMORY_FLAG_READONLY,
82 logic->data_pointer(),
85 logic->data_length());
86 auto buf = Gst::Buffer::create();
87 buf->append_memory(move(mem));
88 _src_pad->push(move(buf));
93 _src_pad->push_event(Gst::EventEos::create());
100 void LegacyCaptureDevice::_run()
102 _session = _device->driver()->parent()->create_session();
103 _session->add_device(_device);
104 _session->add_datafeed_callback(bind(&LegacyCaptureDevice::_datafeed_callback, this, _1, _2));