X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;f=src%2Finput%2Fchronovu_la8.c;h=0afd8ea286cbb7b87dd10ecf077b725c57d995ed;hb=3be42bc22f8b36599a448273c12a76d3e0f7a940;hp=1d7e16adf10b96395db3d2dee0264e5918e773c0;hpb=7066fd466038bb4a8d09751f8a53c2452c5fefc1;p=libsigrok.git diff --git a/src/input/chronovu_la8.c b/src/input/chronovu_la8.c index 1d7e16ad..0afd8ea2 100644 --- a/src/input/chronovu_la8.c +++ b/src/input/chronovu_la8.c @@ -18,19 +18,20 @@ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */ +#include #include #include #include #include -#include "libsigrok.h" +#include #include "libsigrok-internal.h" #define LOG_PREFIX "input/chronovu-la8" #define DEFAULT_NUM_CHANNELS 8 -#define DEFAULT_SAMPLERATE 100000000L -#define MAX_CHUNK_SIZE 4096 -#define CHRONOVU_LA8_FILESIZE 8 * 1024 * 1024 + 5 +#define DEFAULT_SAMPLERATE SR_MHZ(100) +#define MAX_CHUNK_SIZE (4 * 1024) +#define CHRONOVU_LA8_FILESIZE ((8 * 1024 * 1024) + 5) struct context { gboolean started; @@ -51,7 +52,6 @@ static int format_match(GHashTable *metadata) static int init(struct sr_input *in, GHashTable *options) { - struct sr_channel *ch; struct context *inc; int num_channels, i; char name[16]; @@ -62,15 +62,14 @@ static int init(struct sr_input *in, GHashTable *options) return SR_ERR_ARG; } - in->sdi = sr_dev_inst_new(SR_ST_ACTIVE, NULL, NULL, NULL); + in->sdi = g_malloc0(sizeof(struct sr_dev_inst)); in->priv = inc = g_malloc0(sizeof(struct context)); inc->samplerate = g_variant_get_uint64(g_hash_table_lookup(options, "samplerate")); for (i = 0; i < num_channels; i++) { snprintf(name, 16, "%d", i); - ch = sr_channel_new(i, SR_CHANNEL_LOGIC, TRUE, name); - in->sdi->channels = g_slist_append(in->sdi->channels, ch); + sr_channel_new(in->sdi, i, SR_CHANNEL_LOGIC, TRUE, name); } return SR_OK; @@ -96,6 +95,7 @@ static int process_buffer(struct sr_input *in) src = sr_config_new(SR_CONF_SAMPLERATE, g_variant_new_uint64(inc->samplerate)); meta.config = g_slist_append(NULL, src); sr_session_send(in->sdi, &packet); + g_slist_free(meta.config); sr_config_free(src); } @@ -109,7 +109,6 @@ static int process_buffer(struct sr_input *in) /* Cut off at multiple of unitsize. */ chunk_size = in->buf->len / logic.unitsize * logic.unitsize; - chunk = 0; for (i = 0; i < chunk_size; i += chunk) { logic.data = in->buf->str + i; chunk = MIN(MAX_CHUNK_SIZE, chunk_size - i); @@ -141,7 +140,6 @@ static int receive(struct sr_input *in, GString *buf) static int end(struct sr_input *in) { struct context *inc; - struct sr_datafeed_packet packet; int ret; if (in->sdi_ready) @@ -150,10 +148,8 @@ static int end(struct sr_input *in) ret = SR_OK; inc = in->priv; - if (inc->started) { - packet.type = SR_DF_END; - sr_session_send(in->sdi, &packet); - } + if (inc->started) + std_session_send_df_end(in->sdi, LOG_PREFIX); return ret; } @@ -164,7 +160,7 @@ static struct sr_option options[] = { ALL_ZERO }; -static struct sr_option *get_options(void) +static const struct sr_option *get_options(void) { if (!options[0].def) { options[0].def = g_variant_ref_sink(g_variant_new_int32(DEFAULT_NUM_CHANNELS)); @@ -178,6 +174,7 @@ SR_PRIV struct sr_input_module input_chronovu_la8 = { .id = "chronovu-la8", .name = "Chronovu-LA8", .desc = "ChronoVu LA8", + .exts = (const char*[]){"kdt", NULL}, .metadata = { SR_INPUT_META_FILESIZE | SR_INPUT_META_REQUIRED }, .options = get_options, .format_match = format_match,