multiplier.cpp File Reference

#include "config.h"
#include "config_unix.h"
#include "config_win32.h"
#include "debug.h"
#include "host.h"
#include "lib_common.h"
#include "video.h"
#include "video_display.h"
#include "utils/string_view_utils.hpp"
#include <condition_variable>
#include <vector>
#include <memory>
#include <mutex>
#include <queue>
#include <thread>

Include dependency graph for multiplier.cpp:

Go to the source code of this file.

Classes
struct	state_multiplier

Functions
static void	check_reconf (struct state_multiplier *s, struct video_desc *current_desc, struct video_desc desc)
static void	display_multiplier_done (void *state)
static bool	display_multiplier_get_property (void *state, int property, void *val, size_t *len)
static struct video_frame *	display_multiplier_getf (void *state)
static void *	display_multiplier_init (struct module *parent, const char *fmt, unsigned int flags)
static void	display_multiplier_probe (struct device_info **available_cards, int *count, void(**deleter)(void *))
static void	display_multiplier_put_audio_frame (void *state, const struct audio_frame *frame)
static bool	display_multiplier_putf (void *state, struct video_frame *frame, long long flags)
static bool	display_multiplier_reconfigure (void *state, struct video_desc desc)
static bool	display_multiplier_reconfigure_audio (void *state, int quant_samples, int channels, int sample_rate)
static void	display_multiplier_run (void *state)
static void	display_multiplier_worker (void *state)
	REGISTER_MODULE (multiplier, &display_multiplier_info, LIBRARY_CLASS_VIDEO_DISPLAY, VIDEO_DISPLAY_ABI_VERSION)
static void	show_help ()

Variables
static const struct video_display_info	display_multiplier_info
static constexpr unsigned int	IN_QUEUE_MAX_BUFFER_LEN = 5
static constexpr const char *	MOD_NAME = "[multiplier] "
static constexpr int	SKIP_FIRST_N_FRAMES_IN_STREAM = 5

Detailed Description

Author

Martin Pulec pulec.nosp@m.@ces.nosp@m.net.c.nosp@m.z

Martin Piatka piatk.nosp@m.a@ce.nosp@m.snet..nosp@m.cz

Definition in file multiplier.cpp.

Function Documentation

check_reconf()

static void check_reconf ( struct state_multiplier * s, struct video_desc * current_desc, struct video_desc desc )

static

Definition at line 127 of file multiplier.cpp.

{
        if (video_desc_eq(desc, *current_desc)) {
                return;
        }
        *current_desc = desc;
        fprintf(stderr, "RECONFIGURED\n");
        for (auto &disp : s->displays) {
                display_reconfigure(disp.get(), desc, VIDEO_NORMAL);
        }
}

References desc, display_reconfigure(), state_multiplier::displays, video_desc_eq(), and VIDEO_NORMAL.

Referenced by display_multiplier_worker().

Here is the call graph for this function:

display_multiplier_done()

static void display_multiplier_done ( void * state )

static

Definition at line 209 of file multiplier.cpp.

{
        auto *s = (state_multiplier *) state;
        delete s;
}

References state.

display_multiplier_get_property()

static bool display_multiplier_get_property ( void * state, int property, void * val, size_t * len )

static

Definition at line 246 of file multiplier.cpp.

{
        auto *s = (state_multiplier *) state;
 
        //TODO Find common properties, for now just return properties of the first display
        return display_ctl_property(s->displays[0].get(), property, val, len);
}

References display_ctl_property(), len, property, state, and val.

Here is the call graph for this function:

display_multiplier_getf()

static struct video_frame * display_multiplier_getf ( void * state )

static

Definition at line 215 of file multiplier.cpp.

{
        auto *s = (state_multiplier *) state;
 
        return vf_alloc_desc_data(s->desc);
}

References state, and vf_alloc_desc_data().

Here is the call graph for this function:

display_multiplier_init()

static void * display_multiplier_init ( struct module * parent, const char * fmt, unsigned int flags )

static

Definition at line 88 of file multiplier.cpp.

{
        auto s = std::make_unique<state_multiplier>();
 
        if(!fmt || strlen(fmt) == 0){
                show_help();
                return INIT_NOERR;
        }
 
        std::string_view fmt_sv = fmt;
 
        if (fmt_sv == "help") { 
                show_help();
                return INIT_NOERR;
        }
 
        s->parent = parent;
 
        for(auto tok = tokenize(fmt_sv, '#'); !tok.empty(); tok = tokenize(fmt_sv, '#')){
                LOG(LOG_LEVEL_VERBOSE) << MOD_NAME << "Initializing display " << tok << "\n";
                auto display = std::string(tokenize(tok, ':'));
                auto cfg = std::string(tok);
 
                struct display *d_ptr;
                if (initialize_video_display(parent, display.c_str(), cfg.c_str(), flags, NULL, &d_ptr) != 0) {
                        LOG(LOG_LEVEL_FATAL) << "[multiplier] Unable to initialize a display " << display << "!\n";
                        return nullptr;
                }
                unique_disp disp(d_ptr);
                if (display_needs_mainloop(disp.get()) && !s->displays.empty()) {
                        LOG(LOG_LEVEL_ERROR) << "[multiplier] Display " << display << " needs mainloop and should be given first!\n";
                }
 
                s->displays.push_back(std::move(disp));
        }
 
        return s.release();
}

References display_needs_mainloop(), flags, fmt, INIT_NOERR, initialize_video_display(), LOG, LOG_LEVEL_ERROR, LOG_LEVEL_FATAL, LOG_LEVEL_VERBOSE, MOD_NAME, parent, show_help(), and tokenize().

Here is the call graph for this function:

display_multiplier_probe()

static void display_multiplier_probe ( struct device_info ** available_cards, int * count, void(** deleter )(void *) )

static

Definition at line 282 of file multiplier.cpp.

                                                                                                                 {
        UNUSED(deleter);
        *available_cards = nullptr;
        *count = 0;
}

References count, deleter, and UNUSED.

display_multiplier_put_audio_frame()

static void display_multiplier_put_audio_frame ( void * state, const struct audio_frame * frame )

static

Definition at line 267 of file multiplier.cpp.

{
        auto *s = static_cast<struct state_multiplier*>(state);
 
        display_put_audio_frame(s->displays.at(0).get(), frame);
}

References display_put_audio_frame(), frame, and state.

Here is the call graph for this function:

display_multiplier_putf()

static bool display_multiplier_putf ( void * state, struct video_frame * frame, long long flags )

static

Definition at line 222 of file multiplier.cpp.

{
        auto *s = (state_multiplier *) state;
 
        if (flags == PUTF_DISCARD) {
                vf_free(frame);
        } else {
                unique_lock<mutex> lg(s->lock);
                if (s->incoming_queue.size() >= IN_QUEUE_MAX_BUFFER_LEN) {
                        fprintf(stderr, "Multiplier: queue full!\n");
                }
                if (flags != PUTF_BLOCKING && s->incoming_queue.size() >= IN_QUEUE_MAX_BUFFER_LEN) {
                        vf_free(frame);
                        return false;
                }
                s->in_queue_decremented_cv.wait(lg, [s]{return s->incoming_queue.size() < IN_QUEUE_MAX_BUFFER_LEN;});
                s->incoming_queue.push(frame);
                lg.unlock();
                s->cv.notify_one();
        }
 
        return true;
}

References flags, frame, IN_QUEUE_MAX_BUFFER_LEN, PUTF_BLOCKING, PUTF_DISCARD, state, and vf_free().

Here is the call graph for this function:

display_multiplier_reconfigure()

static bool display_multiplier_reconfigure ( void * state, struct video_desc desc )

static

Definition at line 254 of file multiplier.cpp.

{
        auto *s = (state_multiplier *) state;
 
        s->desc = desc;
 
        for (auto &disp : s->displays) {
                display_reconfigure(disp.get(), desc, VIDEO_NORMAL);
        }
 
        return true;
}

References desc, display_reconfigure(), state, and VIDEO_NORMAL.

Here is the call graph for this function:

display_multiplier_reconfigure_audio()

static bool display_multiplier_reconfigure_audio ( void * state, int quant_samples, int channels, int sample_rate )

static

Definition at line 274 of file multiplier.cpp.

{
        auto *s = static_cast<struct state_multiplier *>(state);
 
        return display_reconfigure_audio(s->displays.at(0).get(), quant_samples, channels, sample_rate);
}

References channels, display_reconfigure_audio(), quant_samples, sample_rate, and state.

Here is the call graph for this function:

display_multiplier_run()

static void display_multiplier_run ( void * state )

static

Multiplier main loop

Runs threads for all slave displays except the first one and an additional one for this display. For the first display given on command-line it then switches to its run-loop. This allows a flawless run on macOS where a GUI worker (GL/SDL) needs to be run in the main thread to work properly.

Definition at line 189 of file multiplier.cpp.

{
        auto *s = (state_multiplier *) state; 
 
        assert(!s->displays.empty());
 
        for (size_t i = 1; i < s->displays.size(); i++) {
                display_run_new_thread(s->displays[i].get());
        }
 
        s->worker_thread = thread(display_multiplier_worker, state);
 
        display_run_mainloop(s->displays[0].get());
 
        s->worker_thread.join();
        for (size_t i = 1; i < s->displays.size(); i++) {
                display_join(s->displays[i].get());
        }
}

References display_join(), display_multiplier_worker(), display_run_mainloop(), display_run_new_thread(), and state.

Here is the call graph for this function:

display_multiplier_worker()

static void display_multiplier_worker ( void * state )

static

Definition at line 140 of file multiplier.cpp.

{
        auto *s = (struct state_multiplier *)state;
        int skipped = 0;
        struct video_desc display_desc{};
 
        while (1) {
                struct video_frame *frame;
                {
                        unique_lock<mutex> lg(s->lock);
                        s->cv.wait(lg, [s]{return s->incoming_queue.size() > 0;});
                        frame = s->incoming_queue.front();
                        s->incoming_queue.pop();
                        s->in_queue_decremented_cv.notify_one();
                }
 
                if (!frame) {
                        for (auto& disp : s->displays) {
                                display_put_frame(disp.get(), NULL, PUTF_BLOCKING);
                        }
                        break;
                }
 
                if (skipped < SKIP_FIRST_N_FRAMES_IN_STREAM){
                        skipped++;
                        vf_free(frame);
                        continue;
                }
 
                check_reconf(s, &display_desc, video_desc_from_frame(frame));
 
                for (auto& disp : s->displays) {
                        struct video_frame *real_display_frame = display_get_frame(disp.get());
                        memcpy(real_display_frame->tiles[0].data, frame->tiles[0].data, frame->tiles[0].data_len);
                        display_put_frame(disp.get(), real_display_frame, PUTF_BLOCKING);
                }
 
                vf_free(frame);
        }
}

References check_reconf(), tile::data, tile::data_len, display_get_frame(), display_put_frame(), frame, PUTF_BLOCKING, SKIP_FIRST_N_FRAMES_IN_STREAM, state, video_frame::tiles, vf_free(), and video_desc_from_frame().

Referenced by display_multiplier_run().

Here is the call graph for this function:

REGISTER_MODULE()

REGISTER_MODULE	(	multiplier	,
		&	display_multiplier_info,
		LIBRARY_CLASS_VIDEO_DISPLAY	,
		VIDEO_DISPLAY_ABI_VERSION	)

show_help()

static void show_help ( void )

static

Definition at line 82 of file multiplier.cpp.

                       {
        printf("Multiplier display\n");
        printf("Usage:\n");
        printf("\t-d multiplier:<display1>[:<display_config1>][#<display2>[:<display_config2>]]...\n");
}

Referenced by display_multiplier_init().

Variable Documentation

display_multiplier_info

const struct video_display_info display_multiplier_info

static

Initial value:

= {
        display_multiplier_probe,
        display_multiplier_init,
        display_multiplier_run,
        display_multiplier_done,
        display_multiplier_getf,
        display_multiplier_putf,
        display_multiplier_reconfigure,
        display_multiplier_get_property,
        display_multiplier_put_audio_frame,
        display_multiplier_reconfigure_audio,
        DISPLAY_NO_GENERIC_FPS_INDICATOR,
}

Definition at line 288 of file multiplier.cpp.

                                                                 {
        display_multiplier_probe,
        display_multiplier_init,
        display_multiplier_run,
        display_multiplier_done,
        display_multiplier_getf,
        display_multiplier_putf,
        display_multiplier_reconfigure,
        display_multiplier_get_property,
        display_multiplier_put_audio_frame,
        display_multiplier_reconfigure_audio,
        DISPLAY_NO_GENERIC_FPS_INDICATOR,
};

IN_QUEUE_MAX_BUFFER_LEN

unsigned int IN_QUEUE_MAX_BUFFER_LEN = 5

staticconstexpr

Definition at line 58 of file multiplier.cpp.

Referenced by display_multiplier_putf().

MOD_NAME

const char* MOD_NAME = "[multiplier] "

staticconstexpr

Definition at line 59 of file multiplier.cpp.

Referenced by display_multiplier_init().

SKIP_FIRST_N_FRAMES_IN_STREAM

int SKIP_FIRST_N_FRAMES_IN_STREAM = 5

staticconstexpr

Definition at line 60 of file multiplier.cpp.

Referenced by display_multiplier_worker().