+
+SR_PRIV void lascar_el_usb_receive_transfer(struct libusb_transfer *transfer)
+{
+ struct dev_context *devc;
+ struct sr_dev_inst *sdi;
+ int ret;
+ gboolean packet_has_error;
+
+ sdi = transfer->user_data;
+ devc = sdi->priv;
+
+ packet_has_error = FALSE;
+ switch (transfer->status) {
+ case LIBUSB_TRANSFER_NO_DEVICE:
+ /* USB device was unplugged. */
+ hw_dev_acquisition_stop(sdi, sdi);
+ return;
+ case LIBUSB_TRANSFER_COMPLETED:
+ case LIBUSB_TRANSFER_TIMED_OUT: /* We may have received some data though */
+ break;
+ default:
+ packet_has_error = TRUE;
+ break;
+ }
+
+ if (!packet_has_error) {
+ if (devc->rcvd_samples < devc->logged_samples)
+ lascar_el_usb_dispatch(sdi, transfer->buffer,
+ transfer->actual_length);
+ devc->rcvd_bytes += transfer->actual_length;
+ sr_spew("received %d/%d bytes (%d/%d samples)",
+ devc->rcvd_bytes, devc->log_size,
+ devc->rcvd_samples, devc->logged_samples);
+ if (devc->rcvd_bytes >= devc->log_size)
+ hw_dev_acquisition_stop(sdi, sdi);
+ }
+
+ if (sdi->status == SR_ST_ACTIVE) {
+ /* Send the same request again. */
+ if ((ret = libusb_submit_transfer(transfer) != 0)) {
+ sr_err("Unable to resubmit transfer: %s.",
+ libusb_error_name(ret));
+ g_free(transfer->buffer);
+ libusb_free_transfer(transfer);
+ hw_dev_acquisition_stop(sdi, sdi);
+ }
+ } else {
+ /* This was the last transfer we're going to receive, so
+ * clean up now. */
+ g_free(transfer->buffer);
+ libusb_free_transfer(transfer);
+ }
+
+}
+
+static int get_flags(unsigned char *configblock)
+{
+ int flags;
+
+ flags = (configblock[32] | (configblock[33] << 8)) & 0x1fff;
+ sr_spew("Read flags (0x%.4x).", flags);
+
+ return flags;
+}
+
+static int set_flags(unsigned char *configblock, int flags)
+{
+
+ sr_spew("Setting flags to 0x%.4x.", flags);
+ configblock[32] = flags & 0xff;
+ configblock[33] = (flags >> 8) & 0x1f;
+
+ return flags;
+}
+
+SR_PRIV int lascar_is_logging(const struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc;
+ struct sr_usb_dev_inst *usb;
+ int dummy, flags, ret;
+
+ devc = sdi->priv;
+ usb = sdi->conn;
+
+ if (lascar_get_config(usb->devhdl, devc->config, &dummy) != SR_OK)
+ return -1;
+
+ flags = get_flags(devc->config);
+ if (flags & 0x0100)
+ ret = 1;
+ else
+ ret = 0;
+
+ return ret;
+}
+
+SR_PRIV int lascar_start_logging(const struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc;
+ struct sr_usb_dev_inst *usb;
+ int len, flags, ret;
+
+ devc = sdi->priv;
+ usb = sdi->conn;
+
+ if (lascar_get_config(usb->devhdl, devc->config, &len) != SR_OK)
+ return SR_ERR;
+
+ /* Turn on logging. */
+ flags = get_flags(devc->config);
+ flags |= 0x0100;
+ set_flags(devc->config, flags);
+
+ /* Start logging in 0 seconds. */
+ memset(devc->config + 24, 0, 4);
+
+ ret = lascar_save_config(usb->devhdl, devc->config, len);
+ sr_info("Started internal logging.");
+
+ return ret;
+}
+
+SR_PRIV int lascar_stop_logging(const struct sr_dev_inst *sdi)
+{
+ struct dev_context *devc;
+ struct sr_usb_dev_inst *usb;
+ int len, flags, ret;
+
+ devc = sdi->priv;
+ usb = sdi->conn;
+
+ if (lascar_get_config(usb->devhdl, devc->config, &len) != SR_OK)
+ return SR_ERR;
+
+ flags = get_flags(devc->config);
+ flags &= ~0x0100;
+ set_flags(devc->config, flags);
+
+ ret = lascar_save_config(usb->devhdl, devc->config, len);
+ sr_info("Stopped internal logging.");
+
+ return ret;
+}
+