File tree 1 file changed +7
-2
lines changed
1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change @@ -578,17 +578,19 @@ def do_qualify_reinjections(self, line):
578
578
)
579
579
580
580
print ("debugging " )
581
- print (" dataframe size = %d" % len (df ))
581
+ print ("dataframe size = %d" % len (df ))
582
582
583
583
# print(df.columns)
584
- print (df [['owd' ]].head ())
584
+ # print(df[['owd']].head())
585
585
# print("MERGED_DF", merged_df[TCP_DEBUG_FIELDS].head(20))
586
586
# print(df[mpdata.MPTCP_DEBUG_FIELDS].head(20))
587
587
588
588
# TODO for debug
589
589
# todo we need to add
590
590
# res['mptcpdest'] = dest.name
591
591
592
+ # TODO keep only the ones with "merge_" : "both" ?
593
+
592
594
# reinjections = df[['tcpstream', "reinjection_of"]].dropna(axis=0, )
593
595
# reinjected_in_receiver
594
596
"""
@@ -609,6 +611,7 @@ def do_qualify_reinjections(self, line):
609
611
610
612
receiver_df = df [ df .mptcpdest == destination ]
611
613
sender_df = df [ df .mptcpdest == swap_role (destination )]
614
+ # sender_df = df[ df.mptcpdest == swap_role(destination)]
612
615
613
616
print (sender_df [ sender_df .reinjected_in .notna () ][["packetid" , "reinjected_in" ]])
614
617
@@ -700,6 +703,8 @@ def do_qualify_reinjections(self, line):
700
703
original_arrival = original_packet [ _receiver ("abstime" ) ]
701
704
))
702
705
706
+ if
707
+
703
708
# # set it to the maximum possible value
704
709
# min_rcvtime = sys.maxsize
705
710
You can’t perform that action at this time.
0 commit comments