lab/mininet-sample
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

user min_block_sep parameter, now set to 3

Browse Source
This commit is contained in:
Raphael Bauduin 2015-06-02 13:31:57 -07:00
parent a06c1de805
commit a4165812fd
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/mpBurstBlocks.py
View File

@ -6,7 +6,7 @@ class BurstBlocksAggregator:
def __init__(self, yml, test_name, dest_dir): def __init__(self, yml, test_name, dest_dir):
# csv_file="c2s_seq_1.csv" # csv_file="c2s_seq_1.csv"
# minimum delay to observe to identify the beginning of a block # minimum delay to observe to identify the beginning of a block
self.min_block_sep = 0.1 self.min_block_sep = 0.3
self.headers = [ "ts", "map_begin", "subflow", "is_seq", "map_end", "is_reinject" ] self.headers = [ "ts", "map_begin", "subflow", "is_seq", "map_end", "is_reinject" ]
self.log = open(dest_dir+"/burst_block_aggregator.log","w") self.log = open(dest_dir+"/burst_block_aggregator.log","w")
self.csv_file=dest_dir+"/"+"c2s_seq_1.csv" self.csv_file=dest_dir+"/"+"c2s_seq_1.csv"
@ -39,7 +39,7 @@ class BurstBlocksAggregator:
print >>self.log, "previous seq packet:", "{:10.8f}".format(self.a[previous][self.c("ts")]), "seq:", self.a[previous][self.c("map_begin")] print >>self.log, "previous seq packet:", "{:10.8f}".format(self.a[previous][self.c("ts")]), "seq:", self.a[previous][self.c("map_begin")]
print >>self.log, "found block starting at ", "{:10.8f}".format(self.a[i][self.c("ts")]), "seq:", self.a[i][self.c("map_begin")] print >>self.log, "found block starting at ", "{:10.8f}".format(self.a[i][self.c("ts")]), "seq:", self.a[i][self.c("map_begin")]
# we know the start of the block and look for its last packet # we know the start of the block and look for its last packet
elif self.a[i][self.c("ts")]-self.a[previous][self.c("ts")]>0.1: elif self.a[i][self.c("ts")]-self.a[previous][self.c("ts")]>self.min_block_sep:
print >>self.log, "next block:", "{:10.8f}".format(self.a[i+1][self.c("ts")]), "seq:", self.a[i+1][self.c("map_begin")] print >>self.log, "next block:", "{:10.8f}".format(self.a[i+1][self.c("ts")]), "seq:", self.a[i+1][self.c("map_begin")]
print >>self.log,"--------------------------------------" print >>self.log,"--------------------------------------"
# the ranges we use here are inclusive, ie the range contains both elements. # the ranges we use here are inclusive, ie the range contains both elements.