X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;f=src%2Foutput%2Fbits.c;h=0a9ccc1a41d6f241fa003f9ea6ed5d07b198ac0a;hb=54ab1dcdc4d372765401bc2513f2692f488f4e1d;hp=b44f1057d82c645676ec16a4c31094b3221060ea;hpb=155b680da482cea2381becb73c51cfb838bff31e;p=libsigrok.git diff --git a/src/output/bits.c b/src/output/bits.c index b44f1057..0a9ccc1a 100644 --- a/src/output/bits.c +++ b/src/output/bits.c @@ -29,7 +29,7 @@ struct context { unsigned int num_enabled_channels; - int samples_per_line; + int spl; int spl_cnt; int trigger; uint64_t samplerate; @@ -39,37 +39,20 @@ struct context { GString **lines; }; -static int init(struct sr_output *o) +static int init(struct sr_output *o, GHashTable *options) { struct context *ctx; struct sr_channel *ch; GSList *l; - GHashTableIter iter; - gpointer key, value; unsigned int i, j; - int spl; if (!o || !o->sdi) return SR_ERR_ARG; - spl = DEFAULT_SAMPLES_PER_LINE; - g_hash_table_iter_init(&iter, o->params); - while (g_hash_table_iter_next(&iter, &key, &value)) { - if (!strcmp(key, "width")) { - if ((spl = strtoul(value, NULL, 10)) < 1) { - sr_err("Invalid width."); - return SR_ERR_ARG; - } - } else { - sr_err("Unknown parameter '%s'.", key); - return SR_ERR_ARG; - } - } - ctx = g_malloc0(sizeof(struct context)); - o->internal = ctx; + o->priv = ctx; ctx->trigger = -1; - ctx->samples_per_line = spl; + ctx->spl = g_variant_get_uint32(g_hash_table_lookup(options, "width")); for (l = o->sdi->channels; l; l = l->next) { ch = l->data; @@ -100,7 +83,7 @@ static int init(struct sr_output *o) return SR_OK; } -static GString *gen_header(struct sr_output *o) +static GString *gen_header(const struct sr_output *o) { struct context *ctx; GVariant *gvar; @@ -108,7 +91,7 @@ static GString *gen_header(struct sr_output *o) int num_channels; char *samplerate_s; - ctx = o->internal; + ctx = o->priv; if (ctx->samplerate == 0) { if (sr_config_get(o->sdi->driver, o->sdi, NULL, SR_CONF_SAMPLERATE, &gvar) == SR_OK) { @@ -132,7 +115,7 @@ static GString *gen_header(struct sr_output *o) return header; } -static int receive(struct sr_output *o, const struct sr_datafeed_packet *packet, +static int receive(const struct sr_output *o, const struct sr_datafeed_packet *packet, GString **out) { const struct sr_datafeed_meta *meta; @@ -147,7 +130,7 @@ static int receive(struct sr_output *o, const struct sr_datafeed_packet *packet, *out = NULL; if (!o || !o->sdi) return SR_ERR_ARG; - if (!(ctx = o->internal)) + if (!(ctx = o->priv)) return SR_ERR_ARG; switch (packet->type) { @@ -179,7 +162,7 @@ static int receive(struct sr_output *o, const struct sr_datafeed_packet *packet, c = (*p & (1 << (idx % 8))) ? '1' : '0'; g_string_append_c(ctx->lines[j], c); - if (ctx->spl_cnt == ctx->samples_per_line) { + if (ctx->spl_cnt == ctx->spl) { /* Flush line buffers. */ g_string_append_len(*out, ctx->lines[j]->str, ctx->lines[j]->len); g_string_append_c(*out, '\n'); @@ -194,7 +177,7 @@ static int receive(struct sr_output *o, const struct sr_datafeed_packet *packet, g_string_append_c(ctx->lines[j], ' '); } } - if (ctx->spl_cnt == ctx->samples_per_line) + if (ctx->spl_cnt == ctx->spl) /* Line buffers were already flushed. */ ctx->spl_cnt = 0; } @@ -222,7 +205,7 @@ static int cleanup(struct sr_output *o) if (!o) return SR_ERR_ARG; - if (!(ctx = o->internal)) + if (!(ctx = o->priv)) return SR_OK; g_free(ctx->channel_index); @@ -231,14 +214,31 @@ static int cleanup(struct sr_output *o) g_string_free(ctx->lines[i], TRUE); g_free(ctx->lines); g_free(ctx); - o->internal = NULL; + o->priv = NULL; return SR_OK; } -SR_PRIV struct sr_output_format output_bits = { +static struct sr_option options[] = { + { "width", "Width", "Number of samples per line", NULL, NULL }, + ALL_ZERO +}; + +static const struct sr_option *get_options(void) +{ + if (!options[0].def) { + options[0].def = g_variant_new_uint32(DEFAULT_SAMPLES_PER_LINE); + g_variant_ref_sink(options[0].def); + } + + return options; +} + +SR_PRIV struct sr_output_module output_bits = { .id = "bits", - .description = "Bits", + .name = "Bits", + .desc = "0/1 digits", + .options = get_options, .init = init, .receive = receive, .cleanup = cleanup,