16#include <fmt/format.h>
20std::string defaultIPCFolder()
23 char const* channelPrefix = getenv(
"ALIEN_PROC_ID");
25 return fmt::format(
"@dpl_{}_", channelPrefix);
30 char const* channelPrefix = getenv(
"TMPDIR");
32 return {channelPrefix};
34 return access(
"/tmp", W_OK) == 0 ?
"/tmp" :
".";
52 {
"timeframes-rate-limit-ipcid",
VariantType::String,
"-1", {
"Suffix for IPC channel for metric-feedback, -1 = disable"}},
55 {
"aod-memory-rate-limit",
VariantType::Int64, 0LL, {
"Rate limit AOD processing based on memory"}},
65 {
"aod-writer-maxfilesize",
VariantType::Float, 0.0f, {
"Maximum size of an output file in megabytes"}},
66 {
"aod-writer-resmode",
VariantType::String,
"RECREATE", {
"Creation mode of the result files: NEW, CREATE, RECREATE, UPDATE"}},
67 {
"aod-writer-ntfmerge",
VariantType::Int, -1, {
"Number of time frames to merge into one file"}},
68 {
"aod-writer-keep",
VariantType::String,
"", {
"Comma separated list of ORIGIN/DESCRIPTION/SUBSPECIFICATION:treename:col1/col2/..:filename"}},
70 {
"fairmq-rate-logging",
VariantType::Int, 0, {
"Rate logging for FairMQ channels"}},
71 {
"fairmq-recv-buffer-size",
VariantType::Int, 4, {
"recvBufferSize option for FairMQ channels"}},
72 {
"fairmq-send-buffer-size",
VariantType::Int, 4, {
"sendBufferSize option for FairMQ channels"}},
74 {
"fairmq-ipc-prefix",
VariantType::String, defaultIPCFolder(), {
"Prefix for FairMQ channels location"}},
77 " *dangling*: dangling outputs,"
79 " none: no forwarding - it will complain if you try to create dangling outputs"}},
80 {
"forwarding-destination",
83 {
"Destination for forwarded messages."
84 " drop: simply drop them,"
85 " file: write to file,"
86 " fairmq: send to output proxy"}}}};
GLuint GLint GLboolean GLint GLenum access
Defining PrimaryVertex explicitly as messageable.
static std::vector< ConfigParamSpec > requiredWorkflowOptions()