Skip to content

Commit 16d14ef

Browse files
xemulDavid S. Miller
authored andcommitted
[SCTP]: Consolidate sctp_ulpq_renege_xxx functions
Both are equal, except for the list to be traversed. Signed-off-by: Pavel Emelyanov <xemul@openvz.org> Acked-by: Vlad Yasevich <vladislav.yasevich@hp.com> Signed-off-by: David S. Miller <davem@davemloft.net>
1 parent 5c58298 commit 16d14ef

File tree

1 file changed

+10
-24
lines changed

1 file changed

+10
-24
lines changed

net/sctp/ulpqueue.c

Lines changed: 10 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -908,8 +908,8 @@ void sctp_ulpq_skip(struct sctp_ulpq *ulpq, __u16 sid, __u16 ssn)
908908
return;
909909
}
910910

911-
/* Renege 'needed' bytes from the ordering queue. */
912-
static __u16 sctp_ulpq_renege_order(struct sctp_ulpq *ulpq, __u16 needed)
911+
static __u16 sctp_ulpq_renege_list(struct sctp_ulpq *ulpq,
912+
struct sk_buff_head *list, __u16 needed)
913913
{
914914
__u16 freed = 0;
915915
__u32 tsn;
@@ -919,7 +919,7 @@ static __u16 sctp_ulpq_renege_order(struct sctp_ulpq *ulpq, __u16 needed)
919919

920920
tsnmap = &ulpq->asoc->peer.tsn_map;
921921

922-
while ((skb = __skb_dequeue_tail(&ulpq->lobby)) != NULL) {
922+
while ((skb = __skb_dequeue_tail(list)) != NULL) {
923923
freed += skb_headlen(skb);
924924
event = sctp_skb2event(skb);
925925
tsn = event->tsn;
@@ -933,30 +933,16 @@ static __u16 sctp_ulpq_renege_order(struct sctp_ulpq *ulpq, __u16 needed)
933933
return freed;
934934
}
935935

936+
/* Renege 'needed' bytes from the ordering queue. */
937+
static __u16 sctp_ulpq_renege_order(struct sctp_ulpq *ulpq, __u16 needed)
938+
{
939+
return sctp_ulpq_renege_list(ulpq, &ulpq->lobby, needed);
940+
}
941+
936942
/* Renege 'needed' bytes from the reassembly queue. */
937943
static __u16 sctp_ulpq_renege_frags(struct sctp_ulpq *ulpq, __u16 needed)
938944
{
939-
__u16 freed = 0;
940-
__u32 tsn;
941-
struct sk_buff *skb;
942-
struct sctp_ulpevent *event;
943-
struct sctp_tsnmap *tsnmap;
944-
945-
tsnmap = &ulpq->asoc->peer.tsn_map;
946-
947-
/* Walk backwards through the list, reneges the newest tsns. */
948-
while ((skb = __skb_dequeue_tail(&ulpq->reasm)) != NULL) {
949-
freed += skb_headlen(skb);
950-
event = sctp_skb2event(skb);
951-
tsn = event->tsn;
952-
953-
sctp_ulpevent_free(event);
954-
sctp_tsnmap_renege(tsnmap, tsn);
955-
if (freed >= needed)
956-
return freed;
957-
}
958-
959-
return freed;
945+
return sctp_ulpq_renege_list(ulpq, &ulpq->reasm, needed);
960946
}
961947

962948
/* Partial deliver the first message as there is pressure on rwnd. */

0 commit comments

Comments
 (0)