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.ValvesManager(logname, logger, metrics, notifier, bgp, dot1x, send_flows_to_dp_by_id)

Bases: object

Manage a collection of Valves.

load_configs(now, new_config_file, delete_dp=None)

Load/apply new config to all Valves.

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.

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