MythTV  0.28pre
Public Member Functions | Static Public Member Functions | Static Public Attributes | Protected Member Functions | Protected Attributes | Private Attributes | Static Private Attributes | Friends | List of all members
RingBuffer Class Referenceabstract

Implements a file/stream reader/writer. More...

#include <ringbuffer.h>

Inheritance diagram for RingBuffer:
Inheritance graph
[legend]
Collaboration diagram for RingBuffer:
Collaboration graph
[legend]

Public Member Functions

virtual ~RingBuffer ()=0
 Deletes Classes inheriting from RingBuffer must implement a destructor that calls KillReadAheadThread(). More...
 
void SetWriteBufferSize (int newSize)
 
void SetWriteBufferMinWriteSize (int newMinSize)
 Calls ThreadedFileWriter::SetWriteBufferMinWriteSize(int) More...
 
void SetOldFile (bool is_old)
 Tell RingBuffer if this is an old file or not. More...
 
void UpdateRawBitrate (uint rawbitrate)
 Set the raw bit rate, to allow RingBuffer adjust effective bitrate. More...
 
void UpdatePlaySpeed (float playspeed)
 Set the play speed, to allow RingBuffer adjust effective bitrate. More...
 
void EnableBitrateMonitor (bool enable)
 
void SetBufferSizeFactors (bool estbitrate, bool matroska)
 Tells RingBuffer that the raw bitrate may be innacurate and the underlying container is matroska, both of which may require a larger buffer size. More...
 
void SetWaitForWrite (void)
 
QString GetSafeFilename (void)
 
QString GetFilename (void) const
 Returns name of file used by this RingBuffer. More...
 
QString GetSubtitleFilename (void) const
 
QString GetLastError (void) const
 
bool GetCommsError (void) const
 
void ResetCommsError (void)
 
bool GetStopReads (void) const
 Returns value of stopreads. More...
 
bool isPaused (void) const
 Returns false iff read-ahead is not running and read-ahead is not paused. More...
 
virtual long long GetReadPosition (void) const =0
 Returns how far into the file we have read. More...
 
QString GetDecoderRate (void)
 
QString GetStorageRate (void)
 
QString GetAvailableBuffer (void)
 
uint GetBufferSize (void)
 
long long GetWritePosition (void) const
 Returns how far into a ThreadedFileWriter file we have written. More...
 
long long GetRealFileSize (void) const
 Returns the size of the file we are reading/writing, or -1 if the query fails. More...
 
bool IsNearEnd (double fps, uint vvf) const
 
virtual bool IsOpen (void) const =0
 Returns true if open for either reading or writing. More...
 
virtual bool IsStreamed (void)
 
virtual bool IsSeekingAllowed (void)
 
virtual bool IsBookmarkAllowed (void)
 
virtual int BestBufferSize (void)
 
RingBufferType GetType () const
 
int GetReadBufAvail () const
 Returns number of bytes available for reading from buffer. More...
 
bool SetReadInternalMode (bool mode)
 
bool IsReadInternalMode (void)
 
bool IsDisc (void) const
 
bool IsDVD (void) const
 
bool IsBD (void) const
 
const DVDRingBufferDVD (void) const
 
const BDRingBufferBD (void) const
 
DVDRingBufferDVD (void)
 
BDRingBufferBD (void)
 
virtual bool StartFromBeginning (void)
 
virtual void IgnoreWaitStates (bool ignore)
 
virtual bool IsInMenu (void) const
 
virtual bool IsInStillFrame (void) const
 
virtual bool IsInDiscMenuOrStillFrame (void) const
 
virtual bool HandleAction (const QStringList &, int64_t)
 
virtual bool OpenFile (const QString &lfilename, uint retry_ms=kDefaultOpenTimeout)=0
 Opens a file for reading. More...
 
virtual bool ReOpen (QString newFilename="")
 
int Read (void *buf, int count)
 This is the public method for reading from a file, it calls the appropriate read method if the file is remote or buffered, or a BD/DVD. More...
 
int Peek (void *buf, int count)
 
void Reset (bool full=false, bool toAdjust=false, bool resetInternal=false)
 Resets the read-ahead thread and our position in the file. More...
 
long long Seek (long long pos, int whence, bool has_lock=false)
 Seeks to a particular position in the file. More...
 
void Pause (void)
 Pauses the read-ahead thread. More...
 
void Unpause (void)
 Unpauses the read-ahead thread. More...
 
void WaitForPause (void)
 Waits for Pause(void) to take effect. More...
 
void Start (void)
 Starts the read-ahead thread. More...
 
void StopReads (void)
 ???? More...
 
void StartReads (void)
 ???? More...
 
bool LiveMode (void) const
 Returns true if this RingBuffer has been assigned a LiveTVChain. More...
 
void SetLiveMode (LiveTVChain *chain)
 Assigns a LiveTVChain to this RingBuffer. More...
 
void IgnoreLiveEOF (bool ignore)
 Tells RingBuffer whether to ignore the end-of-file. More...
 
int Write (const void *buf, uint count)
 Writes buffer to ThreadedFileWriter::Write(const void*,uint) More...
 
bool IsIOBound (void) const
 
void WriterFlush (void)
 Calls ThreadedFileWriter::Flush(void) More...
 
void Sync (void)
 Calls ThreadedFileWriter::Sync(void) More...
 
long long WriterSeek (long long pos, int whence, bool has_lock=false)
 Calls ThreadedFileWriter::Seek(long long,int). More...
 
bool WriterSetBlocking (bool lock=true)
 Calls ThreadedFileWriter::SetBlocking(bool) More...
 
long long SetAdjustFilesize (void)
 
void SetTimeout (bool is_old) MDEPRECATED
 

Static Public Member Functions

static RingBufferCreate (const QString &lfilename, bool write, bool usereadahead=true, int timeout_ms=kDefaultOpenTimeout, bool stream_only=false)
 Creates a RingBuffer instance. More...
 
static QString BitrateToString (uint64_t rate, bool hz=false)
 
static void AVFormatInitNetwork (void)
 

Static Public Attributes

static const int kDefaultOpenTimeout = 2000
 
static const int kLiveTVOpenTimeout = 10000
 
static QMutex subExtLock
 
static QStringList subExt
 
static QStringList subExtNoCheck
 

Protected Member Functions

 RingBuffer (RingBufferType rbtype)
 
void run (void)
 Runs the Qt event loop unless we have a QRunnable, in which case we run the runnable run instead. More...
 
void CreateReadAheadBuffer (void)
 
void CalcReadAheadThresh (void)
 Calculates fill_min, fill_threshold, and readblocksize from the estimated effective bitrate of the stream. More...
 
bool PauseAndWait (void)
 
virtual int safe_read (void *data, uint sz)=0
 
int ReadPriv (void *buf, int count, bool peek)
 When possible reads from the read-ahead buffer, otherwise reads directly from the device. More...
 
int ReadDirect (void *buf, int count, bool peek)
 
bool WaitForReadsAllowed (void)
 
int WaitForAvail (int count, int timeout)
 
virtual long long GetRealFileSizeInternal (void) const
 
virtual long long SeekInternal (long long pos, int whence)=0
 
int ReadBufFree (void) const
 Returns number of bytes available for reading into buffer. More...
 
int ReadBufAvail (void) const
 Returns number of bytes available for reading from buffer. More...
 
void ResetReadAhead (long long newinternal)
 Restart the read-ahead thread at the 'newinternal' position. More...
 
void KillReadAheadThread (void)
 Stops the read-ahead thread, and waits for it to stop. More...
 
uint64_t UpdateDecoderRate (uint64_t latest=0)
 
uint64_t UpdateStorageRate (uint64_t latest=0)
 
- Protected Member Functions inherited from MThread
int exec (void)
 Enters the qt event loop. call exit or quit to exit thread. More...
 
 MThread (const QString &objectName)
 Standard constructor. More...
 
 MThread (const QString &objectName, QRunnable *runnable)
 Use this constructor if you want the default run() method to run the QRunnable's run() method instead of entering the Qt event loop. More...
 
virtual ~MThread ()
 
void RunProlog (void)
 Sets up a thread, call this if you reimplement run(). More...
 
void RunEpilog (void)
 Cleans up a thread's resources, call this if you reimplement run(). More...
 
QThread * qthread (void)
 Returns the thread, this will always return the same pointer no matter how often you restart the thread. More...
 
void setObjectName (const QString &name)
 
QString objectName (void) const
 
void setPriority (QThread::Priority priority)
 
QThread::Priority priority (void) const
 
bool isFinished (void) const
 
bool isRunning (void) const
 
void setStackSize (uint stackSize)
 
uint stackSize (void) const
 
void exit (int retcode=0)
 Use this to exit from the thread if you are using a Qt event loop. More...
 
void start (QThread::Priority=QThread::InheritPriority)
 Tell MThread to start running the thread in the near future. More...
 
void terminate (void)
 Kill a thread unsafely. More...
 
void quit (void)
 calls exit(0) More...
 
bool wait (unsigned long time=ULONG_MAX)
 Wait for the MThread to exit, with a maximum timeout. More...
 

Protected Attributes

RingBufferType type
 
QReadWriteLock poslock
 
long long readpos
 
long long writepos
 
long long internalreadpos
 
long long ignorereadpos
 
QReadWriteLock rbrlock
 
int rbrpos
 
QReadWriteLock rbwlock
 
int rbwpos
 
volatile bool stopreads
 
QReadWriteLock rwlock
 
QString safefilename
 
QString filename
 
QString subtitlefilename
 
QString lastError
 
ThreadedFileWritertfw
 
int fd2
 
bool writemode
 
RemoteFileremotefile
 
uint bufferSize
 
bool low_buffers
 
bool fileismatroska
 
bool unknownbitrate
 
bool startreadahead
 
char * readAheadBuffer
 
bool readaheadrunning
 
bool reallyrunning
 
bool request_pause
 
bool paused
 
bool ateof
 
bool waitforwrite
 
bool beingwritten
 
bool readsallowed
 
bool readsdesired
 
volatile bool recentseek
 
bool setswitchtonext
 
uint rawbitrate
 
float playspeed
 
int fill_threshold
 
int fill_min
 
int readblocksize
 
int wanttoread
 
int numfailures
 
bool commserror
 
bool oldfile
 
LiveTVChainlivetvchain
 
bool ignoreliveeof
 
long long readAdjust
 
int readOffset
 
bool readInternalMode
 
bool bitrateMonitorEnabled
 
QMutex decoderReadLock
 
QMap< qint64, uint64_t > decoderReads
 
QMutex storageReadLock
 
QMap< qint64, uint64_t > storageReads
 
QWaitCondition generalWait
 Condition to signal that the read ahead thread is running. More...
 
- Protected Attributes inherited from MThread
MThreadInternalm_thread
 
QRunnable * m_runnable
 
bool m_prolog_executed
 
bool m_epilog_executed
 

Private Attributes

bool bitrateInitialized
 

Static Private Attributes

static bool gAVformat_net_initialised = false
 

Friends

class ICRingBuffer
 

Additional Inherited Members

- Static Protected Member Functions inherited from MThread
static void setTerminationEnabled (bool enabled=true)
 
static void sleep (unsigned long time)
 
static void msleep (unsigned long time)
 
static void usleep (unsigned long time)
 
static void ThreadSetup (const QString &)
 This is to be called on startup in those few threads that haven't been ported to MThread. More...
 
static void ThreadCleanup (void)
 This is to be called on exit in those few threads that haven't been ported to MThread. More...
 
static void Cleanup (void)
 This will print out all the running threads, call exit(1) on each and then wait up to 5 seconds total for all the threads to exit. More...
 
static void GetAllThreadNames (QStringList &list)
 
static void GetAllRunningThreadNames (QStringList &list)
 
- Static Protected Attributes inherited from MThread
static const int kDefaultStartTimeout
 

Detailed Description

Implements a file/stream reader/writer.

This class, despite its name, no-longer provides a ring buffer. It can buffer reads and provide support for streaming files. It also provides a wrapper for the ThreadedFileWriter which makes sure that the file reader does not read past where the wrapped TFW has written new data.

Definition at line 45 of file libs/libmythtv/ringbuffer.h.

Constructor & Destructor Documentation

RingBuffer::~RingBuffer ( void  )
pure virtual

Deletes Classes inheriting from RingBuffer must implement a destructor that calls KillReadAheadThread().

We can not do that here because this would leave pure virtual functions without implementations during destruction.

Definition at line 276 of file ringbuffer.cpp.

RingBuffer::RingBuffer ( RingBufferType  rbtype)
protected

Definition at line 218 of file ringbuffer.cpp.

Member Function Documentation

RingBuffer * RingBuffer::Create ( const QString &  xfilename,
bool  write,
bool  usereadahead = true,
int  timeout_ms = kDefaultOpenTimeout,
bool  stream_only = false 
)
static

Creates a RingBuffer instance.

You can explicitly disable the readahead thread by setting readahead to false, or by just not calling Start(void).

Parameters
lfilenameName of file to read or write.
writeIf true an encapsulated writer is created
readaheadIf false a call to Start(void) will not a pre-buffering thread, otherwise Start(void) will start a pre-buffering thread.
timeout_msif < 0, then we will not open the file. Otherwise it's how long to try opening the file after the first failure in milliseconds before giving up.
stream_onlyIf true, prevent DVD and Bluray (used by FileTransfer)

Definition at line 110 of file ringbuffer.cpp.

Referenced by CopyFile(), FlagCommercials(), TVRec::GetProgramRingBufferForLiveTV(), PreviewGenerator::GetScreenGrab(), TV::HandleStateChange(), NuppelVideoRecorder::Initialize(), mythfile_open(), AVFormatWriter::OpenFile(), pid_counter(), pid_filter(), pid_printer(), RebuildSeekTable(), ImportRecorder::run(), RunCCExtract(), TV::SwitchInputs(), TVRec::SwitchRecordingRingBuffer(), VideoPerformanceTest::Test(), Transcode::TranscodeFile(), and TVRec::TuningNewRecorder().

void RingBuffer::SetWriteBufferSize ( int  newSize)
void RingBuffer::SetWriteBufferMinWriteSize ( int  newMinSize)

Calls ThreadedFileWriter::SetWriteBufferMinWriteSize(int)

Definition at line 1838 of file ringbuffer.cpp.

void RingBuffer::SetOldFile ( bool  is_old)

Tell RingBuffer if this is an old file or not.

Normally the RingBuffer determines that the file is old if it has not been modified in the last minute. This allows one to override that determination externally.

If for instance you are slowly writing to the file you could call this with the value of false. If you just finished writing the file you could call it with the value true. Knowing that the file is old allows MythTV to determine that a read at the end of the file is really an end-of-file condition more quickly. But if the file is growing it can also cause the RingBuffer to report an end-of-file condition prematurely.

Definition at line 1873 of file ringbuffer.cpp.

Referenced by FileTransfer::SetTimeout(), and SetTimeout().

void RingBuffer::UpdateRawBitrate ( uint  rawbitrate)

Set the raw bit rate, to allow RingBuffer adjust effective bitrate.

Parameters
raw_bitrateStreams average number of kilobits per second when playspeed is 1.0

Definition at line 337 of file ringbuffer.cpp.

Referenced by NuppelDecoder::GetFrame(), MythPlayer::JumpToProgram(), MythPlayer::JumpToStream(), NuppelDecoder::OpenFile(), AvFormatDecoder::ScanStreams(), and MythPlayer::SwitchToProgram().

void RingBuffer::UpdatePlaySpeed ( float  playspeed)

Set the play speed, to allow RingBuffer adjust effective bitrate.

Parameters
play_speedSpeed to set. (1.0 for normal speed)

Definition at line 368 of file ringbuffer.cpp.

void RingBuffer::EnableBitrateMonitor ( bool  enable)
inline

Definition at line 62 of file libs/libmythtv/ringbuffer.h.

Referenced by TV::timerEvent(), and TV::ToggleOSDDebug().

void RingBuffer::SetBufferSizeFactors ( bool  estbitrate,
bool  matroska 
)

Tells RingBuffer that the raw bitrate may be innacurate and the underlying container is matroska, both of which may require a larger buffer size.

Definition at line 381 of file ringbuffer.cpp.

Referenced by AvFormatDecoder::ScanStreams().

void RingBuffer::SetWaitForWrite ( void  )
inline

Definition at line 64 of file libs/libmythtv/ringbuffer.h.

Referenced by RunCCExtract().

QString RingBuffer::GetSafeFilename ( void  )
inline

Definition at line 67 of file libs/libmythtv/ringbuffer.h.

Referenced by MythPlayer::GetPlaybackData().

QString RingBuffer::GetFilename ( void  ) const
QString RingBuffer::GetSubtitleFilename ( void  ) const

Definition at line 1890 of file ringbuffer.cpp.

Referenced by MythPlayer::JumpToProgram().

QString RingBuffer::GetLastError ( void  ) const
bool RingBuffer::GetCommsError ( void  ) const
inline

Definition at line 71 of file libs/libmythtv/ringbuffer.h.

Referenced by MythPlayer::EventLoop().

void RingBuffer::ResetCommsError ( void  )
inline

Definition at line 72 of file libs/libmythtv/ringbuffer.h.

Referenced by MythPlayer::EventLoop().

bool RingBuffer::GetStopReads ( void  ) const
inline

Returns value of stopreads.

See also
StartReads(void), StopReads(void)

Definition at line 76 of file libs/libmythtv/ringbuffer.h.

Referenced by FileTransfer::RequestBlock().

bool RingBuffer::isPaused ( void  ) const

Returns false iff read-ahead is not running and read-ahead is not paused.

Definition at line 789 of file ringbuffer.cpp.

virtual long long RingBuffer::GetReadPosition ( void  ) const
pure virtual
QString RingBuffer::GetDecoderRate ( void  )

Definition at line 1660 of file ringbuffer.cpp.

Referenced by MythPlayer::GetPlaybackData().

QString RingBuffer::GetStorageRate ( void  )

Definition at line 1665 of file ringbuffer.cpp.

Referenced by MythPlayer::GetPlaybackData().

QString RingBuffer::GetAvailableBuffer ( void  )

Definition at line 1670 of file ringbuffer.cpp.

Referenced by MythPlayer::GetPlaybackData().

uint RingBuffer::GetBufferSize ( void  )
inline

Definition at line 83 of file libs/libmythtv/ringbuffer.h.

Referenced by MythPlayer::GetPlaybackData().

long long RingBuffer::GetWritePosition ( void  ) const
long long RingBuffer::GetRealFileSize ( void  ) const
bool RingBuffer::IsNearEnd ( double  fps,
uint  vvf 
) const

Definition at line 467 of file ringbuffer.cpp.

Referenced by MythPlayer::IsReallyNearEnd().

virtual bool RingBuffer::IsOpen ( void  ) const
pure virtual
virtual bool RingBuffer::IsStreamed ( void  )
inlinevirtual
virtual bool RingBuffer::IsSeekingAllowed ( void  )
inlinevirtual
virtual bool RingBuffer::IsBookmarkAllowed ( void  )
inlinevirtual
virtual int RingBuffer::BestBufferSize ( void  )
inlinevirtual

Reimplemented in DVDRingBuffer.

Definition at line 94 of file libs/libmythtv/ringbuffer.h.

Referenced by AvFormatDecoder::InitByteContext().

QString RingBuffer::BitrateToString ( uint64_t  rate,
bool  hz = false 
)
static

Definition at line 1627 of file ringbuffer.cpp.

Referenced by GetDecoderRate(), MythPlayer::GetPlaybackData(), and GetStorageRate().

RingBufferType RingBuffer::GetType ( void  ) const
inline
int RingBuffer::GetReadBufAvail ( void  ) const

Returns number of bytes available for reading from buffer.

Definition at line 520 of file ringbuffer.cpp.

bool RingBuffer::SetReadInternalMode ( bool  mode)

Definition at line 588 of file ringbuffer.cpp.

Referenced by AVFRingBuffer::SetInInit().

bool RingBuffer::IsReadInternalMode ( void  )
inline

Definition at line 101 of file libs/libmythtv/ringbuffer.h.

bool RingBuffer::IsDisc ( void  ) const
inline
bool RingBuffer::IsDVD ( void  ) const
inline

Definition at line 105 of file libs/libmythtv/ringbuffer.h.

Referenced by MythDVDPlayer::CalcMaxFFTime(), MythDVDPlayer::ChangeSpeed(), TV::ChangeVolume(), MythDVDPlayer::DecoderGetFrameREW(), MythDVDPlayer::DisableCaptions(), MythDVDPlayer::DisplayDVDButton(), MythDVDPlayer::DisplayPauseFrame(), DecoderBase::DoFastForward(), AvFormatDecoderDVD::DoFastForwardSeek(), MythDVDPlayer::DoJumpChapter(), AvFormatDecoderDVD::DoRewindSeek(), AvFormatDecoderDVD::DVDFindPosition(), MythDVDPlayer::EnableCaptions(), AvFormatDecoderDVD::GetAudioLanguage(), MythDVDPlayer::GetBookmark(), MythDVDPlayer::GetChapterTimes(), MythDVDPlayer::GetCurrentChapter(), MythDVDPlayer::GetNumChapters(), MythDVDPlayer::GetSecondsPlayed(), AvFormatDecoder::GetTrackDesc(), MythDVDPlayer::GoToDVDProgram(), MythDVDPlayer::GoToMenu(), TV::HandleLCDTimerEvent(), TV::HandleStateChange(), AvFormatDecoder::InitVideoCodec(), IsDisc(), AvFormatDecoder::MpegPreProcessPkt(), AvFormatDecoder::OpenFile(), DecoderBase::PosMapFromDb(), AvFormatDecoderDVD::PostProcessTracks(), MythDVDPlayer::PrepareAudioSample(), TV::ProcessKeypress(), TV::ProcessNetworkControlCommand(), AvFormatDecoder::ProcessSubtitlePacket(), AvFormatDecoder::ProcessVideoFrame(), AvFormatDecoder::ProcessVideoPacket(), ReadDirect(), AvFormatDecoder::ScanStreams(), MythDVDPlayer::SeekForScreenGrab(), AvFormatDecoder::SeekReset(), MythDVDPlayer::SetBookmark(), TV::ShowLCDDVDInfo(), TV::ShowOSDStopWatchingRecording(), MythDVDPlayer::StillFrameCheck(), AvFormatDecoderDVD::StreamChangeCheck(), DecoderBase::SyncPositionMap(), AvFormatDecoderDVD::UpdateFramesPlayed(), and MythDVDPlayer::VideoLoop().

bool RingBuffer::IsBD ( void  ) const
inline
const DVDRingBuffer * RingBuffer::DVD ( void  ) const

Definition at line 1948 of file ringbuffer.cpp.

Referenced by TV::ActiveHandleAction(), MythDVDPlayer::CalcMaxFFTime(), MythDVDPlayer::ChangeSpeed(), AvFormatDecoderDVD::CheckContext(), MythDVDPlayer::DecoderGetFrameREW(), MythDVDPlayer::DisableCaptions(), MythDVDPlayer::DisplayDVDButton(), MythDVDPlayer::DisplayPauseFrame(), DecoderBase::DoFastForward(), MythDVDPlayer::DoJumpChapter(), AvFormatDecoderDVD::DVDFindPosition(), MythDVDPlayer::EnableCaptions(), MythDVDPlayer::EventEnd(), MythDVDPlayer::EventStart(), AvFormatDecoderDVD::GetAudioLanguage(), AvFormatDecoderDVD::GetAudioTrackType(), MythDVDPlayer::GetBookmark(), MythDVDPlayer::GetChapterTimes(), MythDVDPlayer::GetCurrentAngle(), MythDVDPlayer::GetCurrentChapter(), MythDVDPlayer::GetNumAngles(), MythDVDPlayer::GetNumChapters(), MythDVDPlayer::GetSecondsPlayed(), MythDVDPlayer::GoToDVDProgram(), MythDVDPlayer::GoToMenu(), MythDVDPlayer::InitialSeek(), AvFormatDecoder::MpegPreProcessPkt(), DecoderBase::PosMapFromDb(), AvFormatDecoderDVD::PostProcessTracks(), MythDVDPlayer::PrepareAudioSample(), AvFormatDecoderDVD::ProcessDataPacket(), AvFormatDecoder::ProcessSubtitlePacket(), AvFormatDecoderDVD::ProcessVideoPacket(), AvFormatDecoderDVD::ReadPacket(), AvFormatDecoder::ScanStreams(), MythDVDPlayer::SeekForScreenGrab(), MythDVDPlayer::SetBookmark(), MythDVDPlayer::SetTrack(), TV::ShowLCDDVDInfo(), MythDVDPlayer::StillFrameCheck(), AvFormatDecoderDVD::StreamChangeCheck(), MythDVDPlayer::SwitchAngle(), DecoderBase::SyncPositionMap(), AvFormatDecoderDVD::UpdateFramesPlayed(), MythDVDPlayer::VideoLoop(), and MythDVDPlayer::VideoStart().

const BDRingBuffer * RingBuffer::BD ( void  ) const
DVDRingBuffer * RingBuffer::DVD ( void  )

Definition at line 1958 of file ringbuffer.cpp.

BDRingBuffer * RingBuffer::BD ( void  )

Definition at line 1963 of file ringbuffer.cpp.

virtual bool RingBuffer::StartFromBeginning ( void  )
inlinevirtual

Reimplemented in DVDRingBuffer, and BDRingBuffer.

Definition at line 111 of file libs/libmythtv/ringbuffer.h.

Referenced by AvFormatDecoder::OpenFile().

virtual void RingBuffer::IgnoreWaitStates ( bool  ignore)
inlinevirtual
virtual bool RingBuffer::IsInMenu ( void  ) const
inlinevirtual

Reimplemented in DVDRingBuffer, and BDRingBuffer.

Definition at line 113 of file libs/libmythtv/ringbuffer.h.

Referenced by IsInDiscMenuOrStillFrame(), and MythDVDPlayer::SetBookmark().

virtual bool RingBuffer::IsInStillFrame ( void  ) const
inlinevirtual
virtual bool RingBuffer::IsInDiscMenuOrStillFrame ( void  ) const
inlinevirtual
virtual bool RingBuffer::HandleAction ( const QStringList &  ,
int64_t   
)
inlinevirtual

Reimplemented in DVDRingBuffer, and BDRingBuffer.

Definition at line 116 of file libs/libmythtv/ringbuffer.h.

Referenced by TV::DiscMenuHandleAction().

virtual bool RingBuffer::OpenFile ( const QString &  lfilename,
uint  retry_ms = kDefaultOpenTimeout 
)
pure virtual

Opens a file for reading.

Parameters
lfilenameName of file to read
retry_msHow many ms to retry reading the file after the first try before giving up.

Implemented in DVDRingBuffer, BDRingBuffer, HLSRingBuffer, DVDStream, FileRingBuffer, ICRingBuffer, and StreamingRingBuffer.

Referenced by MythPlayer::JumpToProgram(), MythPlayer::JumpToStream(), and MythPlayer::SwitchToProgram().

virtual bool RingBuffer::ReOpen ( QString  newFilename = "")
inlinevirtual

Reimplemented in FileRingBuffer.

Definition at line 128 of file libs/libmythtv/ringbuffer.h.

Referenced by FileTransfer::ReOpen(), and AVFormatWriter::ReOpen().

int RingBuffer::Read ( void buf,
int  count 
)

This is the public method for reading from a file, it calls the appropriate read method if the file is remote or buffered, or a BD/DVD.

Parameters
bufPointer to where data will be written
countNumber of bytes to read
Returns
Returns number of bytes read

Definition at line 1613 of file ringbuffer.cpp.

Referenced by AVFRingBuffer::AVF_Read(), CopyFile(), NuppelDecoder::GetFrame(), NuppelDecoder::OpenFile(), pid_counter(), pid_filter(), pid_printer(), NuppelDecoder::ReadFileheader(), NuppelDecoder::ReadFrameheader(), and FileTransfer::RequestBlock().

int RingBuffer::Peek ( void buf,
int  count 
)

Definition at line 1283 of file ringbuffer.cpp.

Referenced by MythPlayer::OpenFile().

void RingBuffer::Reset ( bool  full = false,
bool  toAdjust = false,
bool  resetInternal = false 
)

Resets the read-ahead thread and our position in the file.

Definition at line 295 of file ringbuffer.cpp.

Referenced by MythPlayer::FileChangedCallback(), MythPlayer::JumpToProgram(), ICRingBuffer::OpenFile(), and MythPlayer::SwitchToProgram().

long long RingBuffer::Seek ( long long  pos,
int  whence,
bool  has_lock = false 
)
void RingBuffer::Pause ( void  )

Pauses the read-ahead thread.

Calls StopReads(void).

See also
Unpause(void), WaitForPause(void)

Definition at line 763 of file ringbuffer.cpp.

Referenced by ICRingBuffer::OpenFile(), MythPlayer::PauseBuffer(), TV::StopStuff(), and TV::SwitchInputs().

void RingBuffer::Unpause ( void  )

Unpauses the read-ahead thread.

Calls StartReads(void).

See also
Pause(void)

Definition at line 777 of file ringbuffer.cpp.

Referenced by TV::CreatePBP(), TV::RestartAllPlayers(), MythPlayer::SwitchToProgram(), ICRingBuffer::Take(), and MythPlayer::UnpauseBuffer().

void RingBuffer::WaitForPause ( void  )

Waits for Pause(void) to take effect.

Definition at line 800 of file ringbuffer.cpp.

Referenced by TV::DoTogglePauseFinish(), MythPlayer::PauseBuffer(), TV::StopStuff(), and TV::SwitchInputs().

void RingBuffer::Start ( void  )

Starts the read-ahead thread.

If the RingBuffer constructor was not called with a usereadahead of true of if this was reset to false because we're dealing with a DVD the read ahead thread will not be started.

If this RingBuffer is in write-mode a warning will be printed and the read ahead thread will not be started.

If the read ahead thread is already running a warning will be printed and the read ahead thread will not be started.

Definition at line 683 of file ringbuffer.cpp.

Referenced by FileTransfer::FileTransfer(), mythfile_open(), and MythPlayer::OpenFile().

void RingBuffer::StopReads ( void  )
void RingBuffer::StartReads ( void  )
bool RingBuffer::LiveMode ( void  ) const

Returns true if this RingBuffer has been assigned a LiveTVChain.

See also
SetLiveMode(LiveTVChain*)

Definition at line 1921 of file ringbuffer.cpp.

Referenced by NuppelDecoder::GetFrame(), NuppelVideoRecorder::Initialize(), IsStreamed(), and MythPlayer::OpenFile().

void RingBuffer::SetLiveMode ( LiveTVChain chain)

Assigns a LiveTVChain to this RingBuffer.

See also
LiveMode(void)

Definition at line 1933 of file ringbuffer.cpp.

Referenced by TV::HandleStateChange(), and TV::SwitchInputs().

void RingBuffer::IgnoreLiveEOF ( bool  ignore)

Tells RingBuffer whether to ignore the end-of-file.

Definition at line 1941 of file ringbuffer.cpp.

Referenced by MythPlayer::JumpToProgram(), TV::PauseLiveTV(), TV::SwitchInputs(), and TV::UnpauseLiveTV().

int RingBuffer::Write ( const void buf,
uint  count 
)
bool RingBuffer::IsIOBound ( void  ) const
void RingBuffer::WriterFlush ( void  )
void RingBuffer::Sync ( void  )

Calls ThreadedFileWriter::Sync(void)

Definition at line 1791 of file ringbuffer.cpp.

long long RingBuffer::WriterSeek ( long long  pos,
int  whence,
bool  has_lock = false 
)
bool RingBuffer::WriterSetBlocking ( bool  lock = true)
long long RingBuffer::SetAdjustFilesize ( void  )

Definition at line 1272 of file ringbuffer.cpp.

Referenced by MythPlayer::SwitchToProgram().

void RingBuffer::SetTimeout ( bool  is_old)
inline
Deprecated:
Calls SetOldFile(), do not use

Definition at line 166 of file libs/libmythtv/ringbuffer.h.

void RingBuffer::AVFormatInitNetwork ( void  )
static
void RingBuffer::run ( void  )
protectedvirtual

Runs the Qt event loop unless we have a QRunnable, in which case we run the runnable run instead.

Note
If you override this method you must call RunProlog before you do any work and RunEpilog before you exit the run method.

Reimplemented from MThread.

Definition at line 910 of file ringbuffer.cpp.

void RingBuffer::CreateReadAheadBuffer ( void  )
protected

Definition at line 862 of file ringbuffer.cpp.

Referenced by run(), and SetBufferSizeFactors().

void RingBuffer::CalcReadAheadThresh ( void  )
protected

Calculates fill_min, fill_threshold, and readblocksize from the estimated effective bitrate of the stream.

WARNING: Must be called with rwlock in write lock state.

Definition at line 397 of file ringbuffer.cpp.

Referenced by CreateReadAheadBuffer(), ICRingBuffer::OpenFile(), FileRingBuffer::OpenFile(), BDRingBuffer::OpenFile(), DVDRingBuffer::OpenFile(), ResetReadAhead(), run(), UpdatePlaySpeed(), and UpdateRawBitrate().

bool RingBuffer::PauseAndWait ( void  )
protected

Definition at line 819 of file ringbuffer.cpp.

Referenced by run().

virtual int RingBuffer::safe_read ( void data,
uint  sz 
)
protectedpure virtual
int RingBuffer::ReadPriv ( void buf,
int  count,
bool  peek 
)
protected

When possible reads from the read-ahead buffer, otherwise reads directly from the device.

Parameters
bufPointer to where data will be written
countNumber of bytes to read
peekIf true, don't increment read count
Returns
Returns number of bytes read

Definition at line 1446 of file ringbuffer.cpp.

Referenced by Peek(), and Read().

int RingBuffer::ReadDirect ( void buf,
int  count,
bool  peek 
)
protected

Definition at line 1368 of file ringbuffer.cpp.

Referenced by ReadPriv().

bool RingBuffer::WaitForReadsAllowed ( void  )
protected

Definition at line 1295 of file ringbuffer.cpp.

Referenced by ReadPriv().

int RingBuffer::WaitForAvail ( int  count,
int  timeout 
)
protected

Definition at line 1326 of file ringbuffer.cpp.

Referenced by ReadPriv().

virtual long long RingBuffer::GetRealFileSizeInternal ( void  ) const
inlineprotectedvirtual

Reimplemented in HLSRingBuffer, FileRingBuffer, ICRingBuffer, and StreamingRingBuffer.

Definition at line 186 of file libs/libmythtv/ringbuffer.h.

Referenced by GetRealFileSize().

virtual long long RingBuffer::SeekInternal ( long long  pos,
int  whence 
)
protectedpure virtual
int RingBuffer::ReadBufFree ( void  ) const
protected

Returns number of bytes available for reading into buffer.

WARNING: Must be called with rwlock in locked state.

Definition at line 509 of file ringbuffer.cpp.

Referenced by run().

int RingBuffer::ReadBufAvail ( void  ) const
protected

Returns number of bytes available for reading from buffer.

WARNING: Must be called with rwlock in locked state.

Definition at line 619 of file ringbuffer.cpp.

Referenced by GetReadBufAvail(), GetRealFileSize(), ReadPriv(), Seek(), and WaitForAvail().

void RingBuffer::ResetReadAhead ( long long  newinternal)
protected

Restart the read-ahead thread at the 'newinternal' position.

This is called after a Seek(long long, int) so that the read-ahead buffer doesn't contain any stale data, and so that it will read any new data from the new position in the file.

WARNING: Must be called with rwlock and poslock in write lock state.

Parameters
newinternalPosition in file to start reading data from

Definition at line 640 of file ringbuffer.cpp.

Referenced by Reset(), run(), ICRingBuffer::SeekInternal(), FileRingBuffer::SeekInternal(), BDRingBuffer::SeekInternal(), and DVDRingBuffer::SeekInternal().

void RingBuffer::KillReadAheadThread ( void  )
protected
uint64_t RingBuffer::UpdateDecoderRate ( uint64_t  latest = 0)
protected

Definition at line 1679 of file ringbuffer.cpp.

Referenced by GetDecoderRate(), and Read().

uint64_t RingBuffer::UpdateStorageRate ( uint64_t  latest = 0)
protected

Definition at line 1713 of file ringbuffer.cpp.

Referenced by GetStorageRate(), ReadDirect(), and run().

Friends And Related Function Documentation

friend class ICRingBuffer
friend

Definition at line 47 of file libs/libmythtv/ringbuffer.h.

Member Data Documentation

const int RingBuffer::kDefaultOpenTimeout = 2000
static

Definition at line 168 of file libs/libmythtv/ringbuffer.h.

Referenced by mythfile_open().

const int RingBuffer::kLiveTVOpenTimeout = 10000
static
RingBufferType RingBuffer::type
protected

Definition at line 199 of file libs/libmythtv/ringbuffer.h.

QReadWriteLock RingBuffer::poslock
mutableprotected
long long RingBuffer::readpos
protected
long long RingBuffer::writepos
protected
long long RingBuffer::internalreadpos
protected
long long RingBuffer::ignorereadpos
protected
QReadWriteLock RingBuffer::rbrlock
mutableprotected
int RingBuffer::rbrpos
protected
QReadWriteLock RingBuffer::rbwlock
mutableprotected
int RingBuffer::rbwpos
protected
volatile bool RingBuffer::stopreads
protected
QReadWriteLock RingBuffer::rwlock
mutableprotected
QString RingBuffer::safefilename
protected
QString RingBuffer::filename
protected
QString RingBuffer::subtitlefilename
protected

Definition at line 218 of file libs/libmythtv/ringbuffer.h.

Referenced by GetSubtitleFilename(), and FileRingBuffer::OpenFile().

QString RingBuffer::lastError
protected
ThreadedFileWriter* RingBuffer::tfw
protected
int RingBuffer::fd2
protected
bool RingBuffer::writemode
protected
RemoteFile* RingBuffer::remotefile
protected
uint RingBuffer::bufferSize
protected
bool RingBuffer::low_buffers
protected

Definition at line 229 of file libs/libmythtv/ringbuffer.h.

Referenced by CalcReadAheadThresh(), and WaitForAvail().

bool RingBuffer::fileismatroska
protected

Definition at line 230 of file libs/libmythtv/ringbuffer.h.

Referenced by CreateReadAheadBuffer(), and SetBufferSizeFactors().

bool RingBuffer::unknownbitrate
protected

Definition at line 231 of file libs/libmythtv/ringbuffer.h.

Referenced by CreateReadAheadBuffer(), and SetBufferSizeFactors().

bool RingBuffer::startreadahead
protected
char* RingBuffer::readAheadBuffer
protected

Definition at line 233 of file libs/libmythtv/ringbuffer.h.

Referenced by CreateReadAheadBuffer(), ReadPriv(), run(), and ~RingBuffer().

bool RingBuffer::readaheadrunning
protected
bool RingBuffer::reallyrunning
protected

Definition at line 235 of file libs/libmythtv/ringbuffer.h.

Referenced by run(), and Start().

bool RingBuffer::request_pause
protected
bool RingBuffer::paused
protected

Definition at line 237 of file libs/libmythtv/ringbuffer.h.

Referenced by IsNearEnd(), isPaused(), PauseAndWait(), and WaitForPause().

bool RingBuffer::ateof
protected
bool RingBuffer::waitforwrite
protected

Definition at line 239 of file libs/libmythtv/ringbuffer.h.

Referenced by run(), and SetWaitForWrite().

bool RingBuffer::beingwritten
protected

Definition at line 240 of file libs/libmythtv/ringbuffer.h.

Referenced by run().

bool RingBuffer::readsallowed
protected
bool RingBuffer::readsdesired
protected
volatile bool RingBuffer::recentseek
protected
bool RingBuffer::setswitchtonext
protected
uint RingBuffer::rawbitrate
protected
float RingBuffer::playspeed
protected

Definition at line 246 of file libs/libmythtv/ringbuffer.h.

Referenced by CalcReadAheadThresh(), IsNearEnd(), and UpdatePlaySpeed().

int RingBuffer::fill_threshold
protected

Definition at line 247 of file libs/libmythtv/ringbuffer.h.

Referenced by CalcReadAheadThresh(), and run().

int RingBuffer::fill_min
protected
int RingBuffer::readblocksize
protected
int RingBuffer::wanttoread
protected

Definition at line 250 of file libs/libmythtv/ringbuffer.h.

Referenced by ReadPriv(), and WaitForAvail().

int RingBuffer::numfailures
protected
bool RingBuffer::commserror
protected
bool RingBuffer::oldfile
protected
LiveTVChain* RingBuffer::livetvchain
protected
bool RingBuffer::ignoreliveeof
protected

Definition at line 257 of file libs/libmythtv/ringbuffer.h.

Referenced by IgnoreLiveEOF(), and run().

long long RingBuffer::readAdjust
protected
int RingBuffer::readOffset
protected

Definition at line 262 of file libs/libmythtv/ringbuffer.h.

Referenced by ReadPriv(), ResetReadAhead(), Seek(), and SetReadInternalMode().

bool RingBuffer::readInternalMode
protected
bool RingBuffer::bitrateMonitorEnabled
protected
QMutex RingBuffer::decoderReadLock
protected

Definition at line 267 of file libs/libmythtv/ringbuffer.h.

Referenced by UpdateDecoderRate().

QMap<qint64, uint64_t> RingBuffer::decoderReads
protected

Definition at line 268 of file libs/libmythtv/ringbuffer.h.

Referenced by UpdateDecoderRate().

QMutex RingBuffer::storageReadLock
protected

Definition at line 269 of file libs/libmythtv/ringbuffer.h.

Referenced by UpdateStorageRate().

QMap<qint64, uint64_t> RingBuffer::storageReads
protected

Definition at line 270 of file libs/libmythtv/ringbuffer.h.

Referenced by UpdateStorageRate().

QWaitCondition RingBuffer::generalWait
protected
QMutex RingBuffer::subExtLock
static
QStringList RingBuffer::subExt
static
QStringList RingBuffer::subExtNoCheck
static

Definition at line 284 of file libs/libmythtv/ringbuffer.h.

Referenced by is_subtitle_possible(), and RingBuffer().

bool RingBuffer::gAVformat_net_initialised = false
staticprivate

Definition at line 287 of file libs/libmythtv/ringbuffer.h.

Referenced by AVFormatInitNetwork().

bool RingBuffer::bitrateInitialized
private

Definition at line 288 of file libs/libmythtv/ringbuffer.h.

Referenced by CalcReadAheadThresh(), and UpdateRawBitrate().


The documentation for this class was generated from the following files: