easgd_server.py 文件源码

def run(self, model):

        if self.comm == None:

            print('Server communicator not initialized')

            return

        print('server started')

        while True:
            #  Wait for next request from client

            request = self.comm.recv(source=MPI.ANY_SOURCE, tag=199)

            #  Do some process work and formulate a reply
            reply = self.process_request(model, request['id'],
                                        request['rank'],request['message'])

            #  Send reply back to client
            self.comm.send(reply, dest=request['rank'], tag=200)

            # Do some action work after reply
            self.action_after(model, request['id'],
                                request['rank'], request['message'])