BFD: basic asynchronous session up/down - vpp

diff options

author	Klement Sekera <ksekera@cisco.com>	2016-09-29 14:43:44 +0200
committer	Dave Barach <openvpp@barachs.net>	2016-12-07 19:54:12 +0000
commit	0e3c0de1ed87f3cdf16e26e05e39ea6eebeafb18 (patch)
tree	dd5f11c08311a95ce56eb8c33d4e8681940bf877 /vpp-api/python/tests/test_modules.py
parent	d171d48edc1672564db8bb920586b8ea220df14c (diff)

BFD: basic asynchronous session up/down

This is a work-in-progress basic BFD session handling. Only asynchronous mode is supported at the moment. Setting the session flags doesn't work. Change-Id: Idba27f721b5c35be5a66a6d202a63d23ff7ecf6f Signed-off-by: Klement Sekera <ksekera@cisco.com>

Diffstat (limited to 'vpp-api/python/tests/test_modules.py')

0 files changed, 0 insertions, 0 deletions

#!/usr/bin/env python import sys import re import argparse import matplotlib.pyplot as plt from matplotlib.lines import Line2D class Point(): "CC event" def __init__(self, x, y): self.x = x self.y = y def listx(points): return list(map(lambda pt: pt.x, points)) def listy(points): return list(map(lambda pt: pt.y, points)) def plot_data(d): plt.figure(1) cwndx = listx(d["cwnd"]) cwndy = listy(d["cwnd"]) congx = listx(d["congestion"]) congy = listy(d["congestion"]) rcvrdx = listx(d["recovered"]) rcvrdy = listy(d["recovered"]) rxttx = listx(d["rxtTimeout"]) rxtty = listy(d["rxtTimeout"]) # cwnd/ssthresh/cc events plt.subplot(311) plt.title("cwnd/ssthresh") pcwnd = plt.plot(cwndx, cwndy, 'r') psst = plt.plot(cwndx, d["ssthresh"], 'y-') pcong = plt.plot(congx, congy,'yo') precov = plt.plot(rcvrdx, rcvrdy,'co') prxtt = plt.plot(rxttx, rxtty,'mo') marker1 = Line2D(range(1), range(1), color="r") marker2 = Line2D(range(1), range(1), color="y") marker3 = Line2D(range(1), range(1), color="w", marker="o", markerfacecolor="y") marker4 = Line2D(range(1), range(1), color="w", marker="o", markerfacecolor="c") marker5 = Line2D(range(1), range(1), color="w", marker="o", markerfacecolor="m") plt.legend((marker1, marker2, marker3, marker4, marker5), ('cwnd', 'ssthresh', 'congestion', 'recovered', 'rxt-timeout'), loc=4) axes = plt.gca() axes.set_ylim([-20e4, max(cwndy) + 20e4]) # snd variables plt.subplot(312) plt.title("cc variables") plt.plot(cwndx, d["space"], 'g-', markersize=1) plt.plot(cwndx, d["flight"], 'b-', markersize=1) plt.plot(cwndx, d["sacked"], 'm:', markersize=1) plt.plot(cwndx, d["lost"], 'y:', markersize=1) plt.plot(cwndx, d["cc-space"], 'k:', markersize=1) plt.plot(cwndx, cwndy, 'ro', markersize=2) plt.plot(congx, congy, 'y^', markersize=10, markerfacecolor="y") plt.plot(rcvrdx, rcvrdy, 'c^', markersize=10, markerfacecolor="c") plt.plot(rxttx, rxtty, 'm^', markersize=10, markerfacecolor="m") #plt.plot(cwndx, d["snd_wnd"], 'ko', markersize=1) plt.legend(("snd-space", "flight", "sacked", "lost", "cc-space", "cwnd", "congestion", "recovered", "rxt-timeout"), loc=1) # rto/srrt/rttvar plt.subplot(313) plt.title("rtt") plt.plot(cwndx, d["srtt"], 'g-') plt.plot(cwndx, [x/1000 for x in d["mrtt-us"]], 'r-') plt.plot(cwndx, d["rttvar"], 'b-') plt.legend(["srtt", "mrtt-us", "rttvar"]) axes = plt.gca() #plt.plot(cwndx, rto, 'r-') #axes.set_ylim([0, int(max(rto[2:len(rto)])) + 50]) # show plt.show() def find_pattern(file_path,session_idx): is_active_open = 1 listener_pattern = "l\[\d\]" if (is_active_open): initial_pattern = "\[\d\](\.\d+:\d+\->\.\d+:\d+)\s+open:\s" else: initial_pattern = "\[\d\](\.\d+:\d+\->\.\d+:\d+)\s" idx = 0 f = open(file_path, 'r') for line in f: # skip listener lines (server) if (re.search(listener_pattern, line) != None): continue match = re.search(initial_pattern, line) if (match == None): continue if (idx < session_idx): idx += 1 continue filter_pattern = str(match.group(1)) + "\s+(.+)" print ("pattern is %s" % filter_pattern) f.close() return filter_pattern raise Exception ("Could not find initial pattern") def compute_time(min, sec, msec): return int(min)*60 + int(sec) + int(msec)/1000.0 def run(file_path, session_idx): filter_sessions = 1 filter_pattern = "" patterns = { "time" : "^\d+:(\d+):(\d+):(\d+):\d+", "listener" : "l\[\d\]", "cc" : "cwnd (\d+) flight (\d+) space (\d+) ssthresh (\d+) snd_wnd (\d+)", "cc-snd" : "cc_space (\d+) sacked (\d+) lost (\d+)", "rtt" : "rto (\d+) srtt (\d+) mrtt-us (\d+) rttvar (\d+)", "rxtt" : "rxt-timeout", "congestion": "congestion", "recovered" : "recovered", } d = { "cwnd" : [], "space" : [], "flight" : [], "ssthresh" : [], "snd_wnd" : [], "cc-space" : [], "lost" : [], "sacked" : [], "rto" : [], "srtt" : [], "mrtt-us" : [], "rttvar" : [], "rxtTimeout" : [], "congestion" : [], "recovered" : [], } if (filter_sessions): filter_pattern = find_pattern(file_path, session_idx) f = open(file_path, 'r') stats_index = 0 start_time = 0 for line in f: # skip listener lines (server) if (re.search(patterns["listener"], line) != None): continue # filter sessions if (filter_sessions): match = re.search(filter_pattern, line) if (match == None): continue original_line = line line = match.group(1) match = re.search (patterns["time"], original_line) if (match == None): print "something went wrong! no time!" continue time = compute_time (match.group(1), match.group(2), match.group(3)) if (start_time == 0): start_time = time time = time - start_time match = re.search(patterns["cc"], line) if (match != None): d["cwnd"].append(Point(time, int(match.group(1)))) d["flight"].append(int(match.group(2))) d["space"].append(int(match.group(3))) d["ssthresh"].append(int(match.group(4))) d["snd_wnd"].append(int(match.group(5))) stats_index += 1 continue match = re.search(patterns["cc-snd"], line) if (match != None): d["cc-space"].append(int(match.group(1))) d["sacked"].append(int(match.group(2))) d["lost"].append(int(match.group(3))) match = re.search(patterns["rtt"], line) if (match != None): d["rto"].append(int(match.group(1))) d["srtt"].append(int(match.group(2))) d["mrtt-us"].append(int(match.group(3))) d["rttvar"].append(int(match.group(4))) if (stats_index == 0): continue match = re.search(patterns["rxtt"], line) if (match != None): d["rxtTimeout"].append(Point(time, d["cwnd"][stats_index - 1].y + 1e4)) continue match = re.search(patterns["congestion"], line) if (match != None): d["congestion"].append(Point(time, d["cwnd"][stats_index - 1].y - 1e4)) continue match = re.search(patterns["recovered"], line) if (match != None): d["recovered"].append(Point(time, d["cwnd"][stats_index - 1].y)) continue plot_data(d) if __name__ == "__main__": parser = argparse.ArgumentParser(description="Plot tcp cc logs") parser.add_argument('-f', action='store', dest='file', required=True, help="elog file in txt format") parser.add_argument('-s', action='store', dest='session_index', default=0, help="session index for which to plot cc logs" ) results = parser.parse_args() run(results.file, int(results.session_index))


context:
space:
mode: