^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 1) // SPDX-License-Identifier: GPL-2.0-or-later
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 2) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 3) * net/dccp/minisocks.c
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 4) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 5) * An implementation of the DCCP protocol
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 6) * Arnaldo Carvalho de Melo <acme@conectiva.com.br>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 7) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 8)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 9) #include <linux/dccp.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 10) #include <linux/gfp.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 11) #include <linux/kernel.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 12) #include <linux/skbuff.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 13) #include <linux/timer.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 14)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 15) #include <net/sock.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 16) #include <net/xfrm.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 17) #include <net/inet_timewait_sock.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 18)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 19) #include "ackvec.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 20) #include "ccid.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 21) #include "dccp.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 22) #include "feat.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 23)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 24) struct inet_timewait_death_row dccp_death_row = {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 25) .sysctl_max_tw_buckets = NR_FILE * 2,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 26) .hashinfo = &dccp_hashinfo,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 27) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 28)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 29) EXPORT_SYMBOL_GPL(dccp_death_row);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 30)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 31) void dccp_time_wait(struct sock *sk, int state, int timeo)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 32) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 33) struct inet_timewait_sock *tw;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 34)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 35) tw = inet_twsk_alloc(sk, &dccp_death_row, state);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 36)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 37) if (tw != NULL) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 38) const struct inet_connection_sock *icsk = inet_csk(sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 39) const int rto = (icsk->icsk_rto << 2) - (icsk->icsk_rto >> 1);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 40) #if IS_ENABLED(CONFIG_IPV6)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 41) if (tw->tw_family == PF_INET6) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 42) tw->tw_v6_daddr = sk->sk_v6_daddr;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 43) tw->tw_v6_rcv_saddr = sk->sk_v6_rcv_saddr;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 44) tw->tw_ipv6only = sk->sk_ipv6only;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 45) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 46) #endif
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 47)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 48) /* Get the TIME_WAIT timeout firing. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 49) if (timeo < rto)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 50) timeo = rto;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 51)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 52) if (state == DCCP_TIME_WAIT)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 53) timeo = DCCP_TIMEWAIT_LEN;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 54)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 55) /* tw_timer is pinned, so we need to make sure BH are disabled
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 56) * in following section, otherwise timer handler could run before
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 57) * we complete the initialization.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 58) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 59) local_bh_disable();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 60) inet_twsk_schedule(tw, timeo);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 61) /* Linkage updates.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 62) * Note that access to tw after this point is illegal.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 63) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 64) inet_twsk_hashdance(tw, sk, &dccp_hashinfo);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 65) local_bh_enable();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 66) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 67) /* Sorry, if we're out of memory, just CLOSE this
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 68) * socket up. We've got bigger problems than
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 69) * non-graceful socket closings.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 70) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 71) DCCP_WARN("time wait bucket table overflow\n");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 72) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 73)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 74) dccp_done(sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 75) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 76)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 77) struct sock *dccp_create_openreq_child(const struct sock *sk,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 78) const struct request_sock *req,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 79) const struct sk_buff *skb)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 80) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 81) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 82) * Step 3: Process LISTEN state
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 83) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 84) * (* Generate a new socket and switch to that socket *)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 85) * Set S := new socket for this port pair
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 86) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 87) struct sock *newsk = inet_csk_clone_lock(sk, req, GFP_ATOMIC);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 88)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 89) if (newsk != NULL) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 90) struct dccp_request_sock *dreq = dccp_rsk(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 91) struct inet_connection_sock *newicsk = inet_csk(newsk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 92) struct dccp_sock *newdp = dccp_sk(newsk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 93)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 94) newdp->dccps_role = DCCP_ROLE_SERVER;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 95) newdp->dccps_hc_rx_ackvec = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 96) newdp->dccps_service_list = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 97) newdp->dccps_hc_rx_ccid = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 98) newdp->dccps_hc_tx_ccid = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 99) newdp->dccps_service = dreq->dreq_service;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 100) newdp->dccps_timestamp_echo = dreq->dreq_timestamp_echo;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 101) newdp->dccps_timestamp_time = dreq->dreq_timestamp_time;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 102) newicsk->icsk_rto = DCCP_TIMEOUT_INIT;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 103)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 104) INIT_LIST_HEAD(&newdp->dccps_featneg);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 105) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 106) * Step 3: Process LISTEN state
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 107) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 108) * Choose S.ISS (initial seqno) or set from Init Cookies
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 109) * Initialize S.GAR := S.ISS
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 110) * Set S.ISR, S.GSR from packet (or Init Cookies)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 111) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 112) * Setting AWL/AWH and SWL/SWH happens as part of the feature
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 113) * activation below, as these windows all depend on the local
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 114) * and remote Sequence Window feature values (7.5.2).
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 115) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 116) newdp->dccps_iss = dreq->dreq_iss;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 117) newdp->dccps_gss = dreq->dreq_gss;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 118) newdp->dccps_gar = newdp->dccps_iss;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 119) newdp->dccps_isr = dreq->dreq_isr;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 120) newdp->dccps_gsr = dreq->dreq_gsr;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 121)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 122) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 123) * Activate features: initialise CCIDs, sequence windows etc.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 124) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 125) if (dccp_feat_activate_values(newsk, &dreq->dreq_featneg)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 126) sk_free_unlock_clone(newsk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 127) return NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 128) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 129) dccp_init_xmit_timers(newsk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 130)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 131) __DCCP_INC_STATS(DCCP_MIB_PASSIVEOPENS);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 132) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 133) return newsk;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 134) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 135)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 136) EXPORT_SYMBOL_GPL(dccp_create_openreq_child);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 137)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 138) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 139) * Process an incoming packet for RESPOND sockets represented
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 140) * as an request_sock.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 141) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 142) struct sock *dccp_check_req(struct sock *sk, struct sk_buff *skb,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 143) struct request_sock *req)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 144) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 145) struct sock *child = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 146) struct dccp_request_sock *dreq = dccp_rsk(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 147) bool own_req;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 148)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 149) /* TCP/DCCP listeners became lockless.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 150) * DCCP stores complex state in its request_sock, so we need
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 151) * a protection for them, now this code runs without being protected
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 152) * by the parent (listener) lock.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 153) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 154) spin_lock_bh(&dreq->dreq_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 155)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 156) /* Check for retransmitted REQUEST */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 157) if (dccp_hdr(skb)->dccph_type == DCCP_PKT_REQUEST) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 158)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 159) if (after48(DCCP_SKB_CB(skb)->dccpd_seq, dreq->dreq_gsr)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 160) dccp_pr_debug("Retransmitted REQUEST\n");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 161) dreq->dreq_gsr = DCCP_SKB_CB(skb)->dccpd_seq;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 162) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 163) * Send another RESPONSE packet
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 164) * To protect against Request floods, increment retrans
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 165) * counter (backoff, monitored by dccp_response_timer).
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 166) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 167) inet_rtx_syn_ack(sk, req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 168) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 169) /* Network Duplicate, discard packet */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 170) goto out;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 171) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 172)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 173) DCCP_SKB_CB(skb)->dccpd_reset_code = DCCP_RESET_CODE_PACKET_ERROR;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 174)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 175) if (dccp_hdr(skb)->dccph_type != DCCP_PKT_ACK &&
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 176) dccp_hdr(skb)->dccph_type != DCCP_PKT_DATAACK)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 177) goto drop;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 178)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 179) /* Invalid ACK */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 180) if (!between48(DCCP_SKB_CB(skb)->dccpd_ack_seq,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 181) dreq->dreq_iss, dreq->dreq_gss)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 182) dccp_pr_debug("Invalid ACK number: ack_seq=%llu, "
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 183) "dreq_iss=%llu, dreq_gss=%llu\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 184) (unsigned long long)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 185) DCCP_SKB_CB(skb)->dccpd_ack_seq,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 186) (unsigned long long) dreq->dreq_iss,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 187) (unsigned long long) dreq->dreq_gss);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 188) goto drop;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 189) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 190)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 191) if (dccp_parse_options(sk, dreq, skb))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 192) goto drop;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 193)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 194) child = inet_csk(sk)->icsk_af_ops->syn_recv_sock(sk, skb, req, NULL,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 195) req, &own_req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 196) if (child) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 197) child = inet_csk_complete_hashdance(sk, child, req, own_req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 198) goto out;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 199) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 200)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 201) DCCP_SKB_CB(skb)->dccpd_reset_code = DCCP_RESET_CODE_TOO_BUSY;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 202) drop:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 203) if (dccp_hdr(skb)->dccph_type != DCCP_PKT_RESET)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 204) req->rsk_ops->send_reset(sk, skb);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 205)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 206) inet_csk_reqsk_queue_drop(sk, req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 207) out:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 208) spin_unlock_bh(&dreq->dreq_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 209) return child;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 210) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 211)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 212) EXPORT_SYMBOL_GPL(dccp_check_req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 213)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 214) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 215) * Queue segment on the new socket if the new socket is active,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 216) * otherwise we just shortcircuit this and continue with
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 217) * the new socket.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 218) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 219) int dccp_child_process(struct sock *parent, struct sock *child,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 220) struct sk_buff *skb)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 221) __releases(child)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 222) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 223) int ret = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 224) const int state = child->sk_state;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 225)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 226) if (!sock_owned_by_user(child)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 227) ret = dccp_rcv_state_process(child, skb, dccp_hdr(skb),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 228) skb->len);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 229)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 230) /* Wakeup parent, send SIGIO */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 231) if (state == DCCP_RESPOND && child->sk_state != state)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 232) parent->sk_data_ready(parent);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 233) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 234) /* Alas, it is possible again, because we do lookup
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 235) * in main socket hash table and lock on listening
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 236) * socket does not protect us more.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 237) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 238) __sk_add_backlog(child, skb);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 239) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 240)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 241) bh_unlock_sock(child);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 242) sock_put(child);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 243) return ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 244) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 245)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 246) EXPORT_SYMBOL_GPL(dccp_child_process);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 247)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 248) void dccp_reqsk_send_ack(const struct sock *sk, struct sk_buff *skb,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 249) struct request_sock *rsk)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 250) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 251) DCCP_BUG("DCCP-ACK packets are never sent in LISTEN/RESPOND state");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 252) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 253)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 254) EXPORT_SYMBOL_GPL(dccp_reqsk_send_ack);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 255)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 256) int dccp_reqsk_init(struct request_sock *req,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 257) struct dccp_sock const *dp, struct sk_buff const *skb)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 258) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 259) struct dccp_request_sock *dreq = dccp_rsk(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 260)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 261) spin_lock_init(&dreq->dreq_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 262) inet_rsk(req)->ir_rmt_port = dccp_hdr(skb)->dccph_sport;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 263) inet_rsk(req)->ir_num = ntohs(dccp_hdr(skb)->dccph_dport);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 264) inet_rsk(req)->acked = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 265) dreq->dreq_timestamp_echo = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 266)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 267) /* inherit feature negotiation options from listening socket */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 268) return dccp_feat_clone_list(&dp->dccps_featneg, &dreq->dreq_featneg);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 269) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 270)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 271) EXPORT_SYMBOL_GPL(dccp_reqsk_init);
Orange Pi5 kernel
Deprecated Linux kernel 5.10.110 for OrangePi 5/5B/5+ boards
3 Commits
0 Branches
0 Tags