(1 . 4)(1 . 4)
109 VERSION = "9987"
110 VERSION = "9986"
111
112 import os
113 import select
(166 . 12)(166 . 7)
115 for x in inputready:
116 if x == self.udp_server_socket:
117 bytes_address_pair = self.udp_server_socket.recvfrom(PACKET_SIZE)
118 self.station.embargo_queue_lock.acquire()
119 try:
120 self.station.handle_udp_data(bytes_address_pair)
121 except sqlite3.ProgrammingError as ex:
122 logging.error("sqlite3 concurrency problem")
123 self.station.embargo_queue_lock.release()
124 self.station.handle_udp_data(bytes_address_pair)
125 for x in iwtd:
126 if self.client != None:
127 self.client.socket_readable_notification()