X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;f=src%2Finput%2Fwav.c;h=a1751243f467729c8ee7b2dbc61f3ca753906fc9;hb=87dc5410273abf9307dc25a2528a6aa98a8ae44b;hp=a07fcd100ce51b2d09b22f523c5eae90d1f1acaf;hpb=bee2b0168c087676c1b365861d8c2d4714afa9b9;p=libsigrok.git diff --git a/src/input/wav.c b/src/input/wav.c index a07fcd10..a1751243 100644 --- a/src/input/wav.c +++ b/src/input/wav.c @@ -31,7 +31,7 @@ #define LOG_PREFIX "input/wav" /* How many bytes at a time to process and send to the session bus. */ -#define CHUNK_SIZE 4096 +#define CHUNK_SIZE 4096 /* Minimum size of header + 1 8-bit mono PCM sample. */ #define MIN_DATA_CHUNK_OFFSET 45 @@ -184,7 +184,10 @@ static int find_data_chunk(GString *buf, int initial_offset) static void send_chunk(const struct sr_input *in, int offset, int num_samples) { struct sr_datafeed_packet packet; - struct sr_datafeed_analog_old analog; + struct sr_datafeed_analog analog; + struct sr_analog_encoding encoding; + struct sr_analog_meaning meaning; + struct sr_analog_spec spec; struct context *inc; float fdata[CHUNK_SIZE]; int total_samples, samplenum; @@ -194,7 +197,7 @@ static void send_chunk(const struct sr_input *in, int offset, int num_samples) s = in->buf->str + offset; d = (char *)fdata; - memset(fdata, 0, CHUNK_SIZE); + memset(fdata, 0, CHUNK_SIZE * sizeof(float)); total_samples = num_samples * inc->num_channels; for (samplenum = 0; samplenum < total_samples; samplenum++) { if (inc->fmt_code == WAVE_FORMAT_PCM_) { @@ -223,14 +226,17 @@ static void send_chunk(const struct sr_input *in, int offset, int num_samples) s += inc->unitsize; d += inc->unitsize; } - packet.type = SR_DF_ANALOG_OLD; + + /* TODO: Use proper 'digits' value for this device (and its modes). */ + sr_analog_init(&analog, &encoding, &meaning, &spec, 2); + packet.type = SR_DF_ANALOG; packet.payload = &analog; - analog.channels = in->sdi->channels; analog.num_samples = num_samples; - analog.mq = 0; - analog.mqflags = 0; - analog.unit = 0; analog.data = fdata; + analog.meaning->channels = in->sdi->channels; + analog.meaning->mq = 0; + analog.meaning->mqflags = 0; + analog.meaning->unit = 0; sr_session_send(in->sdi, &packet); } @@ -325,7 +331,7 @@ static int receive(struct sr_input *in, GString *buf) return ret; for (int i = 0; i < inc->num_channels; i++) { - snprintf(channelname, 8, "CH%d", i + 1); + snprintf(channelname, sizeof(channelname), "CH%d", i + 1); sr_channel_new(in->sdi, i, SR_CHANNEL_ANALOG, TRUE, channelname); }