| Index: testing/legion/client_rpc_server.py
|
| diff --git a/testing/legion/rpc_server.py b/testing/legion/client_rpc_server.py
|
| similarity index 94%
|
| rename from testing/legion/rpc_server.py
|
| rename to testing/legion/client_rpc_server.py
|
| index 43b431707e851c0601058c401a3dcf3d0201c255..7a5f565156da667f7454703d4a04df3d145d7d92 100644
|
| --- a/testing/legion/rpc_server.py
|
| +++ b/testing/legion/client_rpc_server.py
|
| @@ -2,10 +2,10 @@
|
| # Use of this source code is governed by a BSD-style license that can be
|
| # found in the LICENSE file.
|
|
|
| -"""The task RPC server code.
|
| +"""The client RPC server code.
|
|
|
| This server is an XML-RPC server which serves code from
|
| -rpc_methods.RPCMethods.
|
| +client_rpc_methods.RPCMethods.
|
|
|
| This server will run until shutdown is called on the server object. This can
|
| be achieved in 2 ways:
|
| @@ -22,8 +22,8 @@ import SimpleXMLRPCServer
|
| import SocketServer
|
|
|
| #pylint: disable=relative-import
|
| +import client_rpc_methods
|
| import common_lib
|
| -import rpc_methods
|
|
|
|
|
| class RequestHandler(SimpleXMLRPCServer.SimpleXMLRPCRequestHandler):
|
| @@ -33,10 +33,10 @@ class RequestHandler(SimpleXMLRPCServer.SimpleXMLRPCRequestHandler):
|
| """
|
|
|
| def do_POST(self):
|
| - """Verifies the task is authorized to perform RPCs."""
|
| + """Verifies the client is authorized to perform RPCs."""
|
| if self.client_address[0] != self.server.authorized_address:
|
| logging.error('Received unauthorized RPC request from %s',
|
| - self.task_address[0])
|
| + self.client_address[0])
|
| self.send_response(403)
|
| response = 'Forbidden'
|
| self.send_header('Content-type', 'text/plain')
|
| @@ -60,7 +60,7 @@ class RPCServer(SimpleXMLRPCServer.SimpleXMLRPCServer,
|
|
|
| self.authorized_address = authorized_address
|
| self.idle_timeout_secs = idle_timeout_secs
|
| - self.register_instance(rpc_methods.RPCMethods(self))
|
| + self.register_instance(client_rpc_methods.RPCMethods(self))
|
|
|
| self._shutdown_requested_event = threading.Event()
|
| self._rpc_received_event = threading.Event()
|
|
|