Class Runtime

Initialize runtime.

Initialized a runtime owned by the given, the threshold, and optionally a set of options. The runtime has no network connections and knows of no other players -- the create_runtime function should be used instead to create a usable runtime.

Abort the execution due to an exception.

The protocol received bad data which resulted in exc being raised when unpacking.

Activate the reactor to do actual communcation.

This is where the recursion happens.

Secure addition.

At least one of the arguments must be a Share, the other can be a FieldElement or a (possible long) Python integer.

Input number to the computation.

The players listed in inputters must provide an input number, everybody will receive a list with Share objects, one from each inputter. If only a single player is listed in inputters, then a Share is given back directly.

Secure multiplication.

At least one of the arguments must be a Share, the other can be a FieldElement or a (possible long) Python integer.

Open share to receivers (defaults to all players).

Returns a Share to players with IDs in receivers and None to the remaining players.

Generate preprocess material.

The program specifies which methods to call and with which arguments. The generator methods called must adhere to the following interface:

• They must return a (int, Deferred) tuple where the int tells us how many items of pre-processed data the Deferred will yield.
• The Deferred must yield a list of the promised length.
• The list contains the actual data. This data can be either a Deferred or a tuple of Deferreds.

The ActiveRuntime.generate_triples method is an example of a method fulfilling this interface.

Execute the callbacks of the deferreds in the queue.

If this function is not called via activate_reactor(), also complex callbacks are executed.

Schedule a callback on a deferred with the correct program counter.

If a callback depends on the current program counter, then use this method to schedule it instead of simply calling addCallback directly. Simple callbacks that are independent of the program counter can still be added directly to the Deferred as usual.

Any extra arguments are passed to the callback as with addCallback.

Schedule a complex callback, i.e. a callback which blocks a long time.

Consider that the deferred is forked, i.e. if the callback returns something to be used afterwards, add further callbacks to the returned deferred.

Shutdown the runtime.

All connections are closed and the runtime cannot be used again after this has been called.

Introduce a synchronization point.

Returns a Deferred which will trigger if and when all other players have made their calls to synchronize. By adding callbacks to the returned Deferred, one can divide a protocol execution into disjoint phases.

Make the runtime wait for the variables given.

The runtime is shut down when all variables are calculated.

num_players

Number of known players.

Equal to len(self.players), but storing it here is more direct.

players

Information on players.

Mapping from Player ID to Player objects.

protocols

Connections to the other players.

Mapping from from Player ID to ShareExchanger objects.