BLAHAJ
/
libsigrok
10
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

sr: session/demo: Remove Windows specific hack 

The session and demo device code contain a hack to make the demo device work on
Windows. This was neccessary since polling on windows requires special handling
and we can not just pass in the raw fd to poll.

With the previous patches which added support for non-fd based event sources
this hack is no longer required. The patch moves the GIOChannels used by the
demo device to the demo device context and uses sr_session_source_add_channel
to register a source for the channels instead of using the raw pipe fds.

Signed-off-by: Lars-Peter Clausen <lars@metafoo.de>
This commit is contained in:
Lars-Peter Clausen 2012-06-30 20:54:45 +02:00 committed by Uwe Hermann
parent aac0ea2563
commit 249ae2be8f
2 changed files with 15 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
hardware/demo/demo.c
View File

@ -64,10 +64,10 @@ enum {
};
/* FIXME: Should not be global. */
SR_PRIV GIOChannel *channels[2];
struct context {
int pipe_fds[2];
GIOChannel *channels[2];
uint8_t sample_generator;
uint8_t thread_running;
uint64_t samples_counter;
@ -354,7 +354,7 @@ static void thread_func(void *data)
samples_generator(buf, nb_to_send, data);
ctx->samples_counter += nb_to_send;
g_io_channel_write_chars(channels[1], (gchar *)&buf,
g_io_channel_write_chars(ctx->channels[1], (gchar *)&buf,
nb_to_send, (gsize *)&bytes_written, NULL);
}
@ -373,6 +373,7 @@ static void thread_func(void *data)
/* Callback handling data */
static int receive_data(int fd, int revents, void *cb_data)
{
struct context *ctx = cb_data;
struct sr_datafeed_packet packet;
struct sr_datafeed_logic logic;
static uint64_t samples_received = 0;
@ -384,7 +385,7 @@ static int receive_data(int fd, int revents, void *cb_data)
(void)revents;
do {
g_io_channel_read_chars(channels[0],
g_io_channel_read_chars(ctx->channels[0],
(gchar *)&c, BUFSIZE, &z, NULL);
if (z > 0) {
@ -393,18 +394,18 @@ static int receive_data(int fd, int revents, void *cb_data)
logic.length = z;
logic.unitsize = 1;
logic.data = c;
sr_session_send(cb_data, &packet);
sr_session_send(ctx->session_dev_id, &packet);
samples_received += z;
}
} while (z > 0);
if (!thread_running && z <= 0) {
/* Make sure we don't receive more packets. */
g_io_channel_shutdown(channels[0], FALSE, NULL);
g_io_channel_shutdown(ctx->channels[0], FALSE, NULL);
/* Send last packet. */
packet.type = SR_DF_END;
sr_session_send(cb_data, &packet);
sr_session_send(ctx->session_dev_id, &packet);
return FALSE;
}
@ -436,19 +437,19 @@ static int hw_dev_acquisition_start(int dev_index, void *cb_data)
return SR_ERR;
}
channels[0] = g_io_channel_unix_new(ctx->pipe_fds[0]);
channels[1] = g_io_channel_unix_new(ctx->pipe_fds[1]);
ctx->channels[0] = g_io_channel_unix_new(ctx->pipe_fds[0]);
ctx->channels[1] = g_io_channel_unix_new(ctx->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);
g_io_channel_set_encoding(ctx->channels[0], NULL, NULL);
g_io_channel_set_encoding(ctx->channels[1], NULL, NULL);
/* Make channels to unbuffered. */
g_io_channel_set_buffered(channels[0], FALSE);
g_io_channel_set_buffered(channels[1], FALSE);
g_io_channel_set_buffered(ctx->channels[0], FALSE);
g_io_channel_set_buffered(ctx->channels[1], FALSE);
sr_source_add(ctx->pipe_fds[0], G_IO_IN | G_IO_ERR, 40,
receive_data, ctx->session_dev_id);
sr_session_source_add_channel(ctx->channels[0], G_IO_IN | G_IO_ERR,
40, receive_data, ctx);
/* Run the demo thread. */
g_thread_init(NULL);

8
session.c
View File

@ -25,9 +25,6 @@
#include "libsigrok.h"
#include "libsigrok-internal.h"
/* demo.c. TODO: Should not be global! */
extern SR_PRIV GIOChannel channels[2];
struct source {
int timeout;
sr_receive_data_callback_t cb;
@ -522,13 +519,8 @@ SR_API int sr_session_source_add(int fd, int events, int timeout,
{
GPollFD p;
#ifdef _WIN32
g_io_channel_win32_make_pollfd(&channels[0],
events, &p);
#else
p.fd = fd;
p.events = events;
#endif
return _sr_session_source_add(&p, timeout, cb, cb_data, (gintptr)fd);
}