diff options
author | Gerrit Renker <gerrit@erg.abdn.ac.uk> | 2010-11-10 15:21:35 -0500 |
---|---|---|
committer | Gerrit Renker <gerrit@erg.abdn.ac.uk> | 2010-11-10 15:21:35 -0500 |
commit | b3d14bff12a38ad13a174eb0cc83d2ac7169eee4 (patch) | |
tree | 2248e4d994ce857113c34ce5f754c554e17d8d9e /net/dccp/dccp.h | |
parent | 7d870936602533836bba821bd5c679c62c52a95f (diff) |
dccp ccid-2: Implementation of circular Ack Vector buffer with overflow handling
This completes the implementation of a circular buffer for Ack Vectors, by
extending the current (linear array-based) implementation. The changes are:
(a) An `overflow' flag to deal with the case of overflow. As before, dynamic
growth of the buffer will not be supported; but code will be added to deal
robustly with overflowing Ack Vector buffers.
(b) A `tail_seqno' field. When naively implementing the algorithm of Appendix A
in RFC 4340, problems arise whenever subsequent Ack Vector records overlap,
which can bring the entire run length calculation completely out of synch.
(This is documented on http://www.erg.abdn.ac.uk/users/gerrit/dccp/notes/\
ack_vectors/tracking_tail_ackno/ .)
(c) The buffer length is now computed dynamically (i.e. current fill level),
as the span between head to tail.
As a result, dccp_ackvec_pending() is now simpler - the #ifdef is no longer
necessary since buf_empty is always true when IP_DCCP_ACKVEC is not configured.
Signed-off-by: Gerrit Renker <gerrit@erg.abdn.ac.uk>
Diffstat (limited to 'net/dccp/dccp.h')
-rw-r--r-- | net/dccp/dccp.h | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/net/dccp/dccp.h b/net/dccp/dccp.h index a8ed459508b2..19fafd597465 100644 --- a/net/dccp/dccp.h +++ b/net/dccp/dccp.h | |||
@@ -457,12 +457,15 @@ static inline void dccp_update_gss(struct sock *sk, u64 seq) | |||
457 | dp->dccps_awh = dp->dccps_gss; | 457 | dp->dccps_awh = dp->dccps_gss; |
458 | } | 458 | } |
459 | 459 | ||
460 | static inline int dccp_ackvec_pending(const struct sock *sk) | ||
461 | { | ||
462 | return dccp_sk(sk)->dccps_hc_rx_ackvec != NULL && | ||
463 | !dccp_ackvec_is_empty(dccp_sk(sk)->dccps_hc_rx_ackvec); | ||
464 | } | ||
465 | |||
460 | static inline int dccp_ack_pending(const struct sock *sk) | 466 | static inline int dccp_ack_pending(const struct sock *sk) |
461 | { | 467 | { |
462 | const struct dccp_sock *dp = dccp_sk(sk); | 468 | return dccp_ackvec_pending(sk) || inet_csk_ack_scheduled(sk); |
463 | return (dp->dccps_hc_rx_ackvec != NULL && | ||
464 | dccp_ackvec_pending(dp->dccps_hc_rx_ackvec)) || | ||
465 | inet_csk_ack_scheduled(sk); | ||
466 | } | 469 | } |
467 | 470 | ||
468 | extern int dccp_feat_finalise_settings(struct dccp_sock *dp); | 471 | extern int dccp_feat_finalise_settings(struct dccp_sock *dp); |