restore demo driver to working state
This commit is contained in:
parent
47697369b5
commit
070befcd1c
|
@ -19,13 +19,10 @@
|
||||||
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
|
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#define DEMO_ANALOG
|
|
||||||
|
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include <unistd.h>
|
#include <unistd.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <sigrok.h>
|
#include <sigrok.h>
|
||||||
#include <math.h>
|
|
||||||
#ifdef _WIN32
|
#ifdef _WIN32
|
||||||
#include <io.h>
|
#include <io.h>
|
||||||
#include <fcntl.h>
|
#include <fcntl.h>
|
||||||
|
@ -33,24 +30,15 @@
|
||||||
#endif
|
#endif
|
||||||
#include "config.h"
|
#include "config.h"
|
||||||
|
|
||||||
#ifdef DEMO_ANALOG
|
|
||||||
#define NUM_PROBES 9
|
|
||||||
#else
|
|
||||||
#define NUM_PROBES 8
|
#define NUM_PROBES 8
|
||||||
#endif
|
|
||||||
#define DEMONAME "Demo device"
|
#define DEMONAME "Demo device"
|
||||||
/* size of chunks to send through the session bus */
|
/* size of chunks to send through the session bus */
|
||||||
#ifdef DEMO_ANALOG
|
|
||||||
#define BUFSIZE 32768
|
|
||||||
#else
|
|
||||||
#define BUFSIZE 4096
|
#define BUFSIZE 4096
|
||||||
#endif
|
|
||||||
|
|
||||||
enum {
|
enum {
|
||||||
GENMODE_DEFAULT,
|
GENMODE_DEFAULT,
|
||||||
GENMODE_RANDOM,
|
GENMODE_RANDOM,
|
||||||
GENMODE_INC,
|
GENMODE_INC,
|
||||||
GENMODE_SINE,
|
|
||||||
};
|
};
|
||||||
|
|
||||||
GIOChannel *channels[2];
|
GIOChannel *channels[2];
|
||||||
|
@ -76,11 +64,9 @@ static int capabilities[] = {
|
||||||
static const char *patternmodes[] = {
|
static const char *patternmodes[] = {
|
||||||
"random",
|
"random",
|
||||||
"incremental",
|
"incremental",
|
||||||
"sine",
|
|
||||||
NULL,
|
NULL,
|
||||||
};
|
};
|
||||||
|
|
||||||
#ifndef DEMO_ANALOG
|
|
||||||
static uint8_t genmode_default[] = {
|
static uint8_t genmode_default[] = {
|
||||||
0x4c, 0x92, 0x92, 0x92, 0x64, 0x00, 0x00, 0x00,
|
0x4c, 0x92, 0x92, 0x92, 0x64, 0x00, 0x00, 0x00,
|
||||||
0x82, 0xfe, 0xfe, 0x82, 0x00, 0x00, 0x00, 0x00,
|
0x82, 0xfe, 0xfe, 0x82, 0x00, 0x00, 0x00, 0x00,
|
||||||
|
@ -91,7 +77,6 @@ static uint8_t genmode_default[] = {
|
||||||
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
||||||
0xbe, 0xbe, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
0xbe, 0xbe, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
||||||
};
|
};
|
||||||
#endif
|
|
||||||
|
|
||||||
/* List of struct sigrok_device_instance, maintained by opendev()/closedev(). */
|
/* List of struct sigrok_device_instance, maintained by opendev()/closedev(). */
|
||||||
static GSList *device_instances = NULL;
|
static GSList *device_instances = NULL;
|
||||||
|
@ -209,9 +194,6 @@ static int hw_set_configuration(int device_index, int capability, void *value)
|
||||||
} else if (!strcmp(stropt, "incremental")) {
|
} else if (!strcmp(stropt, "incremental")) {
|
||||||
default_genmode = GENMODE_INC;
|
default_genmode = GENMODE_INC;
|
||||||
ret = SIGROK_OK;
|
ret = SIGROK_OK;
|
||||||
} else if (!strcmp(stropt, "sine")) {
|
|
||||||
default_genmode = GENMODE_SINE;
|
|
||||||
ret = SIGROK_OK;
|
|
||||||
} else {
|
} else {
|
||||||
ret = SIGROK_ERR;
|
ret = SIGROK_ERR;
|
||||||
}
|
}
|
||||||
|
@ -226,42 +208,6 @@ static void samples_generator(uint8_t *buf, uint64_t size, void *data)
|
||||||
{
|
{
|
||||||
struct databag *mydata = data;
|
struct databag *mydata = data;
|
||||||
uint64_t p, i;
|
uint64_t p, i;
|
||||||
#ifdef DEMO_ANALOG
|
|
||||||
/*
|
|
||||||
* We will simulate a device with 8 logic probes and 1 analog probe.
|
|
||||||
* This fictional device sends the data packed: 8 bits for 8 logic
|
|
||||||
* probes and 16 bits for the analog probe, in this order.
|
|
||||||
* Total of 24 bits.
|
|
||||||
* I could just generate a properly formatted DF_ANALOG packet here,
|
|
||||||
* but I will leave the formatting to receive_data() to make its code
|
|
||||||
* more like a real hardware driver.
|
|
||||||
*/
|
|
||||||
memset(buf, 0, size * 3);
|
|
||||||
|
|
||||||
switch (mydata->sample_generator) {
|
|
||||||
default:
|
|
||||||
case GENMODE_DEFAULT:
|
|
||||||
case GENMODE_SINE:
|
|
||||||
for (i = 0; i < size * 3; i += 3) {
|
|
||||||
*(buf + i) = i / 3;
|
|
||||||
*(uint16_t *) (buf + i + 1) =
|
|
||||||
(uint16_t) (sin(i / 3) * 256 * 30);
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case GENMODE_RANDOM:
|
|
||||||
for (i = 0; i < size * 3; i += 3) {
|
|
||||||
*(buf + i) = (uint8_t)(rand() & 0xff);
|
|
||||||
*(uint16_t *) (buf + i + 1) = (uint16_t)(rand() & 0xffff);
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case GENMODE_INC:
|
|
||||||
for (i = 0; i < size * 3; i += 3) {
|
|
||||||
*(buf + i) = i / 3;
|
|
||||||
*(uint16_t *)(buf + i + 1) = i / 3 * 256 * 10;
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
#else
|
|
||||||
|
|
||||||
memset(buf, 0, size);
|
memset(buf, 0, size);
|
||||||
|
|
||||||
|
@ -283,7 +229,6 @@ static void samples_generator(uint8_t *buf, uint64_t size, void *data)
|
||||||
*(buf + i) = i;
|
*(buf + i) = i;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
#endif
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Thread function */
|
/* Thread function */
|
||||||
|
@ -312,22 +257,14 @@ static void thread_func(void *data)
|
||||||
limit_samples - mydata->samples_counter);
|
limit_samples - mydata->samples_counter);
|
||||||
|
|
||||||
/* Make sure we don't overflow. */
|
/* Make sure we don't overflow. */
|
||||||
#ifdef DEMO_ANALOG
|
|
||||||
nb_to_send = MIN(nb_to_send, BUFSIZE / 3);
|
|
||||||
#else
|
|
||||||
nb_to_send = MIN(nb_to_send, BUFSIZE);
|
nb_to_send = MIN(nb_to_send, BUFSIZE);
|
||||||
#endif
|
|
||||||
|
|
||||||
if (nb_to_send) {
|
if (nb_to_send) {
|
||||||
samples_generator(buf, nb_to_send, data);
|
samples_generator(buf, nb_to_send, data);
|
||||||
mydata->samples_counter += nb_to_send;
|
mydata->samples_counter += nb_to_send;
|
||||||
#ifdef DEMO_ANALOG
|
|
||||||
g_io_channel_write_chars(channels[1], (gchar *) &buf,
|
g_io_channel_write_chars(channels[1], (gchar *)&buf,
|
||||||
nb_to_send * 3, (gsize *) &bytes_written, NULL);
|
nb_to_send, (gsize *)&bytes_written, NULL);
|
||||||
#else
|
|
||||||
g_io_channel_write_chars(channels[1], (gchar *) &buf,
|
|
||||||
nb_to_send, (gsize *) &bytes_written, NULL);
|
|
||||||
#endif
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Check if we're done. */
|
/* Check if we're done. */
|
||||||
|
@ -348,13 +285,6 @@ static int receive_data(int fd, int revents, void *user_data)
|
||||||
struct datafeed_packet packet;
|
struct datafeed_packet packet;
|
||||||
char c[BUFSIZE];
|
char c[BUFSIZE];
|
||||||
uint64_t z;
|
uint64_t z;
|
||||||
#ifdef DEMO_ANALOG
|
|
||||||
struct analog_sample *sample;
|
|
||||||
unsigned int i, x;
|
|
||||||
int sample_size = sizeof(struct analog_sample) +
|
|
||||||
(NUM_PROBES * sizeof(struct analog_probe));
|
|
||||||
char *buf;
|
|
||||||
#endif
|
|
||||||
|
|
||||||
/* Avoid compiler warnings. */
|
/* Avoid compiler warnings. */
|
||||||
fd = fd;
|
fd = fd;
|
||||||
|
@ -362,51 +292,14 @@ static int receive_data(int fd, int revents, void *user_data)
|
||||||
|
|
||||||
do {
|
do {
|
||||||
g_io_channel_read_chars(channels[0],
|
g_io_channel_read_chars(channels[0],
|
||||||
(gchar *) &c, BUFSIZE, (gsize *) &z, NULL);
|
(gchar *)&c, BUFSIZE, &z, NULL);
|
||||||
|
|
||||||
if (z > 0) {
|
if (z > 0) {
|
||||||
#ifdef DEMO_ANALOG
|
|
||||||
packet.type = DF_ANALOG;
|
|
||||||
|
|
||||||
packet.length = (z / 3) * sample_size;
|
|
||||||
packet.unitsize = sample_size;
|
|
||||||
|
|
||||||
buf = malloc(sample_size * packet.length);
|
|
||||||
if (!buf)
|
|
||||||
return FALSE;
|
|
||||||
|
|
||||||
/* Craft our packet. */
|
|
||||||
for (i = 0; i < z / 3; i++) {
|
|
||||||
sample = (struct analog_sample *) (buf + (i * sample_size));
|
|
||||||
sample->num_probes = NUM_PROBES;
|
|
||||||
|
|
||||||
/* 8 Logic probes */
|
|
||||||
for (x = 0; x < NUM_PROBES - 1; x++) {
|
|
||||||
sample->probes[x].val =
|
|
||||||
(c[i * 3] >> x) & 1;
|
|
||||||
sample->probes[x].res = 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* 1 Analog probe, 16 bit adc */
|
|
||||||
for (; x < NUM_PROBES; x++) {
|
|
||||||
sample->probes[x].val =
|
|
||||||
*(uint16_t *) (c + i * 3 + 1);
|
|
||||||
sample->probes[x].val &= ((1 << 16) - 1);
|
|
||||||
sample->probes[x].res = 16;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
packet.payload = buf;
|
|
||||||
session_bus(user_data, &packet);
|
|
||||||
free(buf);
|
|
||||||
#else
|
|
||||||
packet.type = DF_LOGIC;
|
packet.type = DF_LOGIC;
|
||||||
packet.length = z;
|
packet.length = z;
|
||||||
packet.unitsize = 1;
|
packet.unitsize = 1;
|
||||||
packet.payload = c;
|
packet.payload = c;
|
||||||
session_bus(user_data, &packet);
|
session_bus(user_data, &packet);
|
||||||
#endif
|
|
||||||
}
|
}
|
||||||
} while (z > 0);
|
} while (z > 0);
|
||||||
|
|
||||||
|
@ -474,10 +367,6 @@ static int hw_start_acquisition(int device_index, gpointer session_device_id)
|
||||||
packet->type = DF_HEADER;
|
packet->type = DF_HEADER;
|
||||||
packet->length = sizeof(struct datafeed_header);
|
packet->length = sizeof(struct datafeed_header);
|
||||||
packet->payload = (unsigned char *)header;
|
packet->payload = (unsigned char *)header;
|
||||||
#ifdef DEMO_ANALOG
|
|
||||||
packet->unitsize = sizeof(struct analog_sample) +
|
|
||||||
(NUM_PROBES * sizeof(struct analog_probe));
|
|
||||||
#endif
|
|
||||||
header->feed_version = 1;
|
header->feed_version = 1;
|
||||||
gettimeofday(&header->starttime, NULL);
|
gettimeofday(&header->starttime, NULL);
|
||||||
header->samplerate = cur_samplerate;
|
header->samplerate = cur_samplerate;
|
||||||
|
|
Loading…
Reference in New Issue