summaryrefslogtreecommitdiffstats
path: root/abs/core/LinHES-system/myth_mtc.py
blob: a5f02a0d044fe01277f8c94c6e3e8121d27185a6 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
#!/usr/bin/python2
import sys, subprocess
import optparse
import re
import socket
import os
import datetime,time

try:
    from MythTV import MythBE
    mythtv = MythBE()
except:
    mythtv = None

#print mythtv.db.getSetting( 'Theme', socket.gethostname())

def optimize():
    try:
        cursor = mythtv.db.cursor()
        cursor.execute("SHOW tables")
        result = cursor.fetchall()
    except:
        print "Problem getting tables from database"
	return
    ops=["REPAIR","OPTIMIZE","ANALYZE"]
    for row in result:
        ctable=row[0]
        for op in ops:
            print op,ctable
            cmd= "%s  table %s" %(op,ctable)
            cursor.execute(cmd)


def upcoming_check():
    try:
        upcoming = mythtv.getUpcomingRecordings()
    except:
        return True
    try:
        show=str(upcoming[0])
        show=show.strip()
        showtime=show.partition("(")[2].strip(")")
        now=time.time()
        rec_time=time.strptime( showtime ,"%Y-%m-%d %H:%M:%S" )
        r=time.mktime(rec_time)
        time_diff= ( r - now ) / 60
    except:
        time_diff=100
        show="No show"
    if ( time_diff  >  30) :
        return True
    else:
        print show , "is upcoming in " , time_diff
        return False


def schemalock_check():
    try:
        c = mythtv.db.cursor()
        c.execute("select count(*) from schemalock")
        results=c.fetchone()
        schemalock=results[0]
    except:
        return True

    if schemalock == 0:
        return True
    else:
        print "schema is locked"
        return False

def job_check():
    try:
        c = mythtv.db.cursor()
        c.execute("select count(*) from jobqueue where status = 4")
        results=c.fetchone()
    except:
        return True
    jobs= results[0]
    if jobs == 0 :
        return True
    else:
        print " jobs are running"
        return False


def in_use():
    try:
        c = mythtv.db.cursor()
        c.execute("select count(*) from inuseprograms")
        results=c.fetchone()
    except:
        return True
    prginuse=results[0]
    if prginuse == 0 :
        return True
    else:
        print "programs in use"
        return False

def mfd_check():
    ps = subprocess.Popen("ps ax -o pid= -o args= ", shell=True, stdout=subprocess.PIPE)
    ps_pid = ps.pid
    output = ps.stdout.read()
    ps.stdout.close()
    ps.wait()
    proc_name="mythfilldatabase"
    for line in output.split("\n"):
        res = re.findall("(\d+) (.*)", line)
        if res:
            pid = int(res[0][0])
            if proc_name in res[0][1] and pid != os.getpid() and pid != ps_pid:
                print "mythfilldatabase is running"
                return False

    return True



def idle_check():
    if  (   upcoming_check() and schemalock_check() and job_check()  and in_use() and  mfd_check()  ):
        idle=True
        print "Myth is idle"
    else:
        idle=False
        print "Myth is NOT idle"
    return idle

def run_stuff():
    if idle_check():
	print "Running optimize"
        optimize()

	print "Running backup"
        os.system('/usr/LH/bin/lh_system_backup_job')

	print "Running system_update"
	os.system('/usr/LH/bin/lh_system_host_update')
        continue_loop=False
    else:
        continue_loop=True
    return continue_loop

#---------------------------------
starttime=time.time()
ctin=True
while ctin:
    ctin=run_stuff()
    if  ctin:
        time.sleep(600)
    current_time=time.time()
    if (current_time - starttime) > 10800 :
        ctin = False
        print "time exceeded (3 hours)"
        exit(1)