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(now)

raises event for event sock heartbeat

healthy_stack_roots(now, candidate_dps)

Return list of healthy stack root names.

load_configs(now, new_config_file, delete_dp=None)

Load/apply new config to all Valves.

maintain_stack_root(now)

Maintain current stack root and return True if stack root changes.

new_valve(new_dp)

parse_configs(new_config_file)

Return parsed configs for Valves, or None.

port_status_handler(valve, msg)

Handle a port status change message.

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.

update_config_applied(sent=None, reset=False)

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

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 = None