[libsigrok.git] / hardware / gmc-mh-1x-2x / api.c

/*
 * This file is part of the libsigrok project.
 *
 * Copyright (C) 2013 Matthias Heidbrink <m-sigrok@heidbrink.biz>
 *
 * 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 <string.h>

#include "protocol.h"

/* Serial communication parameters for Metrahit 1x/2x with 'RS232' adaptor */
#define SERIALCOMM_1X_RS232 "8228/6n1/dtr=1/rts=1/flow=0" /* =8192, closer with divider */
#define SERIALCOMM_2X_RS232 "9600/6n1/dtr=1/rts=1/flow=0"
#define VENDOR_GMC "Gossen Metrawatt"

SR_PRIV struct sr_dev_driver gmc_mh_1x_2x_rs232_driver_info;

static const int32_t hwopts[] = {
	SR_CONF_CONN,
	SR_CONF_SERIALCOMM,
};

static const int32_t hwcaps[] = {
	SR_CONF_MULTIMETER,
	SR_CONF_LIMIT_SAMPLES,
	SR_CONF_LIMIT_MSEC,
	SR_CONF_CONTINUOUS,
};

/** Driver init function */
static int init_1x_2x_rs232(struct sr_context *sr_ctx)
{
	return std_init(sr_ctx, &gmc_mh_1x_2x_rs232_driver_info, LOG_PREFIX);
}


/** Read single byte from serial port.
 *  \retval -1 Timeout or error.
 *  \retval other Byte.
 */
static int read_byte(struct sr_serial_dev_inst *serial, gint64 timeout)
{
	guint8 result = 0;
	int rc = 0;

	for (;;) {
		rc = serial_read(serial, &result, 1);
		if (rc == 1) {
			sr_spew("read: 0x%02x/%d", result, result);
			return result;
		}
		if (g_get_monotonic_time() > timeout)
			return -1;
		g_usleep(2000);
	}
}

/** Try to detect GMC 1x/2x multimeter model in send mode for max. 1 second.
 *  \param serial Configured, open serial port.
 *
 *  \retval NULL Detection failed.
 *  \retval other Model code.
 */
static enum model scan_model_sm(struct sr_serial_dev_inst *serial)
{
	int byte, bytecnt, cnt;
	enum model model;
	gint64 timeout_us;

	model = SR_METRAHIT_NONE;
	timeout_us = g_get_monotonic_time() + 1*1000*1000;

	/* Try to find message consisting of device code and several
	 * (at least 4) data bytes. */
	for (bytecnt = 0; bytecnt < 100; bytecnt++) {
		byte = read_byte(serial, timeout_us);
		if ((byte == -1) || (timeout_us < g_get_monotonic_time()))
			break;
		if ((byte & MSGID_MASK) == MSGID_INF) {
			if (!(model = sr_gmc_decode_model_sm(byte & MSGC_MASK)))
				break;
			/* Now expect (at least) 4 data bytes */
			for (cnt = 0; cnt < 4; cnt++) {
				byte = read_byte(serial, timeout_us);
				if ((byte == -1) ||
					((byte & MSGID_MASK) != MSGID_DATA))
				{
					model = SR_METRAHIT_NONE;
					bytecnt = 100;
					break;
				}
			}
			break;
		}
	}

	return model;
}

/** Scan for Metrahit 1x and Metrahit 2x in send mode using Gossen Metrawatt
 *  'RS232' interface. The older 1x models use 8192 and the newer 2x 9600 baud.
 *  The DMM usually sends up to about 20 messages per second. However, depending
 *  on configuration and measurement mode the intervals can be much larger and
 *  then the detection might not work.
 */
static GSList *scan_1x_2x_rs232(GSList *options)
{
	struct sr_dev_inst *sdi;
	struct drv_context *drvc;
	struct dev_context *devc;
	struct sr_config *src;
	struct sr_probe *probe;
	struct sr_serial_dev_inst *serial;
	GSList *l, *devices;
	const char *conn, *serialcomm;
	enum model model;
	gboolean serialcomm_given;
	int cnt;

	devices = NULL;
	drvc = (&gmc_mh_1x_2x_rs232_driver_info)->priv;
	drvc->instances = NULL;
	conn = serialcomm = NULL;
	model = SR_METRAHIT_NONE;
	serialcomm_given = FALSE;

	sr_spew("scan_1x_2x_rs232() called!");

	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;
		case SR_CONF_SERIALCOMM:
			serialcomm = g_variant_get_string(src->data, NULL);
			serialcomm_given = TRUE;
			break;
		}
	}
	if (!conn)
		return NULL;
	if (!serialcomm)
		serialcomm = SERIALCOMM_2X_RS232;

	if (!(serial = sr_serial_dev_inst_new(conn, serialcomm)))
		return NULL;

	if (serial_open(serial, SERIAL_RDWR | SERIAL_NONBLOCK) != SR_OK) {
		sr_serial_dev_inst_free(serial);
		return NULL;
	}

	serial_flush(serial);

	model = scan_model_sm(serial);

	/* If detection failed and no user-supplied parameters,
	 * try second baud rate. */
	if ((model == SR_METRAHIT_NONE) && !serialcomm_given) {
		serialcomm = SERIALCOMM_1X_RS232;
		g_free(serial->serialcomm);
		serial->serialcomm = g_strdup(serialcomm);
		if (serial_set_paramstr(serial, serialcomm) == SR_OK) {
			serial_flush(serial);
			model = scan_model_sm(serial);
		}
	}

	if (model != SR_METRAHIT_NONE) {
		sr_spew("%s %s detected!", VENDOR_GMC, sr_gmc_model_str(model));
		if (!(sdi = sr_dev_inst_new(0, SR_ST_INACTIVE, VENDOR_GMC,
				sr_gmc_model_str(model), "")))
			return NULL;
		if (!(devc = g_try_malloc0(sizeof(struct dev_context)))) {
			sr_err("Device context malloc failed.");
			return NULL;
		}
		devc->model = model;
		devc->limit_samples = 0;
		devc->limit_msec = 0;
		devc->num_samples = 0;
		devc->elapsed_msec = g_timer_new();
		devc->settings_ok = FALSE;

		sdi->conn = serial;
		sdi->priv = devc;
		sdi->driver = &gmc_mh_1x_2x_rs232_driver_info;
		if (!(probe = sr_probe_new(0, SR_PROBE_ANALOG, TRUE, "P1")))
			return NULL;
		sdi->probes = g_slist_append(sdi->probes, probe);
		drvc->instances = g_slist_append(drvc->instances, sdi);
		devices = g_slist_append(devices, sdi);
	}

	return devices;
}

/** Driver device list function */
static GSList *dev_list_1x_2x_rs232(void)
{
	return ((struct drv_context *)(gmc_mh_1x_2x_rs232_driver_info.priv))
			->instances;
}

static int dev_clear_1x_2x_rs232(void)
{
	return std_dev_clear(&gmc_mh_1x_2x_rs232_driver_info, NULL);
}

static int dev_open(struct sr_dev_inst *sdi)
{
	struct sr_serial_dev_inst *serial = sdi->conn;
	if (serial_open(serial, SERIAL_RDWR | SERIAL_NONBLOCK) != SR_OK)
		return SR_ERR;

	sdi->status = SR_ST_ACTIVE;

	return SR_OK;
}

static int dev_close(struct sr_dev_inst *sdi)
{
	struct sr_serial_dev_inst *serial;
	struct dev_context *devc;

	serial = sdi->conn;
	if (serial && serial->fd != -1) {
		serial_close(serial);
		sdi->status = SR_ST_INACTIVE;
	}

	sdi->status = SR_ST_INACTIVE;

	/* Free dynamically allocated resources. */
	if ((devc = sdi->priv) && devc->elapsed_msec) {
		g_timer_destroy(devc->elapsed_msec);
		devc->elapsed_msec = NULL;
		devc->model = SR_METRAHIT_NONE;
	}

	return SR_OK;
}

static int cleanup_sm_rs232(void)
{
	return dev_clear_1x_2x_rs232();
}

/** TODO */
static int config_get(int key, GVariant **data, const struct sr_dev_inst *sdi,
		const struct sr_probe_group *probe_group)
{
	int ret;

	(void)sdi;
	(void)data;
	(void)probe_group;

	ret = SR_OK;
	switch (key) {
	/* TODO */
	default:
		return SR_ERR_NA;
	}

	return ret;
}

static int config_set(int key, GVariant *data, const struct sr_dev_inst *sdi,
		const struct sr_probe_group *probe_group)
{
	struct dev_context *devc;

	(void)probe_group;

	if (sdi->status != SR_ST_ACTIVE)
		return SR_ERR_DEV_CLOSED;

	if (!(devc = sdi->priv)) {
		sr_err("sdi->priv was NULL.");
		return SR_ERR_BUG;
	}

	switch (key) {
	case SR_CONF_LIMIT_MSEC:
		if (g_variant_get_uint64(data) == 0) {
			sr_err("LIMIT_MSEC can't be 0.");
			return SR_ERR;
		}
		devc->limit_msec = g_variant_get_uint64(data);
		sr_dbg("Setting time limit to %" PRIu64 "ms.",
		       devc->limit_msec);
		break;
	case SR_CONF_LIMIT_SAMPLES:
		devc->limit_samples = g_variant_get_uint64(data);
		sr_dbg("Setting sample limit to %" PRIu64 ".",
		       devc->limit_samples);
		break;
	default:
		return SR_ERR_NA;
	}

	return SR_OK;
}

static int config_list(int key, GVariant **data, const struct sr_dev_inst *sdi,
		const struct sr_probe_group *probe_group)
{
	(void)sdi;

	switch (key) {
	case SR_CONF_SCAN_OPTIONS:
		*data = g_variant_new_fixed_array(G_VARIANT_TYPE_INT32,
				hwopts, ARRAY_SIZE(hwopts), sizeof(int32_t));
		break;
	case SR_CONF_DEVICE_OPTIONS:
		*data = g_variant_new_fixed_array(G_VARIANT_TYPE_INT32,
				hwcaps, ARRAY_SIZE(hwcaps), sizeof(int32_t));
		break;
	default:
		return SR_ERR_NA;
	}

	return SR_OK;
}

static int dev_acq_start_1x_2x_rs232(const struct sr_dev_inst *sdi,
				    void *cb_data)
{
	struct dev_context *devc;
	struct sr_serial_dev_inst *serial;

	if (!sdi || !cb_data || !(devc = sdi->priv))
		return SR_ERR_BUG;

	if (sdi->status != SR_ST_ACTIVE)
		return SR_ERR_DEV_CLOSED;

	devc->cb_data = cb_data;
	devc->settings_ok = FALSE;
	devc->buflen = 0;

	/* Send header packet to the session bus. */
	std_session_send_df_header(cb_data, LOG_PREFIX);

	/* Start timer, if required. */
	if (devc->limit_msec)
		g_timer_start(devc->elapsed_msec);

	/* Poll every 40ms, or whenever some data comes in. */
	serial = sdi->conn;
	serial_source_add(serial, G_IO_IN, 40, gmc_mh_1x_2x_receive_data,
		(void *)sdi);

	return SR_OK;
}

static int dev_acq_stop(struct sr_dev_inst *sdi, void *cb_data)
{
	struct dev_context *devc;

	/* Stop timer, if required. */
	if (sdi && (devc = sdi->priv) && devc->limit_msec)
		g_timer_stop(devc->elapsed_msec);

	return std_dev_acquisition_stop_serial(sdi, cb_data, dev_close,
			sdi->conn, LOG_PREFIX);
}

SR_PRIV struct sr_dev_driver gmc_mh_1x_2x_rs232_driver_info = {
	.name = "gmc-mh-1x-2x-rs232",
	.longname =
		"Gossen Metrawatt Metrahit 1x/2x DMMs, 'RS232' Interface",
	.api_version = 1,
	.init = init_1x_2x_rs232,
	.cleanup = cleanup_sm_rs232,
	.scan = scan_1x_2x_rs232,
	.dev_list = dev_list_1x_2x_rs232,
	.dev_clear = dev_clear_1x_2x_rs232,
	.config_get = config_get,
	.config_set = config_set,
	.config_list = config_list,
	.dev_open = dev_open,
	.dev_close = dev_close,
	.dev_acquisition_start = dev_acq_start_1x_2x_rs232,
	.dev_acquisition_stop = dev_acq_stop,
	.priv = NULL,
};
Commit	Line	Data
7b4edcb6 MH	1	/*
	2	* This file is part of the libsigrok project.
	3	*
	4	* Copyright (C) 2013 Matthias Heidbrink <m-sigrok@heidbrink.biz>
	5	*
	6	* This program is free software: you can redistribute it and/or modify
	7	* it under the terms of the GNU General Public License as published by
	8	* the Free Software Foundation, either version 3 of the License, or
	9	* (at your option) any later version.
	10	*
	11	* This program is distributed in the hope that it will be useful,
	12	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	13	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	14	* GNU General Public License for more details.
	15	*
	16	* You should have received a copy of the GNU General Public License
	17	* along with this program. If not, see <http://www.gnu.org/licenses/>.
	18	*/
	19
f5792417 MH	20	#include <string.h>
f5792417 MH	21
7b4edcb6 MH	22	#include "protocol.h"
7b4edcb6 MH	23
f5792417 MH	24	/* Serial communication parameters for Metrahit 1x/2x with 'RS232' adaptor */
	25	#define SERIALCOMM_1X_RS232 "8228/6n1/dtr=1/rts=1/flow=0" /* =8192, closer with divider */
	26	#define SERIALCOMM_2X_RS232 "9600/6n1/dtr=1/rts=1/flow=0"
	27	#define VENDOR_GMC "Gossen Metrawatt"
	28
7b4edcb6	29	SR_PRIV struct sr_dev_driver gmc_mh_1x_2x_rs232_driver_info;
7b4edcb6	30
f5792417 MH	31	static const int32_t hwopts[] = {
	32	SR_CONF_CONN,
	33	SR_CONF_SERIALCOMM,
	34	};
	35
	36	static const int32_t hwcaps[] = {
	37	SR_CONF_MULTIMETER,
	38	SR_CONF_LIMIT_SAMPLES,
	39	SR_CONF_LIMIT_MSEC,
	40	SR_CONF_CONTINUOUS,
	41	};
	42
	43	/** Driver init function */
	44	static int init_1x_2x_rs232(struct sr_context *sr_ctx)
7b4edcb6	45	{
f5792417	46	return std_init(sr_ctx, &gmc_mh_1x_2x_rs232_driver_info, LOG_PREFIX);
7b4edcb6 MH	47	}
7b4edcb6 MH	48
f5792417 MH	49
	50	/** Read single byte from serial port.
	51	* \retval -1 Timeout or error.
	52	* \retval other Byte.
	53	*/
	54	static int read_byte(struct sr_serial_dev_inst *serial, gint64 timeout)
7b4edcb6	55	{
f5792417 MH	56	guint8 result = 0;
	57	int rc = 0;
	58
	59	for (;;) {
	60	rc = serial_read(serial, &result, 1);
	61	if (rc == 1) {
	62	sr_spew("read: 0x%02x/%d", result, result);
	63	return result;
	64	}
	65	if (g_get_monotonic_time() > timeout)
	66	return -1;
	67	g_usleep(2000);
	68	}
	69	}
	70
	71	/** Try to detect GMC 1x/2x multimeter model in send mode for max. 1 second.
	72	* \param serial Configured, open serial port.
	73	*
	74	* \retval NULL Detection failed.
	75	* \retval other Model code.
	76	*/
	77	static enum model scan_model_sm(struct sr_serial_dev_inst *serial)
	78	{
	79	int byte, bytecnt, cnt;
	80	enum model model;
	81	gint64 timeout_us;
	82
	83	model = SR_METRAHIT_NONE;
	84	timeout_us = g_get_monotonic_time() + 110001000;
	85
	86	/* Try to find message consisting of device code and several
	87	* (at least 4) data bytes. */
	88	for (bytecnt = 0; bytecnt < 100; bytecnt++) {
	89	byte = read_byte(serial, timeout_us);
	90	if ((byte == -1) \|\| (timeout_us < g_get_monotonic_time()))
	91	break;
	92	if ((byte & MSGID_MASK) == MSGID_INF) {
	93	if (!(model = sr_gmc_decode_model_sm(byte & MSGC_MASK)))
	94	break;
	95	/* Now expect (at least) 4 data bytes */
	96	for (cnt = 0; cnt < 4; cnt++) {
	97	byte = read_byte(serial, timeout_us);
	98	if ((byte == -1) \|\|
	99	((byte & MSGID_MASK) != MSGID_DATA))
	100	{
	101	model = SR_METRAHIT_NONE;
	102	bytecnt = 100;
	103	break;
	104	}
	105	}
	106	break;
	107	}
	108	}
7b4edcb6	109
f5792417 MH	110	return model;
	111	}
	112
	113	/** Scan for Metrahit 1x and Metrahit 2x in send mode using Gossen Metrawatt
	114	* 'RS232' interface. The older 1x models use 8192 and the newer 2x 9600 baud.
	115	* The DMM usually sends up to about 20 messages per second. However, depending
	116	* on configuration and measurement mode the intervals can be much larger and
	117	* then the detection might not work.
	118	*/
	119	static GSList scan_1x_2x_rs232(GSList options)
	120	{
	121	struct sr_dev_inst *sdi;
	122	struct drv_context *drvc;
	123	struct dev_context *devc;
	124	struct sr_config *src;
	125	struct sr_probe *probe;
	126	struct sr_serial_dev_inst *serial;
	127	GSList l, devices;
	128	const char conn, serialcomm;
	129	enum model model;
	130	gboolean serialcomm_given;
	131	int cnt;
7b4edcb6 MH	132
7b4edcb6 MH	133	devices = NULL;
f5792417	134	drvc = (&gmc_mh_1x_2x_rs232_driver_info)->priv;
7b4edcb6	135	drvc->instances = NULL;
f5792417 MH	136	conn = serialcomm = NULL;
	137	model = SR_METRAHIT_NONE;
	138	serialcomm_given = FALSE;
	139
	140	sr_spew("scan_1x_2x_rs232() called!");
	141
	142	for (l = options; l; l = l->next) {
	143	src = l->data;
	144	switch (src->key) {
	145	case SR_CONF_CONN:
	146	conn = g_variant_get_string(src->data, NULL);
	147	break;
	148	case SR_CONF_SERIALCOMM:
	149	serialcomm = g_variant_get_string(src->data, NULL);
	150	serialcomm_given = TRUE;
	151	break;
	152	}
	153	}
	154	if (!conn)
	155	return NULL;
	156	if (!serialcomm)
	157	serialcomm = SERIALCOMM_2X_RS232;
	158
	159	if (!(serial = sr_serial_dev_inst_new(conn, serialcomm)))
	160	return NULL;
	161
	162	if (serial_open(serial, SERIAL_RDWR \| SERIAL_NONBLOCK) != SR_OK) {
	163	sr_serial_dev_inst_free(serial);
	164	return NULL;
	165	}
7b4edcb6	166
f5792417 MH	167	serial_flush(serial);
	168
	169	model = scan_model_sm(serial);
	170
	171	/* If detection failed and no user-supplied parameters,
	172	* try second baud rate. */
	173	if ((model == SR_METRAHIT_NONE) && !serialcomm_given) {
	174	serialcomm = SERIALCOMM_1X_RS232;
	175	g_free(serial->serialcomm);
	176	serial->serialcomm = g_strdup(serialcomm);
	177	if (serial_set_paramstr(serial, serialcomm) == SR_OK) {
	178	serial_flush(serial);
	179	model = scan_model_sm(serial);
	180	}
	181	}
	182
	183	if (model != SR_METRAHIT_NONE) {
	184	sr_spew("%s %s detected!", VENDOR_GMC, sr_gmc_model_str(model));
	185	if (!(sdi = sr_dev_inst_new(0, SR_ST_INACTIVE, VENDOR_GMC,
	186	sr_gmc_model_str(model), "")))
	187	return NULL;
	188	if (!(devc = g_try_malloc0(sizeof(struct dev_context)))) {
	189	sr_err("Device context malloc failed.");
	190	return NULL;
	191	}
	192	devc->model = model;
	193	devc->limit_samples = 0;
	194	devc->limit_msec = 0;
	195	devc->num_samples = 0;
	196	devc->elapsed_msec = g_timer_new();
	197	devc->settings_ok = FALSE;
	198
	199	sdi->conn = serial;
	200	sdi->priv = devc;
	201	sdi->driver = &gmc_mh_1x_2x_rs232_driver_info;
	202	if (!(probe = sr_probe_new(0, SR_PROBE_ANALOG, TRUE, "P1")))
	203	return NULL;
	204	sdi->probes = g_slist_append(sdi->probes, probe);
	205	drvc->instances = g_slist_append(drvc->instances, sdi);
	206	devices = g_slist_append(devices, sdi);
	207	}
7b4edcb6 MH	208
	209	return devices;
	210	}
	211
f5792417 MH	212	/** Driver device list function */
f5792417 MH	213	static GSList *dev_list_1x_2x_rs232(void)
7b4edcb6	214	{
f5792417 MH	215	return ((struct drv_context *)(gmc_mh_1x_2x_rs232_driver_info.priv))
f5792417 MH	216	->instances;
7b4edcb6 MH	217	}
7b4edcb6 MH	218
f5792417	219	static int dev_clear_1x_2x_rs232(void)
7b4edcb6	220	{
f5792417	221	return std_dev_clear(&gmc_mh_1x_2x_rs232_driver_info, NULL);
7b4edcb6 MH	222	}
	223
	224	static int dev_open(struct sr_dev_inst *sdi)
	225	{
f5792417 MH	226	struct sr_serial_dev_inst *serial = sdi->conn;
	227	if (serial_open(serial, SERIAL_RDWR \| SERIAL_NONBLOCK) != SR_OK)
	228	return SR_ERR;
7b4edcb6 MH	229
	230	sdi->status = SR_ST_ACTIVE;
	231
	232	return SR_OK;
	233	}
	234
	235	static int dev_close(struct sr_dev_inst *sdi)
	236	{
f5792417 MH	237	struct sr_serial_dev_inst *serial;
f5792417 MH	238	struct dev_context *devc;
7b4edcb6	239
f5792417 MH	240	serial = sdi->conn;
	241	if (serial && serial->fd != -1) {
	242	serial_close(serial);
	243	sdi->status = SR_ST_INACTIVE;
	244	}
7b4edcb6 MH	245
	246	sdi->status = SR_ST_INACTIVE;
	247
f5792417 MH	248	/* Free dynamically allocated resources. */
	249	if ((devc = sdi->priv) && devc->elapsed_msec) {
	250	g_timer_destroy(devc->elapsed_msec);
	251	devc->elapsed_msec = NULL;
	252	devc->model = SR_METRAHIT_NONE;
	253	}
	254
7b4edcb6 MH	255	return SR_OK;
	256	}
	257
f5792417	258	static int cleanup_sm_rs232(void)
7b4edcb6	259	{
f5792417	260	return dev_clear_1x_2x_rs232();
7b4edcb6 MH	261	}
7b4edcb6 MH	262
f5792417	263	/** TODO */
7b4edcb6 MH	264	static int config_get(int key, GVariant *data, const struct sr_dev_inst sdi,
	265	const struct sr_probe_group *probe_group)
	266	{
	267	int ret;
	268
	269	(void)sdi;
	270	(void)data;
	271	(void)probe_group;
	272
	273	ret = SR_OK;
	274	switch (key) {
	275	/* TODO */
	276	default:
	277	return SR_ERR_NA;
	278	}
	279
	280	return ret;
	281	}
	282
	283	static int config_set(int key, GVariant data, const struct sr_dev_inst sdi,
	284	const struct sr_probe_group *probe_group)
	285	{
f5792417	286	struct dev_context *devc;
7b4edcb6	287
7b4edcb6 MH	288	(void)probe_group;
	289
	290	if (sdi->status != SR_ST_ACTIVE)
	291	return SR_ERR_DEV_CLOSED;
	292
f5792417 MH	293	if (!(devc = sdi->priv)) {
	294	sr_err("sdi->priv was NULL.");
	295	return SR_ERR_BUG;
	296	}
	297
7b4edcb6	298	switch (key) {
f5792417 MH	299	case SR_CONF_LIMIT_MSEC:
	300	if (g_variant_get_uint64(data) == 0) {
	301	sr_err("LIMIT_MSEC can't be 0.");
	302	return SR_ERR;
	303	}
	304	devc->limit_msec = g_variant_get_uint64(data);
	305	sr_dbg("Setting time limit to %" PRIu64 "ms.",
	306	devc->limit_msec);
	307	break;
	308	case SR_CONF_LIMIT_SAMPLES:
	309	devc->limit_samples = g_variant_get_uint64(data);
	310	sr_dbg("Setting sample limit to %" PRIu64 ".",
	311	devc->limit_samples);
	312	break;
7b4edcb6	313	default:
f5792417	314	return SR_ERR_NA;
7b4edcb6 MH	315	}
7b4edcb6 MH	316
f5792417	317	return SR_OK;
7b4edcb6 MH	318	}
	319
	320	static int config_list(int key, GVariant *data, const struct sr_dev_inst sdi,
	321	const struct sr_probe_group *probe_group)
	322	{
7b4edcb6	323	(void)sdi;
7b4edcb6	324
7b4edcb6	325	switch (key) {
f5792417 MH	326	case SR_CONF_SCAN_OPTIONS:
	327	*data = g_variant_new_fixed_array(G_VARIANT_TYPE_INT32,
	328	hwopts, ARRAY_SIZE(hwopts), sizeof(int32_t));
	329	break;
	330	case SR_CONF_DEVICE_OPTIONS:
	331	*data = g_variant_new_fixed_array(G_VARIANT_TYPE_INT32,
	332	hwcaps, ARRAY_SIZE(hwcaps), sizeof(int32_t));
	333	break;
7b4edcb6 MH	334	default:
	335	return SR_ERR_NA;
	336	}
	337
f5792417	338	return SR_OK;
7b4edcb6 MH	339	}
7b4edcb6 MH	340
f5792417	341	static int dev_acq_start_1x_2x_rs232(const struct sr_dev_inst *sdi,
7b4edcb6 MH	342	void *cb_data)
7b4edcb6 MH	343	{
f5792417 MH	344	struct dev_context *devc;
	345	struct sr_serial_dev_inst *serial;
	346
	347	if (!sdi \|\| !cb_data \|\| !(devc = sdi->priv))
	348	return SR_ERR_BUG;
7b4edcb6 MH	349
	350	if (sdi->status != SR_ST_ACTIVE)
	351	return SR_ERR_DEV_CLOSED;
	352
f5792417 MH	353	devc->cb_data = cb_data;
	354	devc->settings_ok = FALSE;
	355	devc->buflen = 0;
	356
	357	/* Send header packet to the session bus. */
	358	std_session_send_df_header(cb_data, LOG_PREFIX);
	359
	360	/* Start timer, if required. */
	361	if (devc->limit_msec)
	362	g_timer_start(devc->elapsed_msec);
	363
	364	/* Poll every 40ms, or whenever some data comes in. */
	365	serial = sdi->conn;
abc4b335	366	serial_source_add(serial, G_IO_IN, 40, gmc_mh_1x_2x_receive_data,
f5792417	367	(void *)sdi);
7b4edcb6 MH	368
	369	return SR_OK;
	370	}
	371
f5792417	372	static int dev_acq_stop(struct sr_dev_inst sdi, void cb_data)
7b4edcb6	373	{
f5792417	374	struct dev_context *devc;
7b4edcb6	375
f5792417 MH	376	/* Stop timer, if required. */
	377	if (sdi && (devc = sdi->priv) && devc->limit_msec)
	378	g_timer_stop(devc->elapsed_msec);
7b4edcb6	379
f5792417 MH	380	return std_dev_acquisition_stop_serial(sdi, cb_data, dev_close,
f5792417 MH	381	sdi->conn, LOG_PREFIX);
7b4edcb6 MH	382	}
	383
	384	SR_PRIV struct sr_dev_driver gmc_mh_1x_2x_rs232_driver_info = {
	385	.name = "gmc-mh-1x-2x-rs232",
	386	.longname =
	387	"Gossen Metrawatt Metrahit 1x/2x DMMs, 'RS232' Interface",
	388	.api_version = 1,
f5792417 MH	389	.init = init_1x_2x_rs232,
	390	.cleanup = cleanup_sm_rs232,
	391	.scan = scan_1x_2x_rs232,
	392	.dev_list = dev_list_1x_2x_rs232,
	393	.dev_clear = dev_clear_1x_2x_rs232,
7b4edcb6 MH	394	.config_get = config_get,
	395	.config_set = config_set,
	396	.config_list = config_list,
	397	.dev_open = dev_open,
	398	.dev_close = dev_close,
f5792417 MH	399	.dev_acquisition_start = dev_acq_start_1x_2x_rs232,
f5792417 MH	400	.dev_acquisition_stop = dev_acq_stop,
7b4edcb6 MH	401	.priv = NULL,
7b4edcb6 MH	402	};