01234567890123456789012345678901234567890123456789012345678901234567890123456789
70147015701670177018701970207021702270237024702570267027702870297030703170327033 70347035703670377038703970407041704270437044704570467047704870497050705170527053 |
<----SKIPPED LINES---->
message_queue = []
next_message_time = time.time()
# We repeat the loop every x seconds; this ensures that if the processing
# time is long, we don't wait another x seconds after processing completes
next_loop_time = time.time() + LOOP_DELAY_SECONDS
# These files are read only if the version on disk has been modified more
# recently than the last time it was read
last_dump_json_timestamp = 0
init_timing.append((time.time(), 7))
WaitUntilKillComplete(already_running_ids)
init_timing.append((time.time(), 8))
personal_message = None # Unknown what personal message is displayed
temp_last_logged = 0 # Keeps track of when temperature was last logged
LogTimes(init_timing)
Log('Finishing initialization of %d; starting radio polling loop' %
os.getpid())
while ((not SIMULATION or SIMULATION_COUNTER < len(DUMP_JSONS))
and not SHUTDOWN_SIGNAL):
last_heartbeat_time = Heartbeat(last_heartbeat_time)
new_configuration = ReadAndParseSettings(CONFIG_FILE)
UpdateRollingLogSize(new_configuration)
CheckForNewFilterCriteria(
configuration, new_configuration, message_queue, flights)
configuration = new_configuration
ResetLogs(configuration) # clear the logs if requested
UpdateRollingLogSize(configuration)
# if this is a SIMULATION, then process every diff dump. But if it
# isn't a simulation, then only read & do related processing for the
# next dump if the last-modified timestamp indicates the file has been
<----SKIPPED LINES---->
|
01234567890123456789012345678901234567890123456789012345678901234567890123456789
70147015701670177018701970207021702270237024702570267027702870297030703170327033703470357036703770387039704070417042704370447045704670477048704970507051705270537054 |
<----SKIPPED LINES---->
message_queue = []
next_message_time = time.time()
# We repeat the loop every x seconds; this ensures that if the processing
# time is long, we don't wait another x seconds after processing completes
next_loop_time = time.time() + LOOP_DELAY_SECONDS
# These files are read only if the version on disk has been modified more
# recently than the last time it was read
last_dump_json_timestamp = 0
init_timing.append((time.time(), 7))
WaitUntilKillComplete(already_running_ids)
init_timing.append((time.time(), 8))
personal_message = None # Unknown what personal message is displayed
temp_last_logged = 0 # Keeps track of when temperature was last logged
LogTimes(init_timing)
reboot = False
Log('Finishing initialization of %d; starting radio polling loop' %
os.getpid())
while ((not SIMULATION or SIMULATION_COUNTER < len(DUMP_JSONS))
and not SHUTDOWN_SIGNAL):
last_heartbeat_time = Heartbeat(last_heartbeat_time)
new_configuration = ReadAndParseSettings(CONFIG_FILE)
UpdateRollingLogSize(new_configuration)
CheckForNewFilterCriteria(
configuration, new_configuration, message_queue, flights)
configuration = new_configuration
ResetLogs(configuration) # clear the logs if requested
UpdateRollingLogSize(configuration)
# if this is a SIMULATION, then process every diff dump. But if it
# isn't a simulation, then only read & do related processing for the
# next dump if the last-modified timestamp indicates the file has been
<----SKIPPED LINES---->
|