• Home
  • Raw
  • Download

Lines Matching full:gap

145  * @last_gap: last gap ack blocks for bcast (FIXME)
146 * @last_ga: ptr to gap ack blocks
281 u16 acked, u16 gap,
426 u16 gap = 0; in link_bc_rcv_gap() local
429 gap = l->snd_nxt - l->rcv_nxt; in link_bc_rcv_gap()
431 gap = buf_seqno(skb) - l->rcv_nxt; in link_bc_rcv_gap()
432 return gap; in link_bc_rcv_gap()
1431 * tipc_get_gap_ack_blks - get Gap ACK blocks from PROTOCOL/STATE_MSG
1432 * @ga: returned pointer to the Gap ACK blocks if any
1435 * @uc: desired Gap ACK blocks type, i.e. unicast (= 1) or broadcast (= 0)
1437 * Return: the total Gap ACK blocks size
1445 /* Does peer support the Gap ACK blocks feature? */ in tipc_get_gap_ack_blks()
1486 gacks[n].gap = htons(seqno - expect); in __tipc_build_gap_ack_blks()
1502 gacks[n].gap = 0; in __tipc_build_gap_ack_blks()
1507 /* tipc_build_gap_ack_blks - build Gap ACK blocks
1509 * @hdr: the tipc message buffer to store the Gap ACK blocks after built
1511 * The function builds Gap ACK blocks for both the unicast & broadcast receiver
1548 * @gap: # of gap packets
1549 * @ga: buffer pointer to Gap ACK blocks from peer
1558 u16 acked, u16 gap, in tipc_link_advance_transmq() argument
1568 u16 nacked = acked, ngap = gap, gack_cnt = 0; in tipc_link_advance_transmq()
1577 trace_tipc_link_retrans(r, acked + 1, acked + gap, &l->transmq); in tipc_link_advance_transmq()
1579 /* Determine Gap ACK blocks if any for the particular link */ in tipc_link_advance_transmq()
1581 /* Get the Gap ACKs, uc part */ in tipc_link_advance_transmq()
1585 /* Copy the Gap ACKs, bc part, for later renewal if needed */ in tipc_link_advance_transmq()
1590 /* Start with the bc Gap ACKs */ in tipc_link_advance_transmq()
1595 pr_warn_ratelimited("Ignoring bc Gap ACKs, no memory\n"); in tipc_link_advance_transmq()
1610 /* Get the next of last Gap ACK blocks */ in tipc_link_advance_transmq()
1616 offset = ntohs(last_ga->gacks[si].gap); in tipc_link_advance_transmq()
1622 "Corrupted Gap ACK: %d %d %d %d %d\n", in tipc_link_advance_transmq()
1626 /* Check against the last Gap ACK block */ in tipc_link_advance_transmq()
1638 /* First gap: check if repeated retrans failures? */ in tipc_link_advance_transmq()
1641 /* Ignore this bc Gap ACKs if any */ in tipc_link_advance_transmq()
1666 /* retry with Gap ACK blocks if any */ in tipc_link_advance_transmq()
1670 ngap = ntohs(gacks[n].gap); in tipc_link_advance_transmq()
1676 /* Renew last Gap ACK blocks for bc if needed */ in tipc_link_advance_transmq()
1681 r->last_gap = gap; in tipc_link_advance_transmq()
1825 /* Defer delivery if sequence gap */ in tipc_link_rcv()
2208 u16 gap = msg_seq_gap(hdr); in tipc_link_proto_rcv() local
2295 /* Validate Gap ACK blocks, drop if invalid */ in tipc_link_proto_rcv()
2338 released = tipc_link_advance_transmq(l, l, ack, gap, ga, xmitq, in tipc_link_proto_rcv()
2340 if (gap) in tipc_link_proto_rcv()
2485 int tipc_link_bc_ack_rcv(struct tipc_link *r, u16 acked, u16 gap, in tipc_link_bc_ack_rcv() argument
2497 if (gap) { in tipc_link_bc_ack_rcv()
2502 if (less(acked, r->acked) || (acked == r->acked && !gap && !ga)) in tipc_link_bc_ack_rcv()
2505 trace_tipc_link_bc_ack(r, acked, gap, &l->transmq); in tipc_link_bc_ack_rcv()
2506 tipc_link_advance_transmq(l, r, acked, gap, ga, retrq, &unused, &rc); in tipc_link_bc_ack_rcv()