finished_checking_retransmission_type:
nextseq = seq+seglen;
- if (seglen || flags&(TH_SYN|TH_FIN)) {
- /* add this new sequence number to the fwd list */
+ if ((seglen || flags&(TH_SYN|TH_FIN)) && tcpd->fwd->segment_count < TCP_MAX_UNACKED_SEGMENTS) {
+ /* Add this new sequence number to the fwd list. But only if there
+ * aren't "too many" unacked segements (e.g., we're not seeing the ACKs).
+ */
ual = wmem_new(wmem_file_scope(), tcp_unacked_t);
ual->next=tcpd->fwd->segments;
tcpd->fwd->segments=ual;
+ tcpd->fwd->segment_count++;
ual->frame=pinfo->fd->num;
ual->seq=seq;
ual->ts=pinfo->fd->abs_ts;
}
wmem_free(wmem_file_scope(), ual);
ual = tmpual;
+ tcpd->rev->segment_count--;
}
/* how many bytes of data are there in flight after this frame
typedef struct _tcp_flow_t {
gboolean base_seq_set; /* true if base seq set */
guint32 base_seq; /* base seq number (used by relative sequence numbers)*/
- tcp_unacked_t *segments;
+#define TCP_MAX_UNACKED_SEGMENTS 1000 /* The most unacked segments we'll store */
+ tcp_unacked_t *segments;/* List of segments for which we haven't seen an ACK */
+ guint16 segment_count; /* How many unacked segments we're currently storing */
guint32 fin; /* frame number of the final FIN */
guint32 lastack; /* last seen ack */
nstime_t lastacktime; /* Time of the last ack packet */