audiomixer.h

Go to the documentation of this file.

/* -*-C++-*- -*-coding: utf-8-unix;-*-
   Classified Ads is Copyright (c) Antti Järvinen 2015.

  This file is part of Classified Ads.

  Classified Ads is free software; you can redistribute it and/or
  modify it under the terms of the GNU Lesser General Public
  License as published by the Free Software Foundation; either
  version 2.1 of the License, or (at your option) any later version.

  Classified Ads is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  Lesser General Public License for more details.

  You should have received a copy of the GNU Lesser General Public
  License along with Classified Ads; if not, write to the Free Software
  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*/

#ifndef AUDIO_MIXER_H
#define AUDIO_MIXER_H

#include <QObject>
#include <QByteArray>
#include <QQueue>
#include "../util/hash.h"

class Model ;

class AudioMixer : public QObject {
    Q_OBJECT

public:
    AudioMixer(Model& aModel) ;
    ~AudioMixer() ;

    void insertStream (quint32 aCallId,
                       quint32 aStartingSeq,
                       bool aIsLocallyCaptured,
                       const Hash& aOriginatingNode ) ;
    void removeStream (quint32 aCallId) ;
signals:
    void frameReadyForLocalSpeaker(const QByteArray& aFrame) ;
    void frameReadyForRemoteSend(quint32 aCallId,
                                 quint32 aSeqNo,
                                 const QByteArray& aFrame,
                                 Hash aForNode ) ;
public slots:
    void insertCapturedAudioFrame ( const QByteArray& aFrame,
                                    quint32 aSeqNo,
                                    float aVolumeLevel);

    void insertReceivedAudioFrame ( quint32 aCallId,
                                    quint32 aSeqNo,
                                    const QByteArray& aFrame,
                                    Hash aOriginatingNode );

private: // methods
    void tryMixFrames(quint32 aCallId,
                      quint32 aSeqNo) ;
    void configureMixedStreams() ;
    void doInsertAudioFrame ( const QByteArray& aFrame,
                              bool aIsLocallyCaptured,
                              quint32 aSeqNo,
                              quint32 aCallId,
                              float aVolumeLevel,
                              Hash &aOriginatingNode );

private: // members
    typedef struct AudioFrameStruct {
        quint32 iCallId ;
        quint32 iSeqNo ;
        bool iIsLocallyCaptured ; 
        QByteArray iFrame ;
        float iVolumeLevel ; 
    } AudioFrame ;
    typedef struct AudioStreamMetadata {
        quint32 iCallId ;
        quint32 iStartingSeq ;
        quint32 iMaxSeqSeen;
        Hash iNode ; 
        bool iIsLocallyCaptured ; 
    } AudioFrameMetadata ;
    QList<QQueue<AudioFrame> > iAudioDataBuffer ;
    QList<AudioFrameMetadata> iStreams ;
    QList<int> iIndexesToMixForLocalSpeaker ;
    QList<int> iIndexesToMixForRemoteOutput ;
    Model& iModel ; 
} ;
#endif