Open Kilda Java Documentation
tests.test_flow_segments Namespace Reference

Functions

def do_push_alot (iteration)
 

Variables

dictionary flow1
 
list isls1
 
 result = flow_utils.fetch_flow_segments(flow1['flowid'], flow1['cookie'])
 
 mc = messageclasses.MessageItem(payload=isl)
 
int r1a = 0x2000000000000001
 
int r1b = 0x2000000000000002
 
int f1a = 0x4000000000000001
 
int f1b = 0x4000000000000002
 
dictionary create_flow
 
dictionary delete_flow
 
dictionary update_flow
 
 event_create = messageclasses.MessageItem(**create_flow)
 
 logger = logging.getLogger('topologylistener.messageclasses')
 
 event_delete = messageclasses.MessageItem(**update_flow)
 
int test_range = 20
 
int num_proc = 5
 
 p = Pool(processes=num_proc)
 

Function Documentation

◆ do_push_alot()

def tests.test_flow_segments.do_push_alot (   iteration)

Definition at line 242 of file test_flow_segments.py.

Variable Documentation

◆ create_flow

dictionary tests.test_flow_segments.create_flow

Definition at line 100 of file test_flow_segments.py.

◆ delete_flow

dictionary tests.test_flow_segments.delete_flow

Definition at line 135 of file test_flow_segments.py.

◆ event_create

tests.test_flow_segments.event_create = messageclasses.MessageItem(**create_flow)

Definition at line 206 of file test_flow_segments.py.

◆ event_delete

tests.test_flow_segments.event_delete = messageclasses.MessageItem(**update_flow)

Definition at line 215 of file test_flow_segments.py.

◆ f1a

int tests.test_flow_segments.f1a = 0x4000000000000001

Definition at line 96 of file test_flow_segments.py.

◆ f1b

int tests.test_flow_segments.f1b = 0x4000000000000002

Definition at line 97 of file test_flow_segments.py.

◆ flow1

dictionary tests.test_flow_segments.flow1
Initial value:
1 = {
2  'flowid' : 'fred_id',
3  'cookie': 1000,
4  'meter_id': 2000,
5  'bandwidth': 3000,
6  'ignore_bandwidth': False,
7  'src_port': 1,
8  'dst_port': 2,
9  'src_switch': 'DE:AD:BE:EF:11:11:11:11',
10  'dst_switch': 'DE:AD:BE:EF:33:33:33:33',
11  'src_vlan': 3,
12  'dst_vlan': 4,
13  'transit_vlan': 5,
14  'description': 'Test Flow #1',
15  'last_updated': 'Last Full Moon',
16  'flowpath': {
17  'latency_ns': 10,
18  'path': [
19  {'switch_id': 'DE:AD:BE:EF:11:11:11:11', 'port_no': 5, 'seq_id': 1, 'segment_latency': 11},
20  {'switch_id': 'DE:AD:BE:EF:22:22:22:22', 'port_no': 6, 'seq_id': 2, 'segment_latency': 22},
21  {'switch_id': 'DE:AD:BE:EF:22:22:22:22', 'port_no': 7, 'seq_id': 3, 'segment_latency': 33},
22  {'switch_id': 'DE:AD:BE:EF:33:33:33:33', 'port_no': 8, 'seq_id': 4, 'segment_latency': 44},
23  ]
24  }
25 }

Definition at line 21 of file test_flow_segments.py.

◆ isls1

list tests.test_flow_segments.isls1
Initial value:
1 = [
2  {
3  'latency_ns': 100,
4  'speed': 1000,
5  'available_bandwidth': 10000,
6  'path': [{'switch_id': 'DE:AD:BE:EF:11:11:11:11','port_no': 5},
7  {'switch_id': 'DE:AD:BE:EF:22:22:22:22','port_no': 6}]
8  },
9  {
10  'latency_ns': 200,
11  'speed': 2000,
12  'available_bandwidth': 20000,
13  'path': [{'switch_id': 'DE:AD:BE:EF:22:22:22:22', 'port_no': 7},
14  {'switch_id': 'DE:AD:BE:EF:33:33:33:33', 'port_no': 8}]
15  }]

Definition at line 47 of file test_flow_segments.py.

◆ logger

tests.test_flow_segments.logger = logging.getLogger('topologylistener.messageclasses')

Definition at line 212 of file test_flow_segments.py.

◆ mc

tests.test_flow_segments.mc = messageclasses.MessageItem(payload=isl)

Definition at line 75 of file test_flow_segments.py.

◆ num_proc

int tests.test_flow_segments.num_proc = 5

Definition at line 240 of file test_flow_segments.py.

◆ p

tests.test_flow_segments.p = Pool(processes=num_proc)

Definition at line 251 of file test_flow_segments.py.

◆ r1a

int tests.test_flow_segments.r1a = 0x2000000000000001

Definition at line 94 of file test_flow_segments.py.

◆ r1b

int tests.test_flow_segments.r1b = 0x2000000000000002

Definition at line 95 of file test_flow_segments.py.

◆ result

tests.test_flow_segments.result = flow_utils.fetch_flow_segments(flow1['flowid'], flow1['cookie'])

Definition at line 68 of file test_flow_segments.py.

◆ test_range

int tests.test_flow_segments.test_range = 20

Definition at line 239 of file test_flow_segments.py.

◆ update_flow

dictionary tests.test_flow_segments.update_flow

Definition at line 171 of file test_flow_segments.py.