def HandleRequests(self):
if not self.init:
try:
self.server_socket.bind(('0.0.0.0', self.port))
except:
print 'signalk_server: bind failed, try again.'
time.sleep(1)
return
self.server_socket.listen(5)
self.init = True
self.fd_to_socket = {self.server_socket.fileno() : self.server_socket}
self.poller = select.poll()
self.poller.register(self.server_socket, select.POLLIN)
t1 = time.time()
if t1 >= self.persistent_timeout:
self.StorePersistentValues()
if time.time() - t1 > .1:
print 'persistent store took too long!', time.time() - t1
return
self.PollSockets()
评论列表
文章目录