X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=src%2Fhardware%2Fbrymen-dmm%2Fprotocol.c;h=1667bef688cbbe9fc6c6d0a5a6188a53b5d7d7cf;hb=1e726f568d6d72a8c6afdcd8fa98b98e910ad523;hp=881881cf026a1366b2993157e464c52c2e550265;hpb=44be13b1f8dfa67345585af8018b60c17c01025d;p=libsigrok.git diff --git a/src/hardware/brymen-dmm/protocol.c b/src/hardware/brymen-dmm/protocol.c index 881881cf..1667bef6 100644 --- a/src/hardware/brymen-dmm/protocol.c +++ b/src/hardware/brymen-dmm/protocol.c @@ -17,6 +17,7 @@ * along with this program. If not, see . */ +#include #include "protocol.h" static void handle_packet(const uint8_t *buf, struct sr_dev_inst *sdi) @@ -24,7 +25,7 @@ static void handle_packet(const uint8_t *buf, struct sr_dev_inst *sdi) float floatval; struct dev_context *devc; struct sr_datafeed_packet packet; - struct sr_datafeed_analog analog; + struct sr_datafeed_analog_old analog; devc = sdi->priv; @@ -39,9 +40,9 @@ static void handle_packet(const uint8_t *buf, struct sr_dev_inst *sdi) if (analog.mq != -1) { /* Got a measurement. */ - packet.type = SR_DF_ANALOG; + packet.type = SR_DF_ANALOG_OLD; packet.payload = &analog; - sr_session_send(devc->cb_data, &packet); + sr_session_send(sdi, &packet); devc->num_samples++; } } @@ -138,7 +139,7 @@ SR_PRIV int brymen_dmm_receive_data(int fd, int revents, void *cb_data) if (devc->limit_samples && devc->num_samples >= devc->limit_samples) { sr_info("Requested number of samples reached, stopping."); - sdi->driver->dev_acquisition_stop(sdi, cb_data); + sdi->driver->dev_acquisition_stop(sdi); return TRUE; } @@ -146,7 +147,7 @@ SR_PRIV int brymen_dmm_receive_data(int fd, int revents, void *cb_data) time = (g_get_monotonic_time() - devc->starttime) / 1000; if (time > (int64_t)devc->limit_msec) { sr_info("Requested time limit reached, stopping."); - sdi->driver->dev_acquisition_stop(sdi, cb_data); + sdi->driver->dev_acquisition_stop(sdi); return TRUE; } } @@ -179,7 +180,9 @@ SR_PRIV int brymen_stream_detect(struct sr_serial_dev_inst *serial, { int64_t start, time, byte_delay_us; size_t ibuf, i, maxlen; - int status, len, packet_len, stream_len; + ssize_t len, stream_len; + int packet_len; + int status; maxlen = *buflen; @@ -187,7 +190,7 @@ SR_PRIV int brymen_stream_detect(struct sr_serial_dev_inst *serial, "ms, baudrate = %d).", serial->port, timeout_ms, baudrate); /* Assume 8n1 transmission. That is 10 bits for every byte. */ - byte_delay_us = 10 * (1000000 / baudrate); + byte_delay_us = 10 * ((1000 * 1000) / baudrate); start = g_get_monotonic_time(); packet_len = i = ibuf = len = 0; @@ -195,7 +198,7 @@ SR_PRIV int brymen_stream_detect(struct sr_serial_dev_inst *serial, len = serial_read_nonblocking(serial, &buf[ibuf], maxlen - ibuf); if (len > 0) { ibuf += len; - sr_spew("Read %d bytes.", len); + sr_spew("Read %zd bytes.", len); } time = g_get_monotonic_time() - start; @@ -206,7 +209,7 @@ SR_PRIV int brymen_stream_detect(struct sr_serial_dev_inst *serial, /* How large of a packet are we expecting? */ packet_len = stream_len; status = get_packet_size(&buf[i], &packet_len); - switch(status) { + switch (status) { case PACKET_HEADER_OK: /* We know how much data we need to wait for. */ break; @@ -247,14 +250,14 @@ SR_PRIV int brymen_stream_detect(struct sr_serial_dev_inst *serial, if (time >= (int64_t)timeout_ms) { /* Timeout */ - sr_dbg("Detection timed out after %dms.", time); + sr_dbg("Detection timed out after %" PRIi64 "ms.", time); break; } g_usleep(byte_delay_us); } *buflen = ibuf; - sr_err("Didn't find a valid packet (read %d bytes).", ibuf); + sr_err("Didn't find a valid packet (read %zu bytes).", ibuf); return SR_ERR; }