Lines Matching +full:min +full:- +full:sample +full:- +full:rate +full:- +full:hz
1 // SPDX-License-Identifier: GPL-2.0-or-later
19 /* rate-limit for syncs in reply to sequence-invalid packets; RFC 4340, 7.5.4 */
20 int sysctl_dccp_sync_ratelimit __read_mostly = HZ / 8;
24 __skb_pull(skb, dccp_hdr(skb)->dccph_doff * 4); in dccp_enqueue_skb()
25 __skb_queue_tail(&sk->sk_receive_queue, skb); in dccp_enqueue_skb()
27 sk->sk_data_ready(sk); in dccp_enqueue_skb()
38 sk->sk_shutdown = SHUTDOWN_MASK; in dccp_fin()
47 switch (sk->sk_state) { in dccp_rcv_close()
50 * - CLOSED (may be a late or duplicate packet) in dccp_rcv_close()
51 * - PASSIVE_CLOSEREQ (the peer has sent a CloseReq earlier) in dccp_rcv_close()
52 * - RESPOND (already handled by dccp_check_req) in dccp_rcv_close()
56 * Simultaneous-close: receiving a Close after sending one. This in dccp_rcv_close()
57 * can happen if both client and server perform active-close and in dccp_rcv_close()
58 * will result in an endless ping-pong of crossing and retrans- in dccp_rcv_close()
60 * nodes times out (min. 64 seconds). Quicker convergence can be in dccp_rcv_close()
61 * achieved when one of the nodes acts as tie-breaker. in dccp_rcv_close()
65 if (dccp_sk(sk)->dccps_role != DCCP_ROLE_CLIENT) in dccp_rcv_close()
99 if (dccp_sk(sk)->dccps_role != DCCP_ROLE_CLIENT) { in dccp_rcv_closereq()
100 dccp_send_sync(sk, DCCP_SKB_CB(skb)->dccpd_seq, DCCP_PKT_SYNC); in dccp_rcv_closereq()
105 switch (sk->sk_state) { in dccp_rcv_closereq()
147 u16 err = dccp_reset_code_convert(dccp_hdr_reset(skb)->dccph_reset_code); in dccp_rcv_reset()
149 sk->sk_err = err; in dccp_rcv_reset()
161 struct dccp_ackvec *av = dccp_sk(sk)->dccps_hc_rx_ackvec; in dccp_handle_ackvec_processing()
165 if (DCCP_SKB_CB(skb)->dccpd_ack_seq != DCCP_PKT_WITHOUT_ACK_SEQ) in dccp_handle_ackvec_processing()
166 dccp_ackvec_clear_state(av, DCCP_SKB_CB(skb)->dccpd_ack_seq); in dccp_handle_ackvec_processing()
175 if (!(sk->sk_shutdown & RCV_SHUTDOWN)) in dccp_deliver_input_to_ccids()
176 ccid_hc_rx_packet_recv(dp->dccps_hc_rx_ccid, sk, skb); in dccp_deliver_input_to_ccids()
181 if (sk->sk_write_queue.qlen > 0 || !(sk->sk_shutdown & SEND_SHUTDOWN)) in dccp_deliver_input_to_ccids()
182 ccid_hc_tx_packet_recv(dp->dccps_hc_tx_ccid, sk, skb); in dccp_deliver_input_to_ccids()
189 u64 lswl, lawl, seqno = DCCP_SKB_CB(skb)->dccpd_seq, in dccp_check_seqno()
190 ackno = DCCP_SKB_CB(skb)->dccpd_ack_seq; in dccp_check_seqno()
204 if (dh->dccph_type == DCCP_PKT_SYNC || in dccp_check_seqno()
205 dh->dccph_type == DCCP_PKT_SYNCACK) { in dccp_check_seqno()
206 if (between48(ackno, dp->dccps_awl, dp->dccps_awh) && in dccp_check_seqno()
207 dccp_delta_seqno(dp->dccps_swl, seqno) >= 0) in dccp_check_seqno()
210 return -1; in dccp_check_seqno()
224 lswl = dp->dccps_swl; in dccp_check_seqno()
225 lawl = dp->dccps_awl; in dccp_check_seqno()
227 if (dh->dccph_type == DCCP_PKT_CLOSEREQ || in dccp_check_seqno()
228 dh->dccph_type == DCCP_PKT_CLOSE || in dccp_check_seqno()
229 dh->dccph_type == DCCP_PKT_RESET) { in dccp_check_seqno()
230 lswl = ADD48(dp->dccps_gsr, 1); in dccp_check_seqno()
231 lawl = dp->dccps_gar; in dccp_check_seqno()
234 if (between48(seqno, lswl, dp->dccps_swh) && in dccp_check_seqno()
236 between48(ackno, lawl, dp->dccps_awh))) { in dccp_check_seqno()
239 if (dh->dccph_type != DCCP_PKT_SYNC && in dccp_check_seqno()
241 after48(ackno, dp->dccps_gar)) in dccp_check_seqno()
242 dp->dccps_gar = ackno; in dccp_check_seqno()
254 * These Syncs are rate-limited as per RFC 4340, 7.5.4: in dccp_check_seqno()
255 * at most 1 / (dccp_sync_rate_limit * HZ) Syncs per second. in dccp_check_seqno()
257 if (time_before(now, (dp->dccps_rate_last + in dccp_check_seqno()
259 return -1; in dccp_check_seqno()
264 "sending SYNC...\n", dccp_packet_name(dh->dccph_type), in dccp_check_seqno()
266 (unsigned long long) dp->dccps_swh, in dccp_check_seqno()
270 (unsigned long long) dp->dccps_awh); in dccp_check_seqno()
272 dp->dccps_rate_last = now; in dccp_check_seqno()
274 if (dh->dccph_type == DCCP_PKT_RESET) in dccp_check_seqno()
275 seqno = dp->dccps_gsr; in dccp_check_seqno()
277 return -1; in dccp_check_seqno()
288 switch (dccp_hdr(skb)->dccph_type) { in __dccp_rcv_established()
293 * - sk_shutdown == RCV_SHUTDOWN, use Code 1, "Not Listening" in __dccp_rcv_established()
294 * - sk_receive_queue is full, use Code 2, "Receive Buffer" in __dccp_rcv_established()
331 if (dp->dccps_role != DCCP_ROLE_LISTEN) in __dccp_rcv_established()
335 if (dp->dccps_role != DCCP_ROLE_CLIENT) in __dccp_rcv_established()
338 if (dccp_delta_seqno(dp->dccps_osr, in __dccp_rcv_established()
339 DCCP_SKB_CB(skb)->dccpd_seq) >= 0) { in __dccp_rcv_established()
341 dccp_send_sync(sk, DCCP_SKB_CB(skb)->dccpd_seq, in __dccp_rcv_established()
346 dccp_send_sync(sk, DCCP_SKB_CB(skb)->dccpd_seq, in __dccp_rcv_established()
351 * As with DCCP-Ack packets, DCCP-Sync and DCCP-SyncAck packets in __dccp_rcv_established()
352 * MAY have non-zero-length application data areas, whose in __dccp_rcv_established()
400 if (dh->dccph_type == DCCP_PKT_RESPONSE) { in dccp_rcv_request_sent_state_process()
405 if (!between48(DCCP_SKB_CB(skb)->dccpd_ack_seq, in dccp_rcv_request_sent_state_process()
406 dp->dccps_awl, dp->dccps_awh)) { in dccp_rcv_request_sent_state_process()
409 (unsigned long long)dp->dccps_awl, in dccp_rcv_request_sent_state_process()
410 (unsigned long long)DCCP_SKB_CB(skb)->dccpd_ack_seq, in dccp_rcv_request_sent_state_process()
411 (unsigned long long)dp->dccps_awh); in dccp_rcv_request_sent_state_process()
423 /* Obtain usec RTT sample from SYN exchange (used by TFRC). */ in dccp_rcv_request_sent_state_process()
424 if (likely(dp->dccps_options_received.dccpor_timestamp_echo)) in dccp_rcv_request_sent_state_process()
425 dp->dccps_syn_rtt = dccp_sample_rtt(sk, 10 * (tstamp - in dccp_rcv_request_sent_state_process()
426 dp->dccps_options_received.dccpor_timestamp_echo)); in dccp_rcv_request_sent_state_process()
430 WARN_ON(sk->sk_send_head == NULL); in dccp_rcv_request_sent_state_process()
431 kfree_skb(sk->sk_send_head); in dccp_rcv_request_sent_state_process()
432 sk->sk_send_head = NULL; in dccp_rcv_request_sent_state_process()
441 dp->dccps_gsr = dp->dccps_isr = DCCP_SKB_CB(skb)->dccpd_seq; in dccp_rcv_request_sent_state_process()
443 dccp_sync_mss(sk, icsk->icsk_pmtu_cookie); in dccp_rcv_request_sent_state_process()
458 * three-way handshake * / in dccp_rcv_request_sent_state_process()
468 if (dccp_feat_activate_values(sk, &dp->dccps_featneg)) in dccp_rcv_request_sent_state_process()
472 icsk->icsk_af_ops->rebuild_header(sk); in dccp_rcv_request_sent_state_process()
475 sk->sk_state_change(sk); in dccp_rcv_request_sent_state_process()
479 if (sk->sk_write_pending || inet_csk_in_pingpong_mode(sk) || in dccp_rcv_request_sent_state_process()
480 icsk->icsk_accept_queue.rskq_defer_accept) { in dccp_rcv_request_sent_state_process()
486 * to stand against the temptation 8) --ANK in dccp_rcv_request_sent_state_process()
492 * us, also stated in the draft. -acme in dccp_rcv_request_sent_state_process()
498 return -1; in dccp_rcv_request_sent_state_process()
503 DCCP_SKB_CB(skb)->dccpd_reset_code = DCCP_RESET_CODE_PACKET_ERROR; in dccp_rcv_request_sent_state_process()
507 DCCP_SKB_CB(skb)->dccpd_reset_code = DCCP_RESET_CODE_ABORTED; in dccp_rcv_request_sent_state_process()
513 sk->sk_err = ECOMM; in dccp_rcv_request_sent_state_process()
523 u32 sample = dp->dccps_options_received.dccpor_timestamp_echo; in dccp_rcv_respond_partopen_state_process() local
526 switch (dh->dccph_type) { in dccp_rcv_respond_partopen_state_process()
531 if (sk->sk_state == DCCP_RESPOND) in dccp_rcv_respond_partopen_state_process()
546 if (sk->sk_state == DCCP_PARTOPEN) in dccp_rcv_respond_partopen_state_process()
549 /* Obtain usec RTT sample from SYN exchange (used by TFRC). */ in dccp_rcv_respond_partopen_state_process()
550 if (likely(sample)) { in dccp_rcv_respond_partopen_state_process()
551 long delta = dccp_timestamp() - sample; in dccp_rcv_respond_partopen_state_process()
553 dp->dccps_syn_rtt = dccp_sample_rtt(sk, 10 * delta); in dccp_rcv_respond_partopen_state_process()
556 dp->dccps_osr = DCCP_SKB_CB(skb)->dccpd_seq; in dccp_rcv_respond_partopen_state_process()
559 if (dh->dccph_type == DCCP_PKT_DATAACK || in dccp_rcv_respond_partopen_state_process()
560 dh->dccph_type == DCCP_PKT_DATA) { in dccp_rcv_respond_partopen_state_process()
576 const int old_state = sk->sk_state; in dccp_rcv_state_process()
602 if (sk->sk_state == DCCP_LISTEN) { in dccp_rcv_state_process()
603 if (dh->dccph_type == DCCP_PKT_REQUEST) { in dccp_rcv_state_process()
609 acceptable = inet_csk(sk)->icsk_af_ops->conn_request(sk, skb) >= 0; in dccp_rcv_state_process()
617 if (dh->dccph_type == DCCP_PKT_RESET) in dccp_rcv_state_process()
621 dcb->dccpd_reset_code = DCCP_RESET_CODE_NO_CONNECTION; in dccp_rcv_state_process()
623 } else if (sk->sk_state == DCCP_CLOSED) { in dccp_rcv_state_process()
624 dcb->dccpd_reset_code = DCCP_RESET_CODE_NO_CONNECTION; in dccp_rcv_state_process()
629 if (sk->sk_state != DCCP_REQUESTING && dccp_check_seqno(sk, skb)) in dccp_rcv_state_process()
640 if ((dp->dccps_role != DCCP_ROLE_CLIENT && in dccp_rcv_state_process()
641 dh->dccph_type == DCCP_PKT_RESPONSE) || in dccp_rcv_state_process()
642 (dp->dccps_role == DCCP_ROLE_CLIENT && in dccp_rcv_state_process()
643 dh->dccph_type == DCCP_PKT_REQUEST) || in dccp_rcv_state_process()
644 (sk->sk_state == DCCP_RESPOND && dh->dccph_type == DCCP_PKT_DATA)) { in dccp_rcv_state_process()
645 dccp_send_sync(sk, dcb->dccpd_seq, DCCP_PKT_SYNC); in dccp_rcv_state_process()
661 if (dh->dccph_type == DCCP_PKT_RESET) { in dccp_rcv_state_process()
664 } else if (dh->dccph_type == DCCP_PKT_CLOSEREQ) { /* Step 13 */ in dccp_rcv_state_process()
668 } else if (dh->dccph_type == DCCP_PKT_CLOSE) { /* Step 14 */ in dccp_rcv_state_process()
674 switch (sk->sk_state) { in dccp_rcv_state_process()
694 if (dh->dccph_type == DCCP_PKT_ACK || in dccp_rcv_state_process()
695 dh->dccph_type == DCCP_PKT_DATAACK) { in dccp_rcv_state_process()
698 sk->sk_state_change(sk); in dccp_rcv_state_process()
702 } else if (unlikely(dh->dccph_type == DCCP_PKT_SYNC)) { in dccp_rcv_state_process()
703 dccp_send_sync(sk, dcb->dccpd_seq, DCCP_PKT_SYNCACK); in dccp_rcv_state_process()
717 * dccp_sample_rtt - Validate and finalise computation of RTT sample
722 * called immediately when the ACK used for the RTT sample arrives.
727 delta -= dccp_sk(sk)->dccps_options_received.dccpor_elapsed_time * 10; in dccp_sample_rtt()
730 DCCP_WARN("unusable RTT sample %ld, using min\n", delta); in dccp_sample_rtt()
734 DCCP_WARN("RTT sample %ld too large, using max\n", delta); in dccp_sample_rtt()