import network.asyncore_pollchoose as asyncore import state from network.connectionpool import BMConnectionPool from queues import excQueue from threads import StoppableThread class BMNetworkThread(StoppableThread): """A thread to handle network concerns""" name = "Asyncore" def run(self): try: while not self._stopped and state.shutdown == 0: BMConnectionPool().loop() except Exception as e: excQueue.put((self.name, e)) raise def stopThread(self): super(BMNetworkThread, self).stopThread() for i in BMConnectionPool().listeningSockets.values(): try: i.close() except: pass for i in BMConnectionPool().outboundConnections.values(): try: i.close() except: pass for i in BMConnectionPool().inboundConnections.values(): try: i.close() except: pass # just in case asyncore.close_all()