ThreadedFrameStream.h

Go to the documentation of this file.

#ifndef CSL_ThreadedFrameStream_H
#define CSL_ThreadedFrameStream_H

#include "CSL_Core.h"
#include "RingBuffer.h"
#include "ThreadUtilities.h"

namespace csl {


class ThreadUtil {
public: 
                        // state
    unsigned    mNumChannels;               
    unsigned    mNumBufferFrames;           
    bool        mIsRunning;                 
    int         mNumAvailableFrames;        
    unsigned    mAvailableFrameThreshold;   
    RingBuffer  mRingBuffer;                    

    void setSize(unsigned numChannels, unsigned numBufferFrames);
    void setThreshold(unsigned threshold);
    void setChannels(unsigned numChannels); 
    virtual void init(unsigned numChannels, unsigned numBufferFrames) = 0;

    virtual void start();
    virtual void stop();    

protected:
    Synch * mSynch;
    Thread * mThread;
    Buffer mBuffer;                 
};

class ThreadedReader : public Effect, public ThreadUtil {
public: 
    ThreadedReader();
    ThreadedReader(UnitGenerator inp);
    ThreadedReader(unsigned numChannels);
    ThreadedReader(unsigned numChannels, unsigned numFrames);
    ~ThreadedReader();
    
    void init(unsigned numChannels, unsigned numBufferFrames);
    void nextBuffer(Buffer & outputBuffer, unsigned chan) throw(CException);
    void start();

protected:
    static void * FeederFunction(void * arg);       
    void readIntoBuffer();
    
};

class ThreadedWriter : public Writeable, public ThreadUtil {
public:
                // ctor / dtor
    ThreadedWriter();
    ThreadedWriter(unsigned numChannels);
    ThreadedWriter(unsigned numChannels, unsigned numBufferFrames);
    virtual ~ThreadedWriter();

    Writeable * mOutput;
    
                // methods
    void init(unsigned numChannels, unsigned numBufferFrames);
    void setOutput(Writeable& output) { mOutput = &output; }
    void writeBuffer(Buffer & inputBuffer) throw(CException);
    void start();
    void stop();    

protected:  
    static void * FeederFunction(void* arg);        // thread function
    void writeToOutput();
};

}

#endif

---