Miroirs/xwords
1
0
Fork 0
mirror of git://xwords.git.sourceforge.net/gitroot/xwords/xwords synced 2025-01-04 23:02:02 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

exit if tile line hasn't change in 2 minutes

Browse source
This commit is contained in:
Eric House 2017-11-29 20:39:15 -08:00
parent 12ab4bdc5c
commit f1b91f4df2
1 changed files with 19 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
xwords4/linux/scripts/discon_ok2.py
View file

@ -633,7 +633,8 @@ def build_cmds(args):
# fi # fi
# } # }
def summarizeTileCounts(devs, endTime): def summarizeTileCounts(devs, endTime, state):
shouldGoOn = True
data = [dev.getTilesCount() for dev in devs] data = [dev.getTilesCount() for dev in devs]
nDevs = len(data) nDevs = len(data)
totalTiles = 0 totalTiles = 0
@ -677,6 +678,18 @@ def summarizeTileCounts(devs, endTime):
for datum in fmtData: for datum in fmtData:
print(fmt.format(**datum)) print(fmt.format(**datum))
# Now let's see if things are stuck: if the tile string hasn't
# changed in two minutes bail. Note that the count of tiles left
# isn't enough because it's zero for a long time as devices are
# using up what's left in their trays and getting killed.
now = datetime.datetime.now()
tilesStr = fmtData[2]['data']
if not 'tilesStr' in state or state['tilesStr'] != tilesStr:
state['lastChange'] = now
state['tilesStr'] = tilesStr
return now - state['lastChange'] < datetime.timedelta(minutes = 1)
def countCores(): def countCores():
return len(glob.glob1('/tmp',"core*")) return len(glob.glob1('/tmp',"core*"))
@ -687,6 +700,7 @@ def run_cmds(args, devs):
endTime = datetime.datetime.now() + datetime.timedelta(seconds = args.TIMEOUT) endTime = datetime.datetime.now() + datetime.timedelta(seconds = args.TIMEOUT)
print('will run until', endTime) print('will run until', endTime)
LOOPCOUNT = 0 LOOPCOUNT = 0
printState = {}
while len(devs) > 0 and not gDone: while len(devs) > 0 and not gDone:
if countCores() > nCores: if countCores() > nCores:
@ -697,7 +711,10 @@ def run_cmds(args, devs):
break break
LOOPCOUNT += 1 LOOPCOUNT += 1
if 0 == LOOPCOUNT % 20: summarizeTileCounts(devs, endTime) if 0 == LOOPCOUNT % 20:
if not summarizeTileCounts(devs, endTime, printState):
print('no change in too long; exiting')
break
dev = random.choice(devs) dev = random.choice(devs)
if not dev.running(): if not dev.running():