X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;f=input%2Finput_chronovu_la8.c;h=6ce66c0c65cfb63e7cf5e80efa503c4c582b6d49;hb=9a751023136a058dadf008a4ff983351947cc0df;hp=dc6a011777c70176c23da33aa088d52f419722ff;hpb=b08024a8363c7a019bebc05a25e2689e774326e8;p=libsigrok.git diff --git a/input/input_chronovu_la8.c b/input/input_chronovu_la8.c index dc6a0117..6ce66c0c 100644 --- a/input/input_chronovu_la8.c +++ b/input/input_chronovu_la8.c @@ -99,6 +99,7 @@ static int loadfile(struct sr_input *in, const char *filename) { struct sr_datafeed_header header; struct sr_datafeed_packet packet; + struct sr_datafeed_logic logic; uint8_t buf[PACKET_SIZE], divcount; int i, fd, size, num_probes; uint64_t samplerate; @@ -125,14 +126,11 @@ static int loadfile(struct sr_input *in, const char *filename) /* Send header packet to the session bus. */ sr_dbg("la8input: %s: sending SR_DF_HEADER packet", __func__); packet.type = SR_DF_HEADER; - packet.length = sizeof(struct sr_datafeed_header); - packet.unitsize = 0; packet.payload = &header; header.feed_version = 1; gettimeofday(&header.starttime, NULL); header.num_logic_probes = num_probes; header.num_analog_probes = 0; - header.protocol_id = SR_PROTO_RAW; header.samplerate = samplerate; sr_session_bus(in->vdevice, &packet); @@ -141,14 +139,15 @@ static int loadfile(struct sr_input *in, const char *filename) /* Send data packets to the session bus. */ sr_dbg("la8input: %s: sending SR_DF_LOGIC data packets", __func__); packet.type = SR_DF_LOGIC; - packet.unitsize = (num_probes + 7) / 8; - packet.payload = buf; + packet.payload = &logic; + logic.unitsize = (num_probes + 7) / 8; + logic.data = buf; /* Send 8MB of total data to the session bus in small chunks. */ for (i = 0; i < NUM_PACKETS; i++) { /* TODO: Handle errors, handle incomplete reads. */ size = read(fd, buf, PACKET_SIZE); - packet.length = PACKET_SIZE; + logic.length = PACKET_SIZE; sr_session_bus(in->vdevice, &packet); } close(fd); /* FIXME */ @@ -156,8 +155,6 @@ static int loadfile(struct sr_input *in, const char *filename) /* Send end packet to the session bus. */ sr_dbg("la8input: %s: sending SR_DF_END", __func__); packet.type = SR_DF_END; - packet.length = 0; - packet.unitsize = 0; packet.payload = NULL; sr_session_bus(in->vdevice, &packet);