vcap/omt: Initial

Author: mpiatka

configure.ac

@@ -3468,7 +3468,7 @@ fi
 if test "${omt_req?}" != no && test "${FOUND_LIBOMT_H?}" && test "${FOUND_LIBOMT_LIB?}" = yes
 then
         omt=yes
-        add_module rxtx_omt "src/omt_common.o src/video_rxtx/omt.o src/video_display/omt.o" "-lomt"
+        add_module rxtx_omt "src/omt_common.o src/video_rxtx/omt.o src/video_display/omt.o src/video_capture/omt.o" "-lomt"
 fi
 
 ENSURE_FEATURE_PRESENT([${omt_req?}], [${omt?}], [libomt not found])

src/video_capture/omt.cpp

@@ -0,0 +1,153 @@
+/**
+ * @file   video_capture/omt.cpp
+ * @author Martin Piatka     <piatka@cesnet.cz>
+ */
+/*
+ * Copyright (c) 2026 CESNET, zájmové sdružení právnických osob
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, is permitted provided that the following conditions
+ * are met:
+ *
+ * 1. Redistributions of source code must retain the above copyright
+ *    notice, this list of conditions and the following disclaimer.
+ *
+ * 2. Redistributions in binary form must reproduce the above copyright
+ *    notice, this list of conditions and the following disclaimer in the
+ *    documentation and/or other materials provided with the distribution.
+ *
+ * 3. Neither the name of CESNET nor the names of its contributors may be
+ *    used to endorse or promote products derived from this software without
+ *    specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE AUTHORS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESSED OR IMPLIED WARRANTIES, INCLUDING,
+ * BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
+ * AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
+ * EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
+ * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
+ * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
+ * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE,
+ * EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+#include <cassert>
+#include <memory>
+
+#include "debug.h"
+#include "omt_common.hpp"
+#include "video_capture.h"
+#include "lib_common.h"
+#include "video_codec.h"
+#include "video_frame.h"
+#include "utils/color_out.h"
+#include "utils/string_view_utils.hpp"
+
+#define MOD_NAME "[omt] "
+
+namespace{
+using video_frame_uniq = std::unique_ptr<video_frame, deleter_from_fcn<vf_free>>;
+
+struct state_omt_cap{
+        omt_receive_uniq omt_h;
+
+        video_frame_uniq ug_frame;
+
+        std::string sender_addr = "localhost";
+        int port = 6400;
+};
+
+void capture_omt_probe(device_info **available_cards, int *count, void(** deleter)(void *)){
+        *deleter = free;
+        *available_cards = nullptr;
+        *count = 0;
+}
+
+void show_help(){
+        color_printf("Open Media Transport\n");
+        color_printf("Usage\n");
+        color_printf(TERM_BOLD TERM_FG_RED "\t-t omt" TERM_FG_RESET "[:addr=<addr>][:port=<port>]\n" TERM_RESET);
+        color_printf("\n");
+}
+
+int parse_cfg(state_omt_cap& s, std::string_view cfg){
+        while(!cfg.empty()){
+                auto tok = tokenize(cfg, ':', '"');
+                const auto key = tokenize(tok, '=', '"');
+                const auto val = tokenize(tok, '=', '"');
+
+                if(key == "addr"){
+                        s.sender_addr = val;
+                } else if(key == "port"){
+                        if(!parse_num(val, s.port)){
+                                log_msg(LOG_LEVEL_FATAL, "Failed to parse port: %s\n", std::string(val).c_str());
+                                return VIDCAP_INIT_FAIL;
+                        }
+                } else if(key == "help"){
+                        show_help();
+                        return VIDCAP_INIT_NOERR;
+                } else{
+                        log_msg(LOG_LEVEL_FATAL, "Unknown parameter: %s\n", std::string(key).c_str());
+                        return VIDCAP_INIT_FAIL;
+                }
+        }
+
+        return VIDCAP_INIT_OK;
+}
+
+int capture_omt_init(const vidcap_params *params, void **state){
+        auto s = std::make_unique<state_omt_cap>();
+
+        if(auto parse_ret = parse_cfg(*s, vidcap_params_get_fmt(params)); parse_ret != VIDCAP_INIT_OK){
+                return parse_ret;
+        }
+
+        std::string addr = "omt://" + s->sender_addr + ":" + std::to_string(s->port);
+
+        s->omt_h.reset(omt_receive_create(addr.c_str(), static_cast<OMTFrameType>(OMTFrameType_Audio | OMTFrameType_Video),
+                OMTPreferredVideoFormat_UYVY, OMTReceiveFlags_None));
+
+        *state = s.release();
+        return VIDCAP_INIT_OK;
+}
+
+void capture_omt_done(void *state){
+        auto s = static_cast<state_omt_cap *>(state);
+        delete s;
+}
+
+video_frame *capture_omt_grab(void *state, audio_frame **/*audio*/){
+        auto s = static_cast<state_omt_cap *>(state);
+
+        const auto omt_frame = omt_receive(s->omt_h.get(), OMTFrameType_Video, 1000);
+        if(!omt_frame){
+                return nullptr;
+        }
+
+        if(const video_desc incoming_desc = video_desc_from_omt_frame(omt_frame);
+                !s->ug_frame || video_desc_eq(incoming_desc, video_desc_from_frame(s->ug_frame.get())))
+        {
+                s->ug_frame.reset(vf_alloc_desc(incoming_desc));
+        }
+
+        assert(omt_frame->Stride == vc_get_linesize(s->ug_frame->tiles[0].width, s->ug_frame->color_spec));
+        s->ug_frame->tiles[0].data = static_cast<char *>(omt_frame->Data);
+        s->ug_frame->tiles[0].data_len = omt_frame->DataLength;
+
+        return s->ug_frame.get();
+}
+
+constexpr video_capture_info vidcap_omt_info = {
+        capture_omt_probe,
+        capture_omt_init,
+        capture_omt_done,
+        capture_omt_grab,
+        MOD_NAME,
+};
+}
+
+REGISTER_MODULE(omt, &vidcap_omt_info, LIBRARY_CLASS_VIDEO_CAPTURE, VIDEO_CAPTURE_ABI_VERSION);