roc_send: --real-time cli parameter

Author: baranovmv

src/tools/roc_send/cmdline.ggo

@@ -5,6 +5,8 @@ option "verbose" v "Increase verbosity level (may be used multiple times)"
     multiple optional
 option "color" - "Set colored logging mode for stderr output"
     values="auto","always","never" default="auto" enum optional
+option "real-time" - "Set realtime priority for timing sensitive threads, 0-99 Requires root privileges."
+    int typestr="INTEGER" optional default="0"
 
 option "list-supported" L "List supported protocols, formats, etc." optional
 

src/tools/roc_send/main.cpp

@@ -82,6 +82,14 @@ bool build_io_config(const gengetopt_args_info& args, sndio::IoConfig& io_config
 bool build_context_config(const gengetopt_args_info& args,
                           const sndio::IoConfig& io_config,
                           node::ContextConfig& context_config) {
+    if (args.real_time_arg != 0) {
+        if (args.real_time_arg < 0 || args.real_time_arg >= 100) {
+            roc_log(LogError, "invalid --real-time: should be in range [0..99]");
+            return false;
+        }
+        context_config.realtime_prio = args.real_time_arg;
+    }
+
     if (args.max_packet_size_given) {
         if (!core::parse_size(args.max_packet_size_arg, context_config.max_packet_size)) {
             roc_log(LogError, "invalid --max-packet-size: bad format");
@@ -613,7 +621,7 @@ int main(int argc, char** argv) {
         return 1;
     }
 
-    const status::StatusCode status = pump.run();
+    const status::StatusCode status = pump.run(args.real_time_arg);
     if (status != status::StatusOK) {
         roc_log(LogError, "io pump failed: status=%s", status::code_to_str(status));
         return 1;