def serve_forever(self):
logger.info(
('action', 'console_server_running'),
('tid', get_thread_number()),
)
# ???????
self._handler = ConsoleHandler()
if self.code:
self._handler.runsource(self.code)
# ???????
from SimpleXMLRPCServer import SimpleXMLRPCRequestHandler
class RequestHandler(SimpleXMLRPCRequestHandler):
rpc_paths = ('/rConsole',)
# ???server??
from SimpleXMLRPCServer import SimpleXMLRPCServer
self._server = SimpleXMLRPCServer(
(self.addr, self.port),
requestHandler=RequestHandler,
logRequests=False,
)
# ????????
self._server.register_function(self._handler.runsource, "runsource")
logger.info(
('action', 'xmlrpc_server_serving'),
('tid', get_thread_number()),
)
# ??RPC??
self._server.serve_forever()
评论列表
文章目录