2 * This file is part of the libsigrok project.
4 * Copyright (C) 2020 Gerhard Sittig <gerhard.sittig@gmx.net>
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/>.
20 #include <libsigrok/libsigrok.h>
21 #include "libsigrok-internal.h"
24 struct feed_queue_logic {
25 struct sr_dev_inst *sdi;
30 struct sr_datafeed_packet packet;
31 struct sr_datafeed_logic logic;
34 SR_API struct feed_queue_logic *feed_queue_logic_alloc(struct sr_dev_inst *sdi,
35 size_t sample_count, size_t unit_size)
37 struct feed_queue_logic *q;
39 q = g_malloc0(sizeof(*q));
41 q->unit_size = unit_size;
42 q->alloc_count = sample_count;
43 q->data_bytes = g_try_malloc(q->alloc_count * q->unit_size);
49 memset(&q->packet, 0, sizeof(q->packet));
50 memset(&q->logic, 0, sizeof(q->logic));
51 q->packet.type = SR_DF_LOGIC;
52 q->packet.payload = &q->logic;
53 q->logic.unitsize = q->unit_size;
54 q->logic.data = q->data_bytes;
59 SR_API int feed_queue_logic_submit(struct feed_queue_logic *q,
60 const uint8_t *data, size_t count)
65 wrptr = &q->data_bytes[q->fill_count * q->unit_size];
67 memcpy(wrptr, data, q->unit_size);
68 wrptr += q->unit_size;
70 if (q->fill_count == q->alloc_count) {
71 ret = feed_queue_logic_flush(q);
74 wrptr = &q->data_bytes[0];
81 SR_API int feed_queue_logic_flush(struct feed_queue_logic *q)
88 q->logic.length = q->fill_count * q->unit_size;
89 ret = sr_session_send(q->sdi, &q->packet);
97 SR_API void feed_queue_logic_free(struct feed_queue_logic *q)
103 g_free(q->data_bytes);
107 struct feed_queue_analog {
108 struct sr_dev_inst *sdi;
113 struct sr_datafeed_packet packet;
114 struct sr_datafeed_analog analog;
115 struct sr_analog_encoding encoding;
116 struct sr_analog_meaning meaning;
117 struct sr_analog_spec spec;
121 SR_API struct feed_queue_analog *feed_queue_analog_alloc(struct sr_dev_inst *sdi,
122 size_t sample_count, int digits, struct sr_channel *ch)
124 struct feed_queue_analog *q;
126 q = g_malloc0(sizeof(*q));
128 q->alloc_count = sample_count;
129 q->data_values = g_try_malloc(q->alloc_count * sizeof(float));
130 if (!q->data_values) {
135 q->channels = g_slist_append(NULL, ch);
137 memset(&q->packet, 0, sizeof(q->packet));
138 sr_analog_init(&q->analog, &q->encoding, &q->meaning, &q->spec, digits);
139 q->packet.type = SR_DF_ANALOG;
140 q->packet.payload = &q->analog;
141 q->encoding.is_signed = TRUE;
142 q->meaning.channels = q->channels;
143 q->analog.data = q->data_values;
148 SR_API int feed_queue_analog_submit(struct feed_queue_analog *q,
149 float data, size_t count)
154 q->data_values[q->fill_count++] = data;
155 if (q->fill_count == q->alloc_count) {
156 ret = feed_queue_analog_flush(q);
165 SR_API int feed_queue_analog_flush(struct feed_queue_analog *q)
172 q->analog.num_samples = q->fill_count;
173 ret = sr_session_send(q->sdi, &q->packet);
181 SR_API void feed_queue_analog_free(struct feed_queue_analog *q)
187 g_free(q->data_values);
188 g_slist_free(q->channels);