libiio  0.26
Library for interfacing with IIO devices
iio_writedev.c

Part of the libiio-utilites, iio_writedev is a utility for writing buffers from connected IIO devices.

// SPDX-License-Identifier: GPL-2.0-or-later
/*
* iio_writedev - Part of the Industrial I/O (IIO) utilities
*
* Copyright (C) 2014-2018 Analog Devices, Inc.
* Author: Paul Cercueil <paul.cercueil@analog.com>
* that Michael Hennerich <michael.hennerich@analog.com>
* */
#include <errno.h>
#include <getopt.h>
#include <iio.h>
#include <inttypes.h>
#include <signal.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#ifdef _WIN32
#include <windows.h>
#include <fcntl.h>
#include <io.h>
#else
#include <unistd.h>
#endif
#include "iio_common.h"
#define MY_NAME "iio_writedev"
#define SAMPLES_PER_READ 256
#define DEFAULT_FREQ_HZ 100
#define REFILL_PER_BENCHMARK 10
static const struct option options[] = {
{"trigger", required_argument, 0, 't'},
{"buffer-size", required_argument, 0, 'b'},
{"samples", required_argument, 0, 's' },
{"auto", no_argument, 0, 'a'},
{"cyclic", no_argument, 0, 'c'},
{"benchmark", no_argument, 0, 'B'},
{0, 0, 0, 0},
};
static const char *options_descriptions[] = {
("[-t <trigger>] "
"[-b <buffer-size>] [-s <samples>] "
"<iio_device> [<channel> ...]"),
"Use the specified trigger.",
"Size of the transmit buffer. Default is 256.",
"Number of samples to write, 0 = infinite. Default is 0.",
"Scan for available contexts and if only one is available use it.",
"Use cyclic buffer mode.",
("Benchmark throughput."
"\n\t\t\tStatistics will be printed on the standard input."),
};
static struct iio_context *ctx;
static struct iio_buffer *buffer;
static const char *trigger_name = NULL;
static size_t num_samples;
static volatile sig_atomic_t app_running = true;
static int exit_code = EXIT_SUCCESS;
static void quit_all(int sig)
{
exit_code = sig;
app_running = false;
if (buffer && exit_code != EXIT_SUCCESS)
}
#ifdef _WIN32
#include <windows.h>
BOOL WINAPI sig_handler_fn(DWORD dwCtrlType)
{
/* Runs in its own thread */
switch (dwCtrlType) {
case CTRL_C_EVENT:
case CTRL_CLOSE_EVENT:
quit_all(SIGTERM);
return TRUE;
default:
return FALSE;
}
}
static void setup_sig_handler(void)
{
SetConsoleCtrlHandler(sig_handler_fn, TRUE);
}
#elif NO_THREADS
static void sig_handler(int sig)
{
/*
* If the main function is stuck waiting for data it will not abort. If the
* user presses Ctrl+C a second time we abort without cleaning up.
*/
if (!app_running)
exit(sig);
app_running = false;
}
static void set_handler(int sig)
{
struct sigaction action;
sigaction(sig, NULL, &action);
action.sa_handler = sig_handler;
sigaction(sig, &action, NULL);
}
static void setup_sig_handler(void)
{
set_handler(SIGHUP);
set_handler(SIGPIPE);
set_handler(SIGINT);
set_handler(SIGSEGV);
set_handler(SIGTERM);
}
#else
#include <pthread.h>
static void * sig_handler_thd(void *data)
{
sigset_t *mask = data;
int ret, sig;
/* Blocks until one of the termination signals is received */
do {
ret = sigwait(mask, &sig);
} while (ret == EINTR);
quit_all(ret);
return NULL;
}
static void setup_sig_handler(void)
{
sigset_t mask, oldmask;
pthread_t thd;
int ret;
/*
* Async signals are difficult to handle and the IIO API is not signal
* safe. Use a separate thread and handle the signals synchronous so we
* can call iio_buffer_cancel().
*/
sigemptyset(&mask);
sigaddset(&mask, SIGHUP);
sigaddset(&mask, SIGPIPE);
sigaddset(&mask, SIGINT);
sigaddset(&mask, SIGSEGV);
sigaddset(&mask, SIGTERM);
pthread_sigmask(SIG_BLOCK, &mask, &oldmask);
ret = pthread_create(&thd, NULL, sig_handler_thd, &mask);
if (ret) {
fprintf(stderr, "Failed to create signal handler thread: %d\n", ret);
pthread_sigmask(SIG_SETMASK, &oldmask, NULL);
}
}
#endif
static ssize_t read_sample(const struct iio_channel *chn,
void *buf, size_t len, void *d)
{
size_t nb = fread(buf, 1, len, stdin);
if (num_samples != 0) {
num_samples--;
if (num_samples == 0) {
quit_all(EXIT_SUCCESS);
return -1;
}
}
return (ssize_t) nb;
}
#define MY_OPTS "t:b:s:T:acB"
int main(int argc, char **argv)
{
char **argw;
unsigned int i, j, nb_channels;
unsigned int nb_active_channels = 0;
unsigned int buffer_size = SAMPLES_PER_READ;
uint64_t refill_per_benchmark = REFILL_PER_BENCHMARK;
int c;
struct iio_device *dev;
ssize_t sample_size;
bool mib, cyclic_buffer = false, benchmark = false;
ssize_t ret;
struct option *opts;
uint64_t before = 0, after, rate, total;
int err_code = EXIT_FAILURE;
argw = dup_argv(MY_NAME, argc, argv);
setup_sig_handler();
ctx = handle_common_opts(MY_NAME, argc, argw, MY_OPTS,
options, options_descriptions, &err_code);
opts = add_common_options(options);
if (!opts) {
fprintf(stderr, "Failed to add common options\n");
return EXIT_FAILURE;
}
while ((c = getopt_long(argc, argw, "+" COMMON_OPTIONS MY_OPTS, /* Flawfinder: ignore */
opts, NULL)) != -1) {
switch (c) {
/* All these are handled in the common */
case 'h':
case 'n':
case 'x':
case 'u':
case 'T':
break;
case 'S':
case 'a':
if (!optarg && argc > optind && argv[optind] != NULL
&& argv[optind][0] != '-')
optind++;
break;
case 't':
if (!optarg) {
fprintf(stderr, "Trigger requires argument\n");
return EXIT_FAILURE;
}
trigger_name = optarg;
break;
case 'b':
if (!optarg) {
fprintf(stderr, "Buffer Size requires argument\n");
return EXIT_FAILURE;
}
buffer_size = sanitize_clamp("buffer size", optarg, 1, SIZE_MAX);
break;
case 'B':
benchmark = true;
break;
case 's':
if (!optarg) {
fprintf(stderr, "Number of samples requires argument\n");
return EXIT_FAILURE;
}
num_samples = sanitize_clamp("number of samples", optarg, 0, SIZE_MAX);
break;
case 'c':
cyclic_buffer = true;
break;
case '?':
printf("Unknown argument '%c'\n", c);
return EXIT_FAILURE;
}
}
free(opts);
if (argc < optind) {
fprintf(stderr, "Too few arguments.\n\n");
usage(MY_NAME, options, options_descriptions);
return EXIT_FAILURE;
}
if (!ctx)
return err_code;
if (!argw[optind]) {
unsigned int nb_devices = iio_context_get_devices_count(ctx);
for (i = 0; i < nb_devices; i++) {
const char *dev_id = NULL, *label = NULL, *name = NULL;
bool hit;
dev = iio_context_get_device(ctx, i);
nb_channels = iio_device_get_channels_count(dev);
if (!nb_channels)
continue;
hit = false;
for (j = 0; j < nb_channels; j++) {
struct iio_channel *ch = iio_device_get_channel(dev, j);
continue;
hit = true;
dev_id = iio_device_get_id(dev);
label = iio_device_get_label(dev);
name = iio_device_get_name(dev);
printf("Example : " MY_NAME " -u %s -b 256 -s 1024 %s %s\n",
label ? label : name ? name : dev_id,
}
if (hit)
printf("Example : " MY_NAME " -u %s -b 256 -s 1024 %s\n",
label ? label : name ? name : dev_id);
}
usage(MY_NAME, options, options_descriptions);
return EXIT_FAILURE;
}
if (benchmark && cyclic_buffer) {
fprintf(stderr, "Cannot benchmark in cyclic mode.\n");
return EXIT_FAILURE;
}
dev = iio_context_find_device(ctx, argw[optind]);
if (!dev) {
fprintf(stderr, "Device %s not found\n", argw[optind]);
return EXIT_FAILURE;
}
if (trigger_name) {
ctx, trigger_name);
if (!trigger) {
fprintf(stderr, "Trigger %s not found\n", trigger_name);
return EXIT_FAILURE;
}
if (!iio_device_is_trigger(trigger)) {
fprintf(stderr, "Specified device is not a trigger\n");
return EXIT_FAILURE;
}
/*
* Fixed rate for now. Try new ABI first,
* fail gracefully to remain compatible.
*/
"sampling_frequency", DEFAULT_FREQ_HZ) < 0) {
"frequency", DEFAULT_FREQ_HZ);
if (ret < 0) {
char buf[256];
iio_strerror(-(int)ret, buf, sizeof(buf));
fprintf(stderr, "sample rate not set : %s\n", buf);
}
}
ret = iio_device_set_trigger(dev, trigger);
if (ret < 0) {
char buf[256];
iio_strerror(-(int)ret, buf, sizeof(buf));
fprintf(stderr, "set trigger failed : %s\n", buf);
}
}
nb_channels = iio_device_get_channels_count(dev);
if (argc == optind + 1) {
/* Enable all channels */
for (i = 0; i < nb_channels; i++) {
struct iio_channel *ch = iio_device_get_channel(dev, i);
nb_active_channels++;
}
}
} else {
for (j = optind + 1; j < (unsigned int) argc; j++) {
ret = iio_device_enable_channel(dev, argw[j], true);
if (ret < 0) {
char buf[256];
iio_strerror(-(int) ret, buf, sizeof(buf));
fprintf(stderr, "Bad channel name \"%s\" : %s\n", argw[j], buf);
return EXIT_FAILURE;
}
nb_active_channels++;
}
}
if (!nb_active_channels) {
fprintf(stderr, "No output channels found\n");
return EXIT_FAILURE;
}
sample_size = iio_device_get_sample_size(dev);
/* Zero isn't normally an error code, but in this case it is an error */
if (sample_size == 0) {
fprintf(stderr, "Unable to get sample size, returned 0\n");
return EXIT_FAILURE;
} else if (sample_size < 0) {
char buf[256];
iio_strerror(errno, buf, sizeof(buf));
fprintf(stderr, "Unable to get sample size : %s\n", buf);
return EXIT_FAILURE;
}
buffer = iio_device_create_buffer(dev, buffer_size, cyclic_buffer);
if (!buffer) {
char buf[256];
iio_strerror(errno, buf, sizeof(buf));
fprintf(stderr, "Unable to allocate buffer: %s\n", buf);
return EXIT_FAILURE;
}
#ifdef _WIN32
_setmode(_fileno( stdin ), _O_BINARY);
#endif
for (i = 0, total = 0; app_running; ) {
if (benchmark) {
before = get_time_us();
} else if (iio_buffer_step(buffer) == sample_size) {
/* If there are only the samples we requested, we don't
* need to demux */
void *start = iio_buffer_start(buffer);
size_t write_len, len = (intptr_t) iio_buffer_end(buffer)
- (intptr_t) start;
if (num_samples && len > num_samples * sample_size)
len = num_samples * sample_size;
for (write_len = len; len; ) {
size_t nb = fread(start, 1, len, stdin);
if (!nb)
goto err_destroy_buffer;
len -= nb;
start = (void *)((intptr_t) start + nb);
}
if (num_samples) {
num_samples -= write_len / sample_size;
if (!num_samples && !cyclic_buffer) {
quit_all(EXIT_SUCCESS);
}
}
} else {
ret = iio_buffer_foreach_sample(buffer, read_sample, NULL);
if (ret < 0) {
char buf[256];
iio_strerror(-(int)ret, buf, sizeof(buf));
fprintf(stderr, "buffer processing failed : %s\n", buf);
}
}
ret = iio_buffer_push(buffer);
if (ret < 0) {
char buf[256];
iio_strerror(-(int)ret, buf, sizeof(buf));
fprintf(stderr, "Unable to push buffer: %s\n", buf);
break;
}
if (benchmark) {
after = get_time_us();
total += after - before;
if (++i == refill_per_benchmark) {
rate = buffer_size * sample_size *
refill_per_benchmark * 1000000ull / total;
mib = rate > 1048576;
fprintf(stderr, "\33[2K\rThroughput: %" PRIu64 " %ciB/s",
rate / (1024 * (mib ? 1024 : 1)),
mib ? 'M' : 'K');
/* Print every 100ms more or less */
refill_per_benchmark = refill_per_benchmark * 100000 / total;
if (refill_per_benchmark < REFILL_PER_BENCHMARK)
refill_per_benchmark = REFILL_PER_BENCHMARK;
i = 0;
total = 0;
}
}
while(cyclic_buffer && app_running) {
#ifdef _WIN32
Sleep(1000);
#else
sleep(1);
#endif
}
}
err_destroy_buffer:
free_argw(argc, argw);
return exit_code;
}
void iio_buffer_cancel(struct iio_buffer *buf)
Cancel all buffer operations.
Definition: buffer.c:313
ptrdiff_t iio_buffer_step(const struct iio_buffer *buffer)
Get the step size between two samples of one channel.
Definition: buffer.c:288
void * iio_buffer_start(const struct iio_buffer *buffer)
Get the start address of the buffer.
Definition: buffer.c:245
__api __check_ret ssize_t iio_buffer_foreach_sample(struct iio_buffer *buf, ssize_t(*callback)(const struct iio_channel *chn, void *src, size_t bytes, void *d), void *data)
Call the supplied callback for each sample found in a buffer.
void * iio_buffer_end(const struct iio_buffer *buffer)
Get the address that follows the last sample in a buffer.
Definition: buffer.c:293
void iio_buffer_destroy(struct iio_buffer *buffer)
Destroy the given buffer.
Definition: buffer.c:104
ssize_t iio_buffer_push(struct iio_buffer *buffer)
Send the samples to the hardware.
Definition: buffer.c:147
struct iio_buffer * iio_device_create_buffer(const struct iio_device *dev, size_t samples_count, bool cyclic)
Create an input or output buffer associated to the given device.
Definition: buffer.c:26
bool iio_channel_is_scan_element(const struct iio_channel *chn)
Return True if the given channel is a scan element.
Definition: channel.c:318
void iio_channel_enable(struct iio_channel *chn)
Enable the given channel.
Definition: channel.c:452
bool iio_channel_is_output(const struct iio_channel *chn)
Return True if the given channel is an output channel.
Definition: channel.c:313
const char * iio_channel_get_id(const struct iio_channel *chn)
Retrieve the channel ID (e.g. voltage0)
Definition: channel.c:303
struct iio_device * iio_context_get_device(const struct iio_context *ctx, unsigned int index)
Get the device present at the given index.
Definition: context.c:285
const char * iio_context_get_attr_value(const struct iio_context *ctx, const char *name)
Retrieve the value of a context-specific attribute.
Definition: context.c:483
void iio_context_destroy(struct iio_context *ctx)
Destroy the given context.
Definition: context.c:258
unsigned int iio_context_get_devices_count(const struct iio_context *ctx)
Enumerate the devices found in the given context.
Definition: context.c:280
struct iio_device * iio_context_find_device(const struct iio_context *ctx, const char *name)
Try to find a device structure by its ID, label or name.
Definition: context.c:294
ssize_t iio_device_get_sample_size(const struct iio_device *dev)
Get the current sample size.
Definition: device.c:483
int iio_device_set_trigger(const struct iio_device *dev, const struct iio_device *trigger)
Associate a trigger to a given device.
Definition: device.c:402
int iio_device_attr_write_longlong(const struct iio_device *dev, const char *attr, long long val)
Set the value of the given device-specific attribute.
Definition: device.c:528
struct iio_channel * iio_device_get_channel(const struct iio_device *dev, unsigned int index)
Get the channel present at the given index.
Definition: device.c:148
const char * iio_device_get_name(const struct iio_device *dev)
Retrieve the device name (e.g. xadc)
Definition: device.c:133
bool iio_device_is_trigger(const struct iio_device *dev)
Return True if the given device is a trigger.
Definition: device.c:368
const char * iio_device_get_id(const struct iio_device *dev)
Retrieve the device ID (e.g. iio:device0)
Definition: device.c:128
const char * iio_device_get_label(const struct iio_device *dev)
Retrieve the device label (e.g. lo_pll0_rx_adf4351)
Definition: device.c:138
unsigned int iio_device_get_channels_count(const struct iio_device *dev)
Enumerate the channels of the given device.
Definition: device.c:143
__api void iio_strerror(int err, char *dst, size_t len)
Get a string description of an error code.
Definition: utilities.c:204
Public interface.
An input or output buffer, used to read or write samples.
Represents an input or output channel of a device.
Contains the representation of an IIO context.
Represents a device in the IIO context.