print received FEC configuration and display in 'i'

(in the keycontrol mode when 'i' is pressed)

Author: MartinPulec

src/keyboard_control.cpp

@@ -807,6 +807,18 @@ void keyboard_control::impl::info()
                               << response_get_text(r) << "\n";
                 }
                 free_response(r);
+
+                m = (struct msg_universal *) new_message(
+                    sizeof(struct msg_universal));
+                strcpy(m->text, "get_fec");
+                r = send_message_sync(
+                    m_root, "receiver.decoder", (struct message *) m, 100,
+                    SEND_MESSAGE_FLAG_QUIET | SEND_MESSAGE_FLAG_NO_STORE);
+                if (response_get_status(r) == RESPONSE_OK) {
+                        col() << TBOLD("Received video FEC: ")
+                              << response_get_text(r) << "\n";
+                }
+                free_response(r);
 	}
 
 	{

src/rtp/fec.cpp

@@ -54,6 +54,8 @@
 #include "ug_runtime_error.hpp"
 #include "utils/macros.h"
 
+#define MOD_NAME "[fec] "
+
 using std::exception;
 using std::stof;
 using std::stoi;
@@ -104,8 +106,40 @@ fec *fec::create_from_config(const char *c_str, bool is_audio) noexcept
         return nullptr;
 }
 
+static const char *
+get_fec_name(enum fec_type type)
+{
+        switch (type) {
+        case FEC_NONE:
+                return "(none)";
+        case FEC_MULT:
+                return "mult";
+        case FEC_LDGM:
+                return "LDGM";
+        case FEC_RS:
+                return "Reed-Solomon";
+        }
+        abort();
+}
+
+const char *get_fec_desc(struct fec_desc desc, size_t buflen, char *buf)
+{
+        if (desc.type == FEC_NONE) {
+                return "none or multiplication";
+        }
+        int ret =
+            snprintf(buf, buflen, "type=%s, k=%u, m=%u, c=%u, seed=%u, ss=%u",
+                     get_fec_name(desc.type), desc.k, desc.m, desc.c, desc.seed,
+                     desc.symbol_size);
+        assert(ret < (int) buflen);
+        return buf;
+}
+
 fec *fec::create_from_desc(struct fec_desc desc) noexcept
 {
+        char buf[STR_LEN];
+        MSG(INFO, "Receiving FEC - %s\n", get_fec_desc(desc, sizeof buf, buf));
+
         try {
                 switch (desc.type) {
                         case FEC_LDGM:

src/rtp/fec.h

@@ -3,7 +3,7 @@
  * @author Martin Pulec     <pulec@cesnet.cz>
  */
 /*
- * Copyright (c) 2014-2021 CESNET z.s.p.o.
+ * Copyright (c) 2014-2026 CESNET, zájmové sdružení právnických osob
  * All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
@@ -72,9 +72,14 @@ struct fec {
 #endif // __cplusplus
 
 #ifdef __cplusplus
+#include <cstddef>
 extern "C" {
+#else
+#include <stddef.h>
 #endif
+
 int fec_pt_from_fec_type(enum tx_media_type media_type, enum fec_type fec_type, bool encrypted);
+const char *get_fec_desc(struct fec_desc desc, size_t buflen, char *buf);
 #ifdef __cplusplus
 }
 #endif

src/rtp/video_decoders.cpp

@@ -353,6 +353,7 @@ struct state_video_decoder
         thread decompress_thread_id,
                   fec_thread_id;
         struct video_desc received_vid_desc = {}; ///< description of the network video
+        struct fec_desc   received_vid_fec = {};
         struct pixfmt_desc received_int_desc = {}; ///< compression int desc
         struct video_desc display_desc = {};      ///< description of the mode that display is currently configured to
 
@@ -448,6 +449,8 @@ static void *fec_thread(void *args) {
                                         exit_uv(1);
                                         goto cleanup;
                                 }
+                                unique_lock<mutex> lk(decoder->lock);
+                                decoder->received_vid_fec = desc;
                         }
                 }
 
@@ -1874,6 +1877,12 @@ static void decoder_process_message(struct module *m)
                         string video_desc = s->received_vid_desc;
                         s->lock.unlock();
                         r = new_response(RESPONSE_OK, video_desc.c_str());
+                } else if (strcmp(m_univ->text, "get_fec") == 0) {
+                        unique_lock<mutex> lk(s->lock);
+                        char               buf[STR_LEN];
+                        r = new_response(
+                            RESPONSE_OK,
+                            get_fec_desc(s->received_vid_fec, sizeof buf, buf));
                 } else {
                         r = new_response(RESPONSE_NOT_FOUND, NULL);
                 }