def run(self):
def on_ready_callback(parts):
logger.debug(
'On ready called with parts %s, calling my callback', parts
)
self.ready_callback(parts)
logger.debug('Request finished')
logger.debug(
'Starting http server on %s:%s' % (HTTP_ADDRESS, HTTP_PORT)
)
try:
self.server = HTTPServer(
(
HTTP_ADDRESS,
HTTP_PORT
),
get_handler(on_ready_callback))
except OSError:
logger.exception('Could not bind to address')
self.started_event.set()
else:
self.started_event.set()
logger.debug('Serving forever...')
self.server.serve_forever()
logger.debug('Server has shut down')
评论列表
文章目录