faucet.valves_manager module

Manage a collection of Valves.

class faucet.valves_manager.ConfigWatcher

Bases: object

Watch config for file or content changes.

config_file = None

config_file_stats = None

config_hashes = None

content_changed(new_config_file)

Return True if config file content actually changed.

files_changed()

Return True if any config files changed.

update(new_config_file, new_config_hashes=None)

Update state with new config file/hashes.

class faucet.valves_manager.MetaDPState

Bases: object

Contains state/config about all DPs.

class faucet.valves_manager.ValvesManager(logname, logger, metrics, notifier, bgp, dot1x, config_auto_revert, send_flows_to_dp_by_id)

Bases: object

Manage a collection of Valves.

datapath_connect(now, valve, discovered_up_ports)

Handle connection from DP.

event_socket_heartbeat()

raises event for event sock heartbeat

load_configs(now, new_config_file, delete_dp=None)

Load/apply new config to all Valves.

maintain_stack_root(now, update_time)

Maintain current stack root

Parameters:

• now (float) – Current time

• update_time (int) – Stack root update time interval

new_valve(new_dp)

parse_configs(new_config_file)

Return parsed configs for Valves, or None.

port_desc_stats_reply_handler(valve, msg, now)

Handle a port desc stats reply message.

port_status_handler(valve, msg, now)

Handle a port status change message.

reload_stack_root_config(now)

Force reload & apply configuration for stack root changes :param now: Current time :type now: float

request_reload_configs(now, new_config_file, delete_dp=None)

Process a request to load config changes.

revert_config()

Attempt to revert config to last known good version.

set_stack_root(now, new_root_name)

Set stack root

Parameters:

• now (float) – Current time

• new_root_name (string) – Name of new stack root

update_config_applied(sent=None, reset=False)

Update faucet_config_applied from {dpid: sent} dict, defining applied == sent == enqueued via Ryu

update_dp_live_time(now)

Update DP running time

Parameters:

now (float) – Current time

update_metrics(now)

Update metrics in all Valves.

valve_flow_services(now, valve_service)

Call a method on all Valves and send any resulting flows.

valve_packet_in(now, valve, msg)

Time a call to Valve packet in handler.

valves_by_name()

Return a name/valve dict of all the stacking valves