6 def get_flow_content(self, tid=1, fid=1, priority=1):
8 flow_template = '''<?xml version="1.0" encoding="UTF-8" standalone="no"?>
9 <flow xmlns="urn:opendaylight:flow:inventory">
10 <strict>false</strict>
22 <table_id>%s</table_id>
24 <cookie_mask>4294967295</cookie_mask>
25 <installHw>false</installHw>
32 <ipv4-source>10.0.0.1</ipv4-source>
35 <flow-name>%s</flow-name>
36 <priority>%s</priority>
37 <barrier>false</barrier>
40 flow_data = flow_template % (tid, fid, fid, 'TestFlow-{0}'.format(fid), priority)
43 def is_cluter_set_up(self, rsp1, rsp2, rsp3):
46 for r in [rsp1, rsp2, rsp3]:
48 states.append(rj['value']['RaftState'])
50 if states == ['Follower', 'Follower', 'Leader']:
56 def get_persistence(self, rsp):
59 return rj['module'][0]['distributed-datastore-provider:config-properties']['persistent']