pydistsim.demo_algorithms.santoro2007.yoyo.YoYo

class YoYo(*args, **kwargs)[source]

Bases: NodeAlgorithm

Methods

`__init__`
`add_observers`
`alarm`
`apply_restrictions`	Apply all applicable restrictions.
`block_inbox`	Block the inbox of a node, so that only messages that satisfy the filter can be processed.
`change_status`
`check_algorithm_initialization`	Check if the algorithm's current state matches the expected initial state.
`check_algorithm_termination`	Check if the algorithm's current state matches the expected termination state.
`check_restrictions`	Check if the restrictions are satisfied.
`clear_observers`
`close`	Close the inbox of the node for a specific neighbor.
`default`
`default_LEADER`
`default_PRUNED`
`disable_alarm`	Disable an alarm.
`disable_all_node_alarms`	Disable all alarms set for the node.
`do`
`do_intermediate`
`do_sink`
`do_source`
`initializer`	Method used to initialize the algorithm.
`invert_edges`
`is_halted`	Check if the distributed algorithm has come to an end or deadlock, i.e. there are no messages to pass and no alarms set.
`is_initialized`
`notify_observers`
`open`	Open the inbox of the node for a specific neighbor.
`prune_nodes`
`receive_id`
`receive_response`
`receiving`
`receiving_IDLE`
`receiving_INTERMEDIATE`
`receiving_SINK`
`receiving_SOURCE`
`reset`	Reset the algorithm to its initial state.
`send`	Send content to destination, with header.
`send_msg`	Send a message to nodes listed in message's destination field.
`send_responses`
`set_alarm`	Set an alarm for the node.
`spontaneously`
`spontaneously_INITIATOR`
`step`
`unblock_inbox`	Unblock the inbox of a node, so that all messages can be processed.
`update_alarm_time`	Update the time of an alarm by adding a time difference.

Attributes

`ID_KEY`
`INI`
`PRUNE_REQUEST`
`RECEIVED_IDS_KEY`
`RECEIVED_IDS_WHILE_WAITING_RESPONSE_KEY`
`RECEIVED_RESPONSES_KEY`
`REQUESTED_PRUNING_KEY`
`SENT_IDS_KEY`
`S_init`	Tuple of statuses that nodes should have at the beginning of the algorithm.
`S_term`	Tuple of statuses that nodes should have at the end of the algorithm.
`algorithm_restrictions`	Tuple of restrictions that must be satisfied for the algorithm to run.
`default_params`
`network`
`required_params`
`nwm`	Node wrapper manager.

S_init = (Status.INITIATOR, Status.IDLE): Tuple of statuses that nodes should have at the beginning of the algorithm.

S_term = (Status.LEADER, Status.PRUNED): Tuple of statuses that nodes should have at the end of the algorithm.

class Status(value, names=None, *, module=None, qualname=None, type=None, start=1, boundary=None)[source]

Bases: StatusValues

__new__(value)

_generate_next_value_(start, count, last_values): Return the lower-cased version of the member name.

_alarms: list[Alarm]: List of alarms set for the nodes.

algorithm_restrictions = (<class 'pydistsim.restrictions.communication.BidirectionalLinks'>, <class 'pydistsim.restrictions.reliability.TotalReliability'>, <class 'pydistsim.restrictions.topological.Connectivity'>, <class 'pydistsim.restrictions.knowledge.InitialDistinctValues'>): Tuple of restrictions that must be satisfied for the algorithm to run.

initializer()[source]

Method used to initialize the algorithm. Is always called first. NodeAlgorithm subclasses may want to reimplement it.

Base implementation sends an INI message to the node with the lowest id and applies all restrictions.