fedlab_core.server.pipe_topology

Module Contents

Classes

PipeTop	Abstract class for server Pipe topology
ConnectClient	Provide service to clients as a middle server
ConnectServer	connect to upper server

class fedlab_core.server.pipe_topology.PipeTop(model, server_process, client_process)

Bases: torch.multiprocessing.Process

Abstract class for server Pipe topology simple example

run(self)

process function

class fedlab_core.server.pipe_topology.ConnectClient(handler, server_address, world_size, dist_backend='gloo')

Bases: fedlab_core.server.topology.EndTop

Provide service to clients as a middle server

run(self)

activate_clients(self)

activate some of clients to join this FL round

listen_clients(self)

listen messages from clients

abstract share_buffer(self, buffer, lock)

class fedlab_core.server.pipe_topology.ConnectServer(locks, server_address, world_size, rank, dist_backend='gloo')

Bases: fedlab_core.client.topology.ClientCommunicationTopology

connect to upper server

abstract run(self)

Please override this function

receive(self, sender, message_code, payload)

synchronise(self, payload)

abstract share_buffer(self, buffer, lock)