[libsigrok.git] / hardware / demo / demo.c

/*
 * This file is part of the sigrok project.
 *
 * Copyright (C) 2010 Uwe Hermann <uwe@hermann-uwe.de>
 * Copyright (C) 2011 Olivier Fauchon <olivier@aixmarseille.com>
 *
 * 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 2 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, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301 USA
 */

#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sigrok.h>
#ifdef _WIN32
#include <io.h>
#include <fcntl.h>
#define pipe(fds) _pipe(fds, 4096, _O_BINARY)
#endif
#include "config.h"

#define NUM_PROBES             8
#define DEMONAME               "Demo device"
/* size of chunks to send through the session bus */
#define BUFSIZE                4096

enum {
	GENMODE_DEFAULT,
	GENMODE_RANDOM,
	GENMODE_INC,
};

GIOChannel *channels[2];

struct databag {
	int pipe_fds[2];
	uint8_t sample_generator;
	uint8_t thread_running;
	uint64_t samples_counter;
	int device_index;
	int loop_sleep;
	gpointer session_device_id;
};

static GThread *my_thread;
static int thread_running;

static int capabilities[] = {
	HWCAP_LOGIC_ANALYZER,
	HWCAP_PATTERN_MODE,
	HWCAP_LIMIT_SAMPLES,
	HWCAP_CONTINUOUS
};

static const char *patternmodes[] = {
	"random",
	"incremental",
	NULL,
};

static uint8_t genmode_default[] = {
	0x4c, 0x92, 0x92, 0x92, 0x64, 0x00, 0x00, 0x00,
	0x82, 0xfe, 0xfe, 0x82, 0x00, 0x00, 0x00, 0x00,
	0x7c, 0x82, 0x82, 0x92, 0x74, 0x00, 0x00, 0x00,
	0xfe, 0x12, 0x12, 0x32, 0xcc, 0x00, 0x00, 0x00,
	0x7c, 0x82, 0x82, 0x82, 0x7c, 0x00, 0x00, 0x00,
	0xfe, 0x10, 0x28, 0x44, 0x82, 0x00, 0x00, 0x00,
	0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	0xbe, 0xbe, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
};

/* List of struct sigrok_device_instance, maintained by opendev()/closedev(). */
static GSList *device_instances = NULL;
static uint64_t cur_samplerate = 0;
static uint64_t limit_samples = -1;
static int default_genmode = GENMODE_DEFAULT;

static void hw_stop_acquisition(int device_index, gpointer session_device_id);

static int hw_init(char *deviceinfo)
{
	struct sigrok_device_instance *sdi;

	/* Avoid compiler warnings. */
	deviceinfo = deviceinfo;

	sdi = sigrok_device_instance_new(0, ST_ACTIVE, DEMONAME, NULL, NULL);
	if (!sdi)
		return 0;

	device_instances = g_slist_append(device_instances, sdi);

	return 1;
}

static int hw_opendev(int device_index)
{
	/* Avoid compiler warnings. */
	device_index = device_index;

	/* Nothing needed so far. */
	return SIGROK_OK;
}

static void hw_closedev(int device_index)
{
	/* Avoid compiler warnings. */
	device_index = device_index;

	/* Nothing needed so far. */
}

static void hw_cleanup(void)
{
	/* Nothing needed so far. */
}

static void *hw_get_device_info(int device_index, int device_info_id)
{
	struct sigrok_device_instance *sdi;
	void *info = NULL;

	if (!(sdi = get_sigrok_device_instance(device_instances, device_index)))
		return NULL;

	switch (device_info_id) {
	case DI_INSTANCE:
		info = sdi;
		break;
	case DI_NUM_PROBES:
		info = GINT_TO_POINTER(NUM_PROBES);
		break;
	case DI_CUR_SAMPLERATE:
		info = &cur_samplerate;
		break;
	case DI_PATTERNMODES:
		info = &patternmodes;
		break;
	}

	return info;
}

static int hw_get_status(int device_index)
{
	/* Avoid compiler warnings. */
	device_index = device_index;

	return ST_ACTIVE;
}

static int *hw_get_capabilities(void)
{
	return capabilities;
}

static int hw_set_configuration(int device_index, int capability, void *value)
{
	int ret;
	uint64_t *tmp_u64;
	char *stropt;

	/* Avoid compiler warnings. */
	device_index = device_index;

	if (capability == HWCAP_PROBECONFIG) {
		/* Nothing to do. */
		ret = SIGROK_OK;
	} else if (capability == HWCAP_LIMIT_SAMPLES) {
		tmp_u64 = value;
		limit_samples = *tmp_u64;
		ret = SIGROK_OK;
	} else if (capability == HWCAP_PATTERN_MODE) {
		stropt = value;
		if (!strcmp(stropt, "random")) {
			default_genmode = GENMODE_RANDOM;
			ret = SIGROK_OK;
		} else if (!strcmp(stropt, "incremental")) {
			default_genmode = GENMODE_INC;
			ret = SIGROK_OK;
		} else {
			ret = SIGROK_ERR;
		}
	} else {
		ret = SIGROK_ERR;
	}

	return ret;
}

static void samples_generator(uint8_t *buf, uint64_t size, void *data)
{
	struct databag *mydata = data;
	uint64_t p, i;

	memset(buf, 0, size);

	switch (mydata->sample_generator) {
	case GENMODE_DEFAULT:
		p = 0;
		for (i = 0; i < size; i++) {
			*(buf + i) = ~(genmode_default[p] >> 1);
			if (++p == 64)
				p = 0;
		}
		break;
	case GENMODE_RANDOM: /* Random */
		for (i = 0; i < size; i++)
			*(buf + i) = (uint8_t)(rand() & 0xff);
		break;
	case GENMODE_INC: /* Simple increment */
		for (i = 0; i < size; i++)
			*(buf + i) = i;
		break;
	}
}

/* Thread function */
static void thread_func(void *data)
{
	struct databag *mydata = data;
	uint8_t buf[BUFSIZE];
	uint64_t nb_to_send = 0;
	int bytes_written;

	while (thread_running) {
		if (limit_samples)
			nb_to_send = limit_samples - mydata->samples_counter;
		else
			nb_to_send = BUFSIZE;  /* Continuous mode */

		if (nb_to_send == 0) {
			close(mydata->pipe_fds[1]);
			thread_running = 0;
			hw_stop_acquisition(mydata->device_index,
					    mydata->session_device_id);
		} else if (nb_to_send > BUFSIZE) {
			nb_to_send = BUFSIZE;
		}

		samples_generator(buf, nb_to_send, data);
		mydata->samples_counter += nb_to_send;

		g_io_channel_write_chars(channels[1], (gchar *)&buf,
				nb_to_send, (gsize *)&bytes_written, NULL);

		g_usleep(mydata->loop_sleep);
	}
}

/* Callback handling data */
static int receive_data(int fd, int revents, void *user_data)
{
	struct datafeed_packet packet;
	char c[BUFSIZE];
	uint64_t z;

	/* Avoid compiler warnings. */
	fd = fd;
	revents = revents;

	g_io_channel_read_chars(channels[0], (gchar *)&c, BUFSIZE, &z, NULL);

	if (z > 0) {
		packet.type = DF_LOGIC;
		packet.length = z;
		packet.unitsize = 1;
		packet.payload = c;
		session_bus(user_data, &packet);
	}
	return TRUE;
}

static int hw_start_acquisition(int device_index, gpointer session_device_id)
{
	struct datafeed_packet *packet;
	struct datafeed_header *header;
	struct databag *mydata;

	mydata = malloc(sizeof(struct databag));
	if (!mydata)
		return SIGROK_ERR_MALLOC;

	mydata->sample_generator = default_genmode;
	mydata->session_device_id = session_device_id;
	mydata->device_index = device_index;
	mydata->samples_counter = 0;
	mydata->loop_sleep = 100000;

	if (pipe(mydata->pipe_fds))
		return SIGROK_ERR;

	channels[0] = g_io_channel_unix_new(mydata->pipe_fds[0]);
	channels[1] = g_io_channel_unix_new(mydata->pipe_fds[1]);

	/* Set channel encoding to binary (default is UTF-8). */
	g_io_channel_set_encoding(channels[0], NULL, NULL);
	g_io_channel_set_encoding(channels[1], NULL, NULL);

	/* Make channels to unbuffered. */
	g_io_channel_set_buffered(channels[0], FALSE);
	g_io_channel_set_buffered(channels[1], FALSE);

	source_add(mydata->pipe_fds[0], G_IO_IN | G_IO_ERR, 40, receive_data,
		   session_device_id);

	/* Run the demo thread. */
	g_thread_init(NULL);
	thread_running = 1;
	my_thread =
	    g_thread_create((GThreadFunc)thread_func, mydata, TRUE, NULL);
	if (!my_thread)
		return SIGROK_ERR;

	packet = malloc(sizeof(struct datafeed_packet));
	header = malloc(sizeof(struct datafeed_header));
	if (!packet || !header)
		return SIGROK_ERR_MALLOC;

	packet->type = DF_HEADER;
	packet->length = sizeof(struct datafeed_header);
	packet->payload = (unsigned char *)header;
	header->feed_version = 1;
	gettimeofday(&header->starttime, NULL);
	header->samplerate = cur_samplerate;
	header->protocol_id = PROTO_RAW;
	header->num_logic_probes = NUM_PROBES;
	header->num_analog_probes = 0;
	session_bus(session_device_id, packet);
	free(header);
	free(packet);

	return SIGROK_OK;
}

static void hw_stop_acquisition(int device_index, gpointer session_device_id)
{
	struct datafeed_packet packet;

	/* Avoid compiler warnings. */
	device_index = device_index;

	/* Send last packet. */
	packet.type = DF_END;
	session_bus(session_device_id, &packet);
}

struct device_plugin demo_plugin_info = {
	"demo",
	1,
	hw_init,
	hw_cleanup,
	hw_opendev,
	hw_closedev,
	hw_get_device_info,
	hw_get_status,
	hw_get_capabilities,
	hw_set_configuration,
	hw_start_acquisition,
	hw_stop_acquisition,
};
Commit	Line	Data
6239c175 UH	1	/*
	2	* This file is part of the sigrok project.
	3	*
	4	* Copyright (C) 2010 Uwe Hermann <uwe@hermann-uwe.de>
fc96e6f8	5	* Copyright (C) 2011 Olivier Fauchon <olivier@aixmarseille.com>
6239c175 UH	6	*
	7	* This program is free software; you can redistribute it and/or modify
	8	* it under the terms of the GNU General Public License as published by
	9	* the Free Software Foundation; either version 2 of the License, or
	10	* (at your option) any later version.
	11	*
	12	* This program is distributed in the hope that it will be useful,
	13	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	14	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	15	* GNU General Public License for more details.
	16	*
	17	* You should have received a copy of the GNU General Public License
	18	* along with this program; if not, write to the Free Software
	19	* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
	20	*/
	21
	22	#include <stdlib.h>
85b5af06	23	#include <unistd.h>
6239c175 UH	24	#include <string.h>
6239c175 UH	25	#include <sigrok.h>
d35aaf02 UH	26	#ifdef _WIN32
	27	#include <io.h>
	28	#include <fcntl.h>
	29	#define pipe(fds) _pipe(fds, 4096, _O_BINARY)
	30	#endif
6239c175 UH	31	#include "config.h"
6239c175 UH	32
e15f48c2 BV	33	#define NUM_PROBES 8
	34	#define DEMONAME "Demo device"
	35	/* size of chunks to send through the session bus */
	36	#define BUFSIZE 4096
85b5af06	37
e15f48c2	38	enum {
917e0e71	39	GENMODE_DEFAULT,
e15f48c2 BV	40	GENMODE_RANDOM,
	41	GENMODE_INC,
	42	};
85b5af06	43
d35aaf02 UH	44	GIOChannel *channels[2];
d35aaf02 UH	45
e15f48c2 BV	46	struct databag {
	47	int pipe_fds[2];
	48	uint8_t sample_generator;
	49	uint8_t thread_running;
	50	uint64_t samples_counter;
	51	int device_index;
	52	int loop_sleep;
	53	gpointer session_device_id;
	54	};
85b5af06 UH	55
	56	static GThread *my_thread;
	57	static int thread_running;
	58
6239c175 UH	59	static int capabilities[] = {
6239c175 UH	60	HWCAP_LOGIC_ANALYZER,
e15f48c2	61	HWCAP_PATTERN_MODE,
6239c175	62	HWCAP_LIMIT_SAMPLES,
ba3d481b	63	HWCAP_CONTINUOUS
6239c175 UH	64	};
6239c175 UH	65
02440dd8	66	static const char *patternmodes[] = {
e15f48c2 BV	67	"random",
e15f48c2 BV	68	"incremental",
02440dd8	69	NULL,
85b5af06 UH	70	};
85b5af06 UH	71
917e0e71 BV	72	static uint8_t genmode_default[] = {
	73	0x4c, 0x92, 0x92, 0x92, 0x64, 0x00, 0x00, 0x00,
	74	0x82, 0xfe, 0xfe, 0x82, 0x00, 0x00, 0x00, 0x00,
	75	0x7c, 0x82, 0x82, 0x92, 0x74, 0x00, 0x00, 0x00,
	76	0xfe, 0x12, 0x12, 0x32, 0xcc, 0x00, 0x00, 0x00,
	77	0x7c, 0x82, 0x82, 0x82, 0x7c, 0x00, 0x00, 0x00,
	78	0xfe, 0x10, 0x28, 0x44, 0x82, 0x00, 0x00, 0x00,
	79	0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	80	0xbe, 0xbe, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	81	};
	82
85b5af06 UH	83	/* List of struct sigrok_device_instance, maintained by opendev()/closedev(). */
85b5af06 UH	84	static GSList *device_instances = NULL;
6239c175	85	static uint64_t cur_samplerate = 0;
ba3d481b	86	static uint64_t limit_samples = -1;
917e0e71	87	static int default_genmode = GENMODE_DEFAULT;
6239c175	88
6239c175 UH	89	static void hw_stop_acquisition(int device_index, gpointer session_device_id);
6239c175 UH	90
6239c175 UH	91	static int hw_init(char *deviceinfo)
6239c175 UH	92	{
85b5af06 UH	93	struct sigrok_device_instance *sdi;
85b5af06 UH	94
e15f48c2 BV	95	/* Avoid compiler warnings. */
e15f48c2 BV	96	deviceinfo = deviceinfo;
85b5af06	97
e15f48c2	98	sdi = sigrok_device_instance_new(0, ST_ACTIVE, DEMONAME, NULL, NULL);
85b5af06 UH	99	if (!sdi)
85b5af06 UH	100	return 0;
e15f48c2	101
85b5af06 UH	102	device_instances = g_slist_append(device_instances, sdi);
	103
	104	return 1;
6239c175 UH	105	}
	106
	107	static int hw_opendev(int device_index)
	108	{
17e1afcb	109	/* Avoid compiler warnings. */
6239c175 UH	110	device_index = device_index;
	111
	112	/* Nothing needed so far. */
	113	return SIGROK_OK;
	114	}
	115
	116	static void hw_closedev(int device_index)
	117	{
17e1afcb	118	/* Avoid compiler warnings. */
6239c175 UH	119	device_index = device_index;
	120
	121	/* Nothing needed so far. */
	122	}
	123
	124	static void hw_cleanup(void)
	125	{
	126	/* Nothing needed so far. */
	127	}
	128
	129	static void *hw_get_device_info(int device_index, int device_info_id)
	130	{
85b5af06 UH	131	struct sigrok_device_instance *sdi;
	132	void *info = NULL;
	133
	134	if (!(sdi = get_sigrok_device_instance(device_instances, device_index)))
	135	return NULL;
	136
6239c175 UH	137	switch (device_info_id) {
6239c175 UH	138	case DI_INSTANCE:
85b5af06	139	info = sdi;
6239c175 UH	140	break;
	141	case DI_NUM_PROBES:
	142	info = GINT_TO_POINTER(NUM_PROBES);
	143	break;
6239c175 UH	144	case DI_CUR_SAMPLERATE:
	145	info = &cur_samplerate;
	146	break;
e15f48c2 BV	147	case DI_PATTERNMODES:
	148	info = &patternmodes;
	149	break;
6239c175 UH	150	}
	151
	152	return info;
	153	}
	154
	155	static int hw_get_status(int device_index)
	156	{
17e1afcb	157	/* Avoid compiler warnings. */
6239c175	158	device_index = device_index;
5096c6a6	159
e15f48c2	160	return ST_ACTIVE;
6239c175 UH	161	}
	162
	163	static int *hw_get_capabilities(void)
	164	{
	165	return capabilities;
	166	}
	167
	168	static int hw_set_configuration(int device_index, int capability, void *value)
	169	{
	170	int ret;
85b5af06	171	uint64_t *tmp_u64;
e15f48c2	172	char *stropt;
6239c175	173
17e1afcb	174	/* Avoid compiler warnings. */
6239c175 UH	175	device_index = device_index;
6239c175 UH	176
e15f48c2	177	if (capability == HWCAP_PROBECONFIG) {
02440dd8	178	/* Nothing to do. */
85b5af06	179	ret = SIGROK_OK;
6239c175	180	} else if (capability == HWCAP_LIMIT_SAMPLES) {
85b5af06 UH	181	tmp_u64 = value;
85b5af06 UH	182	limit_samples = *tmp_u64;
6239c175	183	ret = SIGROK_OK;
e15f48c2 BV	184	} else if (capability == HWCAP_PATTERN_MODE) {
	185	stropt = value;
	186	if (!strcmp(stropt, "random")) {
	187	default_genmode = GENMODE_RANDOM;
	188	ret = SIGROK_OK;
	189	} else if (!strcmp(stropt, "incremental")) {
	190	default_genmode = GENMODE_INC;
	191	ret = SIGROK_OK;
	192	} else {
	193	ret = SIGROK_ERR;
	194	}
6239c175 UH	195	} else {
	196	ret = SIGROK_ERR;
	197	}
	198
	199	return ret;
	200	}
	201
5096c6a6	202	static void samples_generator(uint8_t buf, uint64_t size, void data)
85b5af06 UH	203	{
85b5af06 UH	204	struct databag *mydata = data;
917e0e71	205	uint64_t p, i;
85b5af06	206
5096c6a6	207	memset(buf, 0, size);
85b5af06 UH	208
85b5af06 UH	209	switch (mydata->sample_generator) {
917e0e71 BV	210	case GENMODE_DEFAULT:
	211	p = 0;
	212	for (i = 0; i < size; i++) {
	213	*(buf + i) = ~(genmode_default[p] >> 1);
	214	if (++p == 64)
	215	p = 0;
	216	}
	217	break;
85b5af06	218	case GENMODE_RANDOM: /* Random */
5096c6a6 UH	219	for (i = 0; i < size; i++)
5096c6a6 UH	220	*(buf + i) = (uint8_t)(rand() & 0xff);
85b5af06 UH	221	break;
85b5af06 UH	222	case GENMODE_INC: /* Simple increment */
5096c6a6	223	for (i = 0; i < size; i++)
85b5af06 UH	224	*(buf + i) = i;
	225	break;
	226	}
	227	}
	228
	229	/* Thread function */
	230	static void thread_func(void *data)
	231	{
	232	struct databag *mydata = data;
	233	uint8_t buf[BUFSIZE];
	234	uint64_t nb_to_send = 0;
d35aaf02	235	int bytes_written;
85b5af06 UH	236
85b5af06 UH	237	while (thread_running) {
ba3d481b OF	238	if (limit_samples)
	239	nb_to_send = limit_samples - mydata->samples_counter;
	240	else
02440dd8	241	nb_to_send = BUFSIZE; /* Continuous mode */
85b5af06 UH	242
	243	if (nb_to_send == 0) {
	244	close(mydata->pipe_fds[1]);
	245	thread_running = 0;
	246	hw_stop_acquisition(mydata->device_index,
	247	mydata->session_device_id);
	248	} else if (nb_to_send > BUFSIZE) {
	249	nb_to_send = BUFSIZE;
	250	}
	251
	252	samples_generator(buf, nb_to_send, data);
	253	mydata->samples_counter += nb_to_send;
	254
d35aaf02	255	g_io_channel_write_chars(channels[1], (gchar *)&buf,
10c471ab	256	nb_to_send, (gsize *)&bytes_written, NULL);
d35aaf02	257
85b5af06 UH	258	g_usleep(mydata->loop_sleep);
	259	}
	260	}
	261
	262	/* Callback handling data */
	263	static int receive_data(int fd, int revents, void *user_data)
	264	{
	265	struct datafeed_packet packet;
85b5af06 UH	266	char c[BUFSIZE];
	267	uint64_t z;
	268
	269	/* Avoid compiler warnings. */
10c471ab	270	fd = fd;
85b5af06 UH	271	revents = revents;
85b5af06 UH	272
d35aaf02 UH	273	g_io_channel_read_chars(channels[0], (gchar *)&c, BUFSIZE, &z, NULL);
d35aaf02 UH	274
85b5af06	275	if (z > 0) {
4c046c6b	276	packet.type = DF_LOGIC;
85b5af06	277	packet.length = z;
4c046c6b	278	packet.unitsize = 1;
85b5af06 UH	279	packet.payload = c;
	280	session_bus(user_data, &packet);
	281	}
	282	return TRUE;
	283	}
	284
6239c175 UH	285	static int hw_start_acquisition(int device_index, gpointer session_device_id)
	286	{
	287	struct datafeed_packet *packet;
	288	struct datafeed_header *header;
85b5af06	289	struct databag *mydata;
6239c175	290
85b5af06	291	mydata = malloc(sizeof(struct databag));
5096c6a6 UH	292	if (!mydata)
5096c6a6 UH	293	return SIGROK_ERR_MALLOC;
85b5af06	294
e15f48c2	295	mydata->sample_generator = default_genmode;
85b5af06 UH	296	mydata->session_device_id = session_device_id;
	297	mydata->device_index = device_index;
	298	mydata->samples_counter = 0;
	299	mydata->loop_sleep = 100000;
	300
e15f48c2 BV	301	if (pipe(mydata->pipe_fds))
e15f48c2 BV	302	return SIGROK_ERR;
85b5af06	303
d35aaf02 UH	304	channels[0] = g_io_channel_unix_new(mydata->pipe_fds[0]);
	305	channels[1] = g_io_channel_unix_new(mydata->pipe_fds[1]);
	306
	307	/* Set channel encoding to binary (default is UTF-8). */
	308	g_io_channel_set_encoding(channels[0], NULL, NULL);
	309	g_io_channel_set_encoding(channels[1], NULL, NULL);
	310
	311	/* Make channels to unbuffered. */
	312	g_io_channel_set_buffered(channels[0], FALSE);
	313	g_io_channel_set_buffered(channels[1], FALSE);
	314
85b5af06 UH	315	source_add(mydata->pipe_fds[0], G_IO_IN \| G_IO_ERR, 40, receive_data,
	316	session_device_id);
	317
	318	/* Run the demo thread. */
	319	g_thread_init(NULL);
	320	thread_running = 1;
	321	my_thread =
	322	g_thread_create((GThreadFunc)thread_func, mydata, TRUE, NULL);
e15f48c2 BV	323	if (!my_thread)
e15f48c2 BV	324	return SIGROK_ERR;
6239c175 UH	325
	326	packet = malloc(sizeof(struct datafeed_packet));
	327	header = malloc(sizeof(struct datafeed_header));
e15f48c2	328	if (!packet \|\| !header)
6239c175 UH	329	return SIGROK_ERR_MALLOC;
6239c175 UH	330
6239c175 UH	331	packet->type = DF_HEADER;
	332	packet->length = sizeof(struct datafeed_header);
	333	packet->payload = (unsigned char *)header;
	334	header->feed_version = 1;
	335	gettimeofday(&header->starttime, NULL);
	336	header->samplerate = cur_samplerate;
	337	header->protocol_id = PROTO_RAW;
c2616fb9 DR	338	header->num_logic_probes = NUM_PROBES;
c2616fb9 DR	339	header->num_analog_probes = 0;
6239c175 UH	340	session_bus(session_device_id, packet);
	341	free(header);
	342	free(packet);
	343
	344	return SIGROK_OK;
	345	}
	346
6239c175 UH	347	static void hw_stop_acquisition(int device_index, gpointer session_device_id)
	348	{
	349	struct datafeed_packet packet;
	350
17e1afcb	351	/* Avoid compiler warnings. */
6239c175 UH	352	device_index = device_index;
6239c175 UH	353
85b5af06	354	/* Send last packet. */
6239c175 UH	355	packet.type = DF_END;
6239c175 UH	356	session_bus(session_device_id, &packet);
6239c175 UH	357	}
	358
	359	struct device_plugin demo_plugin_info = {
	360	"demo",
	361	1,
	362	hw_init,
	363	hw_cleanup,
	364	hw_opendev,
	365	hw_closedev,
	366	hw_get_device_info,
	367	hw_get_status,
	368	hw_get_capabilities,
	369	hw_set_configuration,
	370	hw_start_acquisition,
	371	hw_stop_acquisition,
	372	};