X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;f=src%2Flcr%2Fes51919.c;h=3b32df1ed38dd6234783e6ea48b31c30026f3b96;hb=4d399734b4ec7affb58c5881ea1b8d88eaa57d53;hp=896565301796592fbc4d0aa55d0e4826abba271a;hpb=5faebab2903dc91949edc31f0a4b118d86090a30;p=libsigrok.git diff --git a/src/lcr/es51919.c b/src/lcr/es51919.c index 89656530..3b32df1e 100644 --- a/src/lcr/es51919.c +++ b/src/lcr/es51919.c @@ -415,9 +415,6 @@ static const char *const models[] = { /** Private, per-device-instance driver context. */ struct dev_context { - /** Opaque pointer passed in by the frontend. */ - void *cb_data; - /** The number of frames. */ struct dev_limit_counter frame_count; @@ -595,11 +592,7 @@ static gboolean packet_valid(const uint8_t *pkt) static int do_config_update(struct sr_dev_inst *sdi, uint32_t key, GVariant *var) { - struct dev_context *devc; - - devc = sdi->priv; - - return send_config_update_key(devc->cb_data, key, var); + return send_config_update_key(sdi, key, var); } static int send_freq_update(struct sr_dev_inst *sdi, unsigned int freq) @@ -654,14 +647,14 @@ static void handle_packet(struct sr_dev_inst *sdi, const uint8_t *pkt) if (analog.mq >= 0) { if (!frame) { packet.type = SR_DF_FRAME_BEGIN; - sr_session_send(devc->cb_data, &packet); + sr_session_send(sdi, &packet); frame = TRUE; } packet.type = SR_DF_ANALOG_OLD; packet.payload = &analog; - sr_session_send(devc->cb_data, &packet); + sr_session_send(sdi, &packet); } g_slist_free(analog.channels); @@ -671,21 +664,21 @@ static void handle_packet(struct sr_dev_inst *sdi, const uint8_t *pkt) if (analog.mq >= 0) { if (!frame) { packet.type = SR_DF_FRAME_BEGIN; - sr_session_send(devc->cb_data, &packet); + sr_session_send(sdi, &packet); frame = TRUE; } packet.type = SR_DF_ANALOG_OLD; packet.payload = &analog; - sr_session_send(devc->cb_data, &packet); + sr_session_send(sdi, &packet); } g_slist_free(analog.channels); if (frame) { packet.type = SR_DF_FRAME_END; - sr_session_send(devc->cb_data, &packet); + sr_session_send(sdi, &packet); dev_limit_counter_inc(&devc->frame_count); } } @@ -729,7 +722,7 @@ static int receive_data(int fd, int revents, void *cb_data) if (dev_limit_counter_limit_reached(&devc->frame_count) || dev_time_limit_reached(&devc->time_count)) - sdi->driver->dev_acquisition_stop(sdi, cb_data); + sdi->driver->dev_acquisition_stop(sdi); return TRUE; } @@ -816,8 +809,7 @@ SR_PRIV int es51919_serial_config_get(uint32_t key, GVariant **data, (void)cg; - if (!(devc = sdi->priv)) - return SR_ERR_BUG; + devc = sdi->priv; switch (key) { case SR_CONF_OUTPUT_FREQUENCY: @@ -827,7 +819,6 @@ SR_PRIV int es51919_serial_config_get(uint32_t key, GVariant **data, *data = g_variant_new_string(models[devc->model]); break; default: - sr_spew("%s: Unsupported key %u", __func__, key); return SR_ERR_NA; } @@ -903,15 +894,13 @@ SR_PRIV int es51919_serial_config_list(uint32_t key, GVariant **data, *data = g_variant_new_strv(models, ARRAY_SIZE(models)); break; default: - sr_spew("%s: Unsupported key %u", __func__, key); return SR_ERR_NA; } return SR_OK; } -SR_PRIV int es51919_serial_acquisition_start(const struct sr_dev_inst *sdi, - void *cb_data) +SR_PRIV int es51919_serial_acquisition_start(const struct sr_dev_inst *sdi) { struct dev_context *devc; struct sr_serial_dev_inst *serial; @@ -922,13 +911,10 @@ SR_PRIV int es51919_serial_acquisition_start(const struct sr_dev_inst *sdi, if (!(devc = sdi->priv)) return SR_ERR_BUG; - devc->cb_data = cb_data; - dev_limit_counter_start(&devc->frame_count); dev_time_counter_start(&devc->time_count); - /* Send header packet to the session bus. */ - std_session_send_df_header(cb_data, LOG_PREFIX); + std_session_send_df_header(sdi, LOG_PREFIX); /* Poll every 50ms, or whenever some data comes in. */ serial = sdi->conn; @@ -938,9 +924,8 @@ SR_PRIV int es51919_serial_acquisition_start(const struct sr_dev_inst *sdi, return SR_OK; } -SR_PRIV int es51919_serial_acquisition_stop(struct sr_dev_inst *sdi, - void *cb_data) +SR_PRIV int es51919_serial_acquisition_stop(struct sr_dev_inst *sdi) { - return std_serial_dev_acquisition_stop(sdi, cb_data, + return std_serial_dev_acquisition_stop(sdi, std_serial_dev_close, sdi->conn, LOG_PREFIX); }