scottk/wlan-lanforge-scripts
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-lanforge-scripts.git synced 2025-10-31 18:58:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

correct timestamps with realm

Browse Source
This commit is contained in:
Matthew Stidham
2021-01-12 16:40:18 -08:00
parent 1fb560cca6
commit 2b57497ee2
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
py-json/realm.py
View File

@@ -1110,29 +1110,28 @@ class L3CXProfile(LFCliBase):
fields=",".join(col_names) fields=",".join(col_names)
#Step 2, monitor columns #Step 2, monitor columns
start_time = datetime.datetime.now() start_time = datetime.datetime.now()
end_time = start_time + datetime.timedelta(seconds=duration_sec) iterations=duration_sec/monitor_interval
value_map = dict() value_map = dict()
passes = 0 passes = 0
expected_passes = 0 expected_passes = 0
old_cx_rx_values = self.__get_rx_values() old_cx_rx_values = self.__get_rx_values()
timestamps=[] timestamps=[]
while datetime.datetime.now() < end_time: for x in range(0,int(round(iterations,0))):
timepoints.append(datetime.datetime.now())
response = self.json_get("/endp/%s?fields=%s" % (created_cx, fields), debug_=self.debug) response = self.json_get("/endp/%s?fields=%s" % (created_cx, fields), debug_=self.debug)
if "endpoint" not in response: if "endpoint" not in response:
print(response) print(response)
raise ValueError("no endpoint?") raise ValueError("no endpoint?")
if show: if show:
print(response) print(response)
value_map[datetime.datetime.now()]=response t=datetime.datetime.now()
if datetime.datetime.now() > end_time: timestamps.append(t)
break value_map[t]=response
new_cx_rx_values = self.__get_rx_values() new_cx_rx_values = self.__get_rx_values()
if self.debug: if self.debug:
print(old_cx_rx_values, new_cx_rx_values) print(old_cx_rx_values, new_cx_rx_values)
print("\n-----------------------------------") print("\n-----------------------------------")
print(curr_time, end_time) print(curr_time)
print("-----------------------------------\n") print("-----------------------------------\n")
expected_passes += 1 expected_passes += 1
if self.__compare_vals(old_cx_rx_values, new_cx_rx_values): if self.__compare_vals(old_cx_rx_values, new_cx_rx_values):
@@ -1154,8 +1153,10 @@ class L3CXProfile(LFCliBase):
for y in range(0, len(endpoints)): for y in range(0, len(endpoints)):
for x in range(0, len(endpoints[0])): for x in range(0, len(endpoints[0])):
endpoints2.append(list(list(endpoints[y][x].values())[0].values())) endpoints2.append(list(list(endpoints[y][x].values())[0].values()))
import itertools
timestamps2=list(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, timestamps[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')