From: Uwe Hermann Date: Sun, 18 Sep 2016 16:50:11 +0000 (+0200) Subject: agilent-dmm: File naming consistency changes. X-Git-Tag: libsigrok-0.5.0~215 X-Git-Url: http://sigrok.org/gitweb/?p=libsigrok.git;a=commitdiff_plain;h=6cf1a87bfb803e088234e2e313891d27379880cf agilent-dmm: File naming consistency changes. --- diff --git a/Makefile.am b/Makefile.am index cd8a49d3..db51c43a 100644 --- a/Makefile.am +++ b/Makefile.am @@ -179,9 +179,9 @@ src_libdrivers_la_SOURCES = src/drivers.c if HW_AGILENT_DMM src_libdrivers_la_SOURCES += \ - src/hardware/agilent-dmm/api.c \ - src/hardware/agilent-dmm/agilent-dmm.h \ - src/hardware/agilent-dmm/sched.c + src/hardware/agilent-dmm/protocol.h \ + src/hardware/agilent-dmm/protocol.c \ + src/hardware/agilent-dmm/api.c endif if HW_APPA_55II src_libdrivers_la_SOURCES += \ diff --git a/src/hardware/agilent-dmm/agilent-dmm.h b/src/hardware/agilent-dmm/agilent-dmm.h deleted file mode 100644 index e89c7c14..00000000 --- a/src/hardware/agilent-dmm/agilent-dmm.h +++ /dev/null @@ -1,88 +0,0 @@ -/* - * This file is part of the libsigrok project. - * - * Copyright (C) 2012 Bert Vermeulen - * - * This program is free software: you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation, either version 3 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program. If not, see . - */ - -#ifndef LIBSIGROK_HARDWARE_AGILENT_DMM_AGILENT_DMM_H -#define LIBSIGROK_HARDWARE_AGILENT_DMM_AGILENT_DMM_H - -#define LOG_PREFIX "agilent-dmm" - -#define AGDMM_BUFSIZE 256 - -/* Always USB-serial, 1ms is plenty. */ -#define SERIAL_WRITE_TIMEOUT_MS 1 - -/* Supported models */ -enum { - AGILENT_U1231 = 1, - AGILENT_U1232, - AGILENT_U1233, - - AGILENT_U1241, - AGILENT_U1242, - - AGILENT_U1251, - AGILENT_U1252, - AGILENT_U1253, - - KEYSIGHT_U1281, - KEYSIGHT_U1282, -}; - -/* Supported device profiles */ -struct agdmm_profile { - int model; - const char *modelname; - const struct agdmm_job *jobs; - const struct agdmm_recv *recvs; -}; - -/* Private, per-device-instance driver context. */ -struct dev_context { - const struct agdmm_profile *profile; - struct sr_sw_limits limits; - - /* Runtime. */ - int64_t jobqueue[8]; - unsigned char buf[AGDMM_BUFSIZE]; - int buflen; - int cur_mq; - int cur_unit; - int cur_mqflags; - int cur_digits; - int cur_encoding; - int cur_exponent; - int cur_acdc; - int mode_tempaux; - int mode_continuity; - int mode_squarewave; -}; - -struct agdmm_job { - int interval; - int (*send) (const struct sr_dev_inst *sdi); -}; - -struct agdmm_recv { - const char *recv_regex; - int (*recv) (const struct sr_dev_inst *sdi, GMatchInfo *match); -}; - -SR_PRIV int agdmm_receive_data(int fd, int revents, void *cb_data); - -#endif diff --git a/src/hardware/agilent-dmm/api.c b/src/hardware/agilent-dmm/api.c index 0f18baf0..872b6611 100644 --- a/src/hardware/agilent-dmm/api.c +++ b/src/hardware/agilent-dmm/api.c @@ -25,7 +25,7 @@ #include #include #include "libsigrok-internal.h" -#include "agilent-dmm.h" +#include "protocol.h" static const uint32_t scanopts[] = { SR_CONF_CONN, diff --git a/src/hardware/agilent-dmm/protocol.c b/src/hardware/agilent-dmm/protocol.c new file mode 100644 index 00000000..834cc148 --- /dev/null +++ b/src/hardware/agilent-dmm/protocol.c @@ -0,0 +1,664 @@ +/* + * This file is part of the libsigrok project. + * + * Copyright (C) 2012 Bert Vermeulen + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see . + */ + +#include +#include +#include +#include +#include +#include +#include "libsigrok-internal.h" +#include "protocol.h" + +static void dispatch(const struct sr_dev_inst *sdi) +{ + struct dev_context *devc; + const struct agdmm_job *jobs; + int64_t now; + int i; + + devc = sdi->priv; + jobs = devc->profile->jobs; + now = g_get_monotonic_time() / 1000; + for (i = 0; (&jobs[i])->interval; i++) { + if (now - devc->jobqueue[i] > (&jobs[i])->interval) { + sr_spew("Running job %d.", i); + (&jobs[i])->send(sdi); + devc->jobqueue[i] = now; + } + } +} + +static void receive_line(const struct sr_dev_inst *sdi) +{ + struct dev_context *devc; + const struct agdmm_recv *recvs, *recv; + GRegex *reg; + GMatchInfo *match; + int i; + + devc = sdi->priv; + + /* Strip CRLF */ + while (devc->buflen) { + if (*(devc->buf + devc->buflen - 1) == '\r' + || *(devc->buf + devc->buflen - 1) == '\n') + *(devc->buf + --devc->buflen) = '\0'; + else + break; + } + sr_spew("Received '%s'.", devc->buf); + + recv = NULL; + recvs = devc->profile->recvs; + for (i = 0; (&recvs[i])->recv_regex; i++) { + reg = g_regex_new((&recvs[i])->recv_regex, 0, 0, NULL); + if (g_regex_match(reg, (char *)devc->buf, 0, &match)) { + recv = &recvs[i]; + break; + } + g_match_info_unref(match); + g_regex_unref(reg); + } + if (recv) { + recv->recv(sdi, match); + g_match_info_unref(match); + g_regex_unref(reg); + } else + sr_dbg("Unknown line '%s'.", devc->buf); + + /* Done with this. */ + devc->buflen = 0; +} + +SR_PRIV int agdmm_receive_data(int fd, int revents, void *cb_data) +{ + struct sr_dev_inst *sdi; + struct dev_context *devc; + struct sr_serial_dev_inst *serial; + int len; + + (void)fd; + + if (!(sdi = cb_data)) + return TRUE; + + if (!(devc = sdi->priv)) + return TRUE; + + serial = sdi->conn; + if (revents == G_IO_IN) { + /* Serial data arrived. */ + while (AGDMM_BUFSIZE - devc->buflen - 1 > 0) { + len = serial_read_nonblocking(serial, devc->buf + devc->buflen, 1); + if (len < 1) + break; + devc->buflen += len; + *(devc->buf + devc->buflen) = '\0'; + if (*(devc->buf + devc->buflen - 1) == '\n') { + /* End of line */ + receive_line(sdi); + break; + } + } + } + + dispatch(sdi); + + if (sr_sw_limits_check(&devc->limits)) + sdi->driver->dev_acquisition_stop(sdi); + + return TRUE; +} + +static int agdmm_send(const struct sr_dev_inst *sdi, const char *cmd) +{ + struct sr_serial_dev_inst *serial; + char buf[32]; + + serial = sdi->conn; + + sr_spew("Sending '%s'.", cmd); + strncpy(buf, cmd, 28); + if (!strncmp(buf, "*IDN?", 5)) + strcat(buf, "\r\n"); + else + strcat(buf, "\n\r\n"); + if (serial_write_blocking(serial, buf, strlen(buf), SERIAL_WRITE_TIMEOUT_MS) < (int)strlen(buf)) { + sr_err("Failed to send."); + return SR_ERR; + } + + return SR_OK; +} + +static int send_stat(const struct sr_dev_inst *sdi) +{ + return agdmm_send(sdi, "STAT?"); +} + +static int recv_stat_u123x(const struct sr_dev_inst *sdi, GMatchInfo *match) +{ + struct dev_context *devc; + char *s; + + devc = sdi->priv; + s = g_match_info_fetch(match, 1); + sr_spew("STAT response '%s'.", s); + + /* Max, Min or Avg mode -- no way to tell which, so we'll + * set both flags to denote it's not a normal measurement. */ + if (s[0] == '1') + devc->cur_mqflags |= SR_MQFLAG_MAX | SR_MQFLAG_MIN; + else + devc->cur_mqflags &= ~(SR_MQFLAG_MAX | SR_MQFLAG_MIN); + + if (s[1] == '1') + devc->cur_mqflags |= SR_MQFLAG_RELATIVE; + else + devc->cur_mqflags &= ~SR_MQFLAG_RELATIVE; + + /* Triggered or auto hold modes. */ + if (s[2] == '1' || s[3] == '1') + devc->cur_mqflags |= SR_MQFLAG_HOLD; + else + devc->cur_mqflags &= ~SR_MQFLAG_HOLD; + + /* Temp/aux mode. */ + if (s[7] == '1') + devc->mode_tempaux = TRUE; + else + devc->mode_tempaux = FALSE; + + /* Continuity mode. */ + if (s[16] == '1') + devc->mode_continuity = TRUE; + else + devc->mode_continuity = FALSE; + + g_free(s); + + return SR_OK; +} + +static int recv_stat_u124x(const struct sr_dev_inst *sdi, GMatchInfo *match) +{ + struct dev_context *devc; + char *s; + + devc = sdi->priv; + s = g_match_info_fetch(match, 1); + sr_spew("STAT response '%s'.", s); + + /* Max, Min or Avg mode -- no way to tell which, so we'll + * set both flags to denote it's not a normal measurement. */ + if (s[0] == '1') + devc->cur_mqflags |= SR_MQFLAG_MAX | SR_MQFLAG_MIN; + else + devc->cur_mqflags &= ~(SR_MQFLAG_MAX | SR_MQFLAG_MIN); + + if (s[1] == '1') + devc->cur_mqflags |= SR_MQFLAG_RELATIVE; + else + devc->cur_mqflags &= ~SR_MQFLAG_RELATIVE; + + /* Hold mode. */ + if (s[7] == '1') + devc->cur_mqflags |= SR_MQFLAG_HOLD; + else + devc->cur_mqflags &= ~SR_MQFLAG_HOLD; + + g_free(s); + + return SR_OK; +} + +static int recv_stat_u125x(const struct sr_dev_inst *sdi, GMatchInfo *match) +{ + struct dev_context *devc; + char *s; + + devc = sdi->priv; + s = g_match_info_fetch(match, 1); + sr_spew("STAT response '%s'.", s); + + /* Peak hold mode. */ + if (s[4] == '1') + devc->cur_mqflags |= SR_MQFLAG_MAX; + else + devc->cur_mqflags &= ~SR_MQFLAG_MAX; + + /* Triggered hold mode. */ + if (s[7] == '1') + devc->cur_mqflags |= SR_MQFLAG_HOLD; + else + devc->cur_mqflags &= ~SR_MQFLAG_HOLD; + + g_free(s); + + return SR_OK; +} + +static int recv_stat_u128x(const struct sr_dev_inst *sdi, GMatchInfo *match) +{ + struct dev_context *devc; + char *s; + + devc = sdi->priv; + s = g_match_info_fetch(match, 1); + sr_spew("STAT response '%s'.", s); + + /* Max, Min or Avg mode -- no way to tell which, so we'll + * set both flags to denote it's not a normal measurement. */ + if (s[0] == '1') + devc->cur_mqflags |= SR_MQFLAG_MAX | SR_MQFLAG_MIN | SR_MQFLAG_AVG; + else + devc->cur_mqflags &= ~(SR_MQFLAG_MAX | SR_MQFLAG_MIN | SR_MQFLAG_AVG); + + /* Peak hold mode. */ + if (s[4] == '4') + devc->cur_mqflags |= SR_MQFLAG_MAX; + else + devc->cur_mqflags &= ~SR_MQFLAG_MAX; + + /* Null function. */ + if (s[1] == '1') + devc->cur_mqflags |= SR_MQFLAG_RELATIVE; + else + devc->cur_mqflags &= ~SR_MQFLAG_RELATIVE; + + /* Triggered or auto hold modes. */ + if (s[7] == '1' || s[11] == '1') + devc->cur_mqflags |= SR_MQFLAG_HOLD; + else + devc->cur_mqflags &= ~SR_MQFLAG_HOLD; + + g_free(s); + + return SR_OK; +} + +static int send_fetc(const struct sr_dev_inst *sdi) +{ + struct dev_context *devc; + devc = sdi->priv; + if (devc->mode_squarewave) + return SR_OK; + return agdmm_send(sdi, "FETC?"); +} + +static int recv_fetc(const struct sr_dev_inst *sdi, GMatchInfo *match) +{ + struct dev_context *devc; + struct sr_datafeed_packet packet; + struct sr_datafeed_analog analog; + struct sr_analog_encoding encoding; + struct sr_analog_meaning meaning; + struct sr_analog_spec spec; + float fvalue; + const char *s; + char *mstr; + + sr_spew("FETC reply '%s'.", g_match_info_get_string(match)); + devc = sdi->priv; + + if (devc->cur_mq == -1) + /* Haven't seen configuration yet, so can't know what + * the fetched float means. Not really an error, we'll + * get metadata soon enough. */ + return SR_OK; + + s = g_match_info_get_string(match); + if (!strcmp(s, "-9.90000000E+37") || !strcmp(s, "+9.90000000E+37")) { + /* An invalid measurement shows up on the display as "O.L", but + * comes through like this. Since comparing 38-digit floats + * is rather problematic, we'll cut through this here. */ + fvalue = NAN; + } else { + mstr = g_match_info_fetch(match, 1); + if (sr_atof_ascii(mstr, &fvalue) != SR_OK) { + g_free(mstr); + sr_dbg("Invalid float."); + return SR_ERR; + } + g_free(mstr); + if (devc->cur_exponent != 0) + fvalue *= powf(10, devc->cur_exponent); + } + + sr_analog_init(&analog, &encoding, &meaning, &spec, + devc->cur_digits - devc->cur_exponent); + analog.meaning->mq = devc->cur_mq; + analog.meaning->unit = devc->cur_unit; + analog.meaning->mqflags = devc->cur_mqflags; + analog.meaning->channels = sdi->channels; + analog.num_samples = 1; + analog.data = &fvalue; + encoding.digits = devc->cur_encoding - devc->cur_exponent; + packet.type = SR_DF_ANALOG; + packet.payload = &analog; + sr_session_send(sdi, &packet); + + sr_sw_limits_update_samples_read(&devc->limits, 1); + + return SR_OK; +} + +static int send_conf(const struct sr_dev_inst *sdi) +{ + return agdmm_send(sdi, "CONF?"); +} + +static int recv_conf_u123x(const struct sr_dev_inst *sdi, GMatchInfo *match) +{ + struct dev_context *devc; + char *mstr, *rstr; + int resolution; + + sr_spew("CONF? response '%s'.", g_match_info_get_string(match)); + devc = sdi->priv; + + rstr = g_match_info_fetch(match, 2); + if (rstr) + sr_atoi(rstr, &resolution); + g_free(rstr); + + mstr = g_match_info_fetch(match, 1); + if (!strcmp(mstr, "V")) { + devc->cur_mq = SR_MQ_VOLTAGE; + devc->cur_unit = SR_UNIT_VOLT; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + devc->cur_digits = 4 - resolution; + } else if (!strcmp(mstr, "MV")) { + if (devc->mode_tempaux) { + devc->cur_mq = SR_MQ_TEMPERATURE; + /* No way to detect whether Fahrenheit or Celsius + * is used, so we'll just default to Celsius. */ + devc->cur_unit = SR_UNIT_CELSIUS; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + devc->cur_digits = 1; + } else { + devc->cur_mq = SR_MQ_VOLTAGE; + devc->cur_unit = SR_UNIT_VOLT; + devc->cur_mqflags = 0; + devc->cur_exponent = -3; + devc->cur_digits = 5 - resolution; + } + } else if (!strcmp(mstr, "A")) { + devc->cur_mq = SR_MQ_CURRENT; + devc->cur_unit = SR_UNIT_AMPERE; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + devc->cur_digits = 3 - resolution; + } else if (!strcmp(mstr, "UA")) { + devc->cur_mq = SR_MQ_CURRENT; + devc->cur_unit = SR_UNIT_AMPERE; + devc->cur_mqflags = 0; + devc->cur_exponent = -6; + devc->cur_digits = 8 - resolution; + } else if (!strcmp(mstr, "FREQ")) { + devc->cur_mq = SR_MQ_FREQUENCY; + devc->cur_unit = SR_UNIT_HERTZ; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + devc->cur_digits = 2 - resolution; + } else if (!strcmp(mstr, "RES")) { + if (devc->mode_continuity) { + devc->cur_mq = SR_MQ_CONTINUITY; + devc->cur_unit = SR_UNIT_BOOLEAN; + } else { + devc->cur_mq = SR_MQ_RESISTANCE; + devc->cur_unit = SR_UNIT_OHM; + } + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + devc->cur_digits = 1 - resolution; + } else if (!strcmp(mstr, "DIOD")) { + devc->cur_mq = SR_MQ_VOLTAGE; + devc->cur_unit = SR_UNIT_VOLT; + devc->cur_mqflags = SR_MQFLAG_DIODE; + devc->cur_exponent = 0; + devc->cur_digits = 3; + } else if (!strcmp(mstr, "CAP")) { + devc->cur_mq = SR_MQ_CAPACITANCE; + devc->cur_unit = SR_UNIT_FARAD; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + devc->cur_digits = 9 - resolution; + } else + sr_dbg("Unknown first argument."); + g_free(mstr); + + /* This is based on guess, supposing similarity with other models. */ + devc->cur_encoding = devc->cur_digits + 1; + + if (g_match_info_get_match_count(match) == 4) { + mstr = g_match_info_fetch(match, 3); + /* Third value, if present, is always AC or DC. */ + if (!strcmp(mstr, "AC")) { + devc->cur_mqflags |= SR_MQFLAG_AC; + if (devc->cur_mq == SR_MQ_VOLTAGE) + devc->cur_mqflags |= SR_MQFLAG_RMS; + } else if (!strcmp(mstr, "DC")) { + devc->cur_mqflags |= SR_MQFLAG_DC; + } else { + sr_dbg("Unknown first argument '%s'.", mstr); + } + g_free(mstr); + } else + devc->cur_mqflags &= ~(SR_MQFLAG_AC | SR_MQFLAG_DC); + + return SR_OK; +} + +static int recv_conf_u124x_5x(const struct sr_dev_inst *sdi, GMatchInfo *match) +{ + struct dev_context *devc; + char *mstr, *rstr, *m2; + int resolution; + + sr_spew("CONF? response '%s'.", g_match_info_get_string(match)); + devc = sdi->priv; + + devc->mode_squarewave = 0; + + rstr = g_match_info_fetch(match, 4); + if (rstr && sr_atoi(rstr, &resolution) == SR_OK) { + devc->cur_digits = -resolution; + devc->cur_encoding = -resolution + 1; + } + g_free(rstr); + + mstr = g_match_info_fetch(match, 1); + if (!strncmp(mstr, "VOLT", 4)) { + devc->cur_mq = SR_MQ_VOLTAGE; + devc->cur_unit = SR_UNIT_VOLT; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + if (mstr[4] == ':') { + if (!strncmp(mstr + 5, "ACDC", 4)) { + /* AC + DC offset */ + devc->cur_mqflags |= SR_MQFLAG_AC | SR_MQFLAG_DC | SR_MQFLAG_RMS; + } else if (!strncmp(mstr + 5, "AC", 2)) { + devc->cur_mqflags |= SR_MQFLAG_AC | SR_MQFLAG_RMS; + } else if (!strncmp(mstr + 5, "DC", 2)) { + devc->cur_mqflags |= SR_MQFLAG_DC; + } + } else + devc->cur_mqflags |= SR_MQFLAG_DC; + } else if (!strncmp(mstr, "CURR", 4)) { + devc->cur_mq = SR_MQ_CURRENT; + devc->cur_unit = SR_UNIT_AMPERE; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + if (mstr[4] == ':') { + if (!strncmp(mstr + 5, "ACDC", 4)) { + /* AC + DC offset */ + devc->cur_mqflags |= SR_MQFLAG_AC | SR_MQFLAG_DC | SR_MQFLAG_RMS; + } else if (!strncmp(mstr + 5, "AC", 2)) { + devc->cur_mqflags |= SR_MQFLAG_AC | SR_MQFLAG_RMS; + } else if (!strncmp(mstr + 5, "DC", 2)) { + devc->cur_mqflags |= SR_MQFLAG_DC; + } + } else + devc->cur_mqflags |= SR_MQFLAG_DC; + } else if (!strcmp(mstr, "RES")) { + devc->cur_mq = SR_MQ_RESISTANCE; + devc->cur_unit = SR_UNIT_OHM; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + } else if (!strcmp(mstr, "COND")) { + devc->cur_mq = SR_MQ_CONDUCTANCE; + devc->cur_unit = SR_UNIT_SIEMENS; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + } else if (!strcmp(mstr, "CAP")) { + devc->cur_mq = SR_MQ_CAPACITANCE; + devc->cur_unit = SR_UNIT_FARAD; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + } else if (!strncmp(mstr, "FREQ", 4) || !strncmp(mstr, "FC1", 3)) { + devc->cur_mq = SR_MQ_FREQUENCY; + devc->cur_unit = SR_UNIT_HERTZ; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + } else if (!strcmp(mstr, "CONT")) { + devc->cur_mq = SR_MQ_CONTINUITY; + devc->cur_unit = SR_UNIT_BOOLEAN; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + } else if (!strcmp(mstr, "DIOD")) { + devc->cur_mq = SR_MQ_VOLTAGE; + devc->cur_unit = SR_UNIT_VOLT; + devc->cur_mqflags = SR_MQFLAG_DIODE; + devc->cur_exponent = 0; + devc->cur_digits = 4; + devc->cur_encoding = 5; + } else if (!strncmp(mstr, "T1", 2) || !strncmp(mstr, "T2", 2) || + !strncmp(mstr, "TEMP", 2)) { + devc->cur_mq = SR_MQ_TEMPERATURE; + m2 = g_match_info_fetch(match, 2); + if (!strcmp(m2, "FAR")) + devc->cur_unit = SR_UNIT_FAHRENHEIT; + else + devc->cur_unit = SR_UNIT_CELSIUS; + g_free(m2); + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + devc->cur_digits = 1; + devc->cur_encoding = 2; + } else if (!strcmp(mstr, "SCOU")) { + /* + * Switch counter, not supported. Not sure what values + * come from FETC in this mode, or how they would map + * into libsigrok. + */ + } else if (!strncmp(mstr, "CPER:", 5)) { + devc->cur_mq = SR_MQ_CURRENT; + devc->cur_unit = SR_UNIT_PERCENTAGE; + devc->cur_mqflags = 0; + devc->cur_exponent = 0; + devc->cur_digits = 2; + devc->cur_encoding = 3; + } else if (!strcmp(mstr, "SQU")) { + /* + * Square wave output, not supported. FETC just return + * an error in this mode, so don't even call it. + */ + devc->mode_squarewave = 1; + } else { + sr_dbg("Unknown first argument '%s'.", mstr); + } + g_free(mstr); + + return SR_OK; +} + +/* This comes in whenever the rotary switch is changed to a new position. + * We could use it to determine the major measurement mode, but we already + * have the output of CONF? for that, which is more detailed. However + * we do need to catch this here, or it'll show up in some other output. */ +static int recv_switch(const struct sr_dev_inst *sdi, GMatchInfo *match) +{ + (void)sdi; + + sr_spew("Switch '%s'.", g_match_info_get_string(match)); + + return SR_OK; +} + +/* Poll keys/switches and values at 7Hz, mode at 1Hz. */ +SR_PRIV const struct agdmm_job agdmm_jobs_u12xx[] = { + { 143, send_stat }, + { 1000, send_conf }, + { 143, send_fetc }, + ALL_ZERO +}; + +SR_PRIV const struct agdmm_recv agdmm_recvs_u123x[] = { + { "^\"(\\d\\d.{18}\\d)\"$", recv_stat_u123x }, + { "^\\*([0-9])$", recv_switch }, + { "^([-+][0-9]\\.[0-9]{8}E[-+][0-9]{2})$", recv_fetc }, + { "^\"(V|MV|A|UA|FREQ),(\\d),(AC|DC)\"$", recv_conf_u123x }, + { "^\"(RES|CAP),(\\d)\"$", recv_conf_u123x}, + { "^\"(DIOD)\"$", recv_conf_u123x }, + ALL_ZERO +}; + +SR_PRIV const struct agdmm_recv agdmm_recvs_u124x[] = { + { "^\"(\\d\\d.{18}\\d)\"$", recv_stat_u124x }, + { "^\\*([0-9])$", recv_switch }, + { "^([-+][0-9]\\.[0-9]{8}E[-+][0-9]{2})$", recv_fetc }, + { "^\"(VOLT|CURR|RES|CAP|FREQ) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(VOLT:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(CURR:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(CPER:[40]-20mA) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(T[0-9]:[A-Z]+) ([A-Z]+)\"$", recv_conf_u124x_5x }, + { "^\"(DIOD)\"$", recv_conf_u124x_5x }, + ALL_ZERO +}; + +SR_PRIV const struct agdmm_recv agdmm_recvs_u125x[] = { + { "^\"(\\d\\d.{18}\\d)\"$", recv_stat_u125x }, + { "^\\*([0-9])$", recv_switch }, + { "^([-+][0-9]\\.[0-9]{8}E[-+][0-9]{2})$", recv_fetc }, + { "^\"(VOLT|CURR|RES|CAP|FREQ) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(VOLT:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(CURR:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(CPER:[40]-20mA) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(T[0-9]:[A-Z]+) ([A-Z]+)\"$", recv_conf_u124x_5x }, + { "^\"(DIOD)\"$", recv_conf_u124x_5x }, + ALL_ZERO +}; + +SR_PRIV const struct agdmm_recv agdmm_recvs_u128x[] = { + { "^\"(\\d\\d.{18}\\d)\"$", recv_stat_u128x }, + { "^\\*([0-9])$", recv_switch }, + { "^([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))$", recv_fetc }, + { "^\"(VOLT|CURR|RES|COND|CAP|FREQ|FC1|FC100) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(VOLT:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(CURR:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(FREQ:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(CPER:[40]-20mA) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, + { "^\"(TEMP:[A-Z]+) ([A-Z]+)\"$", recv_conf_u124x_5x }, + { "^\"(DIOD|SQU)\"$", recv_conf_u124x_5x }, + ALL_ZERO +}; diff --git a/src/hardware/agilent-dmm/protocol.h b/src/hardware/agilent-dmm/protocol.h new file mode 100644 index 00000000..b065126e --- /dev/null +++ b/src/hardware/agilent-dmm/protocol.h @@ -0,0 +1,88 @@ +/* + * This file is part of the libsigrok project. + * + * Copyright (C) 2012 Bert Vermeulen + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see . + */ + +#ifndef LIBSIGROK_HARDWARE_AGILENT_DMM_PROTOCOL_H +#define LIBSIGROK_HARDWARE_AGILENT_DMM_PROTOCOL_H + +#define LOG_PREFIX "agilent-dmm" + +#define AGDMM_BUFSIZE 256 + +/* Always USB-serial, 1ms is plenty. */ +#define SERIAL_WRITE_TIMEOUT_MS 1 + +/* Supported models */ +enum { + AGILENT_U1231 = 1, + AGILENT_U1232, + AGILENT_U1233, + + AGILENT_U1241, + AGILENT_U1242, + + AGILENT_U1251, + AGILENT_U1252, + AGILENT_U1253, + + KEYSIGHT_U1281, + KEYSIGHT_U1282, +}; + +/* Supported device profiles */ +struct agdmm_profile { + int model; + const char *modelname; + const struct agdmm_job *jobs; + const struct agdmm_recv *recvs; +}; + +/* Private, per-device-instance driver context. */ +struct dev_context { + const struct agdmm_profile *profile; + struct sr_sw_limits limits; + + /* Runtime. */ + int64_t jobqueue[8]; + unsigned char buf[AGDMM_BUFSIZE]; + int buflen; + int cur_mq; + int cur_unit; + int cur_mqflags; + int cur_digits; + int cur_encoding; + int cur_exponent; + int cur_acdc; + int mode_tempaux; + int mode_continuity; + int mode_squarewave; +}; + +struct agdmm_job { + int interval; + int (*send) (const struct sr_dev_inst *sdi); +}; + +struct agdmm_recv { + const char *recv_regex; + int (*recv) (const struct sr_dev_inst *sdi, GMatchInfo *match); +}; + +SR_PRIV int agdmm_receive_data(int fd, int revents, void *cb_data); + +#endif diff --git a/src/hardware/agilent-dmm/sched.c b/src/hardware/agilent-dmm/sched.c deleted file mode 100644 index 27dddc7f..00000000 --- a/src/hardware/agilent-dmm/sched.c +++ /dev/null @@ -1,664 +0,0 @@ -/* - * This file is part of the libsigrok project. - * - * Copyright (C) 2012 Bert Vermeulen - * - * This program is free software: you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation, either version 3 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program. If not, see . - */ - -#include -#include -#include -#include -#include -#include -#include "libsigrok-internal.h" -#include "agilent-dmm.h" - -static void dispatch(const struct sr_dev_inst *sdi) -{ - struct dev_context *devc; - const struct agdmm_job *jobs; - int64_t now; - int i; - - devc = sdi->priv; - jobs = devc->profile->jobs; - now = g_get_monotonic_time() / 1000; - for (i = 0; (&jobs[i])->interval; i++) { - if (now - devc->jobqueue[i] > (&jobs[i])->interval) { - sr_spew("Running job %d.", i); - (&jobs[i])->send(sdi); - devc->jobqueue[i] = now; - } - } -} - -static void receive_line(const struct sr_dev_inst *sdi) -{ - struct dev_context *devc; - const struct agdmm_recv *recvs, *recv; - GRegex *reg; - GMatchInfo *match; - int i; - - devc = sdi->priv; - - /* Strip CRLF */ - while (devc->buflen) { - if (*(devc->buf + devc->buflen - 1) == '\r' - || *(devc->buf + devc->buflen - 1) == '\n') - *(devc->buf + --devc->buflen) = '\0'; - else - break; - } - sr_spew("Received '%s'.", devc->buf); - - recv = NULL; - recvs = devc->profile->recvs; - for (i = 0; (&recvs[i])->recv_regex; i++) { - reg = g_regex_new((&recvs[i])->recv_regex, 0, 0, NULL); - if (g_regex_match(reg, (char *)devc->buf, 0, &match)) { - recv = &recvs[i]; - break; - } - g_match_info_unref(match); - g_regex_unref(reg); - } - if (recv) { - recv->recv(sdi, match); - g_match_info_unref(match); - g_regex_unref(reg); - } else - sr_dbg("Unknown line '%s'.", devc->buf); - - /* Done with this. */ - devc->buflen = 0; -} - -SR_PRIV int agdmm_receive_data(int fd, int revents, void *cb_data) -{ - struct sr_dev_inst *sdi; - struct dev_context *devc; - struct sr_serial_dev_inst *serial; - int len; - - (void)fd; - - if (!(sdi = cb_data)) - return TRUE; - - if (!(devc = sdi->priv)) - return TRUE; - - serial = sdi->conn; - if (revents == G_IO_IN) { - /* Serial data arrived. */ - while (AGDMM_BUFSIZE - devc->buflen - 1 > 0) { - len = serial_read_nonblocking(serial, devc->buf + devc->buflen, 1); - if (len < 1) - break; - devc->buflen += len; - *(devc->buf + devc->buflen) = '\0'; - if (*(devc->buf + devc->buflen - 1) == '\n') { - /* End of line */ - receive_line(sdi); - break; - } - } - } - - dispatch(sdi); - - if (sr_sw_limits_check(&devc->limits)) - sdi->driver->dev_acquisition_stop(sdi); - - return TRUE; -} - -static int agdmm_send(const struct sr_dev_inst *sdi, const char *cmd) -{ - struct sr_serial_dev_inst *serial; - char buf[32]; - - serial = sdi->conn; - - sr_spew("Sending '%s'.", cmd); - strncpy(buf, cmd, 28); - if (!strncmp(buf, "*IDN?", 5)) - strcat(buf, "\r\n"); - else - strcat(buf, "\n\r\n"); - if (serial_write_blocking(serial, buf, strlen(buf), SERIAL_WRITE_TIMEOUT_MS) < (int)strlen(buf)) { - sr_err("Failed to send."); - return SR_ERR; - } - - return SR_OK; -} - -static int send_stat(const struct sr_dev_inst *sdi) -{ - return agdmm_send(sdi, "STAT?"); -} - -static int recv_stat_u123x(const struct sr_dev_inst *sdi, GMatchInfo *match) -{ - struct dev_context *devc; - char *s; - - devc = sdi->priv; - s = g_match_info_fetch(match, 1); - sr_spew("STAT response '%s'.", s); - - /* Max, Min or Avg mode -- no way to tell which, so we'll - * set both flags to denote it's not a normal measurement. */ - if (s[0] == '1') - devc->cur_mqflags |= SR_MQFLAG_MAX | SR_MQFLAG_MIN; - else - devc->cur_mqflags &= ~(SR_MQFLAG_MAX | SR_MQFLAG_MIN); - - if (s[1] == '1') - devc->cur_mqflags |= SR_MQFLAG_RELATIVE; - else - devc->cur_mqflags &= ~SR_MQFLAG_RELATIVE; - - /* Triggered or auto hold modes. */ - if (s[2] == '1' || s[3] == '1') - devc->cur_mqflags |= SR_MQFLAG_HOLD; - else - devc->cur_mqflags &= ~SR_MQFLAG_HOLD; - - /* Temp/aux mode. */ - if (s[7] == '1') - devc->mode_tempaux = TRUE; - else - devc->mode_tempaux = FALSE; - - /* Continuity mode. */ - if (s[16] == '1') - devc->mode_continuity = TRUE; - else - devc->mode_continuity = FALSE; - - g_free(s); - - return SR_OK; -} - -static int recv_stat_u124x(const struct sr_dev_inst *sdi, GMatchInfo *match) -{ - struct dev_context *devc; - char *s; - - devc = sdi->priv; - s = g_match_info_fetch(match, 1); - sr_spew("STAT response '%s'.", s); - - /* Max, Min or Avg mode -- no way to tell which, so we'll - * set both flags to denote it's not a normal measurement. */ - if (s[0] == '1') - devc->cur_mqflags |= SR_MQFLAG_MAX | SR_MQFLAG_MIN; - else - devc->cur_mqflags &= ~(SR_MQFLAG_MAX | SR_MQFLAG_MIN); - - if (s[1] == '1') - devc->cur_mqflags |= SR_MQFLAG_RELATIVE; - else - devc->cur_mqflags &= ~SR_MQFLAG_RELATIVE; - - /* Hold mode. */ - if (s[7] == '1') - devc->cur_mqflags |= SR_MQFLAG_HOLD; - else - devc->cur_mqflags &= ~SR_MQFLAG_HOLD; - - g_free(s); - - return SR_OK; -} - -static int recv_stat_u125x(const struct sr_dev_inst *sdi, GMatchInfo *match) -{ - struct dev_context *devc; - char *s; - - devc = sdi->priv; - s = g_match_info_fetch(match, 1); - sr_spew("STAT response '%s'.", s); - - /* Peak hold mode. */ - if (s[4] == '1') - devc->cur_mqflags |= SR_MQFLAG_MAX; - else - devc->cur_mqflags &= ~SR_MQFLAG_MAX; - - /* Triggered hold mode. */ - if (s[7] == '1') - devc->cur_mqflags |= SR_MQFLAG_HOLD; - else - devc->cur_mqflags &= ~SR_MQFLAG_HOLD; - - g_free(s); - - return SR_OK; -} - -static int recv_stat_u128x(const struct sr_dev_inst *sdi, GMatchInfo *match) -{ - struct dev_context *devc; - char *s; - - devc = sdi->priv; - s = g_match_info_fetch(match, 1); - sr_spew("STAT response '%s'.", s); - - /* Max, Min or Avg mode -- no way to tell which, so we'll - * set both flags to denote it's not a normal measurement. */ - if (s[0] == '1') - devc->cur_mqflags |= SR_MQFLAG_MAX | SR_MQFLAG_MIN | SR_MQFLAG_AVG; - else - devc->cur_mqflags &= ~(SR_MQFLAG_MAX | SR_MQFLAG_MIN | SR_MQFLAG_AVG); - - /* Peak hold mode. */ - if (s[4] == '4') - devc->cur_mqflags |= SR_MQFLAG_MAX; - else - devc->cur_mqflags &= ~SR_MQFLAG_MAX; - - /* Null function. */ - if (s[1] == '1') - devc->cur_mqflags |= SR_MQFLAG_RELATIVE; - else - devc->cur_mqflags &= ~SR_MQFLAG_RELATIVE; - - /* Triggered or auto hold modes. */ - if (s[7] == '1' || s[11] == '1') - devc->cur_mqflags |= SR_MQFLAG_HOLD; - else - devc->cur_mqflags &= ~SR_MQFLAG_HOLD; - - g_free(s); - - return SR_OK; -} - -static int send_fetc(const struct sr_dev_inst *sdi) -{ - struct dev_context *devc; - devc = sdi->priv; - if (devc->mode_squarewave) - return SR_OK; - return agdmm_send(sdi, "FETC?"); -} - -static int recv_fetc(const struct sr_dev_inst *sdi, GMatchInfo *match) -{ - struct dev_context *devc; - struct sr_datafeed_packet packet; - struct sr_datafeed_analog analog; - struct sr_analog_encoding encoding; - struct sr_analog_meaning meaning; - struct sr_analog_spec spec; - float fvalue; - const char *s; - char *mstr; - - sr_spew("FETC reply '%s'.", g_match_info_get_string(match)); - devc = sdi->priv; - - if (devc->cur_mq == -1) - /* Haven't seen configuration yet, so can't know what - * the fetched float means. Not really an error, we'll - * get metadata soon enough. */ - return SR_OK; - - s = g_match_info_get_string(match); - if (!strcmp(s, "-9.90000000E+37") || !strcmp(s, "+9.90000000E+37")) { - /* An invalid measurement shows up on the display as "O.L", but - * comes through like this. Since comparing 38-digit floats - * is rather problematic, we'll cut through this here. */ - fvalue = NAN; - } else { - mstr = g_match_info_fetch(match, 1); - if (sr_atof_ascii(mstr, &fvalue) != SR_OK) { - g_free(mstr); - sr_dbg("Invalid float."); - return SR_ERR; - } - g_free(mstr); - if (devc->cur_exponent != 0) - fvalue *= powf(10, devc->cur_exponent); - } - - sr_analog_init(&analog, &encoding, &meaning, &spec, - devc->cur_digits - devc->cur_exponent); - analog.meaning->mq = devc->cur_mq; - analog.meaning->unit = devc->cur_unit; - analog.meaning->mqflags = devc->cur_mqflags; - analog.meaning->channels = sdi->channels; - analog.num_samples = 1; - analog.data = &fvalue; - encoding.digits = devc->cur_encoding - devc->cur_exponent; - packet.type = SR_DF_ANALOG; - packet.payload = &analog; - sr_session_send(sdi, &packet); - - sr_sw_limits_update_samples_read(&devc->limits, 1); - - return SR_OK; -} - -static int send_conf(const struct sr_dev_inst *sdi) -{ - return agdmm_send(sdi, "CONF?"); -} - -static int recv_conf_u123x(const struct sr_dev_inst *sdi, GMatchInfo *match) -{ - struct dev_context *devc; - char *mstr, *rstr; - int resolution; - - sr_spew("CONF? response '%s'.", g_match_info_get_string(match)); - devc = sdi->priv; - - rstr = g_match_info_fetch(match, 2); - if (rstr) - sr_atoi(rstr, &resolution); - g_free(rstr); - - mstr = g_match_info_fetch(match, 1); - if (!strcmp(mstr, "V")) { - devc->cur_mq = SR_MQ_VOLTAGE; - devc->cur_unit = SR_UNIT_VOLT; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - devc->cur_digits = 4 - resolution; - } else if (!strcmp(mstr, "MV")) { - if (devc->mode_tempaux) { - devc->cur_mq = SR_MQ_TEMPERATURE; - /* No way to detect whether Fahrenheit or Celsius - * is used, so we'll just default to Celsius. */ - devc->cur_unit = SR_UNIT_CELSIUS; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - devc->cur_digits = 1; - } else { - devc->cur_mq = SR_MQ_VOLTAGE; - devc->cur_unit = SR_UNIT_VOLT; - devc->cur_mqflags = 0; - devc->cur_exponent = -3; - devc->cur_digits = 5 - resolution; - } - } else if (!strcmp(mstr, "A")) { - devc->cur_mq = SR_MQ_CURRENT; - devc->cur_unit = SR_UNIT_AMPERE; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - devc->cur_digits = 3 - resolution; - } else if (!strcmp(mstr, "UA")) { - devc->cur_mq = SR_MQ_CURRENT; - devc->cur_unit = SR_UNIT_AMPERE; - devc->cur_mqflags = 0; - devc->cur_exponent = -6; - devc->cur_digits = 8 - resolution; - } else if (!strcmp(mstr, "FREQ")) { - devc->cur_mq = SR_MQ_FREQUENCY; - devc->cur_unit = SR_UNIT_HERTZ; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - devc->cur_digits = 2 - resolution; - } else if (!strcmp(mstr, "RES")) { - if (devc->mode_continuity) { - devc->cur_mq = SR_MQ_CONTINUITY; - devc->cur_unit = SR_UNIT_BOOLEAN; - } else { - devc->cur_mq = SR_MQ_RESISTANCE; - devc->cur_unit = SR_UNIT_OHM; - } - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - devc->cur_digits = 1 - resolution; - } else if (!strcmp(mstr, "DIOD")) { - devc->cur_mq = SR_MQ_VOLTAGE; - devc->cur_unit = SR_UNIT_VOLT; - devc->cur_mqflags = SR_MQFLAG_DIODE; - devc->cur_exponent = 0; - devc->cur_digits = 3; - } else if (!strcmp(mstr, "CAP")) { - devc->cur_mq = SR_MQ_CAPACITANCE; - devc->cur_unit = SR_UNIT_FARAD; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - devc->cur_digits = 9 - resolution; - } else - sr_dbg("Unknown first argument."); - g_free(mstr); - - /* This is based on guess, supposing similarity with other models. */ - devc->cur_encoding = devc->cur_digits + 1; - - if (g_match_info_get_match_count(match) == 4) { - mstr = g_match_info_fetch(match, 3); - /* Third value, if present, is always AC or DC. */ - if (!strcmp(mstr, "AC")) { - devc->cur_mqflags |= SR_MQFLAG_AC; - if (devc->cur_mq == SR_MQ_VOLTAGE) - devc->cur_mqflags |= SR_MQFLAG_RMS; - } else if (!strcmp(mstr, "DC")) { - devc->cur_mqflags |= SR_MQFLAG_DC; - } else { - sr_dbg("Unknown first argument '%s'.", mstr); - } - g_free(mstr); - } else - devc->cur_mqflags &= ~(SR_MQFLAG_AC | SR_MQFLAG_DC); - - return SR_OK; -} - -static int recv_conf_u124x_5x(const struct sr_dev_inst *sdi, GMatchInfo *match) -{ - struct dev_context *devc; - char *mstr, *rstr, *m2; - int resolution; - - sr_spew("CONF? response '%s'.", g_match_info_get_string(match)); - devc = sdi->priv; - - devc->mode_squarewave = 0; - - rstr = g_match_info_fetch(match, 4); - if (rstr && sr_atoi(rstr, &resolution) == SR_OK) { - devc->cur_digits = -resolution; - devc->cur_encoding = -resolution + 1; - } - g_free(rstr); - - mstr = g_match_info_fetch(match, 1); - if (!strncmp(mstr, "VOLT", 4)) { - devc->cur_mq = SR_MQ_VOLTAGE; - devc->cur_unit = SR_UNIT_VOLT; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - if (mstr[4] == ':') { - if (!strncmp(mstr + 5, "ACDC", 4)) { - /* AC + DC offset */ - devc->cur_mqflags |= SR_MQFLAG_AC | SR_MQFLAG_DC | SR_MQFLAG_RMS; - } else if (!strncmp(mstr + 5, "AC", 2)) { - devc->cur_mqflags |= SR_MQFLAG_AC | SR_MQFLAG_RMS; - } else if (!strncmp(mstr + 5, "DC", 2)) { - devc->cur_mqflags |= SR_MQFLAG_DC; - } - } else - devc->cur_mqflags |= SR_MQFLAG_DC; - } else if (!strncmp(mstr, "CURR", 4)) { - devc->cur_mq = SR_MQ_CURRENT; - devc->cur_unit = SR_UNIT_AMPERE; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - if (mstr[4] == ':') { - if (!strncmp(mstr + 5, "ACDC", 4)) { - /* AC + DC offset */ - devc->cur_mqflags |= SR_MQFLAG_AC | SR_MQFLAG_DC | SR_MQFLAG_RMS; - } else if (!strncmp(mstr + 5, "AC", 2)) { - devc->cur_mqflags |= SR_MQFLAG_AC | SR_MQFLAG_RMS; - } else if (!strncmp(mstr + 5, "DC", 2)) { - devc->cur_mqflags |= SR_MQFLAG_DC; - } - } else - devc->cur_mqflags |= SR_MQFLAG_DC; - } else if (!strcmp(mstr, "RES")) { - devc->cur_mq = SR_MQ_RESISTANCE; - devc->cur_unit = SR_UNIT_OHM; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - } else if (!strcmp(mstr, "COND")) { - devc->cur_mq = SR_MQ_CONDUCTANCE; - devc->cur_unit = SR_UNIT_SIEMENS; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - } else if (!strcmp(mstr, "CAP")) { - devc->cur_mq = SR_MQ_CAPACITANCE; - devc->cur_unit = SR_UNIT_FARAD; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - } else if (!strncmp(mstr, "FREQ", 4) || !strncmp(mstr, "FC1", 3)) { - devc->cur_mq = SR_MQ_FREQUENCY; - devc->cur_unit = SR_UNIT_HERTZ; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - } else if (!strcmp(mstr, "CONT")) { - devc->cur_mq = SR_MQ_CONTINUITY; - devc->cur_unit = SR_UNIT_BOOLEAN; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - } else if (!strcmp(mstr, "DIOD")) { - devc->cur_mq = SR_MQ_VOLTAGE; - devc->cur_unit = SR_UNIT_VOLT; - devc->cur_mqflags = SR_MQFLAG_DIODE; - devc->cur_exponent = 0; - devc->cur_digits = 4; - devc->cur_encoding = 5; - } else if (!strncmp(mstr, "T1", 2) || !strncmp(mstr, "T2", 2) || - !strncmp(mstr, "TEMP", 2)) { - devc->cur_mq = SR_MQ_TEMPERATURE; - m2 = g_match_info_fetch(match, 2); - if (!strcmp(m2, "FAR")) - devc->cur_unit = SR_UNIT_FAHRENHEIT; - else - devc->cur_unit = SR_UNIT_CELSIUS; - g_free(m2); - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - devc->cur_digits = 1; - devc->cur_encoding = 2; - } else if (!strcmp(mstr, "SCOU")) { - /* - * Switch counter, not supported. Not sure what values - * come from FETC in this mode, or how they would map - * into libsigrok. - */ - } else if (!strncmp(mstr, "CPER:", 5)) { - devc->cur_mq = SR_MQ_CURRENT; - devc->cur_unit = SR_UNIT_PERCENTAGE; - devc->cur_mqflags = 0; - devc->cur_exponent = 0; - devc->cur_digits = 2; - devc->cur_encoding = 3; - } else if (!strcmp(mstr, "SQU")) { - /* - * Square wave output, not supported. FETC just return - * an error in this mode, so don't even call it. - */ - devc->mode_squarewave = 1; - } else { - sr_dbg("Unknown first argument '%s'.", mstr); - } - g_free(mstr); - - return SR_OK; -} - -/* This comes in whenever the rotary switch is changed to a new position. - * We could use it to determine the major measurement mode, but we already - * have the output of CONF? for that, which is more detailed. However - * we do need to catch this here, or it'll show up in some other output. */ -static int recv_switch(const struct sr_dev_inst *sdi, GMatchInfo *match) -{ - (void)sdi; - - sr_spew("Switch '%s'.", g_match_info_get_string(match)); - - return SR_OK; -} - -/* Poll keys/switches and values at 7Hz, mode at 1Hz. */ -SR_PRIV const struct agdmm_job agdmm_jobs_u12xx[] = { - { 143, send_stat }, - { 1000, send_conf }, - { 143, send_fetc }, - ALL_ZERO -}; - -SR_PRIV const struct agdmm_recv agdmm_recvs_u123x[] = { - { "^\"(\\d\\d.{18}\\d)\"$", recv_stat_u123x }, - { "^\\*([0-9])$", recv_switch }, - { "^([-+][0-9]\\.[0-9]{8}E[-+][0-9]{2})$", recv_fetc }, - { "^\"(V|MV|A|UA|FREQ),(\\d),(AC|DC)\"$", recv_conf_u123x }, - { "^\"(RES|CAP),(\\d)\"$", recv_conf_u123x}, - { "^\"(DIOD)\"$", recv_conf_u123x }, - ALL_ZERO -}; - -SR_PRIV const struct agdmm_recv agdmm_recvs_u124x[] = { - { "^\"(\\d\\d.{18}\\d)\"$", recv_stat_u124x }, - { "^\\*([0-9])$", recv_switch }, - { "^([-+][0-9]\\.[0-9]{8}E[-+][0-9]{2})$", recv_fetc }, - { "^\"(VOLT|CURR|RES|CAP|FREQ) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(VOLT:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(CURR:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(CPER:[40]-20mA) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(T[0-9]:[A-Z]+) ([A-Z]+)\"$", recv_conf_u124x_5x }, - { "^\"(DIOD)\"$", recv_conf_u124x_5x }, - ALL_ZERO -}; - -SR_PRIV const struct agdmm_recv agdmm_recvs_u125x[] = { - { "^\"(\\d\\d.{18}\\d)\"$", recv_stat_u125x }, - { "^\\*([0-9])$", recv_switch }, - { "^([-+][0-9]\\.[0-9]{8}E[-+][0-9]{2})$", recv_fetc }, - { "^\"(VOLT|CURR|RES|CAP|FREQ) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(VOLT:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(CURR:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(CPER:[40]-20mA) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(T[0-9]:[A-Z]+) ([A-Z]+)\"$", recv_conf_u124x_5x }, - { "^\"(DIOD)\"$", recv_conf_u124x_5x }, - ALL_ZERO -}; - -SR_PRIV const struct agdmm_recv agdmm_recvs_u128x[] = { - { "^\"(\\d\\d.{18}\\d)\"$", recv_stat_u128x }, - { "^\\*([0-9])$", recv_switch }, - { "^([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))$", recv_fetc }, - { "^\"(VOLT|CURR|RES|COND|CAP|FREQ|FC1|FC100) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(VOLT:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(CURR:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(FREQ:[ACD]+) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(CPER:[40]-20mA) ([-+][0-9\\.E\\-+]+),([-+][0-9]\\.[0-9]{8}E([-+][0-9]{2}))\"$", recv_conf_u124x_5x }, - { "^\"(TEMP:[A-Z]+) ([A-Z]+)\"$", recv_conf_u124x_5x }, - { "^\"(DIOD|SQU)\"$", recv_conf_u124x_5x }, - ALL_ZERO -};