X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=src%2Fhardware%2Flecroy-xstream%2Fprotocol.c;h=18c02061d4bf020a22e334475f52f361fb906b56;hb=7e463623382e1f574fde150b3fc88a65eaebb578;hp=13a7191ac10959400a093854ad00eff4c2a7fa57;hpb=d0b913eac47d8a1dc38ce84315b57f896bcf8c82;p=libsigrok.git diff --git a/src/hardware/lecroy-xstream/protocol.c b/src/hardware/lecroy-xstream/protocol.c index 13a7191a..18c02061 100644 --- a/src/hardware/lecroy-xstream/protocol.c +++ b/src/hardware/lecroy-xstream/protocol.c @@ -23,12 +23,6 @@ #include "scpi.h" #include "protocol.h" -SR_PRIV void lecroy_queue_logic_data(struct dev_context *devc, - size_t group, GByteArray *pod_data); -SR_PRIV void lecroy_send_logic_packet(struct sr_dev_inst *sdi, - struct dev_context *devc); -SR_PRIV void lecroy_cleanup_logic_data(struct dev_context *devc); - struct lecroy_wavedesc_2_x { uint16_t comm_type; uint16_t comm_order; /* 1 - little endian */ @@ -80,26 +74,9 @@ struct lecroy_wavedesc { }; } __attribute__((packed)); -static const uint32_t lecroy_devopts[] = { - SR_CONF_OSCILLOSCOPE, - SR_CONF_LIMIT_FRAMES | SR_CONF_GET | SR_CONF_SET, - SR_CONF_TRIGGER_SOURCE | SR_CONF_GET | SR_CONF_SET | SR_CONF_LIST, - SR_CONF_TIMEBASE | SR_CONF_GET | SR_CONF_SET | SR_CONF_LIST, - SR_CONF_NUM_HDIV | SR_CONF_GET, - SR_CONF_TRIGGER_SLOPE | SR_CONF_GET | SR_CONF_SET | SR_CONF_LIST, - SR_CONF_HORIZ_TRIGGERPOS | SR_CONF_GET | SR_CONF_SET, - SR_CONF_SAMPLERATE | SR_CONF_GET, -}; - -static const uint32_t lecroy_analog_devopts[] = { - SR_CONF_NUM_VDIV | SR_CONF_GET, - SR_CONF_COUPLING | SR_CONF_GET | SR_CONF_SET | SR_CONF_LIST, - SR_CONF_VDIV | SR_CONF_GET | SR_CONF_SET | SR_CONF_LIST, -}; - -static const char *lecroy_coupling_options[] = { +static const char *coupling_options[] = { "A1M", // AC with 1 MOhm termination - "D50", // DC with 50 Ohm termination + "D50", // DC with 50 Ohm termination "D1M", // DC with 1 MOhm termination "GND", "OVL", @@ -112,7 +89,7 @@ static const char *scope_trigger_slopes[] = { NULL, }; -static const char *lecroy_xstream_trigger_sources[] = { +static const char *trigger_sources[] = { "C1", "C2", "C3", @@ -122,7 +99,7 @@ static const char *lecroy_xstream_trigger_sources[] = { NULL, }; -static const struct sr_rational lecroy_timebases[] = { +static const struct sr_rational timebases[] = { /* picoseconds */ { 20, 1000000000000 }, { 50, 1000000000000 }, @@ -172,7 +149,7 @@ static const struct sr_rational lecroy_timebases[] = { { 1000, 1 }, }; -static const struct sr_rational lecroy_vdivs[] = { +static const struct sr_rational vdivs[] = { /* millivolts */ { 1, 1000 }, { 2, 1000 }, @@ -206,21 +183,15 @@ static const struct scope_config scope_models[] = { .analog_channels = 4, .analog_names = &scope_analog_channel_names, - .devopts = &lecroy_devopts, - .num_devopts = ARRAY_SIZE(lecroy_devopts), - - .analog_devopts = &lecroy_analog_devopts, - .num_analog_devopts = ARRAY_SIZE(lecroy_analog_devopts), - - .coupling_options = &lecroy_coupling_options, - .trigger_sources = &lecroy_xstream_trigger_sources, + .coupling_options = &coupling_options, + .trigger_sources = &trigger_sources, .trigger_slopes = &scope_trigger_slopes, - .timebases = lecroy_timebases, - .num_timebases = ARRAY_SIZE(lecroy_timebases), + .timebases = timebases, + .num_timebases = ARRAY_SIZE(timebases), - .vdivs = lecroy_vdivs, - .num_vdivs = ARRAY_SIZE(lecroy_vdivs), + .vdivs = vdivs, + .num_vdivs = ARRAY_SIZE(vdivs), .num_xdivs = 10, .num_ydivs = 8, @@ -242,8 +213,8 @@ static void scope_state_dump(const struct scope_config *config, tmp, state->analog_channels[i].vertical_offset); } - tmp = sr_period_string_f(1.0/(((float)config->timebases[state->timebase].p) / - ((float)config->timebases[state->timebase].q)), 0); + tmp = sr_period_string(config->timebases[state->timebase].p, + config->timebases[state->timebase].q); sr_info("Current timebase: %s", tmp); g_free(tmp); @@ -258,8 +229,7 @@ static void scope_state_dump(const struct scope_config *config, } static int scope_state_get_array_option(const char *resp, - const char *(*array)[], - int *result) + const char *(*array)[], int *result) { unsigned int i; @@ -293,7 +263,7 @@ static int array_float_get(gchar *value, const struct sr_rational *aval, return SR_ERR; for (int i = 0; i < array_len; i++) { - if (sr_rational_eq(&rval, aval+i)) { + if (sr_rational_eq(&rval, aval + i)) { *result = i; return SR_OK; } @@ -311,19 +281,18 @@ static int analog_channel_state_get(struct sr_scpi_dev_inst *scpi, char *tmp_str; for (i = 0; i < config->analog_channels; i++) { - g_snprintf(command, sizeof(command), "C%d:TRACE?", i+1); + g_snprintf(command, sizeof(command), "C%d:TRACE?", i + 1); if (sr_scpi_get_bool(scpi, command, - &state->analog_channels[i].state) != SR_OK) + &state->analog_channels[i].state) != SR_OK) return SR_ERR; - g_snprintf(command, sizeof(command), "C%d:VDIV?", i+1); + g_snprintf(command, sizeof(command), "C%d:VDIV?", i + 1); if (sr_scpi_get_string(scpi, command, &tmp_str) != SR_OK) return SR_ERR; - if (array_float_get(tmp_str, lecroy_vdivs, ARRAY_SIZE(lecroy_vdivs), - &j) != SR_OK) { + if (array_float_get(tmp_str, vdivs, ARRAY_SIZE(vdivs), &j) != SR_OK) { g_free(tmp_str); sr_err("Could not determine array index for vertical div scale."); return SR_ERR; @@ -332,19 +301,19 @@ static int analog_channel_state_get(struct sr_scpi_dev_inst *scpi, g_free(tmp_str); state->analog_channels[i].vdiv = j; - g_snprintf(command, sizeof(command), "C%d:OFFSET?", i+1); + g_snprintf(command, sizeof(command), "C%d:OFFSET?", i + 1); if (sr_scpi_get_float(scpi, command, &state->analog_channels[i].vertical_offset) != SR_OK) return SR_ERR; - g_snprintf(command, sizeof(command), "C%d:COUPLING?", i+1); + g_snprintf(command, sizeof(command), "C%d:COUPLING?", i + 1); if (sr_scpi_get_string(scpi, command, &tmp_str) != SR_OK) return SR_ERR; if (scope_state_get_array_option(tmp_str, config->coupling_options, - &state->analog_channels[i].coupling) != SR_OK) + &state->analog_channels[i].coupling) != SR_OK) return SR_ERR; g_free(tmp_str); @@ -365,12 +334,12 @@ SR_PRIV int lecroy_xstream_update_sample_rate(const struct sr_dev_inst *sdi) config = devc->model_config; if (sr_scpi_get_float(sdi->conn, "MEMORY_SIZE?", &memsize) != SR_OK) - return SR_ERR; + return SR_ERR; if (sr_scpi_get_float(sdi->conn, "TIME_DIV?", &timediv) != SR_OK) return SR_ERR; - state->sample_rate = 1/((timediv * config->num_xdivs) / memsize); + state->sample_rate = 1 / ((timediv * config->num_xdivs) / memsize); return SR_OK; } @@ -378,8 +347,8 @@ SR_PRIV int lecroy_xstream_update_sample_rate(const struct sr_dev_inst *sdi) SR_PRIV int lecroy_xstream_state_get(struct sr_dev_inst *sdi) { struct dev_context *devc; - struct scope_state *state -; const struct scope_config *config; + struct scope_state *state; + const struct scope_config *config; unsigned int i; char *tmp_str, *tmp_str2, *tmpp, *p, *key; char command[MAX_COMMAND_SIZE]; @@ -397,8 +366,7 @@ SR_PRIV int lecroy_xstream_state_get(struct sr_dev_inst *sdi) if (sr_scpi_get_string(sdi->conn, "TIME_DIV?", &tmp_str) != SR_OK) return SR_ERR; - if (array_float_get(tmp_str, lecroy_timebases, ARRAY_SIZE(lecroy_timebases), - &i) != SR_OK) { + if (array_float_get(tmp_str, timebases, ARRAY_SIZE(timebases), &i) != SR_OK) { g_free(tmp_str); sr_err("Could not determine array index for timbase scale."); return SR_ERR; @@ -409,9 +377,10 @@ SR_PRIV int lecroy_xstream_state_get(struct sr_dev_inst *sdi) if (sr_scpi_get_string(sdi->conn, "TRIG_SELECT?", &tmp_str) != SR_OK) return SR_ERR; + key = tmpp = NULL; tmp_str2 = tmp_str; i = 0; - while((p = strtok_r(tmp_str2, ",", &tmpp))) { + while ((p = strtok_r(tmp_str2, ",", &tmpp))) { tmp_str2 = NULL; if (i == 0) { /* trigger type */ @@ -425,11 +394,9 @@ SR_PRIV int lecroy_xstream_state_get(struct sr_dev_inst *sdi) i++; } - if (!trig_source || scope_state_get_array_option(trig_source, config->trigger_sources, - &state->trigger_source) != SR_OK) + if (!trig_source || scope_state_get_array_option(trig_source, config->trigger_sources, &state->trigger_source) != SR_OK) return SR_ERR; - g_snprintf(command, sizeof(command), "%s:TRIG_SLOPE?", trig_source); if (sr_scpi_get_string(sdi->conn, command, &tmp_str) != SR_OK) return SR_ERR; @@ -492,22 +459,21 @@ SR_PRIV int lecroy_xstream_init_device(struct sr_dev_inst *sdi) } if (model_index == -1) { - sr_dbg("Unsupported LECROY device."); + sr_dbg("Unsupported LeCroy device."); return SR_ERR_NA; } devc->analog_groups = g_malloc0(sizeof(struct sr_channel_group*) * - scope_models[model_index].analog_channels); + scope_models[model_index].analog_channels); /* Add analog channels. */ for (i = 0; i < scope_models[model_index].analog_channels; i++) { - - g_snprintf(command, sizeof(command), "C%d:TRACE?", i+1); + g_snprintf(command, sizeof(command), "C%d:TRACE?", i + 1); if (sr_scpi_get_bool(sdi->conn, command, &channel_enabled) != SR_OK) return SR_ERR; - g_snprintf(command, sizeof(command), "C%d:VDIV?", i+1); + g_snprintf(command, sizeof(command), "C%d:VDIV?", i + 1); ch = sr_channel_new(sdi, i, SR_CHANNEL_ANALOG, channel_enabled, (*scope_models[model_index].analog_names)[i]); @@ -545,19 +511,18 @@ static int lecroy_waveform_2_x_to_analog(GByteArray *data, int16_t *waveform_data; unsigned int i, num_samples; - data_float = g_malloc(desc->version_2_x.wave_array_count * sizeof(float)); + data_float = g_malloc(desc->version_2_x.wave_array_count * sizeof(float)); num_samples = desc->version_2_x.wave_array_count; waveform_data = (int16_t *)(data->data + + desc->version_2_x.wave_descriptor_length + desc->version_2_x.user_text_len); - for(i = 0; i < num_samples; i++) + for (i = 0; i < num_samples; i++) data_float[i] = (float)waveform_data[i] * desc->version_2_x.vertical_gain + desc->version_2_x.vertical_offset; - analog->data = data_float; analog->num_samples = num_samples; @@ -577,13 +542,14 @@ static int lecroy_waveform_2_x_to_analog(GByteArray *data, meaning->mq = SR_MQ_CURRENT; meaning->unit = SR_UNIT_AMPERE; } else { - /* default to voltage */ + /* Default to voltage. */ meaning->mq = SR_MQ_VOLTAGE; meaning->unit = SR_UNIT_VOLT; } meaning->mqflags = 0; spec->spec_digits = 3; + return SR_OK; } @@ -602,7 +568,9 @@ static int lecroy_waveform_to_analog(GByteArray *data, return lecroy_waveform_2_x_to_analog(data, desc, analog); } - sr_err("Waveformat template '%.16s' not supported\n", desc->template_name); + sr_err("Waveformat template '%.16s' not supported.", + desc->template_name); + return SR_ERR; } @@ -618,6 +586,7 @@ SR_PRIV int lecroy_xstream_receive_data(int fd, int revents, void *cb_data) struct sr_analog_meaning meaning; struct sr_analog_spec spec; char buf[8]; + (void)fd; (void)revents; @@ -642,11 +611,10 @@ SR_PRIV int lecroy_xstream_receive_data(int fd, int revents, void *cb_data) if (ch->type != SR_CHANNEL_ANALOG) return SR_ERR; - /* - * Pass on the received data of the channel(s). - */ + + /* Pass on the received data of the channel(s). */ if (sr_scpi_read_data(sdi->conn, buf, 4) != 4) { - sr_err("reading header failed\n"); + sr_err("Reading header failed."); return TRUE; } @@ -674,7 +642,6 @@ SR_PRIV int lecroy_xstream_receive_data(int fd, int revents, void *cb_data) g_slist_free(meaning.channels); g_free(analog.data); - /* * Advance to the next enabled channel. When data for all enabled * channels was received, then flush potentially queued logic data, @@ -695,7 +662,7 @@ SR_PRIV int lecroy_xstream_receive_data(int fd, int revents, void *cb_data) * the first enabled channel. */ if (++devc->num_frames == devc->frame_limit) { - sdi->driver->dev_acquisition_stop(sdi); + sr_dev_acquisition_stop(sdi); } else { devc->current_channel = devc->enabled_channels; lecroy_xstream_request_data(sdi);