BLAHAJ
/
libsigrok
10
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

input/chronovu_la8: Fix broken I/O loop.

This commit is contained in:
Bert Vermeulen 2014-09-17 22:04:22 +02:00
parent af945a6625
commit 04c2f202f2
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/input/chronovu_la8.c
View File

@ -92,6 +92,7 @@ static int receive(const struct sr_input *in, GString *buf)
num_channels = g_slist_length(in->sdi->channels); num_channels = g_slist_length(in->sdi->channels);
if (!inc->started) {
std_session_send_df_header(in->sdi, LOG_PREFIX); std_session_send_df_header(in->sdi, LOG_PREFIX);
inc->started = TRUE; inc->started = TRUE;
@ -101,24 +102,23 @@ static int receive(const struct sr_input *in, GString *buf)
meta.config = g_slist_append(NULL, src); meta.config = g_slist_append(NULL, src);
sr_session_send(in->sdi, &packet); sr_session_send(in->sdi, &packet);
sr_config_free(src); sr_config_free(src);
}
packet.type = SR_DF_LOGIC; packet.type = SR_DF_LOGIC;
packet.payload = &logic; packet.payload = &logic;
logic.unitsize = (num_channels + 7) / 8; logic.unitsize = (num_channels + 7) / 8;
logic.data = in->buf->str;
/* Cut off at multiple of unitsize. */ /* Cut off at multiple of unitsize. */
chunk_size = in->buf->len / logic.unitsize * logic.unitsize; chunk_size = in->buf->len / logic.unitsize * logic.unitsize;
chunk = 0; chunk = 0;
for (i = 0; i < chunk_size; i += chunk) { for (i = 0; i < chunk_size; i += chunk) {
chunk = MAX(MAX_CHUNK_SIZE, chunk_size - i); logic.data = in->buf->str + i;
chunk = MIN(MAX_CHUNK_SIZE, chunk_size - i);
logic.length = chunk; logic.length = chunk;
sr_session_send(in->sdi, &packet); sr_session_send(in->sdi, &packet);
} }
g_string_erase(in->buf, 0, chunk_size);
if (in->buf->len > chunk_size)
g_string_erase(in->buf, 0, in->buf->len - chunk_size);
return SR_OK; return SR_OK;
} }