X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;f=src%2Finput%2Fbinary.c;h=013621373c71dd4eed995c19980fed76c1b13cbc;hb=a299a95413594201b4bb58d7d345e1933ebca5ae;hp=f58af58d16ac1d35e649a1db7761a0cf3fe495ec;hpb=c01378c95f34e60d3b67f84dc3a6c3c6c154186d;p=libsigrok.git diff --git a/src/input/binary.c b/src/input/binary.c index f58af58d..01362137 100644 --- a/src/input/binary.c +++ b/src/input/binary.c @@ -29,9 +29,9 @@ #define LOG_PREFIX "input/binary" -#define MAX_CHUNK_SIZE 4096 -#define DEFAULT_NUM_CHANNELS 8 -#define DEFAULT_SAMPLERATE 0 +#define MAX_CHUNK_SIZE 4096 +#define DEFAULT_NUM_CHANNELS 8 +#define DEFAULT_SAMPLERATE 0 struct context { gboolean started; @@ -56,7 +56,7 @@ static int init(struct sr_input *in, GHashTable *options) inc->samplerate = g_variant_get_uint64(g_hash_table_lookup(options, "samplerate")); for (i = 0; i < num_channels; i++) { - snprintf(name, 16, "%d", i); + snprintf(name, sizeof(name), "%d", i); sr_channel_new(in->sdi, i, SR_CHANNEL_LOGIC, TRUE, name); } @@ -75,7 +75,7 @@ static int process_buffer(struct sr_input *in) inc = in->priv; if (!inc->started) { - std_session_send_df_header(in->sdi, LOG_PREFIX); + std_session_send_df_header(in->sdi); if (inc->samplerate) { packet.type = SR_DF_META; @@ -128,7 +128,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) @@ -137,14 +136,22 @@ 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); return ret; } +static int reset(struct sr_input *in) +{ + struct context *inc = in->priv; + + inc->started = FALSE; + g_string_truncate(in->buf, 0); + + return SR_OK; +} + static struct sr_option options[] = { { "numchannels", "Number of channels", "Number of channels", NULL, NULL }, { "samplerate", "Sample rate", "Sample rate", NULL, NULL }, @@ -170,4 +177,5 @@ SR_PRIV struct sr_input_module input_binary = { .init = init, .receive = receive, .end = end, + .reset = reset, };