scottk/wlan-lanforge-scripts
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-lanforge-scripts.git synced 2025-11-01 03:07:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Updates : printing endpoint data on console

Browse Source 
Signed-off-by: shivamcandela <shivam.thakur@candelatech.com>
This commit is contained in:
shivamcandela
2021-05-02 14:21:41 +05:30
parent af38037016
commit a24fef3a13
2 changed files with 17 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
py-json/l3_cxprofile.py
View File

@@ -252,17 +252,27 @@ class L3CXProfile(LFCliBase):
self.fail("FAIL: Not all stations increased traffic") self.fail("FAIL: Not all stations increased traffic")
self.exit_fail() self.exit_fail()
try: try:
self.refresh_cx()
cx_data = self.json_get("/cx/all") cx_data = self.json_get("/cx/all")
cx_data.pop("handler") cx_data.pop("handler")
cx_data.pop("uri") cx_data.pop("uri")
for i in self.created_cx.keys(): for i in self.created_cx.keys():
print("cx name: ", i, endp_a_data = self.json_get("/endp/"+ cx_data[i]['endpoints'][0])
" bps tx a :", cx_data[i]['bps tx a'], " bps rx a : ", cx_data[i]['bps rx a'], endp_b_data = self.json_get("/endp/" + cx_data[i]['endpoints'][1])
" bps tx b :", cx_data[i]['bps tx b'], " bps rx b : ", cx_data[i]['bps rx b'], print("cx name:", i, "\n",
" bps tx a :", endp_a_data['endpoint']['tx rate'], " --> ",
" bps rx b : ", endp_b_data['endpoint']['rx rate'],
" rx drop % b : ", cx_data[i]['rx drop % b'], "\n"
" tx bytes a : ", endp_a_data['endpoint']['tx bytes'], " --> "
" rx bytes b", endp_b_data['endpoint']['rx bytes'], "\n"
" tx bytes b : ", endp_b_data['endpoint']['tx bytes'], " --> "
" rx bytes a", endp_a_data['endpoint']['rx bytes'], "\n"
" bps tx b :", endp_b_data['endpoint']['tx rate'], " --> "
" bps rx a : ", endp_a_data['endpoint']['rx rate'],
" rx drop % a :", cx_data[i]['rx drop % a'], "\n"
" pkt rx a :", cx_data[i]['pkt rx a'], " pkt rx b : ", cx_data[i]['pkt rx b'], " pkt rx a :", cx_data[i]['pkt rx a'], " pkt rx b : ", cx_data[i]['pkt rx b'],
" rx drop % a :", cx_data[i]['rx drop % a'], " rx drop % b : ", cx_data[i]['rx drop % b']) )
print("\n") print("\n\n\n")
except Exception as e: except Exception as e:
print(e) print(e)
time.sleep(monitor_interval_ms) time.sleep(monitor_interval_ms)

2
py-scripts/test_ipv4_variable_time.py
View File

@@ -291,7 +291,7 @@ python3 ./test_ipv4_variable_time.py
parser.add_argument('--compared_report', help='report path and file which is wished to be compared with new report', parser.add_argument('--compared_report', help='report path and file which is wished to be compared with new report',
default=None) default=None)
parser.add_argument('--monitor_interval', parser.add_argument('--monitor_interval',
help='how frequently do you want your monitor function to take measurements; 250ms, 35s, 2h', help='how frequently do you want your monitor function to take measurements; \, 35s, 2h',
default='10s') default='10s')
parser.add_argument('--influx_token', help='Username for your Influx database') parser.add_argument('--influx_token', help='Username for your Influx database')
parser.add_argument('--influx_bucket', help='Password for your Influx database') parser.add_argument('--influx_bucket', help='Password for your Influx database')