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

looking at first packet of block with (seq - first transmission seq) modulo 65536 = 1428

Browse Source
This commit is contained in:
Raphael Bauduin 2015-06-03 09:41:23 -07:00
parent 944720a29e
commit ef9464fab2
1 changed files with 9 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/mpBurstBlocks.py
View File

@ -56,26 +56,20 @@ class BurstBlocksAggregator:
b=0 b=0
# iteration, we can start at packet 1 # iteration, we can start at packet 1
i=1 i=1
last_end=None first_seq=self.a[i][self.c("map_begin")]
previous_seq=None
while i<len(self.a): while i<len(self.a):
if self.a[i][self.c("is_seq")]==1: if self.a[i][self.c("is_seq")]==1:
# in this case we look for the start of a new sending block if (self.a[i][self.c("map_end")]-self.a[0][self.c("map_begin")])%65536==1428:
if b==None and last_end!=None: print >>self.log, "found block beginning at ", "{:10.8f}".format(self.a[i][self.c("ts")]), "end seq:", self.a[i][self.c("map_end")]
if self.a[i][self.c("map_begin")]==self.a[last_end][self.c("map_end")]:
b=i
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
elif self.a[i][self.c("map_end")]-self.a[b][self.c("map_begin")]==65536:
print >>self.log, "found block ending at ", "{:10.8f}".format(self.a[i][self.c("ts")]), "end seq:", self.a[i][self.c("map_end")]
print >>self.log,"--------------------------------------" print >>self.log,"--------------------------------------"
# the ranges we use here are inclusive, ie the range contains both elements. self.blocks.append((b,previous_seq))
self.blocks.append((b,i)) b = i
last_end = i
b=None
print self.blocks
# keep track of previous seq packet # keep track of previous seq packet
previous_seq=i
i=i+1 i=i+1
self.blocks.append((b,i-1)) self.blocks.append((b,i-1))
print self.blocks
print >>self.log, "# blocks: ", len(self.blocks) print >>self.log, "# blocks: ", len(self.blocks)
def extract_times(self): def extract_times(self):
for i in range(len(self.blocks)): for i in range(len(self.blocks)):
@ -152,7 +146,7 @@ class BurstBlocksAggregator:
while i<len(self.a): while i<len(self.a):
# find ack packets # find ack packets
if self.a[i][self.c("is_seq")]==0: if self.a[i][self.c("is_seq")]==0:
if self.a[i][self.c("map_begin")]>=seq: if self.a[i][self.c("map_begin")]>seq:
return (i,self.a[i]) return (i,self.a[i])
i=i+1 i=i+1
return None return None