recorderbase.h

Go to the documentation of this file.

// -*- Mode: c++ -*-
#ifndef RECORDERBASE_H_
#define RECORDERBASE_H_

#include <qmutex.h>
#include <qstring.h>
#include <qmap.h>
#include <qsqldatabase.h>
#include <qwaitcondition.h>

#include <pthread.h>

#include "mythexp.h"

class TVRec;
class RingBuffer;
class ProgramInfo;
class RecordingProfile;

class MPUBLIC RecorderBase
{
    friend class Transcode; // for access to SetIntOption(), SetStrOption()

  public:
    RecorderBase(TVRec *rec);
    virtual ~RecorderBase();

    void SetFrameRate(double rate)
    {
        video_frame_rate = rate;
        ntsc_framerate = (29.96 <= rate && 29.98 >= rate);
    }

    void SetRecording(const ProgramInfo *pginfo);

    void SetRingBuffer(RingBuffer *rbuf);

    virtual void SetOption(const QString &opt, const QString &value);

    virtual void SetOption(const QString &opt, int value);

    virtual void SetVideoFilters(QString &filters) = 0;

    virtual void SetOptionsFromProfile(RecordingProfile *profile, 
                                       const QString &videodev, 
                                       const QString &audiodev,
                                       const QString &vbidev) = 0;

    virtual void SetNextRecording(const ProgramInfo*, RingBuffer*) = 0;

    virtual void Initialize(void) = 0;

    virtual void StartRecording(void) = 0;

    virtual void StopRecording(void) = 0;

    virtual void Reset(void) = 0;   

    virtual bool IsRecording(void) = 0;

    virtual bool IsErrored(void) = 0;

    virtual long long GetFramesWritten(void) = 0;
    
    virtual bool Open(void) = 0;
    
    virtual int GetVideoFd(void) = 0;
    
    virtual long long GetKeyframePosition(long long desired) = 0;

    virtual void Pause(bool clear = true)
        { (void) clear; request_pause = true; }

    virtual void Unpause(void)
        { request_pause = false; unpauseWait.wakeAll(); }
    virtual bool IsPaused(void) const { return paused; }
    virtual bool WaitForPause(int timeout = 1000);

    double GetFrameRate(void) { return video_frame_rate; }

    virtual void CheckForRingBufferSwitch(void);

    void SavePositionMap(bool force = false);

  protected:
    void SetIntOption(RecordingProfile *profile, const QString &name);
    void SetStrOption(RecordingProfile *profile, const QString &name);
    virtual bool PauseAndWait(int timeout = 100);

    virtual void ResetForNewFile(void) = 0;
    virtual void FinishRecording(void) = 0;
    virtual void StartNewFile(void) { }

    void SetPositionMapType(int type) { positionMapType = type; }

    TVRec         *tvrec;
    RingBuffer    *ringBuffer;
    bool           weMadeBuffer;

    QString        videocodec;
    QString        audiodevice;
    QString        videodevice;
    QString        vbidevice;

    int            vbimode;
    bool           ntsc;
    bool           ntsc_framerate;
    double         video_frame_rate;

    ProgramInfo   *curRecording;

    // For handling pausing
    bool           request_pause;
    bool           paused;
    QWaitCondition pauseWait;
    QWaitCondition unpauseWait;

    // For RingBuffer switching
    QMutex         nextRingBufferLock;
    RingBuffer    *nextRingBuffer;
    ProgramInfo   *nextRecording;

    // Seektable  support
    int                        positionMapType;
    QMutex                     positionMapLock;
    QMap<long long, long long> positionMap;
    QMap<long long, long long> positionMapDelta;
};

#endif

/* vim: set expandtab tabstop=4 shiftwidth=4: */

---