Commit 8306f99a authored by Jon Paul Maloy's avatar Jon Paul Maloy Committed by David S. Miller
Browse files

tipc: disallow packet duplicates in link deferred queue 



After the previous commits, we are guaranteed that no packets
of type LINK_PROTOCOL or with illegal sequence numbers will be
attempted added to the link deferred queue. This makes it possible to
make some simplifications to the sorting algorithm in the function
tipc_skb_queue_sorted().

We also alter the function so that it will drop packets if one with
the same seqeunce number is already present in the queue. This is
necessary because we have identified weird packet sequences, involving
duplicate packets, where a legitimate in-sequence packet may advance to
the head of the queue without being detected and de-queued.

Finally, we make this function outline, since it will now be called only
in exceptional cases.

Signed-off-by: default avatarJon Maloy <jon.maloy@ericsson.com>
Acked-by: default avatarYing Xue <ying.xue@windriver.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 81204c49

net/tipc/link.c

+1 −1
Original line number Original line Diff line number Diff line
@@ -1114,7 +1114,7 @@ int tipc_link_rcv(struct tipc_link *l, struct sk_buff *skb, 




		/* Defer delivery if sequence gap */

		/* Defer delivery if sequence gap */

		if (unlikely(seqno != rcv_nxt)) {

		if (unlikely(seqno != rcv_nxt)) {

			__tipc_skb_queue_sorted(defq, skb);

			__tipc_skb_queue_sorted(defq, seqno, skb);

			tipc_link_build_nack_msg(l, xmitq);

			tipc_link_build_nack_msg(l, xmitq);

			break;

			break;

		}

		}

net/tipc/msg.c

+31 −0
Original line number Original line Diff line number Diff line
@@ -590,3 +590,34 @@ error: 
	kfree_skb(head);

	kfree_skb(head);

	return NULL;

	return NULL;

}

}



/* tipc_skb_queue_sorted(); sort pkt into list according to sequence number

 * @list: list to be appended to

 * @seqno: sequence number of buffer to add

 * @skb: buffer to add

 */

void __tipc_skb_queue_sorted(struct sk_buff_head *list, u16 seqno,

			     struct sk_buff *skb)

{

	struct sk_buff *_skb, *tmp;



	if (skb_queue_empty(list) || less(seqno, buf_seqno(skb_peek(list)))) {

		__skb_queue_head(list, skb);

		return;

	}



	if (more(seqno, buf_seqno(skb_peek_tail(list)))) {

		__skb_queue_tail(list, skb);

		return;

	}



	skb_queue_walk_safe(list, _skb, tmp) {

		if (more(seqno, buf_seqno(_skb)))

			continue;

		if (seqno == buf_seqno(_skb))

			break;

		__skb_queue_before(list, _skb, skb);

		return;

	}

	kfree_skb(skb);

}

net/tipc/msg.h

+2 −32
Original line number Original line Diff line number Diff line
@@ -790,6 +790,8 @@ int tipc_msg_build(struct tipc_msg *mhdr, struct msghdr *m, 
		   int offset, int dsz, int mtu, struct sk_buff_head *list);

		   int offset, int dsz, int mtu, struct sk_buff_head *list);

bool tipc_msg_lookup_dest(struct net *net, struct sk_buff *skb, int *err);

bool tipc_msg_lookup_dest(struct net *net, struct sk_buff *skb, int *err);

struct sk_buff *tipc_msg_reassemble(struct sk_buff_head *list);

struct sk_buff *tipc_msg_reassemble(struct sk_buff_head *list);

void __tipc_skb_queue_sorted(struct sk_buff_head *list, u16 seqno,

			     struct sk_buff *skb);





static inline u16 buf_seqno(struct sk_buff *skb)

static inline u16 buf_seqno(struct sk_buff *skb)

{

{
@@ -862,38 +864,6 @@ static inline struct sk_buff *tipc_skb_dequeue(struct sk_buff_head *list, 
	return skb;

	return skb;

}

}





/* tipc_skb_queue_sorted(); sort pkt into list according to sequence number

 * @list: list to be appended to

 * @skb: buffer to add

 * Returns true if queue should treated further, otherwise false

 */

static inline bool __tipc_skb_queue_sorted(struct sk_buff_head *list,

					   struct sk_buff *skb)

{

	struct sk_buff *_skb, *tmp;

	struct tipc_msg *hdr = buf_msg(skb);

	u16 seqno = msg_seqno(hdr);



	if (skb_queue_empty(list) || (msg_user(hdr) == LINK_PROTOCOL)) {

		__skb_queue_head(list, skb);

		return true;

	}

	if (likely(less(seqno, buf_seqno(skb_peek(list))))) {

		__skb_queue_head(list, skb);

		return true;

	}

	if (!more(seqno, buf_seqno(skb_peek_tail(list)))) {

		skb_queue_walk_safe(list, _skb, tmp) {

			if (likely(less(seqno, buf_seqno(_skb)))) {

				__skb_queue_before(list, _skb, skb);

				return true;

			}

		}

	}

	__skb_queue_tail(list, skb);

	return false;

}



/* tipc_skb_queue_splice_tail - append an skb list to lock protected list

/* tipc_skb_queue_splice_tail - append an skb list to lock protected list

 * @list: the new list to append. Not lock protected

 * @list: the new list to append. Not lock protected

 * @head: target list. Lock protected.

 * @head: target list. Lock protected.

CRA Git | Maintained and supported by SUSTech CRA and CCSE