| /net/rxrpc/ |
| D | ar-ack.c | 338 struct rxrpc_ackpacket *ack, in rxrpc_process_soft_ACKs() argument
350 ack->nAcks); in rxrpc_process_soft_ACKs()
352 if (skb_copy_bits(skb, 0, sacks, ack->nAcks) < 0) in rxrpc_process_soft_ACKs()
357 for (loop = 0; loop < ack->nAcks; loop++) { in rxrpc_process_soft_ACKs()
634 struct rxrpc_ackpacket ack; in rxrpc_process_rx_queue() local
672 if (skb_copy_bits(skb, 0, &ack, sizeof(ack)) < 0) { in rxrpc_process_rx_queue()
676 if (!skb_pull(skb, sizeof(ack))) in rxrpc_process_rx_queue()
680 hard = ntohl(ack.firstPacket); in rxrpc_process_rx_queue()
685 ntohs(ack.maxSkew), in rxrpc_process_rx_queue()
687 ntohl(ack.previousPacket), in rxrpc_process_rx_queue()
[all …]
|
| D | ar-input.c | 139 int ret, ackbit, ack; in rxrpc_fast_process_data() local
157 ack = RXRPC_ACK_DUPLICATE; in rxrpc_fast_process_data()
168 ack = RXRPC_ACK_DUPLICATE; in rxrpc_fast_process_data()
175 ack = RXRPC_ACK_EXCEEDS_WINDOW; in rxrpc_fast_process_data()
186 ack = RXRPC_ACK_OUT_OF_SEQUENCE; in rxrpc_fast_process_data()
213 ack = RXRPC_ACK_NOSPACE; in rxrpc_fast_process_data()
254 __rxrpc_propose_ACK(call, ack, sp->hdr.serial, true); in rxrpc_fast_process_data()
262 __rxrpc_propose_ACK(call, ack, sp->hdr.serial, true); in rxrpc_fast_process_data()
|
| D | Makefile | 8 ar-ack.o \
|
| /net/decnet/ |
| D | dn_nsp_in.c | 100 static void dn_ack(struct sock *sk, struct sk_buff *skb, unsigned short ack) in dn_ack() argument
103 unsigned short type = ((ack >> 12) & 0x0003); in dn_ack()
108 if (dn_after(ack, scp->ackrcv_dat)) { in dn_ack()
109 scp->ackrcv_dat = ack & 0x0fff; in dn_ack()
112 ack); in dn_ack()
118 if (dn_after(ack, scp->ackrcv_oth)) { in dn_ack()
119 scp->ackrcv_oth = ack & 0x0fff; in dn_ack()
122 ack); in dn_ack()
140 unsigned short ack; in dn_process_ack() local
145 if ((ack = le16_to_cpu(*ptr)) & 0x8000) { in dn_process_ack()
[all …]
|
| D | dn_nsp_out.c | 384 struct sk_buff *skb2, *n, *ack = NULL; in dn_nsp_check_xmit_queue() local
396 ack = skb2; in dn_nsp_check_xmit_queue()
400 if (ack == NULL) in dn_nsp_check_xmit_queue()
414 skb_unlink(ack, q); in dn_nsp_check_xmit_queue()
415 kfree_skb(ack); in dn_nsp_check_xmit_queue()
416 ack = NULL; in dn_nsp_check_xmit_queue()
|
| /net/netfilter/ |
| D | nf_conntrack_proto_tcp.c | 328 else if (tcph->syn) return (tcph->ack ? TCP_SYNACK_SET : TCP_SYN_SET); in get_conntrack_index()
330 else if (tcph->ack) return TCP_ACK_SET; in get_conntrack_index()
518 __u32 seq, ack, sack, end, win, swin; in tcp_in_window() local
526 ack = sack = ntohl(tcph->ack_seq); in tcp_in_window()
534 receiver_offset = nf_ct_seq_offset(ct, !dir, ack - 1); in tcp_in_window()
535 ack -= receiver_offset; in tcp_in_window()
542 seq, ack, receiver_offset, sack, receiver_offset, win, end); in tcp_in_window()
573 if (!tcph->ack) in tcp_in_window()
611 if (!(tcph->ack)) { in tcp_in_window()
615 ack = sack = receiver->td_end; in tcp_in_window()
[all …]
|
| D | nfnetlink.c | 340 goto ack; in nfnetlink_rcv_batch()
354 goto ack; in nfnetlink_rcv_batch()
362 goto ack; in nfnetlink_rcv_batch()
368 goto ack; in nfnetlink_rcv_batch()
381 goto ack; in nfnetlink_rcv_batch()
397 ack: in nfnetlink_rcv_batch()
|
| /net/ipv4/ |
| D | tcp_vegas.c | 164 static void tcp_vegas_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_vegas_cong_avoid() argument
170 tcp_reno_cong_avoid(sk, ack, acked); in tcp_vegas_cong_avoid()
174 if (after(ack, vegas->beg_snd_nxt)) { in tcp_vegas_cong_avoid()
195 tcp_reno_cong_avoid(sk, ack, acked); in tcp_vegas_cong_avoid()
|
| D | tcp_veno.c | 117 static void tcp_veno_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_veno_cong_avoid() argument
123 tcp_reno_cong_avoid(sk, ack, acked); in tcp_veno_cong_avoid()
136 tcp_reno_cong_avoid(sk, ack, acked); in tcp_veno_cong_avoid()
|
| D | tcp_hybla.c | 89 static void hybla_cong_avoid(struct sock *sk, u32 ack, u32 acked) in hybla_cong_avoid() argument
106 tcp_reno_cong_avoid(sk, ack, acked); in hybla_cong_avoid()
|
| D | tcp_input.c | 3027 static void tcp_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_cong_avoid() argument
3031 icsk->icsk_ca_ops->cong_avoid(sk, ack, acked); in tcp_cong_avoid()
3360 const u32 ack, const u32 ack_seq, in tcp_may_update_window() argument
3363 return after(ack, tp->snd_una) || in tcp_may_update_window()
3369 static void tcp_snd_una_update(struct tcp_sock *tp, u32 ack) in tcp_snd_una_update() argument
3371 u32 delta = ack - tp->snd_una; in tcp_snd_una_update()
3376 tp->snd_una = ack; in tcp_snd_una_update()
3395 static int tcp_ack_update_window(struct sock *sk, const struct sk_buff *skb, u32 ack, in tcp_ack_update_window() argument
3405 if (tcp_may_update_window(tp, ack, ack_seq, nwin)) { in tcp_ack_update_window()
3428 tcp_snd_una_update(tp, ack); in tcp_ack_update_window()
[all …]
|
| D | tcp_yeah.c | 70 static void tcp_yeah_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_yeah_cong_avoid() argument
120 if (after(ack, yeah->vegas.beg_snd_nxt)) { in tcp_yeah_cong_avoid()
|
| D | tcp_cdg.c | 260 static void tcp_cdg_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_cdg_cong_avoid() argument
270 if (after(ack, ca->rtt_seq) && ca->rtt.v64) { in tcp_cdg_cong_avoid()
291 tcp_reno_cong_avoid(sk, ack, acked); in tcp_cdg_cong_avoid()
|
| D | tcp_lp.c | 118 static void tcp_lp_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_lp_cong_avoid() argument
123 tcp_reno_cong_avoid(sk, ack, acked); in tcp_lp_cong_avoid()
|
| D | tcp_scalable.c | 18 static void tcp_scalable_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_scalable_cong_avoid() argument
|
| D | tcp_illinois.c | 258 static void tcp_illinois_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_illinois_cong_avoid() argument
263 if (after(ack, ca->end_seq)) in tcp_illinois_cong_avoid()
|
| D | tcp_highspeed.c | 111 static void hstcp_cong_avoid(struct sock *sk, u32 ack, u32 acked) in hstcp_cong_avoid() argument
|
| /net/sctp/ |
| D | associola.c | 1665 struct sctp_chunk *ack; in sctp_assoc_free_asconf_acks() local
1668 list_for_each_entry_safe(ack, tmp, &asoc->asconf_ack_list, in sctp_assoc_free_asconf_acks()
1670 list_del_init(&ack->transmitted_list); in sctp_assoc_free_asconf_acks()
1671 sctp_chunk_free(ack); in sctp_assoc_free_asconf_acks()
1678 struct sctp_chunk *ack; in sctp_assoc_clean_asconf_ack_cache() local
1684 list_for_each_entry_safe(ack, tmp, &asoc->asconf_ack_list, in sctp_assoc_clean_asconf_ack_cache()
1686 if (ack->subh.addip_hdr->serial == in sctp_assoc_clean_asconf_ack_cache()
1690 list_del_init(&ack->transmitted_list); in sctp_assoc_clean_asconf_ack_cache()
1691 sctp_chunk_free(ack); in sctp_assoc_clean_asconf_ack_cache()
1700 struct sctp_chunk *ack; in sctp_assoc_lookup_asconf_ack() local
[all …]
|
| /net/ipv4/netfilter/ |
| D | ipt_SYNPROXY.c | 279 if (th->syn && !(th->ack || th->fin || th->rst)) { in synproxy_tg4()
297 } else if (th->ack && !(th->fin || th->rst || th->syn)) { in synproxy_tg4()
344 if (!th->syn || th->ack || in ipv4_synproxy_hook()
361 if (!th->syn && th->ack && in ipv4_synproxy_hook()
379 if (!th->syn || !th->ack) in ipv4_synproxy_hook()
|
| D | nf_reject_ipv4.c | 83 if (oth->ack) { in nf_reject_ip_tcphdr_put()
89 tcph->ack = 1; in nf_reject_ip_tcphdr_put()
|
| /net/tipc/ |
| D | link.c | 202 u16 ack = snd_l->snd_nxt - 1; in tipc_link_remove_bc_peer() local
205 tipc_link_bc_ack_rcv(rcv_l, ack, xmitq); in tipc_link_remove_bc_peer()
718 u16 ack = l->rcv_nxt - 1; in tipc_link_xmit() local
738 msg_set_ack(hdr, ack); in tipc_link_xmit()
778 u16 ack = l->rcv_nxt - 1; in tipc_link_advance_backlog() local
795 msg_set_ack(hdr, ack); in tipc_link_advance_backlog()
820 u16 ack = l->rcv_nxt - 1; in tipc_link_retrans() local
849 msg_set_ack(hdr, ack); in tipc_link_retrans()
1220 u16 ack = msg_ack(hdr); in tipc_link_proto_rcv() local
1302 tipc_link_release_pkts(l, ack); in tipc_link_proto_rcv()
[all …]
|
| /net/ipv6/netfilter/ |
| D | ip6t_SYNPROXY.c | 292 if (th->syn && !(th->ack || th->fin || th->rst)) { in synproxy_tg6()
310 } else if (th->ack && !(th->fin || th->rst || th->syn)) { in synproxy_tg6()
364 if (!th->syn || th->ack || in ipv6_synproxy_hook()
381 if (!th->syn && th->ack && in ipv6_synproxy_hook()
399 if (!th->syn || !th->ack) in ipv6_synproxy_hook()
|
| D | nf_reject_ipv6.c | 105 if (oth->ack) { in nf_reject_ip6_tcphdr_put()
119 tcph->ack = needs_ack; in nf_reject_ip6_tcphdr_put()
|
| /net/rds/ |
| D | tcp_send.c | 170 static int rds_tcp_is_acked(struct rds_message *rm, uint64_t ack) in rds_tcp_is_acked() argument
174 return (__s32)((u32)rm->m_ack_seq - (u32)ack) < 0; in rds_tcp_is_acked()
|
| D | send.c | 450 static inline int rds_send_is_acked(struct rds_message *rm, u64 ack, in rds_send_is_acked() argument
454 return is_acked(rm, ack); in rds_send_is_acked()
455 return be64_to_cpu(rm->m_inc.i_hdr.h_sequence) <= ack; in rds_send_is_acked()
689 void rds_send_drop_acked(struct rds_connection *conn, u64 ack, in rds_send_drop_acked() argument
699 if (!rds_send_is_acked(rm, ack, is_acked)) in rds_send_drop_acked()
|