diff --git a/server/include/path.h b/server/include/path.h index 519832040..6838fa7ad 100644 --- a/server/include/path.h +++ b/server/include/path.h @@ -47,6 +47,8 @@ struct path /** Send messages with a fixed rate over this path */ double rate; + /** Maximum number of values per message for this path */ + int msgsize; /** Size of the history buffer in number of messages */ int poolsize; /** A circular buffer of past messages */ diff --git a/server/src/cfg.c b/server/src/cfg.c index 6d547379c..a0a59bfd1 100644 --- a/server/src/cfg.c +++ b/server/src/cfg.c @@ -134,6 +134,8 @@ int config_parse_path(config_setting_t *cfg, p->rate = 0; /* disabled */ if (!config_setting_lookup_int(cfg, "poolsize", &p->poolsize)) p->poolsize = DEFAULT_POOLSIZE; + if (!config_setting_lookup_int(cfg, "msgsize", &p->msgsize)) + p->msgsize = MAX_VALUES; p->cfg = cfg; diff --git a/server/src/path.c b/server/src/path.c index d15393682..85a7f80a7 100644 --- a/server/src/path.c +++ b/server/src/path.c @@ -122,7 +122,7 @@ static void * path_run(void *arg) int path_start(struct path *p) { INDENT char *buf = path_print(p); - info("Starting path: %s (poolsize = %u)", buf, p->poolsize); + info("Starting path: %s (poolsize = %u, msgsize = %u, #hooks = %zu)", buf, p->poolsize, p->msgsize, list_length(&p->hooks)); free(buf); if (path_run_hook(p, HOOK_PATH_START))