[libsigrok.git] / src / hardware / ipdbg-logic-analyser / protocol.c

/*
 * This file is part of the libsigrok project.
 *
 * Copyright (C) 2016 danselmi <da@da>
 *
 * 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>

#ifdef _WIN32
#define _WIN32_WINNT 0x0501
#include <winsock2.h>
#include <ws2tcpip.h>
#endif

#include <string.h>
#include <unistd.h>

#ifndef _WIN32
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#endif

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

#include <sys/ioctl.h>

#define BUFFER_SIZE 4

/* Top-level command opcodes */
#define CMD_SET_TRIGGER            0x00
#define CMD_CFG_TRIGGER            0xF0
#define CMD_CFG_LA                 0x0F
#define CMD_START                  0xFE
#define CMD_RESET                  0xEE

#define CMD_GET_BUS_WIDTHS         0xAA
#define CMD_GET_LA_ID              0xBB
#define CMD_ESCAPE                 0x55

/* Trigger subfunction command opcodes */
#define CMD_TRIG_MASKS             0xF1
#define CMD_TRIG_MASK              0xF3
#define CMD_TRIG_VALUE             0xF7

#define CMD_TRIG_MASKS_LAST        0xF9
#define CMD_TRIG_MASK_LAST         0xFB
#define CMD_TRIG_VALUE_LAST        0xFF

#define CMD_TRIG_SELECT_EDGE_MASK  0xF5
#define CMD_TRIG_SET_EDGE_MASK     0xF6

/* LA subfunction command opcodes */
#define CMD_LA_DELAY               0x1F

SR_PRIV int data_available(struct ipdbg_org_la_tcp *tcp)
{
#ifdef __WIN32__
	ioctlsocket(tcp->socket, FIONREAD, &bytes_available);
#else
	int status;

	if (ioctl(tcp->socket, FIONREAD, &status) < 0) {	// TIOCMGET
		sr_err("FIONREAD failed: %s\n", strerror(errno));
		return 0;
	}

	return (status < 1) ? 0 : 1;
#endif  // __WIN32__
}

SR_PRIV struct ipdbg_org_la_tcp *ipdbg_org_la_tcp_new(void)
{
	struct ipdbg_org_la_tcp *tcp;

	tcp = g_malloc0(sizeof(struct ipdbg_org_la_tcp));

	tcp->address = NULL;
	tcp->port = NULL;
	tcp->socket = -1;

	return tcp;
}

SR_PRIV void ipdbg_org_la_tcp_free(struct ipdbg_org_la_tcp *tcp)
{
	g_free(tcp->address);
	g_free(tcp->port);
}

SR_PRIV int ipdbg_org_la_tcp_open(struct ipdbg_org_la_tcp *tcp)
{
	struct addrinfo hints;
	struct addrinfo *results, *res;
	int err;

	memset(&hints, 0, sizeof(hints));
	hints.ai_family = AF_UNSPEC;
	hints.ai_socktype = SOCK_STREAM;
	hints.ai_protocol = IPPROTO_TCP;

	err = getaddrinfo(tcp->address, tcp->port, &hints, &results);

	if (err) {
		sr_err("Address lookup failed: %s:%s: %s", tcp->address,
			tcp->port, gai_strerror(err));
		return SR_ERR;
	}

	for (res = results; res; res = res->ai_next) {
		if ((tcp->socket = socket(res->ai_family, res->ai_socktype,
			res->ai_protocol)) < 0)
			continue;
		if (connect(tcp->socket, res->ai_addr, res->ai_addrlen) != 0) {
			close(tcp->socket);
			tcp->socket = -1;
			continue;
		}
		break;
	}

	freeaddrinfo(results);

	if (tcp->socket < 0) {
		sr_err("Failed to connect to %s:%s: %s", tcp->address, tcp->port,
			g_strerror(errno));
		return SR_ERR;
	}

	return SR_OK;
}

SR_PRIV int ipdbg_org_la_tcp_close(struct ipdbg_org_la_tcp *tcp)
{
	int ret = SR_OK;

	if (close(tcp->socket) < 0)
		ret = SR_ERR;

	tcp->socket = -1;

	return ret;
}

SR_PRIV int ipdbg_org_la_tcp_send(struct ipdbg_org_la_tcp *tcp,
	const uint8_t *buf, size_t len)
{
	int out;
	out = send(tcp->socket, (char*)buf, len, 0);

	if (out < 0) {
		sr_err("Send error: %s", g_strerror(errno));
		return SR_ERR;
	}

	if (out < (int)len)
		sr_dbg("Only sent %d/%d bytes of data.", out, (int)len);

	return SR_OK;
}

SR_PRIV int ipdbg_org_la_tcp_receive_blocking(struct ipdbg_org_la_tcp *tcp,
	uint8_t *buf, int bufsize)
{
	int received = 0;
	int error_count = 0;

	/* Timeout after 500ms of not receiving data */
	while ((received < bufsize) && (error_count < 500)) {
		if (ipdbg_org_la_tcp_receive(tcp, buf) > 0) {
			buf++;
			received++;
		} else {
			error_count++;
			g_usleep(1000);  /* Sleep for 1ms */
		}
	}

	return received;
}

SR_PRIV int ipdbg_org_la_tcp_receive(struct ipdbg_org_la_tcp *tcp,
	uint8_t *buf)
{
	int received = 0;

	if (data_available(tcp)) {
		while (received < 1) {
			int len = recv(tcp->socket, buf, 1, 0);

			if (len < 0) {
				sr_err("Receive error: %s", g_strerror(errno));
				return SR_ERR;
			} else
				received += len;
		}

		return received;
	} else
		return -1;
}

SR_PRIV int ipdbg_org_la_convert_trigger(const struct sr_dev_inst *sdi)
{
	struct ipdbg_org_la_dev_context *devc;
	struct sr_trigger *trigger;
	struct sr_trigger_stage *stage;
	struct sr_trigger_match *match;
	const GSList *l, *m;

	devc = sdi->priv;

	devc->num_stages = 0;
	devc->num_transfers = 0;
	devc->raw_sample_buf = NULL;

	for (uint64_t i = 0; i < devc->DATA_WIDTH_BYTES; i++) {
		devc->trigger_mask[i] = 0;
		devc->trigger_value[i] = 0;
		devc->trigger_mask_last[i] = 0;
		devc->trigger_value_last[i] = 0;
		devc->trigger_edge_mask[i] = 0;
	}

	if (!(trigger = sr_session_trigger_get(sdi->session)))
		return SR_OK;

	for (l = trigger->stages; l; l = l->next) {
		stage = l->data;
		for (m = stage->matches; m; m = m->next) {
			match = m->data;
			int byte_idx = match->channel->index / 8;
			uint8_t match_bit = 1 << (match->channel->index % 8);

			if (!match->channel->enabled)
				/* Ignore disabled channels with a trigger. */
				continue;

			if (match->match == SR_TRIGGER_ONE) {
				devc->trigger_value[byte_idx] |= match_bit;
				devc->trigger_mask[byte_idx] |= match_bit;
				devc->trigger_mask_last[byte_idx] &= ~match_bit;
				devc->trigger_edge_mask[byte_idx] &= ~match_bit;
			} else if (match->match == SR_TRIGGER_ZERO) {
				devc->trigger_value[byte_idx] &= ~match_bit;
				devc->trigger_mask[byte_idx] |= match_bit;
				devc->trigger_mask_last[byte_idx] &= ~match_bit;
				devc->trigger_edge_mask[byte_idx] &= ~match_bit;
			} else if (match->match == SR_TRIGGER_RISING) {
				devc->trigger_value[byte_idx] |= match_bit;
				devc->trigger_value_last[byte_idx] &=
				    ~match_bit;
				devc->trigger_mask[byte_idx] |= match_bit;
				devc->trigger_mask_last[byte_idx] |= match_bit;
				devc->trigger_edge_mask[byte_idx] &= ~match_bit;
			} else if (match->match == SR_TRIGGER_FALLING) {
				devc->trigger_value[byte_idx] &= ~match_bit;
				devc->trigger_value_last[byte_idx] |= match_bit;
				devc->trigger_mask[byte_idx] |= match_bit;
				devc->trigger_mask_last[byte_idx] |= match_bit;
				devc->trigger_edge_mask[byte_idx] &= ~match_bit;
			} else if (match->match == SR_TRIGGER_EDGE) {
				devc->trigger_mask[byte_idx] &= ~match_bit;
				devc->trigger_mask_last[byte_idx] &= ~match_bit;
				devc->trigger_edge_mask[byte_idx] |= match_bit;
			}
		}
	}

	return SR_OK;
}

SR_PRIV int ipdbg_org_la_receive_data(int fd, int revents, void *cb_data)
{
	const struct sr_dev_inst *sdi;
	struct ipdbg_org_la_dev_context *devc;

	(void)fd;
	(void)revents;

	sdi = (const struct sr_dev_inst *)cb_data;
	if (!sdi)
		return FALSE;

	if (!(devc = sdi->priv))
		return FALSE;

	struct ipdbg_org_la_tcp *tcp = sdi->conn;
	struct sr_datafeed_packet packet;
	struct sr_datafeed_logic logic;

	if (!devc->raw_sample_buf) {
		devc->raw_sample_buf =
			g_try_malloc(devc->limit_samples * devc->DATA_WIDTH_BYTES);
		if (!devc->raw_sample_buf) {
			sr_warn("Sample buffer malloc failed.");
			return FALSE;
		}
	}

	if (devc->num_transfers <
		(devc->limit_samples_max * devc->DATA_WIDTH_BYTES)) {
		uint8_t byte;

		if (ipdbg_org_la_tcp_receive(tcp, &byte) == 1) {
			if (devc->num_transfers <
				(devc->limit_samples * devc->DATA_WIDTH_BYTES))
				devc->raw_sample_buf[devc->num_transfers] = byte;

			devc->num_transfers++;
		}
	} else {
		if (devc->delay_value > 0) {
			/* There are pre-trigger samples, send those first. */
			packet.type = SR_DF_LOGIC;
			packet.payload = &logic;
			logic.length = devc->delay_value * devc->DATA_WIDTH_BYTES;
			logic.unitsize = devc->DATA_WIDTH_BYTES;
			logic.data = devc->raw_sample_buf;
			sr_session_send(cb_data, &packet);
		}

		/* Send the trigger. */
		packet.type = SR_DF_TRIGGER;
		sr_session_send(cb_data, &packet);

		/* Send post-trigger samples. */
		packet.type = SR_DF_LOGIC;
		packet.payload = &logic;
		logic.length = (devc->limit_samples - devc->delay_value) *
			devc->DATA_WIDTH_BYTES;
		logic.unitsize = devc->DATA_WIDTH_BYTES;
		logic.data = devc->raw_sample_buf +
			(devc->delay_value * devc->DATA_WIDTH_BYTES);
		sr_session_send(cb_data, &packet);

		g_free(devc->raw_sample_buf);
		devc->raw_sample_buf = NULL;

		ipdbg_org_la_abort_acquisition(sdi);
	}

	return TRUE;
}

SR_PRIV int ipdbg_org_la_send_delay(struct ipdbg_org_la_dev_context *devc,
	struct ipdbg_org_la_tcp *tcp)
{
	devc->delay_value = (devc->limit_samples / 100.0) * devc->capture_ratio;

	uint8_t buf;
	buf = CMD_CFG_LA;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	buf = CMD_LA_DELAY;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);

	uint8_t delay_buf[4] = { devc->delay_value & 0x000000ff,
		(devc->delay_value >> 8) & 0x000000ff,
		(devc->delay_value >> 16) & 0x000000ff,
		(devc->delay_value >> 24) & 0x000000ff
	};

	for (uint64_t i = 0; i < devc->ADDR_WIDTH_BYTES; i++)
		send_escaping(tcp, &(delay_buf[devc->ADDR_WIDTH_BYTES - 1 - i]), 1);

	return SR_OK;
}

SR_PRIV int ipdbg_org_la_send_trigger(struct ipdbg_org_la_dev_context *devc,
	struct ipdbg_org_la_tcp *tcp)
{
	uint8_t buf;

	/* Mask */
	buf = CMD_CFG_TRIGGER;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	buf = CMD_TRIG_MASKS;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	buf = CMD_TRIG_MASK;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);

	for (size_t i = 0; i < devc->DATA_WIDTH_BYTES; i++)
		send_escaping(tcp,
			devc->trigger_mask + devc->DATA_WIDTH_BYTES - 1 - i, 1);

	/* Value */
	buf = CMD_CFG_TRIGGER;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	buf = CMD_TRIG_MASKS;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	buf = CMD_TRIG_VALUE;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);

	for (size_t i = 0; i < devc->DATA_WIDTH_BYTES; i++)
		send_escaping(tcp,
			devc->trigger_value + devc->DATA_WIDTH_BYTES - 1 - i, 1);

	/* Mask_last */
	buf = CMD_CFG_TRIGGER;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	buf = CMD_TRIG_MASKS_LAST;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	buf = CMD_TRIG_MASK_LAST;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);

	for (size_t i = 0; i < devc->DATA_WIDTH_BYTES; i++)
		send_escaping(tcp,
			devc->trigger_mask_last + devc->DATA_WIDTH_BYTES - 1 - i, 1);

	/* Value_last */
	buf = CMD_CFG_TRIGGER;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	buf = CMD_TRIG_MASKS_LAST;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	buf = CMD_TRIG_VALUE_LAST;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);

	for (size_t i = 0; i < devc->DATA_WIDTH_BYTES; i++)
		send_escaping(tcp,
			devc->trigger_value_last + devc->DATA_WIDTH_BYTES - 1 - i, 1);

	/* Edge_mask */
	buf = CMD_CFG_TRIGGER;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	buf = CMD_TRIG_SELECT_EDGE_MASK;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	buf = CMD_TRIG_SET_EDGE_MASK;
	ipdbg_org_la_tcp_send(tcp, &buf, 1);

	for (size_t i = 0; i < devc->DATA_WIDTH_BYTES; i++)
		send_escaping(tcp,
			devc->trigger_edge_mask + devc->DATA_WIDTH_BYTES - 1 - i, 1);

	return SR_OK;
}

SR_PRIV int send_escaping(struct ipdbg_org_la_tcp *tcp, uint8_t *dataToSend,
	uint32_t length)
{
	uint8_t escape = CMD_ESCAPE;

	while (length--) {
		uint8_t payload = *dataToSend++;

		if (payload == (uint8_t) CMD_RESET)
			if (ipdbg_org_la_tcp_send(tcp, &escape, 1) != SR_OK)
				sr_warn("Couldn't send escape");

		if (payload == (uint8_t) CMD_ESCAPE)
			if (ipdbg_org_la_tcp_send(tcp, &escape, 1) != SR_OK)
				sr_warn("Couldn't send escape");

		if (ipdbg_org_la_tcp_send(tcp, &payload, 1) != SR_OK)
			sr_warn("Couldn't send data");
	}

	return SR_OK;
}

SR_PRIV void ipdbg_org_la_get_addrwidth_and_datawidth(
	struct ipdbg_org_la_tcp *tcp, struct ipdbg_org_la_dev_context *devc)
{
	uint8_t buf[8];
	uint8_t read_cmd = CMD_GET_BUS_WIDTHS;

	if (ipdbg_org_la_tcp_send(tcp, &read_cmd, 1) != SR_OK)
		sr_warn("Can't send read command");

	if (ipdbg_org_la_tcp_receive_blocking(tcp, buf, 8) != 8)
		sr_warn("Can't get address and data width from device");

	devc->DATA_WIDTH = buf[0] & 0x000000FF;
	devc->DATA_WIDTH |= (buf[1] << 8) & 0x0000FF00;
	devc->DATA_WIDTH |= (buf[2] << 16) & 0x00FF0000;
	devc->DATA_WIDTH |= (buf[3] << 24) & 0xFF000000;

	devc->ADDR_WIDTH = buf[4] & 0x000000FF;
	devc->ADDR_WIDTH |= (buf[5] << 8) & 0x0000FF00;
	devc->ADDR_WIDTH |= (buf[6] << 16) & 0x00FF0000;
	devc->ADDR_WIDTH |= (buf[7] << 24) & 0xFF000000;

	uint8_t HOST_WORD_SIZE = 8;

	devc->DATA_WIDTH_BYTES =
		(devc->DATA_WIDTH + HOST_WORD_SIZE - 1) / HOST_WORD_SIZE;
	devc->ADDR_WIDTH_BYTES =
		(devc->ADDR_WIDTH + HOST_WORD_SIZE - 1) / HOST_WORD_SIZE;

	devc->limit_samples_max = (0x01 << devc->ADDR_WIDTH);
	devc->limit_samples = devc->limit_samples_max;

	devc->trigger_mask = g_malloc0(devc->DATA_WIDTH_BYTES);
	devc->trigger_value = g_malloc0(devc->DATA_WIDTH_BYTES);
	devc->trigger_mask_last = g_malloc0(devc->DATA_WIDTH_BYTES);
	devc->trigger_value_last = g_malloc0(devc->DATA_WIDTH_BYTES);
	devc->trigger_edge_mask = g_malloc0(devc->DATA_WIDTH_BYTES);
}

SR_PRIV struct ipdbg_org_la_dev_context *ipdbg_org_la_dev_new(void)
{
	struct ipdbg_org_la_dev_context *devc;

	devc = g_malloc0(sizeof(struct ipdbg_org_la_dev_context));
	devc->capture_ratio = 50;

	return devc;
}

SR_PRIV int ipdbg_org_la_send_reset(struct ipdbg_org_la_tcp *tcp)
{
	uint8_t buf = CMD_RESET;
	if (ipdbg_org_la_tcp_send(tcp, &buf, 1) != SR_OK)
		sr_warn("Couldn't send reset");

	return SR_OK;
}

SR_PRIV int ipdbg_org_la_request_id(struct ipdbg_org_la_tcp *tcp)
{
	uint8_t buf = CMD_GET_LA_ID;
	if (ipdbg_org_la_tcp_send(tcp, &buf, 1) != SR_OK)
		sr_warn("Couldn't send ID request");

	char id[4];
	if (ipdbg_org_la_tcp_receive_blocking(tcp, (uint8_t*)id, 4) != 4) {
		sr_err("Couldn't read device ID");
		return SR_ERR;
	}

	if (strncmp(id, "IDBG", 4)) {
		sr_err("Invalid device ID: expected 'IDBG', got '%c%c%c%c'.",
			id[0], id[1], id[2], id[3]);
		return SR_ERR;
	}

	return SR_OK;
}

SR_PRIV void ipdbg_org_la_abort_acquisition(const struct sr_dev_inst *sdi)
{
	struct ipdbg_org_la_tcp *tcp = sdi->conn;

	sr_session_source_remove(sdi->session, tcp->socket);

	std_session_send_df_end(sdi);
}

SR_PRIV int ipdbg_org_la_send_start(struct ipdbg_org_la_tcp *tcp)
{
	uint8_t buf = CMD_START;

	if (ipdbg_org_la_tcp_send(tcp, &buf, 1) != SR_OK)
		sr_warn("Couldn't send start");

	return SR_OK;
}
Commit	Line	Data
a4210e18 EK	1	/*
	2	* This file is part of the libsigrok project.
	3	*
	4	* Copyright (C) 2016 danselmi <da@da>
	5	*
	6	* This program is free software: you can redistribute it and/or modify
	7	* it under the terms of the GNU General Public License as published by
	8	* the Free Software Foundation, either version 3 of the License, or
	9	* (at your option) any later version.
	10	*
	11	* This program is distributed in the hope that it will be useful,
	12	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	13	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	14	* GNU General Public License for more details.
	15	*
	16	* You should have received a copy of the GNU General Public License
	17	* along with this program. If not, see <http://www.gnu.org/licenses/>.
	18	*/
	19
	20	#include <config.h>
7f4c9a04	21
a4210e18 EK	22	#ifdef _WIN32
	23	#define _WIN32_WINNT 0x0501
	24	#include <winsock2.h>
	25	#include <ws2tcpip.h>
	26	#endif
7f4c9a04	27
a4210e18 EK	28	#include <string.h>
a4210e18 EK	29	#include <unistd.h>
7f4c9a04	30
a4210e18 EK	31	#ifndef _WIN32
	32	#include <sys/socket.h>
	33	#include <netinet/in.h>
	34	#include <arpa/inet.h>
	35	#include <netdb.h>
	36	#endif
7f4c9a04	37
a4210e18 EK	38	#include <errno.h>
	39	#include "protocol.h"
	40
b51288e3 EK	41	#include <sys/ioctl.h>
b51288e3 EK	42
7f4c9a04	43	#define BUFFER_SIZE 4
2f15f5bf	44
7f4c9a04 SA	45	/* Top-level command opcodes */
	46	#define CMD_SET_TRIGGER 0x00
	47	#define CMD_CFG_TRIGGER 0xF0
	48	#define CMD_CFG_LA 0x0F
	49	#define CMD_START 0xFE
	50	#define CMD_RESET 0xEE
2f15f5bf	51
7f4c9a04 SA	52	#define CMD_GET_BUS_WIDTHS 0xAA
	53	#define CMD_GET_LA_ID 0xBB
	54	#define CMD_ESCAPE 0x55
2f15f5bf	55
7f4c9a04 SA	56	/* Trigger subfunction command opcodes */
	57	#define CMD_TRIG_MASKS 0xF1
	58	#define CMD_TRIG_MASK 0xF3
	59	#define CMD_TRIG_VALUE 0xF7
2f15f5bf	60
7f4c9a04 SA	61	#define CMD_TRIG_MASKS_LAST 0xF9
	62	#define CMD_TRIG_MASK_LAST 0xFB
	63	#define CMD_TRIG_VALUE_LAST 0xFF
2f15f5bf	64
7f4c9a04 SA	65	#define CMD_TRIG_SELECT_EDGE_MASK 0xF5
7f4c9a04 SA	66	#define CMD_TRIG_SET_EDGE_MASK 0xF6
2f15f5bf	67
7f4c9a04 SA	68	/* LA subfunction command opcodes */
7f4c9a04 SA	69	#define CMD_LA_DELAY 0x1F
a66099c6	70
7f4c9a04	71	SR_PRIV int data_available(struct ipdbg_org_la_tcp *tcp)
b51288e3 EK	72	{
b51288e3 EK	73	#ifdef __WIN32__
9d2e5483	74	ioctlsocket(tcp->socket, FIONREAD, &bytes_available);
b51288e3	75	#else
9d2e5483	76	int status;
b51288e3	77
9d2e5483 SA	78	if (ioctl(tcp->socket, FIONREAD, &status) < 0) { // TIOCMGET
	79	sr_err("FIONREAD failed: %s\n", strerror(errno));
	80	return 0;
	81	}
b51288e3	82
9d2e5483	83	return (status < 1) ? 0 : 1;
7f4c9a04	84	#endif // __WIN32__
b51288e3 EK	85	}
b51288e3 EK	86
7f4c9a04	87	SR_PRIV struct ipdbg_org_la_tcp *ipdbg_org_la_tcp_new(void)
a4210e18	88	{
9d2e5483	89	struct ipdbg_org_la_tcp *tcp;
a4210e18	90
9d2e5483	91	tcp = g_malloc0(sizeof(struct ipdbg_org_la_tcp));
a4210e18	92
9d2e5483 SA	93	tcp->address = NULL;
	94	tcp->port = NULL;
	95	tcp->socket = -1;
a4210e18	96
9d2e5483	97	return tcp;
a4210e18 EK	98	}
a4210e18 EK	99
7f4c9a04 SA	100	SR_PRIV void ipdbg_org_la_tcp_free(struct ipdbg_org_la_tcp *tcp)
7f4c9a04 SA	101	{
9d2e5483 SA	102	g_free(tcp->address);
9d2e5483 SA	103	g_free(tcp->port);
7f4c9a04 SA	104	}
7f4c9a04 SA	105
a4210e18 EK	106	SR_PRIV int ipdbg_org_la_tcp_open(struct ipdbg_org_la_tcp *tcp)
a4210e18 EK	107	{
9d2e5483 SA	108	struct addrinfo hints;
	109	struct addrinfo results, res;
	110	int err;
	111
	112	memset(&hints, 0, sizeof(hints));
	113	hints.ai_family = AF_UNSPEC;
	114	hints.ai_socktype = SOCK_STREAM;
	115	hints.ai_protocol = IPPROTO_TCP;
	116
	117	err = getaddrinfo(tcp->address, tcp->port, &hints, &results);
	118
	119	if (err) {
	120	sr_err("Address lookup failed: %s:%s: %s", tcp->address,
	121	tcp->port, gai_strerror(err));
	122	return SR_ERR;
	123	}
	124
	125	for (res = results; res; res = res->ai_next) {
	126	if ((tcp->socket = socket(res->ai_family, res->ai_socktype,
	127	res->ai_protocol)) < 0)
	128	continue;
	129	if (connect(tcp->socket, res->ai_addr, res->ai_addrlen) != 0) {
	130	close(tcp->socket);
	131	tcp->socket = -1;
	132	continue;
	133	}
	134	break;
	135	}
	136
	137	freeaddrinfo(results);
	138
	139	if (tcp->socket < 0) {
	140	sr_err("Failed to connect to %s:%s: %s", tcp->address, tcp->port,
	141	g_strerror(errno));
	142	return SR_ERR;
	143	}
	144
	145	return SR_OK;
a4210e18 EK	146	}
a4210e18 EK	147
7f4c9a04 SA	148	SR_PRIV int ipdbg_org_la_tcp_close(struct ipdbg_org_la_tcp *tcp)
7f4c9a04 SA	149	{
9d2e5483	150	int ret = SR_OK;
7f4c9a04	151
9d2e5483 SA	152	if (close(tcp->socket) < 0)
9d2e5483 SA	153	ret = SR_ERR;
7f4c9a04	154
9d2e5483	155	tcp->socket = -1;
7f4c9a04	156
9d2e5483	157	return ret;
7f4c9a04 SA	158	}
	159
	160	SR_PRIV int ipdbg_org_la_tcp_send(struct ipdbg_org_la_tcp *tcp,
	161	const uint8_t *buf, size_t len)
a4210e18	162	{
9d2e5483 SA	163	int out;
9d2e5483 SA	164	out = send(tcp->socket, (char*)buf, len, 0);
a4210e18	165
9d2e5483 SA	166	if (out < 0) {
	167	sr_err("Send error: %s", g_strerror(errno));
	168	return SR_ERR;
	169	}
a4210e18	170
9d2e5483 SA	171	if (out < (int)len)
9d2e5483 SA	172	sr_dbg("Only sent %d/%d bytes of data.", out, (int)len);
a4210e18	173
9d2e5483	174	return SR_OK;
a4210e18 EK	175	}
a4210e18 EK	176
7f4c9a04 SA	177	SR_PRIV int ipdbg_org_la_tcp_receive_blocking(struct ipdbg_org_la_tcp *tcp,
7f4c9a04 SA	178	uint8_t *buf, int bufsize)
a4210e18	179	{
9d2e5483	180	int received = 0;
ed186484	181	int error_count = 0;
7f4c9a04	182
ed186484 SA	183	/* Timeout after 500ms of not receiving data */
ed186484 SA	184	while ((received < bufsize) && (error_count < 500)) {
9d2e5483 SA	185	if (ipdbg_org_la_tcp_receive(tcp, buf) > 0) {
	186	buf++;
	187	received++;
ed186484 SA	188	} else {
	189	error_count++;
	190	g_usleep(1000); /* Sleep for 1ms */
9d2e5483 SA	191	}
9d2e5483 SA	192	}
7f4c9a04	193
9d2e5483	194	return received;
a4210e18	195	}
7f4c9a04	196
9d2e5483 SA	197	SR_PRIV int ipdbg_org_la_tcp_receive(struct ipdbg_org_la_tcp *tcp,
9d2e5483 SA	198	uint8_t *buf)
b51288e3	199	{
9d2e5483 SA	200	int received = 0;
	201
	202	if (data_available(tcp)) {
	203	while (received < 1) {
	204	int len = recv(tcp->socket, buf, 1, 0);
	205
	206	if (len < 0) {
	207	sr_err("Receive error: %s", g_strerror(errno));
	208	return SR_ERR;
	209	} else
	210	received += len;
	211	}
	212
	213	return received;
	214	} else
	215	return -1;
a4210e18 EK	216	}
	217
	218	SR_PRIV int ipdbg_org_la_convert_trigger(const struct sr_dev_inst *sdi)
	219	{
9d2e5483 SA	220	struct ipdbg_org_la_dev_context *devc;
	221	struct sr_trigger *trigger;
	222	struct sr_trigger_stage *stage;
	223	struct sr_trigger_match *match;
	224	const GSList l, m;
	225
	226	devc = sdi->priv;
	227
	228	devc->num_stages = 0;
	229	devc->num_transfers = 0;
	230	devc->raw_sample_buf = NULL;
	231
	232	for (uint64_t i = 0; i < devc->DATA_WIDTH_BYTES; i++) {
	233	devc->trigger_mask[i] = 0;
	234	devc->trigger_value[i] = 0;
	235	devc->trigger_mask_last[i] = 0;
	236	devc->trigger_value_last[i] = 0;
	237	devc->trigger_edge_mask[i] = 0;
	238	}
	239
	240	if (!(trigger = sr_session_trigger_get(sdi->session)))
	241	return SR_OK;
	242
	243	for (l = trigger->stages; l; l = l->next) {
	244	stage = l->data;
	245	for (m = stage->matches; m; m = m->next) {
	246	match = m->data;
	247	int byte_idx = match->channel->index / 8;
	248	uint8_t match_bit = 1 << (match->channel->index % 8);
	249
	250	if (!match->channel->enabled)
	251	/* Ignore disabled channels with a trigger. */
	252	continue;
	253
	254	if (match->match == SR_TRIGGER_ONE) {
	255	devc->trigger_value[byte_idx] \|= match_bit;
	256	devc->trigger_mask[byte_idx] \|= match_bit;
	257	devc->trigger_mask_last[byte_idx] &= ~match_bit;
	258	devc->trigger_edge_mask[byte_idx] &= ~match_bit;
	259	} else if (match->match == SR_TRIGGER_ZERO) {
	260	devc->trigger_value[byte_idx] &= ~match_bit;
	261	devc->trigger_mask[byte_idx] \|= match_bit;
	262	devc->trigger_mask_last[byte_idx] &= ~match_bit;
	263	devc->trigger_edge_mask[byte_idx] &= ~match_bit;
	264	} else if (match->match == SR_TRIGGER_RISING) {
	265	devc->trigger_value[byte_idx] \|= match_bit;
	266	devc->trigger_value_last[byte_idx] &=
	267	~match_bit;
	268	devc->trigger_mask[byte_idx] \|= match_bit;
	269	devc->trigger_mask_last[byte_idx] \|= match_bit;
	270	devc->trigger_edge_mask[byte_idx] &= ~match_bit;
	271	} else if (match->match == SR_TRIGGER_FALLING) {
	272	devc->trigger_value[byte_idx] &= ~match_bit;
	273	devc->trigger_value_last[byte_idx] \|= match_bit;
	274	devc->trigger_mask[byte_idx] \|= match_bit;
	275	devc->trigger_mask_last[byte_idx] \|= match_bit;
	276	devc->trigger_edge_mask[byte_idx] &= ~match_bit;
	277	} else if (match->match == SR_TRIGGER_EDGE) {
	278	devc->trigger_mask[byte_idx] &= ~match_bit;
	279	devc->trigger_mask_last[byte_idx] &= ~match_bit;
	280	devc->trigger_edge_mask[byte_idx] \|= match_bit;
	281	}
	282	}
	283	}
284
285	return SR_OK;
a4210e18 EK	286	}
	287
	288	SR_PRIV int ipdbg_org_la_receive_data(int fd, int revents, void *cb_data)
	289	{
9d2e5483 SA	290	const struct sr_dev_inst *sdi;
	291	struct ipdbg_org_la_dev_context *devc;
	292
	293	(void)fd;
	294	(void)revents;
	295
	296	sdi = (const struct sr_dev_inst *)cb_data;
	297	if (!sdi)
	298	return FALSE;
	299
	300	if (!(devc = sdi->priv))
	301	return FALSE;
	302
	303	struct ipdbg_org_la_tcp *tcp = sdi->conn;
	304	struct sr_datafeed_packet packet;
	305	struct sr_datafeed_logic logic;
	306
	307	if (!devc->raw_sample_buf) {
	308	devc->raw_sample_buf =
	309	g_try_malloc(devc->limit_samples * devc->DATA_WIDTH_BYTES);
	310	if (!devc->raw_sample_buf) {
	311	sr_warn("Sample buffer malloc failed.");
	312	return FALSE;
	313	}
	314	}
	315
	316	if (devc->num_transfers <
	317	(devc->limit_samples_max * devc->DATA_WIDTH_BYTES)) {
	318	uint8_t byte;
	319
	320	if (ipdbg_org_la_tcp_receive(tcp, &byte) == 1) {
	321	if (devc->num_transfers <
	322	(devc->limit_samples * devc->DATA_WIDTH_BYTES))
	323	devc->raw_sample_buf[devc->num_transfers] = byte;
	324
	325	devc->num_transfers++;
	326	}
	327	} else {
	328	if (devc->delay_value > 0) {
	329	/* There are pre-trigger samples, send those first. */
	330	packet.type = SR_DF_LOGIC;
	331	packet.payload = &logic;
	332	logic.length = devc->delay_value * devc->DATA_WIDTH_BYTES;
	333	logic.unitsize = devc->DATA_WIDTH_BYTES;
	334	logic.data = devc->raw_sample_buf;
	335	sr_session_send(cb_data, &packet);
	336	}
	337
	338	/* Send the trigger. */
	339	packet.type = SR_DF_TRIGGER;
	340	sr_session_send(cb_data, &packet);
	341
	342	/* Send post-trigger samples. */
	343	packet.type = SR_DF_LOGIC;
	344	packet.payload = &logic;
	345	logic.length = (devc->limit_samples - devc->delay_value) *
	346	devc->DATA_WIDTH_BYTES;
	347	logic.unitsize = devc->DATA_WIDTH_BYTES;
	348	logic.data = devc->raw_sample_buf +
	349	(devc->delay_value * devc->DATA_WIDTH_BYTES);
	350	sr_session_send(cb_data, &packet);
	351
	352	g_free(devc->raw_sample_buf);
	353	devc->raw_sample_buf = NULL;
354
355	ipdbg_org_la_abort_acquisition(sdi);
356	}
357
358	return TRUE;
a4210e18 EK	359	}
a4210e18 EK	360
7f4c9a04 SA	361	SR_PRIV int ipdbg_org_la_send_delay(struct ipdbg_org_la_dev_context *devc,
7f4c9a04 SA	362	struct ipdbg_org_la_tcp *tcp)
a4210e18	363	{
9d2e5483	364	devc->delay_value = (devc->limit_samples / 100.0) * devc->capture_ratio;
a4210e18	365
9d2e5483 SA	366	uint8_t buf;
	367	buf = CMD_CFG_LA;
	368	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	369	buf = CMD_LA_DELAY;
	370	ipdbg_org_la_tcp_send(tcp, &buf, 1);
a4210e18	371
9d2e5483 SA	372	uint8_t delay_buf[4] = { devc->delay_value & 0x000000ff,
	373	(devc->delay_value >> 8) & 0x000000ff,
	374	(devc->delay_value >> 16) & 0x000000ff,
	375	(devc->delay_value >> 24) & 0x000000ff
	376	};
a4210e18	377
9d2e5483 SA	378	for (uint64_t i = 0; i < devc->ADDR_WIDTH_BYTES; i++)
9d2e5483 SA	379	send_escaping(tcp, &(delay_buf[devc->ADDR_WIDTH_BYTES - 1 - i]), 1);
a4210e18	380
9d2e5483	381	return SR_OK;
a4210e18 EK	382	}
a4210e18 EK	383
7f4c9a04 SA	384	SR_PRIV int ipdbg_org_la_send_trigger(struct ipdbg_org_la_dev_context *devc,
7f4c9a04 SA	385	struct ipdbg_org_la_tcp *tcp)
a4210e18	386	{
9d2e5483 SA	387	uint8_t buf;
	388
	389	/* Mask */
	390	buf = CMD_CFG_TRIGGER;
	391	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	392	buf = CMD_TRIG_MASKS;
	393	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	394	buf = CMD_TRIG_MASK;
	395	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	396
	397	for (size_t i = 0; i < devc->DATA_WIDTH_BYTES; i++)
	398	send_escaping(tcp,
	399	devc->trigger_mask + devc->DATA_WIDTH_BYTES - 1 - i, 1);
	400
	401	/* Value */
	402	buf = CMD_CFG_TRIGGER;
	403	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	404	buf = CMD_TRIG_MASKS;
	405	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	406	buf = CMD_TRIG_VALUE;
	407	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	408
	409	for (size_t i = 0; i < devc->DATA_WIDTH_BYTES; i++)
	410	send_escaping(tcp,
	411	devc->trigger_value + devc->DATA_WIDTH_BYTES - 1 - i, 1);
	412
	413	/* Mask_last */
	414	buf = CMD_CFG_TRIGGER;
	415	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	416	buf = CMD_TRIG_MASKS_LAST;
	417	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	418	buf = CMD_TRIG_MASK_LAST;
	419	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	420
	421	for (size_t i = 0; i < devc->DATA_WIDTH_BYTES; i++)
	422	send_escaping(tcp,
	423	devc->trigger_mask_last + devc->DATA_WIDTH_BYTES - 1 - i, 1);
	424
	425	/* Value_last */
	426	buf = CMD_CFG_TRIGGER;
	427	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	428	buf = CMD_TRIG_MASKS_LAST;
	429	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	430	buf = CMD_TRIG_VALUE_LAST;
	431	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	432
	433	for (size_t i = 0; i < devc->DATA_WIDTH_BYTES; i++)
	434	send_escaping(tcp,
	435	devc->trigger_value_last + devc->DATA_WIDTH_BYTES - 1 - i, 1);
	436
	437	/* Edge_mask */
	438	buf = CMD_CFG_TRIGGER;
	439	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	440	buf = CMD_TRIG_SELECT_EDGE_MASK;
	441	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	442	buf = CMD_TRIG_SET_EDGE_MASK;
	443	ipdbg_org_la_tcp_send(tcp, &buf, 1);
	444
	445	for (size_t i = 0; i < devc->DATA_WIDTH_BYTES; i++)
	446	send_escaping(tcp,
	447	devc->trigger_edge_mask + devc->DATA_WIDTH_BYTES - 1 - i, 1);
	448
	449	return SR_OK;
a4210e18 EK	450	}
a4210e18 EK	451
9d2e5483 SA	452	SR_PRIV int send_escaping(struct ipdbg_org_la_tcp tcp, uint8_t dataToSend,
9d2e5483 SA	453	uint32_t length)
a4210e18	454	{
9d2e5483	455	uint8_t escape = CMD_ESCAPE;
a4210e18	456
9d2e5483 SA	457	while (length--) {
9d2e5483 SA	458	uint8_t payload = *dataToSend++;
a4210e18	459
9d2e5483 SA	460	if (payload == (uint8_t) CMD_RESET)
	461	if (ipdbg_org_la_tcp_send(tcp, &escape, 1) != SR_OK)
	462	sr_warn("Couldn't send escape");
a4210e18	463
9d2e5483 SA	464	if (payload == (uint8_t) CMD_ESCAPE)
	465	if (ipdbg_org_la_tcp_send(tcp, &escape, 1) != SR_OK)
	466	sr_warn("Couldn't send escape");
a4210e18	467
9d2e5483 SA	468	if (ipdbg_org_la_tcp_send(tcp, &payload, 1) != SR_OK)
	469	sr_warn("Couldn't send data");
	470	}
7f4c9a04	471
9d2e5483	472	return SR_OK;
a4210e18 EK	473	}
a4210e18 EK	474
9d2e5483 SA	475	SR_PRIV void ipdbg_org_la_get_addrwidth_and_datawidth(
9d2e5483 SA	476	struct ipdbg_org_la_tcp tcp, struct ipdbg_org_la_dev_context devc)
a4210e18	477	{
9d2e5483 SA	478	uint8_t buf[8];
9d2e5483 SA	479	uint8_t read_cmd = CMD_GET_BUS_WIDTHS;
a4210e18	480
9d2e5483 SA	481	if (ipdbg_org_la_tcp_send(tcp, &read_cmd, 1) != SR_OK)
9d2e5483 SA	482	sr_warn("Can't send read command");
a4210e18	483
9d2e5483 SA	484	if (ipdbg_org_la_tcp_receive_blocking(tcp, buf, 8) != 8)
9d2e5483 SA	485	sr_warn("Can't get address and data width from device");
b51288e3	486
9d2e5483 SA	487	devc->DATA_WIDTH = buf[0] & 0x000000FF;
	488	devc->DATA_WIDTH \|= (buf[1] << 8) & 0x0000FF00;
	489	devc->DATA_WIDTH \|= (buf[2] << 16) & 0x00FF0000;
	490	devc->DATA_WIDTH \|= (buf[3] << 24) & 0xFF000000;
a4210e18	491
9d2e5483 SA	492	devc->ADDR_WIDTH = buf[4] & 0x000000FF;
	493	devc->ADDR_WIDTH \|= (buf[5] << 8) & 0x0000FF00;
	494	devc->ADDR_WIDTH \|= (buf[6] << 16) & 0x00FF0000;
	495	devc->ADDR_WIDTH \|= (buf[7] << 24) & 0xFF000000;
a4210e18	496
9d2e5483	497	uint8_t HOST_WORD_SIZE = 8;
a4210e18	498
9d2e5483 SA	499	devc->DATA_WIDTH_BYTES =
	500	(devc->DATA_WIDTH + HOST_WORD_SIZE - 1) / HOST_WORD_SIZE;
	501	devc->ADDR_WIDTH_BYTES =
	502	(devc->ADDR_WIDTH + HOST_WORD_SIZE - 1) / HOST_WORD_SIZE;
a4210e18	503
9d2e5483 SA	504	devc->limit_samples_max = (0x01 << devc->ADDR_WIDTH);
	505	devc->limit_samples = devc->limit_samples_max;
	506
	507	devc->trigger_mask = g_malloc0(devc->DATA_WIDTH_BYTES);
	508	devc->trigger_value = g_malloc0(devc->DATA_WIDTH_BYTES);
	509	devc->trigger_mask_last = g_malloc0(devc->DATA_WIDTH_BYTES);
	510	devc->trigger_value_last = g_malloc0(devc->DATA_WIDTH_BYTES);
	511	devc->trigger_edge_mask = g_malloc0(devc->DATA_WIDTH_BYTES);
a4210e18 EK	512	}
	513
	514	SR_PRIV struct ipdbg_org_la_dev_context *ipdbg_org_la_dev_new(void)
	515	{
9d2e5483	516	struct ipdbg_org_la_dev_context *devc;
a4210e18	517
9d2e5483 SA	518	devc = g_malloc0(sizeof(struct ipdbg_org_la_dev_context));
9d2e5483 SA	519	devc->capture_ratio = 50;
a4210e18	520
9d2e5483	521	return devc;
a4210e18 EK	522	}
a4210e18 EK	523
7f4c9a04	524	SR_PRIV int ipdbg_org_la_send_reset(struct ipdbg_org_la_tcp *tcp)
a4210e18	525	{
9d2e5483 SA	526	uint8_t buf = CMD_RESET;
	527	if (ipdbg_org_la_tcp_send(tcp, &buf, 1) != SR_OK)
	528	sr_warn("Couldn't send reset");
7f4c9a04	529
9d2e5483	530	return SR_OK;
a4210e18 EK	531	}
a4210e18 EK	532
7f4c9a04	533	SR_PRIV int ipdbg_org_la_request_id(struct ipdbg_org_la_tcp *tcp)
a4210e18	534	{
9d2e5483 SA	535	uint8_t buf = CMD_GET_LA_ID;
	536	if (ipdbg_org_la_tcp_send(tcp, &buf, 1) != SR_OK)
	537	sr_warn("Couldn't send ID request");
a4210e18	538
9d2e5483	539	char id[4];
ed186484 SA	540	if (ipdbg_org_la_tcp_receive_blocking(tcp, (uint8_t*)id, 4) != 4) {
	541	sr_err("Couldn't read device ID");
	542	return SR_ERR;
	543	}
a4210e18	544
9d2e5483 SA	545	if (strncmp(id, "IDBG", 4)) {
	546	sr_err("Invalid device ID: expected 'IDBG', got '%c%c%c%c'.",
	547	id[0], id[1], id[2], id[3]);
	548	return SR_ERR;
	549	}
a4210e18	550
9d2e5483	551	return SR_OK;
a4210e18 EK	552	}
	553
	554	SR_PRIV void ipdbg_org_la_abort_acquisition(const struct sr_dev_inst *sdi)
	555	{
9d2e5483	556	struct ipdbg_org_la_tcp *tcp = sdi->conn;
a4210e18	557
9d2e5483	558	sr_session_source_remove(sdi->session, tcp->socket);
a4210e18	559
9d2e5483	560	std_session_send_df_end(sdi);
a4210e18 EK	561	}
a4210e18 EK	562
7f4c9a04	563	SR_PRIV int ipdbg_org_la_send_start(struct ipdbg_org_la_tcp *tcp)
a4210e18	564	{
9d2e5483	565	uint8_t buf = CMD_START;
a4210e18	566
9d2e5483 SA	567	if (ipdbg_org_la_tcp_send(tcp, &buf, 1) != SR_OK)
9d2e5483 SA	568	sr_warn("Couldn't send start");
7f4c9a04	569
9d2e5483	570	return SR_OK;
a4210e18	571	}