self.port = self.socket.getsockname()[1]
self._handler = handler
self._thread = None
+ self._quit = False
self.poll_interval = poll_interval
def process_message(self, peer, mailfrom, rcpttos, data):
:func:`select` or :func:`poll` call by
:func:`asyncore.loop`.
"""
- asyncore.loop(poll_interval, map=self._map)
+ while not self._quit:
+ asyncore.loop(poll_interval, map=self._map, count=1)
def stop(self):
"""
Stop the thread by closing the server instance.
Wait for the server thread to terminate.
"""
- self.close()
+ self._quit = True
support.join_thread(self._thread)
self._thread = None
+ self.close()
asyncore.close_all(map=self._map, ignore_all=True)