MythTV  master
Public Types | Public Member Functions | Static Public Member Functions | Protected Member Functions | Private Types | Private Member Functions | Private Attributes | List of all members
Scheduler Class Reference

#include <scheduler.h>

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

Public Types

enum  SchedSortColumn {
  kSortTitle, kSortLastRecorded, kSortNextRecording, kSortPriority,
  kSortType
}
 

Public Member Functions

 Scheduler (bool runthread, QMap< int, EncoderLink * > *tvList, const QString &tmptable="record", Scheduler *master_sched=nullptr)
 
 ~Scheduler ()
 
void Stop (void)
 
void Wait (void)
 
void SetExpirer (AutoExpire *autoExpirer)
 
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 &)
 
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
 
void getConflicting (RecordingInfo *pginfo, QStringList &strlist)
 
void getConflicting (RecordingInfo *pginfo, RecList *retlist)
 
void PrintList (bool onlyFutureRecordings=false)
 
void PrintList (RecList &list, bool onlyFutureRecordings=false)
 
void PrintRec (const RecordingInfo *p, const QString &prefix="")
 
void SetMainServer (MainServer *ms)
 
void SlaveConnected (RecordingList &slavelist)
 
void SlaveDisconnected (uint cardid)
 
void DisableScheduling (void)
 
void EnableScheduling (void)
 
void GetNextLiveTVDir (uint cardid)
 
void ResetIdleTime (void)
 
bool WasStartedAutomatically ()
 
RecStatus::Type GetRecStatus (const ProgramInfo &pginfo)
 
int GetError (void) const
 
void AddChildInput (uint parentid, uint inputid)
 
- 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 ()
 
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...
 
- Public Member Functions inherited from MythScheduler
 MythScheduler ()=default
 
virtual ~MythScheduler ()=default
 

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 Public 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. 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
int exec (void)
 Enters the qt event loop. call exit or quit to exit thread. More...
 

Private Types

enum  OpenEndType { openEndNever = 0, openEndDiffChannel = 1, openEndAlways = 2 }
 
typedef pair< const RecordingInfo *, const RecordingInfo * > IsSameKey
 
typedef QMap< IsSameKey, boolIsSameCacheType
 

Private Member Functions

bool VerifyCards (void)
 
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) const
 
const RecordingInfoFindConflict (const RecordingInfo *p, OpenEndType openEnd=openEndNever, uint *affinity=nullptr, bool checkAll=false) const
 
void MarkOtherShowings (RecordingInfo *p)
 
void MarkShowingsList (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)
 
bool CheckShutdownServer (int prerollseconds, QDateTime &idleSince, bool &blockShutdown, uint logmask)
 
void ShutdownServer (int 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 (int prerollseconds, int idleWaitForRecordingTime)
 
void HandleWakeSlave (RecordingInfo &ri, int prerollseconds)
 
bool HandleRecording (RecordingInfo &ri, bool &statuschanged, QDateTime &nextStartTime, QDateTime &nextWakeTime, int prerollseconds)
 
void HandleRecordingStatusChange (RecordingInfo &ri, RecStatus::Type recStatus, const QString &details)
 
bool AssignGroupInput (RecordingInfo &ri, int prerollseconds)
 
void HandleIdleShutdown (bool &blockShutdown, QDateTime &idleSince, int prerollseconds, int idleTimeoutSecs, int 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)
 

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, SchedInputInfom_sinputinfomap
 
vector< RecList * > m_conflictlists
 
QMap< uint, RecListm_recordidlistmap
 
QMap< QString, RecListm_titlelistmap
 
QDateTime m_schedTime
 
bool m_reclist_changed {false}
 
bool m_specsched
 
bool m_schedulingEnabled {true}
 
QMap< int, boolm_schedAfterStartMap
 
QMap< int, EncoderLink * > * m_tvList {nullptr}
 
AutoExpirem_expirer {nullptr}
 
QSet< uintm_schedorder_warned
 
bool m_doRun
 
MainServerm_mainServer {nullptr}
 
QMutex m_resetIdleTime_lock
 
bool m_resetIdleTime {false}
 
bool m_isShuttingDown {false}
 
MSqlQueryInfo m_dbConn
 
QMap< QString, FileSystemInfom_fsInfoCache
 
int m_error {0}
 
QSet< QString > m_sysEvents [4]
 
QDateTime m_livetvTime
 
QDateTime m_lastPrepareTime
 
OpenEndType m_openEnd
 
IsSameCacheType m_cache_is_same_program
 
int m_tmLastLog {0}
 

Additional Inherited Members

- Static Public Attributes inherited from MThread
static const int kDefaultStartTimeout
 
- 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)
 
- Protected Attributes inherited from MThread
MThreadInternalm_thread {nullptr}
 
QRunnable * m_runnable {nullptr}
 
bool m_prolog_executed {true}
 
bool m_epilog_executed {true}
 

Detailed Description

Definition at line 48 of file scheduler.h.

Member Typedef Documentation

◆ IsSameKey

typedef pair<const RecordingInfo*,const RecordingInfo*> Scheduler::IsSameKey
private

Definition at line 286 of file scheduler.h.

◆ IsSameCacheType

typedef QMap<IsSameKey,bool> Scheduler::IsSameCacheType
private

Definition at line 287 of file scheduler.h.

Member Enumeration Documentation

◆ SchedSortColumn

Enumerator
kSortTitle 
kSortLastRecorded 
kSortNextRecording 
kSortPriority 
kSortType 

Definition at line 87 of file scheduler.h.

◆ OpenEndType

enum Scheduler::OpenEndType
private
Enumerator
openEndNever 
openEndDiffChannel 
openEndAlways 

Definition at line 126 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 58 of file scheduler.cpp.

◆ ~Scheduler()

Scheduler::~Scheduler ( )

Definition at line 102 of file scheduler.cpp.

Member Function Documentation

◆ Stop()

void Scheduler::Stop ( void  )

Definition at line 138 of file scheduler.cpp.

Referenced by MainServer::Stop().

◆ Wait()

void Scheduler::Wait ( void  )
inline

Definition at line 56 of file scheduler.h.

Referenced by MainServer::Stop().

◆ SetExpirer()

void Scheduler::SetExpirer ( AutoExpire autoExpirer)
inline

Definition at line 58 of file scheduler.h.

Referenced by run_backend().

◆ Reschedule()

void Scheduler::Reschedule ( const QStringList &  request)

◆ RescheduleMatch()

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

Definition at line 61 of file scheduler.h.

Referenced by MainServer::HandleGetPendingRecordings().

◆ RescheduleCheck()

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

◆ ReschedulePlace()

void Scheduler::ReschedulePlace ( const QString &  why)
inline

◆ AddRecording() [1/2]

void Scheduler::AddRecording ( const RecordingInfo pi)

Definition at line 1869 of file scheduler.cpp.

Referenced by MainServer::customEvent().

◆ AddRecording() [2/2]

void Scheduler::AddRecording ( const ProgramInfo prog)
inline

Definition at line 71 of file scheduler.h.

◆ FillRecordListFromDB()

void Scheduler::FillRecordListFromDB ( uint  recordid = 0)
Parameters
recordidRecord ID of recording that has changed, or 0 if anything might have been changed.

Definition at line 479 of file scheduler.cpp.

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

◆ FillRecordListFromMaster()

void Scheduler::FillRecordListFromMaster ( void  )

Definition at line 568 of file scheduler.cpp.

Referenced by handle_command().

◆ UpdateRecStatus() [1/2]

void Scheduler::UpdateRecStatus ( RecordingInfo pginfo)

Definition at line 637 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 695 of file scheduler.cpp.

◆ GetAllPending() [1/3]

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

◆ GetAllPending() [2/3]

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

Definition at line 1771 of file scheduler.cpp.

◆ GetAllPending() [3/3]

void Scheduler::GetAllPending ( QStringList &  strList) const
overridevirtual

Implements MythScheduler.

Definition at line 1826 of file scheduler.cpp.

◆ GetRecording()

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

Implements MythScheduler.

Definition at line 1791 of file scheduler.cpp.

Referenced by MainServer::HandleQueryRecordings().

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

Referenced by Dvr::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 4850 of file scheduler.cpp.

◆ getConflicting() [1/2]

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

Definition at line 1723 of file scheduler.cpp.

Referenced by MainServer::HandleGetConflictingRecordings().

◆ getConflicting() [2/2]

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

Definition at line 1739 of file scheduler.cpp.

◆ PrintList() [1/2]

void Scheduler::PrintList ( bool  onlyFutureRecordings = false)
inline

Definition at line 99 of file scheduler.h.

Referenced by handle_command(), and HandleReschedule().

◆ PrintList() [2/2]

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

Definition at line 581 of file scheduler.cpp.

◆ PrintRec()

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

Definition at line 609 of file scheduler.cpp.

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

◆ SetMainServer()

void Scheduler::SetMainServer ( MainServer ms)

Definition at line 145 of file scheduler.cpp.

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

◆ SlaveConnected()

void Scheduler::SlaveConnected ( RecordingList slavelist)

Definition at line 822 of file scheduler.cpp.

Referenced by MainServer::HandleAnnounce().

◆ SlaveDisconnected()

void Scheduler::SlaveDisconnected ( uint  cardid)

Definition at line 901 of file scheduler.cpp.

Referenced by MainServer::HandleSlaveDisconnectedEvent().

◆ 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.

◆ GetNextLiveTVDir()

void Scheduler::GetNextLiveTVDir ( uint  cardid)

Definition at line 5044 of file scheduler.cpp.

Referenced by MainServer::customEvent().

◆ ResetIdleTime()

void Scheduler::ResetIdleTime ( void  )

Definition at line 150 of file scheduler.cpp.

Referenced by MainServer::customEvent().

◆ WasStartedAutomatically()

bool Scheduler::WasStartedAutomatically ( )

Definition at line 5645 of file scheduler.cpp.

Referenced by HandleRunSchedulerStartup().

◆ GetRecStatus()

RecStatus::Type Scheduler::GetRecStatus ( const ProgramInfo pginfo)

Definition at line 1807 of file scheduler.cpp.

Referenced by MainServer::customEvent().

◆ GetError()

int Scheduler::GetError ( void  ) const
inline

Definition at line 118 of file scheduler.h.

Referenced by run_backend().

◆ AddChildInput()

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

Definition at line 5823 of file scheduler.cpp.

Referenced by MainServer::HandleAddChildInput().

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

◆ VerifyCards()

bool Scheduler::VerifyCards ( void  )
private

Definition at line 157 of file scheduler.cpp.

Referenced by Scheduler().

◆ InitInputInfoMap()

bool Scheduler::InitInputInfoMap ( void  )
private

Definition at line 5780 of file scheduler.cpp.

Referenced by Scheduler().

◆ CreateTempTables()

void Scheduler::CreateTempTables ( void  )
private

Definition at line 4127 of file scheduler.cpp.

Referenced by FillRecordListFromDB(), and HandleReschedule().

◆ DeleteTempTables()

void Scheduler::DeleteTempTables ( void  )
private

Definition at line 4175 of file scheduler.cpp.

Referenced by FillRecordListFromDB(), and HandleReschedule().

◆ UpdateDuplicates()

void Scheduler::UpdateDuplicates ( void  )
private

Definition at line 4191 of file scheduler.cpp.

Referenced by FillRecordListFromDB(), and HandleReschedule().

◆ FillRecordList()

bool Scheduler::FillRecordList ( void  )
private

Definition at line 428 of file scheduler.cpp.

Referenced by FillRecordListFromDB(), and HandleReschedule().

◆ UpdateMatches()

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

Definition at line 3956 of file scheduler.cpp.

Referenced by FillRecordListFromDB(), and HandleReschedule().

◆ UpdateManuals()

void Scheduler::UpdateManuals ( uint  recordid)
private

Definition at line 3684 of file scheduler.cpp.

Referenced by BuildNewRecordsQueries().

◆ BuildWorkList()

void Scheduler::BuildWorkList ( void  )
private

Definition at line 934 of file scheduler.cpp.

Referenced by FillRecordList().

◆ ClearWorkList()

bool Scheduler::ClearWorkList ( void  )
private

Definition at line 947 of file scheduler.cpp.

Referenced by FillRecordList().

◆ AddNewRecords()

void Scheduler::AddNewRecords ( void  )
private

Definition at line 4299 of file scheduler.cpp.

Referenced by FillRecordList().

◆ AddNotListed()

void Scheduler::AddNotListed ( void  )
private

Definition at line 4722 of file scheduler.cpp.

Referenced by FillRecordList().

◆ BuildNewRecordsQueries()

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

Definition at line 3794 of file scheduler.cpp.

Referenced by UpdateMatches().

◆ PruneOverlaps()

void Scheduler::PruneOverlaps ( void  )
private

Definition at line 994 of file scheduler.cpp.

Referenced by FillRecordList().

◆ BuildListMaps()

void Scheduler::BuildListMaps ( void  )
private

Definition at line 1018 of file scheduler.cpp.

Referenced by FillRecordList().

◆ ClearListMaps()

void Scheduler::ClearListMaps ( void  )
private

Definition at line 1054 of file scheduler.cpp.

Referenced by FillRecordList().

◆ IsBusyRecording()

bool Scheduler::IsBusyRecording ( const RecordingInfo rcinfo)
private

Definition at line 1911 of file scheduler.cpp.

Referenced by HandleRecording().

◆ IsSameProgram()

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

Definition at line 1063 of file scheduler.cpp.

Referenced by MarkShowingsList(), and TryAnotherShowing().

◆ FindNextConflict()

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

◆ FindConflict()

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

Definition at line 1179 of file scheduler.cpp.

Referenced by SchedNewFirstPass(), and TryAnotherShowing().

◆ MarkOtherShowings()

void Scheduler::MarkOtherShowings ( RecordingInfo p)
private

◆ MarkShowingsList()

void Scheduler::MarkShowingsList ( RecList showinglist,
RecordingInfo p 
)
private

Definition at line 1220 of file scheduler.cpp.

Referenced by MarkOtherShowings().

◆ BackupRecStatus()

void Scheduler::BackupRecStatus ( void  )
private

Definition at line 1247 of file scheduler.cpp.

Referenced by SchedNewRetryPass().

◆ RestoreRecStatus()

void Scheduler::RestoreRecStatus ( void  )
private

Definition at line 1256 of file scheduler.cpp.

Referenced by SchedNewRetryPass().

◆ TryAnotherShowing()

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

Definition at line 1265 of file scheduler.cpp.

Referenced by SchedNewRetryPass().

◆ SchedNewRecords()

void Scheduler::SchedNewRecords ( void  )
private

Definition at line 1375 of file scheduler.cpp.

Referenced by FillRecordList().

◆ SchedNewFirstPass()

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

Definition at line 1445 of file scheduler.cpp.

Referenced by SchedNewRecords().

◆ SchedNewRetryPass()

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

Definition at line 1523 of file scheduler.cpp.

Referenced by SchedLiveTV(), and SchedNewRecords().

◆ SchedLiveTV()

void Scheduler::SchedLiveTV ( void  )
private

Definition at line 5589 of file scheduler.cpp.

Referenced by FillRecordList().

◆ PruneRedundants()

void Scheduler::PruneRedundants ( void  )
private

Definition at line 1575 of file scheduler.cpp.

Referenced by FillRecordList().

◆ UpdateNextRecord()

void Scheduler::UpdateNextRecord ( void  )
private

Definition at line 1656 of file scheduler.cpp.

Referenced by HandleRecordingStatusChange(), and HandleReschedule().

◆ ChangeRecordingEnd()

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

Definition at line 744 of file scheduler.cpp.

Referenced by AddNewRecords().

◆ CheckShutdownServer()

bool Scheduler::CheckShutdownServer ( int  prerollseconds,
QDateTime &  idleSince,
bool blockShutdown,
uint  logmask 
)
private

Definition at line 3274 of file scheduler.cpp.

Referenced by HandleIdleShutdown().

◆ ShutdownServer()

void Scheduler::ShutdownServer ( int  prerollseconds,
QDateTime &  idleSince 
)
private

Definition at line 3332 of file scheduler.cpp.

Referenced by HandleIdleShutdown().

◆ PutInactiveSlavesToSleep()

void Scheduler::PutInactiveSlavesToSleep ( void  )
private

Definition at line 3446 of file scheduler.cpp.

Referenced by run().

◆ WakeUpSlave()

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

Definition at line 3600 of file scheduler.cpp.

Referenced by HandleWakeSlave(), and WakeUpSlaves().

◆ WakeUpSlaves()

void Scheduler::WakeUpSlaves ( void  )
private

Definition at line 3651 of file scheduler.cpp.

Referenced by Scheduler().

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

Referenced by GetNextLiveTVDir(), and HandleRecording().

◆ FillDirectoryInfoCache()

void Scheduler::FillDirectoryInfoCache ( void  )
private

Definition at line 5567 of file scheduler.cpp.

Referenced by FillRecordingDir().

◆ OldRecordedFixups()

void Scheduler::OldRecordedFixups ( void  )
private

Definition at line 1988 of file scheduler.cpp.

Referenced by run().

◆ ResetDuplicates()

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

Definition at line 2232 of file scheduler.cpp.

Referenced by HandleReschedule().

◆ HandleReschedule()

bool Scheduler::HandleReschedule ( void  )
private

Definition at line 2309 of file scheduler.cpp.

Referenced by run().

◆ HandleRunSchedulerStartup()

bool Scheduler::HandleRunSchedulerStartup ( int  prerollseconds,
int  idleWaitForRecordingTime 
)
private

Definition at line 2484 of file scheduler.cpp.

Referenced by run().

◆ HandleWakeSlave()

void Scheduler::HandleWakeSlave ( RecordingInfo ri,
int  prerollseconds 
)
private

Definition at line 2535 of file scheduler.cpp.

Referenced by run().

◆ HandleRecording()

bool Scheduler::HandleRecording ( RecordingInfo ri,
bool statuschanged,
QDateTime &  nextStartTime,
QDateTime &  nextWakeTime,
int  prerollseconds 
)
private

Definition at line 2641 of file scheduler.cpp.

Referenced by run().

◆ HandleRecordingStatusChange()

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

Definition at line 2891 of file scheduler.cpp.

Referenced by HandleRecording().

◆ AssignGroupInput()

bool Scheduler::AssignGroupInput ( RecordingInfo ri,
int  prerollseconds 
)
private

Definition at line 2929 of file scheduler.cpp.

Referenced by HandleRecording().

◆ HandleIdleShutdown()

void Scheduler::HandleIdleShutdown ( bool blockShutdown,
QDateTime &  idleSince,
int  prerollseconds,
int  idleTimeoutSecs,
int  idleWaitForRecordingTime,
bool statuschanged 
)
private

Definition at line 3066 of file scheduler.cpp.

Referenced by run().

◆ EnqueueMatch()

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

Definition at line 221 of file scheduler.h.

Referenced by AddRecording(), and run().

◆ EnqueueCheck()

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

Definition at line 225 of file scheduler.h.

Referenced by UpdateRecStatus().

◆ EnqueuePlace()

void Scheduler::EnqueuePlace ( const QString &  why)
inlineprivate

Definition at line 228 of file scheduler.h.

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

◆ HaveQueuedRequests()

bool Scheduler::HaveQueuedRequests ( void  )
inlineprivate

Definition at line 231 of file scheduler.h.

Referenced by HandleReschedule(), and run().

◆ ClearRequestQueue()

void Scheduler::ClearRequestQueue ( void  )
inlineprivate

Definition at line 233 of file scheduler.h.

Referenced by run().

◆ CreateConflictLists()

bool Scheduler::CreateConflictLists ( void  )
private

Definition at line 5690 of file scheduler.cpp.

Referenced by InitInputInfoMap().

Member Data Documentation

◆ m_recordTable

QString Scheduler::m_recordTable
private

◆ m_priorityTable

QString Scheduler::m_priorityTable
private

Definition at line 133 of file scheduler.h.

Referenced by AddNewRecords(), and Scheduler().

◆ m_reschedQueue

MythDeque<QStringList> Scheduler::m_reschedQueue
private

Definition at line 238 of file scheduler.h.

Referenced by HandleReschedule(), and Reschedule().

◆ m_schedLock

QMutex Scheduler::m_schedLock
mutableprivate

◆ m_recordmatchLock

QMutex Scheduler::m_recordmatchLock
private

Definition at line 240 of file scheduler.h.

Referenced by FillRecordListFromDB(), and HandleReschedule().

◆ m_reschedWait

QWaitCondition Scheduler::m_reschedWait
private

Definition at line 241 of file scheduler.h.

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

◆ m_reclist

RecList Scheduler::m_reclist
private

◆ m_worklist

RecList Scheduler::m_worklist
private

◆ m_livetvlist

RecList Scheduler::m_livetvlist
private

Definition at line 244 of file scheduler.h.

Referenced by SchedLiveTV(), and TryAnotherShowing().

◆ m_sinputinfomap

QMap<uint, SchedInputInfo> Scheduler::m_sinputinfomap
private

◆ m_conflictlists

vector<RecList *> Scheduler::m_conflictlists
private

Definition at line 246 of file scheduler.h.

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

◆ m_recordidlistmap

QMap<uint, RecList> Scheduler::m_recordidlistmap
private

Definition at line 247 of file scheduler.h.

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

◆ m_titlelistmap

QMap<QString, RecList> Scheduler::m_titlelistmap
private

Definition at line 248 of file scheduler.h.

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

◆ m_schedTime

QDateTime Scheduler::m_schedTime
private

◆ m_reclist_changed

bool Scheduler::m_reclist_changed {false}
private

◆ m_specsched

bool Scheduler::m_specsched
private

Definition at line 253 of file scheduler.h.

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

◆ m_schedulingEnabled

bool Scheduler::m_schedulingEnabled {true}
private

Definition at line 254 of file scheduler.h.

Referenced by HandleRecording().

◆ m_schedAfterStartMap

QMap<int, bool> Scheduler::m_schedAfterStartMap
private

Definition at line 255 of file scheduler.h.

Referenced by AddNewRecords(), and HandleRecordingStatusChange().

◆ m_tvList

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

◆ m_expirer

AutoExpire* Scheduler::m_expirer {nullptr}
private

Definition at line 258 of file scheduler.h.

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

◆ m_schedorder_warned

QSet<uint> Scheduler::m_schedorder_warned
private

Definition at line 260 of file scheduler.h.

Referenced by AddNewRecords().

◆ m_doRun

bool Scheduler::m_doRun
private

Definition at line 262 of file scheduler.h.

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

◆ m_mainServer

MainServer* Scheduler::m_mainServer {nullptr}
private

◆ m_resetIdleTime_lock

QMutex Scheduler::m_resetIdleTime_lock
private

Definition at line 266 of file scheduler.h.

Referenced by HandleIdleShutdown(), and ResetIdleTime().

◆ m_resetIdleTime

bool Scheduler::m_resetIdleTime {false}
private

Definition at line 267 of file scheduler.h.

Referenced by HandleIdleShutdown(), and ResetIdleTime().

◆ m_isShuttingDown

bool Scheduler::m_isShuttingDown {false}
private

Definition at line 269 of file scheduler.h.

Referenced by HandleIdleShutdown(), and ShutdownServer().

◆ m_dbConn

MSqlQueryInfo Scheduler::m_dbConn
private

◆ m_fsInfoCache

QMap<QString, FileSystemInfo> Scheduler::m_fsInfoCache
private

Definition at line 272 of file scheduler.h.

Referenced by FillDirectoryInfoCache(), and FillRecordingDir().

◆ m_error

int Scheduler::m_error {0}
private

Definition at line 274 of file scheduler.h.

◆ m_sysEvents

QSet<QString> Scheduler::m_sysEvents[4]
private

Definition at line 276 of file scheduler.h.

Referenced by HandleWakeSlave().

◆ m_livetvTime

QDateTime Scheduler::m_livetvTime
private

◆ m_lastPrepareTime

QDateTime Scheduler::m_lastPrepareTime
private

Definition at line 281 of file scheduler.h.

Referenced by HandleRecording().

◆ m_openEnd

OpenEndType Scheduler::m_openEnd
private

Definition at line 283 of file scheduler.h.

Referenced by SchedNewFirstPass(), and SchedNewRecords().

◆ m_cache_is_same_program

IsSameCacheType Scheduler::m_cache_is_same_program
mutableprivate

Definition at line 288 of file scheduler.h.

Referenced by ClearListMaps(), and IsSameProgram().

◆ m_tmLastLog

int Scheduler::m_tmLastLog {0}
private

Definition at line 289 of file scheduler.h.

Referenced by HandleIdleShutdown().


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