:mod:`fedlab_core.server.pipe_topology`
=======================================

.. py:module:: fedlab_core.server.pipe_topology


Module Contents
---------------

Classes
~~~~~~~

.. autoapisummary::

   fedlab_core.server.pipe_topology.PipeTop
   fedlab_core.server.pipe_topology.ConnectClient
   fedlab_core.server.pipe_topology.ConnectServer



.. class:: PipeTop(model, server_process, client_process)


   Bases: :class:`torch.multiprocessing.Process`

   Abstract class for server Pipe topology
   simple example

   .. method:: run(self)

      process function



.. class:: ConnectClient(handler, server_address, world_size, dist_backend='gloo')


   Bases: :class:`fedlab_core.server.topology.EndTop`

   Provide service to clients as a middle server

   .. method:: run(self)


   .. method:: activate_clients(self)

      activate some of clients to join this FL round


   .. method:: listen_clients(self)

      listen messages from clients


   .. method:: share_buffer(self, buffer, lock)
      :abstractmethod:



.. class:: ConnectServer(locks, server_address, world_size, rank, dist_backend='gloo')


   Bases: :class:`fedlab_core.client.topology.ClientCommunicationTopology`

   connect to upper server

   .. method:: run(self)
      :abstractmethod:

      Please override this function


   .. method:: receive(self, sender, message_code, payload)


   .. method:: synchronise(self, payload)


   .. method:: share_buffer(self, buffer, lock)
      :abstractmethod: