From: Bert Vermeulen Date: Thu, 13 Jun 2013 12:33:15 +0000 (+0200) Subject: cem-dt-885x: Support for turning data logging on/off X-Git-Tag: libsigrok-0.2.1~59 X-Git-Url: https://sigrok.org/gitaction?a=commitdiff_plain;h=e1af0e85b9b48b309f3552bceeed81d356735a33;p=libsigrok.git cem-dt-885x: Support for turning data logging on/off --- diff --git a/hardware/cem-dt-885x/api.c b/hardware/cem-dt-885x/api.c index b69456d9..e19ecc4f 100644 --- a/hardware/cem-dt-885x/api.c +++ b/hardware/cem-dt-885x/api.c @@ -31,6 +31,7 @@ static const int32_t hwcaps[] = { SR_CONF_SOUNDLEVELMETER, SR_CONF_LIMIT_SAMPLES, SR_CONF_CONTINUOUS, + SR_CONF_DATALOG, }; @@ -85,6 +86,8 @@ static GSList *scan(GSList *options) sr_dbg("Device context malloc failed."); return NULL; } + devc->cur_mqflags = 0; + devc->recording = -1; if (!(sdi->conn = sr_serial_dev_inst_new(conn, SERIALCOMM))) return NULL; @@ -165,6 +168,9 @@ static int config_get(int key, GVariant **data, const struct sr_dev_inst *sdi) case SR_CONF_LIMIT_SAMPLES: *data = g_variant_new_uint64(devc->limit_samples); break; + case SR_CONF_DATALOG: + *data = g_variant_new_boolean(cem_dt_885x_recording_get(sdi)); + break; default: return SR_ERR_NA; } @@ -193,6 +199,15 @@ static int config_set(int key, GVariant *data, const struct sr_dev_inst *sdi) devc->limit_samples = tmp_u64; ret = SR_OK; break; + case SR_CONF_DATALOG: + if (g_variant_get_boolean(data)) { + /* Start logging. */ + ret = cem_dt_885x_recording_set(sdi, TRUE); + } else { + /* Stop logging. */ + ret = cem_dt_885x_recording_set(sdi, FALSE); + } + break; default: ret = SR_ERR_NA; } diff --git a/hardware/cem-dt-885x/protocol.c b/hardware/cem-dt-885x/protocol.c index c9d0c89e..3b1d2915 100644 --- a/hardware/cem-dt-885x/protocol.c +++ b/hardware/cem-dt-885x/protocol.c @@ -146,11 +146,15 @@ static void process_mset(const struct sr_dev_inst *sdi) sdi->driver->dev_acquisition_stop((struct sr_dev_inst *)sdi, devc->cb_data); break; + case TOKEN_RECORDING_ON: + devc->recording = TRUE; + break; + case TOKEN_RECORDING_OFF: + devc->recording = FALSE; + break; case TOKEN_TIME: case TOKEN_STORE_OK: case TOKEN_STORE_FULL: - case TOKEN_RECORDING_ON: - case TOKEN_RECORDING_OFF: case TOKEN_BATTERY_OK: case TOKEN_BATTERY_LOW: case TOKEN_MEAS_RANGE_OK: @@ -166,7 +170,8 @@ static void process_mset(const struct sr_dev_inst *sdi) } -static void process_byte(const struct sr_dev_inst *sdi, const unsigned char c) +static void process_byte(const struct sr_dev_inst *sdi, const unsigned char c, + int handle_packets) { struct dev_context *devc; gint64 cur_time; @@ -190,7 +195,8 @@ static void process_byte(const struct sr_dev_inst *sdi, const unsigned char c) /* Force the last measurement out again. */ devc->cmd = 0xa5; devc->token = TOKEN_MEAS_WAS_READOUT; - process_mset(sdi); + if (handle_packets) + process_mset(sdi); devc->hold_last_sent = cur_time; } } @@ -218,7 +224,8 @@ static void process_byte(const struct sr_dev_inst *sdi, const unsigned char c) devc->buf_len = 0; devc->state = ST_GET_DATA; } else { - process_mset(sdi); + if (handle_packets) + process_mset(sdi); devc->state = ST_INIT; } } else if (devc->state == ST_GET_DATA) { @@ -228,7 +235,8 @@ static void process_byte(const struct sr_dev_inst *sdi, const unsigned char c) sr_dbg("Unknown 0xa5 token 0x%.2x", devc->token); if (c == 0xa5 || c == 0xbb) { /* Looks like a new command however. */ - process_mset(sdi); + if (handle_packets) + process_mset(sdi); devc->state = ST_INIT; } else { devc->buf[devc->buf_len++] = c; @@ -240,7 +248,8 @@ static void process_byte(const struct sr_dev_inst *sdi, const unsigned char c) } else { devc->buf[devc->buf_len++] = c; if (devc->buf_len == len) { - process_mset(sdi); + if (handle_packets) + process_mset(sdi); devc->state = ST_INIT; } else if (devc->buf_len > BUF_SIZE) { /* Shouldn't happen, ignore. */ @@ -267,8 +276,122 @@ SR_PRIV int cem_dt_885x_receive_data(int fd, int revents, void *cb_data) if (revents == G_IO_IN) { if (serial_read(serial, &c, 1) != 1) return TRUE; - process_byte(sdi, c); + process_byte(sdi, c, TRUE); } return TRUE; } + + +static int wait_for_token(const struct sr_dev_inst *sdi, char *tokens, int timeout) +{ + struct dev_context *devc; + struct sr_serial_dev_inst *serial; + gint64 start_time; + int i; + unsigned char c; + + serial = sdi->conn; + devc = sdi->priv; + devc->state = ST_INIT; + start_time = g_get_monotonic_time() / 1000; + while (TRUE) { + if (serial_read(serial, &c, 1) != 1) + /* Device might have gone away. */ + return SR_ERR; + process_byte(sdi, c, FALSE); + if (devc->state != ST_INIT) + /* Wait for a whole packet to get processed. */ + continue; + for (i = 0; tokens[i] != -1; i++) { + if (devc->token == tokens[i]) { + sr_spew("wait_for_token: got token 0x%.2x", devc->token); + return SR_OK; + } + } + if (timeout && g_get_monotonic_time() / 1000 - start_time > timeout) + return SR_ERR_TIMEOUT; + } + + return SR_OK; +} + +/* cmd is the command to send, tokens are the tokens that denote the state + * which the command affects. The first token is the desired state. */ +SR_PRIV int cem_dt_885x_toggle(const struct sr_dev_inst *sdi, uint8_t cmd, char *tokens) +{ + struct dev_context *devc; + struct sr_serial_dev_inst *serial; + + serial = sdi->conn; + devc = sdi->priv; + + /* The device doesn't respond to commands very well. The + * only thing to do is wait for the token that will confirm + * whether the command worked or not, and resend if needed. */ + while (TRUE) { + if (serial_write(serial, (const void *)&cmd, 1) != 1) + return SR_ERR; + /* Notifications are sent at 2Hz minimum */ + if (wait_for_token(sdi, tokens, 510) == SR_ERR) + return SR_ERR; + if (devc->token == tokens[0]) + /* It worked. */ + break; + } + + return SR_OK; +} + +SR_PRIV gboolean cem_dt_885x_recording_get(const struct sr_dev_inst *sdi) +{ + struct dev_context *devc; + char tokens[5]; + + devc = sdi->priv; + + if (devc->recording == -1) { + /* Didn't pick up device state yet. */ + tokens[0] = TOKEN_RECORDING_ON; + tokens[1] = TOKEN_RECORDING_OFF; + tokens[2] = -1; + if (wait_for_token(sdi, tokens, 0) != SR_OK) + return SR_ERR; + } + + return devc->token == TOKEN_RECORDING_ON; +} + +SR_PRIV int cem_dt_885x_recording_set(const struct sr_dev_inst *sdi, gboolean start) +{ + struct dev_context *devc; + int ret; + char tokens[5]; + + devc = sdi->priv; + + /* The toggle below needs the desired state in first position. */ + if (start) { + tokens[0] = TOKEN_RECORDING_ON; + tokens[1] = TOKEN_RECORDING_OFF; + } else { + tokens[0] = TOKEN_RECORDING_OFF; + tokens[1] = TOKEN_RECORDING_ON; + } + tokens[2] = -1; + + if (devc->recording == -1) { + /* Didn't pick up device state yet. */ + if (wait_for_token(sdi, tokens, 0) != SR_OK) + return SR_ERR; + if (devc->token == tokens[0]) + /* Nothing to do. */ + return SR_OK; + } else if (devc->recording == start) + /* Nothing to do. */ + return SR_OK; + + ret = cem_dt_885x_toggle(sdi, CMD_TOGGLE_RECORDING, tokens); + + return ret; +} diff --git a/hardware/cem-dt-885x/protocol.h b/hardware/cem-dt-885x/protocol.h index fa96d163..e5030f72 100644 --- a/hardware/cem-dt-885x/protocol.h +++ b/hardware/cem-dt-885x/protocol.h @@ -66,15 +66,22 @@ enum { TOKEN_MEAS_RANGE_80_130 = 0x4c, }; +enum { + CMD_TOGGLE_RECORDING = 0x55, +}; + /** Private, per-device-instance driver context. */ struct dev_context { + /* Device state */ + uint64_t cur_mqflags; + int recording; + /* Acquisition settings */ uint64_t limit_samples; /* Operational state */ int state; uint64_t num_samples; - uint64_t cur_mqflags; /* Temporary state across callbacks */ void *cb_data; @@ -84,7 +91,6 @@ struct dev_context { unsigned char buf[BUF_SIZE]; float last_spl; gint64 hold_last_sent; - }; /* Parser state machine. */ @@ -96,5 +102,7 @@ enum { }; SR_PRIV int cem_dt_885x_receive_data(int fd, int revents, void *cb_data); +SR_PRIV int cem_dt_885x_recording_set(const struct sr_dev_inst *sdi, gboolean start); +SR_PRIV gboolean cem_dt_885x_recording_get(const struct sr_dev_inst *sdi); #endif