hsoundcardreader.h

#ifndef __HSOUNDCARDREADER_H
#define __HSOUNDCARDREADER_H
 
#include "hprobe.h"
 
#include <mutex>
#include <condition_variable>
 
#include "hardt.h"
 
#define NUMBER_OF_BUFFERS 4
#define DEFAULT_BLOCKSIZE 1024
 
template <class T>
class HSoundcardReader : public HReader<T>
{
    private:
 
        // Data accessed by the (static) callback function
        struct CallbackData
        {
            int channels;
            int framesize;
            int wrloc;
            int rdloc;
            T* buffer;
            std::mutex mtx;
            std::condition_variable lock;
        } _cbd;
 
        // The sample stream from the soundcard
        PaStream *_stream;
        bool _isStarted;
 
        // Housekeeping
        bool _isInitialized;
 
        // A probe
        HProbe<T>* _probe;
 
        bool Start();
 
        bool Stop();
 
    public:
 
        HSoundcardReader(int device, H_SAMPLE_RATE rate, int channels, H_SAMPLE_FORMAT format, int blocksize = DEFAULT_BLOCKSIZE, HProbe<T>* probe = nullptr);
 
        ~HSoundcardReader();
 
        int Read(T* dest, size_t blocksize);
 
        static int callback( const void *inputBuffer, void *outputBuffer,
                                   unsigned long blocksize,
                                   const PaStreamCallbackTimeInfo* timeInfo,
                                   PaStreamCallbackFlags statusFlags,
                                   void *userData );
 
        bool Command(HCommand* command) {
            // No further propagation of commands
            return true;
        }
};
 
#endif