Syntalos

Syntalos

Namespaces

Name
Syntalos::ipc

Classes

Name
classSyntalos::AbstractModule
Abstract base class for all modules.
classSyntalos::AbstractStreamPort
structSyntalos::BaseDataType
Base interface for all data types.
classSyntalos::BinaryStreamReader
Reader for Syntalos data entity deserialization.
classSyntalos::BinaryStreamWriter
Writer for Syntalos data entity serialization.
structSyntalos::ConnectInputRequest
structSyntalos::ControlCommand
A control command to a module.
structSyntalos::DeletePortRequest
structSyntalos::DoneResponse
structSyntalos::ErrorEvent
structSyntalos::ExportedStreamInfo
structSyntalos::FirmataControl
Commands to control Firmata output.
structSyntalos::FirmataData
Output data returned from a Firmata device.
structSyntalos::FloatSignalBlock
A block of floating-point signal data from an analog data source.
structSyntalos::Frame
A single frame of a video stream.
classSyntalos::FreqCounterSynchronizer
Synchronizer for a monotonic counter, given a frequency.
classSyntalos::GlobalConfig
structSyntalos::InputPortChange
Information about an input port change.
classSyntalos::InputPortInfo
Reference for an input port.
structSyntalos::IntSignalBlock
A block of integer signal data from a data source.
classSyntalos::IPCConfig
IPC (RouDi) configuration for Syntalos.
structSyntalos::IPCMemPoolInfo
structSyntalos::LoadScriptRequest
classSyntalos::MLinkModule
Master link for out-of-process modules.
classSyntalos::ModuleInfo
Static information about a module.
classSyntalos::OptionalWaitCondition
The OptionalWaitCondition class.
structSyntalos::OutputPortChange
Information about an output port change.
classSyntalos::OutputPortInfo
Reference for an output port.
classSyntalos::OutputPortLink
Reference for an output port to emit new data.
structSyntalos::PrepareStartRequest
classSyntalos::SecondaryClockSynchronizer
Synchronizer for an external steady monotonic clock.
structSyntalos::SetCPUAffinityRequest
structSyntalos::SetMaxRealtimePriority
structSyntalos::SetNicenessRequest
structSyntalos::SetPortsPresetRequest
structSyntalos::SettingsChangeEvent
structSyntalos::ShowDisplayRequest
structSyntalos::ShowSettingsRequest
structSyntalos::ShutdownRequest
classSyntalos::SimpleTerminal
A simple integrated terminal emulator.
structSyntalos::StartRequest
structSyntalos::StateChangeEvent
structSyntalos::StatusMessageEvent
structSyntalos::StopRequest
classSyntalos::StreamExporter
Exporter for streaming data from modules.
classSyntalos::StreamInputPort
classSyntalos::StreamOutputPort
classSyntalos::SubscriptionNotifier
Notifies about new data on a stream subscription in a Qt event loop.
structSyntalos::supports_buffer_reuse
structSyntalos::supports_buffer_reuse< Frame >
structSyntalos::symaster_clock
Syntalos Master Clock.
classSyntalos::SyncTimer
classSyntalos::SyntalosLink
Connection to a Syntalos instance.
classSyntalos::SyntalosLinkModule
Convenience interface to write an OOP Syntalos module.
classSyntalos::SysInfo
structSyntalos::TableRow
A new row for a table.
structSyntalos::TestSubject
The TestSubject struct Data about a test subject.
classSyntalos::TimeSyncFileReader
Read a time-sync (.tsync) file.
classSyntalos::TimeSyncFileWriter
Write a timestamp synchronization file.
structSyntalos::UpdateInputPortMetadataRequest
request to update the metadata of an input port
classSyntalos::VarStreamInputPort

Types

Name
enum class uint16_tModuleState { UNKNOWN, INITIALIZING, IDLE, PREPARING, DORMANT, READY, RUNNING, ERROR}
The ModuleState enum.
enum classControlCommandKind { UNKNOWN, START, PAUSE, STOP, STEP, CUSTOM}
The ControlCommandKind enum.
enum classFirmataCommandKind { UNKNOWN, NEW_DIG_PIN, NEW_ANA_PIN, IO_MODE, WRITE_ANALOG, WRITE_DIGITAL, WRITE_DIGITAL_PULSE, SYSEX}
The FirmataCommandKind enum.
enum classSignalDataType { Amplifier, AuxInput, SupplyVoltage, BoardAdc, BoardDigIn, BoardDigOut}
Type of a signal from a signal source.
enum classTimeSyncStrategy { NONE = 0, SHIFT_TIMESTAMPS_FWD = 1 « 0, SHIFT_TIMESTAMPS_BWD = 1 « 1, ADJUST_CLOCK = 1 « 2, WRITE_TSYNCFILE =
1 « 3}
The time synchronization strategy.
enum classTSyncFileMode { CONTINUOUS = 0, SYNCPOINTS = 1}
Timepoint storage of a TSync file.
enum classTSyncFileTimeUnit { INDEX = 0, NANOSECONDS = 1, MICROSECONDS = 2, MILLISECONDS = 3, SECONDS = 4}
Unit types for time representation in a TSync file.
enum classTSyncFileDataType { INVALID = 0, INT16 = 2, INT32 = 3, INT64 = 4, UINT16 = 6, UINT32 = 7, UINT64 = 8}
Data types use for storing time values in the data file.
enum classSysInfoCheckResult { UNKNOWN, OK, SUSPICIOUS, ISSUE}
enum classColorMode { SYSTEM, BRIGHT, DARK}
enum class uint8_tPortAction { UNKNOWN, ADD, REMOVE, CHANGE}
Action performed to modify a module port.
enum classModuleFeature { NONE = 0, SHOW_SETTINGS = 1 « 0, SHOW_DISPLAY = 1 « 1, REALTIME = 1 « 2, CALL_UI_EVENTS = 1 « 3, REQUEST_CPU_AFFINITY =
1 « 4, PROHIBIT_CPU_AFFINITY = 1
« 5}
The ModuleFeature flags List of basic features this module may or may not support, or may request from the engine to be available.
enum classModuleDriverKind { NONE, THREAD_DEDICATED, EVENTS_DEDICATED, EVENTS_SHARED}
The ModuleDriverKind enum.
enum classUsbHotplugEventKind { NONE, DEVICE_ARRIVED, DEVICE_LEFT, DEVICES_CHANGE}
The UsbHotplugEventKind enum.
enum class uint32_tModuleCategory { NONE = 0, SYNTALOS_DEV = 1 « 0, EXAMPLES = 1 « 1, DEVICES = 1 « 2, GENERATORS = 1 « 3, SCRIPTING = 1 « 4, DISPLAY = 1 « 5, WRITERS = 1 « 6, PROCESSING = 1 « 7}
Categorization for modules.
enum classModuleModifier { NONE = 0, ENABLED = 1 « 0, STOP_ON_FAILURE = 1 « 1}
The ModuleModifier flags Flags set by Syntalos or the user to modify the behavior of the module in the wider context of the running experiment.
enum classPortDirection { NONE, INPUT, OUTPUT}
Enum specifying directionality of a port (in or out)
using std::chrono::time_point< symaster_clock >symaster_timepoint
A timepoint on the master clock.
using std::chrono::secondsseconds_t
Shorthand for seconds.
using std::chrono::millisecondsmilliseconds_t
Shorthand for milliseconds.
using std::chrono::duration< int64_t, std::micro >microseconds_t
Shorthand for microseconds.
using std::chrono::duration< int64_t, std::nano >nanoseconds_t
Shorthand for nanoseconds.
typedef Eigen::Matrix< int32_t, Eigen::Dynamic, 1 >VectorXsi
typedef Eigen::Matrix< uint64_t, Eigen::Dynamic, 1 >VectorXul
typedef Eigen::Matrix< int64_t, Eigen::Dynamic, 1 >VectorXsl
typedef Eigen::Matrix< double, Eigen::Dynamic, 1 >VectorXd
typedef Eigen::Matrix< int32_t, Eigen::Dynamic, Eigen::Dynamic >MatrixXsi
typedef Eigen::Matrix< double, Eigen::Dynamic, Eigen::Dynamic >MatrixXd
using std::function< void(const QString &id, const TimeSyncStrategies &strategies, const microseconds_t &tolerance)>SyncDetailsChangeNotifyFn
Function to call when synchronizer details have changed.
using std::function< void(const QString &id, const microseconds_t &currentOffset)>OffsetChangeNotifyFn
Function to call to notify about an offset change.
using void(AbstractModule::*)(int &)intervalEventFunc_t
Event function type for timed callbacks.
using void(AbstractModule::*)()recvDataEventFunc_t
Event function type for subscription new data callbacks.
using std::vector< std::byte, mi_stl_allocator< std::byte > >ByteVector
ByteVector is a vector of bytes using mimalloc as allocator.
using std::function< void(const QString &script, const QString &wdir)>LoadScriptFn
using std::function< void(const QByteArray &settings)>PrepareStartFn
using std::function< void()>StartFn
using std::function< void()>StopFn
using std::function< void()>ShutdownFn
using std::function< void(const void *data, size_t size)>NewDataRawFn
using std::function< void(const QByteArray &settings)>ShowSettingsFn
using std::function< void(void)>ShowDisplayFn

Functions

Name
template <typename T >
constexpr int
syDataTypeId()
Helper function to get the type ID of a data type.
template <typename T >
T
deserializeFromMemory(const void * memory, size_t size)
Convenience function to deserialize a data type from memory.
voidregisterStreamMetaTypes()
Helper function to register all meta types for stream data.
std::vector< std::pair< std::string, int > >streamTypeIdIndex()
Get a mapping of type names to their IDs.
template <typename T >
std::string
numToString(T x)
Convert a numeric value to a string using Syntalos’ default notation.
const QString &qstr(const QString & s)
QStringqstr(QStringView s)
QStringqstr(const char * s)
QStringqstr(std::string_view s)
QStringqstr(const std::string & s)
autousecToMsec(const microseconds_t & usec)
Convert microseconds to milliseconds.
automsecToUsec(const milliseconds_t & msec)
Convert milliseconds microseconds.
autonsecToUsec(const nanoseconds_t & msec)
Convert nanoseconds microseconds.
autotimeDiffSec(const symaster_timepoint & timePoint1, const symaster_timepoint & timePoint2)
autotimeDiffMsec(const symaster_timepoint & timePoint1, const symaster_timepoint & timePoint2)
autotimeDiffUsec(const symaster_timepoint & timePoint1, const symaster_timepoint & timePoint2)
autotimeDiffToNowMsec(const std::chrono::time_point< symaster_clock > & timePoint)
symaster_timepointcurrentTimePoint()
template <typename T >
double
vectorMedian(const Eigen::Matrix< T, Eigen::Dynamic, 1 > & vec)
template <typename T >
double
vectorMedianInplace(Eigen::Matrix< T, Eigen::Dynamic, 1 > & vec)
template <typename T >
double
vectorVariance(const Eigen::Matrix< T, Eigen::Dynamic, 1 > & vec, const double & mean, bool unbiased =true)
template <typename T >
double
vectorVariance(const Eigen::Matrix< T, Eigen::Dynamic, 1 > & vec, bool unbiased =true)
template <typename EigenType >
void
serializeEigen(BinaryStreamWriter & stream, const EigenType & matrix)
template <typename EigenType >
EigenType
deserializeEigen(BinaryStreamReader & stream)
voidconfigureGlibcAllocator()
voidsetCvMiMatAllocator()
const QStringtimeSyncStrategyToHString(const TimeSyncStrategy & strategy)
const QStringtimeSyncStrategiesToHString(const TimeSyncStrategies & strategies)
template <typename T >
void
safeStopSynchronizer(const T & synchronizerSmartPtr)
template <typename T >
void
safeStopSynchronizer(const T & synchronizer, const microseconds_t & lastValidMasterTimestamp)
QStringtsyncFileTimeUnitToString(const TSyncFileTimeUnit & tsftunit)
QStringtsyncFileDataTypeToString(const TSyncFileDataType & dtype)
QStringtsyncFileModeToString(const TSyncFileMode & mode)
std::optional< QImage >cvMatToQImage(const cv::Mat & mat)
Converts an OpenCV Mat to a QImage.
std::optional< QPixmap >cvMatToQPixmap(const cv::Mat & mat)
QStringshellQuote(const QString & str)
Shell-escape a string.
QStringfindHostExecutable(const QString & exe)
Find executable on the host system (if running in a sandbox)
intrunHostExecutable(const QString & exe, const QStringList & args, bool waitForFinished)
Run command on the host.
intrunInTerminal(const QString & cmd, const QStringList & args, const QString & wdir, const QString & title)
boollaunchProgramNC3Fallback(const QString & exePath, int * pidfd_out)
boollaunchProgramPidFd(const QString & exePath, int * pidfd_out)
Launch a program in a new process, and return the PID of the new process as pidfd.
boolisProcessRunning(int pidfd)
Check if a process is still running using a pidfd.
QStringcolorModeToString(ColorMode mode)
ColorModecolorModeFromString(const QString & str)
QStringfindSyntalosPyWorkerBinary()
voidfindSyntalosLibraryPaths(QString & pkgConfigPath, QString & ldLibraryPath, QString & includePath)
QStringtoString(ModuleCategory category)
ModuleCategorymoduleCategoryFromString(const QString & categoryStr)
ModuleCategoriesmoduleCategoriesFromString(const QString & categoriesStr)
uintqHash(ModuleModifier key, uint seed)
VariantDataStream *newStreamForType(int typeId)
Create a new DataStream for the type identified by the given ID.
VarStreamInputPort *newInputPortForType(int typeId, AbstractModule * mod, const QString & id, const QString & title)
Create a new Input Port for the type identified by the given ID.
template <typename T >
T
streamDataFromRawMemory(const void * data, size_t size)
Convert raw received bytes into their data type.
std::unique_ptr< SyntalosLink >initSyntalosModuleLink()

Attributes

Name
constexpr int64_tUS_PER_MS
constexpr int64_tUS_PER_S
constexpr int64_tUS_PER_MIN
constexpr int64_tUS_PER_H
constexpr int64_tNS_PER_US
constexpr int64_tMS_PER_S
constexpr int64_tMS_PER_MIN
constexpr autoSECONDARY_CLOCK_TOLERANCE
The amount of time a secondary clock is allowed to deviate from the master.
constexpr autoDEFAULT_CLOCKSYNC_CHECK_INTERVAL
Interval at which we check for external clock synchronization.
constexpr uint64_tSY_IOX_QUEUE_CAPACITY
constexpr uint64_tSY_IOX_HISTORY_SIZE
constexpr uint64_tSY_IOX_INITIAL_SLICE_LEN
constexpr size_tSY_IOX_ID_MAX_LEN
const std::stringIN_PORT_CHANGE_CHANNEL_ID
const std::stringOUT_PORT_CHANGE_CHANNEL_ID
const std::stringIN_PORT_UPDATE_METADATA_ID
const std::stringWORKER_CTL_EVENT_ID
const std::stringMASTER_CTL_EVENT_ID
const std::stringERROR_CHANNEL_ID
const std::stringSTATE_CHANNEL_ID
const std::stringSTATUS_MESSAGE_CHANNEL_ID
const std::stringSET_NICENESS_CALL_ID
const std::stringSET_MAX_RT_PRIORITY_CALL_ID
const std::stringSET_CPU_AFFINITY_CALL_ID
const std::stringDELETE_PORT_CALL_ID
const std::stringCONNECT_INPUT_CALL_ID
const std::stringLOAD_SCRIPT_CALL_ID
const std::stringSET_PORTS_PRESET_CALL_ID
const std::stringPREPARE_START_CALL_ID
const std::stringSTART_CALL_ID
const std::stringSTOP_CALL_ID
const std::stringSHUTDOWN_CALL_ID
const std::stringSETTINGS_CHANGE_CHANNEL_ID
const std::stringSHOW_SETTINGS_CALL_ID
const std::stringSHOW_DISPLAY_CALL_ID

Types Documentation

enum ModuleState

EnumeratorValueDescription
UNKNOWN
INITIALIZINGModule is in an unknown state.
IDLEModule is initializing after being added.
PREPARINGModule is inactive and not started.
DORMANTModule is preparing a run.
READYThe module is inactive for this run, as it has no work to do.
RUNNINGEverything is prepared, we are ready to start.
ERRORModule is running. Module failed to run / is in an error state

The ModuleState enum.

Describes the state a module can be in. The state is usually displayed to the user via a module indicator widget.

enum ControlCommandKind

EnumeratorValueDescription
UNKNOWN
START
PAUSEStart an operation.
STOPPause an operation, can be resumed with START.
STEPStop an operation.
CUSTOMAdvance operation by one step.

The ControlCommandKind enum.

Basic operations to control a module from another module.

enum FirmataCommandKind

EnumeratorValueDescription
UNKNOWN
NEW_DIG_PIN
NEW_ANA_PIN
IO_MODE
WRITE_ANALOG
WRITE_DIGITAL
WRITE_DIGITAL_PULSE
SYSEXnot implemented

The FirmataCommandKind enum.

Set which type of change should be made on a Firmata interface.

enum SignalDataType

EnumeratorValueDescription
Amplifier
AuxInput
SupplyVoltage
BoardAdc
BoardDigIn
BoardDigOut

Type of a signal from a signal source.

This is usually set in the metadata of a data stream.

enum TimeSyncStrategy

EnumeratorValueDescription
NONE0
SHIFT_TIMESTAMPS_FWD1 « 0
SHIFT_TIMESTAMPS_BWD1 « 1Move timestamps forward to match the master clock.
ADJUST_CLOCK1 « 2Move timestamps backward to match the master clock.
WRITE_TSYNCFILE=
1 « 3Do not change timestamps by adjust the secondary clocks to match the master clock.

The time synchronization strategy.

enum TSyncFileMode

EnumeratorValueDescription
CONTINUOUS0
SYNCPOINTS1Continous time-point mapping with no gaps.

Timepoint storage of a TSync file.

enum TSyncFileTimeUnit

EnumeratorValueDescription
INDEX0
NANOSECONDS1monotonically increasing counter without dimension
MICROSECONDS2
MILLISECONDS3
SECONDS4

Unit types for time representation in a TSync file.

enum TSyncFileDataType

EnumeratorValueDescription
INVALID0
INT162
INT323
INT644
UINT166
UINT327
UINT648

Data types use for storing time values in the data file.

enum SysInfoCheckResult

EnumeratorValueDescription
UNKNOWN
OK
SUSPICIOUS
ISSUE

enum ColorMode

EnumeratorValueDescription
SYSTEM
BRIGHT
DARK

enum PortAction

EnumeratorValueDescription
UNKNOWN
ADDUndefined action.
REMOVEAdd a new port.
CHANGERemove an existing port. Change an existing port

Action performed to modify a module port.

enum ModuleFeature

EnumeratorValueDescription
NONE0
SHOW_SETTINGS1 « 0
SHOW_DISPLAY1 « 1Module can display a settings window.
REALTIME1 « 2Module has one or more display window(s) to show.
CALL_UI_EVENTS1 « 3Enable realtime scheduling for the module’s thread.
REQUEST_CPU_AFFINITY=
1 « 4Call direct UI events processing method.
PROHIBIT_CPU_AFFINITY1
« 5Pin the module’s thread to a separate CPU core, if possible (even if the user disabled this)

The ModuleFeature flags List of basic features this module may or may not support, or may request from the engine to be available.

enum ModuleDriverKind

EnumeratorValueDescription
NONE
THREAD_DEDICATEDModule will be run in the main (GUI) thread.
EVENTS_DEDICATEDModule wants to run in a dedicated thread.
EVENTS_SHAREDModule shares a thread(pool) with other modules of its kind, via an event loop. Module shares a thread(pool) with arbitrary other modules, actions are triggered by events

The ModuleDriverKind enum.

enum UsbHotplugEventKind

EnumeratorValueDescription
NONE
DEVICE_ARRIVEDNo USB hotplug event.
DEVICE_LEFTA new device appeared.
DEVICES_CHANGEA device has left. Devices have appeared and left

The UsbHotplugEventKind enum.

enum ModuleCategory

EnumeratorValueDescription
NONE0
SYNTALOS_DEV1 « 0Not categorized.
EXAMPLES1 « 1A development/test tool for Syntalos itself.
DEVICES1 « 2An example / template module.
GENERATORS1 « 3Modules which communicate with hwrdware devices.
SCRIPTING1 « 4(Test)data generators)
DISPLAY1 « 5Scripting & customization.
WRITERS1 « 6Display modules.
PROCESSING1 « 7Modules which write data to disk.

Categorization for modules.

enum ModuleModifier

EnumeratorValueDescription
NONE0
ENABLED1 « 0
STOP_ON_FAILURE1 « 1The module is enabled.

The ModuleModifier flags Flags set by Syntalos or the user to modify the behavior of the module in the wider context of the running experiment.

enum PortDirection

EnumeratorValueDescription
NONE
INPUT
OUTPUT

Enum specifying directionality of a port (in or out)

using symaster_timepoint

using Syntalos::symaster_timepoint = typedef std::chrono::time_point<symaster_clock>;

A timepoint on the master clock.

using seconds_t

using Syntalos::seconds_t = typedef std::chrono::seconds;

Shorthand for seconds.

using milliseconds_t

using Syntalos::milliseconds_t = typedef std::chrono::milliseconds;

Shorthand for milliseconds.

using microseconds_t

using Syntalos::microseconds_t = typedef std::chrono::duration<int64_t, std::micro>;

Shorthand for microseconds.

using nanoseconds_t

using Syntalos::nanoseconds_t = typedef std::chrono::duration<int64_t, std::nano>;

Shorthand for nanoseconds.

typedef VectorXsi

typedef Eigen::Matrix<int32_t, Eigen::Dynamic, 1> Syntalos::VectorXsi;

typedef VectorXul

typedef Eigen::Matrix<uint64_t, Eigen::Dynamic, 1> Syntalos::VectorXul;

typedef VectorXsl

typedef Eigen::Matrix<int64_t, Eigen::Dynamic, 1> Syntalos::VectorXsl;

typedef VectorXd

typedef Eigen::Matrix<double, Eigen::Dynamic, 1> Syntalos::VectorXd;

typedef MatrixXsi

typedef Eigen::Matrix<int32_t, Eigen::Dynamic, Eigen::Dynamic> Syntalos::MatrixXsi;

typedef MatrixXd

typedef Eigen::Matrix<double, Eigen::Dynamic, Eigen::Dynamic> Syntalos::MatrixXd;

using SyncDetailsChangeNotifyFn

using Syntalos::SyncDetailsChangeNotifyFn = typedef std::function<void(const QString &id, const TimeSyncStrategies &strategies, const microseconds_t &tolerance)>;

Function to call when synchronizer details have changed.

using OffsetChangeNotifyFn

using Syntalos::OffsetChangeNotifyFn = typedef std::function<void(const QString &id, const microseconds_t &currentOffset)>;

Function to call to notify about an offset change.

using intervalEventFunc_t

using Syntalos::intervalEventFunc_t = typedef void (AbstractModule::*)(int &);

Event function type for timed callbacks.

using recvDataEventFunc_t

using Syntalos::recvDataEventFunc_t = typedef void (AbstractModule::*)();

Event function type for subscription new data callbacks.

using ByteVector

using Syntalos::ByteVector = typedef std::vector<std::byte, mi_stl_allocator<std::byte> >;

ByteVector is a vector of bytes using mimalloc as allocator.

In Syntalos’ heavily threaded environment, where in the worst case a ton of these vectors may be created and destroyed in quick succession, the default glibc allocator is less than optimal. Mimalloc has shown to perform a lot better for this burst-like, threaded activity, therefore we prefer it. Please try to reuse buffers whenever possible still though - while mimalloc is a significant improvement, reusing memory segments is even better.

using LoadScriptFn

using Syntalos::LoadScriptFn = typedef std::function<void(const QString &script, const QString &wdir)>;

using PrepareStartFn

using Syntalos::PrepareStartFn = typedef std::function<void(const QByteArray &settings)>;

using StartFn

using Syntalos::StartFn = typedef std::function<void()>;

using StopFn

using Syntalos::StopFn = typedef std::function<void()>;

using ShutdownFn

using Syntalos::ShutdownFn = typedef std::function<void()>;

using NewDataRawFn

using Syntalos::NewDataRawFn = typedef std::function<void(const void *data, size_t size)>;

using ShowSettingsFn

using Syntalos::ShowSettingsFn = typedef std::function<void(const QByteArray &settings)>;

using ShowDisplayFn

using Syntalos::ShowDisplayFn = typedef std::function<void(void)>;

Functions Documentation

function syDataTypeId

template <typename T >
constexpr int syDataTypeId()

Helper function to get the type ID of a data type.

function deserializeFromMemory

template <typename T >
T deserializeFromMemory(
    const void * memory,
    size_t size
)

Convenience function to deserialize a data type from memory.

function registerStreamMetaTypes

void registerStreamMetaTypes()

Helper function to register all meta types for stream data.

This function registers all types with the meta object system and also creates a global map of all available stream types.

function streamTypeIdIndex

std::vector< std::pair< std::string, int > > streamTypeIdIndex()

Get a mapping of type names to their IDs.

function numToString

template <typename T >
inline std::string numToString(
    T x
)

Convert a numeric value to a string using Syntalos’ default notation.

This function converts arithmetic types to strings in a locale-independent way. For floating-point types, it uses the “general” format (shortest representation). Special values (NaN, infinity) are handled consistently across all types.

function qstr

inline const QString & qstr(
    const QString & s
)

function qstr

inline QString qstr(
    QStringView s
)

function qstr

inline QString qstr(
    const char * s
)

function qstr

inline QString qstr(
    std::string_view s
)

function qstr

inline QString qstr(
    const std::string & s
)

function usecToMsec

inline auto usecToMsec(
    const microseconds_t & usec
)

Convert microseconds to milliseconds.

Shorthand for duration-case to increase code readability.

function msecToUsec

inline auto msecToUsec(
    const milliseconds_t & msec
)

Convert milliseconds microseconds.

Shorthand for duration-case to increase code readability.

function nsecToUsec

inline auto nsecToUsec(
    const nanoseconds_t & msec
)

Convert nanoseconds microseconds.

Shorthand for duration-case to increase code readability.

function timeDiffSec

inline auto timeDiffSec(
    const symaster_timepoint & timePoint1,
    const symaster_timepoint & timePoint2
)

function timeDiffMsec

inline auto timeDiffMsec(
    const symaster_timepoint & timePoint1,
    const symaster_timepoint & timePoint2
)

function timeDiffUsec

inline auto timeDiffUsec(
    const symaster_timepoint & timePoint1,
    const symaster_timepoint & timePoint2
)

function timeDiffToNowMsec

inline auto timeDiffToNowMsec(
    const std::chrono::time_point< symaster_clock > & timePoint
)

function currentTimePoint

inline symaster_timepoint currentTimePoint()

function vectorMedian

template <typename T >
double vectorMedian(
    const Eigen::Matrix< T, Eigen::Dynamic, 1 > & vec
)

function vectorMedianInplace

template <typename T >
double vectorMedianInplace(
    Eigen::Matrix< T, Eigen::Dynamic, 1 > & vec
)

function vectorVariance

template <typename T >
double vectorVariance(
    const Eigen::Matrix< T, Eigen::Dynamic, 1 > & vec,
    const double & mean,
    bool unbiased =true
)

function vectorVariance

template <typename T >
double vectorVariance(
    const Eigen::Matrix< T, Eigen::Dynamic, 1 > & vec,
    bool unbiased =true
)

function serializeEigen

template <typename EigenType >
void serializeEigen(
    BinaryStreamWriter & stream,
    const EigenType & matrix
)

function deserializeEigen

template <typename EigenType >
EigenType deserializeEigen(
    BinaryStreamReader & stream
)

function configureGlibcAllocator

void configureGlibcAllocator()

Change settings of the default Glibc allocator to reduce fragmentation and match Syntalos’ allocation patterns better. Not needed if mimalloc is used.

function setCvMiMatAllocator

void setCvMiMatAllocator()

Install the mimalloc-backed allocator as OpenCV’s default matrix allocator.

Call this once early in main(), before any cv::Mat is created.

function timeSyncStrategyToHString

const QString timeSyncStrategyToHString(
    const TimeSyncStrategy & strategy
)

function timeSyncStrategiesToHString

const QString timeSyncStrategiesToHString(
    const TimeSyncStrategies & strategies
)

function safeStopSynchronizer

template <typename T >
void safeStopSynchronizer(
    const T & synchronizerSmartPtr
)

function safeStopSynchronizer

template <typename T >
void safeStopSynchronizer(
    const T & synchronizer,
    const microseconds_t & lastValidMasterTimestamp
)

function tsyncFileTimeUnitToString

QString tsyncFileTimeUnitToString(
    const TSyncFileTimeUnit & tsftunit
)

function tsyncFileDataTypeToString

QString tsyncFileDataTypeToString(
    const TSyncFileDataType & dtype
)

function tsyncFileModeToString

QString tsyncFileModeToString(
    const TSyncFileMode & mode
)

function cvMatToQImage

std::optional< QImage > cvMatToQImage(
    const cv::Mat & mat
)

Converts an OpenCV Mat to a QImage.

Parameters:

  • mat The OpenCV Mat to convert.

Return: An optional containing the converted QImage, or std::nullopt if conversion fails.

This function attempts to convert the given OpenCV Mat to a QImage. It supports grayscale (1 channel), RGB (3 channels), and RGBA (4 channels) images. If the conversion is successful, it returns a QImage wrapped in std::optional. If the conversion fails (e.g., unsupported number of channels), it returns std::nullopt.

function cvMatToQPixmap

std::optional< QPixmap > cvMatToQPixmap(
    const cv::Mat & mat
)

function shellQuote

QString shellQuote(
    const QString & str
)

Shell-escape a string.

function findHostExecutable

QString findHostExecutable(
    const QString & exe
)

Find executable on the host system (if running in a sandbox)

Parameters:

  • exe Name of the executable to look for

Return: Executable name, or empty string if not found

function runHostExecutable

int runHostExecutable(
    const QString & exe,
    const QStringList & args,
    bool waitForFinished
)

Run command on the host.

Parameters:

  • exe The program to run
  • args Program arguments
  • waitForFinished Wait for the command to finish

Return: Exit status of the program (if waiting for finished)

function runInTerminal

int runInTerminal(
    const QString & cmd,
    const QStringList & args,
    const QString & wdir,
    const QString & title
)

function launchProgramNC3Fallback

static bool launchProgramNC3Fallback(
    const QString & exePath,
    int * pidfd_out
)

Fallback for launchProgram() if the clone3() syscall was not available or is blocked by seccomp filters.

function launchProgramPidFd

bool launchProgramPidFd(
    const QString & exePath,
    int * pidfd_out
)

Launch a program in a new process, and return the PID of the new process as pidfd.

Parameters:

  • exePath The path to the executable to launch.
  • pidfd_out A pointer to an integer, which will be set to the PID of the new process.

Return: true if the program was successfully launched, false otherwise.

This function is used to launch a new program in a new process, and return the PID as pidfd.

function isProcessRunning

bool isProcessRunning(
    int pidfd
)

Check if a process is still running using a pidfd.

Parameters:

  • pidfd The PIDFD of the process to check.

Return: true if the process is still running, false otherwise.

This function checks if a process is still running, by checking if the process has exited or not.

function colorModeToString

QString colorModeToString(
    ColorMode mode
)

function colorModeFromString

ColorMode colorModeFromString(
    const QString & str
)

function findSyntalosPyWorkerBinary

QString findSyntalosPyWorkerBinary()

function findSyntalosLibraryPaths

void findSyntalosLibraryPaths(
    QString & pkgConfigPath,
    QString & ldLibraryPath,
    QString & includePath
)

function toString

QString toString(
    ModuleCategory category
)

function moduleCategoryFromString

ModuleCategory moduleCategoryFromString(
    const QString & categoryStr
)

function moduleCategoriesFromString

ModuleCategories moduleCategoriesFromString(
    const QString & categoriesStr
)

function qHash

inline uint qHash(
    ModuleModifier key,
    uint seed
)

function newStreamForType

VariantDataStream * newStreamForType(
    int typeId
)

Create a new DataStream for the type identified by the given ID.

function newInputPortForType

VarStreamInputPort * newInputPortForType(
    int typeId,
    AbstractModule * mod,
    const QString & id,
    const QString & title
)

Create a new Input Port for the type identified by the given ID.

function streamDataFromRawMemory

template <typename T >
T streamDataFromRawMemory(
    const void * data,
    size_t size
)

Convert raw received bytes into their data type.

function initSyntalosModuleLink

std::unique_ptr< SyntalosLink > initSyntalosModuleLink()

Attributes Documentation

variable US_PER_MS

constexpr int64_t US_PER_MS = 1'000;

variable US_PER_S

constexpr int64_t US_PER_S = 1'000 * US_PER_MS;

variable US_PER_MIN

constexpr int64_t US_PER_MIN = 60 * US_PER_S;

variable US_PER_H

constexpr int64_t US_PER_H = 60 * US_PER_MIN;

variable NS_PER_US

constexpr int64_t NS_PER_US = 1'000;

variable MS_PER_S

constexpr int64_t MS_PER_S = 1'000;

variable MS_PER_MIN

constexpr int64_t MS_PER_MIN = 60 * MS_PER_S;

variable SECONDARY_CLOCK_TOLERANCE

static constexpr auto SECONDARY_CLOCK_TOLERANCE = microseconds_t(1000);

The amount of time a secondary clock is allowed to deviate from the master.

Since Syntalos uses millisecond time resolution, permitting (slightly more than) half a millisecond deviation for secondary clocks from the master clock is sensible.

IMPORTANT: Modules may override this value for their synchronizers to one that fits their device better. This is just a default for modules which do not change the default setting.

variable DEFAULT_CLOCKSYNC_CHECK_INTERVAL

static constexpr auto DEFAULT_CLOCKSYNC_CHECK_INTERVAL = milliseconds_t(4000);

Interval at which we check for external clock synchronization.

IMPORTANT: This is just a default value for modules which do not explicitly define a check interval. Individual modules may choose a different value that fits the device they are communicating with best.

variable SY_IOX_QUEUE_CAPACITY

static constexpr uint64_t SY_IOX_QUEUE_CAPACITY = 12U;

variable SY_IOX_HISTORY_SIZE

static constexpr uint64_t SY_IOX_HISTORY_SIZE = 2U;

variable SY_IOX_INITIAL_SLICE_LEN

static constexpr uint64_t SY_IOX_INITIAL_SLICE_LEN = 4096;

variable SY_IOX_ID_MAX_LEN

static constexpr size_t SY_IOX_ID_MAX_LEN = IOX2_SERVICE_NAME_LENGTH;

variable IN_PORT_CHANGE_CHANNEL_ID

static const std::string IN_PORT_CHANGE_CHANNEL_ID = "InPortChange";

variable OUT_PORT_CHANGE_CHANNEL_ID

static const std::string OUT_PORT_CHANGE_CHANNEL_ID = "OutPortChange";

variable IN_PORT_UPDATE_METADATA_ID

static const std::string IN_PORT_UPDATE_METADATA_ID = "UpdateInputPortMetadata";

variable WORKER_CTL_EVENT_ID

static const std::string WORKER_CTL_EVENT_ID = "worker-event";

Shared wakeup event service names for the control channel.

WORKER_CTL_EVENT_ID - the worker notifies the master whenever it publishes on a control channel (error, state, port-changes …). The master attaches one listener for this to its WaitSet.

MASTER_CTL_EVENT_ID - the master notifies the worker whenever it sends a request (request-response commands).

variable MASTER_CTL_EVENT_ID

static const std::string MASTER_CTL_EVENT_ID = "master-event";

variable ERROR_CHANNEL_ID

static const std::string ERROR_CHANNEL_ID = "Error";

variable STATE_CHANNEL_ID

static const std::string STATE_CHANNEL_ID = "State";

variable STATUS_MESSAGE_CHANNEL_ID

static const std::string STATUS_MESSAGE_CHANNEL_ID = "StatusMessage";

variable SET_NICENESS_CALL_ID

static const std::string SET_NICENESS_CALL_ID = "SetNiceness";

variable SET_MAX_RT_PRIORITY_CALL_ID

static const std::string SET_MAX_RT_PRIORITY_CALL_ID = "SetMaxRealtimePriority";

variable SET_CPU_AFFINITY_CALL_ID

static const std::string SET_CPU_AFFINITY_CALL_ID = "SetCPUAffinity";

variable DELETE_PORT_CALL_ID

static const std::string DELETE_PORT_CALL_ID = "DeletePort";

variable CONNECT_INPUT_CALL_ID

static const std::string CONNECT_INPUT_CALL_ID = "ConnectInputPort";

variable LOAD_SCRIPT_CALL_ID

static const std::string LOAD_SCRIPT_CALL_ID = "LoadScript";

variable SET_PORTS_PRESET_CALL_ID

static const std::string SET_PORTS_PRESET_CALL_ID = "SetPortsPresetRequest";

variable PREPARE_START_CALL_ID

static const std::string PREPARE_START_CALL_ID = "PrepareStart";

variable START_CALL_ID

static const std::string START_CALL_ID = "Start";

variable STOP_CALL_ID

static const std::string STOP_CALL_ID = "Stop";

variable SHUTDOWN_CALL_ID

static const std::string SHUTDOWN_CALL_ID = "Shutdown";

variable SETTINGS_CHANGE_CHANNEL_ID

static const std::string SETTINGS_CHANGE_CHANNEL_ID = "SettingsChange";

variable SHOW_SETTINGS_CALL_ID

static const std::string SHOW_SETTINGS_CALL_ID = "ShowSettings";

variable SHOW_DISPLAY_CALL_ID

static const std::string SHOW_DISPLAY_CALL_ID = "ShowDisplay";

Updated on 2026-03-16 at 19:16:01 +0000