244 static int tipc_link_proto_rcv(struct tipc_link *l, struct sk_buff *skb,
246 static void tipc_link_build_proto_msg(struct tipc_link *l, int mtyp, bool probe,
250 static void link_print(struct tipc_link *l, const char *str);
251 static int tipc_link_build_nack_msg(struct tipc_link *l,
253 static void tipc_link_build_bc_init_msg(struct tipc_link *l,
256 				    struct tipc_link *l, u8 start_index);
257 static u16 tipc_build_gap_ack_blks(struct tipc_link *l, struct tipc_msg *hdr);
258 static int tipc_link_advance_transmq(struct tipc_link *l, struct tipc_link *r,
263 static void tipc_link_update_cwin(struct tipc_link *l, int released,
268 bool tipc_link_is_up(struct tipc_link *l)  in tipc_link_is_up()  argument
270 	return l->state & (LINK_ESTABLISHED | LINK_SYNCHING);  in tipc_link_is_up()
273 bool tipc_link_peer_is_down(struct tipc_link *l)  in tipc_link_peer_is_down()  argument
275 	return l->state == LINK_PEER_RESET;  in tipc_link_peer_is_down()
278 bool tipc_link_is_reset(struct tipc_link *l)  in tipc_link_is_reset()  argument
280 	return l->state & (LINK_RESET | LINK_FAILINGOVER | LINK_ESTABLISHING);  in tipc_link_is_reset()
283 bool tipc_link_is_establishing(struct tipc_link *l)  in tipc_link_is_establishing()  argument
285 	return l->state == LINK_ESTABLISHING;  in tipc_link_is_establishing()
288 bool tipc_link_is_synching(struct tipc_link *l)  in tipc_link_is_synching()  argument
290 	return l->state == LINK_SYNCHING;  in tipc_link_is_synching()
293 bool tipc_link_is_failingover(struct tipc_link *l)  in tipc_link_is_failingover()  argument
295 	return l->state == LINK_FAILINGOVER;  in tipc_link_is_failingover()
298 bool tipc_link_is_blocked(struct tipc_link *l)  in tipc_link_is_blocked()  argument
300 	return l->state & (LINK_RESETTING | LINK_PEER_RESET | LINK_FAILINGOVER);  in tipc_link_is_blocked()
303 static bool link_is_bc_sndlink(struct tipc_link *l)  in link_is_bc_sndlink()  argument
305 	return !l->bc_sndlink;  in link_is_bc_sndlink()
308 static bool link_is_bc_rcvlink(struct tipc_link *l)  in link_is_bc_rcvlink()  argument
310 	return ((l->bc_rcvlink == l) && !link_is_bc_sndlink(l));  in link_is_bc_rcvlink()
313 void tipc_link_set_active(struct tipc_link *l, bool active)  in tipc_link_set_active()  argument
315 	l->active = active;  in tipc_link_set_active()
318 u32 tipc_link_id(struct tipc_link *l)  in tipc_link_id()  argument
320 	return l->peer_bearer_id << 16 | l->bearer_id;  in tipc_link_id()
323 int tipc_link_min_win(struct tipc_link *l)  in tipc_link_min_win()  argument
325 	return l->min_win;  in tipc_link_min_win()
328 int tipc_link_max_win(struct tipc_link *l)  in tipc_link_max_win()  argument
330 	return l->max_win;  in tipc_link_max_win()
333 int tipc_link_prio(struct tipc_link *l)  in tipc_link_prio()  argument
335 	return l->priority;  in tipc_link_prio()
338 unsigned long tipc_link_tolerance(struct tipc_link *l)  in tipc_link_tolerance()  argument
340 	return l->tolerance;  in tipc_link_tolerance()
343 struct sk_buff_head *tipc_link_inputq(struct tipc_link *l)  in tipc_link_inputq()  argument
345 	return l->inputq;  in tipc_link_inputq()
348 char tipc_link_plane(struct tipc_link *l)  in tipc_link_plane()  argument
350 	return l->net_plane;  in tipc_link_plane()
353 struct net *tipc_link_net(struct tipc_link *l)  in tipc_link_net()  argument
355 	return l->net;  in tipc_link_net()
358 void tipc_link_update_caps(struct tipc_link *l, u16 capabilities)  in tipc_link_update_caps()  argument
360 	l->peer_caps = capabilities;  in tipc_link_update_caps()
396 int tipc_link_bc_peers(struct tipc_link *l)  in tipc_link_bc_peers()  argument
398 	return l->ackers;  in tipc_link_bc_peers()
401 static u16 link_bc_rcv_gap(struct tipc_link *l)  in link_bc_rcv_gap()  argument
403 	struct sk_buff *skb = skb_peek(&l->deferdq);  in link_bc_rcv_gap()
406 	if (more(l->snd_nxt, l->rcv_nxt))  in link_bc_rcv_gap()
407 		gap = l->snd_nxt - l->rcv_nxt;  in link_bc_rcv_gap()
409 		gap = buf_seqno(skb) - l->rcv_nxt;  in link_bc_rcv_gap()
413 void tipc_link_set_mtu(struct tipc_link *l, int mtu)  in tipc_link_set_mtu()  argument
415 	l->mtu = mtu;  in tipc_link_set_mtu()
418 int tipc_link_mtu(struct tipc_link *l)  in tipc_link_mtu()  argument
420 	return l->mtu;  in tipc_link_mtu()
423 int tipc_link_mss(struct tipc_link *l)  in tipc_link_mss()  argument
426 	return l->mtu - INT_H_SIZE - EMSG_OVERHEAD;  in tipc_link_mss()
428 	return l->mtu - INT_H_SIZE;  in tipc_link_mss()
432 u16 tipc_link_rcv_nxt(struct tipc_link *l)  in tipc_link_rcv_nxt()  argument
434 	return l->rcv_nxt;  in tipc_link_rcv_nxt()
437 u16 tipc_link_acked(struct tipc_link *l)  in tipc_link_acked()  argument
439 	return l->acked;  in tipc_link_acked()
442 char *tipc_link_name(struct tipc_link *l)  in tipc_link_name()  argument
444 	return l->name;  in tipc_link_name()
447 u32 tipc_link_state(struct tipc_link *l)  in tipc_link_state()  argument
449 	return l->state;  in tipc_link_state()
488 	struct tipc_link *l;  in tipc_link_create()  local
490 	l = kzalloc_obj(*l, GFP_ATOMIC);  in tipc_link_create()
491 	if (!l)  in tipc_link_create()
493 	*link = l;  in tipc_link_create()
494 	l->session = session;  in tipc_link_create()
504 	snprintf(l->name, sizeof(l->name), "%s:%s-%s:unknown",  in tipc_link_create()
507 	strcpy(l->if_name, if_name);  in tipc_link_create()
508 	l->addr = peer;  in tipc_link_create()
509 	l->peer_caps = peer_caps;  in tipc_link_create()
510 	l->net = net;  in tipc_link_create()
511 	l->in_session = false;  in tipc_link_create()
512 	l->bearer_id = bearer_id;  in tipc_link_create()
513 	l->tolerance = tolerance;  in tipc_link_create()
516 	l->net_plane = net_plane;  in tipc_link_create()
517 	l->advertised_mtu = mtu;  in tipc_link_create()
518 	l->mtu = mtu;  in tipc_link_create()
519 	l->priority = priority;  in tipc_link_create()
520 	tipc_link_set_queue_limits(l, min_win, max_win);  in tipc_link_create()
521 	l->ackers = 1;  in tipc_link_create()
522 	l->bc_sndlink = bc_sndlink;  in tipc_link_create()
523 	l->bc_rcvlink = bc_rcvlink;  in tipc_link_create()
524 	l->inputq = inputq;  in tipc_link_create()
525 	l->namedq = namedq;  in tipc_link_create()
526 	l->state = LINK_RESETTING;  in tipc_link_create()
527 	__skb_queue_head_init(&l->transmq);  in tipc_link_create()
528 	__skb_queue_head_init(&l->backlogq);  in tipc_link_create()
529 	__skb_queue_head_init(&l->deferdq);  in tipc_link_create()
530 	__skb_queue_head_init(&l->failover_deferdq);  in tipc_link_create()
531 	skb_queue_head_init(&l->wakeupq);  in tipc_link_create()
532 	skb_queue_head_init(l->inputq);  in tipc_link_create()
560 	struct tipc_link *l;  in tipc_link_bc_create()  local
567 	l = *link;  in tipc_link_bc_create()
574 		snprintf(l->name, sizeof(l->name), "%s:%s", tipc_bclink_name,  in tipc_link_bc_create()
577 		strcpy(l->name, tipc_bclink_name);  in tipc_link_bc_create()
579 	trace_tipc_link_reset(l, TIPC_DUMP_ALL, "bclink created!");  in tipc_link_bc_create()
580 	tipc_link_reset(l);  in tipc_link_bc_create()
581 	l->state = LINK_RESET;  in tipc_link_bc_create()
582 	l->ackers = 0;  in tipc_link_bc_create()
583 	l->bc_rcvlink = l;  in tipc_link_bc_create()
586 	if (link_is_bc_sndlink(l))  in tipc_link_bc_create()
587 		l->state = LINK_ESTABLISHED;  in tipc_link_bc_create()
590 	if (link_is_bc_rcvlink(l) && !(peer_caps & TIPC_BCAST_RCAST))  in tipc_link_bc_create()
601 int tipc_link_fsm_evt(struct tipc_link *l, int evt)  in tipc_link_fsm_evt()  argument
604 	int old_state = l->state;  in tipc_link_fsm_evt()
606 	switch (l->state) {  in tipc_link_fsm_evt()
610 			l->state = LINK_PEER_RESET;  in tipc_link_fsm_evt()
613 			l->state = LINK_RESET;  in tipc_link_fsm_evt()
628 			l->state = LINK_ESTABLISHING;  in tipc_link_fsm_evt()
631 			l->state = LINK_FAILINGOVER;  in tipc_link_fsm_evt()
647 			l->state = LINK_ESTABLISHING;  in tipc_link_fsm_evt()
664 			l->state = LINK_RESET;  in tipc_link_fsm_evt()
681 			l->state = LINK_ESTABLISHED;  in tipc_link_fsm_evt()
684 			l->state = LINK_FAILINGOVER;  in tipc_link_fsm_evt()
687 			l->state = LINK_RESET;  in tipc_link_fsm_evt()
702 			l->state = LINK_PEER_RESET;  in tipc_link_fsm_evt()
706 			l->state = LINK_RESETTING;  in tipc_link_fsm_evt()
710 			l->state = LINK_RESET;  in tipc_link_fsm_evt()
716 			l->state = LINK_SYNCHING;  in tipc_link_fsm_evt()
727 			l->state = LINK_PEER_RESET;  in tipc_link_fsm_evt()
731 			l->state = LINK_RESETTING;  in tipc_link_fsm_evt()
735 			l->state = LINK_RESET;  in tipc_link_fsm_evt()
741 			l->state = LINK_ESTABLISHED;  in tipc_link_fsm_evt()
750 		pr_err("Unknown FSM state %x in %s\n", l->state, l->name);  in tipc_link_fsm_evt()
752 	trace_tipc_link_fsm(l->name, old_state, l->state, evt);  in tipc_link_fsm_evt()
756 	       evt, l->state, l->name);  in tipc_link_fsm_evt()
757 	trace_tipc_link_fsm(l->name, old_state, l->state, evt);  in tipc_link_fsm_evt()
763 static void link_profile_stats(struct tipc_link *l)  in link_profile_stats()  argument
770 	l->stats.accu_queue_sz += skb_queue_len(&l->transmq);  in link_profile_stats()
771 	l->stats.queue_sz_counts++;  in link_profile_stats()
773 	skb = skb_peek(&l->transmq);  in link_profile_stats()
784 	l->stats.msg_lengths_total += length;  in link_profile_stats()
785 	l->stats.msg_length_counts++;  in link_profile_stats()
787 		l->stats.msg_length_profile[0]++;  in link_profile_stats()
789 		l->stats.msg_length_profile[1]++;  in link_profile_stats()
791 		l->stats.msg_length_profile[2]++;  in link_profile_stats()
793 		l->stats.msg_length_profile[3]++;  in link_profile_stats()
795 		l->stats.msg_length_profile[4]++;  in link_profile_stats()
797 		l->stats.msg_length_profile[5]++;  in link_profile_stats()
799 		l->stats.msg_length_profile[6]++;  in link_profile_stats()
809 bool tipc_link_too_silent(struct tipc_link *l)  in tipc_link_too_silent()  argument
811 	return (l->silent_intv_cnt + 2 > l->abort_limit);  in tipc_link_too_silent()
816 int tipc_link_timeout(struct tipc_link *l, struct sk_buff_head *xmitq)  in tipc_link_timeout()  argument
823 	u16 bc_snt = l->bc_sndlink->snd_nxt - 1;  in tipc_link_timeout()
824 	u16 bc_acked = l->bc_rcvlink->acked;  in tipc_link_timeout()
825 	struct tipc_mon_state *mstate = &l->mon_state;  in tipc_link_timeout()
827 	trace_tipc_link_timeout(l, TIPC_DUMP_NONE, " ");  in tipc_link_timeout()
828 	trace_tipc_link_too_silent(l, TIPC_DUMP_ALL, " ");  in tipc_link_timeout()
829 	switch (l->state) {  in tipc_link_timeout()
833 		link_profile_stats(l);  in tipc_link_timeout()
834 		tipc_mon_get_state(l->net, l->addr, mstate, l->bearer_id);  in tipc_link_timeout()
835 		if (mstate->reset || (l->silent_intv_cnt > l->abort_limit))  in tipc_link_timeout()
836 			return tipc_link_fsm_evt(l, LINK_FAILURE_EVT);  in tipc_link_timeout()
838 		state |= l->bc_rcvlink->rcv_unacked;  in tipc_link_timeout()
839 		state |= l->rcv_unacked;  in tipc_link_timeout()
840 		state |= !skb_queue_empty(&l->transmq);  in tipc_link_timeout()
842 		probe |= l->silent_intv_cnt;  in tipc_link_timeout()
844 			l->silent_intv_cnt++;  in tipc_link_timeout()
845 		probe |= !skb_queue_empty(&l->deferdq);  in tipc_link_timeout()
846 		if (l->snd_nxt == l->checkpoint) {  in tipc_link_timeout()
847 			tipc_link_update_cwin(l, 0, 0);  in tipc_link_timeout()
850 		l->checkpoint = l->snd_nxt;  in tipc_link_timeout()
853 		setup = l->rst_cnt++ <= 4;  in tipc_link_timeout()
854 		setup |= !(l->rst_cnt % 16);  in tipc_link_timeout()
870 		tipc_link_build_proto_msg(l, mtyp, probe, 0, 0, 0, 0, xmitq);  in tipc_link_timeout()
881 static int link_schedule_user(struct tipc_link *l, struct tipc_msg *hdr)  in link_schedule_user()  argument
883 	u32 dnode = tipc_own_addr(l->net);  in link_schedule_user()
889 			      dnode, l->addr, dport, 0, 0);  in link_schedule_user()
894 	skb_queue_tail(&l->wakeupq, skb);  in link_schedule_user()
895 	l->stats.link_congs++;  in link_schedule_user()
896 	trace_tipc_link_conges(l, TIPC_DUMP_ALL, "wakeup scheduled!");  in link_schedule_user()
906 static void link_prepare_wakeup(struct tipc_link *l)  in link_prepare_wakeup()  argument
908 	struct sk_buff_head *wakeupq = &l->wakeupq;  in link_prepare_wakeup()
909 	struct sk_buff_head *inputq = l->inputq;  in link_prepare_wakeup()
918 		avail[imp] = l->backlog[imp].limit - l->backlog[imp].len;  in link_prepare_wakeup()
942 					      struct tipc_link *l)  in tipc_link_set_skb_retransmit_time()  argument
944 	if (link_is_bc_sndlink(l))  in tipc_link_set_skb_retransmit_time()
950 void tipc_link_reset(struct tipc_link *l)  in tipc_link_reset()  argument
957 	l->in_session = false;  in tipc_link_reset()
959 	l->peer_session--;  in tipc_link_reset()
960 	l->session++;  in tipc_link_reset()
961 	l->mtu = l->advertised_mtu;  in tipc_link_reset()
963 	spin_lock_bh(&l->wakeupq.lock);  in tipc_link_reset()
964 	skb_queue_splice_init(&l->wakeupq, &list);  in tipc_link_reset()
965 	spin_unlock_bh(&l->wakeupq.lock);  in tipc_link_reset()
967 	spin_lock_bh(&l->inputq->lock);  in tipc_link_reset()
968 	skb_queue_splice_init(&list, l->inputq);  in tipc_link_reset()
969 	spin_unlock_bh(&l->inputq->lock);  in tipc_link_reset()
971 	__skb_queue_purge(&l->transmq);  in tipc_link_reset()
972 	__skb_queue_purge(&l->deferdq);  in tipc_link_reset()
973 	__skb_queue_purge(&l->backlogq);  in tipc_link_reset()
974 	__skb_queue_purge(&l->failover_deferdq);  in tipc_link_reset()
976 		l->backlog[imp].len = 0;  in tipc_link_reset()
977 		l->backlog[imp].target_bskb = NULL;  in tipc_link_reset()
979 	kfree_skb(l->reasm_buf);  in tipc_link_reset()
980 	kfree_skb(l->reasm_tnlmsg);  in tipc_link_reset()
981 	kfree_skb(l->failover_reasm_skb);  in tipc_link_reset()
982 	l->reasm_buf = NULL;  in tipc_link_reset()
983 	l->reasm_tnlmsg = NULL;  in tipc_link_reset()
984 	l->failover_reasm_skb = NULL;  in tipc_link_reset()
985 	l->rcv_unacked = 0;  in tipc_link_reset()
986 	l->snd_nxt = 1;  in tipc_link_reset()
987 	l->rcv_nxt = 1;  in tipc_link_reset()
988 	l->snd_nxt_state = 1;  in tipc_link_reset()
989 	l->rcv_nxt_state = 1;  in tipc_link_reset()
990 	l->acked = 0;  in tipc_link_reset()
991 	l->last_gap = 0;  in tipc_link_reset()
992 	kfree(l->last_ga);  in tipc_link_reset()
993 	l->last_ga = NULL;  in tipc_link_reset()
994 	l->silent_intv_cnt = 0;  in tipc_link_reset()
995 	l->rst_cnt = 0;  in tipc_link_reset()
996 	l->bc_peer_is_up = false;  in tipc_link_reset()
997 	memset(&l->mon_state, 0, sizeof(l->mon_state));  in tipc_link_reset()
998 	tipc_link_reset_stats(l);  in tipc_link_reset()
1011 int tipc_link_xmit(struct tipc_link *l, struct sk_buff_head *list,  in tipc_link_xmit()  argument
1014 	struct sk_buff_head *backlogq = &l->backlogq;  in tipc_link_xmit()
1015 	struct sk_buff_head *transmq = &l->transmq;  in tipc_link_xmit()
1017 	u16 bc_ack = l->bc_rcvlink->rcv_nxt - 1;  in tipc_link_xmit()
1018 	u16 ack = l->rcv_nxt - 1;  in tipc_link_xmit()
1019 	u16 seqno = l->snd_nxt;  in tipc_link_xmit()
1021 	unsigned int mss = tipc_link_mss(l);  in tipc_link_xmit()
1022 	unsigned int cwin = l->window;  in tipc_link_xmit()
1023 	unsigned int mtu = l->mtu;  in tipc_link_xmit()
1043 	if (unlikely(l->backlog[imp].len >= l->backlog[imp].limit)) {  in tipc_link_xmit()
1045 			pr_warn("%s<%s>, link overflow", link_rst_msg, l->name);  in tipc_link_xmit()
1049 		rc = link_schedule_user(l, hdr);  in tipc_link_xmit()
1053 		l->stats.sent_fragmented++;  in tipc_link_xmit()
1054 		l->stats.sent_fragments += pkt_cnt;  in tipc_link_xmit()
1071 			tipc_link_set_skb_retransmit_time(skb, l);  in tipc_link_xmit()
1073 			TIPC_SKB_CB(skb)->ackers = l->ackers;  in tipc_link_xmit()
1074 			l->rcv_unacked = 0;  in tipc_link_xmit()
1075 			l->stats.sent_pkts++;  in tipc_link_xmit()
1079 		if (tipc_msg_try_bundle(l->backlog[imp].target_bskb, &skb,  in tipc_link_xmit()
1080 					mss, l->addr, &new_bundle)) {  in tipc_link_xmit()
1083 				l->backlog[imp].target_bskb = skb;  in tipc_link_xmit()
1084 				l->backlog[imp].len++;  in tipc_link_xmit()
1088 					l->stats.sent_bundles++;  in tipc_link_xmit()
1089 					l->stats.sent_bundled++;  in tipc_link_xmit()
1091 				l->stats.sent_bundled++;  in tipc_link_xmit()
1095 		l->backlog[imp].target_bskb = NULL;  in tipc_link_xmit()
1096 		l->backlog[imp].len += (1 + skb_queue_len(list));  in tipc_link_xmit()
1100 	l->snd_nxt = seqno;  in tipc_link_xmit()
1104 static void tipc_link_update_cwin(struct tipc_link *l, int released,  in tipc_link_update_cwin()  argument
1107 	int bklog_len = skb_queue_len(&l->backlogq);  in tipc_link_update_cwin()
1108 	struct sk_buff_head *txq = &l->transmq;  in tipc_link_update_cwin()
1110 	u16 cwin = l->window;  in tipc_link_update_cwin()
1114 		l->ssthresh = max_t(u16, l->window / 2, 300);  in tipc_link_update_cwin()
1115 		l->window = min_t(u16, l->ssthresh, l->window);  in tipc_link_update_cwin()
1120 		l->ssthresh = max_t(u16, l->window / 2, 300);  in tipc_link_update_cwin()
1121 		l->window = l->min_win;  in tipc_link_update_cwin()
1129 	if (txq_len && l->snd_nxt - buf_seqno(skb_peek(txq)) != txq_len)  in tipc_link_update_cwin()
1132 	l->cong_acks += released;  in tipc_link_update_cwin()
1135 	if (cwin <= l->ssthresh) {  in tipc_link_update_cwin()
1136 		l->window = min_t(u16, cwin + released, l->max_win);  in tipc_link_update_cwin()
1140 	if (l->cong_acks < cwin)  in tipc_link_update_cwin()
1142 	l->window = min_t(u16, ++cwin, l->max_win);  in tipc_link_update_cwin()
1143 	l->cong_acks = 0;  in tipc_link_update_cwin()
1146 static void tipc_link_advance_backlog(struct tipc_link *l,  in tipc_link_advance_backlog()  argument
1149 	u16 bc_ack = l->bc_rcvlink->rcv_nxt - 1;  in tipc_link_advance_backlog()
1150 	struct sk_buff_head *txq = &l->transmq;  in tipc_link_advance_backlog()
1152 	u16 ack = l->rcv_nxt - 1;  in tipc_link_advance_backlog()
1153 	u16 seqno = l->snd_nxt;  in tipc_link_advance_backlog()
1155 	u16 cwin = l->window;  in tipc_link_advance_backlog()
1159 		skb = skb_peek(&l->backlogq);  in tipc_link_advance_backlog()
1165 		__skb_dequeue(&l->backlogq);  in tipc_link_advance_backlog()
1168 		l->backlog[imp].len--;  in tipc_link_advance_backlog()
1169 		if (unlikely(skb == l->backlog[imp].target_bskb))  in tipc_link_advance_backlog()
1170 			l->backlog[imp].target_bskb = NULL;  in tipc_link_advance_backlog()
1171 		__skb_queue_tail(&l->transmq, skb);  in tipc_link_advance_backlog()
1172 		tipc_link_set_skb_retransmit_time(skb, l);  in tipc_link_advance_backlog()
1175 		TIPC_SKB_CB(skb)->ackers = l->ackers;  in tipc_link_advance_backlog()
1179 		l->rcv_unacked = 0;  in tipc_link_advance_backlog()
1180 		l->stats.sent_pkts++;  in tipc_link_advance_backlog()
1183 	l->snd_nxt = seqno;  in tipc_link_advance_backlog()
1195 static bool link_retransmit_failure(struct tipc_link *l, struct tipc_link *r,  in link_retransmit_failure()  argument
1198 	struct sk_buff *skb = skb_peek(&l->transmq);  in link_retransmit_failure()
1212 	if (link_is_bc_sndlink(l) && !less(r->acked, msg_seqno(hdr)))  in link_retransmit_failure()
1215 	pr_warn("Retransmission failure on link <%s>\n", l->name);  in link_retransmit_failure()
1216 	link_print(l, "State of link ");  in link_retransmit_failure()
1225 	trace_tipc_list_dump(&l->transmq, true, "retrans failure!");  in link_retransmit_failure()
1226 	trace_tipc_link_dump(l, TIPC_DUMP_NONE, "retrans failure!");  in link_retransmit_failure()
1229 	if (link_is_bc_sndlink(l)) {  in link_retransmit_failure()
1233 		*rc |= tipc_link_fsm_evt(l, LINK_FAILURE_EVT);  in link_retransmit_failure()
1244 static bool tipc_data_input(struct tipc_link *l, struct sk_buff *skb,  in tipc_data_input()  argument
1247 	struct sk_buff_head *mc_inputq = l->bc_rcvlink->inputq;  in tipc_data_input()
1267 		l->bc_rcvlink->state = LINK_ESTABLISHED;  in tipc_data_input()
1268 		skb_queue_tail(l->namedq, skb);  in tipc_data_input()
1279 			tipc_crypto_msg_rcv(l->net, skb);  in tipc_data_input()
1295 static int tipc_link_input(struct tipc_link *l, struct sk_buff *skb,  in tipc_link_input()  argument
1307 		l->stats.recv_bundles++;  in tipc_link_input()
1308 		l->stats.recv_bundled += msg_msgcnt(hdr);  in tipc_link_input()
1310 			tipc_data_input(l, iskb, &tmpq);  in tipc_link_input()
1314 		l->stats.recv_fragments++;  in tipc_link_input()
1316 			l->stats.recv_fragmented++;  in tipc_link_input()
1317 			tipc_data_input(l, skb, inputq);  in tipc_link_input()
1318 		} else if (!*reasm_skb && !link_is_bc_rcvlink(l)) {  in tipc_link_input()
1320 			return tipc_link_fsm_evt(l, LINK_FAILURE_EVT);  in tipc_link_input()
1324 		tipc_bcast_lock(l->net);  in tipc_link_input()
1325 		tipc_link_bc_init_rcv(l->bc_rcvlink, hdr);  in tipc_link_input()
1326 		tipc_bcast_unlock(l->net);  in tipc_link_input()
1340 static int tipc_link_tnl_rcv(struct tipc_link *l, struct sk_buff *skb,  in tipc_link_tnl_rcv()  argument
1343 	struct sk_buff **reasm_skb = &l->failover_reasm_skb;  in tipc_link_tnl_rcv()
1344 	struct sk_buff **reasm_tnlmsg = &l->reasm_tnlmsg;  in tipc_link_tnl_rcv()
1345 	struct sk_buff_head *fdefq = &l->failover_deferdq;  in tipc_link_tnl_rcv()
1376 			if (*reasm_tnlmsg || link_is_bc_rcvlink(l))  in tipc_link_tnl_rcv()
1379 			return tipc_link_fsm_evt(l, LINK_FAILURE_EVT);  in tipc_link_tnl_rcv()
1386 		if (unlikely(less(seqno, l->drop_point))) {  in tipc_link_tnl_rcv()
1390 		if (unlikely(seqno != l->drop_point)) {  in tipc_link_tnl_rcv()
1395 		l->drop_point++;  in tipc_link_tnl_rcv()
1396 		if (!tipc_data_input(l, iskb, inputq))  in tipc_link_tnl_rcv()
1397 			rc |= tipc_link_input(l, iskb, inputq, reasm_skb);  in tipc_link_tnl_rcv()
1400 	} while ((iskb = __tipc_skb_dequeue(fdefq, l->drop_point)));  in tipc_link_tnl_rcv()
1414 u16 tipc_get_gap_ack_blks(struct tipc_gap_ack_blks **ga, struct tipc_link *l,  in tipc_get_gap_ack_blks()  argument
1421 	if (l->peer_caps & TIPC_GAP_ACK_BLOCK) {  in tipc_get_gap_ack_blks()
1446 				    struct tipc_link *l, u8 start_index)  in __tipc_build_gap_ack_blks()  argument
1449 	struct sk_buff *skb = skb_peek(&l->deferdq);  in __tipc_build_gap_ack_blks()
1457 	skb_queue_walk(&l->deferdq, skb) {  in __tipc_build_gap_ack_blks()
1464 						    l->name, n,  in __tipc_build_gap_ack_blks()
1465 						    skb_queue_len(&l->deferdq));  in __tipc_build_gap_ack_blks()
1492 static u16 tipc_build_gap_ack_blks(struct tipc_link *l, struct tipc_msg *hdr)  in tipc_build_gap_ack_blks()  argument
1494 	struct tipc_link *bcl = l->bc_rcvlink;  in tipc_build_gap_ack_blks()
1509 			__tipc_build_gap_ack_blks(ga, l, ga->bgack_cnt) : 0;  in tipc_build_gap_ack_blks()
1532 static int tipc_link_advance_transmq(struct tipc_link *l, struct tipc_link *r,  in tipc_link_advance_transmq()  argument
1542 	u32 qlen = skb_queue_len(&l->transmq);  in tipc_link_advance_transmq()
1544 	u16 bc_ack = l->bc_rcvlink->rcv_nxt - 1;  in tipc_link_advance_transmq()
1545 	u16 ack = l->rcv_nxt - 1;  in tipc_link_advance_transmq()
1549 	bool is_uc = !link_is_bc_sndlink(l);  in tipc_link_advance_transmq()
1552 	trace_tipc_link_retrans(r, acked + 1, acked + gap, &l->transmq);  in tipc_link_advance_transmq()
1575 	skb_queue_walk_safe(&l->transmq, skb, tmp) {  in tipc_link_advance_transmq()
1610 			__skb_unlink(skb, &l->transmq);  in tipc_link_advance_transmq()
1615 				     link_retransmit_failure(l, r, rc))) {  in tipc_link_advance_transmq()
1624 			tipc_link_set_skb_retransmit_time(skb, l);  in tipc_link_advance_transmq()
1633 			l->stats.retransmitted++;  in tipc_link_advance_transmq()
1680 	return qlen - skb_queue_len(&l->transmq);  in tipc_link_advance_transmq()
1688 int tipc_link_build_state_msg(struct tipc_link *l, struct sk_buff_head *xmitq)  in tipc_link_build_state_msg()  argument
1690 	if (!l)  in tipc_link_build_state_msg()
1694 	if (link_is_bc_rcvlink(l)) {  in tipc_link_build_state_msg()
1695 		if (((l->rcv_nxt ^ tipc_own_addr(l->net)) & 0xf) != 0xf)  in tipc_link_build_state_msg()
1697 		l->rcv_unacked = 0;  in tipc_link_build_state_msg()
1700 		l->snd_nxt = l->rcv_nxt;  in tipc_link_build_state_msg()
1704 	l->rcv_unacked = 0;  in tipc_link_build_state_msg()
1705 	l->stats.sent_acks++;  in tipc_link_build_state_msg()
1706 	tipc_link_build_proto_msg(l, STATE_MSG, 0, 0, 0, 0, 0, xmitq);  in tipc_link_build_state_msg()
1712 void tipc_link_build_reset_msg(struct tipc_link *l, struct sk_buff_head *xmitq)  in tipc_link_build_reset_msg()  argument
1717 	if (l->state == LINK_ESTABLISHING)  in tipc_link_build_reset_msg()
1720 	tipc_link_build_proto_msg(l, mtyp, 0, 0, 0, 0, 0, xmitq);  in tipc_link_build_reset_msg()
1724 	if (skb && (l->state == LINK_RESET))  in tipc_link_build_reset_msg()
1732 static int tipc_link_build_nack_msg(struct tipc_link *l,  in tipc_link_build_nack_msg()  argument
1735 	u32 def_cnt = ++l->stats.deferred_recv;  in tipc_link_build_nack_msg()
1736 	struct sk_buff_head *dfq = &l->deferdq;  in tipc_link_build_nack_msg()
1740 	if (link_is_bc_rcvlink(l)) {  in tipc_link_build_nack_msg()
1742 		match2 = tipc_own_addr(l->net) & 0xf;  in tipc_link_build_nack_msg()
1749 		u16 rcvgap = buf_seqno(skb_peek(dfq)) - l->rcv_nxt;  in tipc_link_build_nack_msg()
1751 		tipc_link_build_proto_msg(l, STATE_MSG, 0, 0,  in tipc_link_build_nack_msg()
1762 int tipc_link_rcv(struct tipc_link *l, struct sk_buff *skb,  in tipc_link_rcv()  argument
1765 	struct sk_buff_head *defq = &l->deferdq;  in tipc_link_rcv()
1773 		return tipc_link_proto_rcv(l, skb, xmitq);  in tipc_link_rcv()
1776 	l->silent_intv_cnt = 0;  in tipc_link_rcv()
1781 		rcv_nxt = l->rcv_nxt;  in tipc_link_rcv()
1784 		if (unlikely(!tipc_link_is_up(l))) {  in tipc_link_rcv()
1785 			if (l->state == LINK_ESTABLISHING)  in tipc_link_rcv()
1793 			l->stats.duplicates++;  in tipc_link_rcv()
1797 		released += tipc_link_advance_transmq(l, l, msg_ack(hdr), 0,  in tipc_link_rcv()
1803 				l->stats.duplicates++;  in tipc_link_rcv()
1804 			rc |= tipc_link_build_nack_msg(l, xmitq);  in tipc_link_rcv()
1809 		l->rcv_nxt++;  in tipc_link_rcv()
1810 		l->stats.recv_pkts++;  in tipc_link_rcv()
1813 			rc |= tipc_link_tnl_rcv(l, skb, l->inputq);  in tipc_link_rcv()
1814 		else if (!tipc_data_input(l, skb, l->inputq))  in tipc_link_rcv()
1815 			rc |= tipc_link_input(l, skb, l->inputq, &l->reasm_buf);  in tipc_link_rcv()
1816 		if (unlikely(++l->rcv_unacked >= TIPC_MIN_LINK_WIN))  in tipc_link_rcv()
1817 			rc |= tipc_link_build_state_msg(l, xmitq);  in tipc_link_rcv()
1820 	} while ((skb = __tipc_skb_dequeue(defq, l->rcv_nxt)));  in tipc_link_rcv()
1824 		tipc_link_update_cwin(l, released, 0);  in tipc_link_rcv()
1825 		tipc_link_advance_backlog(l, xmitq);  in tipc_link_rcv()
1826 		if (unlikely(!skb_queue_empty(&l->wakeupq)))  in tipc_link_rcv()
1827 			link_prepare_wakeup(l);  in tipc_link_rcv()
1832 static void tipc_link_build_proto_msg(struct tipc_link *l, int mtyp, bool probe,  in tipc_link_build_proto_msg()  argument
1837 	struct tipc_mon_state *mstate = &l->mon_state;  in tipc_link_build_proto_msg()
1838 	struct sk_buff_head *dfq = &l->deferdq;  in tipc_link_build_proto_msg()
1839 	struct tipc_link *bcl = l->bc_rcvlink;  in tipc_link_build_proto_msg()
1848 	if (tipc_link_is_blocked(l))  in tipc_link_build_proto_msg()
1851 	if (!tipc_link_is_up(l) && (mtyp == STATE_MSG))  in tipc_link_build_proto_msg()
1855 		rcvgap = buf_seqno(skb_peek(dfq)) - l->rcv_nxt;  in tipc_link_build_proto_msg()
1859 			      l->addr, tipc_own_addr(l->net), 0, 0, 0);  in tipc_link_build_proto_msg()
1865 	msg_set_session(hdr, l->session);  in tipc_link_build_proto_msg()
1866 	msg_set_bearer_id(hdr, l->bearer_id);  in tipc_link_build_proto_msg()
1867 	msg_set_net_plane(hdr, l->net_plane);  in tipc_link_build_proto_msg()
1868 	msg_set_next_sent(hdr, l->snd_nxt);  in tipc_link_build_proto_msg()
1869 	msg_set_ack(hdr, l->rcv_nxt - 1);  in tipc_link_build_proto_msg()
1872 	msg_set_last_bcast(hdr, l->bc_sndlink->snd_nxt - 1);  in tipc_link_build_proto_msg()
1877 	msg_set_seqno(hdr, l->snd_nxt + U16_MAX / 2);  in tipc_link_build_proto_msg()
1880 		if (l->peer_caps & TIPC_LINK_PROTO_SEQNO)  in tipc_link_build_proto_msg()
1881 			msg_set_seqno(hdr, l->snd_nxt_state++);  in tipc_link_build_proto_msg()
1887 		if (l->peer_caps & TIPC_GAP_ACK_BLOCK)  in tipc_link_build_proto_msg()
1888 			glen = tipc_build_gap_ack_blks(l, hdr);  in tipc_link_build_proto_msg()
1889 		tipc_mon_prep(l->net, data + glen, &dlen, mstate, l->bearer_id);  in tipc_link_build_proto_msg()
1892 		l->stats.sent_states++;  in tipc_link_build_proto_msg()
1893 		l->rcv_unacked = 0;  in tipc_link_build_proto_msg()
1898 			msg_set_dest_session(hdr, l->peer_session);  in tipc_link_build_proto_msg()
1900 		msg_set_max_pkt(hdr, l->advertised_mtu);  in tipc_link_build_proto_msg()
1901 		strcpy(data, l->if_name);  in tipc_link_build_proto_msg()
1906 		l->stats.sent_probes++;  in tipc_link_build_proto_msg()
1908 		l->stats.sent_nacks++;  in tipc_link_build_proto_msg()
1913 	trace_tipc_proto_build(skb, false, l->name);  in tipc_link_build_proto_msg()
1916 void tipc_link_create_dummy_tnl_msg(struct tipc_link *l,  in tipc_link_create_dummy_tnl_msg()  argument
1919 	u32 onode = tipc_own_addr(l->net);  in tipc_link_create_dummy_tnl_msg()
1923 	u32 dnode = l->addr;  in tipc_link_create_dummy_tnl_msg()
1936 	msg_set_bearer_id(hdr, l->peer_bearer_id);  in tipc_link_create_dummy_tnl_msg()
1943 	tipc_link_xmit(l, &tnlq, xmitq);  in tipc_link_create_dummy_tnl_msg()
1949 void tipc_link_tnl_prepare(struct tipc_link *l, struct tipc_link *tnl,  in tipc_link_tnl_prepare()  argument
1954 	struct sk_buff_head *queue = &l->transmq;  in tipc_link_tnl_prepare()
1956 	u16 pktlen, pktcnt, seqno = l->snd_nxt;  in tipc_link_tnl_prepare()
1972 					 INT_H_SIZE, 0, l->addr,  in tipc_link_tnl_prepare()
1973 					 tipc_own_addr(l->net),  in tipc_link_tnl_prepare()
1982 		syncpt = l->snd_nxt + skb_queue_len(&l->backlogq) - 1;  in tipc_link_tnl_prepare()
1984 		msg_set_bearer_id(hdr, l->peer_bearer_id);  in tipc_link_tnl_prepare()
1994 			      BASIC_H_SIZE, 0, l->addr, tipc_own_addr(l->net),  in tipc_link_tnl_prepare()
2001 	tipc_link_xmit(l, &tnlq, &tmpxq);  in tipc_link_tnl_prepare()
2005 	tipc_msg_init(tipc_own_addr(l->net), &tnlhdr, TUNNEL_PROTOCOL,  in tipc_link_tnl_prepare()
2006 		      mtyp, INT_H_SIZE, l->addr);  in tipc_link_tnl_prepare()
2008 		pktcnt = l->snd_nxt - buf_seqno(skb_peek(&l->transmq));  in tipc_link_tnl_prepare()
2010 		pktcnt = skb_queue_len(&l->transmq);  in tipc_link_tnl_prepare()
2011 	pktcnt += skb_queue_len(&l->backlogq);  in tipc_link_tnl_prepare()
2013 	msg_set_bearer_id(&tnlhdr, l->peer_bearer_id);  in tipc_link_tnl_prepare()
2018 		if (queue == &l->backlogq)  in tipc_link_tnl_prepare()
2064 	if (queue != &l->backlogq) {  in tipc_link_tnl_prepare()
2065 		queue = &l->backlogq;  in tipc_link_tnl_prepare()
2080 		tnl->drop_point = l->rcv_nxt;  in tipc_link_tnl_prepare()
2081 		tnl->failover_reasm_skb = l->reasm_buf;  in tipc_link_tnl_prepare()
2082 		l->reasm_buf = NULL;  in tipc_link_tnl_prepare()
2090 		skb_queue_splice_init(&l->deferdq, fdefq);  in tipc_link_tnl_prepare()
2104 void tipc_link_failover_prepare(struct tipc_link *l, struct tipc_link *tnl,  in tipc_link_failover_prepare()  argument
2131 bool tipc_link_validate_msg(struct tipc_link *l, struct tipc_msg *hdr)  in tipc_link_validate_msg()  argument
2133 	u16 curr_session = l->peer_session;  in tipc_link_validate_msg()
2142 		if (!l->in_session)  in tipc_link_validate_msg()
2147 		if (!l->in_session)  in tipc_link_validate_msg()
2153 		if (!l->in_session)  in tipc_link_validate_msg()
2158 		if (!tipc_link_is_up(l) && msg_ack(hdr))  in tipc_link_validate_msg()
2160 		if (!(l->peer_caps & TIPC_LINK_PROTO_SEQNO))  in tipc_link_validate_msg()
2163 		return !less(msg_seqno(hdr), l->rcv_nxt_state);  in tipc_link_validate_msg()
2174 static int tipc_link_proto_rcv(struct tipc_link *l, struct sk_buff *skb,  in tipc_link_proto_rcv()  argument
2186 	u16 rcv_nxt = l->rcv_nxt;  in tipc_link_proto_rcv()
2193 	trace_tipc_proto_rcv(skb, false, l->name);  in tipc_link_proto_rcv()
2198 	if (tipc_link_is_blocked(l) || !xmitq)  in tipc_link_proto_rcv()
2201 	if (tipc_own_addr(l->net) > msg_prevnode(hdr))  in tipc_link_proto_rcv()
2202 		l->net_plane = msg_net_plane(hdr);  in tipc_link_proto_rcv()
2210 	if (!tipc_link_validate_msg(l, hdr)) {  in tipc_link_proto_rcv()
2212 		trace_tipc_link_dump(l, TIPC_DUMP_NONE, "PROTO invalid (1)!");  in tipc_link_proto_rcv()
2220 		if (msg_max < tipc_bearer_min_mtu(l->net, l->bearer_id))  in tipc_link_proto_rcv()
2223 		if_name =  strrchr(l->name, ':') + 1;  in tipc_link_proto_rcv()
2224 		if (sizeof(l->name) - (if_name - l->name) <= TIPC_MAX_IF_NAME)  in tipc_link_proto_rcv()
2232 			l->tolerance = peers_tol;  in tipc_link_proto_rcv()
2233 			l->bc_rcvlink->tolerance = peers_tol;  in tipc_link_proto_rcv()
2236 		if (tipc_in_range(peers_prio, l->priority + 1, TIPC_MAX_LINK_PRI))  in tipc_link_proto_rcv()
2237 			l->priority = peers_prio;  in tipc_link_proto_rcv()
2241 			rc = tipc_link_fsm_evt(l, LINK_FAILURE_EVT);  in tipc_link_proto_rcv()
2249 		    l->session != msg_dest_session(hdr)) {  in tipc_link_proto_rcv()
2250 			if (less(l->session, msg_dest_session(hdr)))  in tipc_link_proto_rcv()
2251 				l->session = msg_dest_session(hdr) + 1;  in tipc_link_proto_rcv()
2256 		if (mtyp == RESET_MSG || !tipc_link_is_up(l))  in tipc_link_proto_rcv()
2257 			rc = tipc_link_fsm_evt(l, LINK_PEER_RESET_EVT);  in tipc_link_proto_rcv()
2260 		if (mtyp == ACTIVATE_MSG && l->state == LINK_ESTABLISHING)  in tipc_link_proto_rcv()
2263 		l->peer_session = msg_session(hdr);  in tipc_link_proto_rcv()
2264 		l->in_session = true;  in tipc_link_proto_rcv()
2265 		l->peer_bearer_id = msg_bearer_id(hdr);  in tipc_link_proto_rcv()
2266 		if (l->mtu > msg_max)  in tipc_link_proto_rcv()
2267 			l->mtu = msg_max;  in tipc_link_proto_rcv()
2272 		glen = tipc_get_gap_ack_blks(&ga, l, hdr, true);  in tipc_link_proto_rcv()
2276 		l->rcv_nxt_state = msg_seqno(hdr) + 1;  in tipc_link_proto_rcv()
2280 			l->tolerance = peers_tol;  in tipc_link_proto_rcv()
2281 			l->bc_rcvlink->tolerance = peers_tol;  in tipc_link_proto_rcv()
2284 		if ((peers_prio != l->priority) &&  in tipc_link_proto_rcv()
2286 			l->priority = peers_prio;  in tipc_link_proto_rcv()
2287 			rc = tipc_link_fsm_evt(l, LINK_FAILURE_EVT);  in tipc_link_proto_rcv()
2290 		l->silent_intv_cnt = 0;  in tipc_link_proto_rcv()
2291 		l->stats.recv_states++;  in tipc_link_proto_rcv()
2293 			l->stats.recv_probes++;  in tipc_link_proto_rcv()
2295 		if (!tipc_link_is_up(l)) {  in tipc_link_proto_rcv()
2296 			if (l->state == LINK_ESTABLISHING)  in tipc_link_proto_rcv()
2301 		tipc_mon_rcv(l->net, data + glen, dlen - glen, l->addr,  in tipc_link_proto_rcv()
2302 			     &l->mon_state, l->bearer_id);  in tipc_link_proto_rcv()
2307 		    !tipc_link_is_synching(l) &&  in tipc_link_proto_rcv()
2308 		    skb_queue_empty(&l->deferdq))  in tipc_link_proto_rcv()
2309 			rcvgap = peers_snd_nxt - l->rcv_nxt;  in tipc_link_proto_rcv()
2311 			tipc_link_build_proto_msg(l, STATE_MSG, 0, reply,  in tipc_link_proto_rcv()
2314 		released = tipc_link_advance_transmq(l, l, ack, gap, ga, xmitq,  in tipc_link_proto_rcv()
2317 			l->stats.recv_nacks++;  in tipc_link_proto_rcv()
2319 			tipc_link_update_cwin(l, released, retransmitted);  in tipc_link_proto_rcv()
2321 			tipc_link_advance_backlog(l, xmitq);  in tipc_link_proto_rcv()
2322 		if (unlikely(!skb_queue_empty(&l->wakeupq)))  in tipc_link_proto_rcv()
2323 			link_prepare_wakeup(l);  in tipc_link_proto_rcv()
2332 static bool tipc_link_build_bc_proto_msg(struct tipc_link *l, bool bcast,  in tipc_link_build_bc_proto_msg()  argument
2338 	struct sk_buff *dfrd_skb = skb_peek(&l->deferdq);  in tipc_link_build_bc_proto_msg()
2339 	u16 ack = l->rcv_nxt - 1;  in tipc_link_build_bc_proto_msg()
2343 			      0, l->addr, tipc_own_addr(l->net), 0, 0, 0);  in tipc_link_build_bc_proto_msg()
2347 	msg_set_last_bcast(hdr, l->bc_sndlink->snd_nxt - 1);  in tipc_link_build_bc_proto_msg()
2363 static void tipc_link_build_bc_init_msg(struct tipc_link *l,  in tipc_link_build_bc_init_msg()  argument
2369 	if (!tipc_link_build_bc_proto_msg(l->bc_rcvlink, false, 0, &list))  in tipc_link_build_bc_init_msg()
2372 	tipc_link_xmit(l, &list, xmitq);  in tipc_link_build_bc_init_msg()
2377 void tipc_link_bc_init_rcv(struct tipc_link *l, struct tipc_msg *hdr)  in tipc_link_bc_init_rcv()  argument
2382 	if (tipc_link_is_up(l))  in tipc_link_bc_init_rcv()
2386 		l->rcv_nxt = peers_snd_nxt;  in tipc_link_bc_init_rcv()
2387 		l->state = LINK_ESTABLISHED;  in tipc_link_bc_init_rcv()
2391 	if (l->peer_caps & TIPC_BCAST_SYNCH)  in tipc_link_bc_init_rcv()
2399 		l->rcv_nxt = peers_snd_nxt;  in tipc_link_bc_init_rcv()
2404 int tipc_link_bc_sync_rcv(struct tipc_link *l, struct tipc_msg *hdr,  in tipc_link_bc_sync_rcv()  argument
2410 	if (!tipc_link_is_up(l))  in tipc_link_bc_sync_rcv()
2418 		l->bc_peer_is_up = true;  in tipc_link_bc_sync_rcv()
2420 	if (!l->bc_peer_is_up)  in tipc_link_bc_sync_rcv()
2424 	if (more(peers_snd_nxt, l->rcv_nxt + l->window))  in tipc_link_bc_sync_rcv()
2427 	l->snd_nxt = peers_snd_nxt;  in tipc_link_bc_sync_rcv()
2428 	if (link_bc_rcv_gap(l))  in tipc_link_bc_sync_rcv()
2432 	if (l->peer_caps & TIPC_BCAST_STATE_NACK)  in tipc_link_bc_sync_rcv()
2437 	if (!more(peers_snd_nxt, l->rcv_nxt)) {  in tipc_link_bc_sync_rcv()
2438 		l->nack_state = BC_NACK_SND_CONDITIONAL;  in tipc_link_bc_sync_rcv()
2443 	if (l->nack_state == BC_NACK_SND_SUPPRESS) {  in tipc_link_bc_sync_rcv()
2444 		l->nack_state = BC_NACK_SND_UNCONDITIONAL;  in tipc_link_bc_sync_rcv()
2449 	if (l->nack_state == BC_NACK_SND_CONDITIONAL) {  in tipc_link_bc_sync_rcv()
2450 		l->nack_state = BC_NACK_SND_UNCONDITIONAL;  in tipc_link_bc_sync_rcv()
2451 		if ((peers_snd_nxt - l->rcv_nxt) < TIPC_MIN_LINK_WIN)  in tipc_link_bc_sync_rcv()
2456 	tipc_link_build_bc_proto_msg(l, true, peers_snd_nxt, xmitq);  in tipc_link_bc_sync_rcv()
2457 	l->nack_state = BC_NACK_SND_SUPPRESS;  in tipc_link_bc_sync_rcv()
2466 	struct tipc_link *l = r->bc_sndlink;  in tipc_link_bc_ack_rcv()  local
2474 		l->stats.recv_nacks++;  in tipc_link_bc_ack_rcv()
2481 	trace_tipc_link_bc_ack(r, acked, gap, &l->transmq);  in tipc_link_bc_ack_rcv()
2482 	tipc_link_advance_transmq(l, r, acked, gap, ga, retrq, &unused, &rc);  in tipc_link_bc_ack_rcv()
2484 	tipc_link_advance_backlog(l, xmitq);  in tipc_link_bc_ack_rcv()
2485 	if (unlikely(!skb_queue_empty(&l->wakeupq)))  in tipc_link_bc_ack_rcv()
2486 		link_prepare_wakeup(l);  in tipc_link_bc_ack_rcv()
2495 int tipc_link_bc_nack_rcv(struct tipc_link *l, struct sk_buff *skb,  in tipc_link_bc_nack_rcv()  argument
2509 	if (!tipc_link_is_up(l) || !l->bc_peer_is_up)  in tipc_link_bc_nack_rcv()
2515 	if (dnode == tipc_own_addr(l->net)) {  in tipc_link_bc_nack_rcv()
2516 		rc = tipc_link_bc_ack_rcv(l, acked, to - acked, NULL, xmitq,  in tipc_link_bc_nack_rcv()
2518 		l->stats.recv_nacks++;  in tipc_link_bc_nack_rcv()
2523 	if (more(peers_snd_nxt, l->rcv_nxt) && !less(l->rcv_nxt, from))  in tipc_link_bc_nack_rcv()
2524 		l->nack_state = BC_NACK_SND_SUPPRESS;  in tipc_link_bc_nack_rcv()
2529 void tipc_link_set_queue_limits(struct tipc_link *l, u32 min_win, u32 max_win)  in tipc_link_set_queue_limits()  argument
2531 	int max_bulk = TIPC_MAX_PUBL / (l->mtu / ITEM_SIZE);  in tipc_link_set_queue_limits()
2533 	l->min_win = min_win;  in tipc_link_set_queue_limits()
2534 	l->ssthresh = max_win;  in tipc_link_set_queue_limits()
2535 	l->max_win = max_win;  in tipc_link_set_queue_limits()
2536 	l->window = min_win;  in tipc_link_set_queue_limits()
2537 	l->backlog[TIPC_LOW_IMPORTANCE].limit      = min_win * 2;  in tipc_link_set_queue_limits()
2538 	l->backlog[TIPC_MEDIUM_IMPORTANCE].limit   = min_win * 4;  in tipc_link_set_queue_limits()
2539 	l->backlog[TIPC_HIGH_IMPORTANCE].limit     = min_win * 6;  in tipc_link_set_queue_limits()
2540 	l->backlog[TIPC_CRITICAL_IMPORTANCE].limit = min_win * 8;  in tipc_link_set_queue_limits()
2541 	l->backlog[TIPC_SYSTEM_IMPORTANCE].limit   = max_bulk;  in tipc_link_set_queue_limits()
2548 void tipc_link_reset_stats(struct tipc_link *l)  in tipc_link_reset_stats()  argument
2550 	memset(&l->stats, 0, sizeof(l->stats));  in tipc_link_reset_stats()
2553 static void link_print(struct tipc_link *l, const char *str)  in link_print()  argument
2555 	struct sk_buff *hskb = skb_peek(&l->transmq);  in link_print()
2556 	u16 head = hskb ? msg_seqno(buf_msg(hskb)) : l->snd_nxt - 1;  in link_print()
2557 	u16 tail = l->snd_nxt - 1;  in link_print()
2559 	pr_info("%s Link <%s> state %x\n", str, l->name, l->state);  in link_print()
2561 		skb_queue_len(&l->transmq), head, tail,  in link_print()
2562 		skb_queue_len(&l->backlogq), l->snd_nxt, l->rcv_nxt);  in link_print()
2862 void tipc_link_set_tolerance(struct tipc_link *l, u32 tol,  in tipc_link_set_tolerance()  argument
2865 	l->tolerance = tol;  in tipc_link_set_tolerance()
2866 	if (l->bc_rcvlink)  in tipc_link_set_tolerance()
2867 		l->bc_rcvlink->tolerance = tol;  in tipc_link_set_tolerance()
2868 	if (tipc_link_is_up(l))  in tipc_link_set_tolerance()
2869 		tipc_link_build_proto_msg(l, STATE_MSG, 0, 0, 0, tol, 0, xmitq);  in tipc_link_set_tolerance()
2872 void tipc_link_set_prio(struct tipc_link *l, u32 prio,  in tipc_link_set_prio()  argument
2875 	l->priority = prio;  in tipc_link_set_prio()
2876 	tipc_link_build_proto_msg(l, STATE_MSG, 0, 0, 0, 0, prio, xmitq);  in tipc_link_set_prio()
2879 void tipc_link_set_abort_limit(struct tipc_link *l, u32 limit)  in tipc_link_set_abort_limit()  argument
2881 	l->abort_limit = limit;  in tipc_link_set_abort_limit()
2897 int tipc_link_dump(struct tipc_link *l, u16 dqueues, char *buf)  in tipc_link_dump()  argument
2905 	if (!l) {  in tipc_link_dump()
2910 	i += scnprintf(buf, sz, "link data: %x", l->addr);  in tipc_link_dump()
2911 	i += scnprintf(buf + i, sz - i, " %x", l->state);  in tipc_link_dump()
2912 	i += scnprintf(buf + i, sz - i, " %u", l->in_session);  in tipc_link_dump()
2913 	i += scnprintf(buf + i, sz - i, " %u", l->session);  in tipc_link_dump()
2914 	i += scnprintf(buf + i, sz - i, " %u", l->peer_session);  in tipc_link_dump()
2915 	i += scnprintf(buf + i, sz - i, " %u", l->snd_nxt);  in tipc_link_dump()
2916 	i += scnprintf(buf + i, sz - i, " %u", l->rcv_nxt);  in tipc_link_dump()
2917 	i += scnprintf(buf + i, sz - i, " %u", l->snd_nxt_state);  in tipc_link_dump()
2918 	i += scnprintf(buf + i, sz - i, " %u", l->rcv_nxt_state);  in tipc_link_dump()
2919 	i += scnprintf(buf + i, sz - i, " %x", l->peer_caps);  in tipc_link_dump()
2920 	i += scnprintf(buf + i, sz - i, " %u", l->silent_intv_cnt);  in tipc_link_dump()
2921 	i += scnprintf(buf + i, sz - i, " %u", l->rst_cnt);  in tipc_link_dump()
2924 	i += scnprintf(buf + i, sz - i, " %u", l->acked);  in tipc_link_dump()
2926 	list = &l->transmq;  in tipc_link_dump()
2934 	list = &l->deferdq;  in tipc_link_dump()
2942 	list = &l->backlogq;  in tipc_link_dump()
2950 	list = l->inputq;  in tipc_link_dump()
2960 		i += tipc_list_dump(&l->transmq, false, buf + i);  in tipc_link_dump()
2965 			       l->backlog[TIPC_LOW_IMPORTANCE].len,  in tipc_link_dump()
2966 			       l->backlog[TIPC_MEDIUM_IMPORTANCE].len,  in tipc_link_dump()
2967 			       l->backlog[TIPC_HIGH_IMPORTANCE].len,  in tipc_link_dump()
2968 			       l->backlog[TIPC_CRITICAL_IMPORTANCE].len,  in tipc_link_dump()
2969 			       l->backlog[TIPC_SYSTEM_IMPORTANCE].len);  in tipc_link_dump()
2970 		i += tipc_list_dump(&l->backlogq, false, buf + i);  in tipc_link_dump()
2974 		i += tipc_list_dump(&l->deferdq, false, buf + i);  in tipc_link_dump()
2978 		i += tipc_list_dump(l->inputq, false, buf + i);  in tipc_link_dump()
2982 		i += tipc_list_dump(&l->wakeupq, false, buf + i);  in tipc_link_dump()