01234567890123456789012345678901234567890123456789012345678901234567890123456789
54085409541054115412541354145415541654175418541954205421542254235424542554265427 54285429543054315432543354345435543654375438543954405441544254435444544554465447 |
<----SKIPPED LINES---->
"""
last_flight = {}
if flights:
last_flight = flights[-1]
if SIMULATION:
now = json_desc_dict['now']
else:
now = time.time()
additional_attributes = {}
today = EpochDisplayTime(now, '%x')
flight_count_today = len([1 for f in flights if DisplayTime(f, '%x') == today])
additional_attributes['flight_count_today'] = flight_count_today
additional_attributes['simulation'] = SIMULATION
additional_attributes['last_flight_available'] = LastFlightAvailable(
flights, screen_history)
message = (last_flight, json_desc_dict, configuration, additional_attributes)
try:
if 'enable_servos' in configuration:
to_servo_q.put(message, block=False)
if 'enable_remote' in configuration:
to_remote_q.put(message, block=False)
except queue.Full:
msg = 'Message queues to Arduinos full - trigger shutdown'
Log(msg)
global SHUTDOWN_SIGNAL
SHUTDOWN_SIGNAL = msg
def ProcessArduinoCommmands(q, flights, configuration, message_queue, next_message_time):
"""Executes the commands enqueued by the arduinos.
The commands on the queue q are of the form (command, args), where command is an
identifier indicating the type of instruction, and the args is a possibly empty tuple
with the attributes to follow thru.
<----SKIPPED LINES---->
|
01234567890123456789012345678901234567890123456789012345678901234567890123456789
54085409541054115412541354145415541654175418541954205421542254235424542554265427542854295430543154325433543454355436543754385439544054415442544354445445544654475448 |
<----SKIPPED LINES---->
"""
last_flight = {}
if flights:
last_flight = flights[-1]
if SIMULATION:
now = json_desc_dict['now']
else:
now = time.time()
additional_attributes = {}
today = EpochDisplayTime(now, '%x')
flight_count_today = len([1 for f in flights if DisplayTime(f, '%x') == today])
additional_attributes['flight_count_today'] = flight_count_today
additional_attributes['simulation'] = SIMULATION
additional_attributes['last_flight_available'] = LastFlightAvailable(
flights, screen_history)
Log('last_flight_available: %s' % str(additional_attributes['last_flight_available'])) # TODO - remove after debugging
message = (last_flight, json_desc_dict, configuration, additional_attributes)
try:
if 'enable_servos' in configuration:
to_servo_q.put(message, block=False)
if 'enable_remote' in configuration:
to_remote_q.put(message, block=False)
except queue.Full:
msg = 'Message queues to Arduinos full - trigger shutdown'
Log(msg)
global SHUTDOWN_SIGNAL
SHUTDOWN_SIGNAL = msg
def ProcessArduinoCommmands(q, flights, configuration, message_queue, next_message_time):
"""Executes the commands enqueued by the arduinos.
The commands on the queue q are of the form (command, args), where command is an
identifier indicating the type of instruction, and the args is a possibly empty tuple
with the attributes to follow thru.
<----SKIPPED LINES---->
|