aja.cpp File Reference

#include "config_msvc.h"
#include "debug.h"
#include <ntv2devicescanner.h>
#include <ajantv2/includes/ntv2utils.h>
#include <ajabase/system/debug.h>
#include <ajatypes.h>
#include <ntv2debug.h>
#include <algorithm>
#include <cassert>
#include <chrono>
#include <cmath>
#include <condition_variable>
#include <cstdint>
#include <cstdio>
#include <cstdlib>
#include <cstring>
#include <functional>
#include <iostream>
#include <memory>
#include <mutex>
#include <queue>
#include <sstream>
#include <stdexcept>
#include <string>
#include <thread>
#include <unordered_map>
#include <utility>
#include <vector>
#include "audio/types.h"
#include "host.h"
#include "lib_common.h"
#include "utils/color_out.h"
#include "video_display.h"
#include "video.h"
#include "aja_common.hpp"

Include dependency graph for aja.cpp:

Go to the source code of this file.

Classes
struct	ultragrid::aja::display
struct	ultragrid::aja::display::configuration
struct	ultragrid::aja::display::desc

Namespaces
namespace	ultragrid
namespace	ultragrid::aja

Macros
#define	BPS   4
#define	CHECK(cmd)
#define	CHECK_EX(cmd, msg, action_failed)
#define	DEFAULT_MAX_FRAME_QUEUE_LEN   1
#define	LINK_SPEC   static
#define	MOD_NAME   "[AJA display] "
#define	NOOP   ((void)0)
#define	SAMPLE_RATE   48000

Functions
LINK_SPEC void	display_aja_done (void *state)
static NTV2VideoFormat	display_aja_get_first_matching_video_format (const NTV2FrameRate inFrameRate, const UWord inHeightLines, const UWord inWidthPixels, const bool inIsInterlaced, const bool inIsLevelB, bool skipQuadFormats)
LINK_SPEC bool	display_aja_get_property (void *state, int property, void *val, size_t *len)
LINK_SPEC struct video_frame *	display_aja_getf (void *state)
LINK_SPEC void *	display_aja_init (struct module *, const char *fmt, unsigned int flags)
static bool	display_aja_is_quad_format (NTV2VideoFormat fmt)
LINK_SPEC void	display_aja_probe (struct device_info **available_cards, int *count, void(**deleter)(void *))
LINK_SPEC void	display_aja_put_audio_frame (void *state, const struct audio_frame *frame)
LINK_SPEC bool	display_aja_putf (void *state, struct video_frame *frame, long long nonblock)
LINK_SPEC bool	display_aja_reconfigure (void *state, struct video_desc desc)
LINK_SPEC bool	display_aja_reconfigure_audio (void *state, int quant_samples, int channels, int sample_rate)
	REGISTER_MODULE (aja, &display_aja_info, LIBRARY_CLASS_VIDEO_DISPLAY, VIDEO_DISPLAY_ABI_VERSION)

Variables
const unordered_map< NTV2Channel, NTV2OutputCrosspointID, hash< int > >	ultragrid::aja::chanToLutSrc
static const struct video_display_info	display_aja_info

Detailed Description

Author

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

Definition in file aja.cpp.

Macro Definition Documentation

BPS

#define BPS   4

The maximum number of bytes of 48KHz audio that can be transferred for two frames. Worst case, assuming 16 channels of audio (max), 4 bytes per sample, and 67 msec per frame (assuming the lowest possible frame rate of 14.98 fps)... 48,000 samples per second requires 6,408 samples x 4 bytes/sample x 16 = 410,112 bytes 402K will suffice, with 1536 bytes to spare

Definition at line 102 of file aja.cpp.

Referenced by display_aja_get_property(), and display_aja_reconfigure_audio().

CHECK

#define CHECK

(

cmd

)

Value:

CHECK_EX(cmd, #cmd " failed", NOOP)

Definition at line 137 of file aja.cpp.

CHECK_EX

#define CHECK_EX	(		cmd,
			msg,
			action_failed )

Value:

        do { bool ret = cmd; if (!ret) {\
        LOG(LOG_LEVEL_WARNING) << MOD_NAME << (msg) << "\n";\
        action_failed;\
}\
} while(0)

Definition at line 131 of file aja.cpp.

#define CHECK_EX(cmd, msg, action_failed) do { bool ret = cmd; if (!ret) {\
        LOG(LOG_LEVEL_WARNING) << MOD_NAME << (msg) << "\n";\
        action_failed;\
}\
} while(0)

Referenced by ultragrid::aja::display::~display(), ultragrid::aja::display::RouteOutputSignal(), ultragrid::aja::display::SetUpAudio(), and ultragrid::aja::display::SetUpVideo().

DEFAULT_MAX_FRAME_QUEUE_LEN

#define DEFAULT_MAX_FRAME_QUEUE_LEN   1

Definition at line 93 of file aja.cpp.

Referenced by ultragrid::aja::display::show_help().

LINK_SPEC

#define LINK_SPEC   static

Definition at line 108 of file aja.cpp.

MOD_NAME

#define MOD_NAME   "[AJA display] "

Definition at line 94 of file aja.cpp.

Referenced by display_aja_init(), display_aja_put_audio_frame(), and display_aja_reconfigure().

NOOP

#define NOOP   ((void)0)

Definition at line 136 of file aja.cpp.

SAMPLE_RATE

#define SAMPLE_RATE   48000

Definition at line 103 of file aja.cpp.

Referenced by display_aja_get_property(), and display_aja_reconfigure_audio().

Function Documentation

display_aja_done()

LINK_SPEC void display_aja_done

(

void *

state

)

Definition at line 1008 of file aja.cpp.

{
        auto *s = static_cast<struct ugaja::display *>(state);
 
        if (s->desc.color_spec != VIDEO_CODEC_NONE) {
                s->join();
                s->desc = {};
        }
 
        delete s;
}

References state, and VIDEO_CODEC_NONE.

display_aja_get_first_matching_video_format()

static NTV2VideoFormat display_aja_get_first_matching_video_format ( const NTV2FrameRate inFrameRate, const UWord inHeightLines, const UWord inWidthPixels, const bool inIsInterlaced, const bool inIsLevelB, bool skipQuadFormats )

static

Definition at line 868 of file aja.cpp.

{
        for (NTV2VideoFormat fmt(NTV2_FORMAT_FIRST_HIGH_DEF_FORMAT); fmt < NTV2_MAX_NUM_VIDEO_FORMATS;  fmt = NTV2VideoFormat(fmt + 1)) {
                if (display_aja_is_quad_format(fmt) && skipQuadFormats) {
                        continue; // skip NTV2_FORMAT_4x formats
                }
                if (inFrameRate == ::GetNTV2FrameRateFromVideoFormat(fmt))
                        if (inHeightLines == ::GetDisplayHeight(fmt))
                                if (inWidthPixels == ::GetDisplayWidth(fmt))
                                        if (inIsInterlaced == !::IsProgressiveTransport(fmt) && !IsPSF(fmt))
                                                if (NTV2_VIDEO_FORMAT_IS_B(fmt) == inIsLevelB)
                                                        return fmt;
        }
        return NTV2_FORMAT_UNKNOWN;
}

References display_aja_is_quad_format(), and fmt.

Referenced by display_aja_reconfigure().

Here is the call graph for this function:

display_aja_get_property()

LINK_SPEC bool display_aja_get_property	(	void *	state,
		int	property,
		void *	val,
		size_t *	len )

Definition at line 1041 of file aja.cpp.

{
        auto *s = static_cast<struct ugaja::display *>(state);
 
        vector<codec_t> codecs(ugaja::codec_map.size());
        int count = 0;
 
        for (auto & c : ugaja::codec_map) {
                if (::NTV2DeviceCanDoFrameBufferFormat(s->mDeviceID, c.first)) {
                        codecs[count++] = c.second;
                }
        }
 
        switch (property) {
                case DISPLAY_PROPERTY_CODECS:
                        if (count * sizeof(codec_t) <= *len) {
                                *len = count * sizeof(codec_t);
                                memcpy(val, codecs.data(), *len);
                        } else {
                                return false;
                        }
                        break;
                case DISPLAY_PROPERTY_AUDIO_FORMAT:
                        {
                                assert(*len >= sizeof(struct audio_desc));
                                auto desc = static_cast<struct audio_desc *>(val);
                                desc->sample_rate = SAMPLE_RATE;
                                desc->ch_count = ::NTV2DeviceGetMaxAudioChannels (s->mDeviceID);
                                desc->codec = AC_PCM;
                                desc->bps = BPS;
                                *len = sizeof *desc;
                        }
                        break;
                case DISPLAY_PROPERTY_VIDEO_MODE:
                        if (*len >= sizeof(int)) {
                                *(int *) val = DISPLAY_PROPERTY_VIDEO_SEPARATE_TILES;
                                *len = sizeof(int);
                        } else {
                                return false;
                        }
                        break;
                default:
                        return false;
        }
        return true;
}

References AC_PCM, BPS, ultragrid::aja::codec_map, codecs, count, desc, DISPLAY_PROPERTY_AUDIO_FORMAT, DISPLAY_PROPERTY_CODECS, DISPLAY_PROPERTY_VIDEO_MODE, DISPLAY_PROPERTY_VIDEO_SEPARATE_TILES, len, property, SAMPLE_RATE, state, and val.

display_aja_getf()

LINK_SPEC struct video_frame * display_aja_getf

(

void *

state

)

Definition at line 1020 of file aja.cpp.

{
        auto *s = static_cast<struct ugaja::display *>(state);
 
        return vf_alloc_desc_data(s->desc);
}

References state, and vf_alloc_desc_data().

Here is the call graph for this function:

display_aja_init()

LINK_SPEC void * display_aja_init	(	struct module *	,
		const char *	fmt,
		unsigned int	flags )

Definition at line 938 of file aja.cpp.

{
        struct ugaja::display::configuration conf;
        auto tmp = static_cast<char *>(alloca(strlen(fmt) + 1));
        strcpy(tmp, fmt);
 
        char *item;
        while ((item = strtok(tmp, ":")) != nullptr) {
                if (strcmp("help", item) == 0) {
                        ugaja::display::show_help();
                        return INIT_NOERR;
                } else if (strstr(item, "buffers=") == item) {
                        conf.bufLen = atoi(item + strlen("buffers="));
                        if (conf.bufLen <= 0) {
                                LOG(LOG_LEVEL_ERROR) << MOD_NAME "Buffers must be positive!\n";
                                return nullptr;
                        }
                } else if (strcmp("clear-routing", item) == 0) {
                        conf.clearRouting = true;
                } else if (strstr(item, "connection=") != nullptr) {
                        string connection = item + strlen("connection=");
                        NTV2OutputDestination dest = NTV2OutputDestination();
                        while (dest != NTV2_OUTPUTDESTINATION_INVALID) {
                                if (NTV2OutputDestinationToString(dest, true) == connection) {
                                        conf.outputDestination = dest;
                                        break;
                                }
                                // should be this, but GetNTV2InputSourceForIndex knows only SDIs
                                //source = ::GetNTV2InputSourceForIndex(::GetIndexForNTV2InputSource(source) + 1);
                                dest = (NTV2OutputDestination) ((int) dest + 1);
                        }
                        if (dest == NTV2_OUTPUTDESTINATION_INVALID) {
                                LOG(LOG_LEVEL_ERROR) << MOD_NAME "Unknown destination: " << connection << "!\n";
                                return nullptr;
                        }
                } else if (strstr(item, "channel=") != nullptr) {
                        conf.outputChannel = (NTV2Channel) (atoi(item + strlen("channel=")) - 1);
                } else if (strstr(item, "device=") != nullptr) {
                        conf.deviceId = item + strlen("device=");
                } else if (strstr(item, "multi-channel") != nullptr) {
                        conf.doMultiChannel = strstr(item, "no-") == nullptr;
                } else if (strstr(item, "no-setup") == item) {
                        conf.setupRoute = false;
                        if (strcmp(item, "no-setup") == 0) {
                                conf.setupAll = false;
                        }
                } else if (strstr(item, "novsync") == item) {
                        conf.novsync = true;
                } else if (strcasecmp(item, "RGB") == 0 || strcasecmp(item, "YUV") == 0) {
                        conf.forceOutputColorSpace = strcasecmp(item, "RGB") == 0 ? RGB : UYVY;
                } else if (strcasecmp(item, "smpte-range") == 0 || strcasecmp(item, "full-range") == 0) {
                        conf.smpteRange = strcasecmp(item, "smpte-range") == 0;
                } else {
                        LOG(LOG_LEVEL_ERROR) << MOD_NAME "Unknown option: " << item << "\n";
                        return nullptr;
                }
                tmp = nullptr;
        }
 
        try {
                conf.withAudio = (flags & DISPLAY_FLAG_AUDIO_ANY) != 0u;
                auto *s = new ugaja::display(conf);
                return s;
        } catch (runtime_error &e) {
                LOG(LOG_LEVEL_ERROR) << MOD_NAME << e.what() << "\n";
        }
 
        return nullptr;
}

References DISPLAY_FLAG_AUDIO_ANY, flags, fmt, INIT_NOERR, LOG, LOG_LEVEL_ERROR, MOD_NAME, RGB, and UYVY.

display_aja_is_quad_format()

static bool display_aja_is_quad_format ( NTV2VideoFormat fmt )

static

format is a quad-link format

Definition at line 855 of file aja.cpp.

                                                            {
        if ((fmt >= NTV2_FORMAT_FIRST_4K_DEF_FORMAT && fmt < NTV2_FORMAT_END_4K_DEF_FORMATS)
                        || (fmt >= NTV2_FORMAT_FIRST_4K_DEF_FORMAT2 && fmt < NTV2_FORMAT_END_4K_DEF_FORMATS2)
                        || (fmt >= NTV2_FORMAT_FIRST_UHD2_DEF_FORMAT && fmt < NTV2_FORMAT_END_UHD2_DEF_FORMATS)
                        || (fmt >= NTV2_FORMAT_FIRST_UHD2_FULL_DEF_FORMAT && fmt < NTV2_FORMAT_END_UHD2_FULL_DEF_FORMATS)) {
                return true;
        }
        return false;
}

References fmt.

Referenced by display_aja_get_first_matching_video_format().

display_aja_probe()

LINK_SPEC void display_aja_probe	(	struct device_info **	available_cards,
		int *	count,
		void(**	deleter )(void *) )

Definition at line 831 of file aja.cpp.

{
        *deleter = free;
        CNTV2DeviceScanner      deviceScanner;
        *count = deviceScanner.GetNumDevices();
        *available_cards = static_cast<struct device_info *>(calloc(deviceScanner.GetNumDevices(), sizeof(struct device_info)));
        for (unsigned int i = 0; i < deviceScanner.GetNumDevices (); i++) {
                snprintf((*available_cards)[i].dev, sizeof (*available_cards)[i].dev, ":device=%d", i);
                snprintf((*available_cards)[i].extra, sizeof (*available_cards)[i].extra, "\"embeddedAudioAvailable\":\"t\"");
                CNTV2Card device;
                if (!CNTV2DeviceScanner::GetDeviceAtIndex(i, device)) {
                        MSG(WARNING, "Cannot get device at index #%u!\n", i);
                        continue;
                }
                strncpy((*available_cards)[i].name,
                        device.GetDisplayName().c_str(),
                        sizeof(*available_cards)[0].name - 1);
                (*available_cards)[i].repeatable = false;
        }
}

References count, deleter, MSG, and name.

display_aja_put_audio_frame()

LINK_SPEC void display_aja_put_audio_frame	(	void *	state,
		const struct audio_frame *	frame )

Definition at line 1088 of file aja.cpp.

{
        auto *s = static_cast<struct ugaja::display *>(state);
 
        lock_guard<mutex> lk(s->mAudioLock);
        int len = NTV2_AUDIOSIZE_MAX - s->mAudioLen;
        if (frame->data_len > len) {
                LOG(LOG_LEVEL_WARNING) << MOD_NAME << "Audio buffer overrun!\n";
        } else {
                len = frame->data_len;
        }
        memcpy(s->mAudioBuffer.get() + s->mAudioLen, frame->data, len);
        s->mAudioLen += len;
}

References frame, len, LOG, LOG_LEVEL_WARNING, MOD_NAME, NTV2_AUDIOSIZE_MAX, and state.

display_aja_putf()

LINK_SPEC bool display_aja_putf	(	void *	state,
		struct video_frame *	frame,
		long long	nonblock )

Definition at line 1027 of file aja.cpp.

{
        auto *s = static_cast<struct ugaja::display *>(state);
 
        if (frame && frame->color_spec == R12L) {
                char *tmp = (char *) malloc(frame->tiles[0].data_len);
                vc_copylineR12LtoR12A((unsigned char *) tmp, (unsigned char *) frame->tiles[0].data, frame->tiles[0].data_len, 0, 0, 0);
                free(frame->tiles[0].data);
                frame->tiles[0].data = tmp;
        }
 
        return s->Putf(frame, nonblock);
}

References video_frame::color_spec, tile::data, tile::data_len, frame, nonblock, ultragrid::aja::display::Putf(), R12L, state, video_frame::tiles, and vc_copylineR12LtoR12A().

Here is the call graph for this function:

display_aja_reconfigure()

LINK_SPEC bool display_aja_reconfigure	(	void *	state,
		struct video_desc	desc )

Definition at line 885 of file aja.cpp.

{
        auto *s = static_cast<struct ugaja::display *>(state);
        if (s->desc.color_spec != VIDEO_CODEC_NONE) {
                s->join();
                s->desc = {};
        }
 
        if (desc.tile_count != 1 && desc.tile_count != 4) {
                LOG(LOG_LEVEL_ERROR) << MOD_NAME "Unsupported tile count: " << desc.tile_count << "\n";
                return false;
        }
 
        bool interlaced = desc.interlacing == INTERLACED_MERGED;
        // first try to skip quad split formats (aka quad link)
        s->mVideoFormat = display_aja_get_first_matching_video_format(ugaja::display::getFrameRate(desc.fps),
                        desc.height, desc.width, interlaced, false, false);
        // if not found or supported, include quad formats
        if (s->mVideoFormat == NTV2_FORMAT_UNKNOWN || !::NTV2DeviceCanDoVideoFormat (s->mDeviceID, s->mVideoFormat)) {
                s->mVideoFormat = display_aja_get_first_matching_video_format(ugaja::display::getFrameRate(desc.fps),
                                desc.height, desc.width, interlaced, false, true);
        }
        if (s->mVideoFormat == NTV2_FORMAT_UNKNOWN) {
                LOG(LOG_LEVEL_ERROR) << MOD_NAME "Unsupported resolution"
#ifndef _MSC_VER
                        ": " << desc
#endif
                        << "\n";
                return false;
        }
        s->mPixelFormat = NTV2_FBF_INVALID;
        for (auto & c : ugaja::codec_map) {
                if (c.second == desc.color_spec) {
                        s->mPixelFormat = c.first;
                }
        }
        assert(s->mPixelFormat != NTV2_FBF_INVALID);
 
        // deinit?
        s->desc = desc;
        try {
                s->Init();
        } catch (runtime_error &e) {
                LOG(LOG_LEVEL_ERROR) << MOD_NAME "Reconfiguration failed: " << e.what() << "\n";
                s->desc = {};
                return false;
        }
 
        s->worker = thread(&ugaja::display::process_frames, s);
 
        return true;
}

References ultragrid::aja::codec_map, video_desc::color_spec, desc, display_aja_get_first_matching_video_format(), video_desc::fps, video_desc::height, INTERLACED_MERGED, video_desc::interlacing, LOG, LOG_LEVEL_ERROR, MOD_NAME, state, video_desc::tile_count, VIDEO_CODEC_NONE, and video_desc::width.

Here is the call graph for this function:

display_aja_reconfigure_audio()

LINK_SPEC bool display_aja_reconfigure_audio	(	void *	state,
		int	quant_samples,
		int	channels,
		int	sample_rate )

Definition at line 1103 of file aja.cpp.

{
        auto *s = static_cast<struct ugaja::display *>(state);
        assert(quant_samples == BPS * 8 && sample_rate == SAMPLE_RATE && ::NTV2DeviceGetMaxAudioChannels (s->mDeviceID) == channels);
 
        AJAStatus status = s->SetUpAudio();
        if (AJA_FAILURE(status)) {
                ostringstream oss;
                oss << "Unable to initialize audio: " << AJAStatusToString(status);
                return false;
        }
 
        return true;
}

References BPS, channels, quant_samples, SAMPLE_RATE, sample_rate, and state.

REGISTER_MODULE()

REGISTER_MODULE	(	aja	,
		&	display_aja_info,
		LIBRARY_CLASS_VIDEO_DISPLAY	,
		VIDEO_DISPLAY_ABI_VERSION	)

Variable Documentation

display_aja_info

const struct video_display_info display_aja_info

static

Initial value:

= {
        display_aja_probe,
        display_aja_init,
        NULL, 
        display_aja_done,
        display_aja_getf,
        display_aja_putf,
        display_aja_reconfigure,
        display_aja_get_property,
        display_aja_put_audio_frame,
        display_aja_reconfigure_audio,
        DISPLAY_NO_GENERIC_FPS_INDICATOR,
}

Definition at line 1120 of file aja.cpp.

                                                          {
        display_aja_probe,
        display_aja_init,
        NULL, // _run
        display_aja_done,
        display_aja_getf,
        display_aja_putf,
        display_aja_reconfigure,
        display_aja_get_property,
        display_aja_put_audio_frame,
        display_aja_reconfigure_audio,
        DISPLAY_NO_GENERIC_FPS_INDICATOR,
};