[libsigrok.git] / src / hardware / hantek-4032l / protocol.c

/*
 * This file is part of the libsigrok project.
 *
 * Copyright (C) 2016 Andreas Zschunke <andreas.zschunke@gmx.net>
 * Copyright (C) 2017 Andrej Valek <andy@skyrain.eu>
 * Copyright (C) 2017 Uwe Hermann <uwe@hermann-uwe.de>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

#include <config.h>
#include "protocol.h"

#define H4032L_USB_TIMEOUT 500

enum h4032l_cmd {
	CMD_RESET = 0x00b3, /* Also arms the logic analyzer. */
	CMD_CONFIGURE = 0x2b1a,
	CMD_STATUS = 0x4b3a,
	CMD_GET = 0x6b5a
};

struct h4032l_status_packet {
	uint32_t magic;
	uint32_t values;
	uint32_t status;
	uint32_t usbxi_data;
	uint32_t fpga_version;
};

static void finish_acquisition(struct sr_dev_inst *sdi)
{
	struct drv_context *drvc = sdi->driver->context;

	std_session_send_df_end(sdi);
	usb_source_remove(sdi->session, drvc->sr_ctx);
}

static void free_transfer(struct libusb_transfer *transfer)
{
	struct sr_dev_inst *sdi = transfer->user_data;
	struct dev_context *devc = sdi->priv;

	transfer->buffer = NULL;
	libusb_free_transfer(transfer);
	devc->usb_transfer = NULL;

	finish_acquisition(sdi);
}

SR_PRIV int h4032l_receive_data(int fd, int revents, void *cb_data)
{
	struct timeval tv;
	struct drv_context *drvc;

	(void)fd;
	(void)revents;

	drvc = (struct drv_context *)cb_data;

	tv.tv_sec = tv.tv_usec = 0;
	libusb_handle_events_timeout(drvc->sr_ctx->libusb_ctx, &tv);

	return TRUE;
}

void LIBUSB_CALL h4032l_usb_callback(struct libusb_transfer *transfer)
{
	const struct sr_dev_inst *sdi = transfer->user_data;
	struct dev_context *devc = sdi->priv;
	struct drv_context *drvc = sdi->driver->context;
	struct sr_usb_dev_inst *usb = sdi->conn;
	gboolean cmd = FALSE;
	uint32_t max_samples = 512 / sizeof(uint32_t);
	uint32_t *buffer;
	struct h4032l_status_packet *status;
	struct sr_datafeed_packet packet;
	struct sr_datafeed_logic logic;
	uint32_t number_samples;
	int ret;

	/*
	 * If acquisition has already ended, just free any queued up
	 * transfers that come in.
	 */
	if (devc->acq_aborted) {
		free_transfer(transfer);
		return;
	}

	if (transfer->status != LIBUSB_TRANSFER_COMPLETED)
		sr_dbg("%s error: %d.", __func__, transfer->status);

	buffer = (uint32_t *)transfer->buffer;

	switch (devc->status) {
	case H4032L_STATUS_IDLE:
		sr_err("USB callback called in idle.");
		break;
	case H4032L_STATUS_CMD_CONFIGURE:
		/* Select status request as next. */
		cmd = TRUE;
		devc->cmd_pkt.cmd = CMD_STATUS;
		devc->status = H4032L_STATUS_CMD_STATUS;
		break;
	case H4032L_STATUS_CMD_STATUS:
		/* Select status request as next. */
		devc->status = H4032L_STATUS_RESPONSE_STATUS;
		break;
	case H4032L_STATUS_RESPONSE_STATUS:
		/*
		 * Check magic and if status is complete, then select
		 * First Transfer as next.
		 */
		status = (struct h4032l_status_packet *)transfer->buffer;
		sr_dbg("FPGA version: 0x%x.", status->fpga_version);
		if (status->magic != H4032L_STATUS_PACKET_MAGIC)
			devc->status = H4032L_STATUS_RESPONSE_STATUS;
		else if (status->status == 2)
			devc->status = H4032L_STATUS_RESPONSE_STATUS_CONTINUE;
		else
			devc->status = H4032L_STATUS_RESPONSE_STATUS_RETRY;
		break;
	case H4032L_STATUS_RESPONSE_STATUS_RETRY:
		devc->status = H4032L_STATUS_CMD_STATUS;
		devc->cmd_pkt.cmd = CMD_STATUS;
		cmd = TRUE;
		break;
	case H4032L_STATUS_RESPONSE_STATUS_CONTINUE:
		devc->status = H4032L_STATUS_CMD_GET;
		devc->cmd_pkt.cmd = CMD_GET;
		cmd = TRUE;
		break;
	case H4032L_STATUS_CMD_GET:
		devc->status = H4032L_STATUS_FIRST_TRANSFER;
		break;
	case H4032L_STATUS_FIRST_TRANSFER:
		/* Drop packets until H4032L_START_PACKET_MAGIC. */
		if (buffer[0] != H4032L_START_PACKET_MAGIC) {
			sr_dbg("Mismatch magic number of start poll.");
			break;
		}
		devc->status = H4032L_STATUS_TRANSFER;
		max_samples--;
		buffer++;
		/* Fallthrough. */
	case H4032L_STATUS_TRANSFER:
		number_samples = (devc->remaining_samples < max_samples) ?
			devc->remaining_samples : max_samples;
		devc->remaining_samples -= number_samples;
		packet.type = SR_DF_LOGIC;
		packet.payload = &logic;
		logic.length = number_samples * sizeof(uint32_t);
		logic.unitsize = sizeof(uint32_t);
		logic.data = buffer;
		sr_session_send(sdi, &packet);
		sr_dbg("Remaining: %d %08X %08X.", devc->remaining_samples,
		       buffer[0], buffer[1]);
		if (devc->remaining_samples == 0) {
			std_session_send_df_end(sdi);
			usb_source_remove(sdi->session, drvc->sr_ctx);
			devc->status = H4032L_STATUS_IDLE;
			if (buffer[number_samples] != H4032L_END_PACKET_MAGIC)
				sr_err("Mismatch magic number of end poll.");
		}
		break;
	}

	if (devc->status != H4032L_STATUS_IDLE) {
		if (cmd) {
			/* Setup new USB cmd packet, reuse transfer object. */
			sr_dbg("New command: %d.", devc->status);
			libusb_fill_bulk_transfer(transfer, usb->devhdl,
				2 | LIBUSB_ENDPOINT_OUT,
				(unsigned char *)&devc->cmd_pkt,
				sizeof(struct h4032l_cmd_pkt),
				h4032l_usb_callback,
				(void *)sdi, H4032L_USB_TIMEOUT);
		} else {
			/* Setup new USB poll packet, reuse transfer object. */
			sr_dbg("Poll: %d.", devc->status);
			libusb_fill_bulk_transfer(transfer, usb->devhdl,
				6 | LIBUSB_ENDPOINT_IN,
				devc->buffer, ARRAY_SIZE(devc->buffer),
				h4032l_usb_callback,
				(void *)sdi, H4032L_USB_TIMEOUT);
		}
		/* Send prepared USB packet. */
		if ((ret = libusb_submit_transfer(transfer)) != 0) {
			sr_err("Failed to submit transfer: %s.",
			       libusb_error_name(ret));
			devc->status = H4032L_STATUS_IDLE;
		}
	} else {
		sr_dbg("Now idle.");
	}

	if (devc->status == H4032L_STATUS_IDLE)
		free_transfer(transfer);
}

uint16_t h4032l_voltage2pwm(double voltage)
{
	/*
	 * word PwmA - channel A Vref PWM value, pseudocode:
	 * -6V < ThresholdVoltage < +6V
	 * Vref = 1.8 - ThresholdVoltage
	 * if Vref > 10.0
	 * 	Vref = 10.0
	 * if Vref < -5.0
	 * 	Vref = -5.0
	 * pwm = ToInt((Vref + 5.0) / 15.0 * 4096.0)
	 * if pwm > 4095
	 * 	pwm = 4095
	 */
	voltage = 1.8 - voltage;
	if (voltage > 10.0)
		voltage = 10.0;
	else if (voltage < -5.0)
		voltage = -5.0;

	return (uint16_t) ((voltage + 5.0) * (4096.0 / 15.0));
}

SR_PRIV int h4032l_start(const struct sr_dev_inst *sdi)
{
	struct dev_context *devc = sdi->priv;
	struct sr_usb_dev_inst *usb = sdi->conn;
	struct libusb_transfer *transfer;
	unsigned char buffer[] = {0x0f, 0x03, 0x03, 0x03, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00};
	int ret;

	/* Send reset command to arm the logic analyzer. */
	if ((ret = libusb_control_transfer(usb->devhdl,
		LIBUSB_REQUEST_TYPE_VENDOR | LIBUSB_ENDPOINT_OUT, CMD_RESET,
		0x00, 0x00, buffer, ARRAY_SIZE(buffer), H4032L_USB_TIMEOUT)) < 0) {
		sr_err("Failed to send vendor request %s.",
		       libusb_error_name(ret));
		return SR_ERR;
	}

	/* Wait for reset vendor request. */
	g_usleep(20 * 1000);

	/* Send configure command. */
	devc->cmd_pkt.cmd = CMD_CONFIGURE;
	devc->status = H4032L_STATUS_CMD_CONFIGURE;
	devc->remaining_samples = devc->cmd_pkt.sample_size;

	transfer = libusb_alloc_transfer(0);

	libusb_fill_bulk_transfer(transfer, usb->devhdl,
		2 | LIBUSB_ENDPOINT_OUT, (unsigned char *)&devc->cmd_pkt,
		sizeof(struct h4032l_cmd_pkt), h4032l_usb_callback,
		(void *)sdi, H4032L_USB_TIMEOUT);

	if ((ret = libusb_submit_transfer(transfer)) != 0) {
		sr_err("Failed to submit transfer: %s.",
		       libusb_error_name(ret));
		libusb_free_transfer(transfer);
		return SR_ERR;
	}

	std_session_send_df_header(sdi);

	return SR_OK;
}

SR_PRIV int h4032l_dev_open(struct sr_dev_inst *sdi)
{
	struct drv_context *drvc = sdi->driver->context;
	struct sr_usb_dev_inst *usb = sdi->conn;
	struct libusb_device_descriptor des;
	libusb_device **devlist;
	int ret = SR_ERR, i, device_count;
	char connection_id[64];

	device_count = libusb_get_device_list(drvc->sr_ctx->libusb_ctx, &devlist);
	if (device_count < 0) {
		sr_err("Failed to get device list: %s.",
		       libusb_error_name(device_count));
		return SR_ERR;
	}

	for (i = 0; i < device_count; i++) {
		libusb_get_device_descriptor(devlist[i], &des);

		if (des.idVendor != H4032L_USB_VENDOR ||
		    des.idProduct != H4032L_USB_PRODUCT)
			continue;

		if ((sdi->status == SR_ST_INITIALIZING) ||
		    (sdi->status == SR_ST_INACTIVE)) {
			/* Check device by its physical USB bus/port address. */
			if (usb_get_port_path(devlist[i], connection_id, sizeof(connection_id)) < 0)
				continue;

			if (strcmp(sdi->connection_id, connection_id))
				/* This is not the one. */
				continue;
		}

		if (!(ret = libusb_open(devlist[i], &usb->devhdl))) {
			if (usb->address == 0xff)
				/*
				 * First time we touch this device after FW
				 * upload, so we don't know the address yet.
				 */
				usb->address =
					libusb_get_device_address(devlist[i]);
		} else {
			sr_err("Failed to open device: %s.",
			       libusb_error_name(ret));
			ret = SR_ERR;
			break;
		}

		ret = SR_OK;
		break;
	}

	libusb_free_device_list(devlist, 1);
	return ret;
}
Commit	Line	Data
6a25fa42 AZ	1	/*
	2	* This file is part of the libsigrok project.
	3	*
5089a143 AZ	4	* Copyright (C) 2016 Andreas Zschunke <andreas.zschunke@gmx.net>
	5	* Copyright (C) 2017 Andrej Valek <andy@skyrain.eu>
	6	* Copyright (C) 2017 Uwe Hermann <uwe@hermann-uwe.de>
6a25fa42 AZ	7	*
	8	* This program is free software: you can redistribute it and/or modify
	9	* it under the terms of the GNU General Public License as published by
	10	* the Free Software Foundation, either version 3 of the License, or
	11	* (at your option) any later version.
	12	*
	13	* This program is distributed in the hope that it will be useful,
	14	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	15	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	16	* GNU General Public License for more details.
	17	*
	18	* You should have received a copy of the GNU General Public License
	19	* along with this program. If not, see <http://www.gnu.org/licenses/>.
	20	*/
	21
	22	#include <config.h>
	23	#include "protocol.h"
	24
5089a143 AZ	25	#define H4032L_USB_TIMEOUT 500
	26
	27	enum h4032l_cmd {
74c4c174 AV	28	CMD_RESET = 0x00b3, /* Also arms the logic analyzer. */
74c4c174 AV	29	CMD_CONFIGURE = 0x2b1a,
5089a143 AZ	30	CMD_STATUS = 0x4b3a,
	31	CMD_GET = 0x6b5a
	32	};
	33
e80e1858	34	struct h4032l_status_packet {
5089a143 AZ	35	uint32_t magic;
	36	uint32_t values;
	37	uint32_t status;
2bd5d17c UH	38	uint32_t usbxi_data;
2bd5d17c UH	39	uint32_t fpga_version;
5089a143 AZ	40	};
5089a143 AZ	41
a5b9880e AV	42	static void finish_acquisition(struct sr_dev_inst *sdi)
	43	{
	44	struct drv_context *drvc = sdi->driver->context;
	45
	46	std_session_send_df_end(sdi);
	47	usb_source_remove(sdi->session, drvc->sr_ctx);
	48	}
	49
	50	static void free_transfer(struct libusb_transfer *transfer)
	51	{
	52	struct sr_dev_inst *sdi = transfer->user_data;
	53	struct dev_context *devc = sdi->priv;
	54
	55	transfer->buffer = NULL;
	56	libusb_free_transfer(transfer);
	57	devc->usb_transfer = NULL;
	58
	59	finish_acquisition(sdi);
	60	}
	61
5089a143	62	SR_PRIV int h4032l_receive_data(int fd, int revents, void *cb_data)
6a25fa42	63	{
5089a143 AZ	64	struct timeval tv;
5089a143 AZ	65	struct drv_context *drvc;
6a25fa42 AZ	66
6a25fa42 AZ	67	(void)fd;
5089a143 AZ	68	(void)revents;
	69
	70	drvc = (struct drv_context *)cb_data;
	71
	72	tv.tv_sec = tv.tv_usec = 0;
	73	libusb_handle_events_timeout(drvc->sr_ctx->libusb_ctx, &tv);
6a25fa42	74
5089a143 AZ	75	return TRUE;
5089a143 AZ	76	}
6a25fa42	77
5089a143 AZ	78	void LIBUSB_CALL h4032l_usb_callback(struct libusb_transfer *transfer)
	79	{
	80	const struct sr_dev_inst *sdi = transfer->user_data;
	81	struct dev_context *devc = sdi->priv;
	82	struct drv_context *drvc = sdi->driver->context;
	83	struct sr_usb_dev_inst *usb = sdi->conn;
	84	gboolean cmd = FALSE;
	85	uint32_t max_samples = 512 / sizeof(uint32_t);
	86	uint32_t *buffer;
	87	struct h4032l_status_packet *status;
	88	struct sr_datafeed_packet packet;
	89	struct sr_datafeed_logic logic;
	90	uint32_t number_samples;
	91	int ret;
6a25fa42	92
a5b9880e AV	93	/*
	94	* If acquisition has already ended, just free any queued up
	95	* transfers that come in.
	96	*/
	97	if (devc->acq_aborted) {
	98	free_transfer(transfer);
	99	return;
	100	}
	101
74c4c174 AV	102	if (transfer->status != LIBUSB_TRANSFER_COMPLETED)
74c4c174 AV	103	sr_dbg("%s error: %d.", __func__, transfer->status);
6a25fa42	104
5089a143 AZ	105	buffer = (uint32_t *)transfer->buffer;
	106
	107	switch (devc->status) {
	108	case H4032L_STATUS_IDLE:
	109	sr_err("USB callback called in idle.");
	110	break;
	111	case H4032L_STATUS_CMD_CONFIGURE:
	112	/* Select status request as next. */
	113	cmd = TRUE;
	114	devc->cmd_pkt.cmd = CMD_STATUS;
	115	devc->status = H4032L_STATUS_CMD_STATUS;
	116	break;
	117	case H4032L_STATUS_CMD_STATUS:
	118	/* Select status request as next. */
	119	devc->status = H4032L_STATUS_RESPONSE_STATUS;
	120	break;
	121	case H4032L_STATUS_RESPONSE_STATUS:
	122	/*
	123	* Check magic and if status is complete, then select
	124	* First Transfer as next.
	125	*/
	126	status = (struct h4032l_status_packet *)transfer->buffer;
2bd5d17c	127	sr_dbg("FPGA version: 0x%x.", status->fpga_version);
28f2d07f	128	if (status->magic != H4032L_STATUS_PACKET_MAGIC)
74c4c174	129	devc->status = H4032L_STATUS_RESPONSE_STATUS;
28f2d07f	130	else if (status->status == 2)
5089a143	131	devc->status = H4032L_STATUS_RESPONSE_STATUS_CONTINUE;
28f2d07f	132	else
5089a143	133	devc->status = H4032L_STATUS_RESPONSE_STATUS_RETRY;
5089a143 AZ	134	break;
	135	case H4032L_STATUS_RESPONSE_STATUS_RETRY:
	136	devc->status = H4032L_STATUS_CMD_STATUS;
	137	devc->cmd_pkt.cmd = CMD_STATUS;
	138	cmd = TRUE;
	139	break;
	140	case H4032L_STATUS_RESPONSE_STATUS_CONTINUE:
	141	devc->status = H4032L_STATUS_CMD_GET;
	142	devc->cmd_pkt.cmd = CMD_GET;
	143	cmd = TRUE;
	144	break;
	145	case H4032L_STATUS_CMD_GET:
	146	devc->status = H4032L_STATUS_FIRST_TRANSFER;
	147	break;
	148	case H4032L_STATUS_FIRST_TRANSFER:
74c4c174	149	/* Drop packets until H4032L_START_PACKET_MAGIC. */
5089a143	150	if (buffer[0] != H4032L_START_PACKET_MAGIC) {
74c4c174	151	sr_dbg("Mismatch magic number of start poll.");
5089a143 AZ	152	break;
	153	}
	154	devc->status = H4032L_STATUS_TRANSFER;
	155	max_samples--;
	156	buffer++;
97200156	157	/* Fallthrough. */
5089a143	158	case H4032L_STATUS_TRANSFER:
28f2d07f AV	159	number_samples = (devc->remaining_samples < max_samples) ?
28f2d07f AV	160	devc->remaining_samples : max_samples;
5089a143 AZ	161	devc->remaining_samples -= number_samples;
	162	packet.type = SR_DF_LOGIC;
	163	packet.payload = &logic;
	164	logic.length = number_samples * sizeof(uint32_t);
	165	logic.unitsize = sizeof(uint32_t);
	166	logic.data = buffer;
	167	sr_session_send(sdi, &packet);
	168	sr_dbg("Remaining: %d %08X %08X.", devc->remaining_samples,
28f2d07f	169	buffer[0], buffer[1]);
5089a143 AZ	170	if (devc->remaining_samples == 0) {
	171	std_session_send_df_end(sdi);
	172	usb_source_remove(sdi->session, drvc->sr_ctx);
	173	devc->status = H4032L_STATUS_IDLE;
	174	if (buffer[number_samples] != H4032L_END_PACKET_MAGIC)
	175	sr_err("Mismatch magic number of end poll.");
	176	}
	177	break;
	178	}
	179
	180	if (devc->status != H4032L_STATUS_IDLE) {
	181	if (cmd) {
	182	/* Setup new USB cmd packet, reuse transfer object. */
	183	sr_dbg("New command: %d.", devc->status);
	184	libusb_fill_bulk_transfer(transfer, usb->devhdl,
	185	2 \| LIBUSB_ENDPOINT_OUT,
	186	(unsigned char *)&devc->cmd_pkt,
	187	sizeof(struct h4032l_cmd_pkt),
28f2d07f AV	188	h4032l_usb_callback,
28f2d07f AV	189	(void *)sdi, H4032L_USB_TIMEOUT);
5089a143 AZ	190	} else {
	191	/* Setup new USB poll packet, reuse transfer object. */
	192	sr_dbg("Poll: %d.", devc->status);
	193	libusb_fill_bulk_transfer(transfer, usb->devhdl,
	194	6 \| LIBUSB_ENDPOINT_IN,
	195	devc->buffer, ARRAY_SIZE(devc->buffer),
	196	h4032l_usb_callback,
	197	(void *)sdi, H4032L_USB_TIMEOUT);
	198	}
4868f15a	199	/* Send prepared USB packet. */
5089a143 AZ	200	if ((ret = libusb_submit_transfer(transfer)) != 0) {
	201	sr_err("Failed to submit transfer: %s.",
	202	libusb_error_name(ret));
	203	devc->status = H4032L_STATUS_IDLE;
	204	}
	205	} else {
	206	sr_dbg("Now idle.");
	207	}
	208
	209	if (devc->status == H4032L_STATUS_IDLE)
a5b9880e	210	free_transfer(transfer);
5089a143 AZ	211	}
	212
	213	uint16_t h4032l_voltage2pwm(double voltage)
	214	{
	215	/*
	216	* word PwmA - channel A Vref PWM value, pseudocode:
	217	* -6V < ThresholdVoltage < +6V
	218	* Vref = 1.8 - ThresholdVoltage
	219	* if Vref > 10.0
	220	* Vref = 10.0
	221	* if Vref < -5.0
	222	* Vref = -5.0
	223	* pwm = ToInt((Vref + 5.0) / 15.0 * 4096.0)
	224	* if pwm > 4095
	225	* pwm = 4095
	226	*/
	227	voltage = 1.8 - voltage;
	228	if (voltage > 10.0)
	229	voltage = 10.0;
	230	else if (voltage < -5.0)
	231	voltage = -5.0;
	232
	233	return (uint16_t) ((voltage + 5.0) * (4096.0 / 15.0));
	234	}
	235
	236	SR_PRIV int h4032l_start(const struct sr_dev_inst *sdi)
	237	{
	238	struct dev_context *devc = sdi->priv;
	239	struct sr_usb_dev_inst *usb = sdi->conn;
	240	struct libusb_transfer *transfer;
74c4c174	241	unsigned char buffer[] = {0x0f, 0x03, 0x03, 0x03, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00};
5089a143 AZ	242	int ret;
5089a143 AZ	243
74c4c174 AV	244	/* Send reset command to arm the logic analyzer. */
	245	if ((ret = libusb_control_transfer(usb->devhdl,
	246	LIBUSB_REQUEST_TYPE_VENDOR \| LIBUSB_ENDPOINT_OUT, CMD_RESET,
	247	0x00, 0x00, buffer, ARRAY_SIZE(buffer), H4032L_USB_TIMEOUT)) < 0) {
28f2d07f AV	248	sr_err("Failed to send vendor request %s.",
28f2d07f AV	249	libusb_error_name(ret));
74c4c174 AV	250	return SR_ERR;
	251	}
	252
	253	/* Wait for reset vendor request. */
	254	g_usleep(20 * 1000);
	255
	256	/* Send configure command. */
5089a143 AZ	257	devc->cmd_pkt.cmd = CMD_CONFIGURE;
	258	devc->status = H4032L_STATUS_CMD_CONFIGURE;
	259	devc->remaining_samples = devc->cmd_pkt.sample_size;
	260
	261	transfer = libusb_alloc_transfer(0);
	262
	263	libusb_fill_bulk_transfer(transfer, usb->devhdl,
	264	2 \| LIBUSB_ENDPOINT_OUT, (unsigned char *)&devc->cmd_pkt,
	265	sizeof(struct h4032l_cmd_pkt), h4032l_usb_callback,
	266	(void *)sdi, H4032L_USB_TIMEOUT);
	267
	268	if ((ret = libusb_submit_transfer(transfer)) != 0) {
28f2d07f AV	269	sr_err("Failed to submit transfer: %s.",
28f2d07f AV	270	libusb_error_name(ret));
5089a143 AZ	271	libusb_free_transfer(transfer);
	272	return SR_ERR;
	273	}
	274
	275	std_session_send_df_header(sdi);
	276
	277	return SR_OK;
	278	}
	279
	280	SR_PRIV int h4032l_dev_open(struct sr_dev_inst *sdi)
	281	{
	282	struct drv_context *drvc = sdi->driver->context;
	283	struct sr_usb_dev_inst *usb = sdi->conn;
	284	struct libusb_device_descriptor des;
	285	libusb_device **devlist;
	286	int ret = SR_ERR, i, device_count;
	287	char connection_id[64];
	288
	289	device_count = libusb_get_device_list(drvc->sr_ctx->libusb_ctx, &devlist);
	290	if (device_count < 0) {
	291	sr_err("Failed to get device list: %s.",
	292	libusb_error_name(device_count));
	293	return SR_ERR;
	294	}
	295
	296	for (i = 0; i < device_count; i++) {
	297	libusb_get_device_descriptor(devlist[i], &des);
	298
	299	if (des.idVendor != H4032L_USB_VENDOR \|\|
	300	des.idProduct != H4032L_USB_PRODUCT)
	301	continue;
	302
	303	if ((sdi->status == SR_ST_INITIALIZING) \|\|
	304	(sdi->status == SR_ST_INACTIVE)) {
	305	/* Check device by its physical USB bus/port address. */
28f2d07f AV	306	if (usb_get_port_path(devlist[i], connection_id, sizeof(connection_id)) < 0)
	307	continue;
	308
5089a143 AZ	309	if (strcmp(sdi->connection_id, connection_id))
	310	/* This is not the one. */
	311	continue;
	312	}
	313
	314	if (!(ret = libusb_open(devlist[i], &usb->devhdl))) {
	315	if (usb->address == 0xff)
	316	/*
	317	* First time we touch this device after FW
	318	* upload, so we don't know the address yet.
	319	*/
	320	usb->address =
28f2d07f	321	libusb_get_device_address(devlist[i]);
5089a143 AZ	322	} else {
	323	sr_err("Failed to open device: %s.",
	324	libusb_error_name(ret));
	325	ret = SR_ERR;
	326	break;
	327	}
	328
	329	ret = SR_OK;
	330	break;
	331	}
	332
	333	libusb_free_device_list(devlist, 1);
	334	return ret;
6a25fa42	335	}