1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00

refactor: change include prefix

This commit is contained in:
Steffen Vogel 2017-12-09 02:19:28 +08:00
parent f4cf47137b
commit 0017d1bcb1
90 changed files with 385 additions and 386 deletions

View file

@ -26,9 +26,9 @@
#include <stdbool.h>
#include <jansson.h>
#include "common.h"
#include "queue.h"
#include "buffer.h"
#include <villas/common.h>
#include <villas/queue.h>
#include <villas/buffer.h>
enum api_version {
API_VERSION_UNKOWN = 0,
@ -59,7 +59,7 @@ struct api_session {
struct lws *wsi;
struct api *api;
char *_name;
};

View file

@ -24,7 +24,8 @@
#include <jansson.h>
#include "sample.h"
/* Forward declarations */
struct sample;
int json_pack_sample(json_t **j, struct sample *s, int flags);

View file

@ -25,7 +25,9 @@
#include <stdio.h>
#include "io.h"
/* Forward declarations */
struct io;
struct sample;
int villas_human_print(struct io *io, struct sample *smps[], unsigned cnt);

View file

@ -33,8 +33,8 @@
#include <amqp.h>
#include "node.h"
#include "list.h"
#include <villas/node.h>
#include <villas/list.h>
/* Forward declarations */
struct io_format;

View file

@ -15,7 +15,7 @@
#include <pthread.h>
#include "list.h"
#include <villas/list.h>
/* Forward declaration */
struct cbuilder;
@ -45,7 +45,7 @@ struct cbuilder {
* The simulation step is triggerd by a call to cbuilder_write().
*/
pthread_mutex_t mtx;
int eventfd; /**< Eventfd for synchronizing cbuilder_read() / cbuilder_write() access. */
};

View file

@ -31,9 +31,9 @@
#pragma once
#include "io.h"
#include "node.h"
#include "task.h"
#include <villas/io.h>
#include <villas/node.h>
#include <villas/task.h>
#define FILE_MAX_PATHLEN 512
@ -56,7 +56,7 @@ struct file {
FILE_EPOCH_ABSOLUTE,
FILE_EPOCH_ORIGINAL
} epoch_mode; /**< Specifies how file::offset is calculated. */
enum {
FILE_EOF_EXIT, /**< Terminate when EOF is reached. */
FILE_EOF_REWIND, /**< Rewind the file when EOF is reached. */

View file

@ -29,7 +29,7 @@
#pragma once
#include "list.h"
#include <villas/list.h>
/* Forward declarations */
struct node;

View file

@ -31,8 +31,8 @@
#pragma once
#include "node.h"
#include "list.h"
#include <villas/node.h>
#include <villas/list.h>
/** The maximum length of a packet which contains stuct msg. */
#define NANOMSG_MAX_PACKET_LEN 1500

View file

@ -38,10 +38,10 @@
#include <curl/curl.h>
#include <jansson.h>
#include "list.h"
#include "super_node.h"
#include "node.h"
#include "task.h"
#include <villas/list.h>
#include <villas/super_node.h>
#include <villas/node.h>
#include <villas/task.h>
struct node;

View file

@ -29,12 +29,12 @@
#pragma once
#include "node.h"
#include "memory.h"
#include "pool.h"
#include "queue.h"
#include "config.h"
#include "shmem.h"
#include <villas/node.h>
#include <villas/memory.h>
#include <villas/pool.h>
#include <villas/queue.h>
#include <villas/config.h>
#include <villas/shmem.h>
/** Node-type for shared memory communication.
* @see node_type

View file

@ -29,8 +29,8 @@
#pragma once
#include "timing.h"
#include "task.h"
#include <villas/timing.h>
#include <villas/task.h>
/* Forward declarations */
struct node;
@ -61,7 +61,7 @@ struct signal {
double amplitude; /**< Amplitude of the generated signals. */
double stddev; /**< Standard deviation of random signals (normal distributed). */
double offset; /**< A constant bias. */
double *last; /**< The values from the previous period which are required for random walk. */
int values; /**< The number of values which will be emitted by this node. */

View file

@ -40,14 +40,14 @@
#endif
#ifdef WITH_LIBNL_ROUTE_30
#include "kernel/if.h"
#include "kernel/nl.h"
#include "kernel/tc.h"
#include <villas/kernel/if.h>
#include <villas/kernel/nl.h>
#include <villas/kernel/tc.h>
#define WITH_NETEM
#endif /* WITH_LIBNL_ROUTE_30 */
#include "node.h"
#include <villas/node.h>
/* Forward declarations */
struct io_format;

View file

@ -31,7 +31,7 @@
#include <jansson.h>
#include "task.h"
#include <villas/task.h>
/* Forward declarations */
struct node;

View file

@ -29,9 +29,9 @@
#pragma once
#include "list.h"
#include "io.h"
#include "task.h"
#include <villas/list.h>
#include <villas/io.h>
#include <villas/task.h>
/* Forward declarations */
struct test_rtt;

View file

@ -34,11 +34,11 @@
#include <libwebsockets.h>
#include "node.h"
#include "pool.h"
#include "queue_signalled.h"
#include "common.h"
#include "config.h"
#include <villas/node.h>
#include <villas/pool.h>
#include <villas/queue_signalled.h>
#include <villas/common.h>
#include <villas/config.h>
#define DEFAULT_WEBSOCKET_QUEUELEN (DEFAULT_QUEUELEN * 64)
#define DEFAULT_WEBSOCKET_SAMPLELEN DEFAULT_SAMPLELEN
@ -64,7 +64,7 @@ struct websocket_connection {
STATE_SHUTDOWN,
STATE_ERROR
} state; /**< The current status of this connection. */
enum {
WEBSOCKET_MODE_CLIENT,
WEBSOCKET_MODE_SERVER,
@ -76,11 +76,11 @@ struct websocket_connection {
struct queue queue; /**< For samples which are sent to the WebSocket */
struct websocket_destination *destination;
struct {
struct buffer recv; /**< A buffer for reconstructing fragmented messags. */
struct buffer send; /**< A buffer for contsructing messages before calling lws_write() */
} buffers;
} buffers;
char *_name;
};

View file

@ -32,7 +32,7 @@
#include <stdint.h>
#include <jansson.h>
#include "list.h"
#include <villas/list.h>
#if ZMQ_BUILD_DRAFT_API && (ZMQ_VERSION_MAJOR > 4 || (ZMQ_VERSION_MAJOR == 4 && ZMQ_VERSION_MINOR >= 2))
#define ZMQ_BUILD_DISH 1

View file

@ -32,10 +32,10 @@
#include <curl/curl.h>
#include "utils.h"
#include "config.h"
#include "advio.h"
#include "crypt.h"
#include <villas/utils.h>
#include <villas/config.h>
#include <villas/advio.h>
#include <villas/crypt.h>
#define BAR_WIDTH 60 /**< How wide you want the progress meter to be. */

View file

@ -22,14 +22,14 @@
#include <libwebsockets.h>
#include <string.h>
#include <assert.h>
#include "api.h"
#include "log.h"
#include "web.h"
#include "config.h"
#include "assert.h"
#include "memory.h"
#include "compat.h"
#include <villas/api.h>
#include <villas/log.h>
#include <villas/web.h>
#include <villas/config.h>
#include <villas/memory.h>
#include <villas/compat.h>
/* Forward declarations */
static void * api_worker(void *ctx);

View file

@ -20,7 +20,8 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*********************************************************************************/
#include "plugin.h"
#include <villas/plugin.h>
#include <villas/config.h>
static int api_capabilities(struct api_action *h, json_t *args, json_t **resp, struct api_session *s)
{

View file

@ -20,10 +20,10 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*********************************************************************************/
#include "api.h"
#include "utils.h"
#include "plugin.h"
#include "super_node.h"
#include <villas/api.h>
#include <villas/utils.h>
#include <villas/plugin.h>
#include <villas/super_node.h>
static int api_config(struct api_action *h, json_t *args, json_t **resp, struct api_session *s)
{

View file

@ -22,13 +22,13 @@
#include <jansson.h>
#include "plugin.h"
#include "node.h"
#include "super_node.h"
#include "utils.h"
#include "stats.h"
#include <villas/plugin.h>
#include <villas/node.h>
#include <villas/super_node.h>
#include <villas/utils.h>
#include <villas/stats.h>
#include "api.h"
#include <villas/api.h>
static int api_nodes(struct api_action *r, json_t *args, json_t **resp, struct api_session *s)
{

View file

@ -22,12 +22,11 @@
#include <jansson.h>
#include "plugin.h"
#include "path.h"
#include "utils.h"
#include "super_node.h"
#include "api.h"
#include <villas/plugin.h>
#include <villas/path.h>
#include <villas/utils.h>
#include <villas/super_node.h>
#include <villas/api.h>
static int api_paths(struct api_action *r, json_t *args, json_t **resp, struct api_session *s)
{

View file

@ -22,11 +22,11 @@
#include <string.h>
#include "plugin.h"
#include "api.h"
#include "super_node.h"
#include <villas/plugin.h>
#include <villas/api.h>
#include <villas/super_node.h>
#include "log.h"
#include <villas/log.h>
static char *config;

View file

@ -20,8 +20,8 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*********************************************************************************/
#include "plugin.h"
#include "api.h"
#include <villas/plugin.h>
#include <villas/api.h>
static int api_shutdown(struct api_action *h, json_t *args, json_t **resp, struct api_session *s)
{

View file

@ -20,11 +20,10 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*********************************************************************************/
#include "api/session.h"
#include "web.h"
#include "plugin.h"
#include "memory.h"
#include <villas/api/session.h>
#include <villas/web.h>
#include <villas/plugin.h>
#include <villas/memory.h>
int api_session_init(struct api_session *s, enum api_mode m)
{

View file

@ -23,8 +23,8 @@
#include <string.h>
#include <limits.h>
#include "bitset.h"
#include "utils.h"
#include <villas/bitset.h>
#include <villas/utils.h>
#define bitset_mask(b) (1 << ((b) % CHAR_BIT))
#define bitset_slot(b) ((b) / CHAR_BIT)

View file

@ -23,9 +23,9 @@
#include <string.h>
#include "compat.h"
#include "buffer.h"
#include "common.h"
#include <villas/compat.h>
#include <villas/buffer.h>
#include <villas/common.h>
int buffer_init(struct buffer *b, size_t size)
{

View file

@ -23,7 +23,7 @@
#include <string.h>
#include <jansson.h>
#include "compat.h"
#include <villas/compat.h>
#if JANSSON_VERSION_HEX < 0x020A00
size_t json_dumpb(const json_t *json, char *buffer, size_t size, size_t flags)

View file

@ -22,8 +22,9 @@
#include <string.h>
#include "config_helper.h"
#include "utils.h"
#include <villas/config_helper.h>
#include <villas/utils.h>
#include <villas/config.h>
#ifdef WITH_LIBCONFIG

View file

@ -20,7 +20,7 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*********************************************************************************/
#include "crypt.h"
#include <villas/crypt.h>
int sha1sum(FILE *f, unsigned char *sha1)
{

View file

@ -27,10 +27,10 @@
#include <math.h>
#include <time.h>
#include "utils.h"
#include "hist.h"
#include "config.h"
#include "table.h"
#include <villas/utils.h>
#include <villas/hist.h>
#include <villas/config.h>
#include <villas/table.h>
#define VAL(h, i) ((h)->low + (i) * (h)->resolution)
#define INDEX(h, v) round((v - (h)->low) / (h)->resolution)

View file

@ -22,14 +22,14 @@
#include <string.h>
#include <math.h>
#include "timing.h"
#include "config.h"
#include "hook.h"
#include "path.h"
#include "utils.h"
#include "node.h"
#include "plugin.h"
#include "config_helper.h"
#include <villas/timing.h>
#include <villas/config.h>
#include <villas/hook.h>
#include <villas/path.h>
#include <villas/utils.h>
#include <villas/node.h>
#include <villas/plugin.h>
#include <villas/config_helper.h>
int hook_init(struct hook *h, struct hook_type *vt, struct path *p, struct node *n)
{

View file

@ -26,9 +26,9 @@
#include <string.h>
#include "hook.h"
#include "plugin.h"
#include "sample.h"
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/sample.h>
struct convert {
enum {

View file

@ -24,8 +24,8 @@
* @{
*/
#include "hook.h"
#include "plugin.h"
#include <villas/hook.h>
#include <villas/plugin.h>
struct decimate {
int ratio;

View file

@ -24,11 +24,11 @@
* @{
*/
#include "hook.h"
#include "plugin.h"
#include "stats.h"
#include "node.h"
#include "sample.h"
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/stats.h>
#include <villas/node.h>
#include <villas/sample.h>
struct drop {
struct sample *prev;

View file

@ -27,10 +27,10 @@
#include <inttypes.h>
#include <string.h>
#include "hook.h"
#include "plugin.h"
#include "timing.h"
#include "sample.h"
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/timing.h>
#include <villas/sample.h>
#define GPS_NTP_DELAY_WIN_SIZE 16

View file

@ -24,13 +24,13 @@
* @{
*/
#include "plugin.h"
#include "mapping.h"
#include "list.h"
#include "utils.h"
#include "path.h"
#include "sample.h"
#include "node.h"
#include <villas/plugin.h>
#include <villas/mapping.h>
#include <villas/list.h>
#include <villas/utils.h>
#include <villas/path.h>
#include <villas/sample.h>
#include <villas/node.h>
struct map {
struct list mapping;

View file

@ -24,10 +24,10 @@
* @{
*/
#include "hook.h"
#include "plugin.h"
#include "sample.h"
#include "io.h"
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/sample.h>
#include <villas/io.h>
struct print {
struct io io;

View file

@ -24,10 +24,10 @@
* @{
*/
#include "hook.h"
#include "plugin.h"
#include "node.h"
#include "sample.h"
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/node.h>
#include <villas/sample.h>
struct restart {
struct sample *prev;

View file

@ -24,9 +24,9 @@
* @{
*/
#include "hook.h"
#include "plugin.h"
#include "sample.h"
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/sample.h>
struct shift {
int offset;

View file

@ -26,10 +26,10 @@
#include <string.h>
#include "hook.h"
#include "plugin.h"
#include "timing.h"
#include "sample.h"
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/timing.h>
#include <villas/sample.h>
struct shift_ts {
struct timespec offset;

View file

@ -24,10 +24,10 @@
* @{
*/
#include "hook.h"
#include "plugin.h"
#include "timing.h"
#include "sample.h"
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/timing.h>
#include <villas/sample.h>
struct skip_first {
enum {

View file

@ -26,13 +26,13 @@
#include <string.h>
#include "common.h"
#include "advio.h"
#include "hook.h"
#include "plugin.h"
#include "stats.h"
#include "node.h"
#include "timing.h"
#include <villas/common.h>
#include <villas/advio.h>
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/stats.h>
#include <villas/node.h>
#include <villas/timing.h>
struct stats_collect {
struct stats stats;

View file

@ -24,10 +24,10 @@
* @{
*/
#include "hook.h"
#include "plugin.h"
#include "timing.h"
#include "sample.h"
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/timing.h>
#include <villas/sample.h>
static int ts_read(struct hook *h, struct sample *smps[], unsigned *cnt)
{

View file

@ -25,10 +25,10 @@
#include <string.h>
#include <fcntl.h>
#include "io.h"
#include "io_format.h"
#include "utils.h"
#include "sample.h"
#include <villas/io.h>
#include <villas/io_format.h>
#include <villas/utils.h>
#include <villas/sample.h>
int io_init(struct io *io, struct io_format *fmt, int flags)
{

View file

@ -24,10 +24,10 @@
#include <inttypes.h>
#include <string.h>
#include "io/csv.h"
#include "plugin.h"
#include "sample.h"
#include "timing.h"
#include <villas/io/csv.h>
#include <villas/plugin.h>
#include <villas/sample.h>
#include <villas/timing.h>
size_t csv_sprint_single(char *buf, size_t len, struct sample *s, int flags)
{

View file

@ -20,9 +20,10 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*********************************************************************************/
#include "plugin.h"
#include "compat.h"
#include "io/json.h"
#include <villas/plugin.h>
#include <villas/sample.h>
#include <villas/compat.h>
#include <villas/io/json.h>
int json_pack_sample(json_t **j, struct sample *smp, int flags)
{

View file

@ -22,10 +22,10 @@
#include <arpa/inet.h>
#include "io/msg.h"
#include "io/msg_format.h"
#include "sample.h"
#include "utils.h"
#include <villas/io/msg.h>
#include <villas/io/msg_format.h>
#include <villas/sample.h>
#include <villas/utils.h>
void msg_ntoh(struct msg *m)
{

View file

@ -20,11 +20,11 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*********************************************************************************/
#include "sample.h"
#include "plugin.h"
#include "utils.h"
#include "io/raw.h"
#include "compat.h"
#include <villas/sample.h>
#include <villas/plugin.h>
#include <villas/utils.h>
#include <villas/io/raw.h>
#include <villas/compat.h>
/** Convert float to host byte order */
#define SWAP_FLT_TOH(o, n) ({ \

View file

@ -22,13 +22,12 @@
#include <string.h>
#include "io/villas_binary.h"
#include "io/msg.h"
#include "io/msg_format.h"
#include "sample.h"
#include "utils.h"
#include "plugin.h"
#include <villas/io/villas_binary.h>
#include <villas/io/msg.h>
#include <villas/io/msg_format.h>
#include <villas/sample.h>
#include <villas/utils.h>
#include <villas/plugin.h>
int villas_binary_sprint(char *buf, size_t len, size_t *wbytes, struct sample *smps[], unsigned cnt, int flags)
{

View file

@ -25,12 +25,12 @@
#include <inttypes.h>
#include <string.h>
#include "io.h"
#include "plugin.h"
#include "utils.h"
#include "timing.h"
#include "sample.h"
#include "io/villas_human.h"
#include <villas/io.h>
#include <villas/plugin.h>
#include <villas/utils.h>
#include <villas/timing.h>
#include <villas/sample.h>
#include <villas/io/villas_human.h>
struct villas_human {
bool header_written;

View file

@ -23,8 +23,8 @@
#include <stdlib.h>
#include <stdio.h>
#include "plugin.h"
#include "io_format.h"
#include <villas/plugin.h>
#include <villas/io_format.h>
int io_format_sscan(struct io_format *fmt, char *buf, size_t len, size_t *rbytes, struct sample *smps[], unsigned cnt, int flags)
{

View file

@ -31,9 +31,9 @@
#include <sys/types.h>
#include <sys/wait.h>
#include "utils.h"
#include "config.h"
#include "kernel/kernel.h"
#include <villas/utils.h>
#include <villas/config.h>
#include <villas/kernel/kernel.h>
int kernel_get_cacheline_size()
{

View file

@ -24,12 +24,12 @@
#include <unistd.h>
#include <sys/mman.h>
#include "config.h"
#include "utils.h"
#include "super_node.h"
#include <villas/config.h>
#include <villas/utils.h>
#include <villas/super_node.h>
#include "kernel/kernel.h"
#include "kernel/rt.h"
#include <villas/kernel/kernel.h>
#include <villas/kernel/rt.h>
int rt_init(int priority, int affinity)
{
@ -53,7 +53,7 @@ int rt_init(int priority, int affinity)
rt_set_affinity(affinity);
else
warn("You might want to use the 'affinity' setting to pin VILLASnode to dedicate CPU cores");
rt_lock_memory();
#else
warn("This platform is not optimized for real-time execution");
@ -74,7 +74,7 @@ int rt_lock_memory()
if (ret)
error("Failed to lock memory");
#endif
return 0;
}

View file

@ -25,8 +25,8 @@
#include <stdlib.h>
#include <string.h>
#include "list.h"
#include "utils.h"
#include <villas/list.h>
#include <villas/utils.h>
/* Compare functions */
static int cmp_lookup(const void *a, const void *b) {

View file

@ -28,10 +28,11 @@
#include <unistd.h>
#include <syslog.h>
#include "config.h"
#include "log.h"
#include "utils.h"
#include "timing.h"
#include <villas/config.h>
#include <villas/log.h>
#include <villas/utils.h>
#include <villas/timing.h>
#include <villas/config.h>
#ifdef ENABLE_OPAL_ASYNC
/* Define RTLAB before including OpalPrint.h for messages to be sent

View file

@ -24,12 +24,12 @@
#include <stdlib.h>
#include <unistd.h>
#include <syslog.h>
#include <string.h>
#include "config.h"
#include "log.h"
#include "log_config.h"
#include "utils.h"
#include "string.h"
#include <villas/config.h>
#include <villas/log.h>
#include <villas/log_config.h>
#include <villas/utils.h>
int log_parse(struct log *l, json_t *cfg)
{

View file

@ -24,8 +24,8 @@
#include <unistd.h>
#include <syslog.h>
#include "utils.h"
#include "log.h"
#include <villas/utils.h>
#include <villas/log.h>
void debug(long class, const char *fmt, ...)
{

View file

@ -22,12 +22,12 @@
#include <string.h>
#include "mapping.h"
#include "stats.h"
#include "sample.h"
#include "list.h"
#include "utils.h"
#include "node.h"
#include <villas/mapping.h>
#include <villas/stats.h>
#include <villas/sample.h>
#include <villas/list.h>
#include <villas/utils.h>
#include <villas/node.h>
int mapping_parse_str(struct mapping_entry *me, const char *str, struct list *nodes)
{

View file

@ -34,12 +34,12 @@
#ifdef __MACH__
#include <mach/vm_statistics.h>
#elif defined(__linux__)
#include "kernel/kernel.h"
#include <villas/kernel/kernel.h>
#endif
#include "log.h"
#include "memory.h"
#include "utils.h"
#include <villas/log.h>
#include <villas/memory.h>
#include <villas/utils.h>
int memory_init(int hugepages)
{

View file

@ -22,14 +22,14 @@
#include <string.h>
#include "sample.h"
#include "node.h"
#include "utils.h"
#include "config.h"
#include "plugin.h"
#include "config_helper.h"
#include "mapping.h"
#include "timing.h"
#include <villas/sample.h>
#include <villas/node.h>
#include <villas/utils.h>
#include <villas/config.h>
#include <villas/plugin.h>
#include <villas/config_helper.h>
#include <villas/mapping.h>
#include <villas/timing.h>
int node_init(struct node *n, struct node_type *vt)
{

View file

@ -22,12 +22,12 @@
#include <string.h>
#include "sample.h"
#include "node.h"
#include "super_node.h"
#include "utils.h"
#include "config.h"
#include "plugin.h"
#include <villas/sample.h>
#include <villas/node.h>
#include <villas/super_node.h>
#include <villas/utils.h>
#include <villas/config.h>
#include <villas/plugin.h>
int node_type_start(struct node_type *vt, struct super_node *sn)
{

View file

@ -25,10 +25,10 @@
#include <amqp_ssl_socket.h>
#include <amqp_tcp_socket.h>
#include "plugin.h"
#include "nodes/amqp.h"
#include "utils.h"
#include "io_format.h"
#include <villas/plugin.h>
#include <villas/nodes/amqp.h>
#include <villas/utils.h>
#include <villas/io_format.h>
static void amqp_default_ssl_info(struct amqp_ssl_info *s)
{

View file

@ -24,12 +24,12 @@
#include <string.h>
#include <inttypes.h>
#include "nodes/file.h"
#include "utils.h"
#include "timing.h"
#include "queue.h"
#include "plugin.h"
#include "io.h"
#include <villas/nodes/file.h>
#include <villas/utils.h>
#include <villas/timing.h>
#include <villas/queue.h>
#include <villas/plugin.h>
#include <villas/io.h>
static char * file_format_name(const char *format, struct timespec *ts)
{

View file

@ -23,11 +23,11 @@
#include <string.h>
#include <inttypes.h>
#include "node.h"
#include "plugin.h"
#include "config.h"
#include "nodes/influxdb.h"
#include "memory.h"
#include <villas/node.h>
#include <villas/plugin.h>
#include <villas/config.h>
#include <villas/nodes/influxdb.h>
#include <villas/memory.h>
int influxdb_parse(struct node *n, json_t *json)
{

View file

@ -24,10 +24,10 @@
#include <nanomsg/pubsub.h>
#include <string.h>
#include "plugin.h"
#include "nodes/nanomsg.h"
#include "utils.h"
#include "io_format.h"
#include <villas/plugin.h>
#include <villas/nodes/nanomsg.h>
#include <villas/utils.h>
#include <villas/io_format.h>
int nanomsg_reverse(struct node *n)
{

View file

@ -28,12 +28,11 @@
#include <pthread.h>
#include <unistd.h>
#include "nodes/ngsi.h"
#include "utils.h"
#include "timing.h"
#include "plugin.h"
#include "config.h"
#include <villas/nodes/ngsi.h>
#include <villas/utils.h>
#include <villas/timing.h>
#include <villas/plugin.h>
#include <villas/config.h>
/* Some global settings */
static char *name = NULL;

View file

@ -28,13 +28,13 @@
#include <sys/stat.h>
#include <unistd.h>
#include "kernel/kernel.h"
#include "log.h"
#include "shmem.h"
#include "nodes/shmem.h"
#include "plugin.h"
#include "timing.h"
#include "utils.h"
#include <villas/kernel/kernel.h>
#include <villas/log.h>
#include <villas/shmem.h>
#include <villas/nodes/shmem.h>
#include <villas/plugin.h>
#include <villas/timing.h>
#include <villas/utils.h>
int shmem_parse(struct node *n, json_t *cfg)
{

View file

@ -24,9 +24,9 @@
#include <math.h>
#include <string.h>
#include "node.h"
#include "plugin.h"
#include "nodes/signal.h"
#include <villas/node.h>
#include <villas/plugin.h>
#include <villas/nodes/signal.h>
enum signal_type signal_lookup_type(const char *type)
{

View file

@ -30,22 +30,21 @@
#include <netinet/ether.h>
#endif
#include "nodes/socket.h"
#include "config.h"
#include "utils.h"
#include <villas/nodes/socket.h>
#include <villas/config.h>
#include <villas/utils.h>
#include <villas/io_format.h>
#include <villas/sample.h>
#include <villas/queue.h>
#include <villas/plugin.h>
#include <villas/compat.h>
#ifdef WITH_NETEM
#include "kernel/if.h"
#include "kernel/nl.h"
#include "kernel/tc_netem.h"
#include <villas/kernel/if.h>
#include <villas/kernel/nl.h>
#include <villas/kernel/tc_netem.h>
#endif /* WITH_NETEM */
#include "io_format.h"
#include "sample.h"
#include "queue.h"
#include "plugin.h"
#include "compat.h"
/* Forward declartions */
static struct plugin p;

View file

@ -26,13 +26,13 @@
#include <string.h>
#include "nodes/stats.h"
#include "hook.h"
#include "plugin.h"
#include "stats.h"
#include "super_node.h"
#include "sample.h"
#include "node.h"
#include <villas/nodes/stats.h>
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/stats.h>
#include <villas/super_node.h>
#include <villas/sample.h>
#include <villas/node.h>
#define STATS_METRICS 6

View file

@ -24,11 +24,11 @@
#include <string.h>
#include <sys/stat.h>
#include "node.h"
#include "sample.h"
#include "timing.h"
#include "plugin.h"
#include "nodes/test_rtt.h"
#include <villas/node.h>
#include <villas/sample.h>
#include <villas/timing.h>
#include <villas/plugin.h>
#include <villas/nodes/test_rtt.h>
static int test_rtt_case_start(struct test_rtt *t, int id)
{

View file

@ -26,13 +26,13 @@
#include <string.h>
#include <signal.h>
#include "super_node.h"
#include "timing.h"
#include "utils.h"
#include "buffer.h"
#include "plugin.h"
#include "io_format.h"
#include "nodes/websocket.h"
#include <villas/super_node.h>
#include <villas/timing.h>
#include <villas/utils.h>
#include <villas/buffer.h>
#include <villas/plugin.h>
#include <villas/io_format.h>
#include <villas/nodes/websocket.h>
/* Private static storage */
static struct list connections = { .state = STATE_DESTROYED }; /**< List of active libwebsocket connections which receive samples from all nodes (catch all) */

View file

@ -27,12 +27,12 @@
#include <zmq_utils.h>
#endif
#include "nodes/zeromq.h"
#include "node.h"
#include "utils.h"
#include "queue.h"
#include "plugin.h"
#include "io_format.h"
#include <villas/nodes/zeromq.h>
#include <villas/node.h>
#include <villas/utils.h>
#include <villas/queue.h>
#include <villas/plugin.h>
#include <villas/io_format.h>
static void *context;

View file

@ -27,17 +27,17 @@
#include <inttypes.h>
#include <poll.h>
#include "config.h"
#include "utils.h"
#include "path.h"
#include "timing.h"
#include "pool.h"
#include "queue.h"
#include "hook.h"
#include "plugin.h"
#include "memory.h"
#include "stats.h"
#include "node.h"
#include <villas/config.h>
#include <villas/utils.h>
#include <villas/path.h>
#include <villas/timing.h>
#include <villas/pool.h>
#include <villas/queue.h>
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/memory.h>
#include <villas/stats.h>
#include <villas/node.h>
static int path_source_init(struct path_source *ps)
{

View file

@ -23,7 +23,7 @@
#include <dlfcn.h>
#include <string.h>
#include "plugin.h"
#include <villas/plugin.h>
/** Global list of all known plugins */
struct list plugins = { .state = STATE_DESTROYED };

View file

@ -20,11 +20,10 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*********************************************************************************/
#include "utils.h"
#include "pool.h"
#include "memory.h"
#include "kernel/kernel.h"
#include <villas/utils.h>
#include <villas/pool.h>
#include <villas/memory.h>
#include <villas/kernel/kernel.h>
int pool_init(struct pool *p, size_t cnt, size_t blocksz, struct memtype *m)
{

View file

@ -31,9 +31,9 @@
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*********************************************************************************/
#include "queue.h"
#include "utils.h"
#include "memory.h"
#include <villas/queue.h>
#include <villas/utils.h>
#include <villas/memory.h>
/** Initialize MPMC queue */
int queue_init(struct queue *q, size_t size, struct memtype *mem)

View file

@ -21,8 +21,8 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*********************************************************************************/
#include "queue_signalled.h"
#include "log.h"
#include <villas/queue_signalled.h>
#include <villas/log.h>
#ifdef __linux__
#include <sys/eventfd.h>

View file

@ -24,10 +24,10 @@
#include <math.h>
#include <inttypes.h>
#include "pool.h"
#include "sample.h"
#include "utils.h"
#include "timing.h"
#include <villas/pool.h>
#include <villas/sample.h>
#include <villas/utils.h>
#include <villas/timing.h>
int sample_init(struct sample *s)
{

View file

@ -27,11 +27,11 @@
#include <sys/mman.h>
#include <sys/stat.h>
#include "kernel/kernel.h"
#include "memory.h"
#include "utils.h"
#include "sample.h"
#include "shmem.h"
#include <villas/kernel/kernel.h>
#include <villas/memory.h>
#include <villas/utils.h>
#include <villas/sample.h>
#include <villas/shmem.h>
size_t shmem_total_size(int queuelen, int samplelen)
{

View file

@ -22,15 +22,15 @@
#include <string.h>
#include "stats.h"
#include "hist.h"
#include "timing.h"
#include "node.h"
#include "sample.h"
#include "utils.h"
#include "log.h"
#include "node.h"
#include "table.h"
#include <villas/stats.h>
#include <villas/hist.h>
#include <villas/timing.h>
#include <villas/node.h>
#include <villas/sample.h>
#include <villas/utils.h>
#include <villas/log.h>
#include <villas/node.h>
#include <villas/table.h>
static struct stats_desc {
const char *name;

View file

@ -25,22 +25,22 @@
#include <libgen.h>
#include <unistd.h>
#include "super_node.h"
#include "node.h"
#include "path.h"
#include "utils.h"
#include "list.h"
#include "hook.h"
#include "advio.h"
#include "web.h"
#include "log.h"
#include "api.h"
#include "plugin.h"
#include "memory.h"
#include "config.h"
#include "config_helper.h"
#include <villas/super_node.h>
#include <villas/node.h>
#include <villas/path.h>
#include <villas/utils.h>
#include <villas/list.h>
#include <villas/hook.h>
#include <villas/advio.h>
#include <villas/web.h>
#include <villas/log.h>
#include <villas/api.h>
#include <villas/plugin.h>
#include <villas/memory.h>
#include <villas/config.h>
#include <villas/config_helper.h>
#include "kernel/rt.h"
#include <villas/kernel/rt.h>
int super_node_init(struct super_node *sn)
{

View file

@ -23,9 +23,9 @@
#include <stdlib.h>
#include <string.h>
#include "utils.h"
#include "table.h"
#include "log.h"
#include <villas/utils.h>
#include <villas/table.h>
#include <villas/log.h>
static int table_resize(struct table *t, int width)
{

View file

@ -24,10 +24,9 @@
#include <time.h>
#include <errno.h>
#include "utils.h"
#include "task.h"
#include "timing.h"
#include <villas/utils.h>
#include <villas/task.h>
#include <villas/timing.h>
#if PERIODIC_TASK_IMPL == TIMERFD
#include <sys/timerfd.h>

View file

@ -22,7 +22,7 @@
#include <unistd.h>
#include "timing.h"
#include <villas/timing.h>
struct timespec time_now()
{

View file

@ -31,8 +31,8 @@
#include <fcntl.h>
#include <ctype.h>
#include "config.h"
#include "utils.h"
#include <villas/config.h>
#include <villas/utils.h>
pthread_t main_thread;

View file

@ -23,12 +23,12 @@
#include <libwebsockets.h>
#include <string.h>
#include "utils.h"
#include "log.h"
#include "web.h"
#include "api/session.h"
#include <villas/utils.h>
#include <villas/log.h>
#include <villas/web.h>
#include <villas/api/session.h>
#include "nodes/websocket.h"
#include <villas/nodes/websocket.h>
/* Forward declarations */
lws_callback_function api_ws_protocol_cb;

View file

@ -37,8 +37,7 @@
#include <villas/pool.h>
#include <villas/log.h>
#include <villas/plugin.h>
#include <config_helper.h>
#include <villas/config_helper.h>
#include <villas/kernel/rt.h>
#include "config.h"

View file

@ -23,6 +23,8 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*********************************************************************************/
#include <string.h>
#include <villas/log.h>
#include <villas/node.h>
#include <villas/pool.h>
@ -30,8 +32,6 @@
#include <villas/shmem.h>
#include <villas/utils.h>
#include <string.h>
void *base;
struct shmem_int shm;