sdi.cpp File Reference

#include "audio/audio_capture.h"
#include "audio/capture/sdi.h"
#include "audio/types.h"
#include "debug.h"
#include "host.h"
#include "lib_common.h"
#include "types.h"
#include <condition_variable>
#include <chrono>
#include <mutex>
#include <string>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

Include dependency graph for sdi.cpp:

Go to the source code of this file.

Classes
struct	state_sdi_capture

Macros
#define	DEFAULT_BUF_SIZE_MS   100L
#define	FRAME_CAPTURE   1
#define	FRAME_NETWORK   0
#define	MOD_NAME   "[acap.] "

Functions
static void	audio_cap_sdi_done (void *state)
static void	audio_cap_sdi_help (const char *driver_name)
static void *	audio_cap_sdi_init (struct module *parent, const char *cfg)
static void	audio_cap_sdi_probe_aesebu (struct device_info **available_devices, int *count, void(**deleter)(void *))
static void	audio_cap_sdi_probe_analog (struct device_info **available_devices, int *count, void(**deleter)(void *))
static void	audio_cap_sdi_probe_common (struct device_info **available_devices, int *count, const char *dev, const char *name)
static void	audio_cap_sdi_probe_embedded (struct device_info **available_devices, int *count, void(**deleter)(void *))
static struct audio_frame *	audio_cap_sdi_read (void *state)
	REGISTER_MODULE (AESEBU, &acap_sdi_info_aesebu, LIBRARY_CLASS_AUDIO_CAPTURE, AUDIO_CAPTURE_ABI_VERSION)
	REGISTER_MODULE (analog, &acap_sdi_info_analog, LIBRARY_CLASS_AUDIO_CAPTURE, AUDIO_CAPTURE_ABI_VERSION)
	REGISTER_MODULE (embedded, &acap_sdi_info_embedded, LIBRARY_CLASS_AUDIO_CAPTURE, AUDIO_CAPTURE_ABI_VERSION)
void	sdi_capture_new_incoming_frame (void *state, struct audio_frame *frame)

Variables
static const struct audio_capture_info	acap_sdi_info_aesebu
static const struct audio_capture_info	acap_sdi_info_analog
static const struct audio_capture_info	acap_sdi_info_embedded

Detailed Description

Author

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

Definition in file sdi.cpp.

Macro Definition Documentation

DEFAULT_BUF_SIZE_MS

#define DEFAULT_BUF_SIZE_MS   100L

Definition at line 60 of file sdi.cpp.

FRAME_CAPTURE

#define FRAME_CAPTURE   1

Definition at line 63 of file sdi.cpp.

Referenced by audio_cap_sdi_read(), and sdi_capture_new_incoming_frame().

FRAME_NETWORK

#define FRAME_NETWORK   0

Definition at line 62 of file sdi.cpp.

Referenced by audio_cap_sdi_read().

MOD_NAME

#define MOD_NAME   "[acap.] "

Definition at line 64 of file sdi.cpp.

Referenced by sdi_capture_new_incoming_frame().

Function Documentation

audio_cap_sdi_done()

static void audio_cap_sdi_done ( void * state )

static

Definition at line 153 of file sdi.cpp.

{
        struct state_sdi_capture *s;
 
        s = (struct state_sdi_capture *) state;
        for(int i = 0; i < 2; ++i) {
                free(s->audio_frame[i].data);
        }
}

References state_sdi_capture::audio_frame, audio_frame::data, and state.

audio_cap_sdi_help()

static void audio_cap_sdi_help ( const char * driver_name )

static

Definition at line 163 of file sdi.cpp.

{
        if(strcmp(driver_name, "embedded") == 0) {
                printf("\tembedded[:<index>] : SDI audio (if available)\n");
        } else if(strcmp(driver_name, "AESEBU") == 0) {
                printf("\tAESEBU[:<index>] : separately connected AES/EBU to a grabbing card (if available)\n");
        } else if(strcmp(driver_name, "analog") == 0) {
                printf("\tanalog[:<index>] : analog input of grabbing card (if available)\n");
        }
}

Referenced by audio_cap_sdi_init().

audio_cap_sdi_init()

static void * audio_cap_sdi_init ( struct module * parent, const char * cfg )

static

Definition at line 115 of file sdi.cpp.

{
        UNUSED(parent);
        if (strcmp(cfg, "help") == 0) {
                printf("Available vidcap audio devices:\n");
                audio_cap_sdi_help("embedded");
                audio_cap_sdi_help("AESEBU");
                audio_cap_sdi_help("analog");
                printf("\t\twhere <index> is index of vidcap device "
                                "to be taken audio from.\n");
                return INIT_NOERR;
        }
        
        return new state_sdi_capture();
}

References audio_cap_sdi_help(), INIT_NOERR, parent, and UNUSED.

Here is the call graph for this function:

audio_cap_sdi_probe_aesebu()

static void audio_cap_sdi_probe_aesebu ( struct device_info ** available_devices, int * count, void(** deleter )(void *) )

static

Definition at line 103 of file sdi.cpp.

{
        *deleter = free;
        audio_cap_sdi_probe_common(available_devices, count, "", "Digital AES/EBU audio");
}

References audio_cap_sdi_probe_common(), count, and deleter.

Here is the call graph for this function:

audio_cap_sdi_probe_analog()

static void audio_cap_sdi_probe_analog ( struct device_info ** available_devices, int * count, void(** deleter )(void *) )

static

Definition at line 109 of file sdi.cpp.

{
        *deleter = free;
        audio_cap_sdi_probe_common(available_devices, count, "", "Analog audio through capture card");
}

References audio_cap_sdi_probe_common(), count, and deleter.

Here is the call graph for this function:

audio_cap_sdi_probe_common()

static void audio_cap_sdi_probe_common ( struct device_info ** available_devices, int * count, const char * dev, const char * name )

static

Definition at line 87 of file sdi.cpp.

{
        *available_devices = (struct device_info *) calloc(1, sizeof(struct device_info));
        strncpy((*available_devices)[0].dev, dev, sizeof (*available_devices)[0].dev - 1);
        strncpy((*available_devices)[0].name, name, sizeof (*available_devices)[0].name - 1);
        snprintf((*available_devices)[0].extra, sizeof (*available_devices)[0].extra, "\"isEmbeddedAudio\":\"t\"");
        *count = 1;
}

References count, device_info::dev, device_info::extra, and name.

Referenced by audio_cap_sdi_probe_aesebu(), audio_cap_sdi_probe_analog(), and audio_cap_sdi_probe_embedded().

audio_cap_sdi_probe_embedded()

static void audio_cap_sdi_probe_embedded ( struct device_info ** available_devices, int * count, void(** deleter )(void *) )

static

Definition at line 97 of file sdi.cpp.

{
        *deleter = free;
        audio_cap_sdi_probe_common(available_devices, count, "", "Embedded SDI/HDMI audio");
}

References audio_cap_sdi_probe_common(), count, and deleter.

Here is the call graph for this function:

audio_cap_sdi_read()

static struct audio_frame * audio_cap_sdi_read ( void * state )

static

Definition at line 131 of file sdi.cpp.

{
        struct state_sdi_capture *s = (struct state_sdi_capture *) state;
 
        unique_lock<mutex> lk(s->lock);
        bool rc = s->audio_frame_ready_cv.wait_for(lk, milliseconds(100), [s]{return s->audio_frame[FRAME_CAPTURE].data_len > 0;});
 
        if (rc == false) {
                return NULL;
        }
 
        // FRAME_NETWORK has been "consumed"
        s->audio_frame[FRAME_NETWORK].data_len = 0;
        // swap
        struct audio_frame tmp;
        memcpy(&tmp, &s->audio_frame[FRAME_CAPTURE], sizeof(struct audio_frame));
        memcpy(&s->audio_frame[FRAME_CAPTURE], &s->audio_frame[FRAME_NETWORK], sizeof(struct audio_frame));
        memcpy(&s->audio_frame[FRAME_NETWORK], &tmp, sizeof(struct audio_frame));
 
        return &s->audio_frame[FRAME_NETWORK];
}

References state_sdi_capture::audio_frame, state_sdi_capture::audio_frame_ready_cv, audio_frame::data_len, FRAME_CAPTURE, FRAME_NETWORK, state_sdi_capture::lock, and state.

REGISTER_MODULE() [1/3]

REGISTER_MODULE	(	AESEBU	,
		&	acap_sdi_info_aesebu,
		LIBRARY_CLASS_AUDIO_CAPTURE	,
		AUDIO_CAPTURE_ABI_VERSION	)

REGISTER_MODULE() [2/3]

REGISTER_MODULE	(	analog	,
		&	acap_sdi_info_analog,
		LIBRARY_CLASS_AUDIO_CAPTURE	,
		AUDIO_CAPTURE_ABI_VERSION	)

REGISTER_MODULE() [3/3]

REGISTER_MODULE	(	embedded	,
		&	acap_sdi_info_embedded,
		LIBRARY_CLASS_AUDIO_CAPTURE	,
		AUDIO_CAPTURE_ABI_VERSION	)

sdi_capture_new_incoming_frame()

void sdi_capture_new_incoming_frame	(	void *	state,
		struct audio_frame *	frame )

Definition at line 174 of file sdi.cpp.

{
        struct state_sdi_capture *s;
        
        s = (struct state_sdi_capture *) state;
 
        unique_lock<mutex> lk(s->lock);
 
        if (s->audio_frame[FRAME_CAPTURE].bps != frame->bps ||
                        s->audio_frame[FRAME_CAPTURE].ch_count != frame->ch_count ||
                        s->audio_frame[FRAME_CAPTURE].sample_rate != frame->sample_rate) {
                s->audio_frame[FRAME_CAPTURE].bps = frame->bps;
                s->audio_frame[FRAME_CAPTURE].ch_count = frame->ch_count;
                s->audio_frame[FRAME_CAPTURE].sample_rate = frame->sample_rate;
                s->audio_frame[FRAME_CAPTURE].data_len = 0;
                s->audio_frame[FRAME_CAPTURE].max_size = frame->bps * frame->ch_count * frame->sample_rate / 1000L * s->buf_size_ms;
                s->audio_frame[FRAME_CAPTURE].data = static_cast<char *>(malloc(s->audio_frame[FRAME_CAPTURE].max_size));
        }
 
        int len = frame->data_len;
        if (len + s->audio_frame[FRAME_CAPTURE].data_len > s->audio_frame[FRAME_CAPTURE].max_size) {
                LOG(LOG_LEVEL_WARNING) << MOD_NAME << "Maximal audio buffer length " << s->buf_size_ms << " ms exceeded! Dropping "
                        << len - (s->audio_frame[FRAME_CAPTURE].max_size - s->audio_frame[FRAME_CAPTURE].data_len) << " samples.\n";
                len = s->audio_frame[FRAME_CAPTURE].max_size - s->audio_frame[FRAME_CAPTURE].data_len;
        }
        memcpy(s->audio_frame[FRAME_CAPTURE].data + s->audio_frame[FRAME_CAPTURE].data_len,
                        frame->data, len);
        if (s->audio_frame[FRAME_CAPTURE].data_len == 0 && (frame->flags & TIMESTAMP_VALID) != 0) {
                s->audio_frame[FRAME_CAPTURE].timestamp = frame->timestamp;
                s->audio_frame[FRAME_CAPTURE].flags |= TIMESTAMP_VALID;
        }
        s->audio_frame[FRAME_CAPTURE].data_len += len;
 
        lk.unlock();
        s->audio_frame_ready_cv.notify_one();
}

References state_sdi_capture::audio_frame, state_sdi_capture::audio_frame_ready_cv, audio_frame::bps, state_sdi_capture::buf_size_ms, audio_frame::ch_count, audio_frame::data, audio_frame::data_len, audio_frame::flags, video_frame::flags, frame, FRAME_CAPTURE, len, state_sdi_capture::lock, LOG, LOG_LEVEL_WARNING, audio_frame::max_size, MOD_NAME, audio_frame::sample_rate, state, audio_frame::timestamp, video_frame::timestamp, and TIMESTAMP_VALID.

Referenced by audio_sdi_send().

Variable Documentation

acap_sdi_info_aesebu

const struct audio_capture_info acap_sdi_info_aesebu

static

Initial value:

= {
        audio_cap_sdi_probe_aesebu,
        audio_cap_sdi_init,
        audio_cap_sdi_read,
        audio_cap_sdi_done
}

Definition at line 218 of file sdi.cpp.

                                                              {
        audio_cap_sdi_probe_aesebu,
        audio_cap_sdi_init,
        audio_cap_sdi_read,
        audio_cap_sdi_done
};

acap_sdi_info_analog

const struct audio_capture_info acap_sdi_info_analog

static

Initial value:

= {
        audio_cap_sdi_probe_analog,
        audio_cap_sdi_init,
        audio_cap_sdi_read,
        audio_cap_sdi_done
}

Definition at line 225 of file sdi.cpp.

                                                              {
        audio_cap_sdi_probe_analog,
        audio_cap_sdi_init,
        audio_cap_sdi_read,
        audio_cap_sdi_done
};

acap_sdi_info_embedded

const struct audio_capture_info acap_sdi_info_embedded

static

Initial value:

= {
        audio_cap_sdi_probe_embedded,
        audio_cap_sdi_init,
        audio_cap_sdi_read,
        audio_cap_sdi_done
}

Definition at line 211 of file sdi.cpp.

                                                                {
        audio_cap_sdi_probe_embedded,
        audio_cap_sdi_init,
        audio_cap_sdi_read,
        audio_cap_sdi_done
};