realm cleaned

This commit is contained in:
Matthew Stidham
2021-01-21 15:53:34 -08:00
committed by Jed Reynolds
parent 35fb049a1f
commit e8344dec8a

View File

@@ -1184,7 +1184,12 @@ class L3CXProfile(BaseProfile):
old_cx_rx_values = self.__get_rx_values() old_cx_rx_values = self.__get_rx_values()
timestamps = [] timestamps = []
# for x in range(0,int(round(iterations,0))): # for x in range(0,int(round(iterations,0))):
if col_names = None:
header_row=list((list(self.json_get("/endp/all")['endpoint'][0].values())[0].keys()))
while datetime.datetime.now() < end_time: while datetime.datetime.now() < end_time:
if fields = None:
response = self.json_get("/endp/all")
else:
response = self.json_get("/endp/%s?fields=%s" % (created_cx, fields)) response = self.json_get("/endp/%s?fields=%s" % (created_cx, fields))
if "endpoint" not in response: if "endpoint" not in response:
print(response) print(response)
@@ -1211,10 +1216,8 @@ class L3CXProfile(BaseProfile):
time.sleep(monitor_interval) time.sleep(monitor_interval)
print(value_map) print(value_map)
# if passes == expected_passes: #step 3 organize data
# self._pass("PASS: All tests passed") endpoints=list()
# step 3 organize data
endpoints = list()
for endpoint in value_map.values(): for endpoint in value_map.values():
endpoints.append(endpoint['endpoint']) endpoints.append(endpoint['endpoint'])
endpoints2 = [] endpoints2 = []
@@ -1226,6 +1229,7 @@ class L3CXProfile(BaseProfile):
itertools.chain.from_iterable(itertools.repeat(x, len(created_cx.split(','))) for x in timestamps)) itertools.chain.from_iterable(itertools.repeat(x, len(created_cx.split(','))) for x in timestamps))
for point in range(0, len(endpoints2)): for point in range(0, len(endpoints2)):
endpoints2[point].insert(0, timestamps2[point]) endpoints2[point].insert(0, timestamps2[point])
# step 4 save and close # step 4 save and close
header_row = col_names header_row = col_names
header_row.insert(0, 'Timestamp') header_row.insert(0, 'Timestamp')
@@ -3493,7 +3497,7 @@ class StationProfile:
# First, request remove on the list. # First, request remove on the list.
for port_eid in desired_stations: for port_eid in desired_stations:
self.local_realm.rm_port(port_eid, check_exists=True, debug_=debug_) self.local_realm.rm_port(port_eid, check_exists=True, debug_=debug_)
time.sleep(delay)
# And now see if they are gone # And now see if they are gone
LFUtils.wait_until_ports_disappear(base_url=self.lfclient_url, port_list=desired_stations) LFUtils.wait_until_ports_disappear(base_url=self.lfclient_url, port_list=desired_stations)