Author: tuexen
Date: Sun Aug  3 18:12:55 2014
New Revision: 269481
URL: http://svnweb.freebsd.org/changeset/base/269481

Log:
  Add support for the SCTP_PKTDROP_SUPPORTED socket option and
  the corresponding sysctl variable.
  The default is off, since the specification is not an RFC yet.
  
  MFC after: 1 week

Modified:
  head/lib/libc/net/sctp_sys_calls.c
  head/sys/netinet/sctp.h
  head/sys/netinet/sctp_input.c
  head/sys/netinet/sctp_output.c
  head/sys/netinet/sctp_pcb.c
  head/sys/netinet/sctp_pcb.h
  head/sys/netinet/sctp_peeloff.c
  head/sys/netinet/sctp_structs.h
  head/sys/netinet/sctp_sysctl.c
  head/sys/netinet/sctp_sysctl.h
  head/sys/netinet/sctp_usrreq.c
  head/sys/netinet/sctputil.c

Modified: head/lib/libc/net/sctp_sys_calls.c
==============================================================================
--- head/lib/libc/net/sctp_sys_calls.c  Sun Aug  3 18:03:00 2014        
(r269480)
+++ head/lib/libc/net/sctp_sys_calls.c  Sun Aug  3 18:12:55 2014        
(r269481)
@@ -359,6 +359,9 @@ sctp_opt_info(int sd, sctp_assoc_t id, i
        case SCTP_NRSACK_SUPPORTED:
                ((struct sctp_assoc_value *)arg)->assoc_id = id;
                break;
+       case SCTP_PKTDROP_SUPPORTED:
+               ((struct sctp_assoc_value *)arg)->assoc_id = id;
+               break;
        case SCTP_MAX_BURST:
                ((struct sctp_assoc_value *)arg)->assoc_id = id;
                break;

Modified: head/sys/netinet/sctp.h
==============================================================================
--- head/sys/netinet/sctp.h     Sun Aug  3 18:03:00 2014        (r269480)
+++ head/sys/netinet/sctp.h     Sun Aug  3 18:12:55 2014        (r269481)
@@ -124,6 +124,7 @@ struct sctp_paramhdr {
 #define SCTP_ECN_SUPPORTED              0x00000025
 #define SCTP_PR_SUPPORTED               0x00000026
 #define SCTP_NRSACK_SUPPORTED           0x00000027
+#define SCTP_PKTDROP_SUPPORTED          0x00000028
 
 /*
  * read-only options

Modified: head/sys/netinet/sctp_input.c
==============================================================================
--- head/sys/netinet/sctp_input.c       Sun Aug  3 18:03:00 2014        
(r269480)
+++ head/sys/netinet/sctp_input.c       Sun Aug  3 18:12:55 2014        
(r269481)
@@ -2788,6 +2788,7 @@ sctp_handle_cookie_echo(struct mbuf *m, 
                        inp->ecn_supported = (*inp_p)->ecn_supported;
                        inp->prsctp_supported = (*inp_p)->prsctp_supported;
                        inp->nrsack_supported = (*inp_p)->nrsack_supported;
+                       inp->pktdrop_supported = (*inp_p)->pktdrop_supported;
                        inp->partial_delivery_point = 
(*inp_p)->partial_delivery_point;
                        inp->sctp_context = (*inp_p)->sctp_context;
                        inp->local_strreset_support = 
(*inp_p)->local_strreset_support;

Modified: head/sys/netinet/sctp_output.c
==============================================================================
--- head/sys/netinet/sctp_output.c      Sun Aug  3 18:03:00 2014        
(r269480)
+++ head/sys/netinet/sctp_output.c      Sun Aug  3 18:12:55 2014        
(r269481)
@@ -4817,7 +4817,9 @@ sctp_send_initiate(struct sctp_inpcb *in
        if (stcb->asoc.prsctp_supported == 1) {
                pr_supported->chunk_types[num_ext++] = SCTP_FORWARD_CUM_TSN;
        }
-       pr_supported->chunk_types[num_ext++] = SCTP_PACKET_DROPPED;
+       if (stcb->asoc.pktdrop_supported == 1) {
+               pr_supported->chunk_types[num_ext++] = SCTP_PACKET_DROPPED;
+       }
        pr_supported->chunk_types[num_ext++] = SCTP_STREAM_RESET;
        if (!SCTP_BASE_SYSCTL(sctp_auth_disable)) {
                pr_supported->chunk_types[num_ext++] = SCTP_AUTHENTICATION;
@@ -5920,7 +5922,10 @@ do_a_abort:
            ((asoc == NULL) && (inp->prsctp_supported == 1))) {
                pr_supported->chunk_types[num_ext++] = SCTP_FORWARD_CUM_TSN;
        }
-       pr_supported->chunk_types[num_ext++] = SCTP_PACKET_DROPPED;
+       if (((asoc != NULL) && (asoc->pktdrop_supported == 1)) ||
+           ((asoc == NULL) && (inp->pktdrop_supported == 1))) {
+               pr_supported->chunk_types[num_ext++] = SCTP_PACKET_DROPPED;
+       }
        pr_supported->chunk_types[num_ext++] = SCTP_STREAM_RESET;
        if (!SCTP_BASE_SYSCTL(sctp_auth_disable)) {
                pr_supported->chunk_types[num_ext++] = SCTP_AUTHENTICATION;
@@ -11399,7 +11404,7 @@ sctp_send_packet_dropped(struct sctp_tcb
        }
        asoc = &stcb->asoc;
        SCTP_TCB_LOCK_ASSERT(stcb);
-       if (asoc->peer_supports_pktdrop == 0) {
+       if (asoc->pktdrop_supported == 0) {
                /*-
                 * peer must declare support before I send one.
                 */

Modified: head/sys/netinet/sctp_pcb.c
==============================================================================
--- head/sys/netinet/sctp_pcb.c Sun Aug  3 18:03:00 2014        (r269480)
+++ head/sys/netinet/sctp_pcb.c Sun Aug  3 18:12:55 2014        (r269481)
@@ -2486,6 +2486,7 @@ sctp_inpcb_alloc(struct socket *so, uint
        inp->ecn_supported = (uint8_t) SCTP_BASE_SYSCTL(sctp_ecn_enable);
        inp->prsctp_supported = (uint8_t) SCTP_BASE_SYSCTL(sctp_pr_enable);
        inp->nrsack_supported = (uint8_t) SCTP_BASE_SYSCTL(sctp_nrsack_enable);
+       inp->pktdrop_supported = (uint8_t) 
SCTP_BASE_SYSCTL(sctp_pktdrop_enable);
        /* init the small hash table we use to track asocid <-> tcb */
        inp->sctp_asocidhash = SCTP_HASH_INIT(SCTP_STACK_VTAG_HASH_SIZE, 
&inp->hashasocidmark);
        if (inp->sctp_asocidhash == NULL) {
@@ -6086,6 +6087,7 @@ sctp_load_addresses_from_init(struct sct
        uint8_t ecn_supported;
        uint8_t prsctp_supported;
        uint8_t nrsack_supported;
+       uint8_t pktdrop_supported;
 
 #ifdef INET
        struct sockaddr_in sin;
@@ -6118,6 +6120,7 @@ sctp_load_addresses_from_init(struct sct
        ecn_supported = 0;
        prsctp_supported = 0;
        nrsack_supported = 0;
+       pktdrop_supported = 0;
        TAILQ_FOREACH(net, &stcb->asoc.nets, sctp_next) {
                /* mark all addresses that we have currently on the list */
                net->dest_state |= SCTP_ADDR_NOT_IN_ASSOC;
@@ -6455,7 +6458,6 @@ sctp_load_addresses_from_init(struct sct
                                return (-25);
                        }
                        stcb->asoc.peer_supports_asconf = 0;
-                       stcb->asoc.peer_supports_pktdrop = 0;
                        stcb->asoc.peer_supports_strreset = 0;
                        stcb->asoc.peer_supports_auth = 0;
                        pr_supported = (struct sctp_supported_chunk_types_param 
*)phdr;
@@ -6470,7 +6472,7 @@ sctp_load_addresses_from_init(struct sct
                                        prsctp_supported = 1;
                                        break;
                                case SCTP_PACKET_DROPPED:
-                                       stcb->asoc.peer_supports_pktdrop = 1;
+                                       pktdrop_supported = 1;
                                        break;
                                case SCTP_NR_SELECTIVE_ACK:
                                        nrsack_supported = 1;
@@ -6619,6 +6621,7 @@ next_param:
        stcb->asoc.ecn_supported &= ecn_supported;
        stcb->asoc.prsctp_supported &= prsctp_supported;
        stcb->asoc.nrsack_supported &= nrsack_supported;
+       stcb->asoc.pktdrop_supported &= pktdrop_supported;
        /* validate authentication required parameters */
        if (got_random && got_hmacs) {
                stcb->asoc.peer_supports_auth = 1;

Modified: head/sys/netinet/sctp_pcb.h
==============================================================================
--- head/sys/netinet/sctp_pcb.h Sun Aug  3 18:03:00 2014        (r269480)
+++ head/sys/netinet/sctp_pcb.h Sun Aug  3 18:12:55 2014        (r269481)
@@ -409,6 +409,7 @@ struct sctp_inpcb {
        uint8_t ecn_supported;
        uint8_t prsctp_supported;
        uint8_t nrsack_supported;
+       uint8_t pktdrop_supported;
        struct sctp_nonpad_sndrcvinfo def_send;
        /*-
         * These three are here for the sosend_dgram

Modified: head/sys/netinet/sctp_peeloff.c
==============================================================================
--- head/sys/netinet/sctp_peeloff.c     Sun Aug  3 18:03:00 2014        
(r269480)
+++ head/sys/netinet/sctp_peeloff.c     Sun Aug  3 18:12:55 2014        
(r269481)
@@ -121,6 +121,7 @@ sctp_do_peeloff(struct socket *head, str
        n_inp->ecn_supported = inp->ecn_supported;
        n_inp->prsctp_supported = inp->prsctp_supported;
        n_inp->nrsack_supported = inp->nrsack_supported;
+       n_inp->pktdrop_supported = inp->pktdrop_supported;
        n_inp->partial_delivery_point = inp->partial_delivery_point;
        n_inp->sctp_context = inp->sctp_context;
        n_inp->local_strreset_support = inp->local_strreset_support;

Modified: head/sys/netinet/sctp_structs.h
==============================================================================
--- head/sys/netinet/sctp_structs.h     Sun Aug  3 18:03:00 2014        
(r269480)
+++ head/sys/netinet/sctp_structs.h     Sun Aug  3 18:12:55 2014        
(r269481)
@@ -1154,6 +1154,7 @@ struct sctp_association {
        uint8_t ecn_supported;
        uint8_t prsctp_supported;
        uint8_t nrsack_supported;
+       uint8_t pktdrop_supported;
 
        /* Did the peer make the stream config (add out) request */
        uint8_t peer_req_out;
@@ -1167,11 +1168,6 @@ struct sctp_association {
        uint8_t local_strreset_support;
 
        uint8_t peer_supports_nat;
-       /*
-        * packet drop's are supported by the peer, we don't really care
-        * about this but we bookkeep it anyway.
-        */
-       uint8_t peer_supports_pktdrop;
 
        struct sctp_scoping scope;
        /* flags to handle send alternate net tracking */

Modified: head/sys/netinet/sctp_sysctl.c
==============================================================================
--- head/sys/netinet/sctp_sysctl.c      Sun Aug  3 18:03:00 2014        
(r269480)
+++ head/sys/netinet/sctp_sysctl.c      Sun Aug  3 18:12:55 2014        
(r269481)
@@ -56,6 +56,7 @@ sctp_init_sysctls()
        SCTP_BASE_SYSCTL(sctp_ecn_enable) = SCTPCTL_ECN_ENABLE_DEFAULT;
        SCTP_BASE_SYSCTL(sctp_pr_enable) = SCTPCTL_PR_ENABLE_DEFAULT;
        SCTP_BASE_SYSCTL(sctp_nrsack_enable) = SCTPCTL_NRSACK_ENABLE_DEFAULT;
+       SCTP_BASE_SYSCTL(sctp_pktdrop_enable) = SCTPCTL_PKTDROP_ENABLE_DEFAULT;
        SCTP_BASE_SYSCTL(sctp_strict_sacks) = SCTPCTL_STRICT_SACKS_DEFAULT;
        SCTP_BASE_SYSCTL(sctp_peer_chunk_oh) = SCTPCTL_PEER_CHKOH_DEFAULT;
        SCTP_BASE_SYSCTL(sctp_max_burst_default) = SCTPCTL_MAXBURST_DEFAULT;
@@ -602,6 +603,7 @@ sysctl_sctp_check(SYSCTL_HANDLER_ARGS)
                RANGECHK(SCTP_BASE_SYSCTL(sctp_ecn_enable), 
SCTPCTL_ECN_ENABLE_MIN, SCTPCTL_ECN_ENABLE_MAX);
                RANGECHK(SCTP_BASE_SYSCTL(sctp_pr_enable), 
SCTPCTL_PR_ENABLE_MIN, SCTPCTL_PR_ENABLE_MAX);
                RANGECHK(SCTP_BASE_SYSCTL(sctp_nrsack_enable), 
SCTPCTL_NRSACK_ENABLE_MIN, SCTPCTL_NRSACK_ENABLE_MAX);
+               RANGECHK(SCTP_BASE_SYSCTL(sctp_pktdrop_enable), 
SCTPCTL_PKTDROP_ENABLE_MIN, SCTPCTL_PKTDROP_ENABLE_MAX);
                RANGECHK(SCTP_BASE_SYSCTL(sctp_strict_sacks), 
SCTPCTL_STRICT_SACKS_MIN, SCTPCTL_STRICT_SACKS_MAX);
                RANGECHK(SCTP_BASE_SYSCTL(sctp_peer_chunk_oh), 
SCTPCTL_PEER_CHKOH_MIN, SCTPCTL_PEER_CHKOH_MAX);
                RANGECHK(SCTP_BASE_SYSCTL(sctp_max_burst_default), 
SCTPCTL_MAXBURST_MIN, SCTPCTL_MAXBURST_MAX);
@@ -869,6 +871,10 @@ SYSCTL_VNET_PROC(_net_inet_sctp, OID_AUT
     &SCTP_BASE_SYSCTL(sctp_nrsack_enable), 0, sysctl_sctp_check, "IU",
     SCTPCTL_NRSACK_ENABLE_DESC);
 
+SYSCTL_VNET_PROC(_net_inet_sctp, OID_AUTO, pktdrop_enable, CTLTYPE_UINT | 
CTLFLAG_RW,
+    &SCTP_BASE_SYSCTL(sctp_pktdrop_enable), 0, sysctl_sctp_check, "IU",
+    SCTPCTL_PKTDROP_ENABLE_DESC);
+
 SYSCTL_VNET_PROC(_net_inet_sctp, OID_AUTO, strict_sacks, CTLTYPE_UINT | 
CTLFLAG_RW,
     &SCTP_BASE_SYSCTL(sctp_strict_sacks), 0, sysctl_sctp_check, "IU",
     SCTPCTL_STRICT_SACKS_DESC);

Modified: head/sys/netinet/sctp_sysctl.h
==============================================================================
--- head/sys/netinet/sctp_sysctl.h      Sun Aug  3 18:03:00 2014        
(r269480)
+++ head/sys/netinet/sctp_sysctl.h      Sun Aug  3 18:12:55 2014        
(r269481)
@@ -47,6 +47,7 @@ struct sctp_sysctl {
        uint32_t sctp_ecn_enable;
        uint32_t sctp_pr_enable;
        uint32_t sctp_nrsack_enable;
+       uint32_t sctp_pktdrop_enable;
        uint32_t sctp_fr_max_burst_default;
        uint32_t sctp_strict_sacks;
        uint32_t sctp_peer_chunk_oh;
@@ -166,6 +167,11 @@ struct sctp_sysctl {
 #define SCTPCTL_NRSACK_ENABLE_MAX      1
 #define SCTPCTL_NRSACK_ENABLE_DEFAULT  0
 
+/* pktdrop_enable: Enable SCTP Packet Drop Reports */
+#define SCTPCTL_PKTDROP_ENABLE_DESC    "Enable SCTP PKTDROP"
+#define SCTPCTL_PKTDROP_ENABLE_MIN     0
+#define SCTPCTL_PKTDROP_ENABLE_MAX     1
+#define SCTPCTL_PKTDROP_ENABLE_DEFAULT 0
 
 /* strict_sacks: Enable SCTP Strict SACK checking */
 #define SCTPCTL_STRICT_SACKS_DESC      "Enable SCTP Strict SACK checking"

Modified: head/sys/netinet/sctp_usrreq.c
==============================================================================
--- head/sys/netinet/sctp_usrreq.c      Sun Aug  3 18:03:00 2014        
(r269480)
+++ head/sys/netinet/sctp_usrreq.c      Sun Aug  3 18:12:55 2014        
(r269481)
@@ -3375,6 +3375,33 @@ flags_out:
                        }
                        break;
                }
+       case SCTP_PKTDROP_SUPPORTED:
+               {
+                       struct sctp_assoc_value *av;
+
+                       SCTP_CHECK_AND_CAST(av, optval, struct 
sctp_assoc_value, *optsize);
+                       SCTP_FIND_STCB(inp, stcb, av->assoc_id);
+
+                       if (stcb) {
+                               av->assoc_value = stcb->asoc.pktdrop_supported;
+                               SCTP_TCB_UNLOCK(stcb);
+                       } else {
+                               if ((inp->sctp_flags & SCTP_PCB_FLAGS_TCPTYPE) 
||
+                                   (inp->sctp_flags & 
SCTP_PCB_FLAGS_IN_TCPPOOL) ||
+                                   (av->assoc_id == SCTP_FUTURE_ASSOC)) {
+                                       SCTP_INP_RLOCK(inp);
+                                       av->assoc_value = 
inp->pktdrop_supported;
+                                       SCTP_INP_RUNLOCK(inp);
+                               } else {
+                                       SCTP_LTRACE_ERR_RET(inp, NULL, NULL, 
SCTP_FROM_SCTP_USRREQ, EINVAL);
+                                       error = EINVAL;
+                               }
+                       }
+                       if (error == 0) {
+                               *optsize = sizeof(struct sctp_assoc_value);
+                       }
+                       break;
+               }
        case SCTP_ENABLE_STREAM_RESET:
                {
                        struct sctp_assoc_value *av;
@@ -6025,6 +6052,35 @@ sctp_setopt(struct socket *so, int optna
                        }
                        break;
                }
+       case SCTP_PKTDROP_SUPPORTED:
+               {
+                       struct sctp_assoc_value *av;
+
+                       SCTP_CHECK_AND_CAST(av, optval, struct 
sctp_assoc_value, optsize);
+                       SCTP_FIND_STCB(inp, stcb, av->assoc_id);
+
+                       if (stcb) {
+                               SCTP_LTRACE_ERR_RET(inp, NULL, NULL, 
SCTP_FROM_SCTP_USRREQ, EINVAL);
+                               error = EINVAL;
+                               SCTP_TCB_UNLOCK(stcb);
+                       } else {
+                               if ((inp->sctp_flags & SCTP_PCB_FLAGS_TCPTYPE) 
||
+                                   (inp->sctp_flags & 
SCTP_PCB_FLAGS_IN_TCPPOOL) ||
+                                   (av->assoc_id == SCTP_FUTURE_ASSOC)) {
+                                       SCTP_INP_WLOCK(inp);
+                                       if (av->assoc_value == 0) {
+                                               inp->pktdrop_supported = 0;
+                                       } else {
+                                               inp->pktdrop_supported = 1;
+                                       }
+                                       SCTP_INP_WUNLOCK(inp);
+                               } else {
+                                       SCTP_LTRACE_ERR_RET(inp, NULL, NULL, 
SCTP_FROM_SCTP_USRREQ, EINVAL);
+                                       error = EINVAL;
+                               }
+                       }
+                       break;
+               }
        default:
                SCTP_LTRACE_ERR_RET(inp, NULL, NULL, SCTP_FROM_SCTP_USRREQ, 
ENOPROTOOPT);
                error = ENOPROTOOPT;

Modified: head/sys/netinet/sctputil.c
==============================================================================
--- head/sys/netinet/sctputil.c Sun Aug  3 18:03:00 2014        (r269480)
+++ head/sys/netinet/sctputil.c Sun Aug  3 18:12:55 2014        (r269481)
@@ -907,6 +907,7 @@ sctp_init_asoc(struct sctp_inpcb *inp, s
        asoc->ecn_supported = inp->ecn_supported;
        asoc->prsctp_supported = inp->prsctp_supported;
        asoc->nrsack_supported = inp->nrsack_supported;
+       asoc->pktdrop_supported = inp->pktdrop_supported;
        asoc->sctp_cmt_pf = (uint8_t) 0;
        asoc->sctp_frag_point = inp->sctp_frag_point;
        asoc->sctp_features = inp->sctp_features;
@@ -952,7 +953,6 @@ sctp_init_asoc(struct sctp_inpcb *inp, s
            sctp_select_initial_TSN(&inp->sctp_ep);
        asoc->asconf_seq_out_acked = asoc->asconf_seq_out - 1;
        /* we are optimisitic here */
-       asoc->peer_supports_pktdrop = 1;
        asoc->peer_supports_nat = 0;
        asoc->sent_queue_retran_cnt = 0;
 
_______________________________________________
svn-src-all@freebsd.org mailing list
http://lists.freebsd.org/mailman/listinfo/svn-src-all
To unsubscribe, send any mail to "svn-src-all-unsubscr...@freebsd.org"

Reply via email to