X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;f=session_driver.c;h=b64ce3a35a555c7b0ec2ed257f33f4d592ab2d8b;hb=6dddd902244f314eba721a0d8804731ea9c9912d;hp=a69e404d42af4d076195ff56b0541deb29357c79;hpb=1f9813eb6cf2fa3b6511af46b19270feb9484c1e;p=libsigrok.git diff --git a/session_driver.c b/session_driver.c index a69e404d..b64ce3a3 100644 --- a/session_driver.c +++ b/session_driver.c @@ -77,11 +77,11 @@ static struct session_vdev *get_vdev_by_index(int dev_index) * * @param fd TODO. * @param revents TODO. - * @param session_data TODO. + * @param cb_data TODO. * * @return TODO. */ -static int feed_chunk(int fd, int revents, void *session_data) +static int receive_data(int fd, int revents, void *cb_data) { struct sr_dev_inst *sdi; struct session_vdev *vdev; @@ -120,7 +120,7 @@ static int feed_chunk(int fd, int revents, void *session_data) logic.unitsize = vdev->unitsize; logic.data = buf; vdev->bytes_read += ret; - sr_session_send(session_data, &packet); + sr_session_send(cb_data, &packet); } else { /* done with this capture file */ zip_fclose(vdev->capfile); @@ -132,7 +132,7 @@ static int feed_chunk(int fd, int revents, void *session_data) if (!got_data) { packet.type = SR_DF_END; - sr_session_send(session_data, &packet); + sr_session_send(cb_data, &packet); } return TRUE; @@ -157,7 +157,6 @@ static int hw_init(const char *devinfo) /** * TODO. - * */ static int hw_cleanup(void) { @@ -269,16 +268,13 @@ static int hw_dev_config_set(int dev_index, int hwcap, void *value) return SR_OK; } -static int hw_dev_acquisition_start(int dev_index, void *session_dev_id) +static int hw_dev_acquisition_start(int dev_index, void *cb_data) { struct zip_stat zs; struct session_vdev *vdev; struct sr_datafeed_header *header; struct sr_datafeed_packet *packet; - int err; - - /* Avoid compiler warnings. */ - (void)session_dev_id; + int ret; if (!(vdev = get_vdev_by_index(dev_index))) return SR_ERR; @@ -286,9 +282,9 @@ static int hw_dev_acquisition_start(int dev_index, void *session_dev_id) sr_info("session_driver: opening archive %s file %s", sessionfile, vdev->capturefile); - if (!(vdev->archive = zip_open(sessionfile, 0, &err))) { + if (!(vdev->archive = zip_open(sessionfile, 0, &ret))) { sr_err("session driver: Failed to open session file '%s': " - "zip error %d\n", sessionfile, err); + "zip error %d\n", sessionfile, ret); return SR_ERR; } @@ -305,7 +301,7 @@ static int hw_dev_acquisition_start(int dev_index, void *session_dev_id) } /* freewheeling source */ - sr_session_source_add(-1, 0, 0, feed_chunk, session_dev_id); + sr_session_source_add(-1, 0, 0, receive_data, cb_data); if (!(packet = g_try_malloc(sizeof(struct sr_datafeed_packet)))) { sr_err("session driver: %s: packet malloc failed", __func__); @@ -324,7 +320,7 @@ static int hw_dev_acquisition_start(int dev_index, void *session_dev_id) gettimeofday(&header->starttime, NULL); header->samplerate = vdev->samplerate; header->num_logic_probes = vdev->num_probes; - sr_session_send(session_dev_id, packet); + sr_session_send(cb_data, packet); g_free(header); g_free(packet);