/* * CDDL HEADER START * * The contents of this file are subject to the terms of the * Common Development and Distribution License (the "License"). * You may not use this file except in compliance with the License. * * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE * or http://www.opensolaris.org/os/licensing. * See the License for the specific language governing permissions * and limitations under the License. * * When distributing Covered Code, include this CDDL HEADER in each * file and include the License file at usr/src/OPENSOLARIS.LICENSE. * If applicable, add the following below this CDDL HEADER, with the * fields enclosed by brackets "[]" replaced with your own identifying * information: Portions Copyright [yyyy] [name of copyright owner] * * CDDL HEADER END */ /* * Copyright 2009 Sun Microsystems, Inc. All rights reserved. * Use is subject to license terms. */ /* Copyright (c) 1990 Mentat Inc. */ #include #include #include #include #include #define _SUN_TPI_VERSION 2 #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include /* * Synchronization notes: * * RAWIP is MT and uses the usual kernel synchronization primitives. There is * locks, which is icmp_rwlock. We also use conn_lock when updating things * which affect the IP classifier lookup. * The lock order is icmp_rwlock -> conn_lock. * * The icmp_rwlock: * This protects most of the other fields in the icmp_t. The exact list of * fields which are protected by each of the above locks is documented in * the icmp_t structure definition. * * Plumbing notes: * ICMP is always a device driver. For compatibility with mibopen() code * it is possible to I_PUSH "icmp", but that results in pushing a passthrough * dummy module. */ static void icmp_addr_req(queue_t *q, mblk_t *mp); static void icmp_tpi_bind(queue_t *q, mblk_t *mp); static int icmp_bind_proto(conn_t *connp); static int icmp_build_hdrs(icmp_t *icmp); static void icmp_capability_req(queue_t *q, mblk_t *mp); static int icmp_close(queue_t *q, int flags); static void icmp_tpi_connect(queue_t *q, mblk_t *mp); static void icmp_tpi_disconnect(queue_t *q, mblk_t *mp); static void icmp_err_ack(queue_t *q, mblk_t *mp, t_scalar_t t_error, int sys_error); static void icmp_err_ack_prim(queue_t *q, mblk_t *mp, t_scalar_t primitive, t_scalar_t t_error, int sys_error); static void icmp_icmp_error(conn_t *connp, mblk_t *mp); static void icmp_icmp_error_ipv6(conn_t *connp, mblk_t *mp); static void icmp_info_req(queue_t *q, mblk_t *mp); static void icmp_input(void *, mblk_t *, void *); static conn_t *icmp_open(int family, cred_t *credp, int *err, int flags); static int icmp_openv4(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *credp); static int icmp_openv6(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *credp); static int icmp_unitdata_opt_process(queue_t *q, mblk_t *mp, int *errorp, void *thisdg_attrs); static boolean_t icmp_opt_allow_udr_set(t_scalar_t level, t_scalar_t name); int icmp_opt_set(conn_t *connp, uint_t optset_context, int level, int name, uint_t inlen, uchar_t *invalp, uint_t *outlenp, uchar_t *outvalp, void *thisdg_attrs, cred_t *cr); int icmp_opt_get(conn_t *connp, int level, int name, uchar_t *ptr); static int icmp_param_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr); static boolean_t icmp_param_register(IDP *ndp, icmpparam_t *icmppa, int cnt); static int icmp_param_set(queue_t *q, mblk_t *mp, char *value, caddr_t cp, cred_t *cr); static int icmp_snmp_set(queue_t *q, t_scalar_t level, t_scalar_t name, uchar_t *ptr, int len); static void icmp_ud_err(queue_t *q, mblk_t *mp, t_scalar_t err); static void icmp_tpi_unbind(queue_t *q, mblk_t *mp); static int icmp_update_label(icmp_t *icmp, mblk_t *mp, ipaddr_t dst); static void icmp_wput(queue_t *q, mblk_t *mp); static void icmp_wput_fallback(queue_t *q, mblk_t *mp); static int raw_ip_send_data_v6(queue_t *q, conn_t *connp, mblk_t *mp, sin6_t *sin6, ip6_pkt_t *ipp); static int raw_ip_send_data_v4(queue_t *q, conn_t *connp, mblk_t *mp, ipaddr_t v4dst, ip4_pkt_t *pktinfop); static void icmp_wput_other(queue_t *q, mblk_t *mp); static void icmp_wput_iocdata(queue_t *q, mblk_t *mp); static void icmp_wput_restricted(queue_t *q, mblk_t *mp); static void icmp_ulp_recv(conn_t *, mblk_t *); static void *rawip_stack_init(netstackid_t stackid, netstack_t *ns); static void rawip_stack_fini(netstackid_t stackid, void *arg); static void *rawip_kstat_init(netstackid_t stackid); static void rawip_kstat_fini(netstackid_t stackid, kstat_t *ksp); static int rawip_kstat_update(kstat_t *kp, int rw); static void rawip_stack_shutdown(netstackid_t stackid, void *arg); static int rawip_do_getsockname(icmp_t *icmp, struct sockaddr *sa, uint_t *salenp); static int rawip_do_getpeername(icmp_t *icmp, struct sockaddr *sa, uint_t *salenp); int rawip_getsockname(sock_lower_handle_t, struct sockaddr *, socklen_t *, cred_t *); int rawip_getpeername(sock_lower_handle_t, struct sockaddr *, socklen_t *, cred_t *); static struct module_info icmp_mod_info = { 5707, "icmp", 1, INFPSZ, 512, 128 }; /* * Entry points for ICMP as a device. * We have separate open functions for the /dev/icmp and /dev/icmp6 devices. */ static struct qinit icmprinitv4 = { NULL, NULL, icmp_openv4, icmp_close, NULL, &icmp_mod_info }; static struct qinit icmprinitv6 = { NULL, NULL, icmp_openv6, icmp_close, NULL, &icmp_mod_info }; static struct qinit icmpwinit = { (pfi_t)icmp_wput, NULL, NULL, NULL, NULL, &icmp_mod_info }; /* ICMP entry point during fallback */ static struct qinit icmp_fallback_sock_winit = { (pfi_t)icmp_wput_fallback, NULL, NULL, NULL, NULL, &icmp_mod_info }; /* For AF_INET aka /dev/icmp */ struct streamtab icmpinfov4 = { &icmprinitv4, &icmpwinit }; /* For AF_INET6 aka /dev/icmp6 */ struct streamtab icmpinfov6 = { &icmprinitv6, &icmpwinit }; static sin_t sin_null; /* Zero address for quick clears */ static sin6_t sin6_null; /* Zero address for quick clears */ /* Default structure copied into T_INFO_ACK messages */ static struct T_info_ack icmp_g_t_info_ack = { T_INFO_ACK, IP_MAXPACKET, /* TSDU_size. icmp allows maximum size messages. */ T_INVALID, /* ETSDU_size. icmp does not support expedited data. */ T_INVALID, /* CDATA_size. icmp does not support connect data. */ T_INVALID, /* DDATA_size. icmp does not support disconnect data. */ 0, /* ADDR_size - filled in later. */ 0, /* OPT_size - not initialized here */ IP_MAXPACKET, /* TIDU_size. icmp allows maximum size messages. */ T_CLTS, /* SERV_type. icmp supports connection-less. */ TS_UNBND, /* CURRENT_state. This is set from icmp_state. */ (XPG4_1|SENDZERO) /* PROVIDER_flag */ }; /* * Table of ND variables supported by icmp. These are loaded into is_nd * when the stack instance is created. * All of these are alterable, within the min/max values given, at run time. */ static icmpparam_t icmp_param_arr[] = { /* min max value name */ { 0, 128, 32, "icmp_wroff_extra" }, { 1, 255, 255, "icmp_ipv4_ttl" }, { 0, IPV6_MAX_HOPS, IPV6_DEFAULT_HOPS, "icmp_ipv6_hoplimit"}, { 0, 1, 1, "icmp_bsd_compat" }, { 4096, 65536, 8192, "icmp_xmit_hiwat"}, { 0, 65536, 1024, "icmp_xmit_lowat"}, { 4096, 65536, 8192, "icmp_recv_hiwat"}, { 65536, 1024*1024*1024, 256*1024, "icmp_max_buf"}, }; #define is_wroff_extra is_param_arr[0].icmp_param_value #define is_ipv4_ttl is_param_arr[1].icmp_param_value #define is_ipv6_hoplimit is_param_arr[2].icmp_param_value #define is_bsd_compat is_param_arr[3].icmp_param_value #define is_xmit_hiwat is_param_arr[4].icmp_param_value #define is_xmit_lowat is_param_arr[5].icmp_param_value #define is_recv_hiwat is_param_arr[6].icmp_param_value #define is_max_buf is_param_arr[7].icmp_param_value static int rawip_do_bind(conn_t *connp, struct sockaddr *sa, socklen_t len); static int rawip_do_connect(conn_t *connp, const struct sockaddr *sa, socklen_t len, cred_t *cr); static void rawip_post_ip_bind_connect(icmp_t *icmp, mblk_t *ire_mp, int error); /* * This routine is called to handle each O_T_BIND_REQ/T_BIND_REQ message * passed to icmp_wput. * The O_T_BIND_REQ/T_BIND_REQ is passed downstream to ip with the ICMP * protocol type placed in the message following the address. A T_BIND_ACK * message is returned by ip_bind_v4/v6. */ static void icmp_tpi_bind(queue_t *q, mblk_t *mp) { int error; struct sockaddr *sa; struct T_bind_req *tbr; socklen_t len; sin_t *sin; sin6_t *sin6; icmp_t *icmp; conn_t *connp = Q_TO_CONN(q); mblk_t *mp1; cred_t *cr; /* * All Solaris components should pass a db_credp * for this TPI message, hence we ASSERT. * But in case there is some other M_PROTO that looks * like a TPI message sent by some other kernel * component, we check and return an error. */ cr = msg_getcred(mp, NULL); ASSERT(cr != NULL); if (cr == NULL) { icmp_err_ack(q, mp, TSYSERR, EINVAL); return; } icmp = connp->conn_icmp; if ((mp->b_wptr - mp->b_rptr) < sizeof (*tbr)) { (void) mi_strlog(q, 1, SL_ERROR|SL_TRACE, "icmp_bind: bad req, len %u", (uint_t)(mp->b_wptr - mp->b_rptr)); icmp_err_ack(q, mp, TPROTO, 0); return; } if (icmp->icmp_state != TS_UNBND) { (void) mi_strlog(q, 1, SL_ERROR|SL_TRACE, "icmp_bind: bad state, %d", icmp->icmp_state); icmp_err_ack(q, mp, TOUTSTATE, 0); return; } /* * Reallocate the message to make sure we have enough room for an * address and the protocol type. */ mp1 = reallocb(mp, sizeof (struct T_bind_ack) + sizeof (sin6_t) + 1, 1); if (!mp1) { icmp_err_ack(q, mp, TSYSERR, ENOMEM); return; } mp = mp1; /* Reset the message type in preparation for shipping it back. */ DB_TYPE(mp) = M_PCPROTO; tbr = (struct T_bind_req *)mp->b_rptr; len = tbr->ADDR_length; switch (len) { case 0: /* request for a generic port */ tbr->ADDR_offset = sizeof (struct T_bind_req); if (icmp->icmp_family == AF_INET) { tbr->ADDR_length = sizeof (sin_t); sin = (sin_t *)&tbr[1]; *sin = sin_null; sin->sin_family = AF_INET; mp->b_wptr = (uchar_t *)&sin[1]; sa = (struct sockaddr *)sin; len = sizeof (sin_t); } else { ASSERT(icmp->icmp_family == AF_INET6); tbr->ADDR_length = sizeof (sin6_t); sin6 = (sin6_t *)&tbr[1]; *sin6 = sin6_null; sin6->sin6_family = AF_INET6; mp->b_wptr = (uchar_t *)&sin6[1]; sa = (struct sockaddr *)sin6; len = sizeof (sin6_t); } break; case sizeof (sin_t): /* Complete IPv4 address */ sa = (struct sockaddr *)mi_offset_param(mp, tbr->ADDR_offset, sizeof (sin_t)); break; case sizeof (sin6_t): /* Complete IPv6 address */ sa = (struct sockaddr *)mi_offset_param(mp, tbr->ADDR_offset, sizeof (sin6_t)); break; default: (void) mi_strlog(q, 1, SL_ERROR|SL_TRACE, "icmp_bind: bad ADDR_length %d", tbr->ADDR_length); icmp_err_ack(q, mp, TBADADDR, 0); return; } error = rawip_do_bind(connp, sa, len); done: ASSERT(mp->b_cont == NULL); if (error != 0) { if (error > 0) { icmp_err_ack(q, mp, TSYSERR, error); } else { icmp_err_ack(q, mp, -error, 0); } } else { tbr->PRIM_type = T_BIND_ACK; qreply(q, mp); } } static int rawip_do_bind(conn_t *connp, struct sockaddr *sa, socklen_t len) { sin_t *sin; sin6_t *sin6; icmp_t *icmp; int error = 0; mblk_t *ire_mp; icmp = connp->conn_icmp; if (sa == NULL || !OK_32PTR((char *)sa)) { return (EINVAL); } /* * The state must be TS_UNBND. TPI mandates that users must send * TPI primitives only 1 at a time and wait for the response before * sending the next primitive. */ rw_enter(&icmp->icmp_rwlock, RW_WRITER); if (icmp->icmp_state != TS_UNBND || icmp->icmp_pending_op != -1) { error = -TOUTSTATE; goto done; } ASSERT(len != 0); switch (len) { case sizeof (sin_t): /* Complete IPv4 address */ sin = (sin_t *)sa; if (sin->sin_family != AF_INET || icmp->icmp_family != AF_INET) { /* TSYSERR, EAFNOSUPPORT */ error = EAFNOSUPPORT; goto done; } break; case sizeof (sin6_t): /* Complete IPv6 address */ sin6 = (sin6_t *)sa; if (sin6->sin6_family != AF_INET6 || icmp->icmp_family != AF_INET6) { /* TSYSERR, EAFNOSUPPORT */ error = EAFNOSUPPORT; goto done; } /* No support for mapped addresses on raw sockets */ if (IN6_IS_ADDR_V4MAPPED(&sin6->sin6_addr)) { /* TSYSERR, EADDRNOTAVAIL */ error = EADDRNOTAVAIL; goto done; } break; default: /* TBADADDR */ error = EADDRNOTAVAIL; goto done; } icmp->icmp_pending_op = T_BIND_REQ; icmp->icmp_state = TS_IDLE; /* * Copy the source address into our icmp structure. This address * may still be zero; if so, ip will fill in the correct address * each time an outbound packet is passed to it. * If we are binding to a broadcast or multicast address then * rawip_post_ip_bind_connect will clear the source address. */ if (icmp->icmp_family == AF_INET) { ASSERT(sin != NULL); ASSERT(icmp->icmp_ipversion == IPV4_VERSION); IN6_IPADDR_TO_V4MAPPED(sin->sin_addr.s_addr, &icmp->icmp_v6src); icmp->icmp_max_hdr_len = IP_SIMPLE_HDR_LENGTH + icmp->icmp_ip_snd_options_len; icmp->icmp_bound_v6src = icmp->icmp_v6src; } else { int error; ASSERT(sin6 != NULL); ASSERT(icmp->icmp_ipversion == IPV6_VERSION); icmp->icmp_v6src = sin6->sin6_addr; icmp->icmp_max_hdr_len = icmp->icmp_sticky_hdrs_len; icmp->icmp_bound_v6src = icmp->icmp_v6src; /* Rebuild the header template */ error = icmp_build_hdrs(icmp); if (error != 0) { icmp->icmp_pending_op = -1; /* * TSYSERR */ goto done; } } ire_mp = NULL; if (!(V6_OR_V4_INADDR_ANY(icmp->icmp_v6src))) { /* * request an IRE if src not 0 (INADDR_ANY) */ ire_mp = allocb(sizeof (ire_t), BPRI_HI); if (ire_mp == NULL) { icmp->icmp_pending_op = -1; error = ENOMEM; goto done; } DB_TYPE(ire_mp) = IRE_DB_REQ_TYPE; } done: rw_exit(&icmp->icmp_rwlock); if (error != 0) return (error); if (icmp->icmp_family == AF_INET6) { error = ip_proto_bind_laddr_v6(connp, &ire_mp, icmp->icmp_proto, &sin6->sin6_addr, sin6->sin6_port, B_TRUE); } else { error = ip_proto_bind_laddr_v4(connp, &ire_mp, icmp->icmp_proto, sin->sin_addr.s_addr, sin->sin_port, B_TRUE); } rawip_post_ip_bind_connect(icmp, ire_mp, error); return (error); } static void rawip_post_ip_bind_connect(icmp_t *icmp, mblk_t *ire_mp, int error) { rw_enter(&icmp->icmp_rwlock, RW_WRITER); if (icmp->icmp_state == TS_UNBND) { /* * not yet bound - bind sent by icmp_bind_proto. */ rw_exit(&icmp->icmp_rwlock); return; } ASSERT(icmp->icmp_pending_op != -1); icmp->icmp_pending_op = -1; if (error != 0) { if (icmp->icmp_state == TS_DATA_XFER) { /* Connect failed */ /* Revert back to the bound source */ icmp->icmp_v6src = icmp->icmp_bound_v6src; icmp->icmp_state = TS_IDLE; if (icmp->icmp_family == AF_INET6) (void) icmp_build_hdrs(icmp); } else { V6_SET_ZERO(icmp->icmp_v6src); V6_SET_ZERO(icmp->icmp_bound_v6src); icmp->icmp_state = TS_UNBND; if (icmp->icmp_family == AF_INET6) (void) icmp_build_hdrs(icmp); } } else { if (ire_mp != NULL && ire_mp->b_datap->db_type == IRE_DB_TYPE) { ire_t *ire; ire = (ire_t *)ire_mp->b_rptr; /* * If a broadcast/multicast address was bound set * the source address to 0. * This ensures no datagrams with broadcast address * as source address are emitted (which would violate * RFC1122 - Hosts requirements) * Note: we get IRE_BROADCAST for IPv6 * to "mark" a multicast local address. */ if (ire->ire_type == IRE_BROADCAST && icmp->icmp_state != TS_DATA_XFER) { /* * This was just a local bind to a * MC/broadcast addr */ V6_SET_ZERO(icmp->icmp_v6src); if (icmp->icmp_family == AF_INET6) (void) icmp_build_hdrs(icmp); } } } rw_exit(&icmp->icmp_rwlock); if (ire_mp != NULL) freeb(ire_mp); } /* * Send message to IP to just bind to the protocol. */ static int icmp_bind_proto(conn_t *connp) { icmp_t *icmp; int error; icmp = connp->conn_icmp; if (icmp->icmp_family == AF_INET6) error = ip_proto_bind_laddr_v6(connp, NULL, icmp->icmp_proto, &sin6_null.sin6_addr, 0, B_TRUE); else error = ip_proto_bind_laddr_v4(connp, NULL, icmp->icmp_proto, sin_null.sin_addr.s_addr, 0, B_TRUE); rawip_post_ip_bind_connect(icmp, NULL, error); return (error); } static void icmp_tpi_connect(queue_t *q, mblk_t *mp) { conn_t *connp = Q_TO_CONN(q); struct T_conn_req *tcr; icmp_t *icmp; struct sockaddr *sa; socklen_t len; int error; cred_t *cr; /* * All Solaris components should pass a db_credp * for this TPI message, hence we ASSERT. * But in case there is some other M_PROTO that looks * like a TPI message sent by some other kernel * component, we check and return an error. */ cr = msg_getcred(mp, NULL); ASSERT(cr != NULL); if (cr == NULL) { icmp_err_ack(q, mp, TSYSERR, EINVAL); return; } icmp = connp->conn_icmp; tcr = (struct T_conn_req *)mp->b_rptr; /* Sanity checks */ if ((mp->b_wptr - mp->b_rptr) < sizeof (struct T_conn_req)) { icmp_err_ack(q, mp, TPROTO, 0); return; } if (tcr->OPT_length != 0) { icmp_err_ack(q, mp, TBADOPT, 0); return; } len = tcr->DEST_length; switch (len) { default: icmp_err_ack(q, mp, TBADADDR, 0); return; case sizeof (sin_t): sa = (struct sockaddr *)mi_offset_param(mp, tcr->DEST_offset, sizeof (sin_t)); break; case sizeof (sin6_t): sa = (struct sockaddr *)mi_offset_param(mp, tcr->DEST_offset, sizeof (sin6_t)); break; } error = proto_verify_ip_addr(icmp->icmp_family, sa, len); if (error != 0) { icmp_err_ack(q, mp, TSYSERR, error); return; } error = rawip_do_connect(connp, sa, len, cr); if (error != 0) { if (error < 0) { icmp_err_ack(q, mp, -error, 0); } else { icmp_err_ack(q, mp, 0, error); } } else { mblk_t *mp1; /* * We have to send a connection confirmation to * keep TLI happy. */ if (icmp->icmp_family == AF_INET) { mp1 = mi_tpi_conn_con(NULL, (char *)sa, sizeof (sin_t), NULL, 0); } else { ASSERT(icmp->icmp_family == AF_INET6); mp1 = mi_tpi_conn_con(NULL, (char *)sa, sizeof (sin6_t), NULL, 0); } if (mp1 == NULL) { rw_exit(&icmp->icmp_rwlock); icmp_err_ack(q, mp, TSYSERR, ENOMEM); return; } /* * Send ok_ack for T_CONN_REQ */ mp = mi_tpi_ok_ack_alloc(mp); if (mp == NULL) { /* Unable to reuse the T_CONN_REQ for the ack. */ freemsg(mp1); icmp_err_ack_prim(q, mp1, T_CONN_REQ, TSYSERR, ENOMEM); return; } putnext(connp->conn_rq, mp); putnext(connp->conn_rq, mp1); } } static int rawip_do_connect(conn_t *connp, const struct sockaddr *sa, socklen_t len, cred_t *cr) { icmp_t *icmp; sin_t *sin; sin6_t *sin6; mblk_t *ire_mp; int error; ipaddr_t v4dst; in6_addr_t v6dst; icmp = connp->conn_icmp; if (sa == NULL || !OK_32PTR((char *)sa)) { return (EINVAL); } ire_mp = allocb(sizeof (ire_t), BPRI_HI); if (ire_mp == NULL) return (ENOMEM); DB_TYPE(ire_mp) = IRE_DB_REQ_TYPE; ASSERT(sa != NULL && len != 0); rw_enter(&icmp->icmp_rwlock, RW_WRITER); if (icmp->icmp_state == TS_UNBND || icmp->icmp_pending_op != -1) { rw_exit(&icmp->icmp_rwlock); freeb(ire_mp); return (-TOUTSTATE); } switch (len) { case sizeof (sin_t): sin = (sin_t *)sa; ASSERT(icmp->icmp_family == AF_INET); ASSERT(icmp->icmp_ipversion == IPV4_VERSION); v4dst = sin->sin_addr.s_addr; /* * Interpret a zero destination to mean loopback. * Update the T_CONN_REQ (sin/sin6) since it is used to * generate the T_CONN_CON. */ if (v4dst == INADDR_ANY) { v4dst = htonl(INADDR_LOOPBACK); } IN6_IPADDR_TO_V4MAPPED(v4dst, &v6dst); ASSERT(icmp->icmp_ipversion == IPV4_VERSION); icmp->icmp_max_hdr_len = IP_SIMPLE_HDR_LENGTH + icmp->icmp_ip_snd_options_len; icmp->icmp_v6dst.sin6_addr = v6dst; icmp->icmp_v6dst.sin6_family = AF_INET6; icmp->icmp_v6dst.sin6_flowinfo = 0; icmp->icmp_v6dst.sin6_port = 0; /* * If the destination address is multicast and * an outgoing multicast interface has been set, * use the address of that interface as our * source address if no source address has been set. */ if (V4_PART_OF_V6(icmp->icmp_v6src) == INADDR_ANY && CLASSD(v4dst) && icmp->icmp_multicast_if_addr != INADDR_ANY) { IN6_IPADDR_TO_V4MAPPED(icmp->icmp_multicast_if_addr, &icmp->icmp_v6src); } break; case sizeof (sin6_t): sin6 = (sin6_t *)sa; /* No support for mapped addresses on raw sockets */ if (IN6_IS_ADDR_V4MAPPED(&sin6->sin6_addr)) { rw_exit(&icmp->icmp_rwlock); freeb(ire_mp); return (EADDRNOTAVAIL); } ASSERT(icmp->icmp_ipversion == IPV6_VERSION); ASSERT(icmp->icmp_family == AF_INET6); icmp->icmp_max_hdr_len = icmp->icmp_sticky_hdrs_len; icmp->icmp_v6dst = *sin6; icmp->icmp_v6dst.sin6_port = 0; /* * Interpret a zero destination to mean loopback. * Update the T_CONN_REQ (sin/sin6) since it is used to * generate the T_CONN_CON. */ if (IN6_IS_ADDR_UNSPECIFIED(&icmp->icmp_v6dst.sin6_addr)) { icmp->icmp_v6dst.sin6_addr = ipv6_loopback; } /* * If the destination address is multicast and * an outgoing multicast interface has been set, * then the ip bind logic will pick the correct source * address (i.e. matching the outgoing multicast interface). */ break; } icmp->icmp_pending_op = T_CONN_REQ; if (icmp->icmp_state == TS_DATA_XFER) { /* Already connected - clear out state */ icmp->icmp_v6src = icmp->icmp_bound_v6src; icmp->icmp_state = TS_IDLE; } icmp->icmp_state = TS_DATA_XFER; rw_exit(&icmp->icmp_rwlock); if (icmp->icmp_family == AF_INET6) { error = ip_proto_bind_connected_v6(connp, &ire_mp, icmp->icmp_proto, &icmp->icmp_v6src, 0, &icmp->icmp_v6dst.sin6_addr, NULL, sin6->sin6_port, B_TRUE, B_TRUE, cr); } else { error = ip_proto_bind_connected_v4(connp, &ire_mp, icmp->icmp_proto, &V4_PART_OF_V6(icmp->icmp_v6src), 0, V4_PART_OF_V6(icmp->icmp_v6dst.sin6_addr), sin->sin_port, B_TRUE, B_TRUE, cr); } rawip_post_ip_bind_connect(icmp, ire_mp, error); return (error); } static void icmp_close_free(conn_t *connp) { icmp_t *icmp = connp->conn_icmp; /* If there are any options associated with the stream, free them. */ if (icmp->icmp_ip_snd_options != NULL) { mi_free((char *)icmp->icmp_ip_snd_options); icmp->icmp_ip_snd_options = NULL; icmp->icmp_ip_snd_options_len = 0; } if (icmp->icmp_filter != NULL) { kmem_free(icmp->icmp_filter, sizeof (icmp6_filter_t)); icmp->icmp_filter = NULL; } /* Free memory associated with sticky options */ if (icmp->icmp_sticky_hdrs_len != 0) { kmem_free(icmp->icmp_sticky_hdrs, icmp->icmp_sticky_hdrs_len); icmp->icmp_sticky_hdrs = NULL; icmp->icmp_sticky_hdrs_len = 0; } ip6_pkt_free(&icmp->icmp_sticky_ipp); /* * Clear any fields which the kmem_cache constructor clears. * Only icmp_connp needs to be preserved. * TBD: We should make this more efficient to avoid clearing * everything. */ ASSERT(icmp->icmp_connp == connp); bzero(icmp, sizeof (icmp_t)); icmp->icmp_connp = connp; } static int rawip_do_close(conn_t *connp) { ASSERT(connp != NULL && IPCL_IS_RAWIP(connp)); ip_quiesce_conn(connp); if (!IPCL_IS_NONSTR(connp)) { qprocsoff(connp->conn_rq); } ASSERT(connp->conn_icmp->icmp_fallback_queue_head == NULL && connp->conn_icmp->icmp_fallback_queue_tail == NULL); icmp_close_free(connp); /* * Now we are truly single threaded on this stream, and can * delete the things hanging off the connp, and finally the connp. * We removed this connp from the fanout list, it cannot be * accessed thru the fanouts, and we already waited for the * conn_ref to drop to 0. We are already in close, so * there cannot be any other thread from the top. qprocsoff * has completed, and service has completed or won't run in * future. */ ASSERT(connp->conn_ref == 1); if (!IPCL_IS_NONSTR(connp)) { inet_minor_free(connp->conn_minor_arena, connp->conn_dev); } else { ip_free_helper_stream(connp); } connp->conn_ref--; ipcl_conn_destroy(connp); return (0); } static int icmp_close(queue_t *q, int flags) { conn_t *connp; if (flags & SO_FALLBACK) { /* * stream is being closed while in fallback * simply free the resources that were allocated */ inet_minor_free(WR(q)->q_ptr, (dev_t)(RD(q)->q_ptr)); qprocsoff(q); goto done; } connp = Q_TO_CONN(q); (void) rawip_do_close(connp); done: q->q_ptr = WR(q)->q_ptr = NULL; return (0); } /* * This routine handles each T_DISCON_REQ message passed to icmp * as an indicating that ICMP is no longer connected. This results * in sending a T_BIND_REQ to IP to restore the binding to just * the local address. * * The disconnect completes in rawip_post_ip_bind_connect. */ static int icmp_do_disconnect(conn_t *connp) { icmp_t *icmp; mblk_t *ire_mp; int error; icmp = connp->conn_icmp; rw_enter(&icmp->icmp_rwlock, RW_WRITER); if (icmp->icmp_state != TS_DATA_XFER || icmp->icmp_pending_op != -1) { rw_exit(&icmp->icmp_rwlock); return (-TOUTSTATE); } icmp->icmp_pending_op = T_DISCON_REQ; icmp->icmp_v6src = icmp->icmp_bound_v6src; icmp->icmp_state = TS_IDLE; if (icmp->icmp_family == AF_INET6) { /* Rebuild the header template */ error = icmp_build_hdrs(icmp); if (error != 0) { icmp->icmp_pending_op = -1; rw_exit(&icmp->icmp_rwlock); return (error); } } rw_exit(&icmp->icmp_rwlock); ire_mp = allocb(sizeof (ire_t), BPRI_HI); if (ire_mp == NULL) { return (ENOMEM); } if (icmp->icmp_family == AF_INET6) { error = ip_proto_bind_laddr_v6(connp, &ire_mp, icmp->icmp_proto, &icmp->icmp_bound_v6src, 0, B_TRUE); } else { error = ip_proto_bind_laddr_v4(connp, &ire_mp, icmp->icmp_proto, V4_PART_OF_V6(icmp->icmp_bound_v6src), 0, B_TRUE); } rawip_post_ip_bind_connect(icmp, ire_mp, error); return (error); } static void icmp_tpi_disconnect(queue_t *q, mblk_t *mp) { conn_t *connp = Q_TO_CONN(q); int error; /* * Allocate the largest primitive we need to send back * T_error_ack is > than T_ok_ack */ mp = reallocb(mp, sizeof (struct T_error_ack), 1); if (mp == NULL) { /* Unable to reuse the T_DISCON_REQ for the ack. */ icmp_err_ack_prim(q, mp, T_DISCON_REQ, TSYSERR, ENOMEM); return; } error = icmp_do_disconnect(connp); if (error != 0) { if (error > 0) { icmp_err_ack(q, mp, 0, error); } else { icmp_err_ack(q, mp, -error, 0); } } else { mp = mi_tpi_ok_ack_alloc(mp); ASSERT(mp != NULL); qreply(q, mp); } } static int icmp_disconnect(conn_t *connp) { int error; icmp_t *icmp = connp->conn_icmp; icmp->icmp_dgram_errind = B_FALSE; error = icmp_do_disconnect(connp); if (error < 0) error = proto_tlitosyserr(-error); return (error); } /* This routine creates a T_ERROR_ACK message and passes it upstream. */ static void icmp_err_ack(queue_t *q, mblk_t *mp, t_scalar_t t_error, int sys_error) { if ((mp = mi_tpi_err_ack_alloc(mp, t_error, sys_error)) != NULL) qreply(q, mp); } /* Shorthand to generate and send TPI error acks to our client */ static void icmp_err_ack_prim(queue_t *q, mblk_t *mp, t_scalar_t primitive, t_scalar_t t_error, int sys_error) { struct T_error_ack *teackp; if ((mp = tpi_ack_alloc(mp, sizeof (struct T_error_ack), M_PCPROTO, T_ERROR_ACK)) != NULL) { teackp = (struct T_error_ack *)mp->b_rptr; teackp->ERROR_prim = primitive; teackp->TLI_error = t_error; teackp->UNIX_error = sys_error; qreply(q, mp); } } /* * icmp_icmp_error is called by icmp_input to process ICMP * messages passed up by IP. * Generates the appropriate permanent (non-transient) errors. * Assumes that IP has pulled up everything up to and including * the ICMP header. */ static void icmp_icmp_error(conn_t *connp, mblk_t *mp) { icmph_t *icmph; ipha_t *ipha; int iph_hdr_length; sin_t sin; mblk_t *mp1; int error = 0; icmp_t *icmp = connp->conn_icmp; ipha = (ipha_t *)mp->b_rptr; ASSERT(OK_32PTR(mp->b_rptr)); if (IPH_HDR_VERSION(ipha) != IPV4_VERSION) { ASSERT(IPH_HDR_VERSION(ipha) == IPV6_VERSION); icmp_icmp_error_ipv6(connp, mp); return; } /* * icmp does not support v4 mapped addresses * so we can never be here for a V6 socket * i.e. icmp_family == AF_INET6 */ ASSERT((IPH_HDR_VERSION(ipha) == IPV4_VERSION) && (icmp->icmp_family == AF_INET)); ASSERT(icmp->icmp_family == AF_INET); /* Skip past the outer IP and ICMP headers */ iph_hdr_length = IPH_HDR_LENGTH(ipha); icmph = (icmph_t *)(&mp->b_rptr[iph_hdr_length]); ipha = (ipha_t *)&icmph[1]; iph_hdr_length = IPH_HDR_LENGTH(ipha); switch (icmph->icmph_type) { case ICMP_DEST_UNREACHABLE: switch (icmph->icmph_code) { case ICMP_FRAGMENTATION_NEEDED: /* * IP has already adjusted the path MTU. */ break; case ICMP_PORT_UNREACHABLE: case ICMP_PROTOCOL_UNREACHABLE: error = ECONNREFUSED; break; default: /* Transient errors */ break; } break; default: /* Transient errors */ break; } if (error == 0) { freemsg(mp); return; } /* * Deliver T_UDERROR_IND when the application has asked for it. * The socket layer enables this automatically when connected. */ if (!icmp->icmp_dgram_errind) { freemsg(mp); return; } sin = sin_null; sin.sin_family = AF_INET; sin.sin_addr.s_addr = ipha->ipha_dst; if (IPCL_IS_NONSTR(connp)) { rw_enter(&icmp->icmp_rwlock, RW_WRITER); if (icmp->icmp_state == TS_DATA_XFER) { if (sin.sin_addr.s_addr == V4_PART_OF_V6(icmp->icmp_v6dst.sin6_addr)) { rw_exit(&icmp->icmp_rwlock); (*connp->conn_upcalls->su_set_error) (connp->conn_upper_handle, error); goto done; } } else { icmp->icmp_delayed_error = error; *((sin_t *)&icmp->icmp_delayed_addr) = sin; } rw_exit(&icmp->icmp_rwlock); } else { mp1 = mi_tpi_uderror_ind((char *)&sin, sizeof (sin_t), NULL, 0, error); if (mp1 != NULL) putnext(connp->conn_rq, mp1); } done: ASSERT(!RW_ISWRITER(&icmp->icmp_rwlock)); freemsg(mp); } /* * icmp_icmp_error_ipv6 is called by icmp_icmp_error to process ICMPv6 * for IPv6 packets. * Send permanent (non-transient) errors upstream. * Assumes that IP has pulled up all the extension headers as well * as the ICMPv6 header. */ static void icmp_icmp_error_ipv6(conn_t *connp, mblk_t *mp) { icmp6_t *icmp6; ip6_t *ip6h, *outer_ip6h; uint16_t iph_hdr_length; uint8_t *nexthdrp; sin6_t sin6; mblk_t *mp1; int error = 0; icmp_t *icmp = connp->conn_icmp; outer_ip6h = (ip6_t *)mp->b_rptr; if (outer_ip6h->ip6_nxt != IPPROTO_ICMPV6) iph_hdr_length = ip_hdr_length_v6(mp, outer_ip6h); else iph_hdr_length = IPV6_HDR_LEN; icmp6 = (icmp6_t *)&mp->b_rptr[iph_hdr_length]; ip6h = (ip6_t *)&icmp6[1]; if (!ip_hdr_length_nexthdr_v6(mp, ip6h, &iph_hdr_length, &nexthdrp)) { freemsg(mp); return; } switch (icmp6->icmp6_type) { case ICMP6_DST_UNREACH: switch (icmp6->icmp6_code) { case ICMP6_DST_UNREACH_NOPORT: error = ECONNREFUSED; break; case ICMP6_DST_UNREACH_ADMIN: case ICMP6_DST_UNREACH_NOROUTE: case ICMP6_DST_UNREACH_BEYONDSCOPE: case ICMP6_DST_UNREACH_ADDR: /* Transient errors */ break; default: break; } break; case ICMP6_PACKET_TOO_BIG: { struct T_unitdata_ind *tudi; struct T_opthdr *toh; size_t udi_size; mblk_t *newmp; t_scalar_t opt_length = sizeof (struct T_opthdr) + sizeof (struct ip6_mtuinfo); sin6_t *sin6; struct ip6_mtuinfo *mtuinfo; /* * If the application has requested to receive path mtu * information, send up an empty message containing an * IPV6_PATHMTU ancillary data item. */ if (!icmp->icmp_ipv6_recvpathmtu) break; udi_size = sizeof (struct T_unitdata_ind) + sizeof (sin6_t) + opt_length; if ((newmp = allocb(udi_size, BPRI_MED)) == NULL) { BUMP_MIB(&icmp->icmp_is->is_rawip_mib, rawipInErrors); break; } /* * newmp->b_cont is left to NULL on purpose. This is an * empty message containing only ancillary data. */ newmp->b_datap->db_type = M_PROTO; tudi = (struct T_unitdata_ind *)newmp->b_rptr; newmp->b_wptr = (uchar_t *)tudi + udi_size; tudi->PRIM_type = T_UNITDATA_IND; tudi->SRC_length = sizeof (sin6_t); tudi->SRC_offset = sizeof (struct T_unitdata_ind); tudi->OPT_offset = tudi->SRC_offset + sizeof (sin6_t); tudi->OPT_length = opt_length; sin6 = (sin6_t *)&tudi[1]; bzero(sin6, sizeof (sin6_t)); sin6->sin6_family = AF_INET6; sin6->sin6_addr = icmp->icmp_v6dst.sin6_addr; toh = (struct T_opthdr *)&sin6[1]; toh->level = IPPROTO_IPV6; toh->name = IPV6_PATHMTU; toh->len = opt_length; toh->status = 0; mtuinfo = (struct ip6_mtuinfo *)&toh[1]; bzero(mtuinfo, sizeof (struct ip6_mtuinfo)); mtuinfo->ip6m_addr.sin6_family = AF_INET6; mtuinfo->ip6m_addr.sin6_addr = ip6h->ip6_dst; mtuinfo->ip6m_mtu = icmp6->icmp6_mtu; /* * We've consumed everything we need from the original * message. Free it, then send our empty message. */ freemsg(mp); icmp_ulp_recv(connp, newmp); return; } case ICMP6_TIME_EXCEEDED: /* Transient errors */ break; case ICMP6_PARAM_PROB: /* If this corresponds to an ICMP_PROTOCOL_UNREACHABLE */ if (icmp6->icmp6_code == ICMP6_PARAMPROB_NEXTHEADER && (uchar_t *)ip6h + icmp6->icmp6_pptr == (uchar_t *)nexthdrp) { error = ECONNREFUSED; break; } break; } if (error == 0) { freemsg(mp); return; } /* * Deliver T_UDERROR_IND when the application has asked for it. * The socket layer enables this automatically when connected. */ if (!icmp->icmp_dgram_errind) { freemsg(mp); return; } sin6 = sin6_null; sin6.sin6_family = AF_INET6; sin6.sin6_addr = ip6h->ip6_dst; sin6.sin6_flowinfo = ip6h->ip6_vcf & ~IPV6_VERS_AND_FLOW_MASK; if (IPCL_IS_NONSTR(connp)) { rw_enter(&icmp->icmp_rwlock, RW_WRITER); if (icmp->icmp_state == TS_DATA_XFER) { if (IN6_ARE_ADDR_EQUAL(&sin6.sin6_addr, &icmp->icmp_v6dst.sin6_addr)) { rw_exit(&icmp->icmp_rwlock); (*connp->conn_upcalls->su_set_error) (connp->conn_upper_handle, error); goto done; } } else { icmp->icmp_delayed_error = error; *((sin6_t *)&icmp->icmp_delayed_addr) = sin6; } rw_exit(&icmp->icmp_rwlock); } else { mp1 = mi_tpi_uderror_ind((char *)&sin6, sizeof (sin6_t), NULL, 0, error); if (mp1 != NULL) putnext(connp->conn_rq, mp1); } done: ASSERT(!RW_ISWRITER(&icmp->icmp_rwlock)); freemsg(mp); } /* * This routine responds to T_ADDR_REQ messages. It is called by icmp_wput. * The local address is filled in if endpoint is bound. The remote address * is filled in if remote address has been precified ("connected endpoint") * (The concept of connected CLTS sockets is alien to published TPI * but we support it anyway). */ static void icmp_addr_req(queue_t *q, mblk_t *mp) { icmp_t *icmp = Q_TO_ICMP(q); mblk_t *ackmp; struct T_addr_ack *taa; /* Make it large enough for worst case */ ackmp = reallocb(mp, sizeof (struct T_addr_ack) + 2 * sizeof (sin6_t), 1); if (ackmp == NULL) { icmp_err_ack(q, mp, TSYSERR, ENOMEM); return; } taa = (struct T_addr_ack *)ackmp->b_rptr; bzero(taa, sizeof (struct T_addr_ack)); ackmp->b_wptr = (uchar_t *)&taa[1]; taa->PRIM_type = T_ADDR_ACK; ackmp->b_datap->db_type = M_PCPROTO; rw_enter(&icmp->icmp_rwlock, RW_READER); /* * Note: Following code assumes 32 bit alignment of basic * data structures like sin_t and struct T_addr_ack. */ if (icmp->icmp_state != TS_UNBND) { /* * Fill in local address */ taa->LOCADDR_offset = sizeof (*taa); if (icmp->icmp_family == AF_INET) { sin_t *sin; taa->LOCADDR_length = sizeof (sin_t); sin = (sin_t *)&taa[1]; /* Fill zeroes and then intialize non-zero fields */ *sin = sin_null; sin->sin_family = AF_INET; if (!IN6_IS_ADDR_V4MAPPED_ANY(&icmp->icmp_v6src) && !IN6_IS_ADDR_UNSPECIFIED(&icmp->icmp_v6src)) { IN6_V4MAPPED_TO_IPADDR(&icmp->icmp_v6src, sin->sin_addr.s_addr); } else { /* * INADDR_ANY * icmp_v6src is not set, we might be bound to * broadcast/multicast. Use icmp_bound_v6src as * local address instead (that could * also still be INADDR_ANY) */ IN6_V4MAPPED_TO_IPADDR(&icmp->icmp_bound_v6src, sin->sin_addr.s_addr); } ackmp->b_wptr = (uchar_t *)&sin[1]; } else { sin6_t *sin6; ASSERT(icmp->icmp_family == AF_INET6); taa->LOCADDR_length = sizeof (sin6_t); sin6 = (sin6_t *)&taa[1]; /* Fill zeroes and then intialize non-zero fields */ *sin6 = sin6_null; sin6->sin6_family = AF_INET6; if (!IN6_IS_ADDR_UNSPECIFIED(&icmp->icmp_v6src)) { sin6->sin6_addr = icmp->icmp_v6src; } else { /* * UNSPECIFIED * icmp_v6src is not set, we might be bound to * broadcast/multicast. Use icmp_bound_v6src as * local address instead (that could * also still be UNSPECIFIED) */ sin6->sin6_addr = icmp->icmp_bound_v6src; } ackmp->b_wptr = (uchar_t *)&sin6[1]; } } rw_exit(&icmp->icmp_rwlock); ASSERT(ackmp->b_wptr <= ackmp->b_datap->db_lim); qreply(q, ackmp); } static void icmp_copy_info(struct T_info_ack *tap, icmp_t *icmp) { *tap = icmp_g_t_info_ack; if (icmp->icmp_family == AF_INET6) tap->ADDR_size = sizeof (sin6_t); else tap->ADDR_size = sizeof (sin_t); tap->CURRENT_state = icmp->icmp_state; tap->OPT_size = icmp_max_optsize; } static void icmp_do_capability_ack(icmp_t *icmp, struct T_capability_ack *tcap, t_uscalar_t cap_bits1) { tcap->CAP_bits1 = 0; if (cap_bits1 & TC1_INFO) { icmp_copy_info(&tcap->INFO_ack, icmp); tcap->CAP_bits1 |= TC1_INFO; } } /* * This routine responds to T_CAPABILITY_REQ messages. It is called by * icmp_wput. Much of the T_CAPABILITY_ACK information is copied from * icmp_g_t_info_ack. The current state of the stream is copied from * icmp_state. */ static void icmp_capability_req(queue_t *q, mblk_t *mp) { icmp_t *icmp = Q_TO_ICMP(q); t_uscalar_t cap_bits1; struct T_capability_ack *tcap; cap_bits1 = ((struct T_capability_req *)mp->b_rptr)->CAP_bits1; mp = tpi_ack_alloc(mp, sizeof (struct T_capability_ack), mp->b_datap->db_type, T_CAPABILITY_ACK); if (!mp) return; tcap = (struct T_capability_ack *)mp->b_rptr; icmp_do_capability_ack(icmp, tcap, cap_bits1); qreply(q, mp); } /* * This routine responds to T_INFO_REQ messages. It is called by icmp_wput. * Most of the T_INFO_ACK information is copied from icmp_g_t_info_ack. * The current state of the stream is copied from icmp_state. */ static void icmp_info_req(queue_t *q, mblk_t *mp) { icmp_t *icmp = Q_TO_ICMP(q); mp = tpi_ack_alloc(mp, sizeof (struct T_info_ack), M_PCPROTO, T_INFO_ACK); if (!mp) return; icmp_copy_info((struct T_info_ack *)mp->b_rptr, icmp); qreply(q, mp); } /* For /dev/icmp aka AF_INET open */ static int icmp_tpi_open(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *credp, int family) { conn_t *connp; dev_t conn_dev; icmp_stack_t *is; int error; conn_dev = NULL; /* If the stream is already open, return immediately. */ if (q->q_ptr != NULL) return (0); if (sflag == MODOPEN) return (EINVAL); /* * Since ICMP is not used so heavily, allocating from the small * arena should be sufficient. */ if ((conn_dev = inet_minor_alloc(ip_minor_arena_sa)) == 0) { return (EBUSY); } if (flag & SO_FALLBACK) { /* * Non streams socket needs a stream to fallback to */ RD(q)->q_ptr = (void *)conn_dev; WR(q)->q_qinfo = &icmp_fallback_sock_winit; WR(q)->q_ptr = (void *)ip_minor_arena_sa; qprocson(q); return (0); } connp = icmp_open(family, credp, &error, KM_SLEEP); if (connp == NULL) { ASSERT(error != NULL); inet_minor_free(ip_minor_arena_sa, connp->conn_dev); return (error); } *devp = makedevice(getemajor(*devp), (minor_t)conn_dev); connp->conn_dev = conn_dev; connp->conn_minor_arena = ip_minor_arena_sa; is = connp->conn_icmp->icmp_is; /* * Initialize the icmp_t structure for this stream. */ q->q_ptr = connp; WR(q)->q_ptr = connp; connp->conn_rq = q; connp->conn_wq = WR(q); if (connp->conn_icmp->icmp_family == AF_INET6) { /* Build initial header template for transmit */ rw_enter(&connp->conn_icmp->icmp_rwlock, RW_WRITER); if ((error = icmp_build_hdrs(connp->conn_icmp)) != 0) { rw_exit(&connp->conn_icmp->icmp_rwlock); inet_minor_free(ip_minor_arena_sa, connp->conn_dev); ipcl_conn_destroy(connp); return (error); } rw_exit(&connp->conn_icmp->icmp_rwlock); } q->q_hiwat = is->is_recv_hiwat; WR(q)->q_hiwat = is->is_xmit_hiwat; WR(q)->q_lowat = is->is_xmit_lowat; qprocson(q); /* Set the Stream head write offset. */ (void) proto_set_tx_wroff(q, connp, connp->conn_icmp->icmp_max_hdr_len + is->is_wroff_extra); (void) proto_set_rx_hiwat(connp->conn_rq, connp, q->q_hiwat); mutex_enter(&connp->conn_lock); connp->conn_state_flags &= ~CONN_INCIPIENT; mutex_exit(&connp->conn_lock); return (0); } /* For /dev/icmp4 aka AF_INET open */ static int icmp_openv4(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *credp) { return (icmp_tpi_open(q, devp, flag, sflag, credp, AF_INET)); } /* For /dev/icmp6 aka AF_INET6 open */ static int icmp_openv6(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *credp) { return (icmp_tpi_open(q, devp, flag, sflag, credp, AF_INET6)); } /* * This is the open routine for icmp. It allocates a icmp_t structure for * the stream and, on the first open of the module, creates an ND table. */ /* ARGSUSED */ static conn_t * icmp_open(int family, cred_t *credp, int *err, int flags) { icmp_t *icmp; conn_t *connp; zoneid_t zoneid; netstack_t *ns; icmp_stack_t *is; boolean_t isv6 = B_FALSE; *err = secpolicy_net_icmpaccess(credp); if (*err != 0) return (NULL); if (family == AF_INET6) isv6 = B_TRUE; ns = netstack_find_by_cred(credp); ASSERT(ns != NULL); is = ns->netstack_icmp; ASSERT(is != NULL); /* * For exclusive stacks we set the zoneid to zero * to make ICMP operate as if in the global zone. */ if (ns->netstack_stackid != GLOBAL_NETSTACKID) zoneid = GLOBAL_ZONEID; else zoneid = crgetzoneid(credp); ASSERT(flags == KM_SLEEP || flags == KM_NOSLEEP); connp = ipcl_conn_create(IPCL_RAWIPCONN, flags, ns); icmp = connp->conn_icmp; icmp->icmp_v6dst = sin6_null; /* * ipcl_conn_create did a netstack_hold. Undo the hold that was * done by netstack_find_by_cred() */ netstack_rele(ns); rw_enter(&icmp->icmp_rwlock, RW_WRITER); ASSERT(connp->conn_ulp == IPPROTO_ICMP); ASSERT(connp->conn_icmp == icmp); ASSERT(icmp->icmp_connp == connp); /* Set the initial state of the stream and the privilege status. */ icmp->icmp_state = TS_UNBND; if (isv6) { icmp->icmp_ipversion = IPV6_VERSION; icmp->icmp_family = AF_INET6; connp->conn_ulp = IPPROTO_ICMPV6; /* May be changed by a SO_PROTOTYPE socket option. */ icmp->icmp_proto = IPPROTO_ICMPV6; icmp->icmp_checksum_off = 2; /* Offset for icmp6_cksum */ icmp->icmp_max_hdr_len = IPV6_HDR_LEN; icmp->icmp_ttl = (uint8_t)is->is_ipv6_hoplimit; connp->conn_af_isv6 = B_TRUE; connp->conn_flags |= IPCL_ISV6; } else { icmp->icmp_ipversion = IPV4_VERSION; icmp->icmp_family = AF_INET; /* May be changed by a SO_PROTOTYPE socket option. */ icmp->icmp_proto = IPPROTO_ICMP; icmp->icmp_max_hdr_len = IP_SIMPLE_HDR_LENGTH; icmp->icmp_ttl = (uint8_t)is->is_ipv4_ttl; connp->conn_af_isv6 = B_FALSE; connp->conn_flags &= ~IPCL_ISV6; } icmp->icmp_multicast_ttl = IP_DEFAULT_MULTICAST_TTL; icmp->icmp_pending_op = -1; connp->conn_multicast_loop = IP_DEFAULT_MULTICAST_LOOP; connp->conn_zoneid = zoneid; /* * If the caller has the process-wide flag set, then default to MAC * exempt mode. This allows read-down to unlabeled hosts. */ if (getpflags(NET_MAC_AWARE, credp) != 0) connp->conn_mac_exempt = B_TRUE; connp->conn_ulp_labeled = is_system_labeled(); icmp->icmp_is = is; connp->conn_recv = icmp_input; crhold(credp); connp->conn_cred = credp; rw_exit(&icmp->icmp_rwlock); connp->conn_flow_cntrld = B_FALSE; return (connp); } /* * Which ICMP options OK to set through T_UNITDATA_REQ... */ /* ARGSUSED */ static boolean_t icmp_opt_allow_udr_set(t_scalar_t level, t_scalar_t name) { return (B_TRUE); } /* * This routine gets default values of certain options whose default * values are maintained by protcol specific code */ /* ARGSUSED */ int icmp_opt_default(queue_t *q, int level, int name, uchar_t *ptr) { icmp_t *icmp = Q_TO_ICMP(q); icmp_stack_t *is = icmp->icmp_is; int *i1 = (int *)ptr; switch (level) { case IPPROTO_IP: switch (name) { case IP_MULTICAST_TTL: *ptr = (uchar_t)IP_DEFAULT_MULTICAST_TTL; return (sizeof (uchar_t)); case IP_MULTICAST_LOOP: *ptr = (uchar_t)IP_DEFAULT_MULTICAST_LOOP; return (sizeof (uchar_t)); } break; case IPPROTO_IPV6: switch (name) { case IPV6_MULTICAST_HOPS: *i1 = IP_DEFAULT_MULTICAST_TTL; return (sizeof (int)); case IPV6_MULTICAST_LOOP: *i1 = IP_DEFAULT_MULTICAST_LOOP; return (sizeof (int)); case IPV6_UNICAST_HOPS: *i1 = is->is_ipv6_hoplimit; return (sizeof (int)); } break; case IPPROTO_ICMPV6: switch (name) { case ICMP6_FILTER: /* Make it look like "pass all" */ ICMP6_FILTER_SETPASSALL((icmp6_filter_t *)ptr); return (sizeof (icmp6_filter_t)); } break; } return (-1); } /* * This routine retrieves the current status of socket options. * It returns the size of the option retrieved. */ int icmp_opt_get(conn_t *connp, int level, int name, uchar_t *ptr) { icmp_t *icmp = connp->conn_icmp; icmp_stack_t *is = icmp->icmp_is; int *i1 = (int *)ptr; ip6_pkt_t *ipp = &icmp->icmp_sticky_ipp; int ret = 0; ASSERT(RW_READ_HELD(&icmp->icmp_rwlock)); switch (level) { case SOL_SOCKET: switch (name) { case SO_DEBUG: *i1 = icmp->icmp_debug; break; case SO_TYPE: *i1 = SOCK_RAW; break; case SO_PROTOTYPE: *i1 = icmp->icmp_proto; break; case SO_REUSEADDR: *i1 = icmp->icmp_reuseaddr; break; /* * The following three items are available here, * but are only meaningful to IP. */ case SO_DONTROUTE: *i1 = icmp->icmp_dontroute; break; case SO_USELOOPBACK: *i1 = icmp->icmp_useloopback; break; case SO_BROADCAST: *i1 = icmp->icmp_broadcast; break; case SO_SNDBUF: ASSERT(icmp->icmp_xmit_hiwat <= INT_MAX); *i1 = icmp->icmp_xmit_hiwat; break; case SO_RCVBUF: ASSERT(icmp->icmp_recv_hiwat <= INT_MAX); *i1 = icmp->icmp_recv_hiwat; break; case SO_DGRAM_ERRIND: *i1 = icmp->icmp_dgram_errind; break; case SO_TIMESTAMP: *i1 = icmp->icmp_timestamp; break; case SO_MAC_EXEMPT: *i1 = connp->conn_mac_exempt; break; case SO_DOMAIN: *i1 = icmp->icmp_family; break; /* * Following four not meaningful for icmp * Action is same as "default" to which we fallthrough * so we keep them in comments. * case SO_LINGER: * case SO_KEEPALIVE: * case SO_OOBINLINE: * case SO_ALLZONES: */ default: ret = -1; goto done; } break; case IPPROTO_IP: /* * Only allow IPv4 option processing on IPv4 sockets. */ if (icmp->icmp_family != AF_INET) { ret = -1; goto done; } switch (name) { case IP_OPTIONS: case T_IP_OPTIONS: /* Options are passed up with each packet */ ret = 0; goto done; case IP_HDRINCL: *i1 = (int)icmp->icmp_hdrincl; break; case IP_TOS: case T_IP_TOS: *i1 = (int)icmp->icmp_type_of_service; break; case IP_TTL: *i1 = (int)icmp->icmp_ttl; break; case IP_MULTICAST_IF: /* 0 address if not set */ *(ipaddr_t *)ptr = icmp->icmp_multicast_if_addr; ret = sizeof (ipaddr_t); goto done; case IP_MULTICAST_TTL: *(uchar_t *)ptr = icmp->icmp_multicast_ttl; ret = sizeof (uchar_t); goto done; case IP_MULTICAST_LOOP: *ptr = connp->conn_multicast_loop; ret = sizeof (uint8_t); goto done; case IP_BOUND_IF: /* Zero if not set */ *i1 = icmp->icmp_bound_if; break; /* goto sizeof (int) option return */ case IP_UNSPEC_SRC: *ptr = icmp->icmp_unspec_source; break; /* goto sizeof (int) option return */ case IP_RECVIF: *ptr = icmp->icmp_recvif; break; /* goto sizeof (int) option return */ case IP_BROADCAST_TTL: *(uchar_t *)ptr = connp->conn_broadcast_ttl; return (sizeof (uchar_t)); case IP_RECVPKTINFO: /* * This also handles IP_PKTINFO. * IP_PKTINFO and IP_RECVPKTINFO have the same value. * Differentiation is based on the size of the argument * passed in. * This option is handled in IP which will return an * error for IP_PKTINFO as it's not supported as a * sticky option. */ ret = -EINVAL; goto done; /* * Cannot "get" the value of following options * at this level. Action is same as "default" to * which we fallthrough so we keep them in comments. * * case IP_ADD_MEMBERSHIP: * case IP_DROP_MEMBERSHIP: * case IP_BLOCK_SOURCE: * case IP_UNBLOCK_SOURCE: * case IP_ADD_SOURCE_MEMBERSHIP: * case IP_DROP_SOURCE_MEMBERSHIP: * case MCAST_JOIN_GROUP: * case MCAST_LEAVE_GROUP: * case MCAST_BLOCK_SOURCE: * case MCAST_UNBLOCK_SOURCE: * case MCAST_JOIN_SOURCE_GROUP: * case MCAST_LEAVE_SOURCE_GROUP: * case MRT_INIT: * case MRT_DONE: * case MRT_ADD_VIF: * case MRT_DEL_VIF: * case MRT_ADD_MFC: * case MRT_DEL_MFC: * case MRT_VERSION: * case MRT_ASSERT: * case IP_SEC_OPT: * case IP_NEXTHOP: */ default: ret = -1; goto done; } break; case IPPROTO_IPV6: /* * Only allow IPv6 option processing on native IPv6 sockets. */ if (icmp->icmp_family != AF_INET6) { ret = -1; goto done; } switch (name) { case IPV6_UNICAST_HOPS: *i1 = (unsigned int)icmp->icmp_ttl; break; case IPV6_MULTICAST_IF: /* 0 index if not set */ *i1 = icmp->icmp_multicast_if_index; break; case IPV6_MULTICAST_HOPS: *i1 = icmp->icmp_multicast_ttl; break; case IPV6_MULTICAST_LOOP: *i1 = connp->conn_multicast_loop; break; case IPV6_BOUND_IF: /* Zero if not set */ *i1 = icmp->icmp_bound_if; break; case IPV6_UNSPEC_SRC: *i1 = icmp->icmp_unspec_source; break; case IPV6_CHECKSUM: /* * Return offset or -1 if no checksum offset. * Does not apply to IPPROTO_ICMPV6 */ if (icmp->icmp_proto == IPPROTO_ICMPV6) { ret = -1; goto done; } if (icmp->icmp_raw_checksum) { *i1 = icmp->icmp_checksum_off; } else { *i1 = -1; } break; case IPV6_JOIN_GROUP: case IPV6_LEAVE_GROUP: case MCAST_JOIN_GROUP: case MCAST_LEAVE_GROUP: case MCAST_BLOCK_SOURCE: case MCAST_UNBLOCK_SOURCE: case MCAST_JOIN_SOURCE_GROUP: case MCAST_LEAVE_SOURCE_GROUP: /* cannot "get" the value for these */ ret = -1; goto done; case IPV6_RECVPKTINFO: *i1 = icmp->icmp_ip_recvpktinfo; break; case IPV6_RECVTCLASS: *i1 = icmp->icmp_ipv6_recvtclass; break; case IPV6_RECVPATHMTU: *i1 = icmp->icmp_ipv6_recvpathmtu; break; case IPV6_V6ONLY: *i1 = 1; break; case IPV6_RECVHOPLIMIT: *i1 = icmp->icmp_ipv6_recvhoplimit; break; case IPV6_RECVHOPOPTS: *i1 = icmp->icmp_ipv6_recvhopopts; break; case IPV6_RECVDSTOPTS: *i1 = icmp->icmp_ipv6_recvdstopts; break; case _OLD_IPV6_RECVDSTOPTS: *i1 = icmp->icmp_old_ipv6_recvdstopts; break; case IPV6_RECVRTHDRDSTOPTS: *i1 = icmp->icmp_ipv6_recvrtdstopts; break; case IPV6_RECVRTHDR: *i1 = icmp->icmp_ipv6_recvrthdr; break; case IPV6_PKTINFO: { /* XXX assumes that caller has room for max size! */ struct in6_pktinfo *pkti; pkti = (struct in6_pktinfo *)ptr; if (ipp->ipp_fields & IPPF_IFINDEX) pkti->ipi6_ifindex = ipp->ipp_ifindex; else pkti->ipi6_ifindex = 0; if (ipp->ipp_fields & IPPF_ADDR) pkti->ipi6_addr = ipp->ipp_addr; else pkti->ipi6_addr = ipv6_all_zeros; ret = sizeof (struct in6_pktinfo); goto done; } case IPV6_NEXTHOP: { sin6_t *sin6 = (sin6_t *)ptr; if (!(ipp->ipp_fields & IPPF_NEXTHOP)) return (0); *sin6 = sin6_null; sin6->sin6_family = AF_INET6; sin6->sin6_addr = ipp->ipp_nexthop; ret = (sizeof (sin6_t)); goto done; } case IPV6_HOPOPTS: if (!(ipp->ipp_fields & IPPF_HOPOPTS)) return (0); if (ipp->ipp_hopoptslen <= icmp->icmp_label_len_v6) return (0); bcopy((char *)ipp->ipp_hopopts + icmp->icmp_label_len_v6, ptr, ipp->ipp_hopoptslen - icmp->icmp_label_len_v6); if (icmp->icmp_label_len_v6 > 0) { ptr[0] = ((char *)ipp->ipp_hopopts)[0]; ptr[1] = (ipp->ipp_hopoptslen - icmp->icmp_label_len_v6 + 7) / 8 - 1; } ret = (ipp->ipp_hopoptslen - icmp->icmp_label_len_v6); goto done; case IPV6_RTHDRDSTOPTS: if (!(ipp->ipp_fields & IPPF_RTDSTOPTS)) return (0); bcopy(ipp->ipp_rtdstopts, ptr, ipp->ipp_rtdstoptslen); ret = ipp->ipp_rtdstoptslen; goto done; case IPV6_RTHDR: if (!(ipp->ipp_fields & IPPF_RTHDR)) return (0); bcopy(ipp->ipp_rthdr, ptr, ipp->ipp_rthdrlen); ret = ipp->ipp_rthdrlen; goto done; case IPV6_DSTOPTS: if (!(ipp->ipp_fields & IPPF_DSTOPTS)) { ret = 0; goto done; } bcopy(ipp->ipp_dstopts, ptr, ipp->ipp_dstoptslen); ret = ipp->ipp_dstoptslen; goto done; case IPV6_PATHMTU: if (!(ipp->ipp_fields & IPPF_PATHMTU)) { ret = 0; } else { ret = ip_fill_mtuinfo( &icmp->icmp_v6dst.sin6_addr, 0, (struct ip6_mtuinfo *)ptr, is->is_netstack); } goto done; case IPV6_TCLASS: if (ipp->ipp_fields & IPPF_TCLASS) *i1 = ipp->ipp_tclass; else *i1 = IPV6_FLOW_TCLASS( IPV6_DEFAULT_VERS_AND_FLOW); break; default: ret = -1; goto done; } break; case IPPROTO_ICMPV6: /* * Only allow IPv6 option processing on native IPv6 sockets. */ if (icmp->icmp_family != AF_INET6) { ret = -1; } if (icmp->icmp_proto != IPPROTO_ICMPV6) { ret = -1; } switch (name) { case ICMP6_FILTER: if (icmp->icmp_filter == NULL) { /* Make it look like "pass all" */ ICMP6_FILTER_SETPASSALL((icmp6_filter_t *)ptr); } else { (void) bcopy(icmp->icmp_filter, ptr, sizeof (icmp6_filter_t)); } ret = sizeof (icmp6_filter_t); goto done; default: ret = -1; goto done; } default: ret = -1; goto done; } ret = sizeof (int); done: return (ret); } /* * This routine retrieves the current status of socket options. * It returns the size of the option retrieved. */ int icmp_tpi_opt_get(queue_t *q, int level, int name, uchar_t *ptr) { conn_t *connp = Q_TO_CONN(q); icmp_t *icmp = connp->conn_icmp; int err; rw_enter(&icmp->icmp_rwlock, RW_READER); err = icmp_opt_get(connp, level, name, ptr); rw_exit(&icmp->icmp_rwlock); return (err); } int icmp_do_opt_set(conn_t *connp, int level, int name, uint_t inlen, uchar_t *invalp, uint_t *outlenp, uchar_t *outvalp, cred_t *cr, void *thisdg_attrs, boolean_t checkonly) { int *i1 = (int *)invalp; boolean_t onoff = (*i1 == 0) ? 0 : 1; icmp_t *icmp = connp->conn_icmp; icmp_stack_t *is = icmp->icmp_is; int error; ASSERT(RW_WRITE_HELD(&icmp->icmp_rwlock)); /* * For fixed length options, no sanity check * of passed in length is done. It is assumed *_optcom_req() * routines do the right thing. */ switch (level) { case SOL_SOCKET: switch (name) { case SO_DEBUG: if (!checkonly) icmp->icmp_debug = onoff; break; case SO_PROTOTYPE: if ((*i1 & 0xFF) != IPPROTO_ICMP && (*i1 & 0xFF) != IPPROTO_ICMPV6 && secpolicy_net_rawaccess(cr) != 0) { *outlenp = 0; return (EACCES); } /* Can't use IPPROTO_RAW with IPv6 */ if ((*i1 & 0xFF) == IPPROTO_RAW && icmp->icmp_family == AF_INET6) { *outlenp = 0; return (EPROTONOSUPPORT); } if (checkonly) { /* T_CHECK case */ *(int *)outvalp = (*i1 & 0xFF); break; } icmp->icmp_proto = *i1 & 0xFF; if ((icmp->icmp_proto == IPPROTO_RAW || icmp->icmp_proto == IPPROTO_IGMP) && icmp->icmp_family == AF_INET) icmp->icmp_hdrincl = 1; else icmp->icmp_hdrincl = 0; if (icmp->icmp_family == AF_INET6 && icmp->icmp_proto == IPPROTO_ICMPV6) { /* Set offset for icmp6_cksum */ icmp->icmp_raw_checksum = 0; icmp->icmp_checksum_off = 2; } if (icmp->icmp_proto == IPPROTO_UDP || icmp->icmp_proto == IPPROTO_TCP || icmp->icmp_proto == IPPROTO_SCTP) { icmp->icmp_no_tp_cksum = 1; icmp->icmp_sticky_ipp.ipp_fields |= IPPF_NO_CKSUM; } else { icmp->icmp_no_tp_cksum = 0; icmp->icmp_sticky_ipp.ipp_fields &= ~IPPF_NO_CKSUM; } if (icmp->icmp_filter != NULL && icmp->icmp_proto != IPPROTO_ICMPV6) { kmem_free(icmp->icmp_filter, sizeof (icmp6_filter_t)); icmp->icmp_filter = NULL; } /* Rebuild the header template */ error = icmp_build_hdrs(icmp); if (error != 0) { *outlenp = 0; return (error); } /* * For SCTP, we don't use icmp_bind_proto() for * raw socket binding. Note that we do not need * to set *outlenp. * FIXME: how does SCTP work? */ if (icmp->icmp_proto == IPPROTO_SCTP) return (0); *outlenp = sizeof (int); *(int *)outvalp = *i1 & 0xFF; /* Drop lock across the bind operation */ rw_exit(&icmp->icmp_rwlock); (void) icmp_bind_proto(connp); rw_enter(&icmp->icmp_rwlock, RW_WRITER); return (0); case SO_REUSEADDR: if (!checkonly) { icmp->icmp_reuseaddr = onoff; PASS_OPT_TO_IP(connp); } break; /* * The following three items are available here, * but are only meaningful to IP. */ case SO_DONTROUTE: if (!checkonly) { icmp->icmp_dontroute = onoff; PASS_OPT_TO_IP(connp); } break; case SO_USELOOPBACK: if (!checkonly) { icmp->icmp_useloopback = onoff; PASS_OPT_TO_IP(connp); } break; case SO_BROADCAST: if (!checkonly) { icmp->icmp_broadcast = onoff; PASS_OPT_TO_IP(connp); } break; case SO_SNDBUF: if (*i1 > is->is_max_buf) { *outlenp = 0; return (ENOBUFS); } if (!checkonly) { if (!IPCL_IS_NONSTR(connp)) { connp->conn_wq->q_hiwat = *i1; } icmp->icmp_xmit_hiwat = *i1; } break; case SO_RCVBUF: if (*i1 > is->is_max_buf) { *outlenp = 0; return (ENOBUFS); } if (!checkonly) { icmp->icmp_recv_hiwat = *i1; rw_exit(&icmp->icmp_rwlock); (void) proto_set_rx_hiwat(connp->conn_rq, connp, *i1); rw_enter(&icmp->icmp_rwlock, RW_WRITER); } break; case SO_DGRAM_ERRIND: if (!checkonly) icmp->icmp_dgram_errind = onoff; break; case SO_ALLZONES: /* * "soft" error (negative) * option not handled at this level * Note: Do not modify *outlenp */ return (-EINVAL); case SO_TIMESTAMP: if (!checkonly) { icmp->icmp_timestamp = onoff; } break; case SO_MAC_EXEMPT: /* * "soft" error (negative) * option not handled at this level * Note: Do not modify *outlenp */ return (-EINVAL); case SO_RCVTIMEO: case SO_SNDTIMEO: /* * Pass these two options in order for third part * protocol usage. Here just return directly. */ return (0); /* * Following three not meaningful for icmp * Action is same as "default" so we keep them * in comments. * case SO_LINGER: * case SO_KEEPALIVE: * case SO_OOBINLINE: */ default: *outlenp = 0; return (EINVAL); } break; case IPPROTO_IP: /* * Only allow IPv4 option processing on IPv4 sockets. */ if (icmp->icmp_family != AF_INET) { *outlenp = 0; return (ENOPROTOOPT); } switch (name) { case IP_OPTIONS: case T_IP_OPTIONS: /* Save options for use by IP. */ if ((inlen & 0x3) || inlen + icmp->icmp_label_len > IP_MAX_OPT_LENGTH) { *outlenp = 0; return (EINVAL); } if (checkonly) break; if (!tsol_option_set(&icmp->icmp_ip_snd_options, &icmp->icmp_ip_snd_options_len, icmp->icmp_label_len, invalp, inlen)) { *outlenp = 0; return (ENOMEM); } icmp->icmp_max_hdr_len = IP_SIMPLE_HDR_LENGTH + icmp->icmp_ip_snd_options_len; rw_exit(&icmp->icmp_rwlock); (void) proto_set_tx_wroff(connp->conn_rq == NULL ? NULL: RD(connp->conn_rq), connp, icmp->icmp_max_hdr_len + is->is_wroff_extra); rw_enter(&icmp->icmp_rwlock, RW_WRITER); break; case IP_HDRINCL: if (!checkonly) icmp->icmp_hdrincl = onoff; break; case IP_TOS: case T_IP_TOS: if (!checkonly) { icmp->icmp_type_of_service = (uint8_t)*i1; } break; case IP_TTL: if (!checkonly) { icmp->icmp_ttl = (uint8_t)*i1; } break; case IP_MULTICAST_IF: /* * TODO should check OPTMGMT reply and undo this if * there is an error. */ if (!checkonly) { icmp->icmp_multicast_if_addr = *i1; PASS_OPT_TO_IP(connp); } break; case IP_MULTICAST_TTL: if (!checkonly) icmp->icmp_multicast_ttl = *invalp; break; case IP_MULTICAST_LOOP: if (!checkonly) { connp->conn_multicast_loop = (*invalp == 0) ? 0 : 1; PASS_OPT_TO_IP(connp); } break; case IP_BOUND_IF: if (!checkonly) { icmp->icmp_bound_if = *i1; PASS_OPT_TO_IP(connp); } break; case IP_UNSPEC_SRC: if (!checkonly) { icmp->icmp_unspec_source = onoff; PASS_OPT_TO_IP(connp); } break; case IP_BROADCAST_TTL: if (!checkonly) connp->conn_broadcast_ttl = *invalp; break; case IP_RECVIF: if (!checkonly) { icmp->icmp_recvif = onoff; } /* * pass to ip */ return (-EINVAL); case IP_PKTINFO: { /* * This also handles IP_RECVPKTINFO. * IP_PKTINFO and IP_RECVPKTINFO have the same value. * Differentiation is based on the size of the argument * passed in. */ struct in_pktinfo *pktinfop; ip4_pkt_t *attr_pktinfop; if (checkonly) break; if (inlen == sizeof (int)) { /* * This is IP_RECVPKTINFO option. * Keep a local copy of wether this option is * set or not and pass it down to IP for * processing. */ icmp->icmp_ip_recvpktinfo = onoff; return (-EINVAL); } if (inlen != sizeof (struct in_pktinfo)) { return (EINVAL); } if ((attr_pktinfop = (ip4_pkt_t *)thisdg_attrs) == NULL) { /* * sticky option is not supported */ return (EINVAL); } pktinfop = (struct in_pktinfo *)invalp; /* * Atleast one of the values should be specified */ if (pktinfop->ipi_ifindex == 0 && pktinfop->ipi_spec_dst.s_addr == INADDR_ANY) { return (EINVAL); } attr_pktinfop->ip4_addr = pktinfop->ipi_spec_dst.s_addr; attr_pktinfop->ip4_ill_index = pktinfop->ipi_ifindex; } break; case IP_ADD_MEMBERSHIP: case IP_DROP_MEMBERSHIP: case IP_BLOCK_SOURCE: case IP_UNBLOCK_SOURCE: case IP_ADD_SOURCE_MEMBERSHIP: case IP_DROP_SOURCE_MEMBERSHIP: case MCAST_JOIN_GROUP: case MCAST_LEAVE_GROUP: case MCAST_BLOCK_SOURCE: case MCAST_UNBLOCK_SOURCE: case MCAST_JOIN_SOURCE_GROUP: case MCAST_LEAVE_SOURCE_GROUP: case MRT_INIT: case MRT_DONE: case MRT_ADD_VIF: case MRT_DEL_VIF: case MRT_ADD_MFC: case MRT_DEL_MFC: case MRT_VERSION: case MRT_ASSERT: case IP_SEC_OPT: case IP_NEXTHOP: /* * "soft" error (negative) * option not handled at this level * Note: Do not modify *outlenp */ return (-EINVAL); default: *outlenp = 0; return (EINVAL); } break; case IPPROTO_IPV6: { ip6_pkt_t *ipp; boolean_t sticky; if (icmp->icmp_family != AF_INET6) { *outlenp = 0; return (ENOPROTOOPT); } /* * Deal with both sticky options and ancillary data */ if (thisdg_attrs == NULL) { /* sticky options, or none */ ipp = &icmp->icmp_sticky_ipp; sticky = B_TRUE; } else { /* ancillary data */ ipp = (ip6_pkt_t *)thisdg_attrs; sticky = B_FALSE; } switch (name) { case IPV6_MULTICAST_IF: if (!checkonly) { icmp->icmp_multicast_if_index = *i1; PASS_OPT_TO_IP(connp); } break; case IPV6_UNICAST_HOPS: /* -1 means use default */ if (*i1 < -1 || *i1 > IPV6_MAX_HOPS) { *outlenp = 0; return (EINVAL); } if (!checkonly) { if (*i1 == -1) { icmp->icmp_ttl = ipp->ipp_unicast_hops = is->is_ipv6_hoplimit; ipp->ipp_fields &= ~IPPF_UNICAST_HOPS; /* Pass modified value to IP. */ *i1 = ipp->ipp_hoplimit; } else { icmp->icmp_ttl = ipp->ipp_unicast_hops = (uint8_t)*i1; ipp->ipp_fields |= IPPF_UNICAST_HOPS; } /* Rebuild the header template */ error = icmp_build_hdrs(icmp); if (error != 0) { *outlenp = 0; return (error); } } break; case IPV6_MULTICAST_HOPS: /* -1 means use default */ if (*i1 < -1 || *i1 > IPV6_MAX_HOPS) { *outlenp = 0; return (EINVAL); } if (!checkonly) { if (*i1 == -1) { icmp->icmp_multicast_ttl = ipp->ipp_multicast_hops = IP_DEFAULT_MULTICAST_TTL; ipp->ipp_fields &= ~IPPF_MULTICAST_HOPS; /* Pass modified value to IP. */ *i1 = icmp->icmp_multicast_ttl; } else { icmp->icmp_multicast_ttl = ipp->ipp_multicast_hops = (uint8_t)*i1; ipp->ipp_fields |= IPPF_MULTICAST_HOPS; } } break; case IPV6_MULTICAST_LOOP: if (*i1 != 0 && *i1 != 1) { *outlenp = 0; return (EINVAL); } if (!checkonly) { connp->conn_multicast_loop = *i1; PASS_OPT_TO_IP(connp); } break; case IPV6_CHECKSUM: /* * Integer offset into the user data of where the * checksum is located. * Offset of -1 disables option. * Does not apply to IPPROTO_ICMPV6. */ if (icmp->icmp_proto == IPPROTO_ICMPV6 || !sticky) { *outlenp = 0; return (EINVAL); } if ((*i1 != -1) && ((*i1 < 0) || (*i1 & 0x1) != 0)) { /* Negative or not 16 bit aligned offset */ *outlenp = 0; return (EINVAL); } if (checkonly) break; if (*i1 == -1) { icmp->icmp_raw_checksum = 0; ipp->ipp_fields &= ~IPPF_RAW_CKSUM; } else { icmp->icmp_raw_checksum = 1; icmp->icmp_checksum_off = *i1; ipp->ipp_fields |= IPPF_RAW_CKSUM; } /* Rebuild the header template */ error = icmp_build_hdrs(icmp); if (error != 0) { *outlenp = 0; return (error); } break; case IPV6_JOIN_GROUP: case IPV6_LEAVE_GROUP: case MCAST_JOIN_GROUP: case MCAST_LEAVE_GROUP: case MCAST_BLOCK_SOURCE: case MCAST_UNBLOCK_SOURCE: case MCAST_JOIN_SOURCE_GROUP: case MCAST_LEAVE_SOURCE_GROUP: /* * "soft" error (negative) * option not handled at this level * Note: Do not modify *outlenp */ return (-EINVAL); case IPV6_BOUND_IF: if (!checkonly) { icmp->icmp_bound_if = *i1; PASS_OPT_TO_IP(connp); } break; case IPV6_UNSPEC_SRC: if (!checkonly) { icmp->icmp_unspec_source = onoff; PASS_OPT_TO_IP(connp); } break; case IPV6_RECVTCLASS: if (!checkonly) { icmp->icmp_ipv6_recvtclass = onoff; PASS_OPT_TO_IP(connp); } break; /* * Set boolean switches for ancillary data delivery */ case IPV6_RECVPKTINFO: if (!checkonly) { icmp->icmp_ip_recvpktinfo = onoff; PASS_OPT_TO_IP(connp); } break; case IPV6_RECVPATHMTU: if (!checkonly) { icmp->icmp_ipv6_recvpathmtu = onoff; PASS_OPT_TO_IP(connp); } break; case IPV6_RECVHOPLIMIT: if (!checkonly) { icmp->icmp_ipv6_recvhoplimit = onoff; PASS_OPT_TO_IP(connp); } break; case IPV6_RECVHOPOPTS: if (!checkonly) { icmp->icmp_ipv6_recvhopopts = onoff; PASS_OPT_TO_IP(connp); } break; case IPV6_RECVDSTOPTS: if (!checkonly) { icmp->icmp_ipv6_recvdstopts = onoff; PASS_OPT_TO_IP(connp); } break; case _OLD_IPV6_RECVDSTOPTS: if (!checkonly) icmp->icmp_old_ipv6_recvdstopts = onoff; break; case IPV6_RECVRTHDRDSTOPTS: if (!checkonly) { icmp->icmp_ipv6_recvrtdstopts = onoff; PASS_OPT_TO_IP(connp); } break; case IPV6_RECVRTHDR: if (!checkonly) { icmp->icmp_ipv6_recvrthdr = onoff; PASS_OPT_TO_IP(connp); } break; /* * Set sticky options or ancillary data. * If sticky options, (re)build any extension headers * that might be needed as a result. */ case IPV6_PKTINFO: /* * The source address and ifindex are verified * in ip_opt_set(). For ancillary data the * source address is checked in ip_wput_v6. */ if (inlen != 0 && inlen != sizeof (struct in6_pktinfo)) { return (EINVAL); } if (checkonly) break; if (inlen == 0) { ipp->ipp_fields &= ~(IPPF_IFINDEX|IPPF_ADDR); ipp->ipp_sticky_ignored |= (IPPF_IFINDEX|IPPF_ADDR); } else { struct in6_pktinfo *pkti; pkti = (struct in6_pktinfo *)invalp; ipp->ipp_ifindex = pkti->ipi6_ifindex; ipp->ipp_addr = pkti->ipi6_addr; if (ipp->ipp_ifindex != 0) ipp->ipp_fields |= IPPF_IFINDEX; else ipp->ipp_fields &= ~IPPF_IFINDEX; if (!IN6_IS_ADDR_UNSPECIFIED( &ipp->ipp_addr)) ipp->ipp_fields |= IPPF_ADDR; else ipp->ipp_fields &= ~IPPF_ADDR; } if (sticky) { error = icmp_build_hdrs(icmp); if (error != 0) return (error); PASS_OPT_TO_IP(connp); } break; case IPV6_HOPLIMIT: /* This option can only be used as ancillary data. */ if (sticky) return (EINVAL); if (inlen != 0 && inlen != sizeof (int)) return (EINVAL); if (checkonly) break; if (inlen == 0) { ipp->ipp_fields &= ~IPPF_HOPLIMIT; ipp->ipp_sticky_ignored |= IPPF_HOPLIMIT; } else { if (*i1 > 255 || *i1 < -1) return (EINVAL); if (*i1 == -1) ipp->ipp_hoplimit = is->is_ipv6_hoplimit; else ipp->ipp_hoplimit = *i1; ipp->ipp_fields |= IPPF_HOPLIMIT; } break; case IPV6_TCLASS: /* * IPV6_RECVTCLASS accepts -1 as use kernel default * and [0, 255] as the actualy traffic class. */ if (inlen != 0 && inlen != sizeof (int)) { return (EINVAL); } if (checkonly) break; if (inlen == 0) { ipp->ipp_fields &= ~IPPF_TCLASS; ipp->ipp_sticky_ignored |= IPPF_TCLASS; } else { if (*i1 >= 256 || *i1 < -1) return (EINVAL); if (*i1 == -1) { ipp->ipp_tclass = IPV6_FLOW_TCLASS( IPV6_DEFAULT_VERS_AND_FLOW); } else { ipp->ipp_tclass = *i1; } ipp->ipp_fields |= IPPF_TCLASS; } if (sticky) { error = icmp_build_hdrs(icmp); if (error != 0) return (error); } break; case IPV6_NEXTHOP: /* * IP will verify that the nexthop is reachable * and fail for sticky options. */ if (inlen != 0 && inlen != sizeof (sin6_t)) { return (EINVAL); } if (checkonly) break; if (inlen == 0) { ipp->ipp_fields &= ~IPPF_NEXTHOP; ipp->ipp_sticky_ignored |= IPPF_NEXTHOP; } else { sin6_t *sin6 = (sin6_t *)invalp; if (sin6->sin6_family != AF_INET6) { return (EAFNOSUPPORT); } if (IN6_IS_ADDR_V4MAPPED(&sin6->sin6_addr)) { return (EADDRNOTAVAIL); } ipp->ipp_nexthop = sin6->sin6_addr; if (!IN6_IS_ADDR_UNSPECIFIED( &ipp->ipp_nexthop)) ipp->ipp_fields |= IPPF_NEXTHOP; else ipp->ipp_fields &= ~IPPF_NEXTHOP; } if (sticky) { error = icmp_build_hdrs(icmp); if (error != 0) return (error); PASS_OPT_TO_IP(connp); } break; case IPV6_HOPOPTS: { ip6_hbh_t *hopts = (ip6_hbh_t *)invalp; /* * Sanity checks - minimum size, size a multiple of * eight bytes, and matching size passed in. */ if (inlen != 0 && inlen != (8 * (hopts->ip6h_len + 1))) { return (EINVAL); } if (checkonly) break; error = optcom_pkt_set(invalp, inlen, sticky, (uchar_t **)&ipp->ipp_hopopts, &ipp->ipp_hopoptslen, sticky ? icmp->icmp_label_len_v6 : 0); if (error != 0) return (error); if (ipp->ipp_hopoptslen == 0) { ipp->ipp_fields &= ~IPPF_HOPOPTS; ipp->ipp_sticky_ignored |= IPPF_HOPOPTS; } else { ipp->ipp_fields |= IPPF_HOPOPTS; } if (sticky) { error = icmp_build_hdrs(icmp); if (error != 0) return (error); } break; } case IPV6_RTHDRDSTOPTS: { ip6_dest_t *dopts = (ip6_dest_t *)invalp; /* * Sanity checks - minimum size, size a multiple of * eight bytes, and matching size passed in. */ if (inlen != 0 && inlen != (8 * (dopts->ip6d_len + 1))) return (EINVAL); if (checkonly) break; if (inlen == 0) { if (sticky && (ipp->ipp_fields & IPPF_RTDSTOPTS) != 0) { kmem_free(ipp->ipp_rtdstopts, ipp->ipp_rtdstoptslen); ipp->ipp_rtdstopts = NULL; ipp->ipp_rtdstoptslen = 0; } ipp->ipp_fields &= ~IPPF_RTDSTOPTS; ipp->ipp_sticky_ignored |= IPPF_RTDSTOPTS; } else { error = optcom_pkt_set(invalp, inlen, sticky, (uchar_t **)&ipp->ipp_rtdstopts, &ipp->ipp_rtdstoptslen, 0); if (error != 0) return (error); ipp->ipp_fields |= IPPF_RTDSTOPTS; } if (sticky) { error = icmp_build_hdrs(icmp); if (error != 0) return (error); } break; } case IPV6_DSTOPTS: { ip6_dest_t *dopts = (ip6_dest_t *)invalp; /* * Sanity checks - minimum size, size a multiple of * eight bytes, and matching size passed in. */ if (inlen != 0 && inlen != (8 * (dopts->ip6d_len + 1))) return (EINVAL); if (checkonly) break; if (inlen == 0) { if (sticky && (ipp->ipp_fields & IPPF_DSTOPTS) != 0) { kmem_free(ipp->ipp_dstopts, ipp->ipp_dstoptslen); ipp->ipp_dstopts = NULL; ipp->ipp_dstoptslen = 0; } ipp->ipp_fields &= ~IPPF_DSTOPTS; ipp->ipp_sticky_ignored |= IPPF_DSTOPTS; } else { error = optcom_pkt_set(invalp, inlen, sticky, (uchar_t **)&ipp->ipp_dstopts, &ipp->ipp_dstoptslen, 0); if (error != 0) return (error); ipp->ipp_fields |= IPPF_DSTOPTS; } if (sticky) { error = icmp_build_hdrs(icmp); if (error != 0) return (error); } break; } case IPV6_RTHDR: { ip6_rthdr_t *rt = (ip6_rthdr_t *)invalp; /* * Sanity checks - minimum size, size a multiple of * eight bytes, and matching size passed in. */ if (inlen != 0 && inlen != (8 * (rt->ip6r_len + 1))) return (EINVAL); if (checkonly) break; if (inlen == 0) { if (sticky && (ipp->ipp_fields & IPPF_RTHDR) != 0) { kmem_free(ipp->ipp_rthdr, ipp->ipp_rthdrlen); ipp->ipp_rthdr = NULL; ipp->ipp_rthdrlen = 0; } ipp->ipp_fields &= ~IPPF_RTHDR; ipp->ipp_sticky_ignored |= IPPF_RTHDR; } else { error = optcom_pkt_set(invalp, inlen, sticky, (uchar_t **)&ipp->ipp_rthdr, &ipp->ipp_rthdrlen, 0); if (error != 0) return (error); ipp->ipp_fields |= IPPF_RTHDR; } if (sticky) { error = icmp_build_hdrs(icmp); if (error != 0) return (error); } break; } case IPV6_DONTFRAG: if (checkonly) break; if (onoff) { ipp->ipp_fields |= IPPF_DONTFRAG; } else { ipp->ipp_fields &= ~IPPF_DONTFRAG; } break; case IPV6_USE_MIN_MTU: if (inlen != sizeof (int)) return (EINVAL); if (*i1 < -1 || *i1 > 1) return (EINVAL); if (checkonly) break; ipp->ipp_fields |= IPPF_USE_MIN_MTU; ipp->ipp_use_min_mtu = *i1; break; /* * This option can't be set. Its only returned via * getsockopt() or ancillary data. */ case IPV6_PATHMTU: return (EINVAL); case IPV6_SEC_OPT: case IPV6_SRC_PREFERENCES: case IPV6_V6ONLY: /* Handled at IP level */ return (-EINVAL); default: *outlenp = 0; return (EINVAL); } break; } /* end IPPROTO_IPV6 */ case IPPROTO_ICMPV6: /* * Only allow IPv6 option processing on IPv6 sockets. */ if (icmp->icmp_family != AF_INET6) { *outlenp = 0; return (ENOPROTOOPT); } if (icmp->icmp_proto != IPPROTO_ICMPV6) { *outlenp = 0; return (ENOPROTOOPT); } switch (name) { case ICMP6_FILTER: if (!checkonly) { if ((inlen != 0) && (inlen != sizeof (icmp6_filter_t))) return (EINVAL); if (inlen == 0) { if (icmp->icmp_filter != NULL) { kmem_free(icmp->icmp_filter, sizeof (icmp6_filter_t)); icmp->icmp_filter = NULL; } } else { if (icmp->icmp_filter == NULL) { icmp->icmp_filter = kmem_alloc( sizeof (icmp6_filter_t), KM_NOSLEEP); if (icmp->icmp_filter == NULL) { *outlenp = 0; return (ENOBUFS); } } (void) bcopy(invalp, icmp->icmp_filter, inlen); } } break; default: *outlenp = 0; return (EINVAL); } break; default: *outlenp = 0; return (EINVAL); } /* * Common case of OK return with outval same as inval. */ if (invalp != outvalp) { /* don't trust bcopy for identical src/dst */ (void) bcopy(invalp, outvalp, inlen); } *outlenp = inlen; return (0); } /* This routine sets socket options. */ /* ARGSUSED */ int icmp_opt_set(conn_t *connp, uint_t optset_context, int level, int name, uint_t inlen, uchar_t *invalp, uint_t *outlenp, uchar_t *outvalp, void *thisdg_attrs, cred_t *cr) { boolean_t checkonly; int error; error = 0; switch (optset_context) { case SETFN_OPTCOM_CHECKONLY: checkonly = B_TRUE; /* * Note: Implies T_CHECK semantics for T_OPTCOM_REQ * inlen != 0 implies value supplied and * we have to "pretend" to set it. * inlen == 0 implies that there is no * value part in T_CHECK request and just validation * done elsewhere should be enough, we just return here. */ if (inlen == 0) { *outlenp = 0; error = 0; goto done; } break; case SETFN_OPTCOM_NEGOTIATE: checkonly = B_FALSE; break; case SETFN_UD_NEGOTIATE: case SETFN_CONN_NEGOTIATE: checkonly = B_FALSE; /* * Negotiating local and "association-related" options * through T_UNITDATA_REQ. * * Following routine can filter out ones we do not * want to be "set" this way. */ if (!icmp_opt_allow_udr_set(level, name)) { *outlenp = 0; error = EINVAL; goto done; } break; default: /* * We should never get here */ *outlenp = 0; error = EINVAL; goto done; } ASSERT((optset_context != SETFN_OPTCOM_CHECKONLY) || (optset_context == SETFN_OPTCOM_CHECKONLY && inlen != 0)); error = icmp_do_opt_set(connp, level, name, inlen, invalp, outlenp, outvalp, cr, thisdg_attrs, checkonly); done: return (error); } /* This routine sets socket options. */ /* ARGSUSED */ int icmp_tpi_opt_set(queue_t *q, uint_t optset_context, int level, int name, uint_t inlen, uchar_t *invalp, uint_t *outlenp, uchar_t *outvalp, void *thisdg_attrs, cred_t *cr, mblk_t *mblk) { conn_t *connp = Q_TO_CONN(q); icmp_t *icmp; int error; icmp = connp->conn_icmp; rw_enter(&icmp->icmp_rwlock, RW_WRITER); error = icmp_opt_set(connp, optset_context, level, name, inlen, invalp, outlenp, outvalp, thisdg_attrs, cr); rw_exit(&icmp->icmp_rwlock); return (error); } /* * Update icmp_sticky_hdrs based on icmp_sticky_ipp, icmp_v6src, icmp_ttl, * icmp_proto, icmp_raw_checksum and icmp_no_tp_cksum. * The headers include ip6i_t (if needed), ip6_t, and any sticky extension * headers. * Returns failure if can't allocate memory. */ static int icmp_build_hdrs(icmp_t *icmp) { icmp_stack_t *is = icmp->icmp_is; uchar_t *hdrs; uint_t hdrs_len; ip6_t *ip6h; ip6i_t *ip6i; ip6_pkt_t *ipp = &icmp->icmp_sticky_ipp; ASSERT(RW_WRITE_HELD(&icmp->icmp_rwlock)); hdrs_len = ip_total_hdrs_len_v6(ipp); ASSERT(hdrs_len != 0); if (hdrs_len != icmp->icmp_sticky_hdrs_len) { /* Need to reallocate */ if (hdrs_len != 0) { hdrs = kmem_alloc(hdrs_len, KM_NOSLEEP); if (hdrs == NULL) return (ENOMEM); } else { hdrs = NULL; } if (icmp->icmp_sticky_hdrs_len != 0) { kmem_free(icmp->icmp_sticky_hdrs, icmp->icmp_sticky_hdrs_len); } icmp->icmp_sticky_hdrs = hdrs; icmp->icmp_sticky_hdrs_len = hdrs_len; } ip_build_hdrs_v6(icmp->icmp_sticky_hdrs, icmp->icmp_sticky_hdrs_len, ipp, icmp->icmp_proto); /* Set header fields not in ipp */ if (ipp->ipp_fields & IPPF_HAS_IP6I) { ip6i = (ip6i_t *)icmp->icmp_sticky_hdrs; ip6h = (ip6_t *)&ip6i[1]; if (ipp->ipp_fields & IPPF_RAW_CKSUM) { ip6i->ip6i_flags |= IP6I_RAW_CHECKSUM; ip6i->ip6i_checksum_off = icmp->icmp_checksum_off; } if (ipp->ipp_fields & IPPF_NO_CKSUM) { ip6i->ip6i_flags |= IP6I_NO_ULP_CKSUM; } } else { ip6h = (ip6_t *)icmp->icmp_sticky_hdrs; } if (!(ipp->ipp_fields & IPPF_ADDR)) ip6h->ip6_src = icmp->icmp_v6src; /* Try to get everything in a single mblk */ if (hdrs_len > icmp->icmp_max_hdr_len) { icmp->icmp_max_hdr_len = hdrs_len; rw_exit(&icmp->icmp_rwlock); (void) proto_set_tx_wroff(icmp->icmp_connp->conn_rq, icmp->icmp_connp, icmp->icmp_max_hdr_len + is->is_wroff_extra); rw_enter(&icmp->icmp_rwlock, RW_WRITER); } return (0); } /* * This routine retrieves the value of an ND variable in a icmpparam_t * structure. It is called through nd_getset when a user reads the * variable. */ /* ARGSUSED */ static int icmp_param_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr) { icmpparam_t *icmppa = (icmpparam_t *)cp; (void) mi_mpprintf(mp, "%d", icmppa->icmp_param_value); return (0); } /* * Walk through the param array specified registering each element with the * named dispatch (ND) handler. */ static boolean_t icmp_param_register(IDP *ndp, icmpparam_t *icmppa, int cnt) { for (; cnt-- > 0; icmppa++) { if (icmppa->icmp_param_name && icmppa->icmp_param_name[0]) { if (!nd_load(ndp, icmppa->icmp_param_name, icmp_param_get, icmp_param_set, (caddr_t)icmppa)) { nd_free(ndp); return (B_FALSE); } } } return (B_TRUE); } /* This routine sets an ND variable in a icmpparam_t structure. */ /* ARGSUSED */ static int icmp_param_set(queue_t *q, mblk_t *mp, char *value, caddr_t cp, cred_t *cr) { long new_value; icmpparam_t *icmppa = (icmpparam_t *)cp; /* * Fail the request if the new value does not lie within the * required bounds. */ if (ddi_strtol(value, NULL, 10, &new_value) != 0 || new_value < icmppa->icmp_param_min || new_value > icmppa->icmp_param_max) { return (EINVAL); } /* Set the new value */ icmppa->icmp_param_value = new_value; return (0); } static mblk_t * icmp_queue_fallback(icmp_t *icmp, mblk_t *mp) { ASSERT(MUTEX_HELD(&icmp->icmp_recv_lock)); if (IPCL_IS_NONSTR(icmp->icmp_connp)) { /* * fallback has started but messages have not been moved yet */ if (icmp->icmp_fallback_queue_head == NULL) { ASSERT(icmp->icmp_fallback_queue_tail == NULL); icmp->icmp_fallback_queue_head = mp; icmp->icmp_fallback_queue_tail = mp; } else { ASSERT(icmp->icmp_fallback_queue_tail != NULL); icmp->icmp_fallback_queue_tail->b_next = mp; icmp->icmp_fallback_queue_tail = mp; } return (NULL); } else { /* * Fallback completed, let the caller putnext() the mblk. */ return (mp); } } /* * Deliver data to ULP. In case we have a socket, and it's falling back to * TPI, then we'll queue the mp for later processing. */ static void icmp_ulp_recv(conn_t *connp, mblk_t *mp) { if (IPCL_IS_NONSTR(connp)) { icmp_t *icmp = connp->conn_icmp; int error; if ((*connp->conn_upcalls->su_recv) (connp->conn_upper_handle, mp, msgdsize(mp), 0, &error, NULL) < 0) { mutex_enter(&icmp->icmp_recv_lock); if (error == ENOSPC) { /* * let's confirm while holding the lock */ if ((*connp->conn_upcalls->su_recv) (connp->conn_upper_handle, NULL, 0, 0, &error, NULL) < 0) { ASSERT(error == ENOSPC); if (error == ENOSPC) { connp->conn_flow_cntrld = B_TRUE; } } mutex_exit(&icmp->icmp_recv_lock); } else { ASSERT(error == EOPNOTSUPP); mp = icmp_queue_fallback(icmp, mp); mutex_exit(&icmp->icmp_recv_lock); if (mp != NULL) putnext(connp->conn_rq, mp); } } ASSERT(MUTEX_NOT_HELD(&icmp->icmp_recv_lock)); } else { putnext(connp->conn_rq, mp); } } /*ARGSUSED2*/ static void icmp_input(void *arg1, mblk_t *mp, void *arg2) { conn_t *connp = (conn_t *)arg1; struct T_unitdata_ind *tudi; uchar_t *rptr; icmp_t *icmp; icmp_stack_t *is; sin_t *sin; sin6_t *sin6; ip6_t *ip6h; ip6i_t *ip6i; mblk_t *mp1; int hdr_len; ipha_t *ipha; int udi_size; /* Size of T_unitdata_ind */ uint_t ipvers; ip6_pkt_t ipp; uint8_t nexthdr; ip_pktinfo_t *pinfo = NULL; mblk_t *options_mp = NULL; uint_t icmp_opt = 0; boolean_t icmp_ipv6_recvhoplimit = B_FALSE; uint_t hopstrip; ASSERT(connp->conn_flags & IPCL_RAWIPCONN); icmp = connp->conn_icmp; is = icmp->icmp_is; rptr = mp->b_rptr; ASSERT(DB_TYPE(mp) == M_DATA || DB_TYPE(mp) == M_CTL); ASSERT(OK_32PTR(rptr)); /* * IP should have prepended the options data in an M_CTL * Check M_CTL "type" to make sure are not here bcos of * a valid ICMP message */ if (DB_TYPE(mp) == M_CTL) { /* * FIXME: does IP still do this? * IP sends up the IPSEC_IN message for handling IPSEC * policy at the TCP level. We don't need it here. */ if (*(uint32_t *)(mp->b_rptr) == IPSEC_IN) { mp1 = mp->b_cont; freeb(mp); mp = mp1; rptr = mp->b_rptr; } else if (MBLKL(mp) == sizeof (ip_pktinfo_t) && ((ip_pktinfo_t *)mp->b_rptr)->ip_pkt_ulp_type == IN_PKTINFO) { /* * IP_RECVIF or IP_RECVSLLA or IPF_RECVADDR information * has been prepended to the packet by IP. We need to * extract the mblk and adjust the rptr */ pinfo = (ip_pktinfo_t *)mp->b_rptr; options_mp = mp; mp = mp->b_cont; rptr = mp->b_rptr; } else { /* * ICMP messages. */ icmp_icmp_error(connp, mp); return; } } /* * Discard message if it is misaligned or smaller than the IP header. */ if (!OK_32PTR(rptr) || (mp->b_wptr - rptr) < sizeof (ipha_t)) { freemsg(mp); if (options_mp != NULL) freeb(options_mp); BUMP_MIB(&is->is_rawip_mib, rawipInErrors); return; } ipvers = IPH_HDR_VERSION((ipha_t *)rptr); /* Handle M_DATA messages containing IP packets messages */ if (ipvers == IPV4_VERSION) { /* * Special case where IP attaches * the IRE needs to be handled so that we don't send up * IRE to the user land. */ ipha = (ipha_t *)rptr; hdr_len = IPH_HDR_LENGTH(ipha); if (ipha->ipha_protocol == IPPROTO_TCP) { tcph_t *tcph = (tcph_t *)&mp->b_rptr[hdr_len]; if (((tcph->th_flags[0] & (TH_SYN|TH_ACK)) == TH_SYN) && mp->b_cont != NULL) { mp1 = mp->b_cont; if (mp1->b_datap->db_type == IRE_DB_TYPE) { freeb(mp1); mp->b_cont = NULL; } } } if (is->is_bsd_compat) { ushort_t len; len = ntohs(ipha->ipha_length); if (mp->b_datap->db_ref > 1) { /* * Allocate a new IP header so that we can * modify ipha_length. */ mblk_t *mp1; mp1 = allocb(hdr_len, BPRI_MED); if (!mp1) { freemsg(mp); if (options_mp != NULL) freeb(options_mp); BUMP_MIB(&is->is_rawip_mib, rawipInErrors); return; } bcopy(rptr, mp1->b_rptr, hdr_len); mp->b_rptr = rptr + hdr_len; rptr = mp1->b_rptr; ipha = (ipha_t *)rptr; mp1->b_cont = mp; mp1->b_wptr = rptr + hdr_len; mp = mp1; } len -= hdr_len; ipha->ipha_length = htons(len); } } /* * This is the inbound data path. Packets are passed upstream as * T_UNITDATA_IND messages with full IP headers still attached. */ if (icmp->icmp_family == AF_INET) { ASSERT(ipvers == IPV4_VERSION); udi_size = sizeof (struct T_unitdata_ind) + sizeof (sin_t); if (icmp->icmp_recvif && (pinfo != NULL) && (pinfo->ip_pkt_flags & IPF_RECVIF)) { udi_size += sizeof (struct T_opthdr) + sizeof (uint_t); } if (icmp->icmp_ip_recvpktinfo && (pinfo != NULL) && (pinfo->ip_pkt_flags & IPF_RECVADDR)) { udi_size += sizeof (struct T_opthdr) + sizeof (struct in_pktinfo); } /* * If SO_TIMESTAMP is set allocate the appropriate sized * buffer. Since gethrestime() expects a pointer aligned * argument, we allocate space necessary for extra * alignment (even though it might not be used). */ if (icmp->icmp_timestamp) { udi_size += sizeof (struct T_opthdr) + sizeof (timestruc_t) + _POINTER_ALIGNMENT; } mp1 = allocb(udi_size, BPRI_MED); if (mp1 == NULL) { freemsg(mp); if (options_mp != NULL) freeb(options_mp); BUMP_MIB(&is->is_rawip_mib, rawipInErrors); return; } mp1->b_cont = mp; mp = mp1; tudi = (struct T_unitdata_ind *)mp->b_rptr; mp->b_datap->db_type = M_PROTO; mp->b_wptr = (uchar_t *)tudi + udi_size; tudi->PRIM_type = T_UNITDATA_IND; tudi->SRC_length = sizeof (sin_t); tudi->SRC_offset = sizeof (struct T_unitdata_ind); sin = (sin_t *)&tudi[1]; *sin = sin_null; sin->sin_family = AF_INET; sin->sin_addr.s_addr = ipha->ipha_src; tudi->OPT_offset = sizeof (struct T_unitdata_ind) + sizeof (sin_t); udi_size -= (sizeof (struct T_unitdata_ind) + sizeof (sin_t)); tudi->OPT_length = udi_size; /* * Add options if IP_RECVIF is set */ if (udi_size != 0) { char *dstopt; dstopt = (char *)&sin[1]; if (icmp->icmp_recvif && (pinfo != NULL) && (pinfo->ip_pkt_flags & IPF_RECVIF)) { struct T_opthdr *toh; uint_t *dstptr; toh = (struct T_opthdr *)dstopt; toh->level = IPPROTO_IP; toh->name = IP_RECVIF; toh->len = sizeof (struct T_opthdr) + sizeof (uint_t); toh->status = 0; dstopt += sizeof (struct T_opthdr); dstptr = (uint_t *)dstopt; *dstptr = pinfo->ip_pkt_ifindex; dstopt += sizeof (uint_t); udi_size -= toh->len; } if (icmp->icmp_timestamp) { struct T_opthdr *toh; toh = (struct T_opthdr *)dstopt; toh->level = SOL_SOCKET; toh->name = SCM_TIMESTAMP; toh->len = sizeof (struct T_opthdr) + sizeof (timestruc_t) + _POINTER_ALIGNMENT; toh->status = 0; dstopt += sizeof (struct T_opthdr); /* Align for gethrestime() */ dstopt = (char *)P2ROUNDUP((intptr_t)dstopt, sizeof (intptr_t)); gethrestime((timestruc_t *)dstopt); dstopt = (char *)toh + toh->len; udi_size -= toh->len; } if (icmp->icmp_ip_recvpktinfo && (pinfo != NULL) && (pinfo->ip_pkt_flags & IPF_RECVADDR)) { struct T_opthdr *toh; struct in_pktinfo *pktinfop; toh = (struct T_opthdr *)dstopt; toh->level = IPPROTO_IP; toh->name = IP_PKTINFO; toh->len = sizeof (struct T_opthdr) + sizeof (in_pktinfo_t); toh->status = 0; dstopt += sizeof (struct T_opthdr); pktinfop = (struct in_pktinfo *)dstopt; pktinfop->ipi_ifindex = pinfo->ip_pkt_ifindex; pktinfop->ipi_spec_dst = pinfo->ip_pkt_match_addr; pktinfop->ipi_addr.s_addr = ipha->ipha_dst; dstopt += sizeof (struct in_pktinfo); udi_size -= toh->len; } /* Consumed all of allocated space */ ASSERT(udi_size == 0); } if (options_mp != NULL) freeb(options_mp); BUMP_MIB(&is->is_rawip_mib, rawipInDatagrams); goto deliver; } /* * We don't need options_mp in the IPv6 path. */ if (options_mp != NULL) { freeb(options_mp); options_mp = NULL; } /* * Discard message if it is smaller than the IPv6 header * or if the header is malformed. */ if ((mp->b_wptr - rptr) < sizeof (ip6_t) || IPH_HDR_VERSION((ipha_t *)rptr) != IPV6_VERSION || icmp->icmp_family != AF_INET6) { freemsg(mp); BUMP_MIB(&is->is_rawip_mib, rawipInErrors); return; } /* Initialize */ ipp.ipp_fields = 0; hopstrip = 0; ip6h = (ip6_t *)rptr; /* * Call on ip_find_hdr_v6 which gets the total hdr len * as well as individual lenghts of ext hdrs (and ptrs to * them). */ if (ip6h->ip6_nxt != icmp->icmp_proto) { /* Look for ifindex information */ if (ip6h->ip6_nxt == IPPROTO_RAW) { ip6i = (ip6i_t *)ip6h; if (ip6i->ip6i_flags & IP6I_IFINDEX) { ASSERT(ip6i->ip6i_ifindex != 0); ipp.ipp_fields |= IPPF_IFINDEX; ipp.ipp_ifindex = ip6i->ip6i_ifindex; } rptr = (uchar_t *)&ip6i[1]; mp->b_rptr = rptr; if (rptr == mp->b_wptr) { mp1 = mp->b_cont; freeb(mp); mp = mp1; rptr = mp->b_rptr; } ASSERT(mp->b_wptr - rptr >= IPV6_HDR_LEN); ip6h = (ip6_t *)rptr; } hdr_len = ip_find_hdr_v6(mp, ip6h, &ipp, &nexthdr); /* * We need to lie a bit to the user because users inside * labeled compartments should not see their own labels. We * assume that in all other respects IP has checked the label, * and that the label is always first among the options. (If * it's not first, then this code won't see it, and the option * will be passed along to the user.) * * If we had multilevel ICMP sockets, then the following code * should be skipped for them to allow the user to see the * label. * * Alignment restrictions in the definition of IP options * (namely, the requirement that the 4-octet DOI goes on a * 4-octet boundary) mean that we know exactly where the option * should start, but we're lenient for other hosts. * * Note that there are no multilevel ICMP or raw IP sockets * yet, thus nobody ever sees the IP6OPT_LS option. */ if ((ipp.ipp_fields & IPPF_HOPOPTS) && ipp.ipp_hopoptslen > 5 && is_system_labeled()) { const uchar_t *ucp = (const uchar_t *)ipp.ipp_hopopts + 2; int remlen = ipp.ipp_hopoptslen - 2; while (remlen > 0) { if (*ucp == IP6OPT_PAD1) { remlen--; ucp++; } else if (*ucp == IP6OPT_PADN) { remlen -= ucp[1] + 2; ucp += ucp[1] + 2; } else if (*ucp == ip6opt_ls) { hopstrip = (ucp - (const uchar_t *)ipp.ipp_hopopts) + ucp[1] + 2; hopstrip = (hopstrip + 7) & ~7; break; } else { /* label option must be first */ break; } } } } else { hdr_len = IPV6_HDR_LEN; ip6i = NULL; nexthdr = ip6h->ip6_nxt; } /* * One special case where IP attaches the IRE needs to * be handled so that we don't send up IRE to the user land. */ if (nexthdr == IPPROTO_TCP) { tcph_t *tcph = (tcph_t *)&mp->b_rptr[hdr_len]; if (((tcph->th_flags[0] & (TH_SYN|TH_ACK)) == TH_SYN) && mp->b_cont != NULL) { mp1 = mp->b_cont; if (mp1->b_datap->db_type == IRE_DB_TYPE) { freeb(mp1); mp->b_cont = NULL; } } } /* * Check a filter for ICMPv6 types if needed. * Verify raw checksums if needed. */ if (icmp->icmp_filter != NULL || icmp->icmp_raw_checksum) { if (icmp->icmp_filter != NULL) { int type; /* Assumes that IP has done the pullupmsg */ type = mp->b_rptr[hdr_len]; ASSERT(mp->b_rptr + hdr_len <= mp->b_wptr); if (ICMP6_FILTER_WILLBLOCK(type, icmp->icmp_filter)) { freemsg(mp); return; } } else { /* Checksum */ uint16_t *up; uint32_t sum; int remlen; up = (uint16_t *)&ip6h->ip6_src; remlen = msgdsize(mp) - hdr_len; sum = htons(icmp->icmp_proto + remlen) + up[0] + up[1] + up[2] + up[3] + up[4] + up[5] + up[6] + up[7] + up[8] + up[9] + up[10] + up[11] + up[12] + up[13] + up[14] + up[15]; sum = (sum & 0xffff) + (sum >> 16); sum = IP_CSUM(mp, hdr_len, sum); if (sum != 0) { /* IPv6 RAW checksum failed */ ip0dbg(("icmp_rput: RAW checksum " "failed %x\n", sum)); freemsg(mp); BUMP_MIB(&is->is_rawip_mib, rawipInCksumErrs); return; } } } /* Skip all the IPv6 headers per API */ mp->b_rptr += hdr_len; udi_size = sizeof (struct T_unitdata_ind) + sizeof (sin6_t); /* * We use local variables icmp_opt and icmp_ipv6_recvhoplimit to * maintain state information, instead of relying on icmp_t * structure, since there arent any locks protecting these members * and there is a window where there might be a race between a * thread setting options on the write side and a thread reading * these options on the read size. */ if (ipp.ipp_fields & (IPPF_HOPOPTS|IPPF_DSTOPTS|IPPF_RTDSTOPTS| IPPF_RTHDR|IPPF_IFINDEX)) { if (icmp->icmp_ipv6_recvhopopts && (ipp.ipp_fields & IPPF_HOPOPTS) && ipp.ipp_hopoptslen > hopstrip) { udi_size += sizeof (struct T_opthdr) + ipp.ipp_hopoptslen - hopstrip; icmp_opt |= IPPF_HOPOPTS; } if ((icmp->icmp_ipv6_recvdstopts || icmp->icmp_old_ipv6_recvdstopts) && (ipp.ipp_fields & IPPF_DSTOPTS)) { udi_size += sizeof (struct T_opthdr) + ipp.ipp_dstoptslen; icmp_opt |= IPPF_DSTOPTS; } if (((icmp->icmp_ipv6_recvdstopts && icmp->icmp_ipv6_recvrthdr && (ipp.ipp_fields & IPPF_RTHDR)) || icmp->icmp_ipv6_recvrtdstopts) && (ipp.ipp_fields & IPPF_RTDSTOPTS)) { udi_size += sizeof (struct T_opthdr) + ipp.ipp_rtdstoptslen; icmp_opt |= IPPF_RTDSTOPTS; } if (icmp->icmp_ipv6_recvrthdr && (ipp.ipp_fields & IPPF_RTHDR)) { udi_size += sizeof (struct T_opthdr) + ipp.ipp_rthdrlen; icmp_opt |= IPPF_RTHDR; } if (icmp->icmp_ip_recvpktinfo && (ipp.ipp_fields & IPPF_IFINDEX)) { udi_size += sizeof (struct T_opthdr) + sizeof (struct in6_pktinfo); icmp_opt |= IPPF_IFINDEX; } } if (icmp->icmp_ipv6_recvhoplimit) { udi_size += sizeof (struct T_opthdr) + sizeof (int); icmp_ipv6_recvhoplimit = B_TRUE; } if (icmp->icmp_ipv6_recvtclass) udi_size += sizeof (struct T_opthdr) + sizeof (int); /* * If SO_TIMESTAMP is set allocate the appropriate sized * buffer. Since gethrestime() expects a pointer aligned * argument, we allocate space necessary for extra * alignment (even though it might not be used). */ if (icmp->icmp_timestamp) { udi_size += sizeof (struct T_opthdr) + sizeof (timestruc_t) + _POINTER_ALIGNMENT; } mp1 = allocb(udi_size, BPRI_MED); if (mp1 == NULL) { freemsg(mp); BUMP_MIB(&is->is_rawip_mib, rawipInErrors); return; } mp1->b_cont = mp; mp = mp1; mp->b_datap->db_type = M_PROTO; tudi = (struct T_unitdata_ind *)mp->b_rptr; mp->b_wptr = (uchar_t *)tudi + udi_size; tudi->PRIM_type = T_UNITDATA_IND; tudi->SRC_length = sizeof (sin6_t); tudi->SRC_offset = sizeof (struct T_unitdata_ind); tudi->OPT_offset = sizeof (struct T_unitdata_ind) + sizeof (sin6_t); udi_size -= (sizeof (struct T_unitdata_ind) + sizeof (sin6_t)); tudi->OPT_length = udi_size; sin6 = (sin6_t *)&tudi[1]; sin6->sin6_port = 0; sin6->sin6_family = AF_INET6; sin6->sin6_addr = ip6h->ip6_src; /* No sin6_flowinfo per API */ sin6->sin6_flowinfo = 0; /* For link-scope source pass up scope id */ if ((ipp.ipp_fields & IPPF_IFINDEX) && IN6_IS_ADDR_LINKSCOPE(&ip6h->ip6_src)) sin6->sin6_scope_id = ipp.ipp_ifindex; else sin6->sin6_scope_id = 0; sin6->__sin6_src_id = ip_srcid_find_addr(&ip6h->ip6_dst, icmp->icmp_zoneid, is->is_netstack); if (udi_size != 0) { uchar_t *dstopt; dstopt = (uchar_t *)&sin6[1]; if (icmp_opt & IPPF_IFINDEX) { struct T_opthdr *toh; struct in6_pktinfo *pkti; toh = (struct T_opthdr *)dstopt; toh->level = IPPROTO_IPV6; toh->name = IPV6_PKTINFO; toh->len = sizeof (struct T_opthdr) + sizeof (*pkti); toh->status = 0; dstopt += sizeof (struct T_opthdr); pkti = (struct in6_pktinfo *)dstopt; pkti->ipi6_addr = ip6h->ip6_dst; pkti->ipi6_ifindex = ipp.ipp_ifindex; dstopt += sizeof (*pkti); udi_size -= toh->len; } if (icmp_ipv6_recvhoplimit) { struct T_opthdr *toh; toh = (struct T_opthdr *)dstopt; toh->level = IPPROTO_IPV6; toh->name = IPV6_HOPLIMIT; toh->len = sizeof (struct T_opthdr) + sizeof (uint_t); toh->status = 0; dstopt += sizeof (struct T_opthdr); *(uint_t *)dstopt = ip6h->ip6_hops; dstopt += sizeof (uint_t); udi_size -= toh->len; } if (icmp->icmp_ipv6_recvtclass) { struct T_opthdr *toh; toh = (struct T_opthdr *)dstopt; toh->level = IPPROTO_IPV6; toh->name = IPV6_TCLASS; toh->len = sizeof (struct T_opthdr) + sizeof (uint_t); toh->status = 0; dstopt += sizeof (struct T_opthdr); *(uint_t *)dstopt = IPV6_FLOW_TCLASS(ip6h->ip6_flow); dstopt += sizeof (uint_t); udi_size -= toh->len; } if (icmp->icmp_timestamp) { struct T_opthdr *toh; toh = (struct T_opthdr *)dstopt; toh->level = SOL_SOCKET; toh->name = SCM_TIMESTAMP; toh->len = sizeof (struct T_opthdr) + sizeof (timestruc_t) + _POINTER_ALIGNMENT; toh->status = 0; dstopt += sizeof (struct T_opthdr); /* Align for gethrestime() */ dstopt = (uchar_t *)P2ROUNDUP((intptr_t)dstopt, sizeof (intptr_t)); gethrestime((timestruc_t *)dstopt); dstopt = (uchar_t *)toh + toh->len; udi_size -= toh->len; } if (icmp_opt & IPPF_HOPOPTS) { struct T_opthdr *toh; toh = (struct T_opthdr *)dstopt; toh->level = IPPROTO_IPV6; toh->name = IPV6_HOPOPTS; toh->len = sizeof (struct T_opthdr) + ipp.ipp_hopoptslen - hopstrip; toh->status = 0; dstopt += sizeof (struct T_opthdr); bcopy((char *)ipp.ipp_hopopts + hopstrip, dstopt, ipp.ipp_hopoptslen - hopstrip); if (hopstrip > 0) { /* copy next header value and fake length */ dstopt[0] = ((uchar_t *)ipp.ipp_hopopts)[0]; dstopt[1] = ((uchar_t *)ipp.ipp_hopopts)[1] - hopstrip / 8; } dstopt += ipp.ipp_hopoptslen - hopstrip; udi_size -= toh->len; } if (icmp_opt & IPPF_RTDSTOPTS) { struct T_opthdr *toh; toh = (struct T_opthdr *)dstopt; toh->level = IPPROTO_IPV6; toh->name = IPV6_DSTOPTS; toh->len = sizeof (struct T_opthdr) + ipp.ipp_rtdstoptslen; toh->status = 0; dstopt += sizeof (struct T_opthdr); bcopy(ipp.ipp_rtdstopts, dstopt, ipp.ipp_rtdstoptslen); dstopt += ipp.ipp_rtdstoptslen; udi_size -= toh->len; } if (icmp_opt & IPPF_RTHDR) { struct T_opthdr *toh; toh = (struct T_opthdr *)dstopt; toh->level = IPPROTO_IPV6; toh->name = IPV6_RTHDR; toh->len = sizeof (struct T_opthdr) + ipp.ipp_rthdrlen; toh->status = 0; dstopt += sizeof (struct T_opthdr); bcopy(ipp.ipp_rthdr, dstopt, ipp.ipp_rthdrlen); dstopt += ipp.ipp_rthdrlen; udi_size -= toh->len; } if (icmp_opt & IPPF_DSTOPTS) { struct T_opthdr *toh; toh = (struct T_opthdr *)dstopt; toh->level = IPPROTO_IPV6; toh->name = IPV6_DSTOPTS; toh->len = sizeof (struct T_opthdr) + ipp.ipp_dstoptslen; toh->status = 0; dstopt += sizeof (struct T_opthdr); bcopy(ipp.ipp_dstopts, dstopt, ipp.ipp_dstoptslen); dstopt += ipp.ipp_dstoptslen; udi_size -= toh->len; } /* Consumed all of allocated space */ ASSERT(udi_size == 0); } BUMP_MIB(&is->is_rawip_mib, rawipInDatagrams); deliver: icmp_ulp_recv(connp, mp); } /* * return SNMP stuff in buffer in mpdata */ mblk_t * icmp_snmp_get(queue_t *q, mblk_t *mpctl) { mblk_t *mpdata; struct opthdr *optp; conn_t *connp = Q_TO_CONN(q); icmp_stack_t *is = connp->conn_netstack->netstack_icmp; mblk_t *mp2ctl; /* * make a copy of the original message */ mp2ctl = copymsg(mpctl); if (mpctl == NULL || (mpdata = mpctl->b_cont) == NULL) { freemsg(mpctl); freemsg(mp2ctl); return (0); } /* fixed length structure for IPv4 and IPv6 counters */ optp = (struct opthdr *)&mpctl->b_rptr[sizeof (struct T_optmgmt_ack)]; optp->level = EXPER_RAWIP; optp->name = 0; (void) snmp_append_data(mpdata, (char *)&is->is_rawip_mib, sizeof (is->is_rawip_mib)); optp->len = msgdsize(mpdata); qreply(q, mpctl); return (mp2ctl); } /* * Return 0 if invalid set request, 1 otherwise, including non-rawip requests. * TODO: If this ever actually tries to set anything, it needs to be * to do the appropriate locking. */ /* ARGSUSED */ int icmp_snmp_set(queue_t *q, t_scalar_t level, t_scalar_t name, uchar_t *ptr, int len) { switch (level) { case EXPER_RAWIP: return (0); default: return (1); } } /* * This routine creates a T_UDERROR_IND message and passes it upstream. * The address and options are copied from the T_UNITDATA_REQ message * passed in mp. This message is freed. */ static void icmp_ud_err(queue_t *q, mblk_t *mp, t_scalar_t err) { mblk_t *mp1; uchar_t *rptr = mp->b_rptr; struct T_unitdata_req *tudr = (struct T_unitdata_req *)rptr; mp1 = mi_tpi_uderror_ind((char *)&rptr[tudr->DEST_offset], tudr->DEST_length, (char *)&rptr[tudr->OPT_offset], tudr->OPT_length, err); if (mp1) qreply(q, mp1); freemsg(mp); } static int rawip_do_unbind(conn_t *connp) { icmp_t *icmp = connp->conn_icmp; rw_enter(&icmp->icmp_rwlock, RW_WRITER); /* If a bind has not been done, we can't unbind. */ if (icmp->icmp_state == TS_UNBND || icmp->icmp_pending_op != -1) { rw_exit(&icmp->icmp_rwlock); return (-TOUTSTATE); } icmp->icmp_pending_op = T_UNBIND_REQ; rw_exit(&icmp->icmp_rwlock); /* * Call ip to unbind */ ip_unbind(connp); /* * Once we're unbound from IP, the pending operation may be cleared * here. */ rw_enter(&icmp->icmp_rwlock, RW_WRITER); V6_SET_ZERO(icmp->icmp_v6src); V6_SET_ZERO(icmp->icmp_bound_v6src); icmp->icmp_pending_op = -1; icmp->icmp_state = TS_UNBND; if (icmp->icmp_family == AF_INET6) (void) icmp_build_hdrs(icmp); rw_exit(&icmp->icmp_rwlock); return (0); } /* * This routine is called by icmp_wput to handle T_UNBIND_REQ messages. * After some error checking, the message is passed downstream to ip. */ static void icmp_tpi_unbind(queue_t *q, mblk_t *mp) { conn_t *connp = Q_TO_CONN(q); int error; ASSERT(mp->b_cont == NULL); error = rawip_do_unbind(connp); if (error) { if (error < 0) { icmp_err_ack(q, mp, -error, 0); } else { icmp_err_ack(q, mp, 0, error); } return; } /* * Convert mp into a T_OK_ACK */ mp = mi_tpi_ok_ack_alloc(mp); /* * should not happen in practice... T_OK_ACK is smaller than the * original message. */ ASSERT(mp != NULL); ASSERT(((struct T_ok_ack *)mp->b_rptr)->PRIM_type == T_OK_ACK); qreply(q, mp); } /* * Process IPv4 packets that already include an IP header. * Used when IP_HDRINCL has been set (implicit for IPPROTO_RAW and * IPPROTO_IGMP). */ static int icmp_wput_hdrincl(queue_t *q, conn_t *connp, mblk_t *mp, icmp_t *icmp, ip4_pkt_t *pktinfop) { icmp_stack_t *is = icmp->icmp_is; ipha_t *ipha; int ip_hdr_length; int tp_hdr_len; mblk_t *mp1; uint_t pkt_len; ip_opt_info_t optinfo; optinfo.ip_opt_flags = 0; optinfo.ip_opt_ill_index = 0; ipha = (ipha_t *)mp->b_rptr; ip_hdr_length = IP_SIMPLE_HDR_LENGTH + icmp->icmp_ip_snd_options_len; if ((mp->b_wptr - mp->b_rptr) < IP_SIMPLE_HDR_LENGTH) { if (!pullupmsg(mp, IP_SIMPLE_HDR_LENGTH)) { ASSERT(icmp != NULL); BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); freemsg(mp); return (0); } ipha = (ipha_t *)mp->b_rptr; } ipha->ipha_version_and_hdr_length = (IP_VERSION<<4) | (ip_hdr_length>>2); /* * For the socket of SOCK_RAW type, the checksum is provided in the * pre-built packet. We set the ipha_ident field to IP_HDR_INCLUDED to * tell IP that the application has sent a complete IP header and not * to compute the transport checksum nor change the DF flag. */ ipha->ipha_ident = IP_HDR_INCLUDED; ipha->ipha_hdr_checksum = 0; ipha->ipha_fragment_offset_and_flags &= htons(IPH_DF); /* Insert options if any */ if (ip_hdr_length > IP_SIMPLE_HDR_LENGTH) { /* * Put the IP header plus any transport header that is * checksumed by ip_wput into the first mblk. (ip_wput assumes * that at least the checksum field is in the first mblk.) */ switch (ipha->ipha_protocol) { case IPPROTO_UDP: tp_hdr_len = 8; break; case IPPROTO_TCP: tp_hdr_len = 20; break; default: tp_hdr_len = 0; break; } /* * The code below assumes that IP_SIMPLE_HDR_LENGTH plus * tp_hdr_len bytes will be in a single mblk. */ if ((mp->b_wptr - mp->b_rptr) < (IP_SIMPLE_HDR_LENGTH + tp_hdr_len)) { if (!pullupmsg(mp, IP_SIMPLE_HDR_LENGTH + tp_hdr_len)) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); freemsg(mp); return (0); } ipha = (ipha_t *)mp->b_rptr; } /* * if the length is larger then the max allowed IP packet, * then send an error and abort the processing. */ pkt_len = ntohs(ipha->ipha_length) + icmp->icmp_ip_snd_options_len; if (pkt_len > IP_MAXPACKET) { return (EMSGSIZE); } if (!(mp1 = allocb(ip_hdr_length + is->is_wroff_extra + tp_hdr_len, BPRI_LO))) { return (ENOMEM); } mp1->b_rptr += is->is_wroff_extra; mp1->b_wptr = mp1->b_rptr + ip_hdr_length; ipha->ipha_length = htons((uint16_t)pkt_len); bcopy(ipha, mp1->b_rptr, IP_SIMPLE_HDR_LENGTH); /* Copy transport header if any */ bcopy(&ipha[1], mp1->b_wptr, tp_hdr_len); mp1->b_wptr += tp_hdr_len; /* Add options */ ipha = (ipha_t *)mp1->b_rptr; bcopy(icmp->icmp_ip_snd_options, &ipha[1], icmp->icmp_ip_snd_options_len); /* Drop IP header and transport header from original */ (void) adjmsg(mp, IP_SIMPLE_HDR_LENGTH + tp_hdr_len); mp1->b_cont = mp; mp = mp1; /* * Massage source route putting first source * route in ipha_dst. */ (void) ip_massage_options(ipha, is->is_netstack); } if (pktinfop != NULL) { /* * Over write the source address provided in the header */ if (pktinfop->ip4_addr != INADDR_ANY) { ipha->ipha_src = pktinfop->ip4_addr; optinfo.ip_opt_flags = IP_VERIFY_SRC; } if (pktinfop->ip4_ill_index != 0) { optinfo.ip_opt_ill_index = pktinfop->ip4_ill_index; } } ip_output_options(connp, mp, q, IP_WPUT, &optinfo); return (0); } static int icmp_update_label(icmp_t *icmp, mblk_t *mp, ipaddr_t dst) { int err; uchar_t opt_storage[IP_MAX_OPT_LENGTH]; icmp_stack_t *is = icmp->icmp_is; conn_t *connp = icmp->icmp_connp; cred_t *cr; /* * All Solaris components should pass a db_credp * for this message, hence we ASSERT. * On production kernels we return an error to be robust against * random streams modules sitting on top of us. */ cr = msg_getcred(mp, NULL); ASSERT(cr != NULL); if (cr == NULL) return (EINVAL); err = tsol_compute_label(cr, dst, opt_storage, connp->conn_mac_exempt, is->is_netstack->netstack_ip); if (err == 0) { err = tsol_update_options(&icmp->icmp_ip_snd_options, &icmp->icmp_ip_snd_options_len, &icmp->icmp_label_len, opt_storage); } if (err != 0) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); DTRACE_PROBE4( tx__ip__log__drop__updatelabel__icmp, char *, "icmp(1) failed to update options(2) on mp(3)", icmp_t *, icmp, char *, opt_storage, mblk_t *, mp); return (err); } IN6_IPADDR_TO_V4MAPPED(dst, &icmp->icmp_v6lastdst); return (0); } /* * This routine handles all messages passed downstream. It either * consumes the message or passes it downstream; it never queues a * a message. */ static void icmp_wput(queue_t *q, mblk_t *mp) { uchar_t *rptr = mp->b_rptr; ipha_t *ipha; mblk_t *mp1; #define tudr ((struct T_unitdata_req *)rptr) size_t ip_len; conn_t *connp = Q_TO_CONN(q); icmp_t *icmp = connp->conn_icmp; icmp_stack_t *is = icmp->icmp_is; sin6_t *sin6; sin_t *sin; ipaddr_t v4dst; ip4_pkt_t pktinfo; ip4_pkt_t *pktinfop = &pktinfo; ip6_pkt_t ipp_s; /* For ancillary data options */ ip6_pkt_t *ipp = &ipp_s; int error; ipp->ipp_fields = 0; ipp->ipp_sticky_ignored = 0; switch (mp->b_datap->db_type) { case M_DATA: if (icmp->icmp_hdrincl) { ASSERT(icmp->icmp_ipversion == IPV4_VERSION); ipha = (ipha_t *)mp->b_rptr; if (mp->b_wptr - mp->b_rptr < IP_SIMPLE_HDR_LENGTH) { if (!pullupmsg(mp, IP_SIMPLE_HDR_LENGTH)) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); freemsg(mp); return; } ipha = (ipha_t *)mp->b_rptr; } /* * If this connection was used for v6 (inconceivable!) * or if we have a new destination, then it's time to * figure a new label. */ if (is_system_labeled() && (!IN6_IS_ADDR_V4MAPPED(&icmp->icmp_v6lastdst) || V4_PART_OF_V6(icmp->icmp_v6lastdst) != ipha->ipha_dst)) { error = icmp_update_label(icmp, mp, ipha->ipha_dst); if (error != 0) { icmp_ud_err(q, mp, error); return; } } error = icmp_wput_hdrincl(q, connp, mp, icmp, NULL); if (error != 0) icmp_ud_err(q, mp, error); return; } freemsg(mp); return; case M_PROTO: case M_PCPROTO: ip_len = mp->b_wptr - rptr; if (ip_len >= sizeof (struct T_unitdata_req)) { /* Expedite valid T_UNITDATA_REQ to below the switch */ if (((union T_primitives *)rptr)->type == T_UNITDATA_REQ) break; } /* FALLTHRU */ default: icmp_wput_other(q, mp); return; } /* Handle T_UNITDATA_REQ messages here. */ mp1 = mp->b_cont; if (mp1 == NULL) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); icmp_ud_err(q, mp, EPROTO); return; } if ((rptr + tudr->DEST_offset + tudr->DEST_length) > mp->b_wptr) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); icmp_ud_err(q, mp, EADDRNOTAVAIL); return; } switch (icmp->icmp_family) { case AF_INET6: sin6 = (sin6_t *)&rptr[tudr->DEST_offset]; if (!OK_32PTR((char *)sin6) || tudr->DEST_length != sizeof (sin6_t) || sin6->sin6_family != AF_INET6) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); icmp_ud_err(q, mp, EADDRNOTAVAIL); return; } /* No support for mapped addresses on raw sockets */ if (IN6_IS_ADDR_V4MAPPED(&sin6->sin6_addr)) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); icmp_ud_err(q, mp, EADDRNOTAVAIL); return; } /* * Destination is a native IPv6 address. * Send out an IPv6 format packet. */ if (tudr->OPT_length != 0) { int error; error = 0; if (icmp_unitdata_opt_process(q, mp, &error, (void *)ipp) < 0) { /* failure */ BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); icmp_ud_err(q, mp, error); return; } ASSERT(error == 0); } error = raw_ip_send_data_v6(q, connp, mp1, sin6, ipp); goto done; case AF_INET: sin = (sin_t *)&rptr[tudr->DEST_offset]; if (!OK_32PTR((char *)sin) || tudr->DEST_length != sizeof (sin_t) || sin->sin_family != AF_INET) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); icmp_ud_err(q, mp, EADDRNOTAVAIL); return; } /* Extract and ipaddr */ v4dst = sin->sin_addr.s_addr; break; default: ASSERT(0); } pktinfop->ip4_ill_index = 0; pktinfop->ip4_addr = INADDR_ANY; /* * If options passed in, feed it for verification and handling */ if (tudr->OPT_length != 0) { int error; error = 0; if (icmp_unitdata_opt_process(q, mp, &error, (void *)pktinfop) < 0) { /* failure */ BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); icmp_ud_err(q, mp, error); return; } ASSERT(error == 0); /* * Note: Success in processing options. * mp option buffer represented by * OPT_length/offset now potentially modified * and contain option setting results */ } error = raw_ip_send_data_v4(q, connp, mp1, v4dst, pktinfop); done: if (error != 0) { icmp_ud_err(q, mp, error); return; } else { mp->b_cont = NULL; freeb(mp); } } /* ARGSUSED */ static void icmp_wput_fallback(queue_t *q, mblk_t *mp) { #ifdef DEBUG cmn_err(CE_CONT, "icmp_wput_fallback: Message during fallback \n"); #endif freemsg(mp); } static int raw_ip_send_data_v4(queue_t *q, conn_t *connp, mblk_t *mp, ipaddr_t v4dst, ip4_pkt_t *pktinfop) { ipha_t *ipha; size_t ip_len; icmp_t *icmp = connp->conn_icmp; icmp_stack_t *is = icmp->icmp_is; int ip_hdr_length; ip_opt_info_t optinfo; optinfo.ip_opt_flags = 0; optinfo.ip_opt_ill_index = 0; if (icmp->icmp_state == TS_UNBND) { /* If a port has not been bound to the stream, fail. */ BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); return (EPROTO); } if (v4dst == INADDR_ANY) v4dst = htonl(INADDR_LOOPBACK); /* Check if our saved options are valid; update if not */ if (is_system_labeled() && (!IN6_IS_ADDR_V4MAPPED(&icmp->icmp_v6lastdst) || V4_PART_OF_V6(icmp->icmp_v6lastdst) != v4dst)) { int error = icmp_update_label(icmp, mp, v4dst); if (error != 0) return (error); } /* Protocol 255 contains full IP headers */ if (icmp->icmp_hdrincl) return (icmp_wput_hdrincl(q, connp, mp, icmp, pktinfop)); /* Add an IP header */ ip_hdr_length = IP_SIMPLE_HDR_LENGTH + icmp->icmp_ip_snd_options_len; ipha = (ipha_t *)&mp->b_rptr[-ip_hdr_length]; if ((uchar_t *)ipha < mp->b_datap->db_base || mp->b_datap->db_ref != 1 || !OK_32PTR(ipha)) { mblk_t *mp1; if (!(mp1 = allocb(ip_hdr_length + is->is_wroff_extra, BPRI_LO))) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); return (ENOMEM); } mp1->b_cont = mp; ipha = (ipha_t *)mp1->b_datap->db_lim; mp1->b_wptr = (uchar_t *)ipha; ipha = (ipha_t *)((uchar_t *)ipha - ip_hdr_length); mp = mp1; } #ifdef _BIG_ENDIAN /* Set version, header length, and tos */ *(uint16_t *)&ipha->ipha_version_and_hdr_length = ((((IP_VERSION << 4) | (ip_hdr_length>>2)) << 8) | icmp->icmp_type_of_service); /* Set ttl and protocol */ *(uint16_t *)&ipha->ipha_ttl = (icmp->icmp_ttl << 8) | icmp->icmp_proto; #else /* Set version, header length, and tos */ *(uint16_t *)&ipha->ipha_version_and_hdr_length = ((icmp->icmp_type_of_service << 8) | ((IP_VERSION << 4) | (ip_hdr_length>>2))); /* Set ttl and protocol */ *(uint16_t *)&ipha->ipha_ttl = (icmp->icmp_proto << 8) | icmp->icmp_ttl; #endif if (pktinfop->ip4_addr != INADDR_ANY) { ipha->ipha_src = pktinfop->ip4_addr; optinfo.ip_opt_flags = IP_VERIFY_SRC; } else { /* * Copy our address into the packet. If this is zero, * ip will fill in the real source address. */ IN6_V4MAPPED_TO_IPADDR(&icmp->icmp_v6src, ipha->ipha_src); } ipha->ipha_fragment_offset_and_flags = 0; if (pktinfop->ip4_ill_index != 0) { optinfo.ip_opt_ill_index = pktinfop->ip4_ill_index; } /* * For the socket of SOCK_RAW type, the checksum is provided in the * pre-built packet. We set the ipha_ident field to IP_HDR_INCLUDED to * tell IP that the application has sent a complete IP header and not * to compute the transport checksum nor change the DF flag. */ ipha->ipha_ident = IP_HDR_INCLUDED; /* Finish common formatting of the packet. */ mp->b_rptr = (uchar_t *)ipha; ip_len = mp->b_wptr - (uchar_t *)ipha; if (mp->b_cont != NULL) ip_len += msgdsize(mp->b_cont); /* * Set the length into the IP header. * If the length is greater than the maximum allowed by IP, * then free the message and return. Do not try and send it * as this can cause problems in layers below. */ if (ip_len > IP_MAXPACKET) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); return (EMSGSIZE); } ipha->ipha_length = htons((uint16_t)ip_len); /* * Copy in the destination address request */ ipha->ipha_dst = v4dst; /* * Set ttl based on IP_MULTICAST_TTL to match IPv6 logic. */ if (CLASSD(v4dst)) ipha->ipha_ttl = icmp->icmp_multicast_ttl; /* Copy in options if any */ if (ip_hdr_length > IP_SIMPLE_HDR_LENGTH) { bcopy(icmp->icmp_ip_snd_options, &ipha[1], icmp->icmp_ip_snd_options_len); /* * Massage source route putting first source route in ipha_dst. * Ignore the destination in the T_unitdata_req. */ (void) ip_massage_options(ipha, is->is_netstack); } BUMP_MIB(&is->is_rawip_mib, rawipOutDatagrams); ip_output_options(connp, mp, q, IP_WPUT, &optinfo); return (0); } static int icmp_update_label_v6(icmp_t *icmp, mblk_t *mp, in6_addr_t *dst) { int err; uchar_t opt_storage[TSOL_MAX_IPV6_OPTION]; icmp_stack_t *is = icmp->icmp_is; conn_t *connp = icmp->icmp_connp; cred_t *cr; /* * All Solaris components should pass a db_credp * for this message, hence we ASSERT. * On production kernels we return an error to be robust against * random streams modules sitting on top of us. */ cr = msg_getcred(mp, NULL); ASSERT(cr != NULL); if (cr == NULL) return (EINVAL); err = tsol_compute_label_v6(cr, dst, opt_storage, connp->conn_mac_exempt, is->is_netstack->netstack_ip); if (err == 0) { err = tsol_update_sticky(&icmp->icmp_sticky_ipp, &icmp->icmp_label_len_v6, opt_storage); } if (err != 0) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); DTRACE_PROBE4( tx__ip__log__drop__updatelabel__icmp6, char *, "icmp(1) failed to update options(2) on mp(3)", icmp_t *, icmp, char *, opt_storage, mblk_t *, mp); return (err); } icmp->icmp_v6lastdst = *dst; return (0); } /* * raw_ip_send_data_v6(): * Assumes that icmp_wput did some sanity checking on the destination * address, but that the label may not yet be correct. */ static int raw_ip_send_data_v6(queue_t *q, conn_t *connp, mblk_t *mp, sin6_t *sin6, ip6_pkt_t *ipp) { ip6_t *ip6h; ip6i_t *ip6i; /* mp->b_rptr even if no ip6i_t */ int ip_hdr_len = IPV6_HDR_LEN; size_t ip_len; icmp_t *icmp = connp->conn_icmp; icmp_stack_t *is = icmp->icmp_is; ip6_pkt_t *tipp; uint32_t csum = 0; uint_t ignore = 0; uint_t option_exists = 0, is_sticky = 0; uint8_t *cp; uint8_t *nxthdr_ptr; in6_addr_t ip6_dst; /* * If the local address is a mapped address return * an error. * It would be possible to send an IPv6 packet but the * response would never make it back to the application * since it is bound to a mapped address. */ if (IN6_IS_ADDR_V4MAPPED(&icmp->icmp_v6src)) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); return (EADDRNOTAVAIL); } ignore = ipp->ipp_sticky_ignored; if (sin6->sin6_scope_id != 0 && IN6_IS_ADDR_LINKSCOPE(&sin6->sin6_addr)) { /* * IPPF_SCOPE_ID is special. It's neither a sticky * option nor ancillary data. It needs to be * explicitly set in options_exists. */ option_exists |= IPPF_SCOPE_ID; } /* * Compute the destination address */ ip6_dst = sin6->sin6_addr; if (IN6_IS_ADDR_UNSPECIFIED(&sin6->sin6_addr)) ip6_dst = ipv6_loopback; /* * If we're not going to the same destination as last time, then * recompute the label required. This is done in a separate routine to * avoid blowing up our stack here. */ if (is_system_labeled() && !IN6_ARE_ADDR_EQUAL(&icmp->icmp_v6lastdst, &ip6_dst)) { int error = 0; error = icmp_update_label_v6(icmp, mp, &ip6_dst); if (error != 0) return (error); } /* * If there's a security label here, then we ignore any options the * user may try to set. We keep the peer's label as a hidden sticky * option. */ if (icmp->icmp_label_len_v6 > 0) { ignore &= ~IPPF_HOPOPTS; ipp->ipp_fields &= ~IPPF_HOPOPTS; } if ((icmp->icmp_sticky_ipp.ipp_fields == 0) && (ipp->ipp_fields == 0)) { /* No sticky options nor ancillary data. */ goto no_options; } /* * Go through the options figuring out where each is going to * come from and build two masks. The first mask indicates if * the option exists at all. The second mask indicates if the * option is sticky or ancillary. */ if (!(ignore & IPPF_HOPOPTS)) { if (ipp->ipp_fields & IPPF_HOPOPTS) { option_exists |= IPPF_HOPOPTS; ip_hdr_len += ipp->ipp_hopoptslen; } else if (icmp->icmp_sticky_ipp.ipp_fields & IPPF_HOPOPTS) { option_exists |= IPPF_HOPOPTS; is_sticky |= IPPF_HOPOPTS; ip_hdr_len += icmp->icmp_sticky_ipp.ipp_hopoptslen; } } if (!(ignore & IPPF_RTHDR)) { if (ipp->ipp_fields & IPPF_RTHDR) { option_exists |= IPPF_RTHDR; ip_hdr_len += ipp->ipp_rthdrlen; } else if (icmp->icmp_sticky_ipp.ipp_fields & IPPF_RTHDR) { option_exists |= IPPF_RTHDR; is_sticky |= IPPF_RTHDR; ip_hdr_len += icmp->icmp_sticky_ipp.ipp_rthdrlen; } } if (!(ignore & IPPF_RTDSTOPTS) && (option_exists & IPPF_RTHDR)) { /* * Need to have a router header to use these. */ if (ipp->ipp_fields & IPPF_RTDSTOPTS) { option_exists |= IPPF_RTDSTOPTS; ip_hdr_len += ipp->ipp_rtdstoptslen; } else if (icmp->icmp_sticky_ipp.ipp_fields & IPPF_RTDSTOPTS) { option_exists |= IPPF_RTDSTOPTS; is_sticky |= IPPF_RTDSTOPTS; ip_hdr_len += icmp->icmp_sticky_ipp.ipp_rtdstoptslen; } } if (!(ignore & IPPF_DSTOPTS)) { if (ipp->ipp_fields & IPPF_DSTOPTS) { option_exists |= IPPF_DSTOPTS; ip_hdr_len += ipp->ipp_dstoptslen; } else if (icmp->icmp_sticky_ipp.ipp_fields & IPPF_DSTOPTS) { option_exists |= IPPF_DSTOPTS; is_sticky |= IPPF_DSTOPTS; ip_hdr_len += icmp->icmp_sticky_ipp.ipp_dstoptslen; } } if (!(ignore & IPPF_IFINDEX)) { if (ipp->ipp_fields & IPPF_IFINDEX) { option_exists |= IPPF_IFINDEX; } else if (icmp->icmp_sticky_ipp.ipp_fields & IPPF_IFINDEX) { option_exists |= IPPF_IFINDEX; is_sticky |= IPPF_IFINDEX; } } if (!(ignore & IPPF_ADDR)) { if (ipp->ipp_fields & IPPF_ADDR) { option_exists |= IPPF_ADDR; } else if (icmp->icmp_sticky_ipp.ipp_fields & IPPF_ADDR) { option_exists |= IPPF_ADDR; is_sticky |= IPPF_ADDR; } } if (!(ignore & IPPF_DONTFRAG)) { if (ipp->ipp_fields & IPPF_DONTFRAG) { option_exists |= IPPF_DONTFRAG; } else if (icmp->icmp_sticky_ipp.ipp_fields & IPPF_DONTFRAG) { option_exists |= IPPF_DONTFRAG; is_sticky |= IPPF_DONTFRAG; } } if (!(ignore & IPPF_USE_MIN_MTU)) { if (ipp->ipp_fields & IPPF_USE_MIN_MTU) { option_exists |= IPPF_USE_MIN_MTU; } else if (icmp->icmp_sticky_ipp.ipp_fields & IPPF_USE_MIN_MTU) { option_exists |= IPPF_USE_MIN_MTU; is_sticky |= IPPF_USE_MIN_MTU; } } if (!(ignore & IPPF_NEXTHOP)) { if (ipp->ipp_fields & IPPF_NEXTHOP) { option_exists |= IPPF_NEXTHOP; } else if (icmp->icmp_sticky_ipp.ipp_fields & IPPF_NEXTHOP) { option_exists |= IPPF_NEXTHOP; is_sticky |= IPPF_NEXTHOP; } } if (!(ignore & IPPF_HOPLIMIT) && (ipp->ipp_fields & IPPF_HOPLIMIT)) option_exists |= IPPF_HOPLIMIT; /* IPV6_HOPLIMIT can never be sticky */ ASSERT(!(icmp->icmp_sticky_ipp.ipp_fields & IPPF_HOPLIMIT)); if (!(ignore & IPPF_UNICAST_HOPS) && (icmp->icmp_sticky_ipp.ipp_fields & IPPF_UNICAST_HOPS)) { option_exists |= IPPF_UNICAST_HOPS; is_sticky |= IPPF_UNICAST_HOPS; } if (!(ignore & IPPF_MULTICAST_HOPS) && (icmp->icmp_sticky_ipp.ipp_fields & IPPF_MULTICAST_HOPS)) { option_exists |= IPPF_MULTICAST_HOPS; is_sticky |= IPPF_MULTICAST_HOPS; } if (icmp->icmp_sticky_ipp.ipp_fields & IPPF_NO_CKSUM) { /* This is a sticky socket option only */ option_exists |= IPPF_NO_CKSUM; is_sticky |= IPPF_NO_CKSUM; } if (icmp->icmp_sticky_ipp.ipp_fields & IPPF_RAW_CKSUM) { /* This is a sticky socket option only */ option_exists |= IPPF_RAW_CKSUM; is_sticky |= IPPF_RAW_CKSUM; } if (!(ignore & IPPF_TCLASS)) { if (ipp->ipp_fields & IPPF_TCLASS) { option_exists |= IPPF_TCLASS; } else if (icmp->icmp_sticky_ipp.ipp_fields & IPPF_TCLASS) { option_exists |= IPPF_TCLASS; is_sticky |= IPPF_TCLASS; } } no_options: /* * If any options carried in the ip6i_t were specified, we * need to account for the ip6i_t in the data we'll be sending * down. */ if (option_exists & IPPF_HAS_IP6I) ip_hdr_len += sizeof (ip6i_t); /* check/fix buffer config, setup pointers into it */ ip6h = (ip6_t *)&mp->b_rptr[-ip_hdr_len]; if ((mp->b_datap->db_ref != 1) || ((unsigned char *)ip6h < mp->b_datap->db_base) || !OK_32PTR(ip6h)) { mblk_t *mp1; /* Try to get everything in a single mblk next time */ if (ip_hdr_len > icmp->icmp_max_hdr_len) { icmp->icmp_max_hdr_len = ip_hdr_len; (void) proto_set_tx_wroff(q == NULL ? NULL:RD(q), connp, icmp->icmp_max_hdr_len + is->is_wroff_extra); } mp1 = allocb(ip_hdr_len + is->is_wroff_extra, BPRI_LO); if (!mp1) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); return (ENOMEM); } mp1->b_cont = mp; mp1->b_wptr = mp1->b_datap->db_lim; ip6h = (ip6_t *)(mp1->b_wptr - ip_hdr_len); mp = mp1; } mp->b_rptr = (unsigned char *)ip6h; ip6i = (ip6i_t *)ip6h; #define ANCIL_OR_STICKY_PTR(f) ((is_sticky & f) ? &icmp->icmp_sticky_ipp : ipp) if (option_exists & IPPF_HAS_IP6I) { ip6h = (ip6_t *)&ip6i[1]; ip6i->ip6i_flags = 0; ip6i->ip6i_vcf = IPV6_DEFAULT_VERS_AND_FLOW; /* sin6_scope_id takes precendence over IPPF_IFINDEX */ if (option_exists & IPPF_SCOPE_ID) { ip6i->ip6i_flags |= IP6I_IFINDEX; ip6i->ip6i_ifindex = sin6->sin6_scope_id; } else if (option_exists & IPPF_IFINDEX) { tipp = ANCIL_OR_STICKY_PTR(IPPF_IFINDEX); ASSERT(tipp->ipp_ifindex != 0); ip6i->ip6i_flags |= IP6I_IFINDEX; ip6i->ip6i_ifindex = tipp->ipp_ifindex; } if (option_exists & IPPF_RAW_CKSUM) { ip6i->ip6i_flags |= IP6I_RAW_CHECKSUM; ip6i->ip6i_checksum_off = icmp->icmp_checksum_off; } if (option_exists & IPPF_NO_CKSUM) { ip6i->ip6i_flags |= IP6I_NO_ULP_CKSUM; } if (option_exists & IPPF_ADDR) { /* * Enable per-packet source address verification if * IPV6_PKTINFO specified the source address. * ip6_src is set in the transport's _wput function. */ ip6i->ip6i_flags |= IP6I_VERIFY_SRC; } if (option_exists & IPPF_DONTFRAG) { ip6i->ip6i_flags |= IP6I_DONTFRAG; } if (option_exists & IPPF_USE_MIN_MTU) { ip6i->ip6i_flags = IP6I_API_USE_MIN_MTU( ip6i->ip6i_flags, ipp->ipp_use_min_mtu); } if (option_exists & IPPF_NEXTHOP) { tipp = ANCIL_OR_STICKY_PTR(IPPF_NEXTHOP); ASSERT(!IN6_IS_ADDR_UNSPECIFIED(&tipp->ipp_nexthop)); ip6i->ip6i_flags |= IP6I_NEXTHOP; ip6i->ip6i_nexthop = tipp->ipp_nexthop; } /* * tell IP this is an ip6i_t private header */ ip6i->ip6i_nxt = IPPROTO_RAW; } /* Initialize IPv6 header */ ip6h->ip6_vcf = IPV6_DEFAULT_VERS_AND_FLOW; bzero(&ip6h->ip6_src, sizeof (ip6h->ip6_src)); /* Set the hoplimit of the outgoing packet. */ if (option_exists & IPPF_HOPLIMIT) { /* IPV6_HOPLIMIT ancillary data overrides all other settings. */ ip6h->ip6_hops = ipp->ipp_hoplimit; ip6i->ip6i_flags |= IP6I_HOPLIMIT; } else if (IN6_IS_ADDR_MULTICAST(&sin6->sin6_addr)) { ip6h->ip6_hops = icmp->icmp_multicast_ttl; if (option_exists & IPPF_MULTICAST_HOPS) ip6i->ip6i_flags |= IP6I_HOPLIMIT; } else { ip6h->ip6_hops = icmp->icmp_ttl; if (option_exists & IPPF_UNICAST_HOPS) ip6i->ip6i_flags |= IP6I_HOPLIMIT; } if (option_exists & IPPF_ADDR) { tipp = ANCIL_OR_STICKY_PTR(IPPF_ADDR); ASSERT(!IN6_IS_ADDR_UNSPECIFIED(&tipp->ipp_addr)); ip6h->ip6_src = tipp->ipp_addr; } else { /* * The source address was not set using IPV6_PKTINFO. * First look at the bound source. * If unspecified fallback to __sin6_src_id. */ ip6h->ip6_src = icmp->icmp_v6src; if (sin6->__sin6_src_id != 0 && IN6_IS_ADDR_UNSPECIFIED(&ip6h->ip6_src)) { ip_srcid_find_id(sin6->__sin6_src_id, &ip6h->ip6_src, icmp->icmp_zoneid, is->is_netstack); } } nxthdr_ptr = (uint8_t *)&ip6h->ip6_nxt; cp = (uint8_t *)&ip6h[1]; /* * Here's where we have to start stringing together * any extension headers in the right order: * Hop-by-hop, destination, routing, and final destination opts. */ if (option_exists & IPPF_HOPOPTS) { /* Hop-by-hop options */ ip6_hbh_t *hbh = (ip6_hbh_t *)cp; tipp = ANCIL_OR_STICKY_PTR(IPPF_HOPOPTS); *nxthdr_ptr = IPPROTO_HOPOPTS; nxthdr_ptr = &hbh->ip6h_nxt; bcopy(tipp->ipp_hopopts, cp, tipp->ipp_hopoptslen); cp += tipp->ipp_hopoptslen; } /* * En-route destination options * Only do them if there's a routing header as well */ if (option_exists & IPPF_RTDSTOPTS) { ip6_dest_t *dst = (ip6_dest_t *)cp; tipp = ANCIL_OR_STICKY_PTR(IPPF_RTDSTOPTS); *nxthdr_ptr = IPPROTO_DSTOPTS; nxthdr_ptr = &dst->ip6d_nxt; bcopy(tipp->ipp_rtdstopts, cp, tipp->ipp_rtdstoptslen); cp += tipp->ipp_rtdstoptslen; } /* * Routing header next */ if (option_exists & IPPF_RTHDR) { ip6_rthdr_t *rt = (ip6_rthdr_t *)cp; tipp = ANCIL_OR_STICKY_PTR(IPPF_RTHDR); *nxthdr_ptr = IPPROTO_ROUTING; nxthdr_ptr = &rt->ip6r_nxt; bcopy(tipp->ipp_rthdr, cp, tipp->ipp_rthdrlen); cp += tipp->ipp_rthdrlen; } /* * Do ultimate destination options */ if (option_exists & IPPF_DSTOPTS) { ip6_dest_t *dest = (ip6_dest_t *)cp; tipp = ANCIL_OR_STICKY_PTR(IPPF_DSTOPTS); *nxthdr_ptr = IPPROTO_DSTOPTS; nxthdr_ptr = &dest->ip6d_nxt; bcopy(tipp->ipp_dstopts, cp, tipp->ipp_dstoptslen); cp += tipp->ipp_dstoptslen; } /* * Now set the last header pointer to the proto passed in */ ASSERT((int)(cp - (uint8_t *)ip6i) == ip_hdr_len); *nxthdr_ptr = icmp->icmp_proto; /* * Copy in the destination address */ ip6h->ip6_dst = ip6_dst; ip6h->ip6_vcf = (IPV6_DEFAULT_VERS_AND_FLOW & IPV6_VERS_AND_FLOW_MASK) | (sin6->sin6_flowinfo & ~IPV6_VERS_AND_FLOW_MASK); if (option_exists & IPPF_TCLASS) { tipp = ANCIL_OR_STICKY_PTR(IPPF_TCLASS); ip6h->ip6_vcf = IPV6_TCLASS_FLOW(ip6h->ip6_vcf, tipp->ipp_tclass); } if (option_exists & IPPF_RTHDR) { ip6_rthdr_t *rth; /* * Perform any processing needed for source routing. * We know that all extension headers will be in the same mblk * as the IPv6 header. */ rth = ip_find_rthdr_v6(ip6h, mp->b_wptr); if (rth != NULL && rth->ip6r_segleft != 0) { if (rth->ip6r_type != IPV6_RTHDR_TYPE_0) { /* * Drop packet - only support Type 0 routing. * Notify the application as well. */ BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); return (EPROTO); } /* * rth->ip6r_len is twice the number of * addresses in the header */ if (rth->ip6r_len & 0x1) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); return (EPROTO); } /* * Shuffle the routing header and ip6_dst * addresses, and get the checksum difference * between the first hop (in ip6_dst) and * the destination (in the last routing hdr entry). */ csum = ip_massage_options_v6(ip6h, rth, is->is_netstack); /* * Verify that the first hop isn't a mapped address. * Routers along the path need to do this verification * for subsequent hops. */ if (IN6_IS_ADDR_V4MAPPED(&ip6h->ip6_dst)) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); return (EADDRNOTAVAIL); } } } ip_len = mp->b_wptr - (uchar_t *)ip6h - IPV6_HDR_LEN; if (mp->b_cont != NULL) ip_len += msgdsize(mp->b_cont); /* * Set the length into the IP header. * If the length is greater than the maximum allowed by IP, * then free the message and return. Do not try and send it * as this can cause problems in layers below. */ if (ip_len > IP_MAXPACKET) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); return (EMSGSIZE); } if (icmp->icmp_proto == IPPROTO_ICMPV6 || icmp->icmp_raw_checksum) { uint_t cksum_off; /* From ip6i == mp->b_rptr */ uint16_t *cksum_ptr; uint_t ext_hdrs_len; /* ICMPv6 must have an offset matching icmp6_cksum offset */ ASSERT(icmp->icmp_proto != IPPROTO_ICMPV6 || icmp->icmp_checksum_off == 2); /* * We make it easy for IP to include our pseudo header * by putting our length in uh_checksum, modified (if * we have a routing header) by the checksum difference * between the ultimate destination and first hop addresses. * Note: ICMPv6 must always checksum the packet. */ cksum_off = ip_hdr_len + icmp->icmp_checksum_off; if (cksum_off + sizeof (uint16_t) > mp->b_wptr - mp->b_rptr) { if (!pullupmsg(mp, cksum_off + sizeof (uint16_t))) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); freemsg(mp); return (0); } ip6i = (ip6i_t *)mp->b_rptr; if (ip6i->ip6i_nxt == IPPROTO_RAW) ip6h = (ip6_t *)&ip6i[1]; else ip6h = (ip6_t *)ip6i; } /* Add payload length to checksum */ ext_hdrs_len = ip_hdr_len - IPV6_HDR_LEN - (int)((uchar_t *)ip6h - (uchar_t *)ip6i); csum += htons(ip_len - ext_hdrs_len); cksum_ptr = (uint16_t *)((uchar_t *)ip6i + cksum_off); csum = (csum & 0xFFFF) + (csum >> 16); *cksum_ptr = (uint16_t)csum; } #ifdef _LITTLE_ENDIAN ip_len = htons(ip_len); #endif ip6h->ip6_plen = (uint16_t)ip_len; /* We're done. Pass the packet to IP */ BUMP_MIB(&is->is_rawip_mib, rawipOutDatagrams); ip_output_v6(icmp->icmp_connp, mp, q, IP_WPUT); return (0); } static void icmp_wput_other(queue_t *q, mblk_t *mp) { uchar_t *rptr = mp->b_rptr; struct iocblk *iocp; #define tudr ((struct T_unitdata_req *)rptr) conn_t *connp = Q_TO_CONN(q); icmp_t *icmp = connp->conn_icmp; icmp_stack_t *is = icmp->icmp_is; cred_t *cr; switch (mp->b_datap->db_type) { case M_PROTO: case M_PCPROTO: if (mp->b_wptr - rptr < sizeof (t_scalar_t)) { /* * If the message does not contain a PRIM_type, * throw it away. */ freemsg(mp); return; } switch (((union T_primitives *)rptr)->type) { case T_ADDR_REQ: icmp_addr_req(q, mp); return; case O_T_BIND_REQ: case T_BIND_REQ: icmp_tpi_bind(q, mp); return; case T_CONN_REQ: icmp_tpi_connect(q, mp); return; case T_CAPABILITY_REQ: icmp_capability_req(q, mp); return; case T_INFO_REQ: icmp_info_req(q, mp); return; case T_UNITDATA_REQ: /* * If a T_UNITDATA_REQ gets here, the address must * be bad. Valid T_UNITDATA_REQs are found above * and break to below this switch. */ icmp_ud_err(q, mp, EADDRNOTAVAIL); return; case T_UNBIND_REQ: icmp_tpi_unbind(q, mp); return; case T_SVR4_OPTMGMT_REQ: /* * All Solaris components should pass a db_credp * for this TPI message, hence we ASSERT. * But in case there is some other M_PROTO that looks * like a TPI message sent by some other kernel * component, we check and return an error. */ cr = msg_getcred(mp, NULL); ASSERT(cr != NULL); if (cr == NULL) { icmp_err_ack(q, mp, TSYSERR, EINVAL); return; } if (!snmpcom_req(q, mp, icmp_snmp_set, ip_snmp_get, cr)) { /* Only IP can return anything meaningful */ (void) svr4_optcom_req(q, mp, cr, &icmp_opt_obj, B_TRUE); } return; case T_OPTMGMT_REQ: /* * All Solaris components should pass a db_credp * for this TPI message, hence we ASSERT. * But in case there is some other M_PROTO that looks * like a TPI message sent by some other kernel * component, we check and return an error. */ cr = msg_getcred(mp, NULL); ASSERT(cr != NULL); if (cr == NULL) { icmp_err_ack(q, mp, TSYSERR, EINVAL); return; } /* Only IP can return anything meaningful */ (void) tpi_optcom_req(q, mp, cr, &icmp_opt_obj, B_TRUE); return; case T_DISCON_REQ: icmp_tpi_disconnect(q, mp); return; /* The following TPI message is not supported by icmp. */ case O_T_CONN_RES: case T_CONN_RES: icmp_err_ack(q, mp, TNOTSUPPORT, 0); return; /* The following 3 TPI requests are illegal for icmp. */ case T_DATA_REQ: case T_EXDATA_REQ: case T_ORDREL_REQ: freemsg(mp); (void) putctl1(RD(q), M_ERROR, EPROTO); return; default: break; } break; case M_IOCTL: iocp = (struct iocblk *)mp->b_rptr; switch (iocp->ioc_cmd) { case TI_GETPEERNAME: if (icmp->icmp_state != TS_DATA_XFER) { /* * If a default destination address has not * been associated with the stream, then we * don't know the peer's name. */ iocp->ioc_error = ENOTCONN; err_ret:; iocp->ioc_count = 0; mp->b_datap->db_type = M_IOCACK; qreply(q, mp); return; } /* FALLTHRU */ case TI_GETMYNAME: /* * For TI_GETPEERNAME and TI_GETMYNAME, we first * need to copyin the user's strbuf structure. * Processing will continue in the M_IOCDATA case * below. */ mi_copyin(q, mp, NULL, SIZEOF_STRUCT(strbuf, iocp->ioc_flag)); return; case ND_SET: /* nd_getset performs the necessary error checking */ case ND_GET: if (nd_getset(q, is->is_nd, mp)) { qreply(q, mp); return; } break; case _SIOCSOCKFALLBACK: /* * socket is falling back to be a * streams socket. Nothing to do */ iocp->ioc_count = 0; iocp->ioc_rval = 0; qreply(q, mp); return; default: break; } break; case M_IOCDATA: icmp_wput_iocdata(q, mp); return; default: break; } ip_wput(q, mp); } /* * icmp_wput_iocdata is called by icmp_wput_slow to handle all M_IOCDATA * messages. */ static void icmp_wput_iocdata(queue_t *q, mblk_t *mp) { mblk_t *mp1; STRUCT_HANDLE(strbuf, sb); icmp_t *icmp; uint_t addrlen; uint_t error; /* Make sure it is one of ours. */ switch (((struct iocblk *)mp->b_rptr)->ioc_cmd) { case TI_GETMYNAME: case TI_GETPEERNAME: break; default: icmp = Q_TO_ICMP(q); ip_output(icmp->icmp_connp, mp, q, IP_WPUT); return; } switch (mi_copy_state(q, mp, &mp1)) { case -1: return; case MI_COPY_CASE(MI_COPY_IN, 1): break; case MI_COPY_CASE(MI_COPY_OUT, 1): /* * The address has been copied out, so now * copyout the strbuf. */ mi_copyout(q, mp); return; case MI_COPY_CASE(MI_COPY_OUT, 2): /* * The address and strbuf have been copied out. * We're done, so just acknowledge the original * M_IOCTL. */ mi_copy_done(q, mp, 0); return; default: /* * Something strange has happened, so acknowledge * the original M_IOCTL with an EPROTO error. */ mi_copy_done(q, mp, EPROTO); return; } /* * Now we have the strbuf structure for TI_GETMYNAME * and TI_GETPEERNAME. Next we copyout the requested * address and then we'll copyout the strbuf. */ STRUCT_SET_HANDLE(sb, ((struct iocblk *)mp->b_rptr)->ioc_flag, (void *)mp1->b_rptr); icmp = Q_TO_ICMP(q); if (icmp->icmp_family == AF_INET) addrlen = sizeof (sin_t); else addrlen = sizeof (sin6_t); if (STRUCT_FGET(sb, maxlen) < addrlen) { mi_copy_done(q, mp, EINVAL); return; } mp1 = mi_copyout_alloc(q, mp, STRUCT_FGETP(sb, buf), addrlen, B_TRUE); if (mp1 == NULL) return; rw_enter(&icmp->icmp_rwlock, RW_READER); switch (((struct iocblk *)mp->b_rptr)->ioc_cmd) { case TI_GETMYNAME: error = rawip_do_getsockname(icmp, (void *)mp1->b_rptr, &addrlen); break; case TI_GETPEERNAME: error = rawip_do_getpeername(icmp, (void *)mp1->b_rptr, &addrlen); break; } rw_exit(&icmp->icmp_rwlock); if (error != 0) { mi_copy_done(q, mp, error); } else { mp1->b_wptr += addrlen; STRUCT_FSET(sb, len, addrlen); /* Copy out the address */ mi_copyout(q, mp); } } static int icmp_unitdata_opt_process(queue_t *q, mblk_t *mp, int *errorp, void *thisdg_attrs) { struct T_unitdata_req *udreqp; int is_absreq_failure; cred_t *cr; udreqp = (struct T_unitdata_req *)mp->b_rptr; *errorp = 0; /* * All Solaris components should pass a db_credp * for this TPI message, hence we ASSERT. * But in case there is some other M_PROTO that looks * like a TPI message sent by some other kernel * component, we check and return an error. */ cr = msg_getcred(mp, NULL); ASSERT(cr != NULL); if (cr == NULL) return (-1); *errorp = tpi_optcom_buf(q, mp, &udreqp->OPT_length, udreqp->OPT_offset, cr, &icmp_opt_obj, thisdg_attrs, &is_absreq_failure); if (*errorp != 0) { /* * Note: No special action needed in this * module for "is_absreq_failure" */ return (-1); /* failure */ } ASSERT(is_absreq_failure == 0); return (0); /* success */ } void icmp_ddi_g_init(void) { icmp_max_optsize = optcom_max_optsize(icmp_opt_obj.odb_opt_des_arr, icmp_opt_obj.odb_opt_arr_cnt); /* * We want to be informed each time a stack is created or * destroyed in the kernel, so we can maintain the * set of icmp_stack_t's. */ netstack_register(NS_ICMP, rawip_stack_init, NULL, rawip_stack_fini); } void icmp_ddi_g_destroy(void) { netstack_unregister(NS_ICMP); } #define INET_NAME "ip" /* * Initialize the ICMP stack instance. */ static void * rawip_stack_init(netstackid_t stackid, netstack_t *ns) { icmp_stack_t *is; icmpparam_t *pa; int error = 0; major_t major; is = (icmp_stack_t *)kmem_zalloc(sizeof (*is), KM_SLEEP); is->is_netstack = ns; pa = (icmpparam_t *)kmem_alloc(sizeof (icmp_param_arr), KM_SLEEP); is->is_param_arr = pa; bcopy(icmp_param_arr, is->is_param_arr, sizeof (icmp_param_arr)); (void) icmp_param_register(&is->is_nd, is->is_param_arr, A_CNT(icmp_param_arr)); is->is_ksp = rawip_kstat_init(stackid); major = mod_name_to_major(INET_NAME); error = ldi_ident_from_major(major, &is->is_ldi_ident); ASSERT(error == 0); return (is); } /* * Free the ICMP stack instance. */ static void rawip_stack_fini(netstackid_t stackid, void *arg) { icmp_stack_t *is = (icmp_stack_t *)arg; nd_free(&is->is_nd); kmem_free(is->is_param_arr, sizeof (icmp_param_arr)); is->is_param_arr = NULL; rawip_kstat_fini(stackid, is->is_ksp); is->is_ksp = NULL; ldi_ident_release(is->is_ldi_ident); kmem_free(is, sizeof (*is)); } static void * rawip_kstat_init(netstackid_t stackid) { kstat_t *ksp; rawip_named_kstat_t template = { { "inDatagrams", KSTAT_DATA_UINT32, 0 }, { "inCksumErrs", KSTAT_DATA_UINT32, 0 }, { "inErrors", KSTAT_DATA_UINT32, 0 }, { "outDatagrams", KSTAT_DATA_UINT32, 0 }, { "outErrors", KSTAT_DATA_UINT32, 0 }, }; ksp = kstat_create_netstack("icmp", 0, "rawip", "mib2", KSTAT_TYPE_NAMED, NUM_OF_FIELDS(rawip_named_kstat_t), 0, stackid); if (ksp == NULL || ksp->ks_data == NULL) return (NULL); bcopy(&template, ksp->ks_data, sizeof (template)); ksp->ks_update = rawip_kstat_update; ksp->ks_private = (void *)(uintptr_t)stackid; kstat_install(ksp); return (ksp); } static void rawip_kstat_fini(netstackid_t stackid, kstat_t *ksp) { if (ksp != NULL) { ASSERT(stackid == (netstackid_t)(uintptr_t)ksp->ks_private); kstat_delete_netstack(ksp, stackid); } } static int rawip_kstat_update(kstat_t *ksp, int rw) { rawip_named_kstat_t *rawipkp; netstackid_t stackid = (netstackid_t)(uintptr_t)ksp->ks_private; netstack_t *ns; icmp_stack_t *is; if ((ksp == NULL) || (ksp->ks_data == NULL)) return (EIO); if (rw == KSTAT_WRITE) return (EACCES); rawipkp = (rawip_named_kstat_t *)ksp->ks_data; ns = netstack_find_by_stackid(stackid); if (ns == NULL) return (-1); is = ns->netstack_icmp; if (is == NULL) { netstack_rele(ns); return (-1); } rawipkp->inDatagrams.value.ui32 = is->is_rawip_mib.rawipInDatagrams; rawipkp->inCksumErrs.value.ui32 = is->is_rawip_mib.rawipInCksumErrs; rawipkp->inErrors.value.ui32 = is->is_rawip_mib.rawipInErrors; rawipkp->outDatagrams.value.ui32 = is->is_rawip_mib.rawipOutDatagrams; rawipkp->outErrors.value.ui32 = is->is_rawip_mib.rawipOutErrors; netstack_rele(ns); return (0); } /* ARGSUSED */ int rawip_accept(sock_lower_handle_t lproto_handle, sock_lower_handle_t eproto_handle, sock_upper_handle_t sock_handle, cred_t *cr) { return (EOPNOTSUPP); } /* ARGSUSED */ int rawip_bind(sock_lower_handle_t proto_handle, struct sockaddr *sa, socklen_t len, cred_t *cr) { conn_t *connp = (conn_t *)proto_handle; int error; /* All Solaris components should pass a cred for this operation. */ ASSERT(cr != NULL); /* Binding to a NULL address really means unbind */ if (sa == NULL) error = rawip_do_unbind(connp); else error = rawip_do_bind(connp, sa, len); if (error < 0) { if (error == -TOUTSTATE) error = EINVAL; else error = proto_tlitosyserr(-error); } return (error); } static int rawip_implicit_bind(conn_t *connp) { sin6_t sin6addr; sin_t *sin; sin6_t *sin6; socklen_t len; int error; if (connp->conn_icmp->icmp_family == AF_INET) { len = sizeof (struct sockaddr_in); sin = (sin_t *)&sin6addr; *sin = sin_null; sin->sin_family = AF_INET; sin->sin_addr.s_addr = INADDR_ANY; } else { ASSERT(connp->conn_icmp->icmp_family == AF_INET6); len = sizeof (sin6_t); sin6 = (sin6_t *)&sin6addr; *sin6 = sin6_null; sin6->sin6_family = AF_INET6; V6_SET_ZERO(sin6->sin6_addr); } error = rawip_do_bind(connp, (struct sockaddr *)&sin6addr, len); return ((error < 0) ? proto_tlitosyserr(-error) : error); } static int rawip_unbind(conn_t *connp) { int error; error = rawip_do_unbind(connp); if (error < 0) { error = proto_tlitosyserr(-error); } return (error); } /* ARGSUSED */ int rawip_listen(sock_lower_handle_t proto_handle, int backlog, cred_t *cr) { return (EOPNOTSUPP); } /* ARGSUSED */ int rawip_connect(sock_lower_handle_t proto_handle, const struct sockaddr *sa, socklen_t len, sock_connid_t *id, cred_t *cr) { conn_t *connp = (conn_t *)proto_handle; icmp_t *icmp = connp->conn_icmp; int error; boolean_t did_bind = B_FALSE; /* All Solaris components should pass a cred for this operation. */ ASSERT(cr != NULL); if (sa == NULL) { /* * Disconnect * Make sure we are connected */ if (icmp->icmp_state != TS_DATA_XFER) return (EINVAL); error = icmp_disconnect(connp); return (error); } error = proto_verify_ip_addr(icmp->icmp_family, sa, len); if (error != 0) return (error); /* do an implicit bind if necessary */ if (icmp->icmp_state == TS_UNBND) { error = rawip_implicit_bind(connp); /* * We could be racing with an actual bind, in which case * we would see EPROTO. We cross our fingers and try * to connect. */ if (!(error == 0 || error == EPROTO)) return (error); did_bind = B_TRUE; } /* * set SO_DGRAM_ERRIND */ icmp->icmp_dgram_errind = B_TRUE; error = rawip_do_connect(connp, sa, len, cr); if (error != 0 && did_bind) { int unbind_err; unbind_err = rawip_unbind(connp); ASSERT(unbind_err == 0); } if (error == 0) { *id = 0; (*connp->conn_upcalls->su_connected) (connp->conn_upper_handle, 0, NULL, -1); } else if (error < 0) { error = proto_tlitosyserr(-error); } return (error); } /* ARGSUSED */ int rawip_fallback(sock_lower_handle_t proto_handle, queue_t *q, boolean_t direct_sockfs, so_proto_quiesced_cb_t quiesced_cb) { conn_t *connp = (conn_t *)proto_handle; icmp_t *icmp; struct T_capability_ack tca; struct sockaddr_in6 laddr, faddr; socklen_t laddrlen, faddrlen; short opts; struct stroptions *stropt; mblk_t *stropt_mp; int error; icmp = connp->conn_icmp; stropt_mp = allocb_wait(sizeof (*stropt), BPRI_HI, STR_NOSIG, NULL); /* * setup the fallback stream that was allocated */ connp->conn_dev = (dev_t)RD(q)->q_ptr; connp->conn_minor_arena = WR(q)->q_ptr; RD(q)->q_ptr = WR(q)->q_ptr = connp; WR(q)->q_qinfo = &icmpwinit; connp->conn_rq = RD(q); connp->conn_wq = WR(q); /* Notify stream head about options before sending up data */ stropt_mp->b_datap->db_type = M_SETOPTS; stropt_mp->b_wptr += sizeof (*stropt); stropt = (struct stroptions *)stropt_mp->b_rptr; stropt->so_flags = SO_WROFF | SO_HIWAT; stropt->so_wroff = (ushort_t)(icmp->icmp_max_hdr_len + icmp->icmp_is->is_wroff_extra); stropt->so_hiwat = icmp->icmp_recv_hiwat; putnext(RD(q), stropt_mp); /* * free helper stream */ ip_free_helper_stream(connp); /* * Collect the information needed to sync with the sonode */ icmp_do_capability_ack(icmp, &tca, TC1_INFO); laddrlen = faddrlen = sizeof (sin6_t); (void) rawip_getsockname((sock_lower_handle_t)connp, (struct sockaddr *)&laddr, &laddrlen, CRED()); error = rawip_getpeername((sock_lower_handle_t)connp, (struct sockaddr *)&faddr, &faddrlen, CRED()); if (error != 0) faddrlen = 0; opts = 0; if (icmp->icmp_dgram_errind) opts |= SO_DGRAM_ERRIND; if (icmp->icmp_dontroute) opts |= SO_DONTROUTE; (*quiesced_cb)(connp->conn_upper_handle, q, &tca, (struct sockaddr *)&laddr, laddrlen, (struct sockaddr *)&faddr, faddrlen, opts); /* * Attempts to send data up during fallback will result in it being * queued in udp_t. Now we push up any queued packets. */ mutex_enter(&icmp->icmp_recv_lock); while (icmp->icmp_fallback_queue_head != NULL) { mblk_t *mp; mp = icmp->icmp_fallback_queue_head; icmp->icmp_fallback_queue_head = mp->b_next; mp->b_next = NULL; mutex_exit(&icmp->icmp_recv_lock); putnext(RD(q), mp); mutex_enter(&icmp->icmp_recv_lock); } icmp->icmp_fallback_queue_tail = icmp->icmp_fallback_queue_head; /* * No longer a streams less socket */ rw_enter(&icmp->icmp_rwlock, RW_WRITER); connp->conn_flags &= ~IPCL_NONSTR; rw_exit(&icmp->icmp_rwlock); mutex_exit(&icmp->icmp_recv_lock); ASSERT(icmp->icmp_fallback_queue_head == NULL && icmp->icmp_fallback_queue_tail == NULL); ASSERT(connp->conn_ref >= 1); return (0); } /* ARGSUSED */ sock_lower_handle_t rawip_create(int family, int type, int proto, sock_downcalls_t **sock_downcalls, uint_t *smodep, int *errorp, int flags, cred_t *credp) { conn_t *connp; if (type != SOCK_RAW || (family != AF_INET && family != AF_INET6)) { *errorp = EPROTONOSUPPORT; return (NULL); } connp = icmp_open(family, credp, errorp, flags); if (connp != NULL) { icmp_stack_t *is; is = connp->conn_icmp->icmp_is; connp->conn_flags |= IPCL_NONSTR; if (connp->conn_icmp->icmp_family == AF_INET6) { /* Build initial header template for transmit */ rw_enter(&connp->conn_icmp->icmp_rwlock, RW_WRITER); if ((*errorp = icmp_build_hdrs(connp->conn_icmp)) != 0) { rw_exit(&connp->conn_icmp->icmp_rwlock); ipcl_conn_destroy(connp); return (NULL); } rw_exit(&connp->conn_icmp->icmp_rwlock); } connp->conn_icmp->icmp_recv_hiwat = is->is_recv_hiwat; connp->conn_icmp->icmp_xmit_hiwat = is->is_xmit_hiwat; if ((*errorp = ip_create_helper_stream(connp, is->is_ldi_ident)) != 0) { cmn_err(CE_CONT, "create of IP helper stream failed\n"); (void) rawip_do_close(connp); return (NULL); } mutex_enter(&connp->conn_lock); connp->conn_state_flags &= ~CONN_INCIPIENT; mutex_exit(&connp->conn_lock); *sock_downcalls = &sock_rawip_downcalls; *smodep = SM_ATOMIC; } else { ASSERT(*errorp != 0); } return ((sock_lower_handle_t)connp); } /* ARGSUSED */ void rawip_activate(sock_lower_handle_t proto_handle, sock_upper_handle_t sock_handle, sock_upcalls_t *sock_upcalls, int flags, cred_t *cr) { conn_t *connp = (conn_t *)proto_handle; icmp_stack_t *is = connp->conn_icmp->icmp_is; struct sock_proto_props sopp; /* All Solaris components should pass a cred for this operation. */ ASSERT(cr != NULL); connp->conn_upcalls = sock_upcalls; connp->conn_upper_handle = sock_handle; sopp.sopp_flags = SOCKOPT_WROFF | SOCKOPT_RCVHIWAT | SOCKOPT_RCVLOWAT | SOCKOPT_MAXBLK | SOCKOPT_MAXPSZ | SOCKOPT_MINPSZ; sopp.sopp_wroff = connp->conn_icmp->icmp_max_hdr_len + is->is_wroff_extra; sopp.sopp_rxhiwat = is->is_recv_hiwat; sopp.sopp_rxlowat = icmp_mod_info.mi_lowat; sopp.sopp_maxblk = INFPSZ; sopp.sopp_maxpsz = IP_MAXPACKET; sopp.sopp_minpsz = (icmp_mod_info.mi_minpsz == 1) ? 0 : icmp_mod_info.mi_minpsz; (*connp->conn_upcalls->su_set_proto_props) (connp->conn_upper_handle, &sopp); } static int rawip_do_getsockname(icmp_t *icmp, struct sockaddr *sa, uint_t *salenp) { sin_t *sin = (sin_t *)sa; sin6_t *sin6 = (sin6_t *)sa; ASSERT(icmp != NULL); ASSERT(RW_LOCK_HELD(&icmp->icmp_rwlock)); switch (icmp->icmp_family) { case AF_INET: ASSERT(icmp->icmp_ipversion == IPV4_VERSION); if (*salenp < sizeof (sin_t)) return (EINVAL); *salenp = sizeof (sin_t); *sin = sin_null; sin->sin_family = AF_INET; if (icmp->icmp_state == TS_UNBND) { break; } if (!IN6_IS_ADDR_V4MAPPED_ANY(&icmp->icmp_v6src) && !IN6_IS_ADDR_UNSPECIFIED(&icmp->icmp_v6src)) { sin->sin_addr.s_addr = V4_PART_OF_V6(icmp->icmp_v6src); } else { /* * INADDR_ANY * icmp_v6src is not set, we might be bound to * broadcast/multicast. Use icmp_bound_v6src as * local address instead (that could * also still be INADDR_ANY) */ sin->sin_addr.s_addr = V4_PART_OF_V6(icmp->icmp_bound_v6src); } break; case AF_INET6: if (*salenp < sizeof (sin6_t)) return (EINVAL); *salenp = sizeof (sin6_t); *sin6 = sin6_null; sin6->sin6_family = AF_INET6; if (icmp->icmp_state == TS_UNBND) { break; } if (!IN6_IS_ADDR_UNSPECIFIED(&icmp->icmp_v6src)) { sin6->sin6_addr = icmp->icmp_v6src; } else { /* * UNSPECIFIED * icmp_v6src is not set, we might be bound to * broadcast/multicast. Use icmp_bound_v6src as * local address instead (that could * also still be UNSPECIFIED) */ sin6->sin6_addr = icmp->icmp_bound_v6src; } break; } return (0); } static int rawip_do_getpeername(icmp_t *icmp, struct sockaddr *sa, uint_t *salenp) { sin_t *sin = (sin_t *)sa; sin6_t *sin6 = (sin6_t *)sa; ASSERT(icmp != NULL); ASSERT(RW_LOCK_HELD(&icmp->icmp_rwlock)); if (icmp->icmp_state != TS_DATA_XFER) return (ENOTCONN); sa->sa_family = icmp->icmp_family; switch (icmp->icmp_family) { case AF_INET: ASSERT(icmp->icmp_ipversion == IPV4_VERSION); if (*salenp < sizeof (sin_t)) return (EINVAL); *salenp = sizeof (sin_t); *sin = sin_null; sin->sin_family = AF_INET; sin->sin_addr.s_addr = V4_PART_OF_V6(icmp->icmp_v6dst.sin6_addr); break; case AF_INET6: if (*salenp < sizeof (sin6_t)) return (EINVAL); *salenp = sizeof (sin6_t); *sin6 = sin6_null; *sin6 = icmp->icmp_v6dst; break; } return (0); } /* ARGSUSED */ int rawip_getpeername(sock_lower_handle_t proto_handle, struct sockaddr *sa, socklen_t *salenp, cred_t *cr) { conn_t *connp = (conn_t *)proto_handle; icmp_t *icmp = connp->conn_icmp; int error; /* All Solaris components should pass a cred for this operation. */ ASSERT(cr != NULL); ASSERT(icmp != NULL); rw_enter(&icmp->icmp_rwlock, RW_READER); error = rawip_do_getpeername(icmp, sa, salenp); rw_exit(&icmp->icmp_rwlock); return (error); } /* ARGSUSED */ int rawip_getsockname(sock_lower_handle_t proto_handle, struct sockaddr *sa, socklen_t *salenp, cred_t *cr) { conn_t *connp = (conn_t *)proto_handle; icmp_t *icmp = connp->conn_icmp; int error; /* All Solaris components should pass a cred for this operation. */ ASSERT(cr != NULL); ASSERT(icmp != NULL); rw_enter(&icmp->icmp_rwlock, RW_READER); error = rawip_do_getsockname(icmp, sa, salenp); rw_exit(&icmp->icmp_rwlock); return (error); } int rawip_setsockopt(sock_lower_handle_t proto_handle, int level, int option_name, const void *optvalp, socklen_t optlen, cred_t *cr) { conn_t *connp = (conn_t *)proto_handle; icmp_t *icmp = connp->conn_icmp; int error; /* All Solaris components should pass a cred for this operation. */ ASSERT(cr != NULL); error = proto_opt_check(level, option_name, optlen, NULL, icmp_opt_obj.odb_opt_des_arr, icmp_opt_obj.odb_opt_arr_cnt, icmp_opt_obj.odb_topmost_tpiprovider, B_TRUE, B_FALSE, cr); if (error != 0) { /* * option not recognized */ if (error < 0) { error = proto_tlitosyserr(-error); } return (error); } rw_enter(&icmp->icmp_rwlock, RW_WRITER); error = icmp_opt_set(connp, SETFN_OPTCOM_NEGOTIATE, level, option_name, optlen, (uchar_t *)optvalp, (uint_t *)&optlen, (uchar_t *)optvalp, NULL, cr); rw_exit(&icmp->icmp_rwlock); if (error < 0) { /* * Pass on to ip */ error = ip_set_options(connp, level, option_name, optvalp, optlen, cr); } ASSERT(error >= 0); return (error); } int rawip_getsockopt(sock_lower_handle_t proto_handle, int level, int option_name, void *optvalp, socklen_t *optlen, cred_t *cr) { int error; conn_t *connp = (conn_t *)proto_handle; icmp_t *icmp = connp->conn_icmp; t_uscalar_t max_optbuf_len; void *optvalp_buf; int len; /* All Solaris components should pass a cred for this operation. */ ASSERT(cr != NULL); error = proto_opt_check(level, option_name, *optlen, &max_optbuf_len, icmp_opt_obj.odb_opt_des_arr, icmp_opt_obj.odb_opt_arr_cnt, icmp_opt_obj.odb_topmost_tpiprovider, B_FALSE, B_TRUE, cr); if (error != 0) { if (error < 0) { error = proto_tlitosyserr(-error); } return (error); } optvalp_buf = kmem_alloc(max_optbuf_len, KM_SLEEP); rw_enter(&icmp->icmp_rwlock, RW_READER); len = icmp_opt_get(connp, level, option_name, optvalp_buf); rw_exit(&icmp->icmp_rwlock); if (len < 0) { /* * Pass on to IP */ kmem_free(optvalp_buf, max_optbuf_len); return (ip_get_options(connp, level, option_name, optvalp, optlen, cr)); } else { /* * update optlen and copy option value */ t_uscalar_t size = MIN(len, *optlen); bcopy(optvalp_buf, optvalp, size); bcopy(&size, optlen, sizeof (size)); kmem_free(optvalp_buf, max_optbuf_len); return (0); } } /* ARGSUSED */ int rawip_close(sock_lower_handle_t proto_handle, int flags, cred_t *cr) { conn_t *connp = (conn_t *)proto_handle; /* All Solaris components should pass a cred for this operation. */ ASSERT(cr != NULL); (void) rawip_do_close(connp); return (0); } /* ARGSUSED */ int rawip_shutdown(sock_lower_handle_t proto_handle, int how, cred_t *cr) { conn_t *connp = (conn_t *)proto_handle; /* All Solaris components should pass a cred for this operation. */ ASSERT(cr != NULL); /* shut down the send side */ if (how != SHUT_RD) (*connp->conn_upcalls->su_opctl)(connp->conn_upper_handle, SOCK_OPCTL_SHUT_SEND, 0); /* shut down the recv side */ if (how != SHUT_WR) (*connp->conn_upcalls->su_opctl)(connp->conn_upper_handle, SOCK_OPCTL_SHUT_RECV, 0); return (0); } void rawip_clr_flowctrl(sock_lower_handle_t proto_handle) { conn_t *connp = (conn_t *)proto_handle; icmp_t *icmp = connp->conn_icmp; mutex_enter(&icmp->icmp_recv_lock); connp->conn_flow_cntrld = B_FALSE; mutex_exit(&icmp->icmp_recv_lock); } int rawip_ioctl(sock_lower_handle_t proto_handle, int cmd, intptr_t arg, int mode, int32_t *rvalp, cred_t *cr) { conn_t *connp = (conn_t *)proto_handle; int error; /* All Solaris components should pass a cred for this operation. */ ASSERT(cr != NULL); switch (cmd) { case ND_SET: case ND_GET: case _SIOCSOCKFALLBACK: case TI_GETPEERNAME: case TI_GETMYNAME: #ifdef DEBUG cmn_err(CE_CONT, "icmp_ioctl cmd 0x%x on non streams" " socket", cmd); #endif error = EINVAL; break; default: /* * Pass on to IP using helper stream */ error = ldi_ioctl(connp->conn_helper_info->iphs_handle, cmd, arg, mode, cr, rvalp); break; } return (error); } /* ARGSUSED */ int rawip_send(sock_lower_handle_t proto_handle, mblk_t *mp, struct nmsghdr *msg, cred_t *cr) { conn_t *connp = (conn_t *)proto_handle; icmp_t *icmp = connp->conn_icmp; icmp_stack_t *is = icmp->icmp_is; int error = 0; boolean_t bypass_dgram_errind = B_FALSE; ASSERT(DB_TYPE(mp) == M_DATA); /* All Solaris components should pass a cred for this operation. */ ASSERT(cr != NULL); /* If labeled then sockfs should have already set db_credp */ ASSERT(!is_system_labeled() || msg_getcred(mp, NULL) != NULL); /* do an implicit bind if necessary */ if (icmp->icmp_state == TS_UNBND) { error = rawip_implicit_bind(connp); /* * We could be racing with an actual bind, in which case * we would see EPROTO. We cross our fingers and try * to connect. */ if (!(error == 0 || error == EPROTO)) { freemsg(mp); return (error); } } rw_enter(&icmp->icmp_rwlock, RW_WRITER); if (msg->msg_name != NULL && icmp->icmp_state == TS_DATA_XFER) { error = EISCONN; goto done_lock; } switch (icmp->icmp_family) { case AF_INET6: { sin6_t *sin6; ip6_pkt_t ipp_s; /* For ancillary data options */ ip6_pkt_t *ipp = &ipp_s; sin6 = (sin6_t *)msg->msg_name; if (sin6 != NULL) { error = proto_verify_ip_addr(icmp->icmp_family, (struct sockaddr *)msg->msg_name, msg->msg_namelen); if (error != 0) { bypass_dgram_errind = B_TRUE; goto done_lock; } if (icmp->icmp_delayed_error != 0) { sin6_t *sin1 = (sin6_t *)msg->msg_name; sin6_t *sin2 = (sin6_t *) &icmp->icmp_delayed_addr; error = icmp->icmp_delayed_error; icmp->icmp_delayed_error = 0; /* Compare IP address and port */ if (sin1->sin6_port == sin2->sin6_port && IN6_ARE_ADDR_EQUAL(&sin1->sin6_addr, &sin2->sin6_addr)) { goto done_lock; } } } else { /* * Use connected address */ if (icmp->icmp_state != TS_DATA_XFER) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); error = EDESTADDRREQ; bypass_dgram_errind = B_TRUE; goto done_lock; } sin6 = &icmp->icmp_v6dst; } /* No support for mapped addresses on raw sockets */ if (IN6_IS_ADDR_V4MAPPED(&sin6->sin6_addr)) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); error = EADDRNOTAVAIL; goto done_lock; } ipp->ipp_fields = 0; ipp->ipp_sticky_ignored = 0; /* * If options passed in, feed it for verification and handling */ if (msg->msg_controllen != 0) { error = process_auxiliary_options(connp, msg->msg_control, msg->msg_controllen, ipp, &icmp_opt_obj, icmp_opt_set, cr); if (error != 0) { goto done_lock; } } rw_exit(&icmp->icmp_rwlock); /* * Destination is a native IPv6 address. * Send out an IPv6 format packet. */ error = raw_ip_send_data_v6(connp->conn_wq, connp, mp, sin6, ipp); } break; case AF_INET: { sin_t *sin; ip4_pkt_t pktinfo; ip4_pkt_t *pktinfop = &pktinfo; ipaddr_t v4dst; sin = (sin_t *)msg->msg_name; if (sin != NULL) { error = proto_verify_ip_addr(icmp->icmp_family, (struct sockaddr *)msg->msg_name, msg->msg_namelen); if (error != 0) { bypass_dgram_errind = B_TRUE; goto done_lock; } v4dst = sin->sin_addr.s_addr; if (icmp->icmp_delayed_error != 0) { sin_t *sin1 = (sin_t *)msg->msg_name; sin_t *sin2 = (sin_t *)&icmp->icmp_delayed_addr; error = icmp->icmp_delayed_error; icmp->icmp_delayed_error = 0; /* Compare IP address and port */ if (sin1->sin_port == sin2->sin_port && sin1->sin_addr.s_addr == sin2->sin_addr.s_addr) { goto done_lock; } } } else { /* * Use connected address */ if (icmp->icmp_state != TS_DATA_XFER) { BUMP_MIB(&is->is_rawip_mib, rawipOutErrors); error = EDESTADDRREQ; bypass_dgram_errind = B_TRUE; goto done_lock; } v4dst = V4_PART_OF_V6(icmp->icmp_v6dst.sin6_addr); } pktinfop->ip4_ill_index = 0; pktinfop->ip4_addr = INADDR_ANY; /* * If options passed in, feed it for verification and handling */ if (msg->msg_controllen != 0) { error = process_auxiliary_options(connp, msg->msg_control, msg->msg_controllen, pktinfop, &icmp_opt_obj, icmp_opt_set, cr); if (error != 0) { goto done_lock; } } rw_exit(&icmp->icmp_rwlock); error = raw_ip_send_data_v4(connp->conn_wq, connp, mp, v4dst, pktinfop); break; } default: ASSERT(0); } goto done; done_lock: rw_exit(&icmp->icmp_rwlock); if (error != 0) { ASSERT(mp != NULL); freemsg(mp); } done: if (bypass_dgram_errind) return (error); return (icmp->icmp_dgram_errind ? error : 0); } sock_downcalls_t sock_rawip_downcalls = { rawip_activate, rawip_accept, rawip_bind, rawip_listen, rawip_connect, rawip_getpeername, rawip_getsockname, rawip_getsockopt, rawip_setsockopt, rawip_send, NULL, NULL, NULL, rawip_shutdown, rawip_clr_flowctrl, rawip_ioctl, rawip_close };