coordinator.server.Server Class Reference

Public Member Functions
def	__init__ (self, IContributionHandler handler, Configuration server_config, str server_dir)
None	stop (self)

Public Attributes
	handler
	config
	upload_file
	state_file_path
	processing
	contributors
	state
	handler_finalized
	state_lock
	thread
	server

Detailed Description

Server to coordinate an MPC, that serves challenges and accepts responses
from contributors. Performs basic contribution management, ensuring
contributions are from the correct party and submitted within the correct
time window. MPC-specific operations (validation / challenge computation,
etc) are performed by an IContributionHandler object.

Definition at line 38 of file server.py.

Constructor & Destructor Documentation

__init__()

def coordinator.server.Server.__init__	(		self,
		IContributionHandler	handler,
		Configuration	server_config,
		str	server_dir
	)

Definition at line 47 of file server.py.

    def __init__(
            self,
            handler: IContributionHandler,
            server_config: Configuration,
            server_dir: str):
 
        logging.basicConfig(filename=LOG_FILE, level=logging.DEBUG)
        self.handler = handler
        self.config = server_config
        self.contributors: ContributorList
        self.upload_file = join(server_dir, UPLOAD_FILE)
        self.state_file_path = join(server_dir, STATE_FILE)
        self.state: ServerState
        self.processing = False
 
        # Try to open contributors file and state files. Perform sanity checks.
        with open(self.config.contributors_file, "r") as contributors_f:
            self.contributors = ContributorList.from_json(contributors_f.read())
        print(f"Contributors: {self.contributors}")
        self.contributors.ensure_validity()
 
        if exists(STATE_FILE):
            info(f"run_server: using existing state file: {STATE_FILE}")
            with open(STATE_FILE, "r") as state_f:
                self.state = ServerState.from_json(state_f.read())
        else:
            self.state = initial_server_state(self.config, self.contributors)
            self._write_state_file()
            self._notify_next_contributor()
 
        self.handler_finalized = self.state.have_all_contributions()
        self.state_lock = Lock()
        self.server: Optional[WSGIServer] = None
        self.thread = Thread(target=self._run)
        self.thread.start()
 
        while self.server is None or self.server.socket is None:
            info("Waiting for MPC server to start ...")
            time.sleep(1)
        port = self.server.socket.getsockname()[1]
        info(f"MPC server started (port: {port}).")
 

Member Function Documentation

stop()

None coordinator.server.Server.stop

(

self

)

Definition at line 89 of file server.py.

    def stop(self) -> None:
        if self.server is not None:
            self.server.stop()
            while self.server is not None:
                info("Waiting for server to stop ...")
                time.sleep(1.0)
            self.thread.join()
            info("Server stopped.")
 

Here is the call graph for this function:

Member Data Documentation

config

coordinator.server.Server.config

Definition at line 51 of file server.py.

contributors

coordinator.server.Server.contributors

Definition at line 60 of file server.py.

handler

coordinator.server.Server.handler

Definition at line 50 of file server.py.

handler_finalized

coordinator.server.Server.handler_finalized

Definition at line 73 of file server.py.

processing

coordinator.server.Server.processing

Definition at line 56 of file server.py.

server

coordinator.server.Server.server

Definition at line 336 of file server.py.

state

coordinator.server.Server.state

Definition at line 67 of file server.py.

state_file_path

coordinator.server.Server.state_file_path

Definition at line 54 of file server.py.

state_lock

coordinator.server.Server.state_lock

Definition at line 74 of file server.py.

thread

coordinator.server.Server.thread

Definition at line 76 of file server.py.

upload_file

coordinator.server.Server.upload_file

Definition at line 53 of file server.py.

---

The documentation for this class was generated from the following file:

• /home/runner/work/zeth/zeth/mpc/coordinator/server.py