flow_utils.py File Reference

Go to the source code of this file.

Namespaces
	topologylistener.flow_utils

Functions
def	topologylistener.flow_utils.is_forward_cookie (cookie)
def	topologylistener.flow_utils.is_reverse_cookie (cookie)
def	topologylistener.flow_utils.cookie_to_hex (cookie)
def	topologylistener.flow_utils.is_same_direction (first, second)
def	topologylistener.flow_utils.choose_output_action (input_vlan_id, output_vlan_id)
def	topologylistener.flow_utils.get_one_switch_rules (src_switch, src_port, src_vlan, dst_port, dst_vlan, bandwidth, flowid, cookie, meter_id, output_action, k)
def	topologylistener.flow_utils.get_rules (src_switch, src_port, src_vlan, dst_switch, dst_port, dst_vlan, bandwidth, transit_vlan, flowid, cookie, flowpath, meter_id, output_action, k)
def	topologylistener.flow_utils.build_rules (flow)
def	topologylistener.flow_utils.remove_flow (flow, parent_tx=None)
def	topologylistener.flow_utils.merge_flow_relationship (flow_data, tx=None)
def	topologylistener.flow_utils.merge_flow_segments (_flow, tx=None)
def	topologylistener.flow_utils.get_flow_path (flow)
def	topologylistener.flow_utils.delete_flow_segments (flow, tx=None)
def	topologylistener.flow_utils.fetch_flow_segments (flowid, parent_cookie)
def	topologylistener.flow_utils.update_flow_segment_available_bw (flow, tx=None)
def	topologylistener.flow_utils.update_isl_bandwidth (src_switch, src_port, dst_switch, dst_port, tx=None)
def	topologylistener.flow_utils.store_flow (flow, tx=None)
def	topologylistener.flow_utils.hydrate_flow (one_row)
def	topologylistener.flow_utils.get_old_flow (new_flow)
def	topologylistener.flow_utils.get_flows ()
def	topologylistener.flow_utils.precreate_switches (tx, nodes)
def	topologylistener.flow_utils.get_flow_segments_by_dst_switch (switch_id)
def	topologylistener.flow_utils.get_flows_by_src_switch (switch_id)
def	topologylistener.flow_utils.validate_switch_rules (switch_id, switch_rules)
def	topologylistener.flow_utils.build_commands_to_sync_rules (switch_id, switch_rules)
def	topologylistener.flow_utils.build_install_command_from_segment (segment)
def	topologylistener.flow_utils.get_flow_by_id_and_cookie (flow_id, cookie)
def	topologylistener.flow_utils.get_flow_segment_by_src_switch_and_cookie (switch_id, parent_cookie)

Variables
	topologylistener.flow_utils.graph = db.create_p2n_driver()
	topologylistener.flow_utils.logger = logging.getLogger(__name__)
list	topologylistener.flow_utils.default_rules
int	topologylistener.flow_utils.cookie_flag_forward = 0x4000000000000000
int	topologylistener.flow_utils.cookie_flag_reverse = 0x2000000000000000