/* Node type: comedi. * * Author: Steffen Vogel * SPDX-FileCopyrightText: 2014-2023 Institute for Automation of Complex Power Systems, RWTH Aachen University * SPDX-License-Identifier: Apache-2.0 */ #pragma once #include #include #include namespace villas { namespace node { // Forward declarations class NodeCompat; // whether to use read() or mmap() kernel interface #define COMEDI_USE_READ (1) //#define COMEDI_USE_READ (0) struct comedi_chanspec { unsigned int maxdata; comedi_range *range; }; struct comedi_direction { int subdevice; ///< Comedi subdevice int buffer_size; ///< Comedi's kernel buffer size in kB int sample_size; ///< Size of a single measurement sample int sample_rate_hz; ///< Sample rate in Hz bool present; ///< Config present bool enabled; ///< Card is started successfully bool running; ///< Card is actively transfering samples struct timespec started; ///< Timestamp when sampling started struct timespec last_debug; ///< Timestamp of last debug output size_t counter; ///< Number of villas samples transfered struct comedi_chanspec *chanspecs; ///< Range and maxdata config of channels unsigned *chanlist; ///< Channel list in comedi's packed format size_t chanlist_len; ///< Number of channels for this direction char *buffer; char *bufptr; }; struct comedi { char *device; struct comedi_direction in, out; comedi_t *dev; #if COMEDI_USE_READ char *buf; char *bufptr; #else char *map; size_t bufpos; size_t front; size_t back; #endif }; char *comedi_print(NodeCompat *n); int comedi_parse(NodeCompat *n, json_t *json); int comedi_start(NodeCompat *n); int comedi_stop(NodeCompat *n); int comedi_poll_fds(NodeCompat *n, int fds[]); int comedi_read(NodeCompat *n, struct Sample *const smps[], unsigned cnt); int comedi_write(NodeCompat *n, struct Sample *const smps[], unsigned cnt); } // namespace node } // namespace villas