--- /dev/null
+/*
+ * This file is part of the libsigrok project.
+ *
+ * Copyright (C) 2019 Derek Hageman <hageman@inthat.cloud>
+ *
+ * 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 <http://www.gnu.org/licenses/>.
+ */
+
+#include <config.h>
+#include "protocol.h"
+
+static struct sr_dev_driver mooshimeter_dmm_driver_info;
+
+static const uint32_t scanopts[] = {
+ SR_CONF_CONN,
+};
+
+static const uint32_t drvopts[] = {
+ SR_CONF_MULTIMETER,
+};
+
+static const uint32_t devopts[] = {
+ SR_CONF_CONTINUOUS,
+ SR_CONF_LIMIT_SAMPLES | SR_CONF_SET | SR_CONF_LIST,
+ SR_CONF_LIMIT_MSEC | SR_CONF_SET | SR_CONF_LIST,
+ SR_CONF_AVG_SAMPLES | SR_CONF_GET | SR_CONF_SET | SR_CONF_LIST,
+ SR_CONF_SAMPLERATE | SR_CONF_GET | SR_CONF_SET | SR_CONF_LIST,
+ SR_CONF_CHANNEL_CONFIG | SR_CONF_SET,
+};
+
+static void init_dev(struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc;
+ struct sr_channel *chan;
+
+ devc = g_new0(struct dev_context, 1);
+ sdi->priv = devc;
+ sdi->status = SR_ST_INITIALIZING;
+ sdi->vendor = g_strdup("Mooshim Engineering");
+ sdi->model = g_strdup("Mooshimeter");
+
+ sr_sw_limits_init(&devc->limits);
+
+ chan = sr_channel_new(sdi, 0, SR_CHANNEL_ANALOG, TRUE, "CH1");
+ devc->channel_meaning[0].mq = SR_MQ_CURRENT;
+ devc->channel_meaning[0].unit = SR_UNIT_AMPERE;
+ devc->channel_meaning[0].mqflags = SR_MQFLAG_DC;
+ devc->channel_meaning[0].channels = g_slist_prepend(NULL, chan);
+
+ chan = sr_channel_new(sdi, 1, SR_CHANNEL_ANALOG, TRUE, "CH2");
+ devc->channel_meaning[1].mq = SR_MQ_VOLTAGE;
+ devc->channel_meaning[1].unit = SR_UNIT_VOLT;
+ devc->channel_meaning[1].mqflags = SR_MQFLAG_DC;
+ devc->channel_meaning[1].channels = g_slist_prepend(NULL, chan);
+
+ chan = sr_channel_new(sdi, 2, SR_CHANNEL_ANALOG, FALSE, "P");
+ devc->channel_meaning[2].mq = SR_MQ_POWER;
+ devc->channel_meaning[2].unit = SR_UNIT_WATT;
+ devc->channel_meaning[2].mqflags = SR_MQFLAG_RMS;
+ devc->channel_meaning[2].channels = g_slist_prepend(NULL, chan);
+}
+
+static GSList *scan(struct sr_dev_driver *di, GSList *options)
+{
+ struct sr_bt_desc *desc;
+ const char *conn;
+ struct sr_config *src;
+ GSList *l;
+ int ret;
+
+ conn = NULL;
+ for (l = options; l; l = l->next) {
+ src = l->data;
+ switch (src->key) {
+ case SR_CONF_CONN:
+ conn = g_variant_get_string(src->data, NULL);
+ break;
+ }
+ }
+
+ if (!conn)
+ return NULL;
+
+ desc = sr_bt_desc_new();
+ if (!desc)
+ return NULL;
+
+ ret = sr_bt_config_addr_remote(desc, conn);
+ if (ret < 0)
+ goto err;
+
+ /*
+ * These handles where queried with btgatt-client, since the
+ * documentation specifies them in terms of UUIDs.
+ *
+ * service - start: 0x0010, end: 0xffff, type: primary, uuid: 1bc5ffa0-0200-62ab-e411-f254e005dbd4
+ * charac - start: 0x0011, value: 0x0012, props: 0x08, ext_props: 0x0000, uuid: 1bc5ffa1-0200-62ab-e411-f254e005dbd4
+ * descr - handle: 0x0013, uuid: 00002901-0000-1000-8000-00805f9b34fb
+ * charac - start: 0x0014, value: 0x0015, props: 0x10, ext_props: 0x0000, uuid: 1bc5ffa2-0200-62ab-e411-f254e005dbd4
+ * descr - handle: 0x0016, uuid: 00002902-0000-1000-8000-00805f9b34fb
+ * descr - handle: 0x0017, uuid: 00002901-0000-1000-8000-00805f9b34fb
+ */
+ ret = sr_bt_config_notify(desc, 0x0015, 0x0012, 0x0016, 0x0001);
+ if (ret < 0)
+ goto err;
+
+ ret = sr_bt_connect_ble(desc);
+ if (ret < 0)
+ goto err;
+ sr_bt_disconnect(desc);
+
+ struct sr_dev_inst *sdi = g_malloc0(sizeof(struct sr_dev_inst));
+ struct dev_context *devc = g_malloc0(sizeof(struct dev_context));
+
+ sdi->priv = devc;
+ sdi->inst_type = SR_INST_USER;
+ sdi->connection_id = g_strdup(conn);
+ sdi->conn = desc;
+
+ init_dev(sdi);
+
+ return std_scan_complete(di, g_slist_prepend(NULL, sdi));
+
+err:
+ sr_bt_desc_free(desc);
+ return NULL;
+}
+
+static int dev_clear(const struct sr_dev_driver *di)
+{
+ struct drv_context *drvc = di->context;
+ struct sr_dev_inst *sdi;
+ GSList *l;
+
+ if (drvc) {
+ for (l = drvc->instances; l; l = l->next) {
+ sdi = l->data;
+ struct sr_bt_desc *desc = sdi->conn;
+ if (desc)
+ sr_bt_desc_free(desc);
+ sdi->conn = NULL;
+ }
+ }
+
+ return std_dev_clear(di);
+}
+
+static int set_channel1_mean(const struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc = sdi->priv;
+ devc->channel_meaning[0].mqflags &= ~SR_MQFLAG_RMS;
+ devc->channel_meaning[0].mqflags |= SR_MQFLAG_DC;
+
+ return mooshimeter_dmm_set_chooser(sdi, "CH1:ANALYSIS",
+ "CH1:ANALYSIS:MEAN");
+}
+
+static int set_channel1_rms(const struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc = sdi->priv;
+ devc->channel_meaning[0].mqflags &= ~SR_MQFLAG_DC;
+ devc->channel_meaning[0].mqflags |= SR_MQFLAG_RMS;
+
+ return mooshimeter_dmm_set_chooser(sdi, "CH1:ANALYSIS",
+ "CH1:ANALYSIS:RMS");
+}
+
+static int set_channel1_buffer(const struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc = sdi->priv;
+ devc->channel_meaning[0].mqflags &= ~(SR_MQFLAG_DC | SR_MQFLAG_RMS);
+
+ return mooshimeter_dmm_set_chooser(sdi, "CH1:ANALYSIS",
+ "CH1:ANALYSIS:BUFFER");
+}
+
+static int set_channel2_mean(const struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc = sdi->priv;
+ devc->channel_meaning[1].mqflags &= ~SR_MQFLAG_RMS;
+ devc->channel_meaning[1].mqflags |= SR_MQFLAG_DC;
+
+ return mooshimeter_dmm_set_chooser(sdi, "CH2:ANALYSIS",
+ "CH2:ANALYSIS:MEAN");
+}
+
+static int set_channel2_rms(const struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc = sdi->priv;
+ devc->channel_meaning[1].mqflags &= ~SR_MQFLAG_DC;
+ devc->channel_meaning[1].mqflags |= SR_MQFLAG_RMS;
+
+ return mooshimeter_dmm_set_chooser(sdi, "CH2:ANALYSIS",
+ "CH2:ANALYSIS:RMS");
+}
+
+static int set_channel2_buffer(const struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc = sdi->priv;
+
+ devc->channel_meaning[1].mqflags &= ~(SR_MQFLAG_DC | SR_MQFLAG_RMS);
+
+ return mooshimeter_dmm_set_chooser(sdi, "CH2:ANALYSIS",
+ "CH2:ANALYSIS:BUFFER");
+}
+
+static void autorange_channel1_current(const struct sr_dev_inst *sdi,
+ float value)
+{
+ mooshimeter_dmm_set_autorange(sdi, "CH1:RANGE_I",
+ "CH1:MAPPING:CURRENT", value);
+}
+
+static int configure_channel1_current(const struct sr_dev_inst *sdi,
+ float range)
+{
+ struct dev_context *devc = sdi->priv;
+ int ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "CH1:MAPPING",
+ "CH1:MAPPING:CURRENT");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_larger_number(sdi, "CH1:RANGE_I",
+ "CH1:MAPPING:CURRENT", range);
+ if (ret != SR_OK)
+ return ret;
+
+ if (range <= 0) {
+ devc->channel_autorange[0] = autorange_channel1_current;
+ devc->channel_meaning[0].mqflags |= SR_MQFLAG_AUTORANGE;
+ } else {
+ devc->channel_autorange[0] = NULL;
+ devc->channel_meaning[0].mqflags &= ~SR_MQFLAG_AUTORANGE;
+ }
+
+ devc->channel_meaning[0].mqflags &= ~SR_MQFLAG_DIODE;
+ devc->channel_meaning[0].mq = SR_MQ_CURRENT;
+ devc->channel_meaning[0].unit = SR_UNIT_AMPERE;
+
+ return SR_OK;
+}
+
+static void autorange_channel1_temperature(const struct sr_dev_inst *sdi,
+ float value)
+{
+ mooshimeter_dmm_set_autorange(sdi, "CH1:RANGE_I",
+ "CH1:MAPPING:TEMP", value);
+}
+
+static int configure_channel1_temperature(const struct sr_dev_inst *sdi,
+ float range)
+{
+ struct dev_context *devc = sdi->priv;
+ int ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "CH1:MAPPING",
+ "CH1:MAPPING:TEMP");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_larger_number(sdi, "CH1:RANGE_I",
+ "CH1:MAPPING:TEMP", range);
+ if (ret != SR_OK)
+ return ret;
+
+ if (range <= 0) {
+ devc->channel_autorange[0] = autorange_channel1_temperature;
+ devc->channel_meaning[0].mqflags |= SR_MQFLAG_AUTORANGE;
+ } else {
+ devc->channel_autorange[0] = NULL;
+ devc->channel_meaning[0].mqflags &= ~SR_MQFLAG_AUTORANGE;
+ }
+
+ devc->channel_meaning[0].mqflags &= ~SR_MQFLAG_DIODE;
+ devc->channel_meaning[0].mq = SR_MQ_TEMPERATURE;
+ devc->channel_meaning[0].unit = SR_UNIT_KELVIN;
+
+ return SR_OK;
+}
+
+static void autorange_channel1_auxv(const struct sr_dev_inst *sdi,
+ float value)
+{
+ mooshimeter_dmm_set_autorange(sdi, "CH1:RANGE_I",
+ "SHARED:AUX_V", value);
+}
+
+static int configure_channel1_auxv(const struct sr_dev_inst *sdi,
+ float range)
+{
+ struct dev_context *devc = sdi->priv;
+ int ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "SHARED", "SHARED:AUX_V");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "CH1:MAPPING",
+ "CH1:MAPPING:SHARED");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_larger_number(sdi, "CH1:RANGE_I",
+ "SHARED:AUX_V", range);
+ if (ret != SR_OK)
+ return ret;
+
+ if (range <= 0) {
+ devc->channel_autorange[0] = autorange_channel1_auxv;
+ devc->channel_meaning[0].mqflags |= SR_MQFLAG_AUTORANGE;
+ } else {
+ devc->channel_autorange[0] = NULL;
+ devc->channel_meaning[0].mqflags &= ~SR_MQFLAG_AUTORANGE;
+ }
+
+ devc->channel_meaning[0].mqflags &= ~SR_MQFLAG_DIODE;
+ devc->channel_meaning[0].mq = SR_MQ_VOLTAGE;
+ devc->channel_meaning[0].unit = SR_UNIT_VOLT;
+
+ return SR_OK;
+}
+
+static void autorange_channel1_resistance(const struct sr_dev_inst *sdi,
+ float value)
+{
+ mooshimeter_dmm_set_autorange(sdi, "CH1:RANGE_I",
+ "SHARED:RESISTANCE", value);
+}
+
+static int configure_channel1_resistance(const struct sr_dev_inst *sdi,
+ float range)
+{
+ struct dev_context *devc = sdi->priv;
+ int ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "SHARED", "SHARED:RESISTANCE");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "CH1:MAPPING",
+ "CH1:MAPPING:SHARED");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_larger_number(sdi, "CH1:RANGE_I",
+ "SHARED:RESISTANCE", range);
+ if (ret != SR_OK)
+ return ret;
+
+ if (range <= 0) {
+ devc->channel_autorange[0] = autorange_channel1_resistance;
+ devc->channel_meaning[0].mqflags |= SR_MQFLAG_AUTORANGE;
+ } else {
+ devc->channel_autorange[0] = NULL;
+ devc->channel_meaning[0].mqflags &= ~SR_MQFLAG_AUTORANGE;
+ }
+
+ devc->channel_meaning[0].mqflags &= ~SR_MQFLAG_DIODE;
+ devc->channel_meaning[0].mq = SR_MQ_RESISTANCE;
+ devc->channel_meaning[0].unit = SR_UNIT_OHM;
+
+ return SR_OK;
+}
+
+static void autorange_channel1_diode(const struct sr_dev_inst *sdi,
+ float value)
+{
+ mooshimeter_dmm_set_autorange(sdi, "CH1:RANGE_I",
+ "SHARED:DIODE", value);
+}
+
+static int configure_channel1_diode(const struct sr_dev_inst *sdi,
+ float range)
+{
+ struct dev_context *devc = sdi->priv;
+ int ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "SHARED", "SHARED:DIODE");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "CH1:MAPPING",
+ "CH1:MAPPING:SHARED");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_larger_number(sdi, "CH1:RANGE_I",
+ "SHARED:DIODE", range);
+ if (ret != SR_OK)
+ return ret;
+
+ if (range <= 0) {
+ devc->channel_autorange[0] = autorange_channel1_diode;
+ devc->channel_meaning[0].mqflags |= SR_MQFLAG_AUTORANGE;
+ } else {
+ devc->channel_autorange[0] = NULL;
+ devc->channel_meaning[0].mqflags &= ~SR_MQFLAG_AUTORANGE;
+ }
+
+ devc->channel_meaning[0].mqflags |= SR_MQFLAG_DIODE;
+ devc->channel_meaning[0].mq = SR_MQ_VOLTAGE;
+ devc->channel_meaning[0].unit = SR_UNIT_VOLT;
+
+ return SR_OK;
+}
+
+static void autorange_channel2_voltage(const struct sr_dev_inst *sdi,
+ float value)
+{
+ mooshimeter_dmm_set_autorange(sdi, "CH2:RANGE_I",
+ "CH2:MAPPING:VOLTAGE", value);
+}
+
+static int configure_channel2_voltage(const struct sr_dev_inst *sdi,
+ float range)
+{
+ struct dev_context *devc = sdi->priv;
+ int ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "CH2:MAPPING",
+ "CH2:MAPPING:VOLTAGE");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_larger_number(sdi, "CH2:RANGE_I",
+ "CH2:MAPPING:VOLTAGE", range);
+ if (ret != SR_OK)
+ return ret;
+
+ if (range <= 0) {
+ devc->channel_autorange[1] = autorange_channel2_voltage;
+ devc->channel_meaning[1].mqflags |= SR_MQFLAG_AUTORANGE;
+ } else {
+ devc->channel_autorange[1] = NULL;
+ devc->channel_meaning[1].mqflags &= ~SR_MQFLAG_AUTORANGE;
+ }
+
+ devc->channel_meaning[1].mqflags &= ~SR_MQFLAG_DIODE;
+ devc->channel_meaning[1].mq = SR_MQ_VOLTAGE;
+ devc->channel_meaning[1].unit = SR_UNIT_VOLT;
+
+ return SR_OK;
+}
+
+static void autorange_channel2_temperature(const struct sr_dev_inst *sdi,
+ float value)
+{
+ mooshimeter_dmm_set_autorange(sdi, "CH2:RANGE_I",
+ "CH2:MAPPING:TEMP", value);
+}
+
+static int configure_channel2_temperature(const struct sr_dev_inst *sdi,
+ float range)
+{
+ struct dev_context *devc = sdi->priv;
+ int ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "CH2:MAPPING",
+ "CH2:MAPPING:TEMP");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_larger_number(sdi, "CH2:RANGE_I",
+ "CH2:MAPPING:TEMP", range);
+ if (ret != SR_OK)
+ return ret;
+
+ if (range <= 0) {
+ devc->channel_autorange[1] = autorange_channel2_temperature;
+ devc->channel_meaning[1].mqflags |= SR_MQFLAG_AUTORANGE;
+ } else {
+ devc->channel_autorange[1] = NULL;
+ devc->channel_meaning[1].mqflags &= ~SR_MQFLAG_AUTORANGE;
+ }
+
+ devc->channel_meaning[1].mqflags &= ~SR_MQFLAG_DIODE;
+ devc->channel_meaning[1].mq = SR_MQ_TEMPERATURE;
+ devc->channel_meaning[1].unit = SR_UNIT_CELSIUS;
+
+ return SR_OK;
+}
+
+static void autorange_channel2_auxv(const struct sr_dev_inst *sdi,
+ float value)
+{
+ mooshimeter_dmm_set_autorange(sdi, "CH2:RANGE_I",
+ "SHARED:AUX_V", value);
+}
+
+static int configure_channel2_auxv(const struct sr_dev_inst *sdi,
+ float range)
+{
+ struct dev_context *devc = sdi->priv;
+ int ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "SHARED", "SHARED:AUX_V");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "CH2:MAPPING",
+ "CH2:MAPPING:SHARED");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_larger_number(sdi, "CH2:RANGE_I",
+ "SHARED:AUX_V", range);
+ if (ret != SR_OK)
+ return ret;
+
+ if (range <= 0) {
+ devc->channel_autorange[1] = autorange_channel2_auxv;
+ devc->channel_meaning[1].mqflags |= SR_MQFLAG_AUTORANGE;
+ } else {
+ devc->channel_autorange[1] = NULL;
+ devc->channel_meaning[1].mqflags &= ~SR_MQFLAG_AUTORANGE;
+ }
+
+ devc->channel_meaning[1].mqflags &= ~SR_MQFLAG_DIODE;
+ devc->channel_meaning[1].mq = SR_MQ_VOLTAGE;
+ devc->channel_meaning[1].unit = SR_UNIT_VOLT;
+
+ return SR_OK;
+}
+
+static void autorange_channel2_resistance(const struct sr_dev_inst *sdi,
+ float value)
+{
+ mooshimeter_dmm_set_autorange(sdi, "CH2:RANGE_I",
+ "SHARED:RESISTANCE", value);
+}
+
+static int configure_channel2_resistance(const struct sr_dev_inst *sdi,
+ float range)
+{
+ struct dev_context *devc = sdi->priv;
+ int ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "SHARED", "SHARED:RESISTANCE");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "CH2:MAPPING",
+ "CH2:MAPPING:SHARED");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_larger_number(sdi, "CH2:RANGE_I",
+ "SHARED:RESISTANCE", range);
+ if (ret != SR_OK)
+ return ret;
+
+ if (range <= 0) {
+ devc->channel_autorange[1] = autorange_channel2_resistance;
+ devc->channel_meaning[1].mqflags |= SR_MQFLAG_AUTORANGE;
+ } else {
+ devc->channel_autorange[1] = NULL;
+ devc->channel_meaning[1].mqflags &= ~SR_MQFLAG_AUTORANGE;
+ }
+
+ devc->channel_meaning[1].mqflags &= ~SR_MQFLAG_DIODE;
+ devc->channel_meaning[1].mq = SR_MQ_RESISTANCE;
+ devc->channel_meaning[1].unit = SR_UNIT_OHM;
+
+ return SR_OK;
+}
+
+static void autorange_channel2_diode(const struct sr_dev_inst *sdi,
+ float value)
+{
+ mooshimeter_dmm_set_autorange(sdi, "CH2:RANGE_I",
+ "SHARED:DIODE", value);
+}
+
+static int configure_channel2_diode(const struct sr_dev_inst *sdi,
+ float range)
+{
+ struct dev_context *devc = sdi->priv;
+ int ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "SHARED", "SHARED:DIODE");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "CH2:MAPPING",
+ "CH2:MAPPING:SHARED");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_larger_number(sdi, "CH2:RANGE_I",
+ "SHARED:DIODE", range);
+ if (ret != SR_OK)
+ return ret;
+
+ if (range <= 0) {
+ devc->channel_autorange[1] = autorange_channel2_diode;
+ devc->channel_meaning[1].mqflags |= SR_MQFLAG_AUTORANGE;
+ } else {
+ devc->channel_autorange[1] = NULL;
+ devc->channel_meaning[1].mqflags &= ~SR_MQFLAG_AUTORANGE;
+ }
+
+ devc->channel_meaning[1].mqflags |= SR_MQFLAG_DIODE;
+ devc->channel_meaning[1].mq = SR_MQ_VOLTAGE;
+ devc->channel_meaning[1].unit = SR_UNIT_VOLT;
+
+ return SR_OK;
+}
+
+/*
+ * Full string: CH1,CH2
+ * Each channel: MODE[:RANGE[:ANALYSIS]]
+ * Channel 1 mode:
+ * Current, A
+ * Temperature, T, K
+ * Resistance, Ohm, W
+ * Diode, D
+ * Aux, LV
+ * Channel 2 mode:
+ * Voltage, V
+ * Temperature, T, K
+ * Resistance, Ohm, W
+ * Diode, D
+ * Aux, LV
+ * Range is the upper bound of the range (e.g. 60 for 0-60 V or 600 for 0-600),
+ * zero or absent for autoranging
+ * Analysis:
+ * Mean, DC
+ * RMS, AC
+ * Buffer, Samples
+ */
+static int apply_channel_config(const struct sr_dev_inst *sdi,
+ const char *config)
+{
+ gchar **channel_config;
+ gchar **parameters;
+ const gchar *param;
+ int ret = SR_ERR;
+ float range;
+ gboolean shared_in_use = FALSE;
+
+ channel_config = g_strsplit_set(config, ",/", -1);
+ if (!channel_config[0])
+ goto err_free_channel_config;
+
+ parameters = g_strsplit_set(channel_config[0], ":;", -1);
+ if (parameters[0] && parameters[0][0]) {
+ range = 0;
+ if (parameters[1])
+ range = g_ascii_strtod(parameters[1], NULL);
+
+ param = parameters[0];
+ if (!g_ascii_strncasecmp(param, "Resistance", 10) ||
+ !g_ascii_strncasecmp(param, "Ohm", 3) ||
+ !g_ascii_strncasecmp(param, "W", 1) ||
+ !g_ascii_strncasecmp(param, "R", 1)) {
+ ret = configure_channel1_resistance(sdi, range);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ shared_in_use = TRUE;
+ } else if (!g_ascii_strncasecmp(param, "Diode", 5) ||
+ !g_ascii_strncasecmp(param, "D", 1)) {
+ ret = configure_channel1_diode(sdi, range);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ shared_in_use = TRUE;
+ } else if (!g_ascii_strncasecmp(param, "Aux", 3) ||
+ !g_ascii_strncasecmp(param, "LV", 2)) {
+ ret = configure_channel1_auxv(sdi, range);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ shared_in_use = TRUE;
+ } else if (!g_ascii_strncasecmp(param, "T", 1) ||
+ !g_ascii_strncasecmp(param, "K", 1)) {
+ ret = configure_channel1_temperature(sdi, range);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ } else if (!g_ascii_strncasecmp(param, "Current", 7) ||
+ !g_ascii_strncasecmp(param, "A", 1) ||
+ *parameters[0]) {
+ ret = configure_channel1_current(sdi, range);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ } else {
+ sr_info("Unrecognized mode for CH1: %s.", param);
+ ret = configure_channel1_current(sdi, range);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ }
+
+ if (parameters[1] && parameters[2]) {
+ param = parameters[2];
+ if (!g_ascii_strcasecmp(param, "RMS") ||
+ !g_ascii_strcasecmp(param, "AC")) {
+ ret = set_channel1_rms(sdi);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ } else if (!g_ascii_strcasecmp(param, "Buffer") ||
+ !g_ascii_strcasecmp(param, "Samples")) {
+ ret = set_channel1_buffer(sdi);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ } else {
+ ret = set_channel1_mean(sdi);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ }
+ }
+ }
+ g_strfreev(parameters);
+
+ if (!channel_config[1]) {
+ g_strfreev(channel_config);
+ return SR_OK;
+ }
+
+ parameters = g_strsplit_set(channel_config[1], ":;", -1);
+ if (parameters[0] && parameters[0][0]) {
+ range = 0;
+ if (parameters[1])
+ range = g_ascii_strtod(parameters[1], NULL);
+
+ param = parameters[0];
+ if (!g_ascii_strncasecmp(param, "Resistance", 10) ||
+ !g_ascii_strncasecmp(param, "Ohm", 3) ||
+ !g_ascii_strncasecmp(param, "W", 1) ||
+ !g_ascii_strncasecmp(param, "R", 1)) {
+ if (shared_in_use) {
+ ret = SR_ERR;
+ goto err_free_parameters;
+ }
+ ret = configure_channel2_resistance(sdi, range);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ } else if (!g_ascii_strncasecmp(param, "Diode", 5) ||
+ !g_ascii_strncasecmp(param, "D", 1)) {
+ if (shared_in_use) {
+ ret = SR_ERR;
+ goto err_free_parameters;
+ }
+ ret = configure_channel2_diode(sdi, range);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ } else if (!g_ascii_strncasecmp(param, "Aux", 3) ||
+ !g_ascii_strncasecmp(param, "LV", 2)) {
+ if (shared_in_use) {
+ ret = SR_ERR;
+ goto err_free_parameters;
+ }
+ ret = configure_channel2_auxv(sdi, range);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ } else if (!g_ascii_strncasecmp(param, "T", 1) ||
+ !g_ascii_strncasecmp(param, "K", 1)) {
+ ret = configure_channel2_temperature(sdi, range);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ } else if (!g_ascii_strncasecmp(param, "V", 1) ||
+ !param[0]) {
+ ret = configure_channel2_voltage(sdi, range);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ } else {
+ sr_info("Unrecognized mode for CH2: %s.", param);
+ ret = configure_channel2_voltage(sdi, range);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ }
+
+ if (parameters[1] && parameters[2]) {
+ param = parameters[2];
+ if (!g_ascii_strcasecmp(param, "RMS") ||
+ !g_ascii_strcasecmp(param, "AC")) {
+ ret = set_channel2_rms(sdi);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ } else if (!g_ascii_strcasecmp(param, "Buffer") ||
+ !g_ascii_strcasecmp(param, "Samples")) {
+ ret = set_channel2_buffer(sdi);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ } else {
+ ret = set_channel2_mean(sdi);
+ if (ret != SR_OK)
+ goto err_free_parameters;
+ }
+ }
+ }
+ g_strfreev(parameters);
+
+ g_strfreev(channel_config);
+ return SR_OK;
+
+err_free_parameters:
+ g_strfreev(parameters);
+err_free_channel_config:
+ g_strfreev(channel_config);
+ return ret;
+}
+
+static int dev_open(struct sr_dev_inst *sdi)
+{
+ int ret;
+
+ ret = mooshimeter_dmm_open(sdi);
+ if (ret != SR_OK)
+ return ret;
+
+ sdi->status = SR_ST_INACTIVE;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "SAMPLING:TRIGGER",
+ "SAMPLING:TRIGGER:OFF");
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_larger_number(sdi, "SAMPLING:RATE",
+ "SAMPLING:RATE", 125);
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_larger_number(sdi, "SAMPLING:DEPTH",
+ "SAMPLING:DEPTH", 64);
+ if (ret != SR_OK)
+ return ret;
+
+ /* Looks like these sometimes get set to 8, somehow? */
+ ret = mooshimeter_dmm_set_integer(sdi, "CH1:BUF_BPS", 24);
+ if (ret != SR_OK)
+ return ret;
+
+ ret = mooshimeter_dmm_set_integer(sdi, "CH2:BUF_BPS", 24);
+ if (ret != SR_OK)
+ return ret;
+
+ ret = configure_channel1_current(sdi, 0);
+ if (ret != SR_OK)
+ return ret;
+
+ ret = set_channel1_mean(sdi);
+ if (ret != SR_OK)
+ return ret;
+
+ ret = configure_channel2_voltage(sdi, 0);
+ if (ret != SR_OK)
+ return ret;
+
+ ret = set_channel2_mean(sdi);
+ if (ret != SR_OK)
+ return ret;
+
+ sdi->status = SR_ST_ACTIVE;
+
+ return SR_OK;
+}
+
+static int dev_close(struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc = sdi->priv;
+
+ sdi->status = SR_ST_INACTIVE;
+
+ g_slist_free(devc->channel_meaning[0].channels);
+ devc->channel_meaning[0].channels = NULL;
+
+ g_slist_free(devc->channel_meaning[1].channels);
+ devc->channel_meaning[1].channels = NULL;
+
+ g_slist_free(devc->channel_meaning[2].channels);
+ devc->channel_meaning[2].channels = NULL;
+
+ return mooshimeter_dmm_close(sdi);
+}
+
+static int config_get(uint32_t key, GVariant **data,
+ const struct sr_dev_inst *sdi,
+ const struct sr_channel_group *cg)
+{
+ struct dev_context *devc = sdi->priv;
+ int ret;
+ float value;
+
+ (void)cg;
+
+ switch (key) {
+ case SR_CONF_SAMPLERATE:
+ ret = mooshimeter_dmm_get_chosen_number(sdi, "SAMPLING:RATE",
+ "SAMPLING:RATE", &value);
+ if (ret != SR_OK)
+ return ret;
+ *data = g_variant_new_uint64((guint64)value);
+ return SR_OK;
+ case SR_CONF_AVG_SAMPLES:
+ ret = mooshimeter_dmm_get_chosen_number(sdi, "SAMPLING:DEPTH",
+ "SAMPLING:DEPTH", &value);
+ if (ret != SR_OK)
+ return ret;
+ *data = g_variant_new_uint64((guint64)value);
+ return SR_OK;
+ case SR_CONF_CHANNEL_CONFIG:
+ return SR_ERR_NA;
+ default:
+ break;
+ }
+
+ return sr_sw_limits_config_get(&devc->limits, key, data);
+}
+
+static int config_set(uint32_t key, GVariant *data,
+ const struct sr_dev_inst *sdi,
+ const struct sr_channel_group *cg)
+{
+ struct dev_context *devc = sdi->priv;
+
+ (void)cg;
+
+ switch (key) {
+ case SR_CONF_SAMPLERATE:
+ return mooshimeter_dmm_set_larger_number(sdi, "SAMPLING:RATE",
+ "SAMPLING:RATE", g_variant_get_uint64(data));
+ case SR_CONF_AVG_SAMPLES:
+ return mooshimeter_dmm_set_larger_number(sdi, "SAMPLING:DEPTH",
+ "SAMPLING:DEPTH", g_variant_get_uint64(data));
+ case SR_CONF_CHANNEL_CONFIG:
+ return apply_channel_config(sdi, g_variant_get_string(data, NULL));
+ default:
+ break;
+ }
+
+ return sr_sw_limits_config_set(&devc->limits, key, data);
+}
+
+static int config_list(uint32_t key, GVariant **data,
+ const struct sr_dev_inst *sdi,
+ const struct sr_channel_group *cg)
+{
+ int ret;
+ float *values;
+ size_t count;
+ uint64_t *integers;
+
+ switch (key) {
+ case SR_CONF_SAMPLERATE:
+ ret = mooshimeter_dmm_get_available_number_choices(sdi,
+ "SAMPLING:RATE", &values, &count);
+ if (ret != SR_OK)
+ return ret;
+ integers = g_malloc(sizeof(uint64_t) * count);
+ for (size_t i = 0; i < count; i++)
+ integers[i] = (uint64_t)values[i];
+ g_free(values);
+ *data = std_gvar_samplerates(integers, count);
+ g_free(integers);
+ return SR_OK;
+ case SR_CONF_AVG_SAMPLES:
+ ret = mooshimeter_dmm_get_available_number_choices(sdi,
+ "SAMPLING:DEPTH", &values, &count);
+ if (ret != SR_OK)
+ return ret;
+ integers = g_malloc(sizeof(uint64_t) * count);
+ for (size_t i = 0; i < count; i++)
+ integers[i] = (uint64_t)values[i];
+ g_free(values);
+ *data = std_gvar_array_u64(integers, count);
+ g_free(integers);
+ return SR_OK;
+ case SR_CONF_CHANNEL_CONFIG:
+ return SR_ERR_NA;
+ default:
+ break;
+ }
+
+ return STD_CONFIG_LIST(key, data, sdi, cg, scanopts, drvopts, devopts);
+}
+
+static int dev_acquisition_start(const struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc = sdi->priv;
+ int ret;
+
+ ret = mooshimeter_dmm_set_chooser(sdi, "SAMPLING:TRIGGER",
+ "SAMPLING:TRIGGER:CONTINUOUS");
+ if (ret)
+ return ret;
+
+ sr_sw_limits_acquisition_start(&devc->limits);
+ std_session_send_df_header(sdi);
+
+ sr_session_source_add(sdi->session, -1, 0, 10000,
+ mooshimeter_dmm_heartbeat, (void *)sdi);
+
+ /* The Bluetooth socket isn't exposed, so just poll for data. */
+ sr_session_source_add(sdi->session, -2, 0, 50,
+ mooshimeter_dmm_poll, (void *)sdi);
+
+ devc->enable_value_stream = TRUE;
+
+ return SR_OK;
+}
+
+static int dev_acquisition_stop(struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc = sdi->priv;
+
+ sr_session_source_remove(sdi->session, -1);
+ sr_session_source_remove(sdi->session, -2);
+ devc->enable_value_stream = FALSE;
+
+ mooshimeter_dmm_set_chooser(sdi, "SAMPLING:TRIGGER",
+ "SAMPLING:TRIGGER:OFF");
+
+ return SR_OK;
+}
+
+static struct sr_dev_driver mooshimeter_dmm_driver_info = {
+ .name = "mooshimeter-dmm",
+ .longname = "Mooshimeter DMM",
+ .api_version = 1,
+ .init = std_init,
+ .cleanup = std_cleanup,
+ .scan = scan,
+ .dev_list = std_dev_list,
+ .dev_clear = dev_clear,
+ .config_get = config_get,
+ .config_set = config_set,
+ .config_list = config_list,
+ .dev_open = dev_open,
+ .dev_close = dev_close,
+ .dev_acquisition_start = dev_acquisition_start,
+ .dev_acquisition_stop = dev_acquisition_stop,
+ .context = NULL,
+};
+SR_REGISTER_DEV_DRIVER(mooshimeter_dmm_driver_info);