src/backend/voip/callchannelhandler_p.h

   1 /*
   2     Copyright (C) 2010 Collabora Ltd. <info@collabora.co.uk>
   3       @author George Kiagiadakis <george.kiagiadakis@collabora.co.uk>
   4
   5     This library is free software; you can redistribute it and/or modify
   6     it under the terms of the GNU Lesser General Public License as published
   7     by the Free Software Foundation; either version 2.1 of the License, or
   8     (at your option) any later version.
   9
  10     This program is distributed in the hope that it will be useful,
  11     but WITHOUT ANY WARRANTY; without even the implied warranty of
  12     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13     GNU General Public License for more details.
  14
  15     You should have received a copy of the GNU Lesser General Public License
  16     along with this program.  If not, see <http://www.gnu.org/licenses/>.
  17  */
  18 #ifndef CALLCHANNELHANDLER_P_H
  19 #define CALLCHANNELHANDLER_P_H
  20
  21 #include <QMutex>
  22
  23 #include <QGst/GhostPad>
  24 #include <QGst/Pipeline>
  25 #include <QGst/StreamVolume>
  26 #include <QGst/ColorBalance>
  27 #include <QGst/Ui/VideoWidget>
  28
  29 #include <TelepathyQt4/Contact>
  30 #include <TelepathyQt4/StreamedMediaChannel>
  31
  32 #include "callchannelhandler.h"
  33
  34 class ParticipantData;
  35
  36
  37 //BEGIN Ugly forward declarations
  38
  39 /* These declarations are copied here instead of including the proper headers,
  40  * because the proper headers also include too many unrelated stuff and we have
  41  * to depend on many useless (at build time) external libraries (such as dbus-glib,
  42  * libxml2, gstreamer) for no good reason.
  43  */
  44
  45 typedef unsigned long GType;
  46 typedef int gboolean;
  47 typedef char gchar;
  48 typedef struct _GList GList;
  49 typedef struct _TfChannel TfChannel;
  50
  51 extern "C" {
  52   GType fs_codec_list_get_type(void);
  53   GList *fs_codec_list_from_keyfile(const gchar *filename, GError **error);
  54   gboolean tf_channel_bus_message(TfChannel *channel, GstMessage *message);
  55 }
  56
  57 namespace Tp {
  58   Q_DECL_IMPORT TfChannel *createFarsightChannel(const StreamedMediaChannelPtr &channel);
  59 }
  60 //END Ugly forward declarations
  61
  62
  63 namespace MaknetoBackend {
  64
  65   class CallChannelHandlerPrivate : public QObject {
  66
  67     Q_OBJECT
  68   public:
  69     enum Who {
  70       Myself = 0, RemoteContact = 1
  71     };
  72     enum GstQueueLeaky {
  73       GST_QUEUE_NO_LEAK             = 0,
  74       GST_QUEUE_LEAK_UPSTREAM       = 1,
  75       GST_QUEUE_LEAK_DOWNSTREAM     = 2
  76     };
  77
  78     inline CallChannelHandlerPrivate(CallChannelHandler *qq) : QObject(), q(qq) {
  79     }
  80     void init(const Tp::StreamedMediaChannelPtr & channel);
  81     void accept();
  82     ~CallChannelHandlerPrivate();
  83
  84     inline Tp::StreamedMediaChannelPtr channel() const {
  85       return m_channel;
  86     }
  87
  88     inline QList<CallParticipant*> participants() const {
  89       return m_participants.values();
  90     }
  91     Tp::ContactPtr contactOfParticipant(Who who) const;
  92
  93     private
  94 Q_SLOTS:
  95     void onChannelInvalidated(Tp::DBusProxy *proxy,
  96             const QString & errorName,
  97             const QString & errorMessage);
  98
  99   private:
 100     void onBusMessage(const QGst::MessagePtr & message);
 101     bool tryStopElements(bool audio, QGst::BinPtr &bin, QGst::ElementPtr & element, Who who);
 102     bool tryStopElement(const QGst::ElementPtr &element, QGst::BinPtr bin = QGst::BinPtr());
 103
 104     // -- from TfChannel signals
 105     void onTfChannelClosed();
 106     void onSessionCreated(QGst::ElementPtr & conference);
 107     void onStreamCreated(const QGlib::ObjectPtr & stream);
 108     GList *onStreamGetCodecConfig();
 109
 110     // -- from TfStream signals
 111     void onSrcPadAdded(const QGlib::ObjectPtr & stream, QGst::PadPtr & src);
 112     bool onRequestResource(const QGlib::ObjectPtr & stream, uint direction);
 113     void onFreeResource(const QGlib::ObjectPtr & stream, uint direction);
 114     void onStreamClosed(const QGlib::ObjectPtr & stream);
 115
 116     bool createAudioBin(QExplicitlySharedDataPointer<ParticipantData> & data);
 117     bool createVideoBin(QExplicitlySharedDataPointer<ParticipantData> & data, bool isVideoSrc);
 118
 119     // *** data ***
 120
 121     CallChannelHandler *q;
 122     Tp::StreamedMediaChannelPtr m_channel;
 123
 124     QMap<Who, CallParticipant*> m_participants;
 125     QExplicitlySharedDataPointer<ParticipantData> m_participantData[2];
 126
 127     QGst::PipelinePtr m_pipeline;
 128     QGst::ElementPtr m_audioInputDevice;
 129     QGst::ElementPtr m_videoInputDevice;
 130     QGst::ElementPtr m_audioOutputDevice;
 131
 132     QGlib::ObjectPtr m_tfChannel;
 133     QGst::ElementPtr m_conference;
 134   };
 135
 136   class ParticipantData : public QSharedData {
 137   public:
 138
 139     inline ParticipantData() //just for being able to construct the array above without initialization
 140     : handlerPriv(NULL), who(CallChannelHandlerPrivate::Myself) {
 141     }
 142
 143     inline ParticipantData(CallChannelHandlerPrivate *h, CallChannelHandlerPrivate::Who w)
 144     : handlerPriv(h), who(w) {
 145     }
 146
 147     QGst::BinPtr audioBin;
 148     QGst::BinPtr videoBin;
 149     QGst::StreamVolumePtr volumeControl;
 150     QGst::ColorBalancePtr colorBalanceControl;
 151     QGst::ElementPtr videoOutElemPtr;
 152     //QWeakPointer<QGst::Ui::VideoWidget> videoWidget;
 153     CallChannelHandlerPrivate *handlerPriv;
 154     CallChannelHandlerPrivate::Who who;
 155
 156     QGst::PadPtr preparedPad;
 157     QMutex mutex;
 158   };
 159
 160 }
 161
 162 #endif