@@ -77,21 +77,21 @@ reassemble(#tcp_stream{data = Data}) ->
77
77
{Data :: binary (), [offset_data ()]}.
78
78
reassemble ({0 , TS , Data }, {<<>>, []}) ->
79
79
{Data , [{TS , syn , 0 , 0 }]};
80
- reassemble ({RSN , RTS , Data }, {Stream , Offsets })
81
- when is_integer (RSN ), is_integer (RTS ),
80
+ reassemble ({RSN , TS , Data }, {Stream , Offsets })
81
+ when is_integer (RSN ), is_integer (TS ),
82
82
is_binary (Data ), is_binary (Stream ),
83
83
is_list (Offsets ) ->
84
84
TargetSN = byte_size (Stream ) + 1 ,
85
85
if TargetSN =:= RSN ->
86
86
{<<Stream /binary , Data /binary >>,
87
- [{RTS , normal , RSN - 1 , RSN + byte_size (Data ) - 1 } | Offsets ]};
87
+ [{TS , normal , RSN - 1 , RSN + byte_size (Data ) - 1 } | Offsets ]};
88
88
RSN < TargetSN ->
89
89
{<<Stream :(RSN - 1 )/binary , Data /binary >>,
90
- [{RTS , retransmit , RSN - 1 , RSN + byte_size (Data ) - 1 } | Offsets ]};
90
+ [{TS , retransmit , RSN - 1 , RSN + byte_size (Data ) - 1 } | Offsets ]};
91
91
RSN > TargetSN ->
92
92
DataOffset = RSN - TargetSN ,
93
93
{<<Stream /binary , 0 :DataOffset /integer -unit :8 , Data /binary >>,
94
- [{RTS , missing_packet , DataOffset ,
94
+ [{TS , missing_packet , DataOffset ,
95
95
DataOffset + byte_size (Data )} | Offsets ]}
96
96
end .
97
97
0 commit comments