dccp_usrreq.c revision 1.2.2.6
1 1.2.2.2 skrll /* $KAME: dccp_usrreq.c,v 1.67 2005/11/03 16:05:04 nishida Exp $ */ 2 1.2.2.6 skrll /* $NetBSD: dccp_usrreq.c,v 1.2.2.6 2017/02/05 13:40:59 skrll Exp $ */ 3 1.2.2.2 skrll 4 1.2.2.2 skrll /* 5 1.2.2.3 skrll * Copyright (c) 2003 Joacim Hggmark, Magnus Erixzon, Nils-Erik Mattsson 6 1.2.2.2 skrll * All rights reserved. 7 1.2.2.2 skrll * 8 1.2.2.2 skrll * Redistribution and use in source and binary forms, with or without 9 1.2.2.2 skrll * modification, are permitted provided that the following conditions 10 1.2.2.2 skrll * are met: 11 1.2.2.2 skrll * 12 1.2.2.2 skrll * 1. Redistributions of source code must retain the above copyright 13 1.2.2.2 skrll * notice, this list of conditions and the following disclaimer. 14 1.2.2.2 skrll * 2. Redistributions in binary form must reproduce the above copyright 15 1.2.2.2 skrll * notice, this list of conditions and the following disclaimer in the 16 1.2.2.2 skrll * documentation and/or other materials provided with the distribution. 17 1.2.2.2 skrll * 3. The name of the author may not be used to endorse or promote products 18 1.2.2.2 skrll * derived from this software without specific prior written permission. 19 1.2.2.2 skrll * 20 1.2.2.2 skrll * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR 21 1.2.2.2 skrll * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES 22 1.2.2.2 skrll * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. 23 1.2.2.2 skrll * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, 24 1.2.2.2 skrll * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT 25 1.2.2.2 skrll * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, 26 1.2.2.2 skrll * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 27 1.2.2.2 skrll * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 28 1.2.2.2 skrll * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF 29 1.2.2.2 skrll * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 30 1.2.2.2 skrll * 31 1.2.2.2 skrll * Id: dccp_usrreq.c,v 1.47 2003/07/31 11:23:08 joahag-9 Exp 32 1.2.2.2 skrll */ 33 1.2.2.2 skrll 34 1.2.2.2 skrll /* 35 1.2.2.2 skrll * Copyright (c) 1982, 1986, 1988, 1990, 1993, 1995 36 1.2.2.2 skrll * The Regents of the University of California. All rights reserved. 37 1.2.2.2 skrll * 38 1.2.2.2 skrll * Redistribution and use in source and binary forms, with or without 39 1.2.2.2 skrll * modification, are permitted provided that the following conditions 40 1.2.2.2 skrll * are met: 41 1.2.2.2 skrll * 1. Redistributions of source code must retain the above copyright 42 1.2.2.2 skrll * notice, this list of conditions and the following disclaimer. 43 1.2.2.2 skrll * 2. Redistributions in binary form must reproduce the above copyright 44 1.2.2.2 skrll * notice, this list of conditions and the following disclaimer in the 45 1.2.2.2 skrll * documentation and/or other materials provided with the distribution. 46 1.2.2.2 skrll * 3. All advertising materials mentioning features or use of this software 47 1.2.2.2 skrll * must display the following acknowledgement: 48 1.2.2.2 skrll * This product includes software developed by the University of 49 1.2.2.2 skrll * California, Berkeley and its contributors. 50 1.2.2.2 skrll * 4. Neither the name of the University nor the names of its contributors 51 1.2.2.2 skrll * may be used to endorse or promote products derived from this software 52 1.2.2.2 skrll * without specific prior written permission. 53 1.2.2.2 skrll * 54 1.2.2.2 skrll * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 55 1.2.2.2 skrll * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 56 1.2.2.2 skrll * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 57 1.2.2.2 skrll * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 58 1.2.2.2 skrll * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 59 1.2.2.2 skrll * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 60 1.2.2.2 skrll * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 61 1.2.2.2 skrll * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 62 1.2.2.2 skrll * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 63 1.2.2.2 skrll * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 64 1.2.2.2 skrll * SUCH DAMAGE. 65 1.2.2.2 skrll * 66 1.2.2.2 skrll * @(#)udp_usrreq.c 8.6 (Berkeley) 5/23/95 67 1.2.2.2 skrll */ 68 1.2.2.2 skrll 69 1.2.2.2 skrll #include <sys/cdefs.h> 70 1.2.2.6 skrll __KERNEL_RCSID(0, "$NetBSD: dccp_usrreq.c,v 1.2.2.6 2017/02/05 13:40:59 skrll Exp $"); 71 1.2.2.2 skrll 72 1.2.2.4 skrll #ifdef _KERNEL_OPT 73 1.2.2.2 skrll #include "opt_inet.h" 74 1.2.2.2 skrll #include "opt_dccp.h" 75 1.2.2.4 skrll #endif 76 1.2.2.2 skrll 77 1.2.2.2 skrll #include <sys/param.h> 78 1.2.2.2 skrll #include <sys/systm.h> 79 1.2.2.2 skrll #include <sys/domain.h> 80 1.2.2.2 skrll #include <sys/kernel.h> 81 1.2.2.2 skrll #include <sys/pool.h> 82 1.2.2.2 skrll #include <sys/lock.h> 83 1.2.2.2 skrll #include <sys/malloc.h> 84 1.2.2.2 skrll #include <sys/mbuf.h> 85 1.2.2.2 skrll #include <sys/proc.h> 86 1.2.2.2 skrll #include <sys/protosw.h> 87 1.2.2.2 skrll #include <sys/signalvar.h> 88 1.2.2.2 skrll #include <sys/socket.h> 89 1.2.2.2 skrll #include <sys/socketvar.h> 90 1.2.2.2 skrll #include <sys/mutex.h> 91 1.2.2.2 skrll #include <sys/sysctl.h> 92 1.2.2.2 skrll #include <sys/syslog.h> 93 1.2.2.2 skrll #include <sys/queue.h> 94 1.2.2.2 skrll 95 1.2.2.2 skrll #include <net/if.h> 96 1.2.2.2 skrll 97 1.2.2.2 skrll #include <netinet/in.h> 98 1.2.2.2 skrll #include <netinet/in_systm.h> 99 1.2.2.2 skrll #include <netinet/ip.h> 100 1.2.2.2 skrll #include <netinet/in_pcb.h> 101 1.2.2.2 skrll #include <netinet/in_var.h> 102 1.2.2.2 skrll #ifdef INET6 103 1.2.2.2 skrll #include <netinet/ip6.h> 104 1.2.2.2 skrll #endif 105 1.2.2.2 skrll #include <netinet/ip_icmp.h> 106 1.2.2.2 skrll #include <netinet/icmp_var.h> 107 1.2.2.2 skrll #include <netinet/ip_var.h> 108 1.2.2.2 skrll #ifdef INET6 109 1.2.2.2 skrll #include <netinet6/in6_pcb.h> 110 1.2.2.2 skrll #include <netinet6/ip6_var.h> 111 1.2.2.2 skrll #include <netinet6/dccp6_var.h> 112 1.2.2.2 skrll #endif 113 1.2.2.2 skrll #include <netinet/dccp.h> 114 1.2.2.2 skrll #include <netinet/dccp_var.h> 115 1.2.2.2 skrll #include <netinet/dccp_cc_sw.h> 116 1.2.2.2 skrll 117 1.2.2.2 skrll #define DEFAULT_CCID 2 118 1.2.2.2 skrll 119 1.2.2.2 skrll #define INP_INFO_LOCK_INIT(x,y) 120 1.2.2.2 skrll #define INP_INFO_WLOCK(x) 121 1.2.2.2 skrll #define INP_INFO_WUNLOCK(x) 122 1.2.2.2 skrll #define INP_INFO_RLOCK(x) 123 1.2.2.2 skrll #define INP_INFO_RUNLOCK(x) 124 1.2.2.2 skrll #define INP_LOCK(x) 125 1.2.2.2 skrll #define IN6P_LOCK(x) 126 1.2.2.2 skrll #define INP_UNLOCK(x) 127 1.2.2.2 skrll #define IN6P_UNLOCK(x) 128 1.2.2.2 skrll 129 1.2.2.2 skrll /* Congestion control switch table */ 130 1.2.2.2 skrll extern struct dccp_cc_sw cc_sw[]; 131 1.2.2.2 skrll 132 1.2.2.2 skrll int dccp_log_in_vain = 1; 133 1.2.2.2 skrll int dccp_do_feature_nego = 1; 134 1.2.2.2 skrll 135 1.2.2.2 skrll struct inpcbhead dccpb; /* from dccp_var.h */ 136 1.2.2.2 skrll #ifdef __FreeBSD__ 137 1.2.2.2 skrll struct inpcbinfo dccpbinfo; 138 1.2.2.2 skrll #else 139 1.2.2.2 skrll struct inpcbtable dccpbtable; 140 1.2.2.2 skrll #endif 141 1.2.2.2 skrll 142 1.2.2.2 skrll #ifndef DCCPBHASHSIZE 143 1.2.2.2 skrll #define DCCPBHASHSIZE 16 144 1.2.2.2 skrll #endif 145 1.2.2.2 skrll 146 1.2.2.2 skrll struct pool dccpcb_pool; 147 1.2.2.2 skrll 148 1.2.2.2 skrll u_long dccp_sendspace = 32768; 149 1.2.2.2 skrll u_long dccp_recvspace = 65536; 150 1.2.2.2 skrll 151 1.2.2.2 skrll struct dccpstat dccpstat; /* from dccp_var.h */ 152 1.2.2.2 skrll 153 1.2.2.2 skrll static struct dccpcb * dccp_close(struct dccpcb *); 154 1.2.2.2 skrll static int dccp_disconnect2(struct dccpcb *); 155 1.2.2.2 skrll int dccp_get_option(char *, int, int, char *,int); 156 1.2.2.2 skrll void dccp_parse_options(struct dccpcb *, char *, int); 157 1.2.2.2 skrll int dccp_remove_feature(struct dccpcb *, u_int8_t, u_int8_t); 158 1.2.2.2 skrll int dccp_add_feature_option(struct dccpcb *, u_int8_t, u_int8_t, char *, u_int8_t); 159 1.2.2.2 skrll void dccp_feature_neg(struct dccpcb *, u_int8_t, u_int8_t, u_int8_t, char *); 160 1.2.2.2 skrll void dccp_close_t(void *); 161 1.2.2.2 skrll void dccp_timewait_t(void *); 162 1.2.2.2 skrll 163 1.2.2.2 skrll /* Ack Vector functions */ 164 1.2.2.2 skrll #define DCCP_VECTORSIZE 512 /* initial ack and cwnd-vector size. Multiple of 8 ! */ 165 1.2.2.2 skrll void dccp_use_ackvector(struct dccpcb *); 166 1.2.2.2 skrll void dccp_update_ackvector(struct dccpcb *, u_int64_t); 167 1.2.2.2 skrll void dccp_increment_ackvector(struct dccpcb *, u_int64_t); 168 1.2.2.2 skrll u_int16_t dccp_generate_ackvector(struct dccpcb *, u_char *); 169 1.2.2.2 skrll u_char dccp_ackvector_state(struct dccpcb *, u_int64_t); 170 1.2.2.2 skrll 171 1.2.2.2 skrll /* 172 1.2.2.2 skrll * DCCP initialization 173 1.2.2.2 skrll */ 174 1.2.2.2 skrll void 175 1.2.2.2 skrll dccp_init(void) 176 1.2.2.2 skrll { 177 1.2.2.2 skrll pool_init(&dccpcb_pool, sizeof(struct dccpcb), 0, 0, 0, "dccpcbpl", 178 1.2.2.2 skrll NULL, IPL_SOFTNET); 179 1.2.2.2 skrll 180 1.2.2.2 skrll in_pcbinit(&dccpbtable, DCCPBHASHSIZE, DCCPBHASHSIZE); 181 1.2.2.2 skrll } 182 1.2.2.2 skrll 183 1.2.2.2 skrll void 184 1.2.2.2 skrll dccp_input(struct mbuf *m, ...) 185 1.2.2.2 skrll { 186 1.2.2.2 skrll int iphlen; 187 1.2.2.2 skrll struct ip *ip = NULL; 188 1.2.2.2 skrll struct dccphdr *dh; 189 1.2.2.2 skrll struct dccplhdr *dlh; 190 1.2.2.2 skrll struct inpcb *inp = NULL, *oinp = NULL; 191 1.2.2.2 skrll struct in6pcb *in6p = NULL, *oin6p = NULL; 192 1.2.2.2 skrll struct dccpcb *dp; 193 1.2.2.2 skrll struct ipovly *ipov = NULL; 194 1.2.2.2 skrll struct dccp_requesthdr *drqh; 195 1.2.2.2 skrll struct dccp_ackhdr *dah = NULL; 196 1.2.2.2 skrll struct dccp_acklhdr *dalh = NULL; 197 1.2.2.2 skrll struct dccp_resethdr *drth; 198 1.2.2.2 skrll struct socket *so; 199 1.2.2.2 skrll u_char *optp = NULL; 200 1.2.2.2 skrll struct mbuf *opts = 0; 201 1.2.2.2 skrll int len, data_off, extrah_len, optlen; 202 1.2.2.2 skrll /*struct ip save_ip;*/ 203 1.2.2.2 skrll char options[DCCP_MAX_OPTIONS]; 204 1.2.2.2 skrll char test[2]; 205 1.2.2.2 skrll u_int32_t cslen; 206 1.2.2.2 skrll dccp_seq seqnr, low_seqnr, high_seqnr; 207 1.2.2.2 skrll int isipv6 = 0; 208 1.2.2.3 skrll int is_shortseq; /* Is this shortseq packet? */ 209 1.2.2.2 skrll #ifdef INET6 210 1.2.2.2 skrll struct ip6_hdr *ip6 = NULL; 211 1.2.2.2 skrll #endif 212 1.2.2.2 skrll 213 1.2.2.2 skrll int off; 214 1.2.2.2 skrll va_list ap; 215 1.2.2.3 skrll 216 1.2.2.2 skrll va_start(ap, m); 217 1.2.2.2 skrll iphlen = off = va_arg(ap, int); 218 1.2.2.2 skrll va_end(ap); 219 1.2.2.2 skrll 220 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP packet!\n")); 221 1.2.2.2 skrll 222 1.2.2.2 skrll dccpstat.dccps_ipackets++; 223 1.2.2.2 skrll dccpstat.dccps_ibytes += m->m_pkthdr.len; 224 1.2.2.2 skrll 225 1.2.2.2 skrll #ifdef INET6 226 1.2.2.2 skrll isipv6 = (mtod(m, struct ip *)->ip_v == 6) ? 1 : 0; 227 1.2.2.2 skrll #endif 228 1.2.2.2 skrll 229 1.2.2.2 skrll #ifdef INET6 230 1.2.2.2 skrll if (isipv6) { 231 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP ipv6 packet, iphlen = %u!\n", iphlen)); 232 1.2.2.2 skrll ip6 = mtod(m, struct ip6_hdr *); 233 1.2.2.2 skrll IP6_EXTHDR_GET(dh, struct dccphdr *, m, iphlen, sizeof(*dh)); 234 1.2.2.2 skrll if (dh == NULL) { 235 1.2.2.2 skrll dccpstat.dccps_badlen++; 236 1.2.2.2 skrll return; 237 1.2.2.2 skrll } 238 1.2.2.2 skrll } else 239 1.2.2.2 skrll #endif 240 1.2.2.2 skrll { 241 1.2.2.2 skrll /* 242 1.2.2.2 skrll * Strip IP options, if any; should skip this, 243 1.2.2.2 skrll * make available to user, and use on returned packets, 244 1.2.2.2 skrll * but we don't yet have a way to check the checksum 245 1.2.2.2 skrll * with options still present. 246 1.2.2.2 skrll */ 247 1.2.2.2 skrll if (iphlen > sizeof (struct ip)) { 248 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Need to strip options\n")); 249 1.2.2.2 skrll #if 0 /* XXX */ 250 1.2.2.2 skrll ip_stripoptions(m, (struct mbuf *)0); 251 1.2.2.2 skrll #endif 252 1.2.2.2 skrll iphlen = sizeof(struct ip); 253 1.2.2.2 skrll } 254 1.2.2.2 skrll 255 1.2.2.2 skrll /* 256 1.2.2.2 skrll * Get IP and DCCP header together in first mbuf. 257 1.2.2.2 skrll */ 258 1.2.2.2 skrll ip = mtod(m, struct ip *); 259 1.2.2.2 skrll IP6_EXTHDR_GET(dh, struct dccphdr *, m, iphlen, sizeof(*dh)); 260 1.2.2.2 skrll if (dh == NULL) { 261 1.2.2.2 skrll dccpstat.dccps_badlen++; 262 1.2.2.2 skrll return; 263 1.2.2.2 skrll } 264 1.2.2.2 skrll } 265 1.2.2.3 skrll dlh = (struct dccplhdr*)dh; 266 1.2.2.2 skrll is_shortseq = !dh->dh_x; 267 1.2.2.3 skrll 268 1.2.2.2 skrll if (!is_shortseq) { 269 1.2.2.3 skrll DCCP_DEBUG((LOG_INFO, 270 1.2.2.2 skrll "Header info: cslen = %u, off = %u, type = %u, reserved = %u, seq = %u.%lu\n", 271 1.2.2.2 skrll dlh->dh_cscov, dlh->dh_off, dlh->dh_type, dlh->dh_res, ntohs(dlh->dh_seq), 272 1.2.2.2 skrll (unsigned long)ntohl(dlh->dh_seq2))); 273 1.2.2.2 skrll } else { 274 1.2.2.3 skrll DCCP_DEBUG((LOG_INFO, 275 1.2.2.3 skrll "Header info(short): cslen = %u, off = %u, type = %u, reserved = %u, seq = %u\n", 276 1.2.2.2 skrll dh->dh_cscov, dh->dh_off, dh->dh_type, dh->dh_res, ntohl(dh->dh_seq))); 277 1.2.2.2 skrll } 278 1.2.2.2 skrll 279 1.2.2.2 skrll /* 280 1.2.2.2 skrll * Make mbuf data length reflect DCCP length. 281 1.2.2.2 skrll * If not enough data to reflect DCCP length, drop. 282 1.2.2.2 skrll */ 283 1.2.2.2 skrll 284 1.2.2.2 skrll #ifdef INET6 285 1.2.2.2 skrll if (isipv6) 286 1.2.2.2 skrll len = m->m_pkthdr.len - off; 287 1.2.2.2 skrll else 288 1.2.2.2 skrll #endif 289 1.2.2.2 skrll { 290 1.2.2.2 skrll len = ntohs(ip->ip_len); 291 1.2.2.2 skrll len -= ip->ip_hl << 2; 292 1.2.2.2 skrll } 293 1.2.2.2 skrll 294 1.2.2.2 skrll if (len < sizeof(struct dccphdr)) { 295 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Dropping DCCP packet!\n")); 296 1.2.2.2 skrll dccpstat.dccps_badlen++; 297 1.2.2.2 skrll goto badunlocked; 298 1.2.2.2 skrll } 299 1.2.2.2 skrll /* 300 1.2.2.2 skrll * Save a copy of the IP header in case we want restore it 301 1.2.2.2 skrll * for sending a DCCP reset packet in response. 302 1.2.2.2 skrll */ 303 1.2.2.2 skrll if (!isipv6) { 304 1.2.2.2 skrll /*save_ip = *ip;*/ 305 1.2.2.2 skrll ipov = (struct ipovly *)ip; 306 1.2.2.2 skrll } 307 1.2.2.2 skrll 308 1.2.2.2 skrll if (dh->dh_cscov == 0) { 309 1.2.2.2 skrll cslen = len; 310 1.2.2.2 skrll } else { 311 1.2.2.2 skrll cslen = dh->dh_off * 4 + (dh->dh_cscov - 1) * 4; 312 1.2.2.2 skrll if (cslen > len) 313 1.2.2.2 skrll cslen = len; 314 1.2.2.2 skrll } 315 1.2.2.3 skrll 316 1.2.2.2 skrll /* 317 1.2.2.2 skrll * Checksum extended DCCP header and data. 318 1.2.2.2 skrll */ 319 1.2.2.3 skrll 320 1.2.2.2 skrll #ifdef INET6 321 1.2.2.2 skrll if (isipv6) { 322 1.2.2.2 skrll if (in6_cksum(m, IPPROTO_DCCP, off, cslen) != 0) { 323 1.2.2.2 skrll dccpstat.dccps_badsum++; 324 1.2.2.2 skrll goto badunlocked; 325 1.2.2.2 skrll } 326 1.2.2.2 skrll } else 327 1.2.2.2 skrll #endif 328 1.2.2.2 skrll { 329 1.2.2.2 skrll bzero(ipov->ih_x1, sizeof(ipov->ih_x1)); 330 1.2.2.2 skrll ip->ip_len = htons(m->m_pkthdr.len); 331 1.2.2.2 skrll dh->dh_sum = in4_cksum(m, IPPROTO_DCCP, off, cslen); 332 1.2.2.2 skrll 333 1.2.2.2 skrll if (dh->dh_sum) { 334 1.2.2.2 skrll dccpstat.dccps_badsum++; 335 1.2.2.2 skrll goto badunlocked; 336 1.2.2.2 skrll } 337 1.2.2.2 skrll } 338 1.2.2.2 skrll 339 1.2.2.2 skrll INP_INFO_WLOCK(&dccpbinfo); 340 1.2.2.2 skrll 341 1.2.2.2 skrll /* 342 1.2.2.2 skrll * Locate pcb for datagram. 343 1.2.2.2 skrll */ 344 1.2.2.2 skrll #ifdef INET6 345 1.2.2.2 skrll if (isipv6) { 346 1.2.2.2 skrll in6p = in6_pcblookup_connect(&dccpbtable, &ip6->ip6_src, 347 1.2.2.2 skrll dh->dh_sport, &ip6->ip6_dst, dh->dh_dport, 0, 0); 348 1.2.2.2 skrll if (in6p == 0) { 349 1.2.2.2 skrll /* XXX stats increment? */ 350 1.2.2.2 skrll in6p = in6_pcblookup_bind(&dccpbtable, &ip6->ip6_dst, 351 1.2.2.2 skrll dh->dh_dport, 0); 352 1.2.2.2 skrll } 353 1.2.2.2 skrll } else 354 1.2.2.2 skrll #endif 355 1.2.2.2 skrll { 356 1.2.2.2 skrll inp = in_pcblookup_connect(&dccpbtable, ip->ip_src, 357 1.2.2.2 skrll dh->dh_sport, ip->ip_dst, dh->dh_dport, 0); 358 1.2.2.2 skrll if (inp == NULL) { 359 1.2.2.2 skrll /* XXX stats increment? */ 360 1.2.2.2 skrll inp = in_pcblookup_bind(&dccpbtable, ip->ip_dst, 361 1.2.2.2 skrll dh->dh_dport); 362 1.2.2.2 skrll } 363 1.2.2.2 skrll } 364 1.2.2.2 skrll if (isipv6) { 365 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "in6p=%p\n", in6p)); 366 1.2.2.2 skrll } else { 367 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "inp=%p\n", inp)); 368 1.2.2.2 skrll } 369 1.2.2.2 skrll 370 1.2.2.2 skrll if (isipv6 ? in6p == NULL : inp == NULL) { 371 1.2.2.2 skrll if (dccp_log_in_vain) { 372 1.2.2.2 skrll #ifdef INET6 373 1.2.2.2 skrll char dbuf[INET6_ADDRSTRLEN+2], sbuf[INET6_ADDRSTRLEN+2]; 374 1.2.2.2 skrll #else 375 1.2.2.2 skrll char dbuf[4*sizeof "123"], sbuf[4*sizeof "123"]; 376 1.2.2.2 skrll #endif 377 1.2.2.2 skrll 378 1.2.2.2 skrll #ifdef INET6 379 1.2.2.2 skrll if (isipv6) { 380 1.2.2.6 skrll char ip6buf[INET6_ADDRSTRLEN]; 381 1.2.2.2 skrll strlcpy(dbuf, "[", sizeof dbuf); 382 1.2.2.6 skrll strlcat(dbuf, IN6_PRINT(ip6buf, &ip6->ip6_dst), sizeof dbuf); 383 1.2.2.2 skrll strlcat(dbuf, "]", sizeof dbuf); 384 1.2.2.2 skrll strlcpy(sbuf, "[", sizeof sbuf); 385 1.2.2.6 skrll strlcat(sbuf, IN6_PRINT(ip6buf, &ip6->ip6_src), sizeof sbuf); 386 1.2.2.2 skrll strlcat(sbuf, "]", sizeof sbuf); 387 1.2.2.2 skrll } else 388 1.2.2.2 skrll #endif 389 1.2.2.2 skrll { 390 1.2.2.2 skrll strlcpy(dbuf, inet_ntoa(ip->ip_dst), sizeof dbuf); 391 1.2.2.2 skrll strlcpy(sbuf, inet_ntoa(ip->ip_src), sizeof sbuf); 392 1.2.2.2 skrll } 393 1.2.2.2 skrll log(LOG_INFO, 394 1.2.2.2 skrll "Connection attempt to DCCP %s:%d from %s:%d\n", 395 1.2.2.2 skrll dbuf, ntohs(dh->dh_dport), sbuf, 396 1.2.2.2 skrll ntohs(dh->dh_sport)); 397 1.2.2.2 skrll } 398 1.2.2.2 skrll dccpstat.dccps_noport++; 399 1.2.2.2 skrll 400 1.2.2.2 skrll /* 401 1.2.2.2 skrll * We should send DCCP reset here but we can't call dccp_output 402 1.2.2.2 skrll * since we have no dccpcb. A icmp unreachable works great but 403 1.2.2.2 skrll * the specs says DCCP reset :( 404 1.2.2.2 skrll * 405 1.2.2.2 skrll * if (!isipv6) { 406 1.2.2.2 skrll * *ip = save_ip; 407 1.2.2.2 skrll * ip->ip_len += iphlen; 408 1.2.2.3 skrll * icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_PORT, 0, 0); 409 1.2.2.5 skrll * } 410 1.2.2.2 skrll */ 411 1.2.2.2 skrll 412 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 413 1.2.2.2 skrll goto badunlocked; 414 1.2.2.2 skrll } 415 1.2.2.2 skrll INP_LOCK(inp); 416 1.2.2.2 skrll 417 1.2.2.2 skrll #ifdef INET6 418 1.2.2.2 skrll if (isipv6) 419 1.2.2.2 skrll dp = in6todccpcb(in6p); 420 1.2.2.2 skrll else 421 1.2.2.2 skrll #endif 422 1.2.2.2 skrll dp = intodccpcb(inp); 423 1.2.2.2 skrll 424 1.2.2.2 skrll if (dp == 0) { 425 1.2.2.2 skrll INP_UNLOCK(inp); 426 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 427 1.2.2.2 skrll goto badunlocked; 428 1.2.2.2 skrll } 429 1.2.2.2 skrll 430 1.2.2.2 skrll if (dp->state == DCCPS_CLOSED) { 431 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "We are in closed state, dropping packet and sending reset!\n")); 432 1.2.2.2 skrll if (dh->dh_type != DCCP_TYPE_RESET) 433 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 434 1.2.2.2 skrll INP_UNLOCK(inp); 435 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 436 1.2.2.2 skrll goto badunlocked; 437 1.2.2.2 skrll } 438 1.2.2.2 skrll 439 1.2.2.2 skrll #if defined(INET6) 440 1.2.2.2 skrll if (isipv6) 441 1.2.2.2 skrll so = in6p->in6p_socket; 442 1.2.2.2 skrll else 443 1.2.2.2 skrll #endif 444 1.2.2.2 skrll so = inp->inp_socket; 445 1.2.2.2 skrll 446 1.2.2.2 skrll if (so->so_options & SO_ACCEPTCONN) { 447 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "so->options & SO_ACCEPTCONN! dp->state = %i\n", dp->state)); 448 1.2.2.2 skrll so = sonewconn(so, SS_ISCONNECTED); 449 1.2.2.2 skrll if (so == 0) { 450 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Error, sonewconn failed!\n")); 451 1.2.2.2 skrll INP_UNLOCK(inp); 452 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 453 1.2.2.2 skrll goto badunlocked; 454 1.2.2.2 skrll } 455 1.2.2.2 skrll 456 1.2.2.2 skrll /* INP_LOCK(inp); XXX */ 457 1.2.2.2 skrll 458 1.2.2.2 skrll #if defined(INET6) 459 1.2.2.2 skrll if (isipv6) 460 1.2.2.2 skrll oin6p = in6p; 461 1.2.2.2 skrll else 462 1.2.2.2 skrll #endif 463 1.2.2.2 skrll oinp = inp; 464 1.2.2.2 skrll 465 1.2.2.2 skrll #ifdef INET6 466 1.2.2.2 skrll if (isipv6) { 467 1.2.2.2 skrll in6p = sotoin6pcb(so); 468 1.2.2.2 skrll in6p->in6p_laddr = ip6->ip6_dst; 469 1.2.2.2 skrll in6p->in6p_faddr = ip6->ip6_src; 470 1.2.2.2 skrll in6p->in6p_lport = dh->dh_dport; 471 1.2.2.2 skrll in6p->in6p_fport = dh->dh_sport; 472 1.2.2.2 skrll in6_pcbstate(in6p, IN6P_CONNECTED); 473 1.2.2.3 skrll } else 474 1.2.2.2 skrll #endif 475 1.2.2.2 skrll { 476 1.2.2.2 skrll inp = sotoinpcb(so); 477 1.2.2.2 skrll inp->inp_laddr = ip->ip_dst; 478 1.2.2.2 skrll inp->inp_faddr = ip->ip_src; 479 1.2.2.2 skrll inp->inp_lport = dh->dh_dport; 480 1.2.2.2 skrll inp->inp_fport = dh->dh_sport; 481 1.2.2.2 skrll } 482 1.2.2.2 skrll 483 1.2.2.2 skrll if (!isipv6) 484 1.2.2.2 skrll in_pcbstate(inp, INP_BOUND); 485 1.2.2.2 skrll 486 1.2.2.2 skrll #if defined(INET6) 487 1.2.2.2 skrll if (isipv6) 488 1.2.2.2 skrll dp = (struct dccpcb *)in6p->in6p_ppcb; 489 1.2.2.2 skrll else 490 1.2.2.2 skrll #endif 491 1.2.2.2 skrll dp = (struct dccpcb *)inp->inp_ppcb; 492 1.2.2.2 skrll 493 1.2.2.2 skrll dp->state = DCCPS_LISTEN; 494 1.2.2.2 skrll dp->who = DCCP_SERVER; 495 1.2.2.2 skrll #if defined(INET6) 496 1.2.2.2 skrll if (isipv6) { 497 1.2.2.2 skrll dp->cslen = ((struct dccpcb *)oin6p->in6p_ppcb)->cslen; 498 1.2.2.2 skrll dp->avgpsize = ((struct dccpcb *)oin6p->in6p_ppcb)->avgpsize; 499 1.2.2.2 skrll dp->scode = ((struct dccpcb *)oin6p->in6p_ppcb)->scode; 500 1.2.2.3 skrll } else 501 1.2.2.2 skrll #endif 502 1.2.2.2 skrll { 503 1.2.2.2 skrll dp->cslen = ((struct dccpcb *)oinp->inp_ppcb)->cslen; 504 1.2.2.2 skrll dp->avgpsize = ((struct dccpcb *)oinp->inp_ppcb)->avgpsize; 505 1.2.2.2 skrll dp->scode = ((struct dccpcb *)oinp->inp_ppcb)->scode; 506 1.2.2.2 skrll } 507 1.2.2.2 skrll dp->seq_snd = (((u_int64_t)random() << 32) | random()) % 281474976710656LL; 508 1.2.2.2 skrll dp->ref_seq.hi = dp->seq_snd >> 24; 509 1.2.2.2 skrll dp->ref_seq.lo = (u_int64_t)(dp->seq_snd & 0xffffff); 510 1.2.2.2 skrll INP_UNLOCK(oinp); 511 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "New dp = %u, dp->state = %u!\n", (int)dp, dp->state)); 512 1.2.2.2 skrll } 513 1.2.2.2 skrll 514 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 515 1.2.2.2 skrll 516 1.2.2.2 skrll /* 517 1.2.2.3 skrll * Check if sequence number is inside the loss window 518 1.2.2.2 skrll */ 519 1.2.2.3 skrll if (!is_shortseq) { 520 1.2.2.2 skrll DHDR_TO_DSEQ(seqnr, dlh); 521 1.2.2.2 skrll } else { 522 1.2.2.2 skrll /* shortseq */ 523 1.2.2.2 skrll seqnr = CONVERT_TO_LONGSEQ((ntohl(dh->dh_seq) >> 8), dp->ref_pseq); 524 1.2.2.3 skrll DCCP_DEBUG((LOG_INFO, "short seq conversion %x, %u %u\n", 525 1.2.2.2 skrll ntohl(dh->dh_seq) >> 8, dp->ref_pseq.hi, dp->ref_pseq.lo)); 526 1.2.2.2 skrll } 527 1.2.2.2 skrll 528 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Received DCCP packet with sequence number = %llu , gsn_rcv %llu\n", seqnr, dp->gsn_rcv)); 529 1.2.2.2 skrll 530 1.2.2.2 skrll /* store ccval */ 531 1.2.2.2 skrll dp->ccval = dh->dh_ccval; 532 1.2.2.2 skrll 533 1.2.2.2 skrll if (dp->gsn_rcv == 281474976710656LL) dp->gsn_rcv = seqnr; 534 1.2.2.2 skrll if (dp->gsn_rcv > (dp->loss_window / 4)) 535 1.2.2.2 skrll low_seqnr = (dp->gsn_rcv - (dp->loss_window / 4)) % 281474976710656LL; 536 1.2.2.2 skrll else 537 1.2.2.2 skrll low_seqnr = 0ll; 538 1.2.2.2 skrll high_seqnr = (dp->gsn_rcv + (dp->loss_window / 4 * 3)) % 281474976710656LL; 539 1.2.2.2 skrll 540 1.2.2.2 skrll if (! (DCCP_SEQ_GT(seqnr, low_seqnr) && DCCP_SEQ_LT(seqnr, high_seqnr))) { 541 1.2.2.2 skrll dccpstat.dccps_badseq++; 542 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Recieved DCCP packet with bad sequence number = %llu (low_seqnr = %llu, high_seqnr = %llu)\n", seqnr, low_seqnr, high_seqnr)); 543 1.2.2.2 skrll INP_UNLOCK(inp); 544 1.2.2.2 skrll goto badunlocked; 545 1.2.2.2 skrll } 546 1.2.2.2 skrll 547 1.2.2.2 skrll /* dp->gsn_rcv should always be the highest received valid sequence number */ 548 1.2.2.2 skrll if (DCCP_SEQ_GT(seqnr, dp->gsn_rcv)) 549 1.2.2.2 skrll dp->gsn_rcv = seqnr; 550 1.2.2.2 skrll 551 1.2.2.2 skrll /* Just ignore DCCP-Move for now */ 552 1.2.2.2 skrll if (dlh->dh_type == DCCP_TYPE_DATA) { 553 1.2.2.2 skrll extrah_len = 0; 554 1.2.2.2 skrll if (!is_shortseq) 555 1.2.2.2 skrll optp = (u_char *)(dlh + 1); 556 1.2.2.2 skrll else 557 1.2.2.2 skrll optp = (u_char *)(dh + 1); 558 1.2.2.2 skrll } else if (dh->dh_type == DCCP_TYPE_REQUEST) { 559 1.2.2.2 skrll drqh = (struct dccp_requesthdr *)(dlh + 1); 560 1.2.2.2 skrll if (drqh->drqh_scode != dp->scode){ 561 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "service code in request packet doesn't match! %x %x\n", drqh->drqh_scode, dp->scode)); 562 1.2.2.2 skrll INP_UNLOCK(inp); 563 1.2.2.2 skrll dp->state = DCCPS_SERVER_CLOSE; /* So disconnect2 doesn't send CLOSEREQ */ 564 1.2.2.2 skrll dccp_disconnect2(dp); 565 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 566 1.2.2.2 skrll dccp_close(dp); 567 1.2.2.2 skrll goto badunlocked; 568 1.2.2.2 skrll } 569 1.2.2.2 skrll optp = (u_char *)(drqh + 1); 570 1.2.2.2 skrll extrah_len = 4; 571 1.2.2.2 skrll 572 1.2.2.2 skrll /* store reference peer sequence number */ 573 1.2.2.2 skrll dp->ref_pseq.hi = seqnr >> 24; 574 1.2.2.2 skrll dp->ref_pseq.lo = (u_int64_t)(seqnr & 0xffffff); 575 1.2.2.2 skrll 576 1.2.2.2 skrll } else if (dh->dh_type == DCCP_TYPE_RESET) { 577 1.2.2.2 skrll extrah_len = 8 ; 578 1.2.2.2 skrll drth = (struct dccp_resethdr *)(dlh + 1); 579 1.2.2.2 skrll optp = (u_char *)(drth + 1); 580 1.2.2.2 skrll } else { 581 1.2.2.2 skrll if (!is_shortseq){ 582 1.2.2.2 skrll extrah_len = 8; 583 1.2.2.2 skrll dalh = (struct dccp_acklhdr *)(dlh + 1); 584 1.2.2.2 skrll if (dh->dh_type == DCCP_TYPE_RESPONSE) { 585 1.2.2.2 skrll extrah_len += 4; 586 1.2.2.2 skrll drqh = (struct dccp_requesthdr *)(dalh + 1); 587 1.2.2.2 skrll if (drqh->drqh_scode != dp->scode){ 588 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "service code in response packet doesn't match! %x %x\n", drqh->drqh_scode, dp->scode)); 589 1.2.2.2 skrll INP_UNLOCK(inp); 590 1.2.2.2 skrll dp->state = DCCPS_CLIENT_CLOSE; /* So disconnect2 doesn't send CLOSEREQ */ 591 1.2.2.2 skrll dccp_disconnect2(dp); 592 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 593 1.2.2.2 skrll dccp_close(dp); 594 1.2.2.2 skrll goto badunlocked; 595 1.2.2.2 skrll } 596 1.2.2.2 skrll optp = (u_char *)(drqh + 1); 597 1.2.2.2 skrll 598 1.2.2.2 skrll /* store reference peer sequence number */ 599 1.2.2.2 skrll dp->ref_pseq.hi = seqnr >> 24; 600 1.2.2.2 skrll dp->ref_pseq.lo = (u_int64_t)(seqnr & 0xffffff); 601 1.2.2.3 skrll } else 602 1.2.2.2 skrll optp = (u_char *)(dalh + 1); 603 1.2.2.2 skrll } else { 604 1.2.2.2 skrll extrah_len = 4; 605 1.2.2.2 skrll dah = (struct dccp_ackhdr *)(dh + 1); 606 1.2.2.2 skrll optp = (u_char *)(dah + 1); 607 1.2.2.2 skrll } 608 1.2.2.2 skrll 609 1.2.2.2 skrll } 610 1.2.2.2 skrll 611 1.2.2.2 skrll data_off = (dh->dh_off << 2); 612 1.2.2.2 skrll 613 1.2.2.2 skrll dp->seq_rcv = seqnr; 614 1.2.2.2 skrll dp->ack_rcv = 0; /* Clear it for now */ 615 1.2.2.2 skrll dp->type_rcv = dh->dh_type; 616 1.2.2.2 skrll dp->len_rcv = m->m_len - data_off - iphlen; /* Correct length ? */ 617 1.2.2.3 skrll 618 1.2.2.2 skrll if (!is_shortseq) 619 1.2.2.2 skrll optlen = data_off - (sizeof(struct dccplhdr) + extrah_len); 620 1.2.2.2 skrll else 621 1.2.2.2 skrll optlen = data_off - (sizeof(struct dccphdr) + extrah_len); 622 1.2.2.2 skrll 623 1.2.2.2 skrll if (optlen < 0) { 624 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Data offset is smaller then it could be, optlen = %i data_off = %i, m_len = %i, iphlen = %i extrah_len = %i !\n", optlen, data_off, m->m_len, iphlen, extrah_len)); 625 1.2.2.2 skrll INP_UNLOCK(inp); 626 1.2.2.2 skrll goto badunlocked; 627 1.2.2.2 skrll } 628 1.2.2.2 skrll 629 1.2.2.2 skrll if (optlen > 0) { 630 1.2.2.2 skrll if (optlen > DCCP_MAX_OPTIONS) { 631 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Error, more options (%i) then DCCP_MAX_OPTIONS options!\n", optlen)); 632 1.2.2.2 skrll INP_UNLOCK(inp); 633 1.2.2.2 skrll goto badunlocked; 634 1.2.2.2 skrll } 635 1.2.2.2 skrll 636 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Parsing DCCP options, optlen = %i\n", optlen)); 637 1.2.2.2 skrll bcopy(optp, options, optlen); 638 1.2.2.2 skrll dccp_parse_options(dp, options, optlen); 639 1.2.2.2 skrll } 640 1.2.2.2 skrll 641 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "BEFORE state check, Got a %u packet while in %u state, who = %u!\n", dh->dh_type, dp->state, dp->who)); 642 1.2.2.2 skrll 643 1.2.2.2 skrll if (dp->state == DCCPS_LISTEN) { 644 1.2.2.2 skrll switch (dh->dh_type) { 645 1.2.2.2 skrll 646 1.2.2.2 skrll case DCCP_TYPE_REQUEST: 647 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP REQUEST\n")); 648 1.2.2.2 skrll dp->state = DCCPS_REQUEST; 649 1.2.2.2 skrll if (dp->cc_in_use[1] < 0) { 650 1.2.2.2 skrll test[0] = DEFAULT_CCID; 651 1.2.2.2 skrll test[1] = 3; 652 1.2.2.2 skrll dccp_add_feature(dp, DCCP_OPT_CHANGE_R, DCCP_FEATURE_CC, test, 2); 653 1.2.2.2 skrll } 654 1.2.2.2 skrll if (len > data_off) { 655 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "XXX: len=%d, data_off=%d\n", len, data_off)); 656 1.2.2.2 skrll dccp_add_option(dp, DCCP_OPT_DATA_DISCARD, test, 0); 657 1.2.2.2 skrll } 658 1.2.2.2 skrll callout_reset(&dp->connect_timer, DCCP_CONNECT_TIMER, 659 1.2.2.2 skrll dccp_connect_t, dp); 660 1.2.2.2 skrll dccp_output(dp, 0); 661 1.2.2.2 skrll break; 662 1.2.2.2 skrll 663 1.2.2.2 skrll 664 1.2.2.2 skrll /* These are ok if the sender has a valid init Cookie */ 665 1.2.2.2 skrll case DCCP_TYPE_ACK: 666 1.2.2.2 skrll case DCCP_TYPE_DATAACK: 667 1.2.2.2 skrll case DCCP_TYPE_DATA: 668 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP ACK/DATAACK/DATA, should check init cookie...\n")); 669 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 670 1.2.2.2 skrll break; 671 1.2.2.2 skrll 672 1.2.2.2 skrll case DCCP_TYPE_RESET: 673 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP RESET\n")); 674 1.2.2.2 skrll dp->state = DCCPS_TIME_WAIT; 675 1.2.2.2 skrll dp = dccp_close(dp); 676 1.2.2.2 skrll return; 677 1.2.2.2 skrll 678 1.2.2.2 skrll default: 679 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got a %u packet while in listen stage!\n", dh->dh_type)); 680 1.2.2.2 skrll /* Force send reset. */ 681 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 682 1.2.2.2 skrll } 683 1.2.2.2 skrll } else if (dp->state == DCCPS_REQUEST) { 684 1.2.2.2 skrll switch (dh->dh_type) { 685 1.2.2.2 skrll case DCCP_TYPE_RESPONSE: 686 1.2.2.2 skrll DAHDR_TO_DSEQ(dp->ack_rcv, ((struct dccp_acklhdr*)dalh)->dash); 687 1.2.2.2 skrll dp->ack_snd = dp->seq_rcv; 688 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP REPSONSE %x %llx\n", dp, dp->ack_snd)); 689 1.2.2.2 skrll 690 1.2.2.2 skrll callout_stop(&dp->retrans_timer); 691 1.2.2.2 skrll callout_stop(&dp->connect_timer); 692 1.2.2.2 skrll 693 1.2.2.2 skrll /* First check if we have negotiated a cc */ 694 1.2.2.2 skrll if (dp->cc_in_use[0] > 0 && dp->cc_in_use[1] > 0) { 695 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Setting DCCPS_ESTAB & soisconnected\n")); 696 1.2.2.2 skrll dp->state = DCCPS_ESTAB; 697 1.2.2.2 skrll dccpstat.dccps_connects++; 698 1.2.2.2 skrll #if defined(INET6) 699 1.2.2.2 skrll if (isipv6) 700 1.2.2.2 skrll soisconnected(in6p->in6p_socket); 701 1.2.2.2 skrll else 702 1.2.2.2 skrll #endif 703 1.2.2.2 skrll soisconnected(inp->inp_socket); 704 1.2.2.2 skrll } else { 705 1.2.2.2 skrll dp->state = DCCPS_RESPOND; 706 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "CC negotiation is not finished, cc_in_use[0] = %u, cc_in_use[1] = %u\n",dp->cc_in_use[0], dp->cc_in_use[1])); 707 1.2.2.2 skrll 708 1.2.2.2 skrll } 709 1.2.2.2 skrll dccp_output(dp, 0); 710 1.2.2.2 skrll break; 711 1.2.2.2 skrll 712 1.2.2.2 skrll case DCCP_TYPE_RESET: 713 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP RESET\n")); 714 1.2.2.2 skrll dp->state = DCCPS_TIME_WAIT; 715 1.2.2.2 skrll dp = dccp_close(dp); 716 1.2.2.2 skrll return; 717 1.2.2.2 skrll 718 1.2.2.2 skrll default: 719 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got a %u packet while in REQUEST stage!\n", dh->dh_type)); 720 1.2.2.2 skrll /* Force send reset. */ 721 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 722 1.2.2.2 skrll if (dh->dh_type == DCCP_TYPE_CLOSE) { 723 1.2.2.2 skrll dp = dccp_close(dp); 724 1.2.2.2 skrll return; 725 1.2.2.2 skrll } else { 726 1.2.2.2 skrll callout_stop(&dp->retrans_timer); 727 1.2.2.2 skrll dp->state = DCCPS_TIME_WAIT; 728 1.2.2.2 skrll } 729 1.2.2.2 skrll } 730 1.2.2.2 skrll } else if (dp->state == DCCPS_RESPOND) { 731 1.2.2.2 skrll switch (dh->dh_type) { 732 1.2.2.2 skrll 733 1.2.2.2 skrll case DCCP_TYPE_REQUEST: 734 1.2.2.2 skrll break; 735 1.2.2.2 skrll case DCCP_TYPE_ACK: 736 1.2.2.2 skrll case DCCP_TYPE_DATAACK: 737 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP ACK/DATAACK\n")); 738 1.2.2.2 skrll 739 1.2.2.2 skrll callout_stop(&dp->connect_timer); 740 1.2.2.2 skrll 741 1.2.2.2 skrll if (!is_shortseq) { 742 1.2.2.2 skrll DAHDR_TO_DSEQ(dp->ack_rcv, ((struct dccp_acklhdr*)dalh)->dash); 743 1.2.2.2 skrll } else { 744 1.2.2.2 skrll /* shortseq XXX */ 745 1.2.2.2 skrll dp->ack_rcv = CONVERT_TO_LONGSEQ((ntohl(dah->dash.dah_ack) >> 8), dp->ref_seq); 746 1.2.2.3 skrll } 747 1.2.2.2 skrll 748 1.2.2.2 skrll if (dp->cc_in_use[0] > 0 && dp->cc_in_use[1] > 0) { 749 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Setting DCCPS_ESTAB & soisconnected\n")); 750 1.2.2.2 skrll dp->state = DCCPS_ESTAB; 751 1.2.2.2 skrll dccpstat.dccps_connects++; 752 1.2.2.2 skrll #if defined(INET6) 753 1.2.2.2 skrll if (isipv6) 754 1.2.2.2 skrll soisconnected(in6p->in6p_socket); 755 1.2.2.2 skrll else 756 1.2.2.2 skrll #endif 757 1.2.2.2 skrll soisconnected(inp->inp_socket); 758 1.2.2.2 skrll } else { 759 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "CC negotiation is not finished, cc_in_use[0] = %u, cc_in_use[1] = %u\n",dp->cc_in_use[0], dp->cc_in_use[1])); 760 1.2.2.2 skrll /* Force an output!!! */ 761 1.2.2.2 skrll dp->ack_snd = dp->seq_rcv; 762 1.2.2.2 skrll dccp_output(dp, 0); 763 1.2.2.2 skrll } 764 1.2.2.2 skrll 765 1.2.2.2 skrll if (dh->dh_type == DCCP_TYPE_DATAACK && dp->cc_in_use[1] > 0) { 766 1.2.2.2 skrll if (!dp->ack_snd) dp->ack_snd = dp->seq_rcv; 767 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Calling *cc_sw[%u].cc_recv_packet_recv!\n", dp->cc_in_use[1])); 768 1.2.2.3 skrll (*cc_sw[dp->cc_in_use[1]].cc_recv_packet_recv)(dp->cc_state[1], options, optlen); 769 1.2.2.2 skrll } 770 1.2.2.2 skrll break; 771 1.2.2.2 skrll 772 1.2.2.2 skrll case DCCP_TYPE_CLOSE: 773 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_CLOSE + 1); 774 1.2.2.2 skrll dp = dccp_close(dp); 775 1.2.2.2 skrll goto badunlocked; 776 1.2.2.2 skrll 777 1.2.2.2 skrll case DCCP_TYPE_RESET: 778 1.2.2.2 skrll dp->state = DCCPS_TIME_WAIT; 779 1.2.2.2 skrll callout_stop(&dp->retrans_timer); 780 1.2.2.2 skrll break; 781 1.2.2.2 skrll 782 1.2.2.2 skrll default: 783 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got a %u packet while in response stage!\n", dh->dh_type)); 784 1.2.2.2 skrll /* Force send reset. */ 785 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 786 1.2.2.2 skrll } 787 1.2.2.2 skrll } else if (dp->state == DCCPS_ESTAB) { 788 1.2.2.2 skrll switch (dh->dh_type) { 789 1.2.2.2 skrll 790 1.2.2.2 skrll case DCCP_TYPE_DATA: 791 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP DATA, state = %i, cc_in_use[1] = %u\n", dp->state, dp->cc_in_use[1])); 792 1.2.2.3 skrll 793 1.2.2.2 skrll if (dp->cc_in_use[1] > 0) { 794 1.2.2.2 skrll if (!dp->ack_snd) dp->ack_snd = dp->seq_rcv; 795 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Calling data *cc_sw[%u].cc_recv_packet_recv! %llx %llx dp=%x\n", dp->cc_in_use[1], dp->ack_snd, dp->seq_rcv, dp)); 796 1.2.2.2 skrll (*cc_sw[dp->cc_in_use[1]].cc_recv_packet_recv)(dp->cc_state[1], options, optlen); 797 1.2.2.2 skrll } 798 1.2.2.2 skrll break; 799 1.2.2.3 skrll 800 1.2.2.2 skrll case DCCP_TYPE_ACK: 801 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP ACK\n")); 802 1.2.2.2 skrll if (!is_shortseq) { 803 1.2.2.2 skrll DAHDR_TO_DSEQ(dp->ack_rcv, ((struct dccp_acklhdr*)dalh)->dash); 804 1.2.2.2 skrll } else { 805 1.2.2.2 skrll /* shortseq */ 806 1.2.2.2 skrll dp->ack_rcv = CONVERT_TO_LONGSEQ((ntohl(dah->dash.dah_ack) >> 8), dp->ref_seq); 807 1.2.2.3 skrll } 808 1.2.2.2 skrll 809 1.2.2.2 skrll if (dp->cc_in_use[1] > 0) { 810 1.2.2.2 skrll /* This is called so Acks on Acks can be handled */ 811 1.2.2.2 skrll if (!dp->ack_snd) dp->ack_snd = dp->seq_rcv; 812 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Calling ACK *cc_sw[%u].cc_recv_packet_recv! %llx %llx\n", dp->cc_in_use[1], dp->ack_snd, dp->seq_rcv)); 813 1.2.2.3 skrll (*cc_sw[dp->cc_in_use[1]].cc_recv_packet_recv)(dp->cc_state[1], options, optlen); 814 1.2.2.2 skrll } 815 1.2.2.2 skrll break; 816 1.2.2.3 skrll 817 1.2.2.2 skrll case DCCP_TYPE_DATAACK: 818 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP DATAACK\n")); 819 1.2.2.2 skrll 820 1.2.2.2 skrll if (!is_shortseq) { 821 1.2.2.2 skrll DAHDR_TO_DSEQ(dp->ack_rcv, ((struct dccp_acklhdr*)dalh)->dash); 822 1.2.2.2 skrll } else { 823 1.2.2.2 skrll /* shortseq */ 824 1.2.2.2 skrll dp->ack_rcv = CONVERT_TO_LONGSEQ((ntohl(dah->dash.dah_ack) >> 8), dp->ref_seq); 825 1.2.2.3 skrll } 826 1.2.2.2 skrll 827 1.2.2.2 skrll if (dp->cc_in_use[1] > 0) { 828 1.2.2.2 skrll if (!dp->ack_snd) dp->ack_snd = dp->seq_rcv; 829 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Calling *cc_sw[%u].cc_recv_packet_recv! %llx %llx\n", dp->cc_in_use[1], dp->ack_snd, dp->seq_rcv)); 830 1.2.2.3 skrll (*cc_sw[dp->cc_in_use[1]].cc_recv_packet_recv)(dp->cc_state[1], options, optlen); 831 1.2.2.2 skrll } 832 1.2.2.2 skrll break; 833 1.2.2.3 skrll 834 1.2.2.2 skrll case DCCP_TYPE_CLOSEREQ: 835 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP CLOSEREQ, state = estab\n")); 836 1.2.2.2 skrll if (dp->who == DCCP_CLIENT) { 837 1.2.2.2 skrll dccp_disconnect2(dp); 838 1.2.2.2 skrll } else { 839 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 840 1.2.2.2 skrll } 841 1.2.2.2 skrll break; 842 1.2.2.3 skrll 843 1.2.2.2 skrll case DCCP_TYPE_CLOSE: 844 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP CLOSE, state = estab\n")); 845 1.2.2.2 skrll dp->state = DCCPS_SERVER_CLOSE; /* So disconnect2 doesn't send CLOSEREQ */ 846 1.2.2.2 skrll dccp_disconnect2(dp); 847 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 848 1.2.2.2 skrll dccp_close(dp); 849 1.2.2.2 skrll goto badunlocked; 850 1.2.2.2 skrll break; 851 1.2.2.3 skrll 852 1.2.2.2 skrll case DCCP_TYPE_RESET: 853 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP RESET\n")); 854 1.2.2.2 skrll dp->state = DCCPS_TIME_WAIT; 855 1.2.2.2 skrll callout_stop(&dp->retrans_timer); 856 1.2.2.2 skrll callout_reset(&dp->timewait_timer, DCCP_TIMEWAIT_TIMER, 857 1.2.2.2 skrll dccp_timewait_t, dp); 858 1.2.2.2 skrll break; 859 1.2.2.3 skrll 860 1.2.2.2 skrll case DCCP_TYPE_MOVE: 861 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP MOVE\n")); 862 1.2.2.2 skrll break; 863 1.2.2.2 skrll 864 1.2.2.2 skrll default: 865 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got a %u packet while in established stage!\n", dh->dh_type)); 866 1.2.2.2 skrll } 867 1.2.2.2 skrll 868 1.2.2.2 skrll } else if (dp->state == DCCPS_SERVER_CLOSE) { 869 1.2.2.2 skrll /* Server */ 870 1.2.2.2 skrll switch (dh->dh_type) { 871 1.2.2.2 skrll case DCCP_TYPE_CLOSE: 872 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP CLOSE (State DCCPS_SERVER_CLOSE)\n")); 873 1.2.2.2 skrll callout_stop(&dp->retrans_timer); 874 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 875 1.2.2.2 skrll dp = dccp_close(dp); 876 1.2.2.2 skrll goto badunlocked; 877 1.2.2.2 skrll 878 1.2.2.2 skrll case DCCP_TYPE_RESET: 879 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP RESET\n")); 880 1.2.2.2 skrll callout_stop(&dp->retrans_timer); 881 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 882 1.2.2.2 skrll dp->state = DCCPS_TIME_WAIT; 883 1.2.2.2 skrll break; 884 1.2.2.2 skrll default: 885 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got a %u packet while in server_close stage!\n", dh->dh_type)); 886 1.2.2.2 skrll } 887 1.2.2.2 skrll 888 1.2.2.2 skrll } else if (dp->state == DCCPS_CLIENT_CLOSE) { 889 1.2.2.2 skrll /* Client */ 890 1.2.2.2 skrll switch (dh->dh_type) { 891 1.2.2.2 skrll case DCCP_TYPE_CLOSE: 892 1.2.2.2 skrll /* Ignore */ 893 1.2.2.2 skrll break; 894 1.2.2.2 skrll case DCCP_TYPE_CLOSEREQ: 895 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP CLOSEREQ, state = DCCPS_CLIENT_CLOSE\n")); 896 1.2.2.2 skrll /* Just resend close */ 897 1.2.2.2 skrll dccp_output(dp, 0); 898 1.2.2.2 skrll break; 899 1.2.2.2 skrll case DCCP_TYPE_RESET: 900 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP RESET\n")); 901 1.2.2.2 skrll callout_stop(&dp->retrans_timer); 902 1.2.2.2 skrll dp->state = DCCPS_TIME_WAIT; 903 1.2.2.2 skrll callout_reset(&dp->timewait_timer, DCCP_TIMEWAIT_TIMER, 904 1.2.2.2 skrll dccp_timewait_t, dp); 905 1.2.2.2 skrll break; 906 1.2.2.2 skrll default: 907 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got a %u packet while in client_close stage!\n", dh->dh_type)); 908 1.2.2.2 skrll 909 1.2.2.2 skrll } 910 1.2.2.2 skrll } else { 911 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got a %u packet while in %u state!\n", dh->dh_type, dp->state)); 912 1.2.2.2 skrll if (dh->dh_type != DCCP_TYPE_RESET) { 913 1.2.2.2 skrll /* Force send reset. */ 914 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Force sending a request!\n")); 915 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 916 1.2.2.2 skrll } 917 1.2.2.2 skrll } 918 1.2.2.2 skrll 919 1.2.2.2 skrll if (dh->dh_type == DCCP_TYPE_DATA || 920 1.2.2.2 skrll dh->dh_type == DCCP_TYPE_ACK || 921 1.2.2.2 skrll dh->dh_type == DCCP_TYPE_DATAACK) { 922 1.2.2.2 skrll if (dp->cc_in_use[0] > 0) { 923 1.2.2.2 skrll (*cc_sw[dp->cc_in_use[0]].cc_send_packet_recv)(dp->cc_state[0],options, optlen); 924 1.2.2.2 skrll } 925 1.2.2.3 skrll 926 1.2.2.2 skrll } 927 1.2.2.2 skrll 928 1.2.2.2 skrll if (dh->dh_type == DCCP_TYPE_DATA || dh->dh_type == DCCP_TYPE_DATAACK) { 929 1.2.2.2 skrll #if defined(__FreeBSD__) && __FreeBSD_version >= 503000 930 1.2.2.3 skrll if (so->so_rcv.sb_state & SBS_CANTRCVMORE) 931 1.2.2.2 skrll #else 932 1.2.2.3 skrll if (so->so_state & SS_CANTRCVMORE) 933 1.2.2.2 skrll #endif 934 1.2.2.2 skrll { 935 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "state & SS_CANTRCVMORE...!\n")); 936 1.2.2.2 skrll m_freem(m); 937 1.2.2.2 skrll if (opts) 938 1.2.2.2 skrll m_freem(opts); 939 1.2.2.2 skrll } else { 940 1.2.2.2 skrll m_adj(m, (iphlen + data_off)); 941 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Calling sbappend!\n")); 942 1.2.2.2 skrll sbappend(&so->so_rcv, m); 943 1.2.2.2 skrll } 944 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Calling sorwakeup...!\n")); 945 1.2.2.2 skrll sorwakeup(so); 946 1.2.2.2 skrll } else { 947 1.2.2.2 skrll m_freem(m); 948 1.2.2.2 skrll if (opts) 949 1.2.2.2 skrll m_freem(opts); 950 1.2.2.2 skrll } 951 1.2.2.2 skrll #if defined(__FreeBSD__) && __FreeBSD_version >= 500000 952 1.2.2.2 skrll if (dp) 953 1.2.2.2 skrll INP_UNLOCK(inp); 954 1.2.2.2 skrll #endif 955 1.2.2.2 skrll 956 1.2.2.2 skrll return; 957 1.2.2.2 skrll 958 1.2.2.2 skrll badunlocked: 959 1.2.2.2 skrll m_freem(m); 960 1.2.2.2 skrll if (opts) 961 1.2.2.2 skrll m_freem(opts); 962 1.2.2.2 skrll return; 963 1.2.2.2 skrll } 964 1.2.2.2 skrll 965 1.2.2.2 skrll /* 966 1.2.2.2 skrll * Notify a dccp user of an asynchronous error; 967 1.2.2.2 skrll * just wake up so that he can collect error status. 968 1.2.2.2 skrll */ 969 1.2.2.2 skrll void 970 1.2.2.2 skrll dccp_notify(struct inpcb *inp, int errno) 971 1.2.2.2 skrll { 972 1.2.2.2 skrll inp->inp_socket->so_error = errno; 973 1.2.2.2 skrll sorwakeup(inp->inp_socket); 974 1.2.2.2 skrll sowwakeup(inp->inp_socket); 975 1.2.2.2 skrll return; 976 1.2.2.2 skrll } 977 1.2.2.2 skrll 978 1.2.2.2 skrll /* 979 1.2.2.2 skrll * Called when we get ICMP errors (destination unrechable, 980 1.2.2.2 skrll * parameter problem, source quench, time exceeded and redirects) 981 1.2.2.2 skrll */ 982 1.2.2.2 skrll void * 983 1.2.2.2 skrll dccp_ctlinput(int cmd, const struct sockaddr *sa, void *vip) 984 1.2.2.2 skrll { 985 1.2.2.2 skrll struct ip *ip = vip; 986 1.2.2.2 skrll struct dccphdr *dh; 987 1.2.2.2 skrll void (*notify)(struct inpcb *, int) = dccp_notify; 988 1.2.2.2 skrll struct in_addr faddr; 989 1.2.2.2 skrll struct inpcb *inp = NULL; 990 1.2.2.2 skrll 991 1.2.2.2 skrll faddr = ((const struct sockaddr_in *)sa)->sin_addr; 992 1.2.2.2 skrll if (sa->sa_family != AF_INET || faddr.s_addr == INADDR_ANY) 993 1.2.2.2 skrll return NULL; 994 1.2.2.2 skrll 995 1.2.2.2 skrll if (PRC_IS_REDIRECT(cmd)) { 996 1.2.2.2 skrll ip = 0; 997 1.2.2.2 skrll notify = in_rtchange; 998 1.2.2.2 skrll } else if (cmd == PRC_HOSTDEAD) 999 1.2.2.2 skrll ip = 0; 1000 1.2.2.2 skrll else if ((unsigned)cmd >= PRC_NCMDS || inetctlerrmap[cmd] == 0) 1001 1.2.2.2 skrll return NULL; 1002 1.2.2.2 skrll if (ip) { 1003 1.2.2.2 skrll /*s = splsoftnet();*/ 1004 1.2.2.2 skrll dh = (struct dccphdr *)((vaddr_t)ip + (ip->ip_hl << 2)); 1005 1.2.2.2 skrll INP_INFO_RLOCK(&dccpbinfo); 1006 1.2.2.2 skrll in_pcbnotify(&dccpbtable, faddr, dh->dh_dport, 1007 1.2.2.3 skrll ip->ip_src, dh->dh_sport, inetctlerrmap[cmd], notify); 1008 1.2.2.2 skrll if (inp != NULL) { 1009 1.2.2.2 skrll INP_LOCK(inp); 1010 1.2.2.2 skrll if (inp->inp_socket != NULL) { 1011 1.2.2.2 skrll (*notify)(inp, inetctlerrmap[cmd]); 1012 1.2.2.2 skrll } 1013 1.2.2.2 skrll INP_UNLOCK(inp); 1014 1.2.2.2 skrll } 1015 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 1016 1.2.2.2 skrll /*splx(s);*/ 1017 1.2.2.2 skrll } else 1018 1.2.2.2 skrll in_pcbnotifyall(&dccpbtable, faddr, inetctlerrmap[cmd], notify); 1019 1.2.2.2 skrll 1020 1.2.2.2 skrll return NULL; 1021 1.2.2.2 skrll } 1022 1.2.2.2 skrll 1023 1.2.2.2 skrll static int 1024 1.2.2.2 skrll dccp_optsset(struct dccpcb *dp, struct sockopt *sopt) 1025 1.2.2.2 skrll { 1026 1.2.2.2 skrll int optval; 1027 1.2.2.2 skrll int error = 0; 1028 1.2.2.2 skrll 1029 1.2.2.2 skrll switch (sopt->sopt_name) { 1030 1.2.2.2 skrll case DCCP_CCID: 1031 1.2.2.2 skrll error = sockopt_getint(sopt, &optval); 1032 1.2.2.2 skrll /* Add check that optval is a CCID we support!!! */ 1033 1.2.2.2 skrll if (optval == 2 || optval == 3 || optval == 0) { 1034 1.2.2.2 skrll dp->pref_cc = optval; 1035 1.2.2.2 skrll } else { 1036 1.2.2.2 skrll error = EINVAL; 1037 1.2.2.2 skrll } 1038 1.2.2.2 skrll break; 1039 1.2.2.2 skrll case DCCP_CSLEN: 1040 1.2.2.2 skrll error = sockopt_getint(sopt, &optval); 1041 1.2.2.2 skrll if (optval > 15 || optval < 0) { 1042 1.2.2.2 skrll error = EINVAL; 1043 1.2.2.2 skrll } else { 1044 1.2.2.2 skrll dp->cslen = optval; 1045 1.2.2.2 skrll } 1046 1.2.2.2 skrll break; 1047 1.2.2.2 skrll case DCCP_MAXSEG: 1048 1.2.2.2 skrll error = sockopt_getint(sopt, &optval); 1049 1.2.2.2 skrll if (optval > 0 && optval <= dp->d_maxseg) { 1050 1.2.2.2 skrll dp->d_maxseg = optval; 1051 1.2.2.2 skrll } else { 1052 1.2.2.2 skrll error = EINVAL; 1053 1.2.2.2 skrll } 1054 1.2.2.2 skrll break; 1055 1.2.2.2 skrll case DCCP_SERVICE: 1056 1.2.2.2 skrll error = sockopt_getint(sopt, &optval); 1057 1.2.2.2 skrll dp->scode = optval; 1058 1.2.2.2 skrll break; 1059 1.2.2.3 skrll 1060 1.2.2.2 skrll default: 1061 1.2.2.2 skrll error = ENOPROTOOPT; 1062 1.2.2.2 skrll } 1063 1.2.2.2 skrll 1064 1.2.2.2 skrll return error; 1065 1.2.2.2 skrll } 1066 1.2.2.2 skrll 1067 1.2.2.3 skrll static int 1068 1.2.2.2 skrll dccp_optsget(struct dccpcb *dp, struct sockopt *sopt) 1069 1.2.2.2 skrll { 1070 1.2.2.2 skrll int optval = 0; 1071 1.2.2.2 skrll int error = 0; 1072 1.2.2.2 skrll 1073 1.2.2.2 skrll switch (sopt->sopt_name) { 1074 1.2.2.2 skrll case DCCP_CCID: 1075 1.2.2.2 skrll optval = dp->pref_cc; 1076 1.2.2.2 skrll error = sockopt_set(sopt, &optval, sizeof(optval)); 1077 1.2.2.2 skrll break; 1078 1.2.2.2 skrll case DCCP_CSLEN: 1079 1.2.2.2 skrll optval = dp->cslen; 1080 1.2.2.2 skrll error = sockopt_set(sopt, &optval, sizeof(optval)); 1081 1.2.2.2 skrll break; 1082 1.2.2.2 skrll case DCCP_MAXSEG: 1083 1.2.2.2 skrll optval = dp->d_maxseg; 1084 1.2.2.2 skrll error = sockopt_set(sopt, &optval, sizeof(optval)); 1085 1.2.2.2 skrll break; 1086 1.2.2.2 skrll case DCCP_SERVICE: 1087 1.2.2.2 skrll optval = dp->scode; 1088 1.2.2.2 skrll error = sockopt_set(sopt, &optval, sizeof(optval)); 1089 1.2.2.2 skrll break; 1090 1.2.2.2 skrll default: 1091 1.2.2.2 skrll error = ENOPROTOOPT; 1092 1.2.2.2 skrll } 1093 1.2.2.2 skrll 1094 1.2.2.2 skrll return error; 1095 1.2.2.2 skrll } 1096 1.2.2.2 skrll 1097 1.2.2.3 skrll /* 1098 1.2.2.2 skrll * Called by getsockopt and setsockopt. 1099 1.2.2.2 skrll * 1100 1.2.2.2 skrll */ 1101 1.2.2.2 skrll int 1102 1.2.2.2 skrll dccp_ctloutput(int op, struct socket *so, struct sockopt *sopt) 1103 1.2.2.2 skrll { 1104 1.2.2.2 skrll int s, error = 0; 1105 1.2.2.2 skrll struct inpcb *inp; 1106 1.2.2.2 skrll #if defined(INET6) 1107 1.2.2.2 skrll struct in6pcb *in6p; 1108 1.2.2.2 skrll #endif 1109 1.2.2.2 skrll struct dccpcb *dp; 1110 1.2.2.2 skrll int family; /* family of the socket */ 1111 1.2.2.2 skrll 1112 1.2.2.2 skrll family = so->so_proto->pr_domain->dom_family; 1113 1.2.2.2 skrll error = 0; 1114 1.2.2.2 skrll 1115 1.2.2.2 skrll s = splsoftnet(); 1116 1.2.2.2 skrll INP_INFO_RLOCK(&dccpbinfo); 1117 1.2.2.2 skrll switch (family) { 1118 1.2.2.2 skrll case PF_INET: 1119 1.2.2.2 skrll inp = sotoinpcb(so); 1120 1.2.2.2 skrll #if defined(INET6) 1121 1.2.2.2 skrll in6p = NULL; 1122 1.2.2.2 skrll #endif 1123 1.2.2.2 skrll break; 1124 1.2.2.2 skrll #if defined(INET6) 1125 1.2.2.2 skrll case PF_INET6: 1126 1.2.2.2 skrll inp = NULL; 1127 1.2.2.2 skrll in6p = sotoin6pcb(so); 1128 1.2.2.2 skrll break; 1129 1.2.2.2 skrll #endif 1130 1.2.2.2 skrll default: 1131 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 1132 1.2.2.2 skrll splx(s); 1133 1.2.2.2 skrll return EAFNOSUPPORT; 1134 1.2.2.2 skrll } 1135 1.2.2.2 skrll #if defined(INET6) 1136 1.2.2.2 skrll if (inp == NULL && in6p == NULL) 1137 1.2.2.2 skrll #else 1138 1.2.2.2 skrll if (inp == NULL) 1139 1.2.2.2 skrll #endif 1140 1.2.2.2 skrll { 1141 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 1142 1.2.2.2 skrll splx(s); 1143 1.2.2.2 skrll return (ECONNRESET); 1144 1.2.2.2 skrll } 1145 1.2.2.2 skrll /* 1146 1.2.2.2 skrll if (inp) 1147 1.2.2.2 skrll INP_LOCK(inp); 1148 1.2.2.2 skrll else 1149 1.2.2.2 skrll IN6P_LOCK(in6p); 1150 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 1151 1.2.2.2 skrll */ 1152 1.2.2.2 skrll if (sopt->sopt_level != IPPROTO_DCCP) { 1153 1.2.2.2 skrll switch (family) { 1154 1.2.2.2 skrll case PF_INET: 1155 1.2.2.2 skrll error = ip_ctloutput(op, so, sopt); 1156 1.2.2.2 skrll break; 1157 1.2.2.2 skrll #if defined(INET6) 1158 1.2.2.2 skrll case PF_INET6: 1159 1.2.2.2 skrll error = ip6_ctloutput(op, so, sopt); 1160 1.2.2.2 skrll break; 1161 1.2.2.2 skrll #endif 1162 1.2.2.2 skrll } 1163 1.2.2.2 skrll splx(s); 1164 1.2.2.2 skrll return (error); 1165 1.2.2.2 skrll } 1166 1.2.2.2 skrll 1167 1.2.2.2 skrll if (inp) 1168 1.2.2.2 skrll dp = intodccpcb(inp); 1169 1.2.2.2 skrll #if defined(INET6) 1170 1.2.2.2 skrll else if (in6p) 1171 1.2.2.2 skrll dp = in6todccpcb(in6p); 1172 1.2.2.2 skrll #endif 1173 1.2.2.2 skrll else 1174 1.2.2.2 skrll dp = NULL; 1175 1.2.2.2 skrll 1176 1.2.2.2 skrll if (op == PRCO_SETOPT) { 1177 1.2.2.2 skrll error = dccp_optsset(dp, sopt); 1178 1.2.2.2 skrll } else if (op == PRCO_GETOPT) { 1179 1.2.2.2 skrll error = dccp_optsget(dp, sopt); 1180 1.2.2.2 skrll } else { 1181 1.2.2.2 skrll error = EINVAL; 1182 1.2.2.2 skrll } 1183 1.2.2.2 skrll /* 1184 1.2.2.2 skrll if (inp) 1185 1.2.2.2 skrll INP_UNLOCK(inp); 1186 1.2.2.2 skrll else 1187 1.2.2.2 skrll IN6P_UNLOCK(in6p); 1188 1.2.2.2 skrll */ 1189 1.2.2.2 skrll splx(s); 1190 1.2.2.2 skrll return error; 1191 1.2.2.2 skrll } 1192 1.2.2.2 skrll 1193 1.2.2.2 skrll int 1194 1.2.2.2 skrll dccp_output(struct dccpcb *dp, u_int8_t extra) 1195 1.2.2.2 skrll { 1196 1.2.2.2 skrll struct inpcb *inp; 1197 1.2.2.2 skrll struct in6pcb *in6p = NULL; 1198 1.2.2.2 skrll struct socket *so; 1199 1.2.2.2 skrll struct mbuf *m; 1200 1.2.2.2 skrll 1201 1.2.2.2 skrll struct ip *ip = NULL; 1202 1.2.2.2 skrll struct dccphdr *dh; 1203 1.2.2.2 skrll struct dccplhdr *dlh; 1204 1.2.2.2 skrll struct dccp_requesthdr *drqh; 1205 1.2.2.2 skrll struct dccp_ackhdr *dah; 1206 1.2.2.2 skrll struct dccp_acklhdr *dalh; 1207 1.2.2.2 skrll struct dccp_resethdr *drth; 1208 1.2.2.2 skrll u_char *optp = NULL; 1209 1.2.2.2 skrll int error = 0; 1210 1.2.2.2 skrll int off, sendalot, t, i; 1211 1.2.2.2 skrll u_int32_t hdrlen, optlen, extrah_len, cslen; 1212 1.2.2.2 skrll u_int8_t type; 1213 1.2.2.2 skrll char options[DCCP_MAX_OPTIONS *2]; 1214 1.2.2.2 skrll long len, pktlen; 1215 1.2.2.2 skrll int isipv6 = 0; 1216 1.2.2.2 skrll int use_shortseq = 0; 1217 1.2.2.2 skrll #ifdef INET6 1218 1.2.2.2 skrll struct ip6_hdr *ip6 = NULL; 1219 1.2.2.2 skrll #endif 1220 1.2.2.2 skrll 1221 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "dccp_output start!\n")); 1222 1.2.2.2 skrll 1223 1.2.2.2 skrll isipv6 = (dp->inp_vflag & INP_IPV6) != 0; 1224 1.2.2.2 skrll 1225 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Going to send a DCCP packet!\n")); 1226 1.2.2.2 skrll #if defined(__FreeBSD__) && __FreeBSD_version >= 500000 1227 1.2.2.2 skrll KASSERT(mutex_assert(&dp->d_inpcb->inp_mtx, MA_OWNED)); 1228 1.2.2.2 skrll #endif 1229 1.2.2.2 skrll 1230 1.2.2.2 skrll #if defined(INET6) 1231 1.2.2.2 skrll if (isipv6) { 1232 1.2.2.2 skrll inp = 0; 1233 1.2.2.2 skrll in6p = dp->d_in6pcb; 1234 1.2.2.2 skrll so = in6p->in6p_socket; 1235 1.2.2.2 skrll } else 1236 1.2.2.2 skrll #endif 1237 1.2.2.2 skrll { 1238 1.2.2.2 skrll inp = dp->d_inpcb; 1239 1.2.2.2 skrll so = inp->inp_socket; 1240 1.2.2.2 skrll } 1241 1.2.2.2 skrll 1242 1.2.2.2 skrll if (dp->state != DCCPS_ESTAB && extra == 1) { 1243 1.2.2.2 skrll /* Only let cc decide when to resend if we are in establised state */ 1244 1.2.2.2 skrll return 0; 1245 1.2.2.2 skrll } 1246 1.2.2.2 skrll 1247 1.2.2.2 skrll if (so->so_snd.sb_cc){ 1248 1.2.2.2 skrll pktlen = dp->pktlen[dp->pktlenidx]; 1249 1.2.2.3 skrll } else 1250 1.2.2.2 skrll pktlen = 0; 1251 1.2.2.2 skrll 1252 1.2.2.2 skrll /* Check with CC if we can send... */ 1253 1.2.2.2 skrll if (pktlen && dp->cc_in_use[0] > 0 && dp->state == DCCPS_ESTAB) { 1254 1.2.2.2 skrll if (!(*cc_sw[dp->cc_in_use[0]].cc_send_packet)(dp->cc_state[0], pktlen)) { 1255 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Not allowed to send right now\n")); 1256 1.2.2.2 skrll return 0; 1257 1.2.2.2 skrll } 1258 1.2.2.2 skrll } 1259 1.2.2.2 skrll 1260 1.2.2.2 skrll if (pktlen) { 1261 1.2.2.2 skrll dp->pktcnt --; 1262 1.2.2.3 skrll dp->pktlenidx = (dp->pktlenidx +1) % DCCP_MAX_PKTS; 1263 1.2.2.2 skrll } 1264 1.2.2.2 skrll 1265 1.2.2.2 skrll again: 1266 1.2.2.2 skrll sendalot = 0; 1267 1.2.2.2 skrll 1268 1.2.2.2 skrll /* 1269 1.2.2.2 skrll * off not needed for dccp because we do not need to wait for ACK 1270 1.2.2.2 skrll * before removing the packet 1271 1.2.2.2 skrll */ 1272 1.2.2.2 skrll off = 0; 1273 1.2.2.2 skrll optlen = 0; 1274 1.2.2.2 skrll 1275 1.2.2.2 skrll if (pktlen > dp->d_maxseg) { 1276 1.2.2.2 skrll /* this should not happen */ 1277 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "packet will be fragmented! maxseg %d\n", dp->d_maxseg)); 1278 1.2.2.2 skrll len = dp->d_maxseg; 1279 1.2.2.2 skrll pktlen -= len; 1280 1.2.2.2 skrll sendalot = 1; 1281 1.2.2.2 skrll } else 1282 1.2.2.2 skrll len = pktlen; 1283 1.2.2.2 skrll 1284 1.2.2.2 skrll if (extra == DCCP_TYPE_RESET + 2) { 1285 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Force sending of DCCP TYPE_RESET! seq=%llu\n", dp->seq_snd)); 1286 1.2.2.2 skrll type = DCCP_TYPE_RESET; 1287 1.2.2.3 skrll extrah_len = 12; 1288 1.2.2.2 skrll } else if (dp->state <= DCCPS_REQUEST && dp->who == DCCP_CLIENT) { 1289 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Sending DCCP TYPE_REQUEST!\n")); 1290 1.2.2.2 skrll type = DCCP_TYPE_REQUEST; 1291 1.2.2.2 skrll dp->state = DCCPS_REQUEST; 1292 1.2.2.3 skrll extrah_len = 4; 1293 1.2.2.2 skrll } else if (dp->state == DCCPS_REQUEST && dp->who == DCCP_SERVER) { 1294 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Sending DCCP TYPE_RESPONSE!\n")); 1295 1.2.2.2 skrll type = DCCP_TYPE_RESPONSE; 1296 1.2.2.2 skrll dp->state = DCCPS_RESPOND; 1297 1.2.2.3 skrll extrah_len = 12; 1298 1.2.2.2 skrll } else if (dp->state == DCCPS_RESPOND) { 1299 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Still in feature neg, sending DCCP TYPE_ACK!\n")); 1300 1.2.2.2 skrll type = DCCP_TYPE_ACK; 1301 1.2.2.2 skrll if (!dp->shortseq) 1302 1.2.2.2 skrll extrah_len = 8; 1303 1.2.2.2 skrll else { 1304 1.2.2.2 skrll extrah_len = 4; 1305 1.2.2.2 skrll use_shortseq = 1; 1306 1.2.2.2 skrll } 1307 1.2.2.2 skrll } else if (dp->state == DCCPS_ESTAB) { 1308 1.2.2.2 skrll if (dp->ack_snd && len) { 1309 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Sending DCCP TYPE_DATAACK!\n")); 1310 1.2.2.2 skrll type = DCCP_TYPE_DATAACK; 1311 1.2.2.2 skrll /*(u_int32_t *)&extrah = dp->seq_rcv; */ 1312 1.2.2.2 skrll if (!dp->shortseq) 1313 1.2.2.2 skrll extrah_len = 8; 1314 1.2.2.2 skrll else { 1315 1.2.2.2 skrll extrah_len = 4; 1316 1.2.2.2 skrll use_shortseq = 1; 1317 1.2.2.2 skrll } 1318 1.2.2.2 skrll } else if (dp->ack_snd) { 1319 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Sending DCCP TYPE_ACK!\n")); 1320 1.2.2.2 skrll type = DCCP_TYPE_ACK; 1321 1.2.2.2 skrll if (!dp->shortseq) 1322 1.2.2.2 skrll extrah_len = 8; 1323 1.2.2.2 skrll else { 1324 1.2.2.2 skrll extrah_len = 4; 1325 1.2.2.2 skrll use_shortseq = 1; 1326 1.2.2.2 skrll } 1327 1.2.2.2 skrll } else if (len) { 1328 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Sending DCCP TYPE_DATA!\n")); 1329 1.2.2.2 skrll type = DCCP_TYPE_DATA; 1330 1.2.2.2 skrll extrah_len = 0; 1331 1.2.2.2 skrll } else { 1332 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "No ack or data to send!\n")); 1333 1.2.2.2 skrll return 0; 1334 1.2.2.2 skrll } 1335 1.2.2.2 skrll } else if (dp->state == DCCPS_CLIENT_CLOSE) { 1336 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Sending DCCP TYPE_CLOSE!\n")); 1337 1.2.2.2 skrll type = DCCP_TYPE_CLOSE; 1338 1.2.2.2 skrll extrah_len = 8; 1339 1.2.2.2 skrll } else if (dp->state == DCCPS_SERVER_CLOSE) { 1340 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Sending DCCP TYPE_CLOSEREQ!\n")); 1341 1.2.2.2 skrll type = DCCP_TYPE_CLOSEREQ; 1342 1.2.2.2 skrll extrah_len = 8; 1343 1.2.2.2 skrll } else { 1344 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Hey, we should never get here, state = %u\n", dp->state)); 1345 1.2.2.2 skrll return 1; 1346 1.2.2.2 skrll } 1347 1.2.2.2 skrll 1348 1.2.2.2 skrll /* Adding options. */ 1349 1.2.2.2 skrll if (dp->optlen) { 1350 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Copying options from dp->options! %u\n", dp->optlen)); 1351 1.2.2.2 skrll bcopy(dp->options, options , dp->optlen); 1352 1.2.2.2 skrll optlen = dp->optlen; 1353 1.2.2.2 skrll dp->optlen = 0; 1354 1.2.2.2 skrll } 1355 1.2.2.2 skrll 1356 1.2.2.2 skrll if (dp->featlen && (optlen + dp->featlen < DCCP_MAX_OPTIONS)) { 1357 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Copying options from dp->features! %u\n", dp->featlen)); 1358 1.2.2.2 skrll bcopy(dp->features, options + optlen, dp->featlen); 1359 1.2.2.2 skrll optlen += dp->featlen; 1360 1.2.2.2 skrll } 1361 1.2.2.2 skrll 1362 1.2.2.2 skrll t = optlen % 4; 1363 1.2.2.2 skrll 1364 1.2.2.2 skrll if (t) { 1365 1.2.2.2 skrll t = 4 - t; 1366 1.2.2.2 skrll for (i = 0 ; i<t; i++) { 1367 1.2.2.2 skrll options[optlen] = 0; 1368 1.2.2.2 skrll optlen++; 1369 1.2.2.2 skrll } 1370 1.2.2.2 skrll } 1371 1.2.2.2 skrll 1372 1.2.2.2 skrll #ifdef INET6 1373 1.2.2.2 skrll if (isipv6) { 1374 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Sending ipv6 packet...\n")); 1375 1.2.2.2 skrll if (!use_shortseq) 1376 1.2.2.2 skrll hdrlen = sizeof(struct ip6_hdr) + sizeof(struct dccplhdr) + 1377 1.2.2.2 skrll extrah_len + optlen; 1378 1.2.2.3 skrll else 1379 1.2.2.2 skrll hdrlen = sizeof(struct ip6_hdr) + sizeof(struct dccphdr) + 1380 1.2.2.2 skrll extrah_len + optlen; 1381 1.2.2.2 skrll } else 1382 1.2.2.2 skrll #endif 1383 1.2.2.2 skrll { 1384 1.2.2.2 skrll if (!use_shortseq) 1385 1.2.2.2 skrll hdrlen = sizeof(struct ip) + sizeof(struct dccplhdr) + 1386 1.2.2.2 skrll extrah_len + optlen; 1387 1.2.2.2 skrll else 1388 1.2.2.2 skrll hdrlen = sizeof(struct ip) + sizeof(struct dccphdr) + 1389 1.2.2.2 skrll extrah_len + optlen; 1390 1.2.2.2 skrll } 1391 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Pkt headerlen %u\n", hdrlen)); 1392 1.2.2.2 skrll 1393 1.2.2.2 skrll if (len > (dp->d_maxseg - extrah_len - optlen)) { 1394 1.2.2.2 skrll len = dp->d_maxseg - extrah_len - optlen; 1395 1.2.2.2 skrll sendalot = 1; 1396 1.2.2.2 skrll } 1397 1.2.2.3 skrll 1398 1.2.2.2 skrll MGETHDR(m, M_DONTWAIT, MT_HEADER); 1399 1.2.2.2 skrll if (m == NULL) { 1400 1.2.2.2 skrll error = ENOBUFS; 1401 1.2.2.2 skrll goto release; 1402 1.2.2.2 skrll } 1403 1.2.2.2 skrll if (MHLEN < hdrlen + max_linkhdr) { 1404 1.2.2.2 skrll MCLGET(m, M_DONTWAIT); 1405 1.2.2.2 skrll if ((m->m_flags & M_EXT) == 0) { 1406 1.2.2.2 skrll error = ENOBUFS; 1407 1.2.2.2 skrll goto release; 1408 1.2.2.2 skrll } 1409 1.2.2.2 skrll } 1410 1.2.2.2 skrll 1411 1.2.2.2 skrll m->m_data += max_linkhdr; 1412 1.2.2.2 skrll m->m_len = hdrlen; 1413 1.2.2.2 skrll 1414 1.2.2.2 skrll if (len) { /* We have data to send */ 1415 1.2.2.2 skrll if (len <= M_TRAILINGSPACE(m) - hdrlen) { 1416 1.2.2.2 skrll m_copydata(so->so_snd.sb_mb, off, (int) len, 1417 1.2.2.2 skrll mtod(m, char *) + hdrlen); 1418 1.2.2.2 skrll m->m_len += len; 1419 1.2.2.2 skrll } else { 1420 1.2.2.2 skrll m->m_next = m_copy(so->so_snd.sb_mb, off, (int) len); 1421 1.2.2.2 skrll if (m->m_next == 0) { 1422 1.2.2.2 skrll error = ENOBUFS; 1423 1.2.2.2 skrll goto release; 1424 1.2.2.2 skrll } 1425 1.2.2.2 skrll } 1426 1.2.2.2 skrll } else { 1427 1.2.2.2 skrll dp->ndp++; 1428 1.2.2.2 skrll } 1429 1.2.2.2 skrll 1430 1.2.2.5 skrll m_reset_rcvif(m); 1431 1.2.2.2 skrll 1432 1.2.2.2 skrll if (!isipv6 && (len + hdrlen) > IP_MAXPACKET) { 1433 1.2.2.2 skrll error = EMSGSIZE; 1434 1.2.2.2 skrll goto release; 1435 1.2.2.2 skrll } 1436 1.2.2.2 skrll 1437 1.2.2.2 skrll /* 1438 1.2.2.2 skrll * Fill in mbuf with extended DCCP header 1439 1.2.2.2 skrll * and addresses and length put into network format. 1440 1.2.2.2 skrll */ 1441 1.2.2.2 skrll #ifdef INET6 1442 1.2.2.2 skrll if (isipv6) { 1443 1.2.2.2 skrll ip6 = mtod(m, struct ip6_hdr *); 1444 1.2.2.2 skrll dh = (struct dccphdr *)(ip6 + 1); 1445 1.2.2.2 skrll ip6->ip6_flow = (ip6->ip6_flow & ~IPV6_FLOWINFO_MASK) | 1446 1.2.2.2 skrll (in6p->in6p_flowinfo & IPV6_FLOWINFO_MASK); 1447 1.2.2.2 skrll ip6->ip6_vfc = (ip6->ip6_vfc & ~IPV6_VERSION_MASK) | 1448 1.2.2.2 skrll (IPV6_VERSION & IPV6_VERSION_MASK); 1449 1.2.2.2 skrll ip6->ip6_nxt = IPPROTO_DCCP; 1450 1.2.2.2 skrll ip6->ip6_src = in6p->in6p_laddr; 1451 1.2.2.2 skrll ip6->ip6_dst = in6p->in6p_faddr; 1452 1.2.2.3 skrll } else 1453 1.2.2.2 skrll #endif 1454 1.2.2.2 skrll { 1455 1.2.2.2 skrll ip = mtod(m, struct ip *); 1456 1.2.2.2 skrll dh = (struct dccphdr *)(ip + 1); 1457 1.2.2.2 skrll bzero(ip, sizeof(struct ip)); 1458 1.2.2.2 skrll ip->ip_p = IPPROTO_DCCP; 1459 1.2.2.2 skrll ip->ip_src = inp->inp_laddr; 1460 1.2.2.2 skrll ip->ip_dst = inp->inp_faddr; 1461 1.2.2.2 skrll } 1462 1.2.2.2 skrll dlh = (struct dccplhdr *)dh; 1463 1.2.2.2 skrll 1464 1.2.2.2 skrll if (inp) { 1465 1.2.2.2 skrll dh->dh_sport = inp->inp_lport; 1466 1.2.2.2 skrll dh->dh_dport = inp->inp_fport; 1467 1.2.2.2 skrll } 1468 1.2.2.2 skrll #ifdef INET6 1469 1.2.2.2 skrll else if (in6p) { 1470 1.2.2.2 skrll dh->dh_sport = in6p->in6p_lport; 1471 1.2.2.2 skrll dh->dh_dport = in6p->in6p_fport; 1472 1.2.2.2 skrll } 1473 1.2.2.2 skrll #endif 1474 1.2.2.2 skrll dh->dh_cscov = dp->cslen; 1475 1.2.2.2 skrll dh->dh_ccval = dp->ccval; 1476 1.2.2.2 skrll dh->dh_type = type; 1477 1.2.2.2 skrll dh->dh_res = 0; /* Reserved field should be zero */ 1478 1.2.2.3 skrll if (!use_shortseq) { 1479 1.2.2.2 skrll dlh->dh_res2 = 0; /* Reserved field should be zero */ 1480 1.2.2.2 skrll dh->dh_off = 4 + (extrah_len / 4) + (optlen / 4); 1481 1.2.2.3 skrll } else 1482 1.2.2.2 skrll dh->dh_off = 3 + (extrah_len / 4) + (optlen / 4); 1483 1.2.2.2 skrll 1484 1.2.2.2 skrll dp->seq_snd = (dp->seq_snd +1) % 281474976710656LL; 1485 1.2.2.3 skrll if (!use_shortseq) { 1486 1.2.2.2 skrll DSEQ_TO_DHDR(dlh, dp->seq_snd); 1487 1.2.2.2 skrll dlh->dh_x = 1; 1488 1.2.2.2 skrll } else { 1489 1.2.2.2 skrll /* short sequene number */ 1490 1.2.2.2 skrll dh->dh_seq = htonl(dp->seq_snd) >> 8; 1491 1.2.2.2 skrll dh->dh_x = 0; 1492 1.2.2.3 skrll } 1493 1.2.2.2 skrll 1494 1.2.2.2 skrll if (!use_shortseq) { 1495 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Sending with seq %x.%x, (dp->seq_snd = %llu)\n\n", dlh->dh_seq, dlh->dh_seq2, dp->seq_snd)); 1496 1.2.2.2 skrll } else { 1497 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Sending with seq %x, (dp->seq_snd = %llu)\n\n", dh->dh_seq, dp->seq_snd)); 1498 1.2.2.2 skrll } 1499 1.2.2.2 skrll 1500 1.2.2.2 skrll if (dh->dh_type == DCCP_TYPE_REQUEST) { 1501 1.2.2.2 skrll drqh = (struct dccp_requesthdr *)(dlh + 1); 1502 1.2.2.2 skrll drqh->drqh_scode = dp->scode; 1503 1.2.2.2 skrll optp = (u_char *)(drqh + 1); 1504 1.2.2.2 skrll } else if (dh->dh_type == DCCP_TYPE_RESET) { 1505 1.2.2.2 skrll drth = (struct dccp_resethdr *)(dlh + 1); 1506 1.2.2.2 skrll drth->drth_dash.dah_res = 0; 1507 1.2.2.2 skrll DSEQ_TO_DAHDR(drth->drth_dash, dp->seq_rcv); 1508 1.2.2.5 skrll if (dp->state == DCCPS_SERVER_CLOSE) 1509 1.2.2.3 skrll drth->drth_reason = 1; 1510 1.2.2.2 skrll else 1511 1.2.2.3 skrll drth->drth_reason = 2; 1512 1.2.2.2 skrll drth->drth_data1 = 0; 1513 1.2.2.2 skrll drth->drth_data2 = 0; 1514 1.2.2.2 skrll drth->drth_data3 = 0; 1515 1.2.2.2 skrll optp = (u_char *)(drth + 1); 1516 1.2.2.2 skrll } else if (extrah_len) { 1517 1.2.2.2 skrll if (!use_shortseq){ 1518 1.2.2.2 skrll dalh = (struct dccp_acklhdr *)(dlh + 1); 1519 1.2.2.2 skrll dalh->dash.dah_res = 0; /* Reserved field should be zero */ 1520 1.2.2.2 skrll 1521 1.2.2.2 skrll if (dp->state == DCCPS_ESTAB) { 1522 1.2.2.2 skrll DSEQ_TO_DAHDR(dalh->dash, dp->ack_snd); 1523 1.2.2.2 skrll dp->ack_snd = 0; 1524 1.2.2.2 skrll } else { 1525 1.2.2.2 skrll DSEQ_TO_DAHDR(dalh->dash, dp->seq_rcv); 1526 1.2.2.2 skrll } 1527 1.2.2.2 skrll 1528 1.2.2.2 skrll if (dh->dh_type == DCCP_TYPE_RESPONSE) { 1529 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Sending dccp type response\n")); 1530 1.2.2.2 skrll drqh = (struct dccp_requesthdr *)(dalh + 1); 1531 1.2.2.3 skrll drqh->drqh_scode = dp->scode; 1532 1.2.2.2 skrll optp = (u_char *)(drqh + 1); 1533 1.2.2.3 skrll } else 1534 1.2.2.2 skrll optp = (u_char *)(dalh + 1); 1535 1.2.2.2 skrll } else { 1536 1.2.2.2 skrll /* XXX shortseq */ 1537 1.2.2.2 skrll dah = (struct dccp_ackhdr *)(dh + 1); 1538 1.2.2.2 skrll dah->dash.dah_res = 0; /* Reserved field should be zero */ 1539 1.2.2.2 skrll dah->dash.dah_ack = htonl(dp->seq_rcv) >> 8; 1540 1.2.2.2 skrll optp = (u_char *)(dah + 1); 1541 1.2.2.2 skrll } 1542 1.2.2.3 skrll 1543 1.2.2.2 skrll } else { 1544 1.2.2.2 skrll optp = (u_char *)(dlh + 1); 1545 1.2.2.2 skrll } 1546 1.2.2.2 skrll 1547 1.2.2.2 skrll if (optlen) 1548 1.2.2.2 skrll bcopy(options, optp, optlen); 1549 1.2.2.2 skrll 1550 1.2.2.2 skrll m->m_pkthdr.len = hdrlen + len; 1551 1.2.2.2 skrll 1552 1.2.2.2 skrll if (dh->dh_cscov == 0) { 1553 1.2.2.2 skrll #ifdef INET6 1554 1.2.2.2 skrll if (isipv6) 1555 1.2.2.2 skrll cslen = (hdrlen - sizeof(struct ip6_hdr)) + len; 1556 1.2.2.2 skrll else 1557 1.2.2.2 skrll cslen = (hdrlen - sizeof(struct ip)) + len; 1558 1.2.2.2 skrll #else 1559 1.2.2.2 skrll cslen = (hdrlen - sizeof(struct ip)) + len; 1560 1.2.2.2 skrll #endif 1561 1.2.2.2 skrll } else { 1562 1.2.2.2 skrll cslen = dh->dh_off * 4 + (dh->dh_cscov - 1) * 4; 1563 1.2.2.2 skrll #ifdef INET6 1564 1.2.2.2 skrll if (isipv6) { 1565 1.2.2.2 skrll if (cslen > (hdrlen - sizeof(struct ip6_hdr)) + len) 1566 1.2.2.2 skrll cslen = (hdrlen - sizeof(struct ip6_hdr)) + len; 1567 1.2.2.2 skrll } else { 1568 1.2.2.2 skrll if (cslen > (hdrlen - sizeof(struct ip)) + len) 1569 1.2.2.2 skrll cslen = (hdrlen - sizeof(struct ip)) + len; 1570 1.2.2.2 skrll } 1571 1.2.2.2 skrll #else 1572 1.2.2.2 skrll if (cslen > (hdrlen - sizeof(struct ip)) + len) 1573 1.2.2.2 skrll cslen = (hdrlen - sizeof(struct ip)) + len; 1574 1.2.2.2 skrll #endif 1575 1.2.2.2 skrll } 1576 1.2.2.2 skrll 1577 1.2.2.2 skrll /* 1578 1.2.2.3 skrll * Set up checksum 1579 1.2.2.2 skrll */ 1580 1.2.2.2 skrll #ifdef __FreeBSD__ 1581 1.2.2.2 skrll m->m_pkthdr.csum_flags = CSUM_IP; /* Do not allow the network card to calculate the checksum */ 1582 1.2.2.2 skrll #elif defined(__NetBSD__) 1583 1.2.2.2 skrll m->m_pkthdr.csum_flags = 0; 1584 1.2.2.2 skrll #else 1585 1.2.2.2 skrll m->m_pkthdr.csum = 0; 1586 1.2.2.2 skrll #endif 1587 1.2.2.2 skrll 1588 1.2.2.2 skrll dh->dh_sum = 0; 1589 1.2.2.2 skrll #ifdef INET6 1590 1.2.2.2 skrll if (isipv6) { 1591 1.2.2.2 skrll dh->dh_sum = in6_cksum(m, IPPROTO_DCCP, sizeof(struct ip6_hdr), 1592 1.2.2.2 skrll cslen); 1593 1.2.2.2 skrll } else 1594 1.2.2.2 skrll #endif 1595 1.2.2.2 skrll { 1596 1.2.2.2 skrll ip->ip_len = htons(hdrlen + len); 1597 1.2.2.2 skrll ip->ip_ttl = dp->inp_ip_ttl; /* XXX */ 1598 1.2.2.2 skrll ip->ip_tos = dp->inp_ip_tos; /* XXX */ 1599 1.2.2.2 skrll 1600 1.2.2.2 skrll dh->dh_sum = in4_cksum(m, IPPROTO_DCCP, sizeof(struct ip), 1601 1.2.2.2 skrll cslen); 1602 1.2.2.2 skrll #ifndef __OpenBSD__ 1603 1.2.2.2 skrll m->m_pkthdr.csum_data = offsetof(struct dccphdr, dh_sum); 1604 1.2.2.2 skrll #endif 1605 1.2.2.2 skrll } 1606 1.2.2.2 skrll 1607 1.2.2.2 skrll dccpstat.dccps_opackets++; 1608 1.2.2.2 skrll dccpstat.dccps_obytes += m->m_pkthdr.len; 1609 1.2.2.2 skrll 1610 1.2.2.2 skrll #ifdef INET6 1611 1.2.2.2 skrll if (isipv6) { 1612 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Calling ip_output6, mbuf->m_len = %u, mbuf->m_pkthdr.len = %u\n", m->m_len, m->m_pkthdr.len)); 1613 1.2.2.2 skrll 1614 1.2.2.2 skrll error = ip6_output(m, in6p->in6p_outputopts, &in6p->in6p_route, 1615 1.2.2.2 skrll (in6p->in6p_socket->so_options & SO_DONTROUTE), NULL, NULL, 1616 1.2.2.2 skrll NULL); 1617 1.2.2.2 skrll } else 1618 1.2.2.2 skrll #endif 1619 1.2.2.2 skrll { 1620 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Calling ip_output, mbuf->m_len = %u, mbuf->m_pkthdr.len = %u\n", m->m_len, m->m_pkthdr.len)); 1621 1.2.2.2 skrll error = ip_output(m, inp->inp_options, &inp->inp_route, 1622 1.2.2.5 skrll (inp->inp_socket->so_options & SO_DONTROUTE), 0, 1623 1.2.2.3 skrll inp->inp_socket); 1624 1.2.2.2 skrll } 1625 1.2.2.2 skrll 1626 1.2.2.2 skrll if (error) { 1627 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "IP output failed! %d\n", error)); 1628 1.2.2.2 skrll return (error); 1629 1.2.2.2 skrll } 1630 1.2.2.2 skrll 1631 1.2.2.2 skrll #if defined(INET6) 1632 1.2.2.2 skrll if (isipv6) { 1633 1.2.2.2 skrll sbdrop(&in6p->in6p_socket->so_snd, len); 1634 1.2.2.2 skrll sowwakeup(in6p->in6p_socket); 1635 1.2.2.2 skrll } else 1636 1.2.2.2 skrll #endif 1637 1.2.2.2 skrll { 1638 1.2.2.2 skrll sbdrop(&inp->inp_socket->so_snd, len); 1639 1.2.2.2 skrll sowwakeup(inp->inp_socket); 1640 1.2.2.2 skrll } 1641 1.2.2.2 skrll 1642 1.2.2.2 skrll if (dp->cc_in_use[0] > 0 && dp->state == DCCPS_ESTAB) { 1643 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Calling *cc_sw[%u].cc_send_packet_sent!\n", dp->cc_in_use[0])); 1644 1.2.2.2 skrll if (sendalot) { 1645 1.2.2.2 skrll (*cc_sw[dp->cc_in_use[0]].cc_send_packet_sent)(dp->cc_state[0], 1,len); 1646 1.2.2.2 skrll goto again; 1647 1.2.2.2 skrll } else { 1648 1.2.2.2 skrll (*cc_sw[dp->cc_in_use[0]].cc_send_packet_sent)(dp->cc_state[0], 0,len); 1649 1.2.2.2 skrll } 1650 1.2.2.2 skrll } else { 1651 1.2.2.2 skrll if (sendalot) 1652 1.2.2.2 skrll goto again; 1653 1.2.2.2 skrll } 1654 1.2.2.2 skrll 1655 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "dccp_output finished\n")); 1656 1.2.2.2 skrll 1657 1.2.2.2 skrll return (0); 1658 1.2.2.2 skrll 1659 1.2.2.2 skrll release: 1660 1.2.2.2 skrll m_freem(m); 1661 1.2.2.2 skrll return (error); 1662 1.2.2.2 skrll } 1663 1.2.2.2 skrll 1664 1.2.2.2 skrll int 1665 1.2.2.2 skrll dccp_abort(struct socket *so) 1666 1.2.2.2 skrll { 1667 1.2.2.2 skrll struct inpcb *inp = 0; 1668 1.2.2.2 skrll struct in6pcb *in6p; 1669 1.2.2.2 skrll struct dccpcb *dp; 1670 1.2.2.2 skrll 1671 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_abort!\n")); 1672 1.2.2.2 skrll INP_INFO_WLOCK(&dccpbinfo); 1673 1.2.2.2 skrll if (so->so_proto->pr_domain->dom_family == PF_INET6) { 1674 1.2.2.2 skrll in6p = sotoin6pcb(so); 1675 1.2.2.2 skrll if (in6p == 0) { 1676 1.2.2.2 skrll return EINVAL; 1677 1.2.2.2 skrll } 1678 1.2.2.2 skrll inp = 0; 1679 1.2.2.2 skrll dp = (struct dccpcb *)in6p->in6p_ppcb; 1680 1.2.2.2 skrll } else { 1681 1.2.2.2 skrll inp = sotoinpcb(so); 1682 1.2.2.2 skrll if (inp == 0) { 1683 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 1684 1.2.2.2 skrll return EINVAL; 1685 1.2.2.2 skrll } 1686 1.2.2.2 skrll dp = (struct dccpcb *)inp->inp_ppcb; 1687 1.2.2.2 skrll } 1688 1.2.2.2 skrll 1689 1.2.2.2 skrll dccp_disconnect2(dp); 1690 1.2.2.2 skrll 1691 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 1692 1.2.2.2 skrll return 0; 1693 1.2.2.2 skrll } 1694 1.2.2.2 skrll 1695 1.2.2.2 skrll static struct dccpcb * 1696 1.2.2.2 skrll dccp_close(struct dccpcb *dp) 1697 1.2.2.2 skrll { 1698 1.2.2.2 skrll struct socket *so; 1699 1.2.2.2 skrll struct inpcb *inp = dp->d_inpcb; 1700 1.2.2.2 skrll struct in6pcb *in6p = dp->d_in6pcb; 1701 1.2.2.2 skrll so = dptosocket(dp); 1702 1.2.2.2 skrll 1703 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_close!\n")); 1704 1.2.2.2 skrll 1705 1.2.2.2 skrll /* Stop all timers */ 1706 1.2.2.2 skrll callout_stop(&dp->connect_timer); 1707 1.2.2.2 skrll callout_stop(&dp->retrans_timer); 1708 1.2.2.2 skrll callout_stop(&dp->close_timer); 1709 1.2.2.2 skrll callout_stop(&dp->timewait_timer); 1710 1.2.2.2 skrll 1711 1.2.2.2 skrll if (dp->cc_in_use[0] > 0) 1712 1.2.2.2 skrll (*cc_sw[dp->cc_in_use[0]].cc_send_free)(dp->cc_state[0]); 1713 1.2.2.2 skrll if (dp->cc_in_use[1] > 0) 1714 1.2.2.2 skrll (*cc_sw[dp->cc_in_use[1]].cc_recv_free)(dp->cc_state[1]); 1715 1.2.2.2 skrll 1716 1.2.2.2 skrll pool_put(&dccpcb_pool, dp); 1717 1.2.2.2 skrll if (inp) { 1718 1.2.2.2 skrll inp->inp_ppcb = NULL; 1719 1.2.2.2 skrll soisdisconnected(so); 1720 1.2.2.2 skrll in_pcbdetach(inp); 1721 1.2.2.2 skrll } 1722 1.2.2.2 skrll #if defined(INET6) 1723 1.2.2.2 skrll else if (in6p) { 1724 1.2.2.2 skrll in6p->in6p_ppcb = 0; 1725 1.2.2.2 skrll soisdisconnected(so); 1726 1.2.2.2 skrll in6_pcbdetach(in6p); 1727 1.2.2.2 skrll } 1728 1.2.2.2 skrll #endif 1729 1.2.2.2 skrll return ((struct dccpcb *)0); 1730 1.2.2.2 skrll } 1731 1.2.2.2 skrll 1732 1.2.2.2 skrll /* 1733 1.2.2.2 skrll * Runs when a new socket is created with the 1734 1.2.2.2 skrll * socket system call or sonewconn. 1735 1.2.2.2 skrll */ 1736 1.2.2.2 skrll int 1737 1.2.2.2 skrll dccp_attach(struct socket *so, int proto) 1738 1.2.2.2 skrll { 1739 1.2.2.2 skrll struct inpcb *inp = 0; 1740 1.2.2.2 skrll struct in6pcb *in6p = 0; 1741 1.2.2.2 skrll struct dccpcb *dp; 1742 1.2.2.2 skrll int s, family, error = 0; 1743 1.2.2.2 skrll 1744 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_attach(proto=%d)!\n", proto)); 1745 1.2.2.2 skrll INP_INFO_WLOCK(&dccpbinfo); 1746 1.2.2.2 skrll s = splsoftnet(); 1747 1.2.2.2 skrll sosetlock(so); 1748 1.2.2.2 skrll 1749 1.2.2.2 skrll family = so->so_proto->pr_domain->dom_family; 1750 1.2.2.2 skrll switch (family) { 1751 1.2.2.2 skrll case PF_INET: 1752 1.2.2.2 skrll inp = sotoinpcb(so); 1753 1.2.2.2 skrll if (inp != 0) { 1754 1.2.2.2 skrll error = EINVAL; 1755 1.2.2.2 skrll goto out; 1756 1.2.2.2 skrll } 1757 1.2.2.2 skrll error = soreserve(so, dccp_sendspace, dccp_recvspace); 1758 1.2.2.2 skrll if (error) 1759 1.2.2.2 skrll goto out; 1760 1.2.2.2 skrll error = in_pcballoc(so, &dccpbtable); 1761 1.2.2.2 skrll if (error) 1762 1.2.2.2 skrll goto out; 1763 1.2.2.2 skrll inp = sotoinpcb(so); 1764 1.2.2.2 skrll break; 1765 1.2.2.2 skrll #if defined(INET6) 1766 1.2.2.2 skrll case PF_INET6: 1767 1.2.2.2 skrll in6p = sotoin6pcb(so); 1768 1.2.2.2 skrll if (in6p != 0) { 1769 1.2.2.2 skrll error = EINVAL; 1770 1.2.2.2 skrll goto out; 1771 1.2.2.2 skrll } 1772 1.2.2.2 skrll error = soreserve(so, dccp_sendspace, dccp_recvspace); 1773 1.2.2.2 skrll if (error) 1774 1.2.2.2 skrll goto out; 1775 1.2.2.2 skrll error = in6_pcballoc(so, &dccpbtable); 1776 1.2.2.2 skrll if (error) 1777 1.2.2.2 skrll goto out; 1778 1.2.2.2 skrll in6p = sotoin6pcb(so); 1779 1.2.2.2 skrll break; 1780 1.2.2.2 skrll #endif 1781 1.2.2.2 skrll default: 1782 1.2.2.2 skrll error = EAFNOSUPPORT; 1783 1.2.2.2 skrll goto out; 1784 1.2.2.2 skrll } 1785 1.2.2.2 skrll 1786 1.2.2.2 skrll if (inp) 1787 1.2.2.2 skrll dp = dccp_newdccpcb(PF_INET, (void *)inp); 1788 1.2.2.2 skrll else if (in6p) 1789 1.2.2.2 skrll dp = dccp_newdccpcb(PF_INET6, (void *)in6p); 1790 1.2.2.2 skrll else 1791 1.2.2.2 skrll dp = NULL; 1792 1.2.2.2 skrll 1793 1.2.2.2 skrll if (dp == 0) { 1794 1.2.2.2 skrll int nofd = so->so_state & SS_NOFDREF; 1795 1.2.2.2 skrll so->so_state &= ~SS_NOFDREF; 1796 1.2.2.2 skrll #if defined(INET6) 1797 1.2.2.2 skrll if (proto == PF_INET6) { 1798 1.2.2.2 skrll in6_pcbdetach(in6p); 1799 1.2.2.2 skrll } else 1800 1.2.2.2 skrll #endif 1801 1.2.2.2 skrll in_pcbdetach(inp); 1802 1.2.2.2 skrll so->so_state |= nofd; 1803 1.2.2.2 skrll error = ENOBUFS; 1804 1.2.2.2 skrll goto out; 1805 1.2.2.2 skrll } 1806 1.2.2.2 skrll 1807 1.2.2.2 skrll #ifdef INET6 1808 1.2.2.2 skrll if (proto == PF_INET6) { 1809 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "We are a ipv6 socket!!!\n")); 1810 1.2.2.2 skrll dp->inp_vflag |= INP_IPV6; 1811 1.2.2.3 skrll } else 1812 1.2.2.2 skrll #endif 1813 1.2.2.2 skrll dp->inp_vflag |= INP_IPV4; 1814 1.2.2.2 skrll dp->inp_ip_ttl = ip_defttl; 1815 1.2.2.2 skrll 1816 1.2.2.2 skrll dp->state = DCCPS_CLOSED; 1817 1.2.2.2 skrll out: 1818 1.2.2.2 skrll splx(s); 1819 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 1820 1.2.2.2 skrll return error; 1821 1.2.2.2 skrll } 1822 1.2.2.2 skrll 1823 1.2.2.2 skrll static int 1824 1.2.2.2 skrll dccp_bind(struct socket *so, struct sockaddr *nam, struct lwp *l) 1825 1.2.2.2 skrll { 1826 1.2.2.2 skrll struct inpcb *inp; 1827 1.2.2.2 skrll int error; 1828 1.2.2.2 skrll struct sockaddr_in *sin = (struct sockaddr_in *)nam; 1829 1.2.2.2 skrll 1830 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_bind!\n")); 1831 1.2.2.2 skrll INP_INFO_WLOCK(&dccpbinfo); 1832 1.2.2.2 skrll inp = sotoinpcb(so); 1833 1.2.2.2 skrll if (inp == 0) { 1834 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 1835 1.2.2.2 skrll return EINVAL; 1836 1.2.2.2 skrll } 1837 1.2.2.2 skrll 1838 1.2.2.2 skrll /* Do not bind to multicast addresses! */ 1839 1.2.2.2 skrll if (sin->sin_family == AF_INET && 1840 1.2.2.2 skrll IN_MULTICAST(ntohl(sin->sin_addr.s_addr))) { 1841 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 1842 1.2.2.2 skrll return EAFNOSUPPORT; 1843 1.2.2.2 skrll } 1844 1.2.2.2 skrll INP_LOCK(inp); 1845 1.2.2.2 skrll error = in_pcbbind(inp, sin, l); 1846 1.2.2.2 skrll INP_UNLOCK(inp); 1847 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 1848 1.2.2.2 skrll return error; 1849 1.2.2.2 skrll } 1850 1.2.2.2 skrll 1851 1.2.2.2 skrll /* 1852 1.2.2.2 skrll * Initiates a connection to a server 1853 1.2.2.2 skrll * Called by the connect system call. 1854 1.2.2.2 skrll */ 1855 1.2.2.2 skrll static int 1856 1.2.2.3 skrll dccp_connect(struct socket *so, struct sockaddr *nam, struct lwp *l) 1857 1.2.2.2 skrll { 1858 1.2.2.2 skrll struct inpcb *inp; 1859 1.2.2.2 skrll struct dccpcb *dp; 1860 1.2.2.2 skrll int error; 1861 1.2.2.2 skrll struct sockaddr_in *sin; 1862 1.2.2.2 skrll char test[2]; 1863 1.2.2.2 skrll 1864 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_connect!\n")); 1865 1.2.2.2 skrll 1866 1.2.2.2 skrll INP_INFO_WLOCK(&dccpbinfo); 1867 1.2.2.2 skrll inp = sotoinpcb(so); 1868 1.2.2.2 skrll if (inp == 0) { 1869 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 1870 1.2.2.2 skrll return EINVAL; 1871 1.2.2.2 skrll } 1872 1.2.2.2 skrll INP_LOCK(inp); 1873 1.2.2.2 skrll if (inp->inp_faddr.s_addr != INADDR_ANY) { 1874 1.2.2.2 skrll INP_UNLOCK(inp); 1875 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 1876 1.2.2.2 skrll return EISCONN; 1877 1.2.2.2 skrll } 1878 1.2.2.2 skrll 1879 1.2.2.2 skrll dp = (struct dccpcb *)inp->inp_ppcb; 1880 1.2.2.2 skrll 1881 1.2.2.2 skrll if (dp->state == DCCPS_ESTAB) { 1882 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Why are we in connect when we already have a established connection?\n")); 1883 1.2.2.2 skrll } 1884 1.2.2.2 skrll 1885 1.2.2.2 skrll dp->who = DCCP_CLIENT; 1886 1.2.2.2 skrll dp->seq_snd = (((u_int64_t)random() << 32) | random()) % 281474976710656LL; 1887 1.2.2.2 skrll dp->ref_seq.hi = dp->seq_snd >> 24; 1888 1.2.2.2 skrll dp->ref_seq.lo = (u_int64_t)(dp->seq_snd & 0xffffff); 1889 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "dccp_connect seq_snd %llu\n", dp->seq_snd)); 1890 1.2.2.2 skrll 1891 1.2.2.2 skrll dccpstat.dccps_connattempt++; 1892 1.2.2.2 skrll 1893 1.2.2.2 skrll sin = (struct sockaddr_in *)nam; 1894 1.2.2.2 skrll if (sin->sin_family == AF_INET 1895 1.2.2.2 skrll && IN_MULTICAST(ntohl(sin->sin_addr.s_addr))) { 1896 1.2.2.2 skrll error = EAFNOSUPPORT; 1897 1.2.2.2 skrll goto bad; 1898 1.2.2.2 skrll } 1899 1.2.2.2 skrll 1900 1.2.2.3 skrll error = dccp_doconnect(so, nam, l, 0); 1901 1.2.2.2 skrll 1902 1.2.2.2 skrll if (error != 0) 1903 1.2.2.2 skrll goto bad; 1904 1.2.2.2 skrll 1905 1.2.2.2 skrll callout_reset(&dp->retrans_timer, dp->retrans, dccp_retrans_t, dp); 1906 1.2.2.2 skrll callout_reset(&dp->connect_timer, DCCP_CONNECT_TIMER, dccp_connect_t, dp); 1907 1.2.2.2 skrll 1908 1.2.2.2 skrll if (dccp_do_feature_nego){ 1909 1.2.2.2 skrll test[0] = dp->pref_cc; 1910 1.2.2.2 skrll dccp_add_feature(dp, DCCP_OPT_CHANGE_R, DCCP_FEATURE_CC, test, 1); 1911 1.2.2.2 skrll } 1912 1.2.2.2 skrll 1913 1.2.2.2 skrll error = dccp_output(dp, 0); 1914 1.2.2.2 skrll 1915 1.2.2.2 skrll bad: 1916 1.2.2.2 skrll INP_UNLOCK(inp); 1917 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 1918 1.2.2.2 skrll return error; 1919 1.2.2.2 skrll } 1920 1.2.2.2 skrll 1921 1.2.2.2 skrll static int 1922 1.2.2.2 skrll dccp_connect2(struct socket *so, struct socket *so2) 1923 1.2.2.2 skrll { 1924 1.2.2.2 skrll KASSERT(solocked(so)); 1925 1.2.2.2 skrll 1926 1.2.2.2 skrll return EOPNOTSUPP; 1927 1.2.2.2 skrll } 1928 1.2.2.2 skrll 1929 1.2.2.2 skrll /* 1930 1.2.2.2 skrll * 1931 1.2.2.2 skrll * 1932 1.2.2.2 skrll */ 1933 1.2.2.2 skrll int 1934 1.2.2.3 skrll dccp_doconnect(struct socket *so, struct sockaddr *nam, 1935 1.2.2.3 skrll struct lwp *l, int isipv6) 1936 1.2.2.3 skrll { 1937 1.2.2.2 skrll struct inpcb *inp; 1938 1.2.2.2 skrll #ifdef INET6 1939 1.2.2.2 skrll struct in6pcb *in6p; 1940 1.2.2.2 skrll #endif 1941 1.2.2.2 skrll int error = 0; 1942 1.2.2.2 skrll 1943 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_doconnect!\n")); 1944 1.2.2.2 skrll 1945 1.2.2.2 skrll #if defined(INET6) 1946 1.2.2.2 skrll if (isipv6) { 1947 1.2.2.2 skrll in6p = sotoin6pcb(so); 1948 1.2.2.2 skrll inp = 0; 1949 1.2.2.2 skrll } else 1950 1.2.2.2 skrll #endif 1951 1.2.2.2 skrll { 1952 1.2.2.2 skrll inp = sotoinpcb(so); 1953 1.2.2.2 skrll in6p = 0; 1954 1.2.2.2 skrll } 1955 1.2.2.2 skrll 1956 1.2.2.2 skrll #if !defined(__NetBSD__) || !defined(INET6) 1957 1.2.2.2 skrll if (inp->inp_lport == 0) { 1958 1.2.2.2 skrll #else 1959 1.2.2.2 skrll if (isipv6 ? in6p->in6p_lport == 0 : inp->inp_lport == 0) { 1960 1.2.2.2 skrll #endif 1961 1.2.2.2 skrll #ifdef INET6 1962 1.2.2.2 skrll if (isipv6) { 1963 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Running in6_pcbbind!\n")); 1964 1.2.2.2 skrll error = in6_pcbbind(in6p, NULL, l); 1965 1.2.2.2 skrll } else 1966 1.2.2.2 skrll #endif /* INET6 */ 1967 1.2.2.2 skrll { 1968 1.2.2.2 skrll error = in_pcbbind(inp, NULL, l); 1969 1.2.2.2 skrll } 1970 1.2.2.2 skrll if (error) { 1971 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "in_pcbbind=%d\n",error)); 1972 1.2.2.2 skrll return error; 1973 1.2.2.2 skrll } 1974 1.2.2.2 skrll } 1975 1.2.2.2 skrll 1976 1.2.2.2 skrll #ifdef INET6 1977 1.2.2.2 skrll if (isipv6) { 1978 1.2.2.3 skrll error = in6_pcbconnect(in6p, (struct sockaddr_in6 *)nam, l); 1979 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "in6_pcbconnect=%d\n",error)); 1980 1.2.2.2 skrll } else 1981 1.2.2.2 skrll #endif 1982 1.2.2.3 skrll error = in_pcbconnect(inp, (struct sockaddr_in *)nam, l); 1983 1.2.2.2 skrll if (error) { 1984 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "in_pcbconnect=%d\n",error)); 1985 1.2.2.2 skrll return error; 1986 1.2.2.2 skrll } 1987 1.2.2.2 skrll 1988 1.2.2.2 skrll soisconnecting(so); 1989 1.2.2.2 skrll return error; 1990 1.2.2.2 skrll } 1991 1.2.2.2 skrll 1992 1.2.2.2 skrll /* 1993 1.2.2.2 skrll * Detaches the DCCP protocol from the socket. 1994 1.2.2.2 skrll * 1995 1.2.2.2 skrll */ 1996 1.2.2.2 skrll int 1997 1.2.2.2 skrll dccp_detach(struct socket *so) 1998 1.2.2.2 skrll { 1999 1.2.2.2 skrll struct inpcb *inp; 2000 1.2.2.2 skrll struct in6pcb *in6p; 2001 1.2.2.2 skrll struct dccpcb *dp; 2002 1.2.2.2 skrll 2003 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_detach!\n")); 2004 1.2.2.2 skrll #ifdef INET6 2005 1.2.2.2 skrll if (so->so_proto->pr_domain->dom_family == AF_INET6) { 2006 1.2.2.2 skrll in6p = sotoin6pcb(so); 2007 1.2.2.2 skrll if (in6p == 0) { 2008 1.2.2.2 skrll return EINVAL; 2009 1.2.2.2 skrll } 2010 1.2.2.2 skrll dp = (struct dccpcb *)in6p->in6p_ppcb; 2011 1.2.2.2 skrll } else 2012 1.2.2.2 skrll #endif 2013 1.2.2.2 skrll { 2014 1.2.2.2 skrll inp = sotoinpcb(so); 2015 1.2.2.2 skrll if (inp == 0) { 2016 1.2.2.2 skrll return EINVAL; 2017 1.2.2.2 skrll } 2018 1.2.2.2 skrll dp = (struct dccpcb *)inp->inp_ppcb; 2019 1.2.2.2 skrll } 2020 1.2.2.2 skrll if (! dccp_disconnect2(dp)) { 2021 1.2.2.2 skrll INP_UNLOCK(inp); 2022 1.2.2.2 skrll } 2023 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 2024 1.2.2.2 skrll return 0; 2025 1.2.2.2 skrll } 2026 1.2.2.2 skrll 2027 1.2.2.2 skrll /* 2028 1.2.2.3 skrll * 2029 1.2.2.2 skrll * 2030 1.2.2.2 skrll */ 2031 1.2.2.2 skrll int 2032 1.2.2.2 skrll dccp_disconnect(struct socket *so) 2033 1.2.2.2 skrll { 2034 1.2.2.2 skrll struct inpcb *inp; 2035 1.2.2.2 skrll struct in6pcb *in6p; 2036 1.2.2.2 skrll struct dccpcb *dp; 2037 1.2.2.2 skrll 2038 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_disconnect!\n")); 2039 1.2.2.2 skrll INP_INFO_WLOCK(&dccpbinfo); 2040 1.2.2.2 skrll #ifndef __NetBSD__ 2041 1.2.2.2 skrll inp = sotoinpcb(so); 2042 1.2.2.2 skrll if (inp == 0) { 2043 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 2044 1.2.2.2 skrll return EINVAL; 2045 1.2.2.2 skrll } 2046 1.2.2.2 skrll INP_LOCK(inp); 2047 1.2.2.2 skrll if (inp->inp_faddr.s_addr == INADDR_ANY) { 2048 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 2049 1.2.2.2 skrll INP_UNLOCK(inp); 2050 1.2.2.2 skrll return ENOTCONN; 2051 1.2.2.2 skrll } 2052 1.2.2.2 skrll 2053 1.2.2.2 skrll dp = (struct dccpcb *)inp->inp_ppcb; 2054 1.2.2.2 skrll #else /* NetBSD */ 2055 1.2.2.2 skrll #ifdef INET6 2056 1.2.2.2 skrll if (so->so_proto->pr_domain->dom_family == AF_INET6) { 2057 1.2.2.2 skrll in6p = sotoin6pcb(so); 2058 1.2.2.2 skrll if (in6p == 0) { 2059 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 2060 1.2.2.2 skrll return EINVAL; 2061 1.2.2.2 skrll } 2062 1.2.2.2 skrll dp = (struct dccpcb *)in6p->in6p_ppcb; 2063 1.2.2.2 skrll } else 2064 1.2.2.2 skrll #endif 2065 1.2.2.2 skrll { 2066 1.2.2.2 skrll inp = sotoinpcb(so); 2067 1.2.2.2 skrll if (inp == 0) { 2068 1.2.2.2 skrll return EINVAL; 2069 1.2.2.2 skrll } 2070 1.2.2.2 skrll dp = (struct dccpcb *)inp->inp_ppcb; 2071 1.2.2.2 skrll } 2072 1.2.2.2 skrll #endif 2073 1.2.2.2 skrll if (!dccp_disconnect2(dp)) { 2074 1.2.2.2 skrll INP_UNLOCK(inp); 2075 1.2.2.2 skrll } 2076 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 2077 1.2.2.2 skrll return 0; 2078 1.2.2.2 skrll } 2079 1.2.2.2 skrll 2080 1.2.2.2 skrll /* 2081 1.2.2.2 skrll * If we have don't have a established connection 2082 1.2.2.2 skrll * we can call dccp_close, otherwise we can just 2083 1.2.2.2 skrll * set SS_ISDISCONNECTED and flush the receive queue. 2084 1.2.2.2 skrll */ 2085 1.2.2.2 skrll static int 2086 1.2.2.2 skrll dccp_disconnect2(struct dccpcb *dp) 2087 1.2.2.2 skrll { 2088 1.2.2.2 skrll struct socket *so = dptosocket(dp); 2089 1.2.2.2 skrll 2090 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_disconnect2!\n")); 2091 1.2.2.2 skrll 2092 1.2.2.2 skrll if (dp->state < DCCPS_ESTAB) { 2093 1.2.2.2 skrll dccp_close(dp); 2094 1.2.2.2 skrll return 1; 2095 1.2.2.2 skrll } else { 2096 1.2.2.2 skrll soisdisconnecting(so); 2097 1.2.2.2 skrll sbflush(&so->so_rcv); 2098 1.2.2.2 skrll if (dp->state == DCCPS_ESTAB) { 2099 1.2.2.2 skrll dp->retrans = 100; 2100 1.2.2.2 skrll callout_reset(&dp->retrans_timer, dp->retrans, 2101 1.2.2.2 skrll dccp_retrans_t, dp); 2102 1.2.2.2 skrll callout_reset(&dp->close_timer, DCCP_CLOSE_TIMER, 2103 1.2.2.2 skrll dccp_close_t, dp); 2104 1.2.2.2 skrll if (dp->who == DCCP_CLIENT) { 2105 1.2.2.2 skrll dp->state = DCCPS_CLIENT_CLOSE; 2106 1.2.2.2 skrll } else { 2107 1.2.2.2 skrll dp->state = DCCPS_SERVER_CLOSE; 2108 1.2.2.2 skrll } 2109 1.2.2.2 skrll dccp_output(dp, 0); 2110 1.2.2.2 skrll } 2111 1.2.2.2 skrll } 2112 1.2.2.2 skrll return 0; 2113 1.2.2.2 skrll } 2114 1.2.2.2 skrll 2115 1.2.2.2 skrll int 2116 1.2.2.3 skrll dccp_send(struct socket *so, struct mbuf *m, struct sockaddr *addr, 2117 1.2.2.2 skrll struct mbuf *control, struct lwp *l) 2118 1.2.2.2 skrll { 2119 1.2.2.2 skrll struct inpcb *inp; 2120 1.2.2.2 skrll struct dccpcb *dp; 2121 1.2.2.2 skrll int error = 0; 2122 1.2.2.2 skrll int isipv6 = 0; 2123 1.2.2.2 skrll 2124 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_send!\n")); 2125 1.2.2.2 skrll KASSERT(solocked(so)); 2126 1.2.2.2 skrll KASSERT(m != NULL); 2127 1.2.2.2 skrll 2128 1.2.2.2 skrll if (control && control->m_len) { 2129 1.2.2.2 skrll m_freem(control); 2130 1.2.2.2 skrll m_freem(m); 2131 1.2.2.2 skrll return EINVAL; 2132 1.2.2.2 skrll } 2133 1.2.2.2 skrll 2134 1.2.2.2 skrll #ifdef INET6 2135 1.2.2.2 skrll isipv6 = addr && addr->sa_family == AF_INET6; 2136 1.2.2.2 skrll #endif 2137 1.2.2.2 skrll 2138 1.2.2.2 skrll #if defined(INET6) 2139 1.2.2.2 skrll if (so->so_proto->pr_domain->dom_family == AF_INET6) { 2140 1.2.2.2 skrll struct in6pcb *in6p; 2141 1.2.2.2 skrll in6p = sotoin6pcb(so); 2142 1.2.2.2 skrll if (in6p == 0) { 2143 1.2.2.2 skrll error = EINVAL; 2144 1.2.2.2 skrll goto release; 2145 1.2.2.2 skrll } 2146 1.2.2.2 skrll dp = (struct dccpcb *)in6p->in6p_ppcb; 2147 1.2.2.2 skrll } else 2148 1.2.2.2 skrll #endif 2149 1.2.2.2 skrll { 2150 1.2.2.2 skrll INP_INFO_WLOCK(&dccpbinfo); 2151 1.2.2.2 skrll inp = sotoinpcb(so); 2152 1.2.2.2 skrll if (inp == 0) { 2153 1.2.2.2 skrll error = EINVAL; 2154 1.2.2.2 skrll goto release; 2155 1.2.2.2 skrll } 2156 1.2.2.2 skrll INP_LOCK(inp); 2157 1.2.2.2 skrll dp = (struct dccpcb *)inp->inp_ppcb; 2158 1.2.2.2 skrll } 2159 1.2.2.2 skrll if (dp->state != DCCPS_ESTAB) { 2160 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "We have no established connection!\n")); 2161 1.2.2.2 skrll } 2162 1.2.2.2 skrll 2163 1.2.2.2 skrll if (control != NULL) { 2164 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "We got a control message!\n")); 2165 1.2.2.2 skrll /* Are we going to use control messages??? */ 2166 1.2.2.2 skrll if (control->m_len) { 2167 1.2.2.2 skrll m_freem(control); 2168 1.2.2.2 skrll } 2169 1.2.2.2 skrll } 2170 1.2.2.2 skrll 2171 1.2.2.2 skrll if (sbspace(&so->so_snd) < -512) { 2172 1.2.2.2 skrll INP_UNLOCK(inp); 2173 1.2.2.2 skrll error = ENOBUFS; 2174 1.2.2.2 skrll goto release; 2175 1.2.2.2 skrll } 2176 1.2.2.2 skrll 2177 1.2.2.2 skrll if (m->m_pkthdr.len > dp->d_maxseg) { 2178 1.2.2.2 skrll /* XXX we should calculate packet size more carefully */ 2179 1.2.2.2 skrll INP_UNLOCK(inp); 2180 1.2.2.2 skrll error = EINVAL; 2181 1.2.2.2 skrll goto release; 2182 1.2.2.2 skrll } 2183 1.2.2.2 skrll 2184 1.2.2.2 skrll if (dp->pktcnt >= DCCP_MAX_PKTS) { 2185 1.2.2.2 skrll INP_UNLOCK(inp); 2186 1.2.2.2 skrll error = ENOBUFS; 2187 1.2.2.2 skrll goto release; 2188 1.2.2.2 skrll } 2189 1.2.2.2 skrll 2190 1.2.2.2 skrll sbappend(&so->so_snd, m); 2191 1.2.2.3 skrll dp->pktlen[(dp->pktlenidx + dp->pktcnt) % DCCP_MAX_PKTS] = m->m_pkthdr.len; 2192 1.2.2.2 skrll dp->pktcnt ++; 2193 1.2.2.2 skrll 2194 1.2.2.2 skrll if (addr && dp->state == DCCPS_CLOSED) { 2195 1.2.2.3 skrll error = dccp_doconnect(so, addr, l, isipv6); 2196 1.2.2.2 skrll if (error) 2197 1.2.2.2 skrll goto out; 2198 1.2.2.2 skrll } 2199 1.2.2.2 skrll 2200 1.2.2.2 skrll error = dccp_output(dp, 0); 2201 1.2.2.2 skrll 2202 1.2.2.2 skrll out: 2203 1.2.2.2 skrll INP_UNLOCK(inp); 2204 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 2205 1.2.2.3 skrll return error; 2206 1.2.2.2 skrll 2207 1.2.2.2 skrll release: 2208 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 2209 1.2.2.2 skrll m_freem(m); 2210 1.2.2.2 skrll return (error); 2211 1.2.2.2 skrll } 2212 1.2.2.2 skrll 2213 1.2.2.2 skrll /* 2214 1.2.2.3 skrll * Sets socket to SS_CANTSENDMORE 2215 1.2.2.2 skrll */ 2216 1.2.2.2 skrll int 2217 1.2.2.2 skrll dccp_shutdown(struct socket *so) 2218 1.2.2.2 skrll { 2219 1.2.2.2 skrll struct inpcb *inp; 2220 1.2.2.2 skrll 2221 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_shutdown!\n")); 2222 1.2.2.2 skrll INP_INFO_RLOCK(&dccpbinfo); 2223 1.2.2.2 skrll inp = sotoinpcb(so); 2224 1.2.2.2 skrll if (inp == 0) { 2225 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 2226 1.2.2.2 skrll return EINVAL; 2227 1.2.2.2 skrll } 2228 1.2.2.2 skrll INP_LOCK(inp); 2229 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 2230 1.2.2.2 skrll socantsendmore(so); 2231 1.2.2.2 skrll INP_UNLOCK(inp); 2232 1.2.2.2 skrll return 0; 2233 1.2.2.2 skrll } 2234 1.2.2.2 skrll 2235 1.2.2.2 skrll static int 2236 1.2.2.2 skrll dccp_listen(struct socket *so, struct lwp *td) 2237 1.2.2.2 skrll { 2238 1.2.2.2 skrll struct inpcb *inp; 2239 1.2.2.2 skrll struct dccpcb *dp; 2240 1.2.2.2 skrll int error = 0; 2241 1.2.2.2 skrll 2242 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_listen!\n")); 2243 1.2.2.2 skrll 2244 1.2.2.2 skrll INP_INFO_RLOCK(&dccpbinfo); 2245 1.2.2.2 skrll inp = sotoinpcb(so); 2246 1.2.2.2 skrll if (inp == 0) { 2247 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 2248 1.2.2.2 skrll return EINVAL; 2249 1.2.2.2 skrll } 2250 1.2.2.2 skrll INP_LOCK(inp); 2251 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 2252 1.2.2.2 skrll dp = (struct dccpcb *)inp->inp_ppcb; 2253 1.2.2.2 skrll if (inp->inp_lport == 0) 2254 1.2.2.2 skrll error = in_pcbbind(inp, NULL, td); 2255 1.2.2.2 skrll if (error == 0) { 2256 1.2.2.2 skrll dp->state = DCCPS_LISTEN; 2257 1.2.2.2 skrll dp->who = DCCP_LISTENER; 2258 1.2.2.2 skrll } 2259 1.2.2.2 skrll INP_UNLOCK(inp); 2260 1.2.2.2 skrll return error; 2261 1.2.2.2 skrll } 2262 1.2.2.2 skrll 2263 1.2.2.2 skrll /* 2264 1.2.2.2 skrll * Accepts a connection (accept system call) 2265 1.2.2.2 skrll */ 2266 1.2.2.2 skrll static int 2267 1.2.2.3 skrll dccp_accept(struct socket *so, struct sockaddr *nam) 2268 1.2.2.2 skrll { 2269 1.2.2.2 skrll struct inpcb *inp = NULL; 2270 1.2.2.2 skrll int error = 0; 2271 1.2.2.2 skrll 2272 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_accept!\n")); 2273 1.2.2.2 skrll 2274 1.2.2.2 skrll if (nam == NULL) { 2275 1.2.2.2 skrll return EINVAL; 2276 1.2.2.2 skrll } 2277 1.2.2.2 skrll if (so->so_state & SS_ISDISCONNECTED) { 2278 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "so_state && SS_ISDISCONNECTED!, so->state = %i\n", so->so_state)); 2279 1.2.2.2 skrll return ECONNABORTED; 2280 1.2.2.2 skrll } 2281 1.2.2.2 skrll 2282 1.2.2.2 skrll INP_INFO_RLOCK(&dccpbinfo); 2283 1.2.2.2 skrll inp = sotoinpcb(so); 2284 1.2.2.2 skrll if (inp == 0) { 2285 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 2286 1.2.2.2 skrll return EINVAL; 2287 1.2.2.2 skrll } 2288 1.2.2.2 skrll INP_LOCK(inp); 2289 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 2290 1.2.2.3 skrll in_setpeeraddr(inp, (struct sockaddr_in *)nam); 2291 1.2.2.2 skrll 2292 1.2.2.2 skrll return error; 2293 1.2.2.2 skrll } 2294 1.2.2.2 skrll 2295 1.2.2.2 skrll /* 2296 1.2.2.2 skrll * Initializes a new DCCP control block 2297 1.2.2.2 skrll * (in_pcballoc in attach has already allocated memory for it) 2298 1.2.2.2 skrll */ 2299 1.2.2.2 skrll struct dccpcb * 2300 1.2.2.2 skrll dccp_newdccpcb(int family, void *aux) 2301 1.2.2.2 skrll { 2302 1.2.2.2 skrll struct inpcb *inp; 2303 1.2.2.2 skrll struct in6pcb *in6p; 2304 1.2.2.2 skrll struct dccpcb *dp; 2305 1.2.2.2 skrll 2306 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Creating a new dccpcb!\n")); 2307 1.2.2.2 skrll 2308 1.2.2.2 skrll dp = pool_get(&dccpcb_pool, PR_NOWAIT); 2309 1.2.2.2 skrll if (dp == NULL) 2310 1.2.2.2 skrll return NULL; 2311 1.2.2.2 skrll bzero((char *) dp, sizeof(struct dccpcb)); 2312 1.2.2.2 skrll 2313 1.2.2.2 skrll callout_init(&dp->connect_timer, 0); 2314 1.2.2.2 skrll callout_init(&dp->retrans_timer, 0); 2315 1.2.2.2 skrll callout_init(&dp->close_timer, 0); 2316 1.2.2.2 skrll callout_init(&dp->timewait_timer, 0); 2317 1.2.2.2 skrll 2318 1.2.2.2 skrll dp->ndp = 0; 2319 1.2.2.2 skrll dp->loss_window = 1000; 2320 1.2.2.2 skrll dp->cslen = 0; 2321 1.2.2.2 skrll dp->pref_cc = DEFAULT_CCID; 2322 1.2.2.2 skrll dp->who = DCCP_UNDEF; 2323 1.2.2.2 skrll dp->seq_snd = 0; 2324 1.2.2.2 skrll dp->seq_rcv = 0; 2325 1.2.2.2 skrll dp->shortseq = 0; 2326 1.2.2.2 skrll dp->gsn_rcv = 281474976710656LL; 2327 1.2.2.2 skrll dp->optlen = 0; 2328 1.2.2.2 skrll if (dccp_do_feature_nego){ 2329 1.2.2.2 skrll dp->cc_in_use[0] = -1; 2330 1.2.2.2 skrll dp->cc_in_use[1] = -1; 2331 1.2.2.2 skrll } else { 2332 1.2.2.2 skrll /* for compatibility with linux */ 2333 1.2.2.3 skrll dp->cc_in_use[0] = 4; 2334 1.2.2.2 skrll dp->cc_in_use[1] = 4; 2335 1.2.2.2 skrll } 2336 1.2.2.2 skrll dp->av_size = 0; /* no ack vector initially */ 2337 1.2.2.2 skrll dp->remote_ackvector = 0; /* no ack vector on remote side initially */ 2338 1.2.2.2 skrll dp->retrans = 200; 2339 1.2.2.2 skrll dp->avgpsize = 0; 2340 1.2.2.2 skrll dp->d_maxseg = 1400; 2341 1.2.2.2 skrll dp->ref_pseq.hi = 0; 2342 1.2.2.2 skrll dp->ref_pseq.lo = 0; 2343 1.2.2.2 skrll dp->pktlenidx = 0; 2344 1.2.2.2 skrll dp->pktcnt = 0; 2345 1.2.2.2 skrll 2346 1.2.2.2 skrll switch (family) { 2347 1.2.2.2 skrll case PF_INET: 2348 1.2.2.2 skrll inp = (struct inpcb *)aux; 2349 1.2.2.2 skrll dp->d_inpcb = inp; 2350 1.2.2.2 skrll inp->inp_ip.ip_ttl = ip_defttl; 2351 1.2.2.2 skrll inp->inp_ppcb = dp; 2352 1.2.2.2 skrll break; 2353 1.2.2.2 skrll case PF_INET6: 2354 1.2.2.2 skrll in6p = (struct in6pcb *)aux; 2355 1.2.2.2 skrll dp->d_in6pcb = in6p; 2356 1.2.2.3 skrll in6p->in6p_ip6.ip6_hlim = in6_selecthlim_rt(in6p); 2357 1.2.2.2 skrll in6p->in6p_ppcb = dp; 2358 1.2.2.2 skrll break; 2359 1.2.2.2 skrll } 2360 1.2.2.3 skrll 2361 1.2.2.2 skrll if (!dccp_do_feature_nego){ 2362 1.2.2.2 skrll dp->cc_state[0] = (*cc_sw[4].cc_send_init)(dp); 2363 1.2.2.2 skrll dp->cc_state[1] = (*cc_sw[4].cc_recv_init)(dp); 2364 1.2.2.2 skrll } 2365 1.2.2.2 skrll 2366 1.2.2.2 skrll return dp; 2367 1.2.2.2 skrll } 2368 1.2.2.2 skrll 2369 1.2.2.2 skrll int 2370 1.2.2.2 skrll dccp_add_option(struct dccpcb *dp, u_int8_t opt, char *val, u_int8_t val_len) 2371 1.2.2.2 skrll { 2372 1.2.2.2 skrll return dccp_add_feature_option(dp, opt, 0, val, val_len); 2373 1.2.2.2 skrll } 2374 1.2.2.2 skrll 2375 1.2.2.2 skrll int 2376 1.2.2.2 skrll dccp_add_feature_option(struct dccpcb *dp, u_int8_t opt, u_int8_t feature, char *val, u_int8_t val_len) 2377 1.2.2.2 skrll { 2378 1.2.2.2 skrll int i; 2379 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_add_feature_option, opt = %u, val_len = %u optlen %u\n", opt, val_len, dp->optlen)); 2380 1.2.2.2 skrll 2381 1.2.2.2 skrll if (DCCP_MAX_OPTIONS > (dp->optlen + val_len + 2)) { 2382 1.2.2.2 skrll dp->options[dp->optlen] = opt; 2383 1.2.2.2 skrll if (opt < 32) { 2384 1.2.2.2 skrll dp->optlen++; 2385 1.2.2.2 skrll } else { 2386 1.2.2.2 skrll if (opt == DCCP_OPT_CONFIRM_L && val_len) { 2387 1.2.2.2 skrll dp->options[dp->optlen + 1] = val_len + 3; 2388 1.2.2.2 skrll dp->options[dp->optlen +2] = feature; 2389 1.2.2.2 skrll dp->optlen += 3; 2390 1.2.2.2 skrll } else { 2391 1.2.2.2 skrll dp->options[dp->optlen + 1] = val_len + 2; 2392 1.2.2.2 skrll dp->optlen += 2; 2393 1.2.2.2 skrll } 2394 1.2.2.3 skrll 2395 1.2.2.2 skrll for (i = 0; i<val_len; i++) { 2396 1.2.2.2 skrll dp->options[dp->optlen] = val[i]; 2397 1.2.2.2 skrll dp->optlen++; 2398 1.2.2.2 skrll } 2399 1.2.2.2 skrll } 2400 1.2.2.2 skrll } else { 2401 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "No room for more options, optlen = %u\n", dp->optlen)); 2402 1.2.2.2 skrll return -1; 2403 1.2.2.2 skrll } 2404 1.2.2.2 skrll 2405 1.2.2.2 skrll return 0; 2406 1.2.2.2 skrll } 2407 1.2.2.2 skrll 2408 1.2.2.2 skrll /* 2409 1.2.2.2 skrll * Searches "options" for given option type. if found, the data is copied to buffer 2410 1.2.2.2 skrll * and returns the data length. 2411 1.2.2.2 skrll * Returns 0 if option type not found 2412 1.2.2.2 skrll */ 2413 1.2.2.2 skrll int 2414 1.2.2.2 skrll dccp_get_option(char *options, int optlen, int type, char *buffer, int buflen) 2415 1.2.2.2 skrll { 2416 1.2.2.2 skrll int i, j, size; 2417 1.2.2.2 skrll u_int8_t t; 2418 1.2.2.3 skrll 2419 1.2.2.2 skrll for (i=0; i < optlen;) { 2420 1.2.2.2 skrll t = options[i++]; 2421 1.2.2.3 skrll if (t >= 32) { 2422 1.2.2.2 skrll size = options[i++] - 2; 2423 1.2.2.2 skrll if (t == type) { 2424 1.2.2.2 skrll if (size > buflen) 2425 1.2.2.2 skrll return 0; 2426 1.2.2.2 skrll for (j = 0; j < size; j++) 2427 1.2.2.2 skrll buffer[j] = options[i++]; 2428 1.2.2.2 skrll return size; 2429 1.2.2.2 skrll } 2430 1.2.2.2 skrll i += size; 2431 1.2.2.2 skrll } 2432 1.2.2.2 skrll } 2433 1.2.2.2 skrll /* If we get here the options was not found */ 2434 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "dccp_get_option option(%d) not found\n", type)); 2435 1.2.2.2 skrll return 0; 2436 1.2.2.2 skrll } 2437 1.2.2.2 skrll 2438 1.2.2.2 skrll void 2439 1.2.2.2 skrll dccp_parse_options(struct dccpcb *dp, char *options, int optlen) 2440 1.2.2.2 skrll { 2441 1.2.2.2 skrll u_int8_t opt, size, i, j; 2442 1.2.2.2 skrll char val[8]; 2443 1.2.2.2 skrll 2444 1.2.2.2 skrll for (i = 0; i < optlen; i++) { 2445 1.2.2.2 skrll opt = options[i]; 2446 1.2.2.2 skrll 2447 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Parsing opt: 0x%02x\n", opt)); 2448 1.2.2.2 skrll 2449 1.2.2.2 skrll if (opt < 32) { 2450 1.2.2.2 skrll switch (opt) { 2451 1.2.2.2 skrll case DCCP_OPT_PADDING: 2452 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP_OPT_PADDING!\n")); 2453 1.2.2.2 skrll break; 2454 1.2.2.2 skrll case DCCP_OPT_DATA_DISCARD: 2455 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP_OPT_DATA_DISCARD!\n")); 2456 1.2.2.2 skrll break; 2457 1.2.2.2 skrll case DCCP_OPT_SLOW_RECV: 2458 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP_OPT_SLOW_RECV!\n")); 2459 1.2.2.2 skrll break; 2460 1.2.2.2 skrll case DCCP_OPT_BUF_CLOSED: 2461 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP_OPT_BUF_CLOSED!\n")); 2462 1.2.2.2 skrll break; 2463 1.2.2.2 skrll default: 2464 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got an unknown option, option = %u!\n", opt)); 2465 1.2.2.2 skrll } 2466 1.2.2.2 skrll } else if (opt > 32 && opt < 36) { 2467 1.2.2.2 skrll size = options[i+ 1]; 2468 1.2.2.2 skrll if (size < 3 || size > 10) { 2469 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Error, option size = %u\n", size)); 2470 1.2.2.2 skrll return; 2471 1.2.2.2 skrll } 2472 1.2.2.3 skrll /* Feature negotiations are options 33 to 35 */ 2473 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got option %u, size = %u, feature = %u\n", opt, size, options[i+2])); 2474 1.2.2.2 skrll bcopy(options + i + 3, val, size -3); 2475 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Calling dccp_feature neg(%u, %u, options[%u + 1], %u)!\n", (u_int)dp, opt, i+ 1, (size - 3))); 2476 1.2.2.2 skrll dccp_feature_neg(dp, opt, options[i+2], (size -3) , val); 2477 1.2.2.2 skrll i += size - 1; 2478 1.2.2.2 skrll 2479 1.2.2.2 skrll } else if (opt < 128) { 2480 1.2.2.2 skrll size = options[i+ 1]; 2481 1.2.2.2 skrll if (size < 3 || size > 10) { 2482 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Error, option size = %u\n", size)); 2483 1.2.2.2 skrll return; 2484 1.2.2.2 skrll } 2485 1.2.2.2 skrll 2486 1.2.2.2 skrll switch (opt) { 2487 1.2.2.2 skrll case DCCP_OPT_RECV_BUF_DROPS: 2488 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP_OPT_RECV_BUF_DROPS, size = %u!\n", size)); 2489 1.2.2.2 skrll for (j=2; j < size; j++) { 2490 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "val[%u] = %u ", j-1, options[i+j])); 2491 1.2.2.2 skrll } 2492 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "\n")); 2493 1.2.2.2 skrll break; 2494 1.2.2.2 skrll 2495 1.2.2.2 skrll case DCCP_OPT_TIMESTAMP: 2496 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP_OPT_TIMESTAMP, size = %u\n", size)); 2497 1.2.2.2 skrll 2498 1.2.2.2 skrll /* Adding TimestampEcho to next outgoing */ 2499 1.2.2.2 skrll bcopy(options + i + 2, val, 4); 2500 1.2.2.2 skrll bzero(val + 4, 4); 2501 1.2.2.2 skrll dccp_add_option(dp, DCCP_OPT_TIMESTAMP_ECHO, val, 8); 2502 1.2.2.2 skrll break; 2503 1.2.2.3 skrll 2504 1.2.2.2 skrll case DCCP_OPT_TIMESTAMP_ECHO: 2505 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP_OPT_TIMESTAMP_ECHO, size = %u\n",size)); 2506 1.2.2.2 skrll for (j=2; j < size; j++) { 2507 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "val[%u] = %u ", j-1, options[i+j])); 2508 1.2.2.2 skrll } 2509 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "\n")); 2510 1.2.2.2 skrll 2511 1.2.2.2 skrll /* 2512 1.2.2.2 skrll bcopy(options + i + 2, &(dp->timestamp_echo), 4); 2513 1.2.2.2 skrll bcopy(options + i + 6, &(dp->timestamp_elapsed), 4); 2514 1.2.2.2 skrll ACK_DEBUG((LOG_INFO, "DATA; echo = %u , elapsed = %u\n", 2515 1.2.2.2 skrll dp->timestamp_echo, dp->timestamp_elapsed)); 2516 1.2.2.2 skrll */ 2517 1.2.2.3 skrll 2518 1.2.2.2 skrll break; 2519 1.2.2.2 skrll 2520 1.2.2.2 skrll case DCCP_OPT_ACK_VECTOR0: 2521 1.2.2.2 skrll case DCCP_OPT_ACK_VECTOR1: 2522 1.2.2.2 skrll case DCCP_OPT_ELAPSEDTIME: 2523 1.2.2.2 skrll /* Dont do nothing here. Let the CC deal with it */ 2524 1.2.2.2 skrll break; 2525 1.2.2.3 skrll 2526 1.2.2.2 skrll default: 2527 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got an unknown option, option = %u, size = %u!\n", opt, size)); 2528 1.2.2.2 skrll break; 2529 1.2.2.2 skrll 2530 1.2.2.2 skrll } 2531 1.2.2.2 skrll i += size - 1; 2532 1.2.2.2 skrll 2533 1.2.2.2 skrll } else { 2534 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got a CCID option (%d), do nothing!\n", opt)); 2535 1.2.2.2 skrll size = options[i+ 1]; 2536 1.2.2.2 skrll if (size < 3 || size > 10) { 2537 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Error, option size = %u\n", size)); 2538 1.2.2.2 skrll return; 2539 1.2.2.2 skrll } 2540 1.2.2.2 skrll i += size - 1; 2541 1.2.2.2 skrll } 2542 1.2.2.2 skrll } 2543 1.2.2.2 skrll 2544 1.2.2.2 skrll } 2545 1.2.2.2 skrll 2546 1.2.2.2 skrll int 2547 1.2.2.2 skrll dccp_add_feature(struct dccpcb *dp, u_int8_t opt, u_int8_t feature, char *val, u_int8_t val_len) 2548 1.2.2.2 skrll { 2549 1.2.2.2 skrll int i; 2550 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_add_feature, opt = %u, feature = %u, val_len = %u\n", opt, feature, val_len)); 2551 1.2.2.2 skrll 2552 1.2.2.2 skrll if (DCCP_MAX_OPTIONS > (dp->featlen + val_len + 3)) { 2553 1.2.2.2 skrll dp->features[dp->featlen] = opt; 2554 1.2.2.2 skrll dp->features[dp->featlen + 1] = val_len + 3; 2555 1.2.2.2 skrll dp->features[dp->featlen +2] = feature; 2556 1.2.2.2 skrll dp->featlen += 3; 2557 1.2.2.2 skrll for (i = 0; i<val_len; i++) { 2558 1.2.2.2 skrll dp->features[dp->featlen] = val[i]; 2559 1.2.2.2 skrll dp->featlen++; 2560 1.2.2.2 skrll } 2561 1.2.2.2 skrll } else { 2562 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "No room for more features, featlen = %u\n", dp->featlen)); 2563 1.2.2.2 skrll return -1; 2564 1.2.2.2 skrll } 2565 1.2.2.2 skrll 2566 1.2.2.2 skrll return 0; 2567 1.2.2.2 skrll } 2568 1.2.2.2 skrll 2569 1.2.2.2 skrll int 2570 1.2.2.2 skrll dccp_remove_feature(struct dccpcb *dp, u_int8_t opt, u_int8_t feature) 2571 1.2.2.2 skrll { 2572 1.2.2.2 skrll int i = 0, j = 0, k; 2573 1.2.2.2 skrll u_int8_t t_opt, t_feature, len; 2574 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_remove_feature, featlen = %u, opt = %u, feature = %u\n", dp->featlen, opt, feature)); 2575 1.2.2.2 skrll 2576 1.2.2.2 skrll while (i < dp->featlen) { 2577 1.2.2.2 skrll t_opt = dp->features[i]; 2578 1.2.2.2 skrll len = dp->features[i+ 1]; 2579 1.2.2.2 skrll 2580 1.2.2.2 skrll if (i + len > dp->featlen) { 2581 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Error, len = %u and i(%u) + len > dp->featlen (%u)\n", len, i, dp->featlen)); 2582 1.2.2.2 skrll return 1; 2583 1.2.2.2 skrll } 2584 1.2.2.2 skrll t_feature = dp->features[i+2]; 2585 1.2.2.2 skrll 2586 1.2.2.2 skrll if (t_opt == opt && t_feature == feature) { 2587 1.2.2.2 skrll i += len; 2588 1.2.2.2 skrll } else { 2589 1.2.2.2 skrll if (i != j) { 2590 1.2.2.2 skrll for (k = 0; k < len; k++) { 2591 1.2.2.2 skrll dp->features[j+k] = dp->features[i+k]; 2592 1.2.2.2 skrll } 2593 1.2.2.2 skrll } 2594 1.2.2.2 skrll i += len; 2595 1.2.2.2 skrll j += len; 2596 1.2.2.2 skrll } 2597 1.2.2.2 skrll } 2598 1.2.2.2 skrll dp->featlen = j; 2599 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Exiting dccp_remove_feature, featlen = %u\n", dp->featlen)); 2600 1.2.2.2 skrll return 0; 2601 1.2.2.2 skrll } 2602 1.2.2.2 skrll 2603 1.2.2.2 skrll void 2604 1.2.2.2 skrll dccp_feature_neg(struct dccpcb *dp, u_int8_t opt, u_int8_t feature, u_int8_t val_len, char *val) 2605 1.2.2.2 skrll { 2606 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Running dccp_feature_neg, opt = %u, feature = %u len = %u ", opt, feature, val_len)); 2607 1.2.2.2 skrll 2608 1.2.2.2 skrll switch (feature) { 2609 1.2.2.2 skrll case DCCP_FEATURE_CC: 2610 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got CCID negotiation, opt = %u, val[0] = %u\n", opt, val[0])); 2611 1.2.2.2 skrll if (opt == DCCP_OPT_CHANGE_R) { 2612 1.2.2.2 skrll if (val[0] == 2 || val[0] == 3 || val[0] == 0) { 2613 1.2.2.2 skrll /* try to use preferable CCID */ 2614 1.2.2.2 skrll int i; 2615 1.2.2.2 skrll for (i = 1; i < val_len; i ++) if (val[i] == dp->pref_cc) val[0] = dp->pref_cc; 2616 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Sending DCCP_OPT_CONFIRM_L on CCID %u\n", val[0])); 2617 1.2.2.2 skrll dccp_remove_feature(dp, DCCP_OPT_CONFIRM_L, DCCP_FEATURE_CC); 2618 1.2.2.2 skrll dccp_add_feature_option(dp, DCCP_OPT_CONFIRM_L, DCCP_FEATURE_CC , val, 1); 2619 1.2.2.2 skrll if (dp->cc_in_use[0] < 1) { 2620 1.2.2.2 skrll dp->cc_state[0] = (*cc_sw[val[0] + 1].cc_send_init)(dp); 2621 1.2.2.2 skrll dp->cc_in_use[0] = val[0] + 1; 2622 1.2.2.2 skrll } else { 2623 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "We already have negotiated a CC!!!\n")); 2624 1.2.2.2 skrll } 2625 1.2.2.2 skrll } 2626 1.2.2.2 skrll } else if (opt == DCCP_OPT_CONFIRM_L) { 2627 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Got DCCP_OPT_CONFIRM_L on CCID %u\n", val[0])); 2628 1.2.2.2 skrll dccp_remove_feature(dp, DCCP_OPT_CHANGE_R, DCCP_FEATURE_CC); 2629 1.2.2.2 skrll if (dp->cc_in_use[1] < 1) { 2630 1.2.2.2 skrll dp->cc_state[1] = (*cc_sw[val[0] + 1].cc_recv_init)(dp); 2631 1.2.2.2 skrll dp->cc_in_use[1] = val[0] + 1; 2632 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "confirmed cc_in_use[1] = %d\n", dp->cc_in_use[1])); 2633 1.2.2.2 skrll } else { 2634 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "We already have negotiated a CC!!! (confirm) %d\n", dp->cc_in_use[1])); 2635 1.2.2.2 skrll } 2636 1.2.2.2 skrll } 2637 1.2.2.3 skrll 2638 1.2.2.2 skrll break; 2639 1.2.2.2 skrll 2640 1.2.2.2 skrll case DCCP_FEATURE_ACKVECTOR: 2641 1.2.2.2 skrll ACK_DEBUG((LOG_INFO, "Got _Use Ack Vector_\n")); 2642 1.2.2.2 skrll if (opt == DCCP_OPT_CHANGE_R) { 2643 1.2.2.2 skrll if (val[0] == 1) { 2644 1.2.2.2 skrll dccp_use_ackvector(dp); 2645 1.2.2.2 skrll dccp_remove_feature(dp, DCCP_OPT_CONFIRM_L, DCCP_FEATURE_ACKVECTOR); 2646 1.2.2.2 skrll dccp_add_feature_option(dp, DCCP_OPT_CONFIRM_L, DCCP_FEATURE_ACKVECTOR , val, 1); 2647 1.2.2.2 skrll } else { 2648 1.2.2.2 skrll ACK_DEBUG((LOG_INFO, "ERROR. Strange val %u\n", val[0])); 2649 1.2.2.2 skrll } 2650 1.2.2.2 skrll } else if (opt == DCCP_OPT_CONFIRM_L) { 2651 1.2.2.2 skrll dccp_remove_feature(dp, DCCP_OPT_CONFIRM_L, DCCP_FEATURE_ACKVECTOR); 2652 1.2.2.2 skrll if (val[0] == 1) { 2653 1.2.2.2 skrll dp->remote_ackvector = 1; 2654 1.2.2.2 skrll ACK_DEBUG((LOG_INFO,"Remote side confirmed AckVector usage\n")); 2655 1.2.2.2 skrll } else { 2656 1.2.2.2 skrll ACK_DEBUG((LOG_INFO, "ERROR. Strange val %u\n", val[0])); 2657 1.2.2.2 skrll } 2658 1.2.2.2 skrll } 2659 1.2.2.2 skrll break; 2660 1.2.2.3 skrll 2661 1.2.2.2 skrll case DCCP_FEATURE_ACKRATIO: 2662 1.2.2.2 skrll if (opt == DCCP_OPT_CHANGE_R) { 2663 1.2.2.2 skrll bcopy(val , &(dp->ack_ratio), 1); 2664 1.2.2.2 skrll ACK_DEBUG((LOG_INFO, "Feature: Change Ack Ratio to %u\n", dp->ack_ratio)); 2665 1.2.2.2 skrll } 2666 1.2.2.2 skrll break; 2667 1.2.2.3 skrll 2668 1.2.2.2 skrll case DCCP_FEATURE_ECN: 2669 1.2.2.2 skrll case DCCP_FEATURE_MOBILITY: 2670 1.2.2.2 skrll default: 2671 1.2.2.2 skrll /* we should send back empty CONFIRM_L for unknown feature unless it's not mandatory */ 2672 1.2.2.2 skrll dccp_add_option(dp, DCCP_OPT_CONFIRM_L, NULL, 0); 2673 1.2.2.2 skrll break; 2674 1.2.2.2 skrll 2675 1.2.2.2 skrll } 2676 1.2.2.2 skrll } 2677 1.2.2.2 skrll 2678 1.2.2.2 skrll #ifdef __FreeBSD__ 2679 1.2.2.2 skrll static int 2680 1.2.2.2 skrll dccp_pcblist(SYSCTL_HANDLER_ARGS) 2681 1.2.2.2 skrll { 2682 1.2.2.2 skrll 2683 1.2.2.2 skrll int error, i, n, s; 2684 1.2.2.2 skrll struct inpcb *inp, **inp_list; 2685 1.2.2.2 skrll inp_gen_t gencnt; 2686 1.2.2.2 skrll struct xinpgen xig; 2687 1.2.2.2 skrll 2688 1.2.2.2 skrll /* 2689 1.2.2.2 skrll * The process of preparing the TCB list is too time-consuming and 2690 1.2.2.2 skrll * resource-intensive to repeat twice on every request. 2691 1.2.2.2 skrll */ 2692 1.2.2.2 skrll if (req->oldptr == 0) { 2693 1.2.2.2 skrll n = dccpbinfo.ipi_count; 2694 1.2.2.2 skrll req->oldidx = 2 * (sizeof xig) 2695 1.2.2.2 skrll + (n + n/8) * sizeof(struct xdccpcb); 2696 1.2.2.2 skrll return 0; 2697 1.2.2.2 skrll } 2698 1.2.2.2 skrll 2699 1.2.2.2 skrll 2700 1.2.2.2 skrll if (req->newptr != 0) 2701 1.2.2.2 skrll return EPERM; 2702 1.2.2.2 skrll 2703 1.2.2.2 skrll 2704 1.2.2.2 skrll /* 2705 1.2.2.2 skrll * OK, now we're committed to doing something. 2706 1.2.2.2 skrll */ 2707 1.2.2.2 skrll s = splnet(); 2708 1.2.2.2 skrll gencnt = dccpbinfo.ipi_gencnt; 2709 1.2.2.2 skrll n = dccpbinfo.ipi_count; 2710 1.2.2.2 skrll splx(s); 2711 1.2.2.2 skrll 2712 1.2.2.2 skrll #if __FreeBSD_version >= 500000 2713 1.2.2.2 skrll sysctl_wire_old_buffer(req, 2 * (sizeof xig) 2714 1.2.2.2 skrll + n * sizeof(struct xdccpcb)); 2715 1.2.2.2 skrll #endif 2716 1.2.2.2 skrll 2717 1.2.2.2 skrll xig.xig_len = sizeof xig; 2718 1.2.2.2 skrll xig.xig_count = n; 2719 1.2.2.2 skrll xig.xig_gen = gencnt; 2720 1.2.2.2 skrll xig.xig_sogen = so_gencnt; 2721 1.2.2.2 skrll error = SYSCTL_OUT(req, &xig, sizeof xig); 2722 1.2.2.2 skrll if (error) 2723 1.2.2.2 skrll return error; 2724 1.2.2.2 skrll 2725 1.2.2.2 skrll inp_list = malloc(n * sizeof *inp_list, M_TEMP, M_WAITOK); 2726 1.2.2.2 skrll if (inp_list == 0) 2727 1.2.2.2 skrll return ENOMEM; 2728 1.2.2.3 skrll 2729 1.2.2.2 skrll s = splsoftnet(); 2730 1.2.2.2 skrll INP_INFO_RLOCK(&dccpbinfo); 2731 1.2.2.2 skrll 2732 1.2.2.2 skrll for (inp = LIST_FIRST(dccpbinfo.listhead), i = 0; inp && i < n; 2733 1.2.2.2 skrll inp = LIST_NEXT(inp, inp_list)) { 2734 1.2.2.2 skrll INP_LOCK(inp); 2735 1.2.2.2 skrll if (inp->inp_gencnt <= gencnt && 2736 1.2.2.2 skrll #if __FreeBSD_version >= 500000 2737 1.2.2.2 skrll cr_canseesocket(req->td->td_ucred, inp->inp_socket) == 0) 2738 1.2.2.2 skrll #else 2739 1.2.2.2 skrll !prison_xinpcb(req->p, inp)) 2740 1.2.2.2 skrll #endif 2741 1.2.2.2 skrll inp_list[i++] = inp; 2742 1.2.2.2 skrll INP_UNLOCK(inp); 2743 1.2.2.2 skrll } 2744 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 2745 1.2.2.2 skrll splx(s); 2746 1.2.2.2 skrll n = i; 2747 1.2.2.2 skrll 2748 1.2.2.2 skrll error = 0; 2749 1.2.2.2 skrll for (i = 0; i < n; i++) { 2750 1.2.2.2 skrll inp = inp_list[i]; 2751 1.2.2.2 skrll INP_LOCK(inp); 2752 1.2.2.2 skrll 2753 1.2.2.2 skrll if (inp->inp_gencnt <= gencnt) { 2754 1.2.2.2 skrll struct xdccpcb xd; 2755 1.2.2.2 skrll vaddr_t inp_ppcb; 2756 1.2.2.2 skrll xd.xd_len = sizeof xd; 2757 1.2.2.2 skrll /* XXX should avoid extra copy */ 2758 1.2.2.2 skrll bcopy(inp, &xd.xd_inp, sizeof *inp); 2759 1.2.2.2 skrll inp_ppcb = inp->inp_ppcb; 2760 1.2.2.2 skrll if (inp_ppcb != NULL) 2761 1.2.2.2 skrll bcopy(inp_ppcb, &xd.xd_dp, sizeof xd.xd_dp); 2762 1.2.2.2 skrll else 2763 1.2.2.2 skrll bzero((char *) &xd.xd_dp, sizeof xd.xd_dp); 2764 1.2.2.2 skrll if (inp->inp_socket) 2765 1.2.2.2 skrll sotoxsocket(inp->inp_socket, &xd.xd_socket); 2766 1.2.2.2 skrll error = SYSCTL_OUT(req, &xd, sizeof xd); 2767 1.2.2.2 skrll } 2768 1.2.2.2 skrll INP_UNLOCK(inp); 2769 1.2.2.2 skrll } 2770 1.2.2.2 skrll if (!error) { 2771 1.2.2.2 skrll /* 2772 1.2.2.2 skrll * Give the user an updated idea of our state. 2773 1.2.2.2 skrll * If the generation differs from what we told 2774 1.2.2.2 skrll * her before, she knows that something happened 2775 1.2.2.2 skrll * while we were processing this request, and it 2776 1.2.2.2 skrll * might be necessary to retry. 2777 1.2.2.2 skrll */ 2778 1.2.2.2 skrll s = splnet(); 2779 1.2.2.2 skrll INP_INFO_RLOCK(&dccpbinfo); 2780 1.2.2.2 skrll xig.xig_gen = dccpbinfo.ipi_gencnt; 2781 1.2.2.2 skrll xig.xig_sogen = so_gencnt; 2782 1.2.2.2 skrll xig.xig_count = dccpbinfo.ipi_count; 2783 1.2.2.2 skrll 2784 1.2.2.2 skrll 2785 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 2786 1.2.2.2 skrll splx(s); 2787 1.2.2.2 skrll error = SYSCTL_OUT(req, &xig, sizeof xig); 2788 1.2.2.2 skrll } 2789 1.2.2.2 skrll free(inp_list, M_TEMP); 2790 1.2.2.2 skrll return error; 2791 1.2.2.2 skrll } 2792 1.2.2.2 skrll #endif 2793 1.2.2.2 skrll 2794 1.2.2.2 skrll #ifdef __FreeBSD__ 2795 1.2.2.2 skrll SYSCTL_PROC(_net_inet_dccp, DCCPCTL_PCBLIST, pcblist, CTLFLAG_RD, 0, 0, 2796 1.2.2.2 skrll dccp_pcblist, "S,xdccpcb", "List of active DCCP sockets"); 2797 1.2.2.2 skrll #endif 2798 1.2.2.2 skrll 2799 1.2.2.2 skrll void 2800 1.2.2.2 skrll dccp_timewait_t(void *dcb) 2801 1.2.2.2 skrll { 2802 1.2.2.2 skrll struct dccpcb *dp = dcb; 2803 1.2.2.2 skrll 2804 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_timewait_t!\n")); 2805 1.2.2.2 skrll mutex_enter(softnet_lock); 2806 1.2.2.2 skrll INP_INFO_WLOCK(&dccpbinfo); 2807 1.2.2.2 skrll INP_LOCK(dp->d_inpcb); 2808 1.2.2.2 skrll dccp_close(dp); 2809 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 2810 1.2.2.2 skrll mutex_exit(softnet_lock); 2811 1.2.2.2 skrll } 2812 1.2.2.2 skrll 2813 1.2.2.2 skrll void 2814 1.2.2.2 skrll dccp_connect_t(void *dcb) 2815 1.2.2.2 skrll { 2816 1.2.2.2 skrll struct dccpcb *dp = dcb; 2817 1.2.2.2 skrll 2818 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_connect_t!\n")); 2819 1.2.2.2 skrll mutex_enter(softnet_lock); 2820 1.2.2.2 skrll INP_INFO_WLOCK(&dccpbinfo); 2821 1.2.2.2 skrll INP_LOCK(dp->d_inpcb); 2822 1.2.2.2 skrll dccp_close(dp); 2823 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 2824 1.2.2.2 skrll mutex_exit(softnet_lock); 2825 1.2.2.2 skrll } 2826 1.2.2.2 skrll 2827 1.2.2.2 skrll void 2828 1.2.2.2 skrll dccp_close_t(void *dcb) 2829 1.2.2.2 skrll { 2830 1.2.2.2 skrll struct dccpcb *dp = dcb; 2831 1.2.2.2 skrll 2832 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_close_t!\n")); 2833 1.2.2.2 skrll mutex_enter(softnet_lock); 2834 1.2.2.2 skrll INP_INFO_WLOCK(&dccpbinfo); 2835 1.2.2.2 skrll dp->state = DCCPS_TIME_WAIT; /* HMM */ 2836 1.2.2.2 skrll if (dp->who == DCCP_SERVER) { 2837 1.2.2.2 skrll INP_LOCK(dp->d_inpcb); 2838 1.2.2.2 skrll KERNEL_LOCK(1, NULL); 2839 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 2840 1.2.2.2 skrll KERNEL_UNLOCK_ONE(NULL); 2841 1.2.2.2 skrll dccp_close(dp); 2842 1.2.2.2 skrll } else { 2843 1.2.2.2 skrll INP_LOCK(dp->d_inpcb); 2844 1.2.2.2 skrll dccp_output(dp, DCCP_TYPE_RESET + 2); 2845 1.2.2.2 skrll /*dp->state = DCCPS_TIME_WAIT; */ 2846 1.2.2.2 skrll callout_reset(&dp->timewait_timer, DCCP_TIMEWAIT_TIMER, 2847 1.2.2.2 skrll dccp_timewait_t, dp); 2848 1.2.2.2 skrll INP_UNLOCK(dp->d_inpcb); 2849 1.2.2.2 skrll } 2850 1.2.2.2 skrll INP_INFO_WUNLOCK(&dccpbinfo); 2851 1.2.2.2 skrll mutex_exit(softnet_lock); 2852 1.2.2.2 skrll } 2853 1.2.2.2 skrll 2854 1.2.2.2 skrll void 2855 1.2.2.2 skrll dccp_retrans_t(void *dcb) 2856 1.2.2.2 skrll { 2857 1.2.2.2 skrll struct dccpcb *dp = dcb; 2858 1.2.2.2 skrll /*struct inpcb *inp;*/ 2859 1.2.2.2 skrll 2860 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_retrans_t!\n")); 2861 1.2.2.2 skrll mutex_enter(softnet_lock); 2862 1.2.2.2 skrll INP_INFO_RLOCK(&dccpbinfo); 2863 1.2.2.2 skrll /*inp = dp->d_inpcb;*/ 2864 1.2.2.2 skrll INP_LOCK(inp); 2865 1.2.2.2 skrll INP_INFO_RUNLOCK(&dccpbinfo); 2866 1.2.2.2 skrll callout_stop(&dp->retrans_timer); 2867 1.2.2.2 skrll KERNEL_LOCK(1, NULL); 2868 1.2.2.2 skrll dccp_output(dp, 0); 2869 1.2.2.2 skrll KERNEL_UNLOCK_ONE(NULL); 2870 1.2.2.2 skrll dp->retrans = dp->retrans * 2; 2871 1.2.2.2 skrll callout_reset(&dp->retrans_timer, dp->retrans, dccp_retrans_t, dp); 2872 1.2.2.2 skrll INP_UNLOCK(inp); 2873 1.2.2.2 skrll mutex_exit(softnet_lock); 2874 1.2.2.2 skrll } 2875 1.2.2.2 skrll 2876 1.2.2.2 skrll static int 2877 1.2.2.2 skrll dccp_ioctl(struct socket *so, u_long cmd, void *nam, struct ifnet *ifp) 2878 1.2.2.2 skrll { 2879 1.2.2.2 skrll int error = 0; 2880 1.2.2.2 skrll int family; 2881 1.2.2.2 skrll 2882 1.2.2.2 skrll family = so->so_proto->pr_domain->dom_family; 2883 1.2.2.2 skrll switch (family) { 2884 1.2.2.2 skrll case PF_INET: 2885 1.2.2.2 skrll error = in_control(so, cmd, nam, ifp); 2886 1.2.2.2 skrll break; 2887 1.2.2.2 skrll #ifdef INET6 2888 1.2.2.2 skrll case PF_INET6: 2889 1.2.2.2 skrll error = in6_control(so, cmd, nam, ifp); 2890 1.2.2.2 skrll break; 2891 1.2.2.2 skrll #endif 2892 1.2.2.2 skrll default: 2893 1.2.2.2 skrll error = EAFNOSUPPORT; 2894 1.2.2.2 skrll } 2895 1.2.2.2 skrll return (error); 2896 1.2.2.2 skrll } 2897 1.2.2.2 skrll 2898 1.2.2.2 skrll static int 2899 1.2.2.2 skrll dccp_stat(struct socket *so, struct stat *ub) 2900 1.2.2.2 skrll { 2901 1.2.2.2 skrll return 0; 2902 1.2.2.2 skrll } 2903 1.2.2.2 skrll 2904 1.2.2.2 skrll static int 2905 1.2.2.3 skrll dccp_peeraddr(struct socket *so, struct sockaddr *nam) 2906 1.2.2.2 skrll { 2907 1.2.2.3 skrll 2908 1.2.2.2 skrll KASSERT(solocked(so)); 2909 1.2.2.2 skrll KASSERT(sotoinpcb(so) != NULL); 2910 1.2.2.2 skrll KASSERT(nam != NULL); 2911 1.2.2.2 skrll 2912 1.2.2.3 skrll in_setpeeraddr(sotoinpcb(so), (struct sockaddr_in *)nam); 2913 1.2.2.2 skrll return 0; 2914 1.2.2.2 skrll } 2915 1.2.2.2 skrll 2916 1.2.2.2 skrll static int 2917 1.2.2.3 skrll dccp_sockaddr(struct socket *so, struct sockaddr *nam) 2918 1.2.2.2 skrll { 2919 1.2.2.3 skrll 2920 1.2.2.2 skrll KASSERT(solocked(so)); 2921 1.2.2.2 skrll KASSERT(sotoinpcb(so) != NULL); 2922 1.2.2.2 skrll KASSERT(nam != NULL); 2923 1.2.2.2 skrll 2924 1.2.2.3 skrll in_setsockaddr(sotoinpcb(so), (struct sockaddr_in *)nam); 2925 1.2.2.2 skrll return 0; 2926 1.2.2.2 skrll } 2927 1.2.2.2 skrll 2928 1.2.2.2 skrll static int 2929 1.2.2.2 skrll dccp_rcvd(struct socket *so, int flags, struct lwp *l) 2930 1.2.2.2 skrll { 2931 1.2.2.2 skrll KASSERT(solocked(so)); 2932 1.2.2.2 skrll 2933 1.2.2.2 skrll return EOPNOTSUPP; 2934 1.2.2.2 skrll } 2935 1.2.2.2 skrll 2936 1.2.2.2 skrll static int 2937 1.2.2.2 skrll dccp_recvoob(struct socket *so, struct mbuf *m, int flags) 2938 1.2.2.2 skrll { 2939 1.2.2.2 skrll KASSERT(solocked(so)); 2940 1.2.2.2 skrll 2941 1.2.2.2 skrll return EOPNOTSUPP; 2942 1.2.2.2 skrll } 2943 1.2.2.2 skrll 2944 1.2.2.2 skrll static int 2945 1.2.2.2 skrll dccp_sendoob(struct socket *so, struct mbuf *m, struct mbuf *control) 2946 1.2.2.2 skrll { 2947 1.2.2.2 skrll KASSERT(solocked(so)); 2948 1.2.2.2 skrll 2949 1.2.2.2 skrll m_freem(m); 2950 1.2.2.2 skrll m_freem(control); 2951 1.2.2.2 skrll 2952 1.2.2.2 skrll return EOPNOTSUPP; 2953 1.2.2.2 skrll } 2954 1.2.2.2 skrll 2955 1.2.2.2 skrll static int 2956 1.2.2.2 skrll dccp_purgeif(struct socket *so, struct ifnet *ifp) 2957 1.2.2.2 skrll { 2958 1.2.2.2 skrll int s; 2959 1.2.2.2 skrll 2960 1.2.2.2 skrll s = splsoftnet(); 2961 1.2.2.2 skrll mutex_enter(softnet_lock); 2962 1.2.2.2 skrll in_pcbpurgeif0(&dccpbtable, ifp); 2963 1.2.2.2 skrll in_purgeif(ifp); 2964 1.2.2.2 skrll in_pcbpurgeif(&dccpbtable, ifp); 2965 1.2.2.2 skrll mutex_exit(softnet_lock); 2966 1.2.2.2 skrll splx(s); 2967 1.2.2.2 skrll 2968 1.2.2.2 skrll return 0; 2969 1.2.2.2 skrll } 2970 1.2.2.2 skrll 2971 1.2.2.2 skrll /****** Ack Vector functions *********/ 2972 1.2.2.2 skrll 2973 1.2.2.2 skrll /** 2974 1.2.2.2 skrll * Initialize and allocate mem for Ack Vector 2975 1.2.2.2 skrll **/ 2976 1.2.2.2 skrll void 2977 1.2.2.2 skrll dccp_use_ackvector(struct dccpcb *dp) 2978 1.2.2.2 skrll { 2979 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO,"Initializing AckVector\n")); 2980 1.2.2.2 skrll if (dp->ackvector != 0) { 2981 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "It was already initialized!!!\n")); 2982 1.2.2.2 skrll return; 2983 1.2.2.2 skrll } 2984 1.2.2.2 skrll dp->av_size = DCCP_VECTORSIZE; 2985 1.2.2.2 skrll /* need 2 bits per entry */ 2986 1.2.2.2 skrll dp->ackvector = malloc(dp->av_size/4, M_PCB, M_NOWAIT | M_ZERO); 2987 1.2.2.2 skrll if (dp->ackvector == 0) { 2988 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Unable to allocate memory for ackvector\n")); 2989 1.2.2.2 skrll /* What to do now? */ 2990 1.2.2.2 skrll dp->av_size = 0; 2991 1.2.2.2 skrll return; 2992 1.2.2.2 skrll } 2993 1.2.2.2 skrll memset(dp->ackvector, 0xff, dp->av_size/4); 2994 1.2.2.2 skrll dp->av_hs = dp->av_ts = 0; 2995 1.2.2.2 skrll dp->av_hp = dp->ackvector; 2996 1.2.2.2 skrll } 2997 1.2.2.2 skrll 2998 1.2.2.2 skrll /** 2999 1.2.2.2 skrll * Set 'seqnr' as the new head in ackvector 3000 1.2.2.2 skrll **/ 3001 1.2.2.2 skrll void 3002 1.2.2.2 skrll dccp_update_ackvector(struct dccpcb *dp, u_int64_t seqnr) 3003 1.2.2.2 skrll { 3004 1.2.2.2 skrll int64_t gap; 3005 1.2.2.2 skrll u_char *t; 3006 1.2.2.2 skrll 3007 1.2.2.2 skrll /* Ignore wrapping for now */ 3008 1.2.2.3 skrll 3009 1.2.2.2 skrll ACK_DEBUG((LOG_INFO,"New head in ackvector: %u\n", seqnr)); 3010 1.2.2.3 skrll 3011 1.2.2.2 skrll if (dp->av_size == 0) { 3012 1.2.2.2 skrll ACK_DEBUG((LOG_INFO, "Update: AckVector NOT YET INITIALIZED!!!\n")); 3013 1.2.2.2 skrll dccp_use_ackvector(dp); 3014 1.2.2.2 skrll } 3015 1.2.2.3 skrll 3016 1.2.2.2 skrll if (seqnr > dp->av_hs) { 3017 1.2.2.2 skrll gap = seqnr - dp->av_hs; 3018 1.2.2.2 skrll } else { 3019 1.2.2.2 skrll /* We received obsolete information */ 3020 1.2.2.2 skrll return; 3021 1.2.2.2 skrll } 3022 1.2.2.3 skrll 3023 1.2.2.2 skrll t = dp->av_hp + (gap/4); 3024 1.2.2.2 skrll if (t >= (dp->ackvector + (dp->av_size/4))) 3025 1.2.2.2 skrll t -= (dp->av_size / 4); /* ackvector wrapped */ 3026 1.2.2.2 skrll dp->av_hp = t; 3027 1.2.2.2 skrll dp->av_hs = seqnr; 3028 1.2.2.2 skrll } 3029 1.2.2.2 skrll 3030 1.2.2.2 skrll /** 3031 1.2.2.2 skrll * We've received a packet. store in local av so it's included in 3032 1.2.2.2 skrll * next Ack Vector sent 3033 1.2.2.2 skrll **/ 3034 1.2.2.2 skrll void 3035 1.2.2.2 skrll dccp_increment_ackvector(struct dccpcb *dp, u_int64_t seqnr) 3036 1.2.2.2 skrll { 3037 1.2.2.2 skrll u_int64_t offset, dc; 3038 1.2.2.2 skrll int64_t gap; 3039 1.2.2.2 skrll u_char *t, *n; 3040 1.2.2.3 skrll 3041 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Entering dccp_increment_ackvecktor %d\n", dp->av_size)); 3042 1.2.2.2 skrll if (dp->av_size == 0) { 3043 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "Increment: AckVector NOT YET INITIALIZED!!!\n")); 3044 1.2.2.2 skrll dccp_use_ackvector(dp); 3045 1.2.2.2 skrll } 3046 1.2.2.3 skrll 3047 1.2.2.2 skrll if (dp->av_hs == dp->av_ts) { 3048 1.2.2.2 skrll /* Empty ack vector */ 3049 1.2.2.2 skrll dp->av_hs = dp->av_ts = seqnr; 3050 1.2.2.2 skrll } 3051 1.2.2.2 skrll 3052 1.2.2.2 skrll /* Check for wrapping */ 3053 1.2.2.2 skrll if (seqnr >= dp->av_hs) { 3054 1.2.2.2 skrll /* Not wrapped */ 3055 1.2.2.2 skrll gap = seqnr - dp->av_hs; 3056 1.2.2.2 skrll } else { 3057 1.2.2.2 skrll /* Wrapped */ 3058 1.2.2.2 skrll gap = seqnr + 0x1000000000000LL - dp->av_hs; /* seqnr = 48 bits */ 3059 1.2.2.2 skrll } 3060 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "dccp_increment_ackvecktor gap=%llu av_size %d\n", gap, dp->av_size)); 3061 1.2.2.2 skrll 3062 1.2.2.2 skrll if (gap >= dp->av_size) { 3063 1.2.2.2 skrll /* gap is bigger than ackvector size? baaad */ 3064 1.2.2.2 skrll /* maybe we should increase the ackvector here */ 3065 1.2.2.2 skrll DCCP_DEBUG((LOG_INFO, "increment_ackvector error. gap: %llu, av_size: %d, seqnr: %d\n", 3066 1.2.2.2 skrll gap, dp->av_size, seqnr)); 3067 1.2.2.2 skrll return; 3068 1.2.2.2 skrll } 3069 1.2.2.3 skrll 3070 1.2.2.2 skrll offset = gap % 4; /* hi or low 2 bits to mark */ 3071 1.2.2.2 skrll t = dp->av_hp + (gap/4); 3072 1.2.2.2 skrll if (t >= (dp->ackvector + (dp->av_size/4))) 3073 1.2.2.2 skrll t -= (dp->av_size / 4); /* ackvector wrapped */ 3074 1.2.2.3 skrll 3075 1.2.2.2 skrll *t = *t & (~(0x03 << (offset *2))); /* turn off bits, 00 is rcvd, 11 is missing */ 3076 1.2.2.2 skrll 3077 1.2.2.2 skrll dp->av_ts = seqnr + 1; 3078 1.2.2.2 skrll if (dp->av_ts == 0x1000000000000LL) 3079 1.2.2.2 skrll dp->av_ts = 0; 3080 1.2.2.2 skrll 3081 1.2.2.2 skrll if (gap > (dp->av_size - 128)) { 3082 1.2.2.2 skrll n = malloc(dp->av_size/2, M_PCB, M_NOWAIT | M_ZERO); /* old size * 2 */ 3083 1.2.2.2 skrll memset (n + dp->av_size / 4, 0xff, dp->av_size / 4); /* new half all missing */ 3084 1.2.2.2 skrll dc = (dp->ackvector + (dp->av_size/4)) - dp->av_hp; 3085 1.2.2.2 skrll memcpy (n, dp->av_hp, dc); /* tail to end */ 3086 1.2.2.2 skrll memcpy (n+dc, dp->ackvector, dp->av_hp - dp->ackvector); /* start to tail */ 3087 1.2.2.2 skrll dp->av_size = dp->av_size * 2; /* counted in items, so it';s a doubling */ 3088 1.2.2.2 skrll free (dp->ackvector, M_PCB); 3089 1.2.2.2 skrll dp->av_hp = dp->ackvector = n; 3090 1.2.2.2 skrll } 3091 1.2.2.2 skrll } 3092 1.2.2.2 skrll 3093 1.2.2.2 skrll /** 3094 1.2.2.2 skrll * Generates the ack vector to send in outgoing packet. 3095 1.2.2.2 skrll * These are backwards (first packet in ack vector is packet indicated by Ack Number, 3096 1.2.2.2 skrll * subsequent are older packets). 3097 1.2.2.2 skrll **/ 3098 1.2.2.2 skrll 3099 1.2.2.2 skrll u_int16_t 3100 1.2.2.2 skrll dccp_generate_ackvector(struct dccpcb *dp, u_char *buf) 3101 1.2.2.2 skrll { 3102 1.2.2.2 skrll int64_t j; 3103 1.2.2.2 skrll u_int64_t i; 3104 1.2.2.2 skrll u_int16_t cnt, oldlen, bufsize; 3105 1.2.2.2 skrll u_char oldstate, st; 3106 1.2.2.2 skrll 3107 1.2.2.2 skrll bufsize = 16; 3108 1.2.2.2 skrll cnt = 0; 3109 1.2.2.2 skrll 3110 1.2.2.2 skrll oldstate = 0x04; /* bad value */ 3111 1.2.2.2 skrll oldlen = 0; 3112 1.2.2.3 skrll 3113 1.2.2.2 skrll if (dp->av_size == 0) { 3114 1.2.2.2 skrll ACK_DEBUG((LOG_INFO, "Generate: AckVector NOT YET INITIALIZED!!!\n")); 3115 1.2.2.2 skrll return 0; 3116 1.2.2.2 skrll } 3117 1.2.2.2 skrll 3118 1.2.2.2 skrll if (dp->seq_rcv > dp->av_ts) { 3119 1.2.2.2 skrll /* AckNum is beyond our av-list , so we'll start with some 3120 1.2.2.2 skrll * 0x3 (Packet not yet received) */ 3121 1.2.2.2 skrll j = dp->seq_rcv - dp->av_ts -1; 3122 1.2.2.2 skrll do { 3123 1.2.2.2 skrll /* state | length */ 3124 1.2.2.2 skrll oldstate = 0x03; 3125 1.2.2.2 skrll if (j > 63) 3126 1.2.2.2 skrll oldlen = 63; 3127 1.2.2.2 skrll else 3128 1.2.2.2 skrll oldlen = j; 3129 1.2.2.3 skrll 3130 1.2.2.2 skrll buf[cnt] = (0x03 << 6) | oldlen; 3131 1.2.2.2 skrll cnt++; 3132 1.2.2.2 skrll if (cnt == bufsize) { 3133 1.2.2.2 skrll /* I've skipped the realloc bshit */ 3134 1.2.2.2 skrll /* PANIC */ 3135 1.2.2.2 skrll } 3136 1.2.2.2 skrll j-=63; 3137 1.2.2.2 skrll } while (j > 0); 3138 1.2.2.2 skrll } 3139 1.2.2.3 skrll 3140 1.2.2.2 skrll /* Ok now we're at dp->av_ts (unless AckNum is lower) */ 3141 1.2.2.2 skrll i = (dp->seq_rcv < dp->av_ts) ? dp->seq_rcv : dp->av_ts; 3142 1.2.2.2 skrll st = dccp_ackvector_state(dp, i); 3143 1.2.2.2 skrll 3144 1.2.2.2 skrll if (st == oldstate) { 3145 1.2.2.2 skrll cnt--; 3146 1.2.2.2 skrll oldlen++; 3147 1.2.2.2 skrll } else { 3148 1.2.2.2 skrll oldlen = 0; 3149 1.2.2.2 skrll oldstate = st; 3150 1.2.2.2 skrll } 3151 1.2.2.2 skrll 3152 1.2.2.2 skrll if (dp->av_ts > dp->av_hs) { 3153 1.2.2.2 skrll do { 3154 1.2.2.2 skrll i--; 3155 1.2.2.2 skrll st = dccp_ackvector_state(dp, i); 3156 1.2.2.2 skrll if (st == oldstate && oldlen < 64) { 3157 1.2.2.2 skrll oldlen++; 3158 1.2.2.2 skrll } else { 3159 1.2.2.2 skrll buf[cnt] = (oldstate << 6) | (oldlen & 0x3f); 3160 1.2.2.2 skrll cnt++; 3161 1.2.2.2 skrll oldlen = 0; 3162 1.2.2.2 skrll oldstate = st; 3163 1.2.2.2 skrll if (cnt == bufsize) { 3164 1.2.2.2 skrll /* PANIC */ 3165 1.2.2.2 skrll } 3166 1.2.2.2 skrll } 3167 1.2.2.3 skrll 3168 1.2.2.2 skrll } while (i > dp->av_hs); 3169 1.2.2.2 skrll } else { 3170 1.2.2.2 skrll /* It's wrapped */ 3171 1.2.2.2 skrll do { 3172 1.2.2.2 skrll i--; 3173 1.2.2.2 skrll st = dccp_ackvector_state(dp, i); 3174 1.2.2.2 skrll if (st == oldstate && oldlen < 64) { 3175 1.2.2.2 skrll oldlen++; 3176 1.2.2.2 skrll } else { 3177 1.2.2.2 skrll buf[cnt] = (oldstate << 6) | (oldlen & 0x3f); 3178 1.2.2.2 skrll cnt++; 3179 1.2.2.2 skrll oldlen = 0; 3180 1.2.2.2 skrll oldstate = st; 3181 1.2.2.2 skrll if (cnt == bufsize) { 3182 1.2.2.2 skrll /* PANIC */ 3183 1.2.2.2 skrll } 3184 1.2.2.2 skrll } 3185 1.2.2.3 skrll 3186 1.2.2.2 skrll } while (i > 0); 3187 1.2.2.2 skrll i = 0x1000000; 3188 1.2.2.2 skrll do { 3189 1.2.2.2 skrll i--; 3190 1.2.2.2 skrll st = dccp_ackvector_state(dp, i); 3191 1.2.2.2 skrll if (st == oldstate && oldlen < 64) { 3192 1.2.2.2 skrll oldlen++; 3193 1.2.2.2 skrll } else { 3194 1.2.2.2 skrll buf[cnt] = (oldstate << 6) | (oldlen & 0x3f); 3195 1.2.2.2 skrll cnt++; 3196 1.2.2.2 skrll oldlen = 0; 3197 1.2.2.2 skrll oldstate = st; 3198 1.2.2.2 skrll if (cnt == bufsize) { 3199 1.2.2.2 skrll /* PANIC */ 3200 1.2.2.2 skrll } 3201 1.2.2.2 skrll } 3202 1.2.2.2 skrll } while (i > dp->av_hs); 3203 1.2.2.2 skrll } 3204 1.2.2.3 skrll 3205 1.2.2.2 skrll /* add the last one */ 3206 1.2.2.2 skrll buf[cnt] = (oldstate << 6) | (oldlen & 0x3f); 3207 1.2.2.2 skrll cnt++; 3208 1.2.2.2 skrll 3209 1.2.2.2 skrll return cnt; 3210 1.2.2.2 skrll } 3211 1.2.2.2 skrll 3212 1.2.2.2 skrll u_char 3213 1.2.2.2 skrll dccp_ackvector_state(struct dccpcb *dp, u_int64_t seqnr) 3214 1.2.2.2 skrll { 3215 1.2.2.2 skrll u_int64_t gap, offset; 3216 1.2.2.2 skrll u_char *t; 3217 1.2.2.2 skrll 3218 1.2.2.2 skrll /* Check for wrapping */ 3219 1.2.2.2 skrll if (seqnr >= dp->av_hs) { 3220 1.2.2.2 skrll /* Not wrapped */ 3221 1.2.2.2 skrll gap = seqnr - dp->av_hs; 3222 1.2.2.2 skrll } else { 3223 1.2.2.2 skrll /* Wrapped */ 3224 1.2.2.2 skrll gap = seqnr + 0x1000000000000LL - dp->av_hs; /* seq nr = 48 bits */ 3225 1.2.2.2 skrll } 3226 1.2.2.2 skrll 3227 1.2.2.2 skrll if (gap >= dp->av_size) { 3228 1.2.2.2 skrll /* gap is bigger than ackvector size? baaad */ 3229 1.2.2.2 skrll return 0x03; 3230 1.2.2.2 skrll } 3231 1.2.2.2 skrll 3232 1.2.2.2 skrll offset = gap % 4 *2; 3233 1.2.2.2 skrll t = dp->av_hp + (gap/4); 3234 1.2.2.2 skrll if (t >= (dp->ackvector + (dp->av_size/4))) 3235 1.2.2.2 skrll t -= (dp->av_size / 4); /* wrapped */ 3236 1.2.2.3 skrll 3237 1.2.2.2 skrll return ((*t & (0x03 << offset)) >> offset); 3238 1.2.2.2 skrll } 3239 1.2.2.2 skrll 3240 1.2.2.2 skrll /****** End of Ack Vector functions *********/ 3241 1.2.2.2 skrll 3242 1.2.2.2 skrll /* No cc functions */ 3243 1.2.2.2 skrll void * 3244 1.2.2.2 skrll dccp_nocc_init(struct dccpcb *pcb) 3245 1.2.2.2 skrll { 3246 1.2.2.2 skrll return (void*) 1; 3247 1.2.2.2 skrll } 3248 1.2.2.2 skrll 3249 1.2.2.2 skrll void 3250 1.2.2.2 skrll dccp_nocc_free(void *ccb) 3251 1.2.2.2 skrll { 3252 1.2.2.2 skrll } 3253 1.2.2.2 skrll 3254 1.2.2.2 skrll int 3255 1.2.2.2 skrll dccp_nocc_send_packet(void *ccb, long size) 3256 1.2.2.2 skrll { 3257 1.2.2.2 skrll return 1; 3258 1.2.2.2 skrll } 3259 1.2.2.2 skrll 3260 1.2.2.2 skrll void 3261 1.2.2.2 skrll dccp_nocc_send_packet_sent(void *ccb, int moreToSend, long size) 3262 1.2.2.2 skrll { 3263 1.2.2.2 skrll } 3264 1.2.2.2 skrll 3265 1.2.2.2 skrll void 3266 1.2.2.2 skrll dccp_nocc_packet_recv(void *ccb, char* options ,int optlen) 3267 1.2.2.2 skrll { 3268 1.2.2.2 skrll } 3269 1.2.2.2 skrll 3270 1.2.2.2 skrll void 3271 1.2.2.2 skrll dccp_log(int level, const char *format, ...) 3272 1.2.2.2 skrll { 3273 1.2.2.2 skrll va_list ap; 3274 1.2.2.2 skrll 3275 1.2.2.2 skrll va_start(ap, format); 3276 1.2.2.2 skrll vprintf(format, ap); 3277 1.2.2.2 skrll va_end(ap); 3278 1.2.2.2 skrll return; 3279 1.2.2.2 skrll } 3280 1.2.2.2 skrll 3281 1.2.2.2 skrll /* 3282 1.2.2.2 skrll * Sysctl for dccp variables. 3283 1.2.2.2 skrll */ 3284 1.2.2.2 skrll SYSCTL_SETUP(sysctl_net_inet_dccp_setup, "sysctl net.inet.dccp subtree setup") 3285 1.2.2.2 skrll { 3286 1.2.2.2 skrll 3287 1.2.2.2 skrll sysctl_createv(clog, 0, NULL, NULL, 3288 1.2.2.2 skrll CTLFLAG_PERMANENT, 3289 1.2.2.2 skrll CTLTYPE_NODE, "net", NULL, 3290 1.2.2.2 skrll NULL, 0, NULL, 0, 3291 1.2.2.2 skrll CTL_NET, CTL_EOL); 3292 1.2.2.2 skrll 3293 1.2.2.2 skrll sysctl_createv(clog, 0, NULL, NULL, 3294 1.2.2.2 skrll CTLFLAG_PERMANENT, 3295 1.2.2.2 skrll CTLTYPE_NODE, "inet", NULL, 3296 1.2.2.2 skrll NULL, 0, NULL, 0, 3297 1.2.2.2 skrll CTL_NET, PF_INET, CTL_EOL); 3298 1.2.2.2 skrll 3299 1.2.2.2 skrll sysctl_createv(clog, 0, NULL, NULL, 3300 1.2.2.2 skrll CTLFLAG_PERMANENT, 3301 1.2.2.2 skrll CTLTYPE_NODE, "dccp", 3302 1.2.2.2 skrll SYSCTL_DESCR("DCCPv4 related settings"), 3303 1.2.2.2 skrll NULL, 0, NULL, 0, 3304 1.2.2.2 skrll CTL_NET, PF_INET, IPPROTO_DCCP, CTL_EOL); 3305 1.2.2.2 skrll 3306 1.2.2.2 skrll sysctl_createv(clog, 0, NULL, NULL, 3307 1.2.2.2 skrll CTLFLAG_PERMANENT|CTLFLAG_READWRITE, 3308 1.2.2.2 skrll CTLTYPE_INT, "dccp_log_in_vain", 3309 1.2.2.2 skrll SYSCTL_DESCR("log all connection attempt"), 3310 1.2.2.2 skrll NULL, 0, &dccp_log_in_vain, 0, 3311 1.2.2.2 skrll CTL_NET, PF_INET, IPPROTO_DCCP, DCCPCTL_LOGINVAIN, 3312 1.2.2.2 skrll CTL_EOL); 3313 1.2.2.2 skrll 3314 1.2.2.2 skrll sysctl_createv(clog, 0, NULL, NULL, 3315 1.2.2.2 skrll CTLFLAG_PERMANENT|CTLFLAG_READWRITE, 3316 1.2.2.2 skrll CTLTYPE_INT, "do_feature_nego", 3317 1.2.2.2 skrll SYSCTL_DESCR("enable feature negotiation"), 3318 1.2.2.2 skrll NULL, 0, &dccp_do_feature_nego, 0, 3319 1.2.2.2 skrll CTL_NET, PF_INET, IPPROTO_DCCP, DCCPCTL_DOFEATURENEGO, 3320 1.2.2.2 skrll CTL_EOL); 3321 1.2.2.2 skrll } 3322 1.2.2.2 skrll 3323 1.2.2.2 skrll PR_WRAP_USRREQS(dccp) 3324 1.2.2.2 skrll #define dccp_attach dccp_attach_wrapper 3325 1.2.2.2 skrll #define dccp_detach dccp_detach_wrapper 3326 1.2.2.2 skrll #define dccp_accept dccp_accept_wrapper 3327 1.2.2.2 skrll #define dccp_bind dccp_bind_wrapper 3328 1.2.2.2 skrll #define dccp_listen dccp_listen_wrapper 3329 1.2.2.2 skrll #define dccp_connect dccp_connect_wrapper 3330 1.2.2.2 skrll #define dccp_connect2 dccp_connect2_wrapper 3331 1.2.2.2 skrll #define dccp_disconnect dccp_disconnect_wrapper 3332 1.2.2.2 skrll #define dccp_shutdown dccp_shutdown_wrapper 3333 1.2.2.2 skrll #define dccp_abort dccp_abort_wrapper 3334 1.2.2.2 skrll #define dccp_ioctl dccp_ioctl_wrapper 3335 1.2.2.2 skrll #define dccp_stat dccp_stat_wrapper 3336 1.2.2.2 skrll #define dccp_peeraddr dccp_peeraddr_wrapper 3337 1.2.2.2 skrll #define dccp_sockaddr dccp_sockaddr_wrapper 3338 1.2.2.2 skrll #define dccp_rcvd dccp_rcvd_wrapper 3339 1.2.2.2 skrll #define dccp_recvoob dccp_recvoob_wrapper 3340 1.2.2.2 skrll #define dccp_send dccp_send_wrapper 3341 1.2.2.2 skrll #define dccp_sendoob dccp_sendoob_wrapper 3342 1.2.2.2 skrll #define dccp_purgeif dccp_purgeif_wrapper 3343 1.2.2.2 skrll 3344 1.2.2.2 skrll const struct pr_usrreqs dccp_usrreqs = { 3345 1.2.2.2 skrll .pr_attach = dccp_attach, 3346 1.2.2.2 skrll .pr_detach = dccp_detach, 3347 1.2.2.2 skrll .pr_accept = dccp_accept, 3348 1.2.2.2 skrll .pr_bind = dccp_bind, 3349 1.2.2.2 skrll .pr_listen = dccp_listen, 3350 1.2.2.2 skrll .pr_connect = dccp_connect, 3351 1.2.2.2 skrll .pr_connect2 = dccp_connect2, 3352 1.2.2.2 skrll .pr_disconnect = dccp_disconnect, 3353 1.2.2.2 skrll .pr_shutdown = dccp_shutdown, 3354 1.2.2.2 skrll .pr_abort = dccp_abort, 3355 1.2.2.2 skrll .pr_ioctl = dccp_ioctl, 3356 1.2.2.2 skrll .pr_stat = dccp_stat, 3357 1.2.2.2 skrll .pr_peeraddr = dccp_peeraddr, 3358 1.2.2.2 skrll .pr_sockaddr = dccp_sockaddr, 3359 1.2.2.2 skrll .pr_rcvd = dccp_rcvd, 3360 1.2.2.2 skrll .pr_recvoob = dccp_recvoob, 3361 1.2.2.2 skrll .pr_send = dccp_send, 3362 1.2.2.2 skrll .pr_sendoob = dccp_sendoob, 3363 1.2.2.2 skrll .pr_purgeif = dccp_purgeif, 3364 1.2.2.2 skrll }; 3365
Indexes created Tue Sep 30 20:09:53 GMT 2025