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

#include <ringbuffer.h>

Inheritance diagram for RingBuffer:

Collaboration diagram for RingBuffer:

Public Member Functions
virtual	~RingBuffer ()=0
	Deletes Classes inheriting from RingBuffer must implement a destructor that calls KillReadAheadThread().
void	SetWriteBufferSize (int newSize)
void	SetWriteBufferMinWriteSize (int newMinSize)
	Calls ThreadedFileWriter::SetWriteBufferMinWriteSize(int)
void	SetOldFile (bool is_old)
	Tell RingBuffer if this is an old file or not.
void	UpdateRawBitrate (uint rawbitrate)
	Set the raw bit rate, to allow RingBuffer adjust effective bitrate.
void	UpdatePlaySpeed (float playspeed)
	Set the play speed, to allow RingBuffer adjust effective bitrate.
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.
QString	GetSafeFilename (void)
QString	GetFilename (void) const
	Returns name of file used by this RingBuffer.
QString	GetSubtitleFilename (void) const
bool	GetStopReads (void) const
	Returns value of stopreads.
bool	isPaused (void) const
	Returns false iff read-ahead is not running and read-ahead is not paused.
virtual long long	GetReadPosition (void) const =0
	Returns how far into the file we have read.
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.
virtual long long	GetRealFileSize (void) const
	Returns the size of the file we are reading/writing, or -1 if the query fails.
bool	IsNearEnd (double fps, uint vvf) const
virtual bool	IsOpen (void) const =0
	Returns true if open for either reading or writing.
virtual bool	IsStreamed (void)
virtual bool	IsSeekingAllowed (void)
virtual bool	IsBookmarkAllowed (void)
virtual int	BestBufferSize (void)
RingBufferType	GetType () const
bool	IsDisc (void) const
bool	IsDVD (void) const
bool	IsBD (void) const
const DVDRingBuffer *	DVD (void) const
const BDRingBuffer *	BD (void) const
DVDRingBuffer *	DVD (void)
BDRingBuffer *	BD (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.
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.
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.
virtual long long	Seek (long long pos, int whence, bool has_lock=false)=0
	Seeks to a particular position in the file.
void	Pause (void)
	Pauses the read-ahead thread.
void	Unpause (void)
	Unpauses the read-ahead thread.
void	WaitForPause (void)
	Waits for Pause(void) to take effect.
void	Start (void)
	Starts the read-ahead thread.
void	StopReads (void)
	????
void	StartReads (void)
	????
bool	LiveMode (void) const
	Returns true if this RingBuffer has been assigned a LiveTVChain.
void	SetLiveMode (LiveTVChain *chain)
	Assigns a LiveTVChain to this RingBuffer.
void	IgnoreLiveEOF (bool ignore)
	Tells RingBuffer whether to igonre the end-of-file.
int	Write (const void *buf, uint count)
	Writes buffer to ThreadedFileWriter::Write(const void*,uint)
bool	IsIOBound (void) const
void	WriterFlush (void)
	Calls ThreadedFileWriter::Flush(void)
void	Sync (void)
	Calls ThreadedFileWriter::Sync(void)
long long	WriterSeek (long long pos, int whence, bool has_lock=false)
	Calls ThreadedFileWriter::Seek(long long,int).
long long	SetAdjustFilesize (void)
void	SetTimeout (bool is_old) MDEPRECATED
	Calls SetOldFile(), do not use.

Static Public Member Functions
static RingBuffer *	Create (const QString &lfilename, bool write, bool usereadahead=true, int timeout_ms=kDefaultOpenTimeout, bool stream_only=false)
	Creates a RingBuffer instance.
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.
void	CreateReadAheadBuffer (void)
void	CalcReadAheadThresh (void)
	Calculates fill_min, fill_threshold, and readblocksize from the estimated effective bitrate of the stream.
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.
int	ReadDirect (void *buf, int count, bool peek)
bool	WaitForReadsAllowed (void)
bool	WaitForAvail (int count)
int	ReadBufFree (void) const
	Returns number of bytes available for reading into buffer.
int	ReadBufAvail (void) const
	Returns number of bytes available for reading from buffer.
void	ResetReadAhead (long long newinternal)
	Restart the read-ahead thread at the 'newinternal' position.
void	KillReadAheadThread (void)
	Stops the read-ahead thread, and waits for it to stop.
uint64_t	UpdateDecoderRate (uint64_t latest=0)
uint64_t	UpdateStorageRate (uint64_t latest=0)
Protected Member Functions inherited from MThread
	MThread (const QString &objectName)
	Standard constructor.
	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.
virtual	~MThread ()
void	RunProlog (void)
	Sets up a thread, call this if you reimplement run().
void	RunEpilog (void)
	Cleans up a thread's resources, call this if you reimplement run().
QThread *	qthread (void)
	Returns the thread, this will always return the same pointer no matter how often you restart the thread.
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.
void	start (QThread::Priority=QThread::InheritPriority)
	Tell MThread to start running the thread in the near future.
void	terminate (void)
	Kill a thread unsafely.
void	quit (void)
	calls exit(0)
bool	wait (unsigned long time=ULONG_MAX)
	Wait for the MThread to exit, with a maximum timeout.
int	exec (void)
	Enters the qt event loop. call exit or quit to exit thread.

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
ThreadedFileWriter *	tfw
int	fd2
bool	writemode
RemoteFile *	remotefile
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	readsallowed
bool	setswitchtonext
uint	rawbitrate
float	playspeed
int	fill_threshold
int	fill_min
int	readblocksize
int	wanttoread
int	numfailures
bool	commserror
bool	oldfile
LiveTVChain *	livetvchain
bool	ignoreliveeof
long long	readAdjust
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.

Static Private Attributes
static bool	gAVformat_net_initialised = false

Friends
class	ICRingBuffer

Additional Inherited Members
Static Protected Member Functions inherited from MThread
static void	ThreadSetup (const QString &)
	This is to be called on startup in those few threads that haven't been ported to MThread.
static void	ThreadCleanup (void)
	This is to be called on exit in those few threads that haven't been ported to MThread.
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.
static void	GetAllThreadNames (QStringList &list)
static void	GetAllRunningThreadNames (QStringList &list)
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 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 231 of file ringbuffer.cpp.

RingBuffer::RingBuffer ( RingBufferType rbtype )

protected

Definition at line 178 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

lfilename	Name of file to read or write.
write	If true an encapsulated writer is created
readahead	If false a call to Start(void) will not a pre-buffering thread, otherwise Start(void) will start a pre-buffering thread.
timeout_ms	if < 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.

Definition at line 105 of file ringbuffer.cpp.

Referenced by CopyFile(), FlagCommercials(), TVRec::GetProgramRingBufferForLiveTV(), PreviewGenerator::GetScreenGrab(), TV::HandleStateChange(), NuppelVideoRecorder::Initialize(), TextSubtitleParser::LoadSubtitles(), mythfile_open(), AVFormatWriter::OpenFile(), pid_counter(), pid_filter(), pid_printer(), RebuildSeekTable(), ImportRecorder::run(), RunCCExtract(), TV::SwitchCards(), 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 1537 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 1560 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_bitrate Streams average number of kilobits per second when playspeed is 1.0

Definition at line 292 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_speed Speed to set. (1.0 for normal speed)

Definition at line 316 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 329 of file ringbuffer.cpp.

Referenced by AvFormatDecoder::ScanStreams().

QString RingBuffer::GetSafeFilename ( void )

inline

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

Referenced by MythPlayer::GetPlaybackData().

QString RingBuffer::GetFilename ( void ) const

Returns name of file used by this RingBuffer.

Definition at line 1569 of file ringbuffer.cpp.

Referenced by MythBDPlayer::CreateDecoder(), MythDVDPlayer::CreateDecoder(), MythPlayer::CreateDecoder(), TV::customEvent(), FileTransfer::GetFileSize(), NuppelDecoder::OpenFile(), AvFormatDecoder::OpenFile(), MythPlayer::OpenFile(), TV::ProcessNetworkControlCommand(), ImportRecorder::run(), ASIRecorder::run(), NuppelVideoRecorder::run(), and RecorderBase::SetRingBuffer().

QString RingBuffer::GetSubtitleFilename ( void ) const

Definition at line 1577 of file ringbuffer.cpp.

bool RingBuffer::GetStopReads ( void ) const

inline

Returns value of stopreads.

See Also: StartReads(void), StopReads(void)

Definition at line 71 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 613 of file ringbuffer.cpp.

virtual long long RingBuffer::GetReadPosition ( void ) const

pure virtual

Returns how far into the file we have read.

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

Referenced by NuppelDecoder::GetFrame(), NuppelDecoder::OpenFile(), FileTransfer::Seek(), and AvFormatDecoder::SeekReset().

QString RingBuffer::GetDecoderRate ( void )

Definition at line 1359 of file ringbuffer.cpp.

Referenced by MythPlayer::GetPlaybackData().

QString RingBuffer::GetStorageRate ( void )

Definition at line 1364 of file ringbuffer.cpp.

Referenced by MythPlayer::GetPlaybackData().

QString RingBuffer::GetAvailableBuffer ( void )

Definition at line 1369 of file ringbuffer.cpp.

Referenced by MythPlayer::GetPlaybackData().

uint RingBuffer::GetBufferSize ( void )

inline

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

Referenced by MythPlayer::GetPlaybackData().

long long RingBuffer::GetWritePosition ( void ) const

Returns how far into a ThreadedFileWriter file we have written.

Definition at line 1588 of file ringbuffer.cpp.

Referenced by DTVRecorder::FindH264Keyframes(), DTVRecorder::FindMPEG2Keyframes(), TVRec::GetFilePosition(), DTVRecorder::HandleKeyframe(), RecorderBase::SavePositionMap(), NuppelVideoRecorder::UpdateSeekTable(), NuppelVideoRecorder::WriteHeader(), NuppelVideoRecorder::WriteKeyFrameAdjustTable(), and NuppelVideoRecorder::WriteSeekTable().

virtual long long RingBuffer::GetRealFileSize ( void ) const

inlinevirtual

Returns the size of the file we are reading/writing, or -1 if the query fails.

Reimplemented in HLSRingBuffer, ICRingBuffer, StreamingRingBuffer, and FileRingBuffer.

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

Referenced by AVFRingBuffer::AVF_Seek(), CopyFile(), DTVRecorder::FinishRecording(), NuppelVideoRecorder::FinishRecording(), AvFormatDecoder::HandleGopStart(), MythPlayer::JumpToStream(), AvFormatDecoder::OpenFile(), ImportRecorder::run(), and RecorderBase::SetNextRecording().

bool RingBuffer::IsNearEnd	(	double	fps,
		uint	vvf
	)		const

Definition at line 408 of file ringbuffer.cpp.

Referenced by MythPlayer::IsReallyNearEnd().

virtual bool RingBuffer::IsOpen ( void ) const

pure virtual

Returns true if open for either reading or writing.

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

Referenced by CopyFile(), NuppelVideoRecorder::CreateNuppelFile(), PreviewGenerator::GetScreenGrab(), TV::HandleStateChange(), NuppelVideoRecorder::Initialize(), FileTransfer::isOpen(), MythPlayer::JumpToProgram(), MythPlayer::JumpToStream(), TVRec::SwitchRecordingRingBuffer(), MythPlayer::SwitchToProgram(), and TVRec::TuningNewRecorder().

virtual bool RingBuffer::IsStreamed ( void )

inlinevirtual

Reimplemented in DVDRingBuffer, BDRingBuffer, HLSRingBuffer, ICRingBuffer, and StreamingRingBuffer.

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

Referenced by AvFormatDecoder::FindStreamInfo(), and AvFormatDecoder::InitByteContext().

virtual bool RingBuffer::IsSeekingAllowed ( void )

inlinevirtual

Reimplemented in HLSRingBuffer, ICRingBuffer, and StreamingRingBuffer.

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

Referenced by MythPlayer::DoFastForward(), TV::DoPlayerSeek(), TV::DoPlayerSeekToFrame(), MythPlayer::DoRewind(), TV::PlaybackMenuInit(), and TV::SetFFRew().

virtual bool RingBuffer::IsBookmarkAllowed ( void )

inlinevirtual

Reimplemented in DVDRingBuffer, HLSRingBuffer, ICRingBuffer, and StreamingRingBuffer.

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

Referenced by MythPlayer::GetBookmark(), and TV::IsBookmarkAllowed().

virtual int RingBuffer::BestBufferSize ( void )

inlinevirtual

Reimplemented in DVDRingBuffer.

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

Referenced by AvFormatDecoder::InitByteContext().

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

static

Definition at line 1326 of file ringbuffer.cpp.

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

RingBufferType RingBuffer::GetType ( void ) const

inline

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

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

bool RingBuffer::IsDisc ( void ) const

inline

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

Referenced by DecoderBase::DoRewind(), DecoderBase::GetKey(), AvFormatDecoder::OpenFile(), DecoderBase::PosMapFromDb(), and DecoderBase::PosMapFromEnc().

bool RingBuffer::IsDVD ( void ) const

inline

Definition at line 95 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::SetDVDBookmark(), TV::ShowLCDDVDInfo(), TV::ShowOSDStopWatchingRecording(), MythDVDPlayer::StillFrameCheck(), AvFormatDecoderDVD::StreamChangeCheck(), DecoderBase::SyncPositionMap(), AvFormatDecoderDVD::UpdateFramesPlayed(), and MythDVDPlayer::VideoLoop().

const DVDRingBuffer * RingBuffer::DVD ( void ) const

Definition at line 1627 of file ringbuffer.cpp.

const BDRingBuffer * RingBuffer::BD ( void ) const

Definition at line 1632 of file ringbuffer.cpp.

Referenced by AvFormatDecoderBD::BDFindPosition(), MythBDPlayer::DisplayMenu(), MythBDPlayer::DisplayPauseFrame(), MythBDPlayer::EventStart(), AvFormatDecoderBD::GetAudioLanguage(), MythBDPlayer::GetChapter(), MythBDPlayer::GetChapterTimes(), MythBDPlayer::GetCurrentAngle(), MythBDPlayer::GetCurrentChapter(), MythBDPlayer::GetCurrentTitle(), MythBDPlayer::GetNumAngles(), MythBDPlayer::GetNumChapters(), MythBDPlayer::GetNumTitles(), AvFormatDecoderBD::GetSubtitleLanguage(), MythBDPlayer::GetTitleDuration(), MythBDPlayer::GoToMenu(), MythBDPlayer::NextTitle(), TV::PlaybackMenuInit(), DecoderBase::PosMapFromDb(), MythBDPlayer::PrevTitle(), AvFormatDecoderBD::StreamChangeCheck(), MythBDPlayer::SwitchAngle(), MythBDPlayer::SwitchTitle(), DecoderBase::SyncPositionMap(), AvFormatDecoderBD::UpdateFramesPlayed(), and MythBDPlayer::VideoLoop().

DVDRingBuffer * RingBuffer::DVD ( void )

Definition at line 1637 of file ringbuffer.cpp.

BDRingBuffer * RingBuffer::BD ( void )

Definition at line 1642 of file ringbuffer.cpp.

virtual bool RingBuffer::StartFromBeginning ( void )

inlinevirtual

Reimplemented in DVDRingBuffer, and BDRingBuffer.

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

Referenced by AvFormatDecoder::OpenFile().

virtual void RingBuffer::IgnoreWaitStates ( bool ignore )

inlinevirtual

Reimplemented in DVDRingBuffer, and BDRingBuffer.

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

Referenced by MythDVDPlayer::InitialSeek(), AvFormatDecoder::OpenFile(), and TV::StopStuff().

virtual bool RingBuffer::IsInMenu ( void ) const

inlinevirtual

Reimplemented in BDRingBuffer, and DVDRingBuffer.

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

Referenced by IsInDiscMenuOrStillFrame().

virtual bool RingBuffer::IsInStillFrame ( void ) const

inlinevirtual

Reimplemented in BDRingBuffer, and DVDRingBuffer.

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

Referenced by AvFormatDecoder::GetFrame(), IsInDiscMenuOrStillFrame(), DVDRingBuffer::NeedsStillFrame(), and AvFormatDecoder::ProcessAudioPacket().

virtual bool RingBuffer::IsInDiscMenuOrStillFrame ( void ) const

inlinevirtual

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

Referenced by AvFormatDecoder::AutoSelectTrack(), DecoderBase::DoFastForward(), MythDVDPlayer::DoJumpChapter(), TV::DoTogglePauseFinish(), TV::DoTogglePauseStart(), TV::DVDJumpBack(), TV::HandleLCDTimerEvent(), MythDVDPlayer::PrepareAudioSample(), TV::ProcessKeypress(), TV::ProcessNetworkControlCommand(), MythDVDPlayer::ReleaseNextVideoFrame(), MythDVDPlayer::SetBookmark(), and MythDVDPlayer::SetDVDBookmark().

virtual bool RingBuffer::HandleAction	(	const QStringList &	,
		int64_t
	)

inlinevirtual

Reimplemented in BDRingBuffer, and DVDRingBuffer.

Definition at line 106 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

lfilename	Name of file to read
retry_ms	How many ms to retry reading the file after the first try before giving up.

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

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

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

inlinevirtual

Reimplemented in FileRingBuffer.

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

Referenced by AVFormatWriter::ReOpen(), and FileTransfer::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

buf	Pointer to where data will be written
count	Number of bytes to read

Returns: Returns number of bytes read

Definition at line 1312 of file ringbuffer.cpp.

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

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

Definition at line 1010 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 250 of file ringbuffer.cpp.

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

virtual long long RingBuffer::Seek	(	long long	pos,
		int	whence,
		bool	has_lock = `false`
	)

pure virtual

Seeks to a particular position in the file.

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

Referenced by AVFRingBuffer::AVF_Seek(), TV::CreatePBP(), AvFormatDecoderBD::DoFastForwardSeek(), AvFormatDecoderDVD::DoFastForwardSeek(), DecoderBase::DoFastForwardSeek(), AvFormatDecoderBD::DoRewindSeek(), AvFormatDecoderDVD::DoRewindSeek(), DecoderBase::DoRewindSeek(), NuppelDecoder::GetFrame(), NuppelDecoder::OpenFile(), TV::PBPRestartMainPlayer(), ReadDirect(), TV::RestartAllPlayers(), FileTransfer::Seek(), and sub_read_line_subrip().

void RingBuffer::Pause ( void )

Pauses the read-ahead thread.

Calls StopReads(void).

See Also: Unpause(void), WaitForPause(void)

Definition at line 587 of file ringbuffer.cpp.

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

void RingBuffer::Unpause ( void )

Unpauses the read-ahead thread.

Calls StartReads(void).

See Also: Pause(void)

Definition at line 601 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 624 of file ringbuffer.cpp.

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

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 507 of file ringbuffer.cpp.

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

void RingBuffer::StopReads ( void )

????

See Also: StartReads(void), Pause(void)

Definition at line 565 of file ringbuffer.cpp.

Referenced by KillReadAheadThread(), FileTransfer::Pause(), Pause(), TV::PauseLiveTV(), FileRingBuffer::Seek(), FileTransfer::Stop(), TV::StopStuff(), TV::SwitchCards(), and TVRec::TeardownRecorder().

void RingBuffer::StartReads ( void )

????

See Also: StopReads(void), Unpause(void)

Definition at line 576 of file ringbuffer.cpp.

Referenced by TV::PauseLiveTV(), FileRingBuffer::Seek(), Start(), FileTransfer::Unpause(), and Unpause().

bool RingBuffer::LiveMode ( void ) const

Returns true if this RingBuffer has been assigned a LiveTVChain.

See Also: SetLiveMode(LiveTVChain*)

Definition at line 1600 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 1612 of file ringbuffer.cpp.

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

void RingBuffer::IgnoreLiveEOF ( bool ignore )

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

Definition at line 1620 of file ringbuffer.cpp.

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

int RingBuffer::Write	(	const void *	buf,
		uint	count
	)

Writes buffer to ThreadedFileWriter::Write(const void*,uint)

Returns: Bytes written, or -1 on error.

Definition at line 1452 of file ringbuffer.cpp.

bool RingBuffer::IsIOBound ( void ) const

void RingBuffer::WriterFlush ( void )

Calls ThreadedFileWriter::Flush(void)

Definition at line 1526 of file ringbuffer.cpp.

Referenced by DTVRecorder::FinishRecording(), NuppelVideoRecorder::FinishRecording(), RecorderBase::SetNextRecording(), and FileTransfer::Stop().

void RingBuffer::Sync ( void )

Calls ThreadedFileWriter::Sync(void)

Definition at line 1490 of file ringbuffer.cpp.

long long RingBuffer::WriterSeek	(	long long	pos,
		int	whence,
		bool	has_lock = `false`
	)

Calls ThreadedFileWriter::Seek(long long,int).

Definition at line 1500 of file ringbuffer.cpp.

Referenced by FileRingBuffer::Seek(), NuppelVideoRecorder::WriteKeyFrameAdjustTable(), and NuppelVideoRecorder::WriteSeekTable().

long long RingBuffer::SetAdjustFilesize ( void )

Definition at line 999 of file ringbuffer.cpp.

Referenced by MythPlayer::SwitchToProgram().

void RingBuffer::SetTimeout ( bool is_old )

inline

Calls SetOldFile(), do not use.

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

void RingBuffer::AVFormatInitNetwork ( void )

static

Definition at line 1647 of file ringbuffer.cpp.

Referenced by StreamingRingBuffer::OpenFile(), and HLSRingBuffer::TestForHTTPLiveStreaming().

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 734 of file ringbuffer.cpp.

void RingBuffer::CreateReadAheadBuffer ( void )

protected

Definition at line 686 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 345 of file ringbuffer.cpp.

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

bool RingBuffer::PauseAndWait ( void )

protected

Definition at line 643 of file ringbuffer.cpp.

Referenced by run().

virtual int RingBuffer::safe_read	(	void *	data,
		uint	sz
	)

protectedpure virtual

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

Referenced by ReadDirect(), run(), and FileRingBuffer::safe_read().

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

buf	Pointer to where data will be written
count	Number of bytes to read
peek	If true, don't increment read count

Returns: Returns number of bytes read

Definition at line 1187 of file ringbuffer.cpp.

Referenced by Peek(), and Read().

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

protected

Definition at line 1115 of file ringbuffer.cpp.

Referenced by ReadPriv().

bool RingBuffer::WaitForReadsAllowed ( void )

protected

Definition at line 1022 of file ringbuffer.cpp.

Referenced by ReadPriv().

bool RingBuffer::WaitForAvail ( int count )

protected

Definition at line 1048 of file ringbuffer.cpp.

Referenced by ReadPriv().

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 438 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 450 of file ringbuffer.cpp.

Referenced by IsNearEnd(), ReadPriv(), 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

newinternal Position in file to start reading data from

Definition at line 471 of file ringbuffer.cpp.

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