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