Commit 77cf8edb authored by Jon Maloy's avatar Jon Maloy Committed by David S. Miller

tipc: simplify stale link failure criteria

In commit a4dc70d4 ("tipc: extend link reset criteria for stale
packet retransmission") we made link retransmission failure events
dependent on the link tolerance, and not only of the number of failed
retransmission attempts, as we did earlier. This works well. However,
keeping the original, additional criteria of 99 failed retransmissions
is now redundant, and may in some cases lead to failure detection
times in the order of minutes instead of the expected 1.5 sec link
tolerance value.

We now remove this criteria altogether.
Acked-by: default avatarYing Xue <ying.xue@windriver.com>
Signed-off-by: default avatarJon Maloy <jon.maloy@ericsson.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 489ce2f4
...@@ -107,7 +107,6 @@ struct tipc_stats { ...@@ -107,7 +107,6 @@ struct tipc_stats {
* @backlogq: queue for messages waiting to be sent * @backlogq: queue for messages waiting to be sent
* @snt_nxt: next sequence number to use for outbound messages * @snt_nxt: next sequence number to use for outbound messages
* @prev_from: sequence number of most previous retransmission request * @prev_from: sequence number of most previous retransmission request
* @stale_cnt: counter for number of identical retransmit attempts
* @stale_limit: time when repeated identical retransmits must force link reset * @stale_limit: time when repeated identical retransmits must force link reset
* @ackers: # of peers that needs to ack each packet before it can be released * @ackers: # of peers that needs to ack each packet before it can be released
* @acked: # last packet acked by a certain peer. Used for broadcast. * @acked: # last packet acked by a certain peer. Used for broadcast.
...@@ -167,7 +166,6 @@ struct tipc_link { ...@@ -167,7 +166,6 @@ struct tipc_link {
u16 snd_nxt; u16 snd_nxt;
u16 prev_from; u16 prev_from;
u16 window; u16 window;
u16 stale_cnt;
unsigned long stale_limit; unsigned long stale_limit;
/* Reception */ /* Reception */
...@@ -910,7 +908,6 @@ void tipc_link_reset(struct tipc_link *l) ...@@ -910,7 +908,6 @@ void tipc_link_reset(struct tipc_link *l)
l->acked = 0; l->acked = 0;
l->silent_intv_cnt = 0; l->silent_intv_cnt = 0;
l->rst_cnt = 0; l->rst_cnt = 0;
l->stale_cnt = 0;
l->bc_peer_is_up = false; l->bc_peer_is_up = false;
memset(&l->mon_state, 0, sizeof(l->mon_state)); memset(&l->mon_state, 0, sizeof(l->mon_state));
tipc_link_reset_stats(l); tipc_link_reset_stats(l);
...@@ -1068,8 +1065,7 @@ static bool link_retransmit_failure(struct tipc_link *l, struct tipc_link *r, ...@@ -1068,8 +1065,7 @@ static bool link_retransmit_failure(struct tipc_link *l, struct tipc_link *r,
if (r->prev_from != from) { if (r->prev_from != from) {
r->prev_from = from; r->prev_from = from;
r->stale_limit = jiffies + msecs_to_jiffies(r->tolerance); r->stale_limit = jiffies + msecs_to_jiffies(r->tolerance);
r->stale_cnt = 0; } else if (time_after(jiffies, r->stale_limit)) {
} else if (++r->stale_cnt > 99 && time_after(jiffies, r->stale_limit)) {
pr_warn("Retransmission failure on link <%s>\n", l->name); pr_warn("Retransmission failure on link <%s>\n", l->name);
link_print(l, "State of link "); link_print(l, "State of link ");
pr_info("Failed msg: usr %u, typ %u, len %u, err %u\n", pr_info("Failed msg: usr %u, typ %u, len %u, err %u\n",
...@@ -1515,7 +1511,6 @@ int tipc_link_rcv(struct tipc_link *l, struct sk_buff *skb, ...@@ -1515,7 +1511,6 @@ int tipc_link_rcv(struct tipc_link *l, struct sk_buff *skb,
/* Forward queues and wake up waiting users */ /* Forward queues and wake up waiting users */
if (likely(tipc_link_release_pkts(l, msg_ack(hdr)))) { if (likely(tipc_link_release_pkts(l, msg_ack(hdr)))) {
l->stale_cnt = 0;
tipc_link_advance_backlog(l, xmitq); tipc_link_advance_backlog(l, xmitq);
if (unlikely(!skb_queue_empty(&l->wakeupq))) if (unlikely(!skb_queue_empty(&l->wakeupq)))
link_prepare_wakeup(l); link_prepare_wakeup(l);
...@@ -2584,7 +2579,7 @@ int tipc_link_dump(struct tipc_link *l, u16 dqueues, char *buf) ...@@ -2584,7 +2579,7 @@ int tipc_link_dump(struct tipc_link *l, u16 dqueues, char *buf)
i += scnprintf(buf + i, sz - i, " %u", l->silent_intv_cnt); i += scnprintf(buf + i, sz - i, " %u", l->silent_intv_cnt);
i += scnprintf(buf + i, sz - i, " %u", l->rst_cnt); i += scnprintf(buf + i, sz - i, " %u", l->rst_cnt);
i += scnprintf(buf + i, sz - i, " %u", l->prev_from); i += scnprintf(buf + i, sz - i, " %u", l->prev_from);
i += scnprintf(buf + i, sz - i, " %u", l->stale_cnt); i += scnprintf(buf + i, sz - i, " %u", 0);
i += scnprintf(buf + i, sz - i, " %u", l->acked); i += scnprintf(buf + i, sz - i, " %u", l->acked);
list = &l->transmq; list = &l->transmq;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment