Scheduler Class Reference

#include <mythbackend/scheduler.h>

Inheritance diagram for Scheduler:

Collaboration diagram for Scheduler:

Public Types
enum	SchedSortColumn : std::uint8_t {   kSortTitle , kSortLastRecorded , kSortNextRecording , kSortPriority ,   kSortType }

Public Member Functions
	Scheduler (bool runthread, QMap< int, EncoderLink * > *_tvList, const QString &tmptable="record", Scheduler *master_sched=nullptr)
	~Scheduler () override
void	Stop (void)
void	Wait (void)
void	SetExpirer (AutoExpire *autoExpirer)
AutoExpire *	GetExpirer ()
void	Reschedule (const QStringList &request)
void	RescheduleMatch (uint recordid, uint sourceid, uint mplexid, const QDateTime &maxstarttime, const QString &why)
void	RescheduleCheck (const RecordingInfo &recinfo, const QString &why)
void	ReschedulePlace (const QString &why)
void	AddRecording (const RecordingInfo &pi)
void	AddRecording (const ProgramInfo &prog)
void	FillRecordListFromDB (uint recordid=0)
void	FillRecordListFromMaster (void)
void	UpdateRecStatus (RecordingInfo *pginfo)
void	UpdateRecStatus (uint cardid, uint chanid, const QDateTime &startts, RecStatus::Type recstatus, const QDateTime &recendts)
bool	GetAllPending (RecList &retList, int recRuleId=0) const
bool	GetAllPending (ProgramList &retList, int recRuleId=0) const
void	GetAllPending (QStringList &strList) const override
QMap< QString, ProgramInfo * >	GetRecording (void) const override
virtual RecordingInfo *	GetRecording (uint recordedid) const
void	getConflicting (RecordingInfo *pginfo, QStringList &strlist)
void	getConflicting (RecordingInfo *pginfo, RecList *retlist)
void	PrintList (bool onlyFutureRecordings=false)
void	SetMainServer (MainServer *ms)
MainServer *	GetMainServer ()
void	SlaveConnected (const RecordingList &slavelist)
void	SlaveDisconnected (uint cardid)
void	DisableScheduling (void)
void	EnableScheduling (void)
bool	QueryScheduling (void) const
void	GetNextLiveTVDir (uint cardid)
void	ResetIdleTime (void)
RecStatus::Type	GetRecStatus (const ProgramInfo &pginfo)
int	GetError (void) const
void	AddChildInput (uint parentid, uint childid)
void	DelayShutdown ()
Public Member Functions inherited from MThread
	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 ()
	MThread (const MThread &)=delete
MThread &	operator= (const MThread &)=delete
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 p=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 (std::chrono::milliseconds time=std::chrono::milliseconds::max())
	Wait for the MThread to exit, with a maximum timeout. More...
Public Member Functions inherited from MythScheduler
	MythScheduler ()=default
virtual	~MythScheduler ()=default
virtual void	GetAllPending (QStringList &strList) const =0
virtual QMap< QString, ProgramInfo * >	GetRecording (void) const =0

Static Public Member Functions
static void	GetAllScheduled (QStringList &strList, SchedSortColumn sortBy=kSortTitle, bool ascending=true)
	Returns all scheduled programs serialized into a QStringList. More...
static void	GetAllScheduled (RecList &proglist, SchedSortColumn sortBy=kSortTitle, bool ascending=true)
	Returns all scheduled programs. More...
static void	PrintList (const RecList &list, bool onlyFutureRecordings=false)
static void	PrintRec (const RecordingInfo *p, const QString &prefix="")
static bool	WasStartedAutomatically ()
Static Public Member Functions inherited from MThread
static void	ThreadSetup (const QString &name)
	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)

Protected Member Functions
void	run (void) override
	Runs the Qt event loop unless we have a QRunnable, in which case we run the runnable run instead. More...
Protected Member Functions inherited from MThread
virtual void	run (void)
	Runs the Qt event loop unless we have a QRunnable, in which case we run the runnable run instead. More...
int	exec (void)
	Enters the qt event loop. call exit or quit to exit thread. More...

Private Types
enum	OpenEndType : std::uint8_t { openEndNever = 0 , openEndDiffChannel = 1 , openEndAlways = 2 }
using	IsSameKey = std::pair< const RecordingInfo *, const RecordingInfo * >
using	IsSameCacheType = QMap< IsSameKey, bool >

Private Member Functions
bool	InitInputInfoMap (void)
void	CreateTempTables (void)
void	DeleteTempTables (void)
void	UpdateDuplicates (void)
bool	FillRecordList (void)
void	UpdateMatches (uint recordid, uint sourceid, uint mplexid, const QDateTime &maxstarttime)
void	UpdateManuals (uint recordid)
void	BuildWorkList (void)
bool	ClearWorkList (void)
void	AddNewRecords (void)
void	AddNotListed (void)
void	BuildNewRecordsQueries (uint recordid, QStringList &from, QStringList &where, MSqlBindings &bindings)
void	PruneOverlaps (void)
void	BuildListMaps (void)
void	ClearListMaps (void)
bool	IsBusyRecording (const RecordingInfo *rcinfo)
bool	IsSameProgram (const RecordingInfo *a, const RecordingInfo *b) const
bool	FindNextConflict (const RecList &cardlist, const RecordingInfo *p, RecConstIter &iter, OpenEndType openEnd=openEndNever, uint *paffinity=nullptr, bool ignoreinput=false) const
const RecordingInfo *	FindConflict (const RecordingInfo *p, OpenEndType openEnd=openEndNever, uint *affinity=nullptr, bool checkAll=false) const
void	MarkOtherShowings (RecordingInfo *p)
void	MarkShowingsList (const RecList &showinglist, RecordingInfo *p)
void	BackupRecStatus (void)
void	RestoreRecStatus (void)
bool	TryAnotherShowing (RecordingInfo *p, bool samePriority, bool livetv=false)
void	SchedNewRecords (void)
void	SchedNewFirstPass (RecIter &start, const RecIter &end, int recpriority, int recpriority2)
void	SchedNewRetryPass (const RecIter &start, const RecIter &end, bool samePriority, bool livetv=false)
void	SchedLiveTV (void)
void	PruneRedundants (void)
void	UpdateNextRecord (void)
bool	ChangeRecordingEnd (RecordingInfo *oldp, RecordingInfo *newp)
void	ShutdownServer (std::chrono::seconds prerollseconds, QDateTime &idleSince)
void	PutInactiveSlavesToSleep (void)
bool	WakeUpSlave (const QString &slaveHostname, bool setWakingStatus=true)
void	WakeUpSlaves (void)
int	FillRecordingDir (const QString &title, const QString &hostname, const QString &storagegroup, const QDateTime &recstartts, const QDateTime &recendts, uint cardid, QString &recording_dir, const RecList &reclist)
void	FillDirectoryInfoCache (void)
void	OldRecordedFixups (void)
void	ResetDuplicates (uint recordid, uint findid, const QString &title, const QString &subtitle, const QString &descrip, const QString &programid)
bool	HandleReschedule (void)
bool	HandleRunSchedulerStartup (std::chrono::seconds prerollseconds, std::chrono::minutes idleWaitForRecordingTime)
void	HandleWakeSlave (RecordingInfo &ri, std::chrono::seconds prerollseconds)
bool	HandleRecording (RecordingInfo &ri, bool &statuschanged, QDateTime &nextStartTime, QDateTime &nextWakeTime, std::chrono::seconds prerollseconds)
void	HandleRecordingStatusChange (RecordingInfo &ri, RecStatus::Type recStatus, const QString &details)
bool	AssignGroupInput (RecordingInfo &ri, std::chrono::seconds prerollseconds)
void	HandleIdleShutdown (bool &blockShutdown, QDateTime &idleSince, std::chrono::seconds prerollseconds, std::chrono::seconds idleTimeoutSecs, std::chrono::minutes idleWaitForRecordingTime, bool statuschanged)
void	EnqueueMatch (uint recordid, uint sourceid, uint mplexid, const QDateTime &maxstarttime, const QString &why)
void	EnqueueCheck (const RecordingInfo &recinfo, const QString &why)
void	EnqueuePlace (const QString &why)
bool	HaveQueuedRequests (void)
void	ClearRequestQueue (void)
bool	CreateConflictLists (void)

Static Private Member Functions
static bool	VerifyCards (void)
static bool	CheckShutdownServer (std::chrono::seconds prerollseconds, QDateTime &idleSince, bool &blockShutdown, uint logmask)

Private Attributes
QString	m_recordTable
QString	m_priorityTable
MythDeque< QStringList >	m_reschedQueue
QMutex	m_schedLock
QMutex	m_recordMatchLock
QWaitCondition	m_reschedWait
RecList	m_recList
RecList	m_workList
RecList	m_livetvList
QMap< uint, SchedInputInfo >	m_sinputInfoMap
std::vector< RecList * >	m_conflictLists
QMap< uint, RecList >	m_recordIdListMap
QMap< QString, RecList >	m_titleListMap
QDateTime	m_schedTime
bool	m_recListChanged {false}
bool	m_specSched {false}
bool	m_schedulingEnabled {true}
QMap< int, bool >	m_schedAfterStartMap
QMap< int, EncoderLink * > *	m_tvList {nullptr}
AutoExpire *	m_expirer {nullptr}
QSet< uint >	m_schedOrderWarned
bool	m_doRun {false}
MainServer *	m_mainServer {nullptr}
QMutex	m_resetIdleTimeLock
bool	m_resetIdleTime {false}
bool	m_isShuttingDown {false}
MSqlQueryInfo	m_dbConn
QMap< QString, FileSystemInfo >	m_fsInfoCache
int	m_error {0}
std::array< QSet< QString >, 4 >	m_sysEvents
QDateTime	m_livetvTime
QDateTime	m_lastPrepareTime
std::chrono::milliseconds	m_delayShutdownTime {0ms}
OpenEndType	m_openEnd { openEndNever }
IsSameCacheType	m_cacheIsSameProgram
int	m_tmLastLog {0}

Additional Inherited Members
Static Protected Member Functions inherited from MThread
static void	setTerminationEnabled (bool enabled=true)
static void	usleep (std::chrono::microseconds time)
template<typename R , typename P >
static std::enable_if_t< std::chrono::treat_as_floating_point< R >::value, void >	usleep (std::chrono::duration< R, P > time)
Protected Attributes inherited from MThread
MThreadInternal *	m_thread {nullptr}
QRunnable *	m_runnable {nullptr}
bool	m_prologExecuted {true}
bool	m_epilogExecuted {true}

Detailed Description

Definition at line 44 of file scheduler.h.

Member Typedef Documentation

IsSameCacheType

using Scheduler::IsSameCacheType = QMap<IsSameKey,bool>

private

Definition at line 292 of file scheduler.h.

IsSameKey

using Scheduler::IsSameKey = std::pair<const RecordingInfo*,const RecordingInfo*>

private

Definition at line 291 of file scheduler.h.

Member Enumeration Documentation

OpenEndType

enum Scheduler::OpenEndType : std::uint8_t

private

Enumerator
openEndNever
openEndDiffChannel
openEndAlways

Definition at line 128 of file scheduler.h.

SchedSortColumn

enum Scheduler::SchedSortColumn : std::uint8_t

Enumerator
kSortTitle
kSortLastRecorded
kSortNextRecording
kSortPriority
kSortType

Definition at line 85 of file scheduler.h.

Constructor & Destructor Documentation

Scheduler()

Scheduler::Scheduler	(	bool	runthread,
		QMap< int, EncoderLink * > *	_tvList,
		const QString &	tmptable = "record",
		Scheduler *	master_sched = nullptr
	)

Definition at line 67 of file scheduler.cpp.

~Scheduler()

Scheduler::~Scheduler ( )

override

Definition at line 107 of file scheduler.cpp.

Member Function Documentation

AddChildInput()

void Scheduler::AddChildInput	(	uint	parentid,
		uint	childid
	)

Definition at line 5956 of file scheduler.cpp.

Referenced by MainServer::HandleAddChildInput().

AddNewRecords()

void Scheduler::AddNewRecords ( void  )

private

Definition at line 4387 of file scheduler.cpp.

Referenced by FillRecordList().

AddNotListed()

void Scheduler::AddNotListed ( void  )

private

Definition at line 4827 of file scheduler.cpp.

Referenced by FillRecordList().

AddRecording() [1/2]

void Scheduler::AddRecording ( const ProgramInfo &  prog )

inline

Definition at line 68 of file scheduler.h.

AddRecording() [2/2]

void Scheduler::AddRecording

(

const RecordingInfo &

pi

)

Definition at line 1877 of file scheduler.cpp.

Referenced by AddRecording(), and MainServer::customEvent().

AssignGroupInput()

bool Scheduler::AssignGroupInput ( RecordingInfo &  ri, std::chrono::seconds  prerollseconds  )

private

Definition at line 2956 of file scheduler.cpp.

Referenced by HandleRecording().

BackupRecStatus()

void Scheduler::BackupRecStatus ( void  )

private

Definition at line 1251 of file scheduler.cpp.

Referenced by SchedNewRetryPass().

BuildListMaps()

void Scheduler::BuildListMaps ( void  )

private

Definition at line 1022 of file scheduler.cpp.

Referenced by FillRecordList().

BuildNewRecordsQueries()

void Scheduler::BuildNewRecordsQueries ( uint  recordid, QStringList &  from, QStringList &  where, MSqlBindings &  bindings  )

private

Definition at line 3883 of file scheduler.cpp.

Referenced by UpdateMatches().

BuildWorkList()

void Scheduler::BuildWorkList ( void  )

private

Definition at line 941 of file scheduler.cpp.

Referenced by FillRecordList().

ChangeRecordingEnd()

bool Scheduler::ChangeRecordingEnd ( RecordingInfo *  oldp, RecordingInfo *  newp  )

private

Definition at line 759 of file scheduler.cpp.

Referenced by AddNewRecords().

CheckShutdownServer()

bool Scheduler::CheckShutdownServer ( std::chrono::seconds  prerollseconds, QDateTime &  idleSince, bool &  blockShutdown, uint  logmask  )

staticprivate

Definition at line 3325 of file scheduler.cpp.

Referenced by HandleIdleShutdown().

ClearListMaps()

void Scheduler::ClearListMaps ( void  )

private

Definition at line 1057 of file scheduler.cpp.

Referenced by FillRecordList().

ClearRequestQueue()

void Scheduler::ClearRequestQueue ( void  )

inlineprivate

Definition at line 236 of file scheduler.h.

Referenced by run().

ClearWorkList()

bool Scheduler::ClearWorkList ( void  )

private

Definition at line 953 of file scheduler.cpp.

Referenced by FillRecordList().

CreateConflictLists()

bool Scheduler::CreateConflictLists ( void  )

private

Definition at line 5822 of file scheduler.cpp.

Referenced by InitInputInfoMap().

CreateTempTables()

void Scheduler::CreateTempTables ( void  )

private

Definition at line 4215 of file scheduler.cpp.

Referenced by FillRecordListFromDB(), and HandleReschedule().

DelayShutdown()

void Scheduler::DelayShutdown

(

)

Definition at line 3095 of file scheduler.cpp.

Referenced by V2Myth::DelayShutdown().

DeleteTempTables()

void Scheduler::DeleteTempTables ( void  )

private

Definition at line 4263 of file scheduler.cpp.

Referenced by FillRecordListFromDB(), and HandleReschedule().

DisableScheduling()

void Scheduler::DisableScheduling ( void  )

inline

Definition at line 109 of file scheduler.h.

Referenced by run_backend().

EnableScheduling()

void Scheduler::EnableScheduling ( void  )

inline

Definition at line 110 of file scheduler.h.

EnqueueCheck()

void Scheduler::EnqueueCheck ( const RecordingInfo &  recinfo, const QString &  why  )

inlineprivate

Definition at line 228 of file scheduler.h.

Referenced by UpdateRecStatus().

EnqueueMatch()

void Scheduler::EnqueueMatch ( uint  recordid, uint  sourceid, uint  mplexid, const QDateTime &  maxstarttime, const QString &  why  )

inlineprivate

Definition at line 224 of file scheduler.h.

Referenced by AddRecording(), and run().

EnqueuePlace()

void Scheduler::EnqueuePlace ( const QString &  why )

inlineprivate

Definition at line 231 of file scheduler.h.

Referenced by HandleRecording(), HandleReschedule(), and HandleWakeSlave().

FillDirectoryInfoCache()

void Scheduler::FillDirectoryInfoCache ( void  )

private

Definition at line 5701 of file scheduler.cpp.

Referenced by FillRecordingDir().

FillRecordingDir()

int Scheduler::FillRecordingDir ( const QString &  title, const QString &  hostname, const QString &  storagegroup, const QDateTime &  recstartts, const QDateTime &  recendts, uint  cardid, QString &  recording_dir, const RecList &  reclist  )

private

Definition at line 5200 of file scheduler.cpp.

Referenced by GetNextLiveTVDir(), and HandleRecording().

FillRecordList()

bool Scheduler::FillRecordList ( void  )

private

Definition at line 445 of file scheduler.cpp.

Referenced by FillRecordListFromDB(), and HandleReschedule().

FillRecordListFromDB()

void Scheduler::FillRecordListFromDB

(

uint

recordid = 0

)

Parameters

recordid

Record ID of recording that has changed, or 0 if anything might have been changed.

Definition at line 496 of file scheduler.cpp.

Referenced by handle_command(), and MainServer::HandleGetPendingRecordings().

FillRecordListFromMaster()

void Scheduler::FillRecordListFromMaster

(

void

)

Definition at line 579 of file scheduler.cpp.

Referenced by handle_command().

FindConflict()

const RecordingInfo * Scheduler::FindConflict ( const RecordingInfo *  p, OpenEndType  openEnd = openEndNever, uint *  affinity = nullptr, bool  checkAll = false  ) const

private

Definition at line 1187 of file scheduler.cpp.

Referenced by SchedNewFirstPass(), and TryAnotherShowing().

FindNextConflict()

bool Scheduler::FindNextConflict ( const RecList &  cardlist, const RecordingInfo *  p, RecConstIter &  iter, OpenEndType  openEnd = openEndNever, uint *  paffinity = nullptr, bool  ignoreinput = false  ) const

private

Definition at line 1082 of file scheduler.cpp.

Referenced by ChangeRecordingEnd(), FindConflict(), getConflicting(), SchedNewRetryPass(), and TryAnotherShowing().

GetAllPending() [1/3]

bool Scheduler::GetAllPending	(	ProgramList &	retList,
		int	recRuleId = 0
	)		const

Definition at line 1769 of file scheduler.cpp.

GetAllPending() [2/3]

void Scheduler::GetAllPending ( QStringList &  strList ) const

overridevirtual

Implements MythScheduler.

Definition at line 1834 of file scheduler.cpp.

GetAllPending() [3/3]

bool Scheduler::GetAllPending	(	RecList &	retList,
		int	recRuleId = 0
	)		const

Definition at line 1750 of file scheduler.cpp.

Referenced by HttpStatus::FillStatusXML(), V2Status::FillStatusXML(), FillUpcomingList(), GetAllPending(), V2Guide::GetProgramGuide(), V2Guide::GetProgramList(), MainServer::HandleGetPendingRecordings(), ProgramInfo::LoadFromScheduler(), Scheduler(), and MainServer::UpdateSystemdStatus().

GetAllScheduled() [1/2]

void Scheduler::GetAllScheduled ( QStringList &  strList, SchedSortColumn  sortBy = kSortTitle, bool  ascending = true  )

static

Returns all scheduled programs serialized into a QStringList.

Definition at line 1852 of file scheduler.cpp.

Referenced by GetAllScheduled(), V2Dvr::GetRecordScheduleList(), and MainServer::HandleGetScheduledRecordings().

GetAllScheduled() [2/2]

void Scheduler::GetAllScheduled ( RecList &  proglist, SchedSortColumn  sortBy = kSortTitle, bool  ascending = true  )

static

Returns all scheduled programs.

Note

Caller is responsible for deleting the RecordingInfo's returned.

Definition at line 4959 of file scheduler.cpp.

getConflicting() [1/2]

void Scheduler::getConflicting	(	RecordingInfo *	pginfo,
		QStringList &	strlist
	)

Definition at line 1720 of file scheduler.cpp.

Referenced by getConflicting(), and MainServer::HandleGetConflictingRecordings().

getConflicting() [2/2]

void Scheduler::getConflicting	(	RecordingInfo *	pginfo,
		RecList *	retlist
	)

Definition at line 1736 of file scheduler.cpp.

GetError()

int Scheduler::GetError ( void  ) const

inline

Definition at line 119 of file scheduler.h.

Referenced by run_backend().

GetExpirer()

AutoExpire * Scheduler::GetExpirer ( )

inline

Definition at line 55 of file scheduler.h.

GetMainServer()

MainServer * Scheduler::GetMainServer ( )

inline

Definition at line 104 of file scheduler.h.

Referenced by V2Status::V2Status().

GetNextLiveTVDir()

void Scheduler::GetNextLiveTVDir

(

uint

cardid

)

Definition at line 5173 of file scheduler.cpp.

Referenced by MainServer::customEvent().

GetRecording() [1/2]

RecordingInfo * Scheduler::GetRecording ( uint  recordedid ) const

virtual

Definition at line 1805 of file scheduler.cpp.

GetRecording() [2/2]

QMap< QString, ProgramInfo * > Scheduler::GetRecording ( void  ) const

overridevirtual

Implements MythScheduler.

Definition at line 1789 of file scheduler.cpp.

Referenced by MainServer::HandleQueryRecordings(), RecordingExtender::processActiveRecordings(), and RecordingExtender::processNewRecordings().

GetRecStatus()

RecStatus::Type Scheduler::GetRecStatus

(

const ProgramInfo &

pginfo

)

Definition at line 1815 of file scheduler.cpp.

Referenced by MainServer::customEvent().

HandleIdleShutdown()

void Scheduler::HandleIdleShutdown ( bool &  blockShutdown, QDateTime &  idleSince, std::chrono::seconds  prerollseconds, std::chrono::seconds  idleTimeoutSecs, std::chrono::minutes  idleWaitForRecordingTime, bool  statuschanged  )

private

Definition at line 3100 of file scheduler.cpp.

Referenced by run().

HandleRecording()

bool Scheduler::HandleRecording ( RecordingInfo &  ri, bool &  statuschanged, QDateTime &  nextStartTime, QDateTime &  nextWakeTime, std::chrono::seconds  prerollseconds  )

private

Definition at line 2662 of file scheduler.cpp.

Referenced by run().

HandleRecordingStatusChange()

void Scheduler::HandleRecordingStatusChange ( RecordingInfo &  ri, RecStatus::Type  recStatus, const QString &  details  )

private

Definition at line 2917 of file scheduler.cpp.

Referenced by HandleRecording().

HandleReschedule()

bool Scheduler::HandleReschedule ( void  )

private

Definition at line 2337 of file scheduler.cpp.

Referenced by run().

HandleRunSchedulerStartup()

bool Scheduler::HandleRunSchedulerStartup ( std::chrono::seconds  prerollseconds, std::chrono::minutes  idleWaitForRecordingTime  )

private

Definition at line 2507 of file scheduler.cpp.

Referenced by run().

HandleWakeSlave()

void Scheduler::HandleWakeSlave ( RecordingInfo &  ri, std::chrono::seconds  prerollseconds  )

private

Definition at line 2559 of file scheduler.cpp.

Referenced by run().

HaveQueuedRequests()

bool Scheduler::HaveQueuedRequests ( void  )

inlineprivate

Definition at line 234 of file scheduler.h.

Referenced by HandleReschedule(), and run().

InitInputInfoMap()

bool Scheduler::InitInputInfoMap ( void  )

private

Definition at line 5912 of file scheduler.cpp.

Referenced by Scheduler().

IsBusyRecording()

bool Scheduler::IsBusyRecording ( const RecordingInfo *  rcinfo )

private

Definition at line 1918 of file scheduler.cpp.

Referenced by HandleRecording().

IsSameProgram()

bool Scheduler::IsSameProgram ( const RecordingInfo *  a, const RecordingInfo *  b  ) const

private

Definition at line 1066 of file scheduler.cpp.

Referenced by MarkShowingsList(), and TryAnotherShowing().

MarkOtherShowings()

void Scheduler::MarkOtherShowings ( RecordingInfo *  p )

private

Definition at line 1207 of file scheduler.cpp.

Referenced by SchedNewFirstPass(), SchedNewRecords(), SchedNewRetryPass(), and TryAnotherShowing().

MarkShowingsList()

void Scheduler::MarkShowingsList ( const RecList &  showinglist, RecordingInfo *  p  )

private

Definition at line 1226 of file scheduler.cpp.

Referenced by MarkOtherShowings().

OldRecordedFixups()

void Scheduler::OldRecordedFixups ( void  )

private

Definition at line 1995 of file scheduler.cpp.

Referenced by run().

PrintList() [1/2]

void Scheduler::PrintList ( bool  onlyFutureRecordings = false )

inline

Definition at line 98 of file scheduler.h.

Referenced by handle_command(), HandleReschedule(), and PrintList().

PrintList() [2/2]

void Scheduler::PrintList ( const RecList &  list, bool  onlyFutureRecordings = false  )

static

Definition at line 591 of file scheduler.cpp.

PrintRec()

void Scheduler::PrintRec ( const RecordingInfo *  p, const QString &  prefix = ""  )

static

Definition at line 616 of file scheduler.cpp.

Referenced by PrintList(), SchedNewFirstPass(), SchedNewRetryPass(), and TryAnotherShowing().

PruneOverlaps()

void Scheduler::PruneOverlaps ( void  )

private

Definition at line 998 of file scheduler.cpp.

Referenced by FillRecordList().

PruneRedundants()

void Scheduler::PruneRedundants ( void  )

private

Definition at line 1572 of file scheduler.cpp.

Referenced by FillRecordList().

PutInactiveSlavesToSleep()

void Scheduler::PutInactiveSlavesToSleep ( void  )

private

Definition at line 3500 of file scheduler.cpp.

Referenced by run().

QueryScheduling()

bool Scheduler::QueryScheduling ( void  ) const

inline

Definition at line 111 of file scheduler.h.

Reschedule()

void Scheduler::Reschedule

(

const QStringList &

request

)

Definition at line 1870 of file scheduler.cpp.

Referenced by MainServer::customEvent(), MainServer::HandleRescheduleRecordings(), RescheduleCheck(), RescheduleMatch(), and ReschedulePlace().

RescheduleCheck()

void Scheduler::RescheduleCheck ( const RecordingInfo &  recinfo, const QString &  why  )

inline

Definition at line 62 of file scheduler.h.

Referenced by MainServer::DoHandleDeleteRecording(), and MainServer::DoHandleUndeleteRecording().

RescheduleMatch()

void Scheduler::RescheduleMatch ( uint  recordid, uint  sourceid, uint  mplexid, const QDateTime &  maxstarttime, const QString &  why  )

inline

Definition at line 58 of file scheduler.h.

Referenced by MainServer::HandleGetPendingRecordings().

ReschedulePlace()

void Scheduler::ReschedulePlace ( const QString &  why )

inline

Definition at line 64 of file scheduler.h.

Referenced by MainServer::HandleAnnounce(), MainServer::HandleFreeTuner(), MainServer::HandleLockTuner(), and MainServer::HandleSlaveDisconnectedEvent().

ResetDuplicates()

void Scheduler::ResetDuplicates ( uint  recordid, uint  findid, const QString &  title, const QString &  subtitle, const QString &  descrip, const QString &  programid  )

private

Definition at line 2260 of file scheduler.cpp.

Referenced by HandleReschedule().

ResetIdleTime()

void Scheduler::ResetIdleTime

(

void

)

Definition at line 155 of file scheduler.cpp.

Referenced by MainServer::customEvent().

RestoreRecStatus()

void Scheduler::RestoreRecStatus ( void  )

private

Definition at line 1259 of file scheduler.cpp.

Referenced by SchedNewRetryPass().

run()

void Scheduler::run ( void  )

overrideprotectedvirtual

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 2040 of file scheduler.cpp.

SchedLiveTV()

void Scheduler::SchedLiveTV ( void  )

private

Definition at line 5722 of file scheduler.cpp.

Referenced by FillRecordList().

SchedNewFirstPass()

void Scheduler::SchedNewFirstPass ( RecIter &  start, const RecIter &  end, int  recpriority, int  recpriority2  )

private

Definition at line 1444 of file scheduler.cpp.

Referenced by SchedNewRecords().

SchedNewRecords()

void Scheduler::SchedNewRecords ( void  )

private

Definition at line 1375 of file scheduler.cpp.

Referenced by FillRecordList().

SchedNewRetryPass()

void Scheduler::SchedNewRetryPass ( const RecIter &  start, const RecIter &  end, bool  samePriority, bool  livetv = false  )

private

Definition at line 1522 of file scheduler.cpp.

Referenced by SchedLiveTV(), and SchedNewRecords().

SetExpirer()

void Scheduler::SetExpirer ( AutoExpire *  autoExpirer )

inline

Definition at line 54 of file scheduler.h.

Referenced by run_backend().

SetMainServer()

void Scheduler::SetMainServer

(

MainServer *

ms

)

Definition at line 150 of file scheduler.cpp.

Referenced by MainServer::MainServer(), and MainServer::Stop().

ShutdownServer()

void Scheduler::ShutdownServer ( std::chrono::seconds  prerollseconds, QDateTime &  idleSince  )

private

Definition at line 3385 of file scheduler.cpp.

Referenced by HandleIdleShutdown().

SlaveConnected()

void Scheduler::SlaveConnected

(

const RecordingList &

slavelist

)

Definition at line 836 of file scheduler.cpp.

Referenced by MainServer::HandleAnnounce().

SlaveDisconnected()

void Scheduler::SlaveDisconnected

(

uint

cardid

)

Definition at line 911 of file scheduler.cpp.

Referenced by MainServer::HandleSlaveDisconnectedEvent().

Stop()

void Scheduler::Stop

(

void

)

Definition at line 143 of file scheduler.cpp.

Referenced by MainServer::Stop().

TryAnotherShowing()

bool Scheduler::TryAnotherShowing ( RecordingInfo *  p, bool  samePriority, bool  livetv = false  )

private

Definition at line 1267 of file scheduler.cpp.

Referenced by SchedNewRetryPass().

UpdateDuplicates()

void Scheduler::UpdateDuplicates ( void  )

private

Definition at line 4279 of file scheduler.cpp.

Referenced by FillRecordListFromDB(), and HandleReschedule().

UpdateManuals()

void Scheduler::UpdateManuals ( uint  recordid )

private

Definition at line 3721 of file scheduler.cpp.

Referenced by BuildNewRecordsQueries().

UpdateMatches()

void Scheduler::UpdateMatches ( uint  recordid, uint  sourceid, uint  mplexid, const QDateTime &  maxstarttime  )

private

Definition at line 4045 of file scheduler.cpp.

Referenced by FillRecordListFromDB(), and HandleReschedule().

UpdateNextRecord()

void Scheduler::UpdateNextRecord ( void  )

private

Definition at line 1653 of file scheduler.cpp.

Referenced by HandleRecordingStatusChange(), and HandleReschedule().

UpdateRecStatus() [1/2]

void Scheduler::UpdateRecStatus

(

RecordingInfo *

pginfo

)

Definition at line 654 of file scheduler.cpp.

Referenced by MainServer::customEvent(), and MainServer::DoHandleStopRecording().

UpdateRecStatus() [2/2]

void Scheduler::UpdateRecStatus	(	uint	cardid,
		uint	chanid,
		const QDateTime &	startts,
		RecStatus::Type	recstatus,
		const QDateTime &	recendts
	)

Definition at line 711 of file scheduler.cpp.

VerifyCards()

bool Scheduler::VerifyCards ( void  )

staticprivate

Definition at line 162 of file scheduler.cpp.

Referenced by Scheduler().

Wait()

void Scheduler::Wait ( void  )

inline

Definition at line 52 of file scheduler.h.

Referenced by MainServer::Stop().

WakeUpSlave()

bool Scheduler::WakeUpSlave ( const QString &  slaveHostname, bool  setWakingStatus = true  )

private

Definition at line 3644 of file scheduler.cpp.

Referenced by HandleWakeSlave(), and WakeUpSlaves().

WakeUpSlaves()

void Scheduler::WakeUpSlaves ( void  )

private

Definition at line 3691 of file scheduler.cpp.

Referenced by Scheduler().

WasStartedAutomatically()

bool Scheduler::WasStartedAutomatically ( )

static

Definition at line 5774 of file scheduler.cpp.

Referenced by HandleRunSchedulerStartup().

Member Data Documentation

m_cacheIsSameProgram

IsSameCacheType Scheduler::m_cacheIsSameProgram

mutableprivate

Definition at line 293 of file scheduler.h.

Referenced by ClearListMaps(), and IsSameProgram().

m_conflictLists

std::vector<RecList *> Scheduler::m_conflictLists

private

Definition at line 249 of file scheduler.h.

Referenced by ClearListMaps(), CreateConflictLists(), and ~Scheduler().

m_dbConn

MSqlQueryInfo Scheduler::m_dbConn

private

Definition at line 273 of file scheduler.h.

Referenced by AddNewRecords(), AddNotListed(), BuildNewRecordsQueries(), CreateTempTables(), DeleteTempTables(), FillRecordListFromDB(), HandleReschedule(), OldRecordedFixups(), ResetDuplicates(), run(), Scheduler(), UpdateDuplicates(), UpdateManuals(), UpdateMatches(), and UpdateNextRecord().

m_delayShutdownTime

std::chrono::milliseconds Scheduler::m_delayShutdownTime {0ms}

private

Definition at line 286 of file scheduler.h.

Referenced by DelayShutdown(), and HandleIdleShutdown().

m_doRun

bool Scheduler::m_doRun {false}

private

Definition at line 265 of file scheduler.h.

Referenced by AddNewRecords(), run(), Scheduler(), Stop(), and ~Scheduler().

m_error

int Scheduler::m_error {0}

private

Definition at line 277 of file scheduler.h.

Referenced by GetError().

m_expirer

AutoExpire* Scheduler::m_expirer {nullptr}

private

Definition at line 261 of file scheduler.h.

Referenced by FillRecordingDir(), GetExpirer(), GetNextLiveTVDir(), HandleRecording(), and SetExpirer().

m_fsInfoCache

QMap<QString, FileSystemInfo> Scheduler::m_fsInfoCache

private

Definition at line 275 of file scheduler.h.

Referenced by FillDirectoryInfoCache(), and FillRecordingDir().

m_isShuttingDown

bool Scheduler::m_isShuttingDown {false}

private

Definition at line 272 of file scheduler.h.

Referenced by HandleIdleShutdown(), and ShutdownServer().

m_lastPrepareTime

QDateTime Scheduler::m_lastPrepareTime

private

Definition at line 284 of file scheduler.h.

Referenced by HandleRecording().

m_livetvList

RecList Scheduler::m_livetvList

private

Definition at line 247 of file scheduler.h.

Referenced by SchedLiveTV(), and TryAnotherShowing().

m_livetvTime

QDateTime Scheduler::m_livetvTime

private

Definition at line 282 of file scheduler.h.

Referenced by SchedLiveTV(), SchedNewFirstPass(), SchedNewRecords(), SchedNewRetryPass(), and TryAnotherShowing().

m_mainServer

MainServer* Scheduler::m_mainServer {nullptr}

private

Definition at line 267 of file scheduler.h.

Referenced by FillDirectoryInfoCache(), FillRecordingDir(), GetMainServer(), HandleIdleShutdown(), run(), SetMainServer(), and ShutdownServer().

m_openEnd

OpenEndType Scheduler::m_openEnd { openEndNever }

private

Definition at line 288 of file scheduler.h.

Referenced by SchedNewFirstPass(), and SchedNewRecords().

m_priorityTable

QString Scheduler::m_priorityTable

private

Definition at line 135 of file scheduler.h.

Referenced by AddNewRecords(), and Scheduler().

m_recList

RecList Scheduler::m_recList

private

Definition at line 245 of file scheduler.h.

Referenced by AddRecording(), AssignGroupInput(), BuildWorkList(), ChangeRecordingEnd(), ClearWorkList(), FillRecordListFromDB(), FillRecordListFromMaster(), GetAllPending(), getConflicting(), GetNextLiveTVDir(), GetRecording(), GetRecStatus(), HandleIdleShutdown(), HandleRecording(), HandleReschedule(), HandleRunSchedulerStartup(), HandleWakeSlave(), PrintList(), PutInactiveSlavesToSleep(), run(), Scheduler(), ShutdownServer(), SlaveConnected(), SlaveDisconnected(), UpdateNextRecord(), UpdateRecStatus(), and ~Scheduler().

m_recListChanged

bool Scheduler::m_recListChanged {false}

private

Definition at line 254 of file scheduler.h.

Referenced by AddRecording(), AssignGroupInput(), ChangeRecordingEnd(), ClearWorkList(), HandleIdleShutdown(), HandleRecording(), run(), SlaveConnected(), SlaveDisconnected(), and UpdateRecStatus().

m_recordIdListMap

QMap<uint, RecList> Scheduler::m_recordIdListMap

private

Definition at line 250 of file scheduler.h.

Referenced by BuildListMaps(), ClearListMaps(), MarkOtherShowings(), and TryAnotherShowing().

m_recordMatchLock

QMutex Scheduler::m_recordMatchLock

private

Definition at line 243 of file scheduler.h.

Referenced by FillRecordListFromDB(), and HandleReschedule().

m_recordTable

QString Scheduler::m_recordTable

private

Definition at line 134 of file scheduler.h.

Referenced by AddNewRecords(), AddNotListed(), BuildNewRecordsQueries(), CreateTempTables(), DeleteTempTables(), ResetDuplicates(), Scheduler(), UpdateDuplicates(), UpdateManuals(), and UpdateMatches().

m_reschedQueue

MythDeque<QStringList> Scheduler::m_reschedQueue

private

Definition at line 241 of file scheduler.h.

Referenced by ClearRequestQueue(), EnqueueCheck(), EnqueueMatch(), EnqueuePlace(), HandleReschedule(), HaveQueuedRequests(), and Reschedule().

m_reschedWait

QWaitCondition Scheduler::m_reschedWait

private

Definition at line 244 of file scheduler.h.

Referenced by AddRecording(), Reschedule(), run(), Scheduler(), Stop(), UpdateRecStatus(), and ~Scheduler().

m_resetIdleTime

bool Scheduler::m_resetIdleTime {false}

private

Definition at line 270 of file scheduler.h.

Referenced by HandleIdleShutdown(), and ResetIdleTime().

m_resetIdleTimeLock

QMutex Scheduler::m_resetIdleTimeLock

private

Definition at line 269 of file scheduler.h.

Referenced by HandleIdleShutdown(), and ResetIdleTime().

m_schedAfterStartMap

QMap<int, bool> Scheduler::m_schedAfterStartMap

private

Definition at line 258 of file scheduler.h.

Referenced by AddNewRecords(), and HandleRecordingStatusChange().

m_schedLock

QMutex Scheduler::m_schedLock

mutableprivate

Definition at line 242 of file scheduler.h.

Referenced by AddRecording(), AssignGroupInput(), ChangeRecordingEnd(), FillRecordList(), FillRecordListFromDB(), FillRecordListFromMaster(), GetAllPending(), getConflicting(), GetNextLiveTVDir(), GetRecording(), GetRecStatus(), HandleIdleShutdown(), HandleRecording(), HandleReschedule(), HandleRunSchedulerStartup(), Reschedule(), run(), Scheduler(), ShutdownServer(), SlaveConnected(), SlaveDisconnected(), Stop(), UpdateRecStatus(), and ~Scheduler().

m_schedOrderWarned

QSet<uint> Scheduler::m_schedOrderWarned

private

Definition at line 263 of file scheduler.h.

Referenced by AddNewRecords().

m_schedTime

QDateTime Scheduler::m_schedTime

private

Definition at line 253 of file scheduler.h.

Referenced by AddNewRecords(), AddNotListed(), FillRecordList(), HandleRecording(), HandleReschedule(), PruneRedundants(), SchedLiveTV(), and TryAnotherShowing().

m_schedulingEnabled

bool Scheduler::m_schedulingEnabled {true}

private

Definition at line 257 of file scheduler.h.

Referenced by DisableScheduling(), EnableScheduling(), HandleRecording(), and QueryScheduling().

m_sinputInfoMap

QMap<uint, SchedInputInfo> Scheduler::m_sinputInfoMap

private

Definition at line 248 of file scheduler.h.

Referenced by AddChildInput(), AddRecording(), AssignGroupInput(), BuildListMaps(), CreateConflictLists(), FindConflict(), FindNextConflict(), InitInputInfoMap(), IsBusyRecording(), SchedLiveTV(), SchedNewRetryPass(), SlaveConnected(), and ~Scheduler().

m_specSched

bool Scheduler::m_specSched {false}

private

Definition at line 256 of file scheduler.h.

Referenced by AddNewRecords(), ChangeRecordingEnd(), and UpdateNextRecord().

m_sysEvents

std::array<QSet<QString>,4> Scheduler::m_sysEvents

private

Definition at line 279 of file scheduler.h.

Referenced by HandleWakeSlave().

m_titleListMap

QMap<QString, RecList> Scheduler::m_titleListMap

private

Definition at line 251 of file scheduler.h.

Referenced by BuildListMaps(), ClearListMaps(), and MarkOtherShowings().

m_tmLastLog

int Scheduler::m_tmLastLog {0}

private

Definition at line 294 of file scheduler.h.

Referenced by HandleIdleShutdown().

m_tvList

QMap<int, EncoderLink *>* Scheduler::m_tvList {nullptr}

private

Definition at line 260 of file scheduler.h.

Referenced by AddNewRecords(), FillRecordingDir(), GetNextLiveTVDir(), HandleIdleShutdown(), HandleRecording(), HandleWakeSlave(), IsBusyRecording(), PutInactiveSlavesToSleep(), SchedLiveTV(), WakeUpSlave(), and WakeUpSlaves().

m_workList

RecList Scheduler::m_workList

private

Definition at line 246 of file scheduler.h.

Referenced by AddNewRecords(), AddNotListed(), BackupRecStatus(), BuildListMaps(), BuildWorkList(), ClearWorkList(), FillRecordList(), PruneOverlaps(), PruneRedundants(), RestoreRecStatus(), SchedNewRecords(), and ~Scheduler().

---

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

• mythtv/programs/mythbackend/scheduler.h
• mythtv/programs/mythbackend/scheduler.cpp