mixer.cpp File Reference

#include "audio/audio_capture.h"
#include "audio/audio_playback.h"
#include "audio/codec.h"
#include "audio/types.h"
#include "debug.h"
#include "lib_common.h"
#include "module.h"
#include "rtp/rtp.h"
#include "transmit.h"
#include "utils/audio_buffer.h"
#include "utils/thread.h"
#include <chrono>
#include <iostream>
#include <map>
#include <mutex>
#include <thread>
#include <vector>

Include dependency graph for mixer.cpp:

Go to the source code of this file.

Classes
struct	am_participant
class	generic_mix_algo< source_t, intermediate_t >
class	linear_mix_algo< source_t, intermediate_t >
class	logarithmic_mix_algo< source_t, intermediate_t >
class	sockaddr_storage_less
struct	state_audio_mixer

Macros
#define	BPS   2
#define	CHANNELS   1
#define	FRAMES_PER_SEC   25
#define	PARTICIPANT_TIMEOUT_S   60
#define	SAMPLE_RATE   48000
#define	SAMPLES_PER_FRAME   (SAMPLE_RATE / FRAMES_PER_SEC)

Typedefs
typedef int32_t	sample_type_mixed
typedef int16_t	sample_type_source

Functions
static bool	audio_play_mixer_ctl (void *state, int request, void *data, size_t *len)
static void	audio_play_mixer_done (void *state)
static void	audio_play_mixer_help ()
static void *	audio_play_mixer_init (const char *cfg)
static void	audio_play_mixer_probe (struct device_info **available_devices, int *count, void(**deleter)(void *))
static void	audio_play_mixer_put_frame (void *state, const struct audio_frame *frame)
static bool	audio_play_mixer_reconfigure (void *state, struct audio_desc desc)
static void	mixer_dummy_rtp_callback (struct rtp *session, rtp_event *e)
	REGISTER_MODULE (mixer, &aplay_mixer_info, LIBRARY_CLASS_AUDIO_PLAYBACK, AUDIO_PLAYBACK_ABI_VERSION)

Variables
static const struct audio_playback_info	aplay_mixer_info

Detailed Description

Author

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

Definition in file mixer.cpp.

Macro Definition Documentation

BPS

#define BPS   2

Definition at line 64 of file mixer.cpp.

Referenced by am_participant::am_participant(), audio_play_mixer_ctl(), audio_play_mixer_reconfigure(), calculate_rms_helper(), get_avg_volume_helper(), ultragrid::aja::display::process_frames(), and state_audio_mixer::worker().

CHANNELS

#define CHANNELS   1

Definition at line 65 of file mixer.cpp.

Referenced by am_participant::am_participant(), audio_play_mixer_ctl(), audio_play_mixer_reconfigure(), and state_audio_mixer::worker().

FRAMES_PER_SEC

#define FRAMES_PER_SEC   25

Definition at line 66 of file mixer.cpp.

PARTICIPANT_TIMEOUT_S

#define PARTICIPANT_TIMEOUT_S   60

Definition at line 70 of file mixer.cpp.

Referenced by state_audio_mixer::worker().

SAMPLE_RATE

#define SAMPLE_RATE   48000

Definition at line 63 of file mixer.cpp.

Referenced by am_participant::am_participant(), audio_play_mixer_ctl(), audio_play_mixer_reconfigure(), ultragrid::aja::display::process_frames(), and state_audio_mixer::worker().

SAMPLES_PER_FRAME

#define SAMPLES_PER_FRAME   (SAMPLE_RATE / FRAMES_PER_SEC)

Definition at line 68 of file mixer.cpp.

Referenced by state_audio_mixer::worker().

Typedef Documentation

sample_type_mixed

typedef int32_t sample_type_mixed

Definition at line 72 of file mixer.cpp.

sample_type_source

typedef int16_t sample_type_source

Definition at line 71 of file mixer.cpp.

Function Documentation

audio_play_mixer_ctl()

static bool audio_play_mixer_ctl ( void * state, int request, void * data, size_t * len )

static

Definition at line 433 of file mixer.cpp.

{
        struct state_audio_mixer *s = (struct state_audio_mixer *) state;
 
        switch (request) {
        case AUDIO_PLAYBACK_CTL_QUERY_FORMAT:
                if (*len >= sizeof(struct audio_desc)) {
                        struct audio_desc desc { BPS, SAMPLE_RATE, CHANNELS, AC_PCM };
                        memcpy(data, &desc, sizeof desc);
                        *len = sizeof desc;
                        return true;
                } else {
                        return false;
                }
        case AUDIO_PLAYBACK_CTL_MULTIPLE_STREAMS:
                if (*len >= sizeof(bool)) {
                        *(bool *) data = true;
                        *len = sizeof(bool);
                        return true;
                } else {
                        return false;
                }
        case AUDIO_PLAYBACK_PUT_NETWORK_DEVICE:
                if (*len != sizeof(struct rtp *)) {
                        return false;
                } else {
                        s->recv_socket = rtp_get_udp_local_socket(*(struct rtp **) data);
                        assert(s->recv_socket != NULL);
                        return true;
                }
        default:
                return false;
        }
}

References AC_PCM, AUDIO_PLAYBACK_CTL_MULTIPLE_STREAMS, AUDIO_PLAYBACK_CTL_QUERY_FORMAT, AUDIO_PLAYBACK_PUT_NETWORK_DEVICE, BPS, CHANNELS, desc, len, state_audio_mixer::recv_socket, rtp_get_udp_local_socket(), SAMPLE_RATE, and state.

Here is the call graph for this function:

audio_play_mixer_done()

static void audio_play_mixer_done ( void * state )

static

Definition at line 425 of file mixer.cpp.

{
        struct state_audio_mixer *s = (struct state_audio_mixer *) state;
        s->should_exit = true;
 
        delete s;
}

References state_audio_mixer::should_exit, and state.

audio_play_mixer_help()

static void audio_play_mixer_help ( )

static

Definition at line 364 of file mixer.cpp.

{
        printf("Usage:\n"
               "\t%s -r mixer[:codec=<codec>][:algo={linear|logarithmic}]\n"
               "\n"
               "<codec>\n"
               "\taudio codec to use\n"
               "linear\n"
               "\tlinear sum of signals (with clamping)\n"
               "logarithmic\n"
               "\tlinear sum of signals to threshold, above threshold logarithmic dynamic range compression is used\n"
               "\n"
               "Notes:\n"
               "1)\tYou do not need to specify audio participants explicitly,\n"
               "\t" PACKAGE_NAME " simply sends the the stream back to the host\n"
               "\tthat is sending to mixer. Therefore it is necessary that the\n"
               "\tparticipant uses single " PACKAGE_NAME " for both sending and\n"
               "\treceiving audio.\n"
               "2)\tUses default port for receiving, therefore if you want to use it\n"
               "\ton machine that is a part of the conference, you should use something like:\n"
               "\t\t%s -s <your_capture> -P 5004:5004:5010:5006\n"
               "\tfor the " PACKAGE_NAME " instance that is part of the conference (not mixer!)\n",
               uv_argv[0], uv_argv[0]);
}

References uv_argv.

Referenced by audio_play_mixer_init().

audio_play_mixer_init()

static void * audio_play_mixer_init ( const char * cfg )

static

Definition at line 396 of file mixer.cpp.

{
        if (strcmp(cfg, "help") == 0) {
                audio_play_mixer_help();
                return INIT_NOERR;
        }
        try {
                return new state_audio_mixer{cfg};
        } catch (...) {
                return nullptr;
        }
}

References audio_play_mixer_help(), and INIT_NOERR.

Here is the call graph for this function:

audio_play_mixer_probe()

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

static

Definition at line 389 of file mixer.cpp.

{
        *deleter = free;
        *available_devices = NULL;
        *count = 0;
}

References count, and deleter.

audio_play_mixer_put_frame()

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

static

Definition at line 409 of file mixer.cpp.

{
        struct state_audio_mixer *s = (struct state_audio_mixer *) state;
 
        unique_lock<mutex> lk(s->participants_lock);
 
        auto ss = *(struct sockaddr_storage *) frame->network_source;
 
        if (s->participants.find(ss) == s->participants.end()) {
                s->participants.emplace(ss, am_participant{s->recv_socket, &ss, s->audio_codec});
        }
 
        audio_buffer_write(s->participants.at(ss).m_buffer, frame->data, frame->data_len);
        s->participants.at(ss).last_seen = chrono::steady_clock::now();
}

References audio_buffer_write(), state_audio_mixer::audio_codec, frame, state_audio_mixer::participants, state_audio_mixer::participants_lock, state_audio_mixer::recv_socket, and state.

Here is the call graph for this function:

audio_play_mixer_reconfigure()

static bool audio_play_mixer_reconfigure ( void * state, struct audio_desc desc )

static

Definition at line 468 of file mixer.cpp.

{
        audio_desc requested{BPS, SAMPLE_RATE, CHANNELS, AC_PCM};
        assert(desc == requested);
        return true;
}

References AC_PCM, BPS, CHANNELS, desc, and SAMPLE_RATE.

mixer_dummy_rtp_callback()

static void mixer_dummy_rtp_callback ( struct rtp * session, rtp_event * e )

static

Definition at line 114 of file mixer.cpp.

                                                                                                     {
}

REGISTER_MODULE()

REGISTER_MODULE	(	mixer	,
		&	aplay_mixer_info,
		LIBRARY_CLASS_AUDIO_PLAYBACK	,
		AUDIO_PLAYBACK_ABI_VERSION	)

Variable Documentation

aplay_mixer_info

const struct audio_playback_info aplay_mixer_info

static

Initial value:

= {
        audio_play_mixer_probe,
        audio_play_mixer_init,
        audio_play_mixer_put_frame,
        audio_play_mixer_ctl,
        audio_play_mixer_reconfigure,
        audio_play_mixer_done
}

Definition at line 475 of file mixer.cpp.

                                                           {
        audio_play_mixer_probe,
        audio_play_mixer_init,
        audio_play_mixer_put_frame,
        audio_play_mixer_ctl,
        audio_play_mixer_reconfigure,
        audio_play_mixer_done
};