PlayBack-PulseAudio.h

Go to the documentation of this file.

/***************************************************************************
  PlayBack-PulseAudio.h  -  playback device for PulseAudio
                             -------------------
    begin                : Tue Sep 29 2009
    copyright            : (C) 2009 by Thomas Eschenbacher
    email                : Thomas.Eschenbacher@gmx.de
 ***************************************************************************/

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

#ifndef PLAY_BACK_PULSE_AUDIO_H
#define PLAY_BACK_PULSE_AUDIO_H

#include "config.h"
#ifdef HAVE_PULSEAUDIO_SUPPORT

#include <poll.h>

#include <pulse/context.h>
#include <pulse/error.h>
#include <pulse/gccmacro.h>
#include <pulse/introspect.h>
#include <pulse/mainloop.h>
#include <pulse/proplist.h>
#include <pulse/stream.h>

#include <QList>
#include <QMap>
#include <QMutex>
#include <QString>
#include <QWaitCondition>

#include "libkwave/FileInfo.h"
#include "libkwave/PlayBackDevice.h"
#include "libkwave/Runnable.h"
#include "libkwave/SampleArray.h"
#include "libkwave/WorkerThread.h"

namespace Kwave
{
    class PlayBackPulseAudio: public Kwave::PlayBackDevice,
                              public Kwave::Runnable
    {
    public:

        explicit PlayBackPulseAudio(const Kwave::FileInfo &info);

        virtual ~PlayBackPulseAudio() Q_DECL_OVERRIDE;

        virtual QString open(const QString &device, double rate,
                             unsigned int channels, unsigned int bits,
                             unsigned int bufbase) Q_DECL_OVERRIDE;

        virtual int write(const Kwave::SampleArray &samples) Q_DECL_OVERRIDE;

        virtual int close() Q_DECL_OVERRIDE;

        virtual QStringList supportedDevices() Q_DECL_OVERRIDE;

        virtual QString fileFilter() Q_DECL_OVERRIDE;

        virtual QList<unsigned int> supportedBits(const QString &device)
            Q_DECL_OVERRIDE;

        virtual int detectChannels(const QString &device,
                                   unsigned int &min, unsigned int &max)
            Q_DECL_OVERRIDE;

        int mainloopPoll(struct pollfd *ufds, unsigned long int nfds,
                         int timeout);

    protected:

        int flush();

        virtual void run_wrapper(const QVariant &params) Q_DECL_OVERRIDE;

    private:

        static void pa_context_notify_cb(pa_context *c, void *data);

        static void pa_sink_info_cb(pa_context *c, const pa_sink_info *info,
                                    int eol, void *userdata);

        static void pa_stream_state_cb(pa_stream *p, void *userdata);

        static void pa_write_cb(pa_stream *p, size_t nbytes, void *userdata);

        static void pa_stream_success_cb(pa_stream *s, int success,
                                         void *userdata);

        void notifyContext(pa_context *c);

        void notifySinkInfo(pa_context *c, const pa_sink_info *info, int eol);

        void notifyStreamState(pa_stream *stream);

        void notifyWrite(pa_stream *stream, size_t nbytes);

        void notifySuccess(pa_stream *stream, int success);

        bool connectToServer();

        void disconnectFromServer();

        void scanDevices();

    private:

        typedef struct
        {
            QString m_name;               
            QString m_description;        
            QString m_driver;             
            quint32  m_card;              
            pa_sample_spec m_sample_spec; 
        } sink_info_t;

    private:
        Kwave::WorkerThread m_mainloop_thread;

        QMutex m_mainloop_lock;

        QWaitCondition m_mainloop_signal;

        Kwave::FileInfo m_info;

        double m_rate;

        unsigned int m_bytes_per_sample;

        void *m_buffer;

        size_t m_buffer_size;

        size_t m_buffer_used;

        unsigned int m_bufbase;

        pa_proplist *m_pa_proplist;

        pa_mainloop *m_pa_mainloop;

        pa_context *m_pa_context;

        pa_stream *m_pa_stream;

        QMap<QString, sink_info_t> m_device_list;

    };
}

#endif /* HAVE_PULSEAUDIO_SUPPORT */

#endif /* PLAY_BACK_PULSE_AUDIO_H */

//***************************************************************************
//***************************************************************************