Lines Matching refs:server
57 A RPC server can be implemented as follows:
59 server = PipedRPCServer(server_pipe_fd)
60 server.register_introspection_functions()
61 server.register_function(lambda x,y: x+y, 'add')
62 server.serve_forever()
448 """Create a new PipedHTTP connection to the server. This
450 to the server, and then wrapping the local end of the pipe
472 """Send a request to the server."""
489 self.__pipe_file = PipeFile(fd, "server-transport")
502 """Trigger a shutdown of the RPC server. This is done via a
511 """Shutdown the server thread."""
528 return (PipeSocket(fd, "server-connection",
556 response = self.server._marshaled_dispatch(request)
559 # The server had an unexpected exception.
571 # tell the server to exit
572 self.server.initiate_shutdown()
603 # server encountered an error, time for seppuku
607 """Check for unexpected server exceptions while handling a
618 """Check for unexpected server exceptions while handling a
629 """Check for unexpected server exceptions while handling a
642 an RPC server on the other end of a pipe."""