11676Sjpk /* 21676Sjpk * CDDL HEADER START 31676Sjpk * 41676Sjpk * The contents of this file are subject to the terms of the 51676Sjpk * Common Development and Distribution License (the "License"). 61676Sjpk * You may not use this file except in compliance with the License. 71676Sjpk * 81676Sjpk * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 91676Sjpk * or http://www.opensolaris.org/os/licensing. 101676Sjpk * See the License for the specific language governing permissions 111676Sjpk * and limitations under the License. 121676Sjpk * 131676Sjpk * When distributing Covered Code, include this CDDL HEADER in each 141676Sjpk * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 151676Sjpk * If applicable, add the following below this CDDL HEADER, with the 161676Sjpk * fields enclosed by brackets "[]" replaced with your own identifying 171676Sjpk * information: Portions Copyright [yyyy] [name of copyright owner] 181676Sjpk * 191676Sjpk * CDDL HEADER END 201676Sjpk */ 211676Sjpk /* 22*8778SErik.Nordmark@Sun.COM * Copyright 2009 Sun Microsystems, Inc. All rights reserved. 231676Sjpk * Use is subject to license terms. 241676Sjpk */ 251676Sjpk 261676Sjpk #include <sys/types.h> 271676Sjpk #include <sys/stream.h> 281676Sjpk #include <sys/strsubr.h> 291676Sjpk #include <sys/stropts.h> 301676Sjpk #include <sys/sunddi.h> 311676Sjpk #include <sys/cred.h> 321676Sjpk #include <sys/debug.h> 331676Sjpk #include <sys/kmem.h> 341676Sjpk #include <sys/errno.h> 351676Sjpk #include <sys/disp.h> 361676Sjpk #include <netinet/in.h> 371676Sjpk #include <netinet/in_systm.h> 381676Sjpk #include <netinet/ip.h> 391676Sjpk #include <netinet/ip_icmp.h> 401676Sjpk #include <netinet/tcp.h> 411676Sjpk #include <inet/common.h> 421676Sjpk #include <inet/ipclassifier.h> 431676Sjpk #include <inet/ip.h> 441676Sjpk #include <inet/mib2.h> 451676Sjpk #include <inet/nd.h> 461676Sjpk #include <inet/tcp.h> 471676Sjpk #include <inet/ip_rts.h> 481676Sjpk #include <inet/ip_ire.h> 491676Sjpk #include <inet/ip_if.h> 501676Sjpk #include <sys/modhash.h> 511676Sjpk 521676Sjpk #include <sys/tsol/label.h> 531676Sjpk #include <sys/tsol/label_macro.h> 541676Sjpk #include <sys/tsol/tnet.h> 551676Sjpk #include <sys/tsol/tndb.h> 561676Sjpk #include <sys/strsun.h> 571676Sjpk 581676Sjpk /* tunable for strict error-reply behavior (TCP RST and ICMP Unreachable) */ 591676Sjpk int tsol_strict_error; 601676Sjpk 611676Sjpk /* 621676Sjpk * Some notes on the Trusted Solaris IRE gateway security attributes: 631676Sjpk * 641676Sjpk * When running in Trusted mode, the routing subsystem determines whether or 651676Sjpk * not a packet can be delivered to an off-link host (not directly reachable 661676Sjpk * through an interface) based on the accreditation checks of the packet's 671676Sjpk * security attributes against those associated with the next-hop gateway. 681676Sjpk * 691676Sjpk * The next-hop gateway's security attributes can be derived from two sources 701676Sjpk * (in order of preference): route-related and the host database. A Trusted 711676Sjpk * system must be configured with at least the host database containing an 721676Sjpk * entry for the next-hop gateway, or otherwise no accreditation checks can 731676Sjpk * be performed, which may result in the inability to send packets to any 741676Sjpk * off-link destination host. 751676Sjpk * 761676Sjpk * The major differences between the two sources are the number and type of 771676Sjpk * security attributes used for accreditation checks. A host database entry 781676Sjpk * can contain at most one set of security attributes, specific only to the 791676Sjpk * next-hop gateway. On contrast, route-related security attributes are made 801676Sjpk * up of a collection of security attributes for the distant networks, and 811676Sjpk * are grouped together per next-hop gateway used to reach those networks. 821676Sjpk * This is the preferred method, and the routing subsystem will fallback to 831676Sjpk * the host database entry only if there are no route-related attributes 841676Sjpk * associated with the next-hop gateway. 851676Sjpk * 861676Sjpk * In Trusted mode, all of the IRE entries (except LOCAL/LOOPBACK/BROADCAST/ 871676Sjpk * INTERFACE type) are initialized to contain a placeholder to store this 881676Sjpk * information. The ire_gw_secattr structure gets allocated, initialized 891676Sjpk * and associated with the IRE during the time of the IRE creation. The 901676Sjpk * initialization process also includes resolving the host database entry 911676Sjpk * of the next-hop gateway for fallback purposes. It does not include any 921676Sjpk * route-related attribute setup, as that process comes separately as part 931676Sjpk * of the route requests (add/change) made to the routing subsystem. 941676Sjpk * 951676Sjpk * The underlying logic which involves associating IREs with the gateway 961676Sjpk * security attributes are represented by the following data structures: 971676Sjpk * 981676Sjpk * tsol_gcdb_t, or "gcdb" 991676Sjpk * 1001676Sjpk * - This is a system-wide collection of records containing the 1011676Sjpk * currently used route-related security attributes, which are fed 1021676Sjpk * through the routing socket interface, e.g. "route add/change". 1031676Sjpk * 1041676Sjpk * tsol_gc_t, or "gc" 1051676Sjpk * 1061676Sjpk * - This is the gateway credential structure, and it provides for the 1071676Sjpk * only mechanism to access the contents of gcdb. More than one gc 1081676Sjpk * entries may refer to the same gcdb record. gc's in the system are 1091676Sjpk * grouped according to the next-hop gateway address. 1101676Sjpk * 1111676Sjpk * tsol_gcgrp_t, or "gcgrp" 1121676Sjpk * 1131676Sjpk * - Group of gateway credentials, and is unique per next-hop gateway 1141676Sjpk * address. When the group is not empty, i.e. when gcgrp_count is 1151676Sjpk * greater than zero, it contains one or more gc's, each pointing to 1161676Sjpk * a gcdb record which indicates the gateway security attributes 1171676Sjpk * associated with the next-hop gateway. 1181676Sjpk * 1191676Sjpk * The fields of the tsol_ire_gw_secattr_t used from within the IRE are: 1201676Sjpk * 1211676Sjpk * igsa_lock 1221676Sjpk * 1231676Sjpk * - Lock that protects all fields within tsol_ire_gw_secattr_t. 1241676Sjpk * 1251676Sjpk * igsa_rhc 1261676Sjpk * 1271676Sjpk * - Remote host cache database entry of next-hop gateway. This is 1281676Sjpk * used in the case when there are no route-related attributes 1291676Sjpk * configured for the IRE. 1301676Sjpk * 1311676Sjpk * igsa_gc 1321676Sjpk * 1331676Sjpk * - A set of route-related attributes that only get set for prefix 1341676Sjpk * IREs. If this is non-NULL, the prefix IRE has been associated 1351676Sjpk * with a set of gateway security attributes by way of route add/ 1361676Sjpk * change functionality. This field stays NULL for IRE_CACHEs. 1371676Sjpk * 1381676Sjpk * igsa_gcgrp 1391676Sjpk * 1401676Sjpk * - Group of gc's which only gets set for IRE_CACHEs. Each of the gc 1411676Sjpk * points to a gcdb record that contains the security attributes 1421676Sjpk * used to perform the credential checks of the packet which uses 1431676Sjpk * the IRE. If the group is not empty, the list of gc's can be 1441676Sjpk * traversed starting at gcgrp_head. This field stays NULL for 1451676Sjpk * prefix IREs. 1461676Sjpk */ 1471676Sjpk 1481676Sjpk static kmem_cache_t *ire_gw_secattr_cache; 1491676Sjpk 1501676Sjpk #define GCDB_HASH_SIZE 101 1511676Sjpk #define GCGRP_HASH_SIZE 101 1521676Sjpk 1531676Sjpk #define GCDB_REFRELE(p) { \ 1541676Sjpk mutex_enter(&gcdb_lock); \ 1551676Sjpk ASSERT((p)->gcdb_refcnt > 0); \ 1561676Sjpk if (--((p)->gcdb_refcnt) == 0) \ 1571676Sjpk gcdb_inactive(p); \ 1581676Sjpk ASSERT(MUTEX_HELD(&gcdb_lock)); \ 1591676Sjpk mutex_exit(&gcdb_lock); \ 1601676Sjpk } 1611676Sjpk 1621676Sjpk static int gcdb_hash_size = GCDB_HASH_SIZE; 1631676Sjpk static int gcgrp_hash_size = GCGRP_HASH_SIZE; 1641676Sjpk static mod_hash_t *gcdb_hash; 1651676Sjpk static mod_hash_t *gcgrp4_hash; 1661676Sjpk static mod_hash_t *gcgrp6_hash; 1671676Sjpk 1681676Sjpk static kmutex_t gcdb_lock; 1691676Sjpk kmutex_t gcgrp_lock; 1701676Sjpk 1711676Sjpk static uint_t gcdb_hash_by_secattr(void *, mod_hash_key_t); 1721676Sjpk static int gcdb_hash_cmp(mod_hash_key_t, mod_hash_key_t); 1731676Sjpk static tsol_gcdb_t *gcdb_lookup(struct rtsa_s *, boolean_t); 1741676Sjpk static void gcdb_inactive(tsol_gcdb_t *); 1751676Sjpk 1761676Sjpk static uint_t gcgrp_hash_by_addr(void *, mod_hash_key_t); 1771676Sjpk static int gcgrp_hash_cmp(mod_hash_key_t, mod_hash_key_t); 1781676Sjpk 1791676Sjpk static int ire_gw_secattr_constructor(void *, void *, int); 1801676Sjpk static void ire_gw_secattr_destructor(void *, void *); 1811676Sjpk 1821676Sjpk void 1831676Sjpk tnet_init(void) 1841676Sjpk { 1851676Sjpk ire_gw_secattr_cache = kmem_cache_create("ire_gw_secattr_cache", 1861676Sjpk sizeof (tsol_ire_gw_secattr_t), 64, ire_gw_secattr_constructor, 1871676Sjpk ire_gw_secattr_destructor, NULL, NULL, NULL, 0); 1881676Sjpk 1891676Sjpk gcdb_hash = mod_hash_create_extended("gcdb_hash", 1901676Sjpk gcdb_hash_size, mod_hash_null_keydtor, mod_hash_null_valdtor, 1911676Sjpk gcdb_hash_by_secattr, NULL, gcdb_hash_cmp, KM_SLEEP); 1921676Sjpk 1931676Sjpk gcgrp4_hash = mod_hash_create_extended("gcgrp4_hash", 1941676Sjpk gcgrp_hash_size, mod_hash_null_keydtor, mod_hash_null_valdtor, 1951676Sjpk gcgrp_hash_by_addr, NULL, gcgrp_hash_cmp, KM_SLEEP); 1961676Sjpk 1971676Sjpk gcgrp6_hash = mod_hash_create_extended("gcgrp6_hash", 1981676Sjpk gcgrp_hash_size, mod_hash_null_keydtor, mod_hash_null_valdtor, 1991676Sjpk gcgrp_hash_by_addr, NULL, gcgrp_hash_cmp, KM_SLEEP); 2001676Sjpk 2011676Sjpk mutex_init(&gcdb_lock, NULL, MUTEX_DEFAULT, NULL); 2021676Sjpk mutex_init(&gcgrp_lock, NULL, MUTEX_DEFAULT, NULL); 2031676Sjpk } 2041676Sjpk 2051676Sjpk void 2061676Sjpk tnet_fini(void) 2071676Sjpk { 2081676Sjpk kmem_cache_destroy(ire_gw_secattr_cache); 2091676Sjpk mod_hash_destroy_hash(gcdb_hash); 2101676Sjpk mod_hash_destroy_hash(gcgrp4_hash); 2111676Sjpk mod_hash_destroy_hash(gcgrp6_hash); 2121676Sjpk mutex_destroy(&gcdb_lock); 2131676Sjpk mutex_destroy(&gcgrp_lock); 2141676Sjpk } 2151676Sjpk 2161676Sjpk /* ARGSUSED */ 2171676Sjpk static int 2181676Sjpk ire_gw_secattr_constructor(void *buf, void *cdrarg, int kmflags) 2191676Sjpk { 2201676Sjpk tsol_ire_gw_secattr_t *attrp = buf; 2211676Sjpk 2221676Sjpk mutex_init(&attrp->igsa_lock, NULL, MUTEX_DEFAULT, NULL); 2231676Sjpk 2241676Sjpk attrp->igsa_rhc = NULL; 2251676Sjpk attrp->igsa_gc = NULL; 2261676Sjpk attrp->igsa_gcgrp = NULL; 2271676Sjpk 2281676Sjpk return (0); 2291676Sjpk } 2301676Sjpk 2311676Sjpk /* ARGSUSED */ 2321676Sjpk static void 2331676Sjpk ire_gw_secattr_destructor(void *buf, void *cdrarg) 2341676Sjpk { 2351676Sjpk tsol_ire_gw_secattr_t *attrp = (tsol_ire_gw_secattr_t *)buf; 2361676Sjpk 2371676Sjpk mutex_destroy(&attrp->igsa_lock); 2381676Sjpk } 2391676Sjpk 2401676Sjpk tsol_ire_gw_secattr_t * 2411676Sjpk ire_gw_secattr_alloc(int kmflags) 2421676Sjpk { 2431676Sjpk return (kmem_cache_alloc(ire_gw_secattr_cache, kmflags)); 2441676Sjpk } 2451676Sjpk 2461676Sjpk void 2471676Sjpk ire_gw_secattr_free(tsol_ire_gw_secattr_t *attrp) 2481676Sjpk { 2491676Sjpk ASSERT(MUTEX_NOT_HELD(&attrp->igsa_lock)); 2501676Sjpk 2511676Sjpk if (attrp->igsa_rhc != NULL) { 2521676Sjpk TNRHC_RELE(attrp->igsa_rhc); 2531676Sjpk attrp->igsa_rhc = NULL; 2541676Sjpk } 2551676Sjpk 2561676Sjpk if (attrp->igsa_gc != NULL) { 2571676Sjpk GC_REFRELE(attrp->igsa_gc); 2581676Sjpk attrp->igsa_gc = NULL; 2591676Sjpk } 2601676Sjpk if (attrp->igsa_gcgrp != NULL) { 2611676Sjpk GCGRP_REFRELE(attrp->igsa_gcgrp); 2621676Sjpk attrp->igsa_gcgrp = NULL; 2631676Sjpk } 2641676Sjpk 2651676Sjpk ASSERT(attrp->igsa_rhc == NULL); 2661676Sjpk ASSERT(attrp->igsa_gc == NULL); 2671676Sjpk ASSERT(attrp->igsa_gcgrp == NULL); 2681676Sjpk 2691676Sjpk kmem_cache_free(ire_gw_secattr_cache, attrp); 2701676Sjpk } 2711676Sjpk 2721676Sjpk /* ARGSUSED */ 2731676Sjpk static uint_t 2741676Sjpk gcdb_hash_by_secattr(void *hash_data, mod_hash_key_t key) 2751676Sjpk { 2761676Sjpk const struct rtsa_s *rp = (struct rtsa_s *)key; 2771676Sjpk const uint32_t *up, *ue; 2781676Sjpk uint_t hash; 2791676Sjpk int i; 2801676Sjpk 2811676Sjpk ASSERT(rp != NULL); 2821676Sjpk 2831676Sjpk /* See comments in hash_bylabel in zone.c for details */ 2841676Sjpk hash = rp->rtsa_doi + (rp->rtsa_doi << 1); 2851676Sjpk up = (const uint32_t *)&rp->rtsa_slrange; 2861676Sjpk ue = up + sizeof (rp->rtsa_slrange) / sizeof (*up); 2871676Sjpk i = 1; 2881676Sjpk while (up < ue) { 2891676Sjpk /* using 2^n + 1, 1 <= n <= 16 as source of many primes */ 2901676Sjpk hash += *up + (*up << ((i % 16) + 1)); 2911676Sjpk up++; 2921676Sjpk i++; 2931676Sjpk } 2941676Sjpk return (hash); 2951676Sjpk } 2961676Sjpk 2971676Sjpk static int 2981676Sjpk gcdb_hash_cmp(mod_hash_key_t key1, mod_hash_key_t key2) 2991676Sjpk { 3001676Sjpk struct rtsa_s *rp1 = (struct rtsa_s *)key1; 3011676Sjpk struct rtsa_s *rp2 = (struct rtsa_s *)key2; 3021676Sjpk 3031676Sjpk ASSERT(rp1 != NULL && rp2 != NULL); 3041676Sjpk 3051676Sjpk if (blequal(&rp1->rtsa_slrange.lower_bound, 3061676Sjpk &rp2->rtsa_slrange.lower_bound) && 3071676Sjpk blequal(&rp1->rtsa_slrange.upper_bound, 3081676Sjpk &rp2->rtsa_slrange.upper_bound) && 3091676Sjpk rp1->rtsa_doi == rp2->rtsa_doi) 3101676Sjpk return (0); 3111676Sjpk 3121676Sjpk /* No match; not found */ 3131676Sjpk return (-1); 3141676Sjpk } 3151676Sjpk 3161676Sjpk /* ARGSUSED */ 3171676Sjpk static uint_t 3181676Sjpk gcgrp_hash_by_addr(void *hash_data, mod_hash_key_t key) 3191676Sjpk { 3201676Sjpk tsol_gcgrp_addr_t *ga = (tsol_gcgrp_addr_t *)key; 3211676Sjpk uint_t idx = 0; 3221676Sjpk uint32_t *ap; 3231676Sjpk 3241676Sjpk ASSERT(ga != NULL); 3251676Sjpk ASSERT(ga->ga_af == AF_INET || ga->ga_af == AF_INET6); 3261676Sjpk 3271676Sjpk ap = (uint32_t *)&ga->ga_addr.s6_addr32[0]; 3281676Sjpk idx ^= *ap++; 3291676Sjpk idx ^= *ap++; 3301676Sjpk idx ^= *ap++; 3311676Sjpk idx ^= *ap; 3321676Sjpk 3331676Sjpk return (idx); 3341676Sjpk } 3351676Sjpk 3361676Sjpk static int 3371676Sjpk gcgrp_hash_cmp(mod_hash_key_t key1, mod_hash_key_t key2) 3381676Sjpk { 3391676Sjpk tsol_gcgrp_addr_t *ga1 = (tsol_gcgrp_addr_t *)key1; 3401676Sjpk tsol_gcgrp_addr_t *ga2 = (tsol_gcgrp_addr_t *)key2; 3411676Sjpk 3421676Sjpk ASSERT(ga1 != NULL && ga2 != NULL); 3431676Sjpk 3441676Sjpk /* Address family must match */ 3451676Sjpk if (ga1->ga_af != ga2->ga_af) 3461676Sjpk return (-1); 3471676Sjpk 3481676Sjpk if (ga1->ga_addr.s6_addr32[0] == ga2->ga_addr.s6_addr32[0] && 3491676Sjpk ga1->ga_addr.s6_addr32[1] == ga2->ga_addr.s6_addr32[1] && 3501676Sjpk ga1->ga_addr.s6_addr32[2] == ga2->ga_addr.s6_addr32[2] && 3511676Sjpk ga1->ga_addr.s6_addr32[3] == ga2->ga_addr.s6_addr32[3]) 3521676Sjpk return (0); 3531676Sjpk 3541676Sjpk /* No match; not found */ 3551676Sjpk return (-1); 3561676Sjpk } 3571676Sjpk 3581676Sjpk #define RTSAFLAGS "\20\11cipso\3doi\2max_sl\1min_sl" 3591676Sjpk 3601676Sjpk int 3611676Sjpk rtsa_validate(const struct rtsa_s *rp) 3621676Sjpk { 3631676Sjpk uint32_t mask = rp->rtsa_mask; 3641676Sjpk 3651676Sjpk /* RTSA_CIPSO must be set, and DOI must not be zero */ 3661676Sjpk if ((mask & RTSA_CIPSO) == 0 || rp->rtsa_doi == 0) { 3671676Sjpk DTRACE_PROBE2(tx__gcdb__log__error__rtsa__validate, char *, 3681676Sjpk "rtsa(1) lacks flag or has 0 doi.", 3691676Sjpk rtsa_s *, rp); 3701676Sjpk return (EINVAL); 3711676Sjpk } 3721676Sjpk /* 3731676Sjpk * SL range must be specified, and it must have its 3741676Sjpk * upper bound dominating its lower bound. 3751676Sjpk */ 3761676Sjpk if ((mask & RTSA_SLRANGE) != RTSA_SLRANGE || 3771676Sjpk !bldominates(&rp->rtsa_slrange.upper_bound, 3781676Sjpk &rp->rtsa_slrange.lower_bound)) { 3791676Sjpk DTRACE_PROBE2(tx__gcdb__log__error__rtsa__validate, char *, 3801676Sjpk "rtsa(1) min_sl and max_sl not set or max_sl is " 3811676Sjpk "not dominating.", rtsa_s *, rp); 3821676Sjpk return (EINVAL); 3831676Sjpk } 3841676Sjpk return (0); 3851676Sjpk } 3861676Sjpk 3871676Sjpk /* 3881676Sjpk * A brief explanation of the reference counting scheme: 3891676Sjpk * 3901676Sjpk * Prefix IREs have a non-NULL igsa_gc and a NULL igsa_gcgrp; 3911676Sjpk * IRE_CACHEs have it vice-versa. 3921676Sjpk * 3931676Sjpk * Apart from dynamic references due to to reference holds done 3941676Sjpk * actively by threads, we have the following references: 3951676Sjpk * 3961676Sjpk * gcdb_refcnt: 3971676Sjpk * - Every tsol_gc_t pointing to a tsol_gcdb_t contributes a reference 3981676Sjpk * to the gcdb_refcnt. 3991676Sjpk * 4001676Sjpk * gc_refcnt: 4011676Sjpk * - A prefix IRE that points to an igsa_gc contributes a reference 4021676Sjpk * to the gc_refcnt. 4031676Sjpk * 4041676Sjpk * gcgrp_refcnt: 4051676Sjpk * - An IRE_CACHE that points to an igsa_gcgrp contributes a reference 4061676Sjpk * to the gcgrp_refcnt of the associated tsol_gcgrp_t. 4071676Sjpk * - Every tsol_gc_t in the chain headed by tsol_gcgrp_t contributes 4081676Sjpk * a reference to the gcgrp_refcnt. 4091676Sjpk */ 4101676Sjpk static tsol_gcdb_t * 4111676Sjpk gcdb_lookup(struct rtsa_s *rp, boolean_t alloc) 4121676Sjpk { 4131676Sjpk tsol_gcdb_t *gcdb = NULL; 4141676Sjpk 4151676Sjpk if (rtsa_validate(rp) != 0) 4161676Sjpk return (NULL); 4171676Sjpk 4181676Sjpk mutex_enter(&gcdb_lock); 4191676Sjpk /* Find a copy in the cache; otherwise, create one and cache it */ 4201676Sjpk if (mod_hash_find(gcdb_hash, (mod_hash_key_t)rp, 4211676Sjpk (mod_hash_val_t *)&gcdb) == 0) { 4221676Sjpk gcdb->gcdb_refcnt++; 4231676Sjpk ASSERT(gcdb->gcdb_refcnt != 0); 4241676Sjpk 4251676Sjpk DTRACE_PROBE2(tx__gcdb__log__info__gcdb__lookup, char *, 4261676Sjpk "gcdb(1) is in gcdb_hash(global)", tsol_gcdb_t *, gcdb); 4271676Sjpk } else if (alloc) { 4281676Sjpk gcdb = kmem_zalloc(sizeof (*gcdb), KM_NOSLEEP); 4291676Sjpk if (gcdb != NULL) { 4301676Sjpk gcdb->gcdb_refcnt = 1; 4311676Sjpk gcdb->gcdb_mask = rp->rtsa_mask; 4321676Sjpk gcdb->gcdb_doi = rp->rtsa_doi; 4331676Sjpk gcdb->gcdb_slrange = rp->rtsa_slrange; 4341676Sjpk 4351676Sjpk if (mod_hash_insert(gcdb_hash, 4361676Sjpk (mod_hash_key_t)&gcdb->gcdb_attr, 4371676Sjpk (mod_hash_val_t)gcdb) != 0) { 4381676Sjpk mutex_exit(&gcdb_lock); 4391676Sjpk kmem_free(gcdb, sizeof (*gcdb)); 4401676Sjpk return (NULL); 4411676Sjpk } 4421676Sjpk 4431676Sjpk DTRACE_PROBE2(tx__gcdb__log__info__gcdb__insert, char *, 4441676Sjpk "gcdb(1) inserted in gcdb_hash(global)", 4451676Sjpk tsol_gcdb_t *, gcdb); 4461676Sjpk } 4471676Sjpk } 4481676Sjpk mutex_exit(&gcdb_lock); 4491676Sjpk return (gcdb); 4501676Sjpk } 4511676Sjpk 4521676Sjpk static void 4531676Sjpk gcdb_inactive(tsol_gcdb_t *gcdb) 4541676Sjpk { 4551676Sjpk ASSERT(MUTEX_HELD(&gcdb_lock)); 4561676Sjpk ASSERT(gcdb != NULL && gcdb->gcdb_refcnt == 0); 4571676Sjpk 4581676Sjpk (void) mod_hash_remove(gcdb_hash, (mod_hash_key_t)&gcdb->gcdb_attr, 4591676Sjpk (mod_hash_val_t *)&gcdb); 4601676Sjpk 4611676Sjpk DTRACE_PROBE2(tx__gcdb__log__info__gcdb__remove, char *, 4621676Sjpk "gcdb(1) removed from gcdb_hash(global)", 4631676Sjpk tsol_gcdb_t *, gcdb); 4641676Sjpk kmem_free(gcdb, sizeof (*gcdb)); 4651676Sjpk } 4661676Sjpk 4671676Sjpk tsol_gc_t * 4681676Sjpk gc_create(struct rtsa_s *rp, tsol_gcgrp_t *gcgrp, boolean_t *gcgrp_xtrarefp) 4691676Sjpk { 4701676Sjpk tsol_gc_t *gc; 4711676Sjpk tsol_gcdb_t *gcdb; 4721676Sjpk 4731676Sjpk *gcgrp_xtrarefp = B_TRUE; 4741676Sjpk 4751676Sjpk rw_enter(&gcgrp->gcgrp_rwlock, RW_WRITER); 4761676Sjpk if ((gcdb = gcdb_lookup(rp, B_TRUE)) == NULL) { 4771676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 4781676Sjpk return (NULL); 4791676Sjpk } 4801676Sjpk 4811676Sjpk for (gc = gcgrp->gcgrp_head; gc != NULL; gc = gc->gc_next) { 4821676Sjpk if (gc->gc_db == gcdb) { 4831676Sjpk ASSERT(gc->gc_grp == gcgrp); 4841676Sjpk 4851676Sjpk gc->gc_refcnt++; 4861676Sjpk ASSERT(gc->gc_refcnt != 0); 4871676Sjpk 4881676Sjpk GCDB_REFRELE(gcdb); 4891676Sjpk 4901676Sjpk DTRACE_PROBE3(tx__gcdb__log__info__gc__create, 4911676Sjpk char *, "found gc(1) in gcgrp(2)", 4921676Sjpk tsol_gc_t *, gc, tsol_gcgrp_t *, gcgrp); 4931676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 4941676Sjpk return (gc); 4951676Sjpk } 4961676Sjpk } 4971676Sjpk 4981676Sjpk gc = kmem_zalloc(sizeof (*gc), KM_NOSLEEP); 4991676Sjpk if (gc != NULL) { 5001676Sjpk if (gcgrp->gcgrp_head == NULL) { 5011676Sjpk gcgrp->gcgrp_head = gcgrp->gcgrp_tail = gc; 5021676Sjpk } else { 5031676Sjpk gcgrp->gcgrp_tail->gc_next = gc; 5041676Sjpk gc->gc_prev = gcgrp->gcgrp_tail; 5051676Sjpk gcgrp->gcgrp_tail = gc; 5061676Sjpk } 5071676Sjpk gcgrp->gcgrp_count++; 5081676Sjpk ASSERT(gcgrp->gcgrp_count != 0); 5091676Sjpk 5101676Sjpk /* caller has incremented gcgrp reference for us */ 5111676Sjpk gc->gc_grp = gcgrp; 5121676Sjpk 5131676Sjpk gc->gc_db = gcdb; 5141676Sjpk gc->gc_refcnt = 1; 5151676Sjpk 5161676Sjpk DTRACE_PROBE3(tx__gcdb__log__info__gc__create, char *, 5171676Sjpk "added gc(1) to gcgrp(2)", tsol_gc_t *, gc, 5181676Sjpk tsol_gcgrp_t *, gcgrp); 5191676Sjpk 5201676Sjpk *gcgrp_xtrarefp = B_FALSE; 5211676Sjpk } 5221676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 5231676Sjpk 5241676Sjpk return (gc); 5251676Sjpk } 5261676Sjpk 5271676Sjpk void 5281676Sjpk gc_inactive(tsol_gc_t *gc) 5291676Sjpk { 5301676Sjpk tsol_gcgrp_t *gcgrp = gc->gc_grp; 5311676Sjpk 5321676Sjpk ASSERT(gcgrp != NULL); 5331676Sjpk ASSERT(RW_WRITE_HELD(&gcgrp->gcgrp_rwlock)); 5341676Sjpk ASSERT(gc->gc_refcnt == 0); 5351676Sjpk 5361676Sjpk if (gc->gc_prev != NULL) 5371676Sjpk gc->gc_prev->gc_next = gc->gc_next; 5381676Sjpk else 5391676Sjpk gcgrp->gcgrp_head = gc->gc_next; 5401676Sjpk if (gc->gc_next != NULL) 5411676Sjpk gc->gc_next->gc_prev = gc->gc_prev; 5421676Sjpk else 5431676Sjpk gcgrp->gcgrp_tail = gc->gc_prev; 5441676Sjpk ASSERT(gcgrp->gcgrp_count > 0); 5451676Sjpk gcgrp->gcgrp_count--; 5461676Sjpk 5471676Sjpk /* drop lock before it's destroyed */ 5481676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 5491676Sjpk 5501676Sjpk DTRACE_PROBE3(tx__gcdb__log__info__gc__remove, char *, 5511676Sjpk "removed inactive gc(1) from gcgrp(2)", 5521676Sjpk tsol_gc_t *, gc, tsol_gcgrp_t *, gcgrp); 5531676Sjpk 5541676Sjpk GCGRP_REFRELE(gcgrp); 5551676Sjpk 5561676Sjpk gc->gc_grp = NULL; 5571676Sjpk gc->gc_prev = gc->gc_next = NULL; 5581676Sjpk 5591676Sjpk if (gc->gc_db != NULL) 5601676Sjpk GCDB_REFRELE(gc->gc_db); 5611676Sjpk 5621676Sjpk kmem_free(gc, sizeof (*gc)); 5631676Sjpk } 5641676Sjpk 5651676Sjpk tsol_gcgrp_t * 5661676Sjpk gcgrp_lookup(tsol_gcgrp_addr_t *ga, boolean_t alloc) 5671676Sjpk { 5681676Sjpk tsol_gcgrp_t *gcgrp = NULL; 5691676Sjpk mod_hash_t *hashp; 5701676Sjpk 5711676Sjpk ASSERT(ga->ga_af == AF_INET || ga->ga_af == AF_INET6); 5721676Sjpk 5731676Sjpk hashp = (ga->ga_af == AF_INET) ? gcgrp4_hash : gcgrp6_hash; 5741676Sjpk 5751676Sjpk mutex_enter(&gcgrp_lock); 5761676Sjpk if (mod_hash_find(hashp, (mod_hash_key_t)ga, 5771676Sjpk (mod_hash_val_t *)&gcgrp) == 0) { 5781676Sjpk gcgrp->gcgrp_refcnt++; 5791676Sjpk ASSERT(gcgrp->gcgrp_refcnt != 0); 5801676Sjpk 5811676Sjpk DTRACE_PROBE3(tx__gcdb__log__info__gcgrp__lookup, char *, 5821676Sjpk "found gcgrp(1) in hash(2)", tsol_gcgrp_t *, gcgrp, 5831676Sjpk mod_hash_t *, hashp); 5841676Sjpk 5851676Sjpk } else if (alloc) { 5861676Sjpk gcgrp = kmem_zalloc(sizeof (*gcgrp), KM_NOSLEEP); 5871676Sjpk if (gcgrp != NULL) { 5881676Sjpk gcgrp->gcgrp_refcnt = 1; 5891676Sjpk rw_init(&gcgrp->gcgrp_rwlock, NULL, RW_DEFAULT, NULL); 5901676Sjpk bcopy(ga, &gcgrp->gcgrp_addr, sizeof (*ga)); 5911676Sjpk 5921676Sjpk if (mod_hash_insert(hashp, 5931676Sjpk (mod_hash_key_t)&gcgrp->gcgrp_addr, 5941676Sjpk (mod_hash_val_t)gcgrp) != 0) { 5951676Sjpk mutex_exit(&gcgrp_lock); 5961676Sjpk kmem_free(gcgrp, sizeof (*gcgrp)); 5971676Sjpk return (NULL); 5981676Sjpk } 5991676Sjpk 6001676Sjpk DTRACE_PROBE3(tx__gcdb__log__info__gcgrp__insert, 6011676Sjpk char *, "inserted gcgrp(1) in hash(2)", 6021676Sjpk tsol_gcgrp_t *, gcgrp, mod_hash_t *, hashp); 6031676Sjpk } 6041676Sjpk } 6051676Sjpk mutex_exit(&gcgrp_lock); 6061676Sjpk return (gcgrp); 6071676Sjpk } 6081676Sjpk 6091676Sjpk void 6101676Sjpk gcgrp_inactive(tsol_gcgrp_t *gcgrp) 6111676Sjpk { 6121676Sjpk tsol_gcgrp_addr_t *ga; 6131676Sjpk mod_hash_t *hashp; 6141676Sjpk 6151676Sjpk ASSERT(MUTEX_HELD(&gcgrp_lock)); 6161676Sjpk ASSERT(!RW_LOCK_HELD(&gcgrp->gcgrp_rwlock)); 6171676Sjpk ASSERT(gcgrp != NULL && gcgrp->gcgrp_refcnt == 0); 6181676Sjpk ASSERT(gcgrp->gcgrp_head == NULL && gcgrp->gcgrp_count == 0); 6191676Sjpk 6201676Sjpk ga = &gcgrp->gcgrp_addr; 6211676Sjpk ASSERT(ga->ga_af == AF_INET || ga->ga_af == AF_INET6); 6221676Sjpk 6231676Sjpk hashp = (ga->ga_af == AF_INET) ? gcgrp4_hash : gcgrp6_hash; 6241676Sjpk (void) mod_hash_remove(hashp, (mod_hash_key_t)ga, 6251676Sjpk (mod_hash_val_t *)&gcgrp); 6261676Sjpk rw_destroy(&gcgrp->gcgrp_rwlock); 6271676Sjpk 6281676Sjpk DTRACE_PROBE3(tx__gcdb__log__info__gcgrp__remove, char *, 6291676Sjpk "removed inactive gcgrp(1) from hash(2)", 6301676Sjpk tsol_gcgrp_t *, gcgrp, mod_hash_t *, hashp); 6311676Sjpk 6321676Sjpk kmem_free(gcgrp, sizeof (*gcgrp)); 6331676Sjpk } 6341676Sjpk 6351676Sjpk /* 6361676Sjpk * Converts CIPSO option to sensitivity label. 6371676Sjpk * Validity checks based on restrictions defined in 6381676Sjpk * COMMERCIAL IP SECURITY OPTION (CIPSO 2.2) (draft-ietf-cipso-ipsecurity) 6391676Sjpk */ 6401676Sjpk static boolean_t 6411676Sjpk cipso_to_sl(const uchar_t *option, bslabel_t *sl) 6421676Sjpk { 6431676Sjpk const struct cipso_option *co = (const struct cipso_option *)option; 6441676Sjpk const struct cipso_tag_type_1 *tt1; 6451676Sjpk 6461676Sjpk tt1 = (struct cipso_tag_type_1 *)&co->cipso_tag_type[0]; 6471676Sjpk if (tt1->tag_type != 1 || 6481676Sjpk tt1->tag_length < TSOL_TT1_MIN_LENGTH || 6491676Sjpk tt1->tag_length > TSOL_TT1_MAX_LENGTH || 6501676Sjpk tt1->tag_length + TSOL_CIPSO_TAG_OFFSET > co->cipso_length) 6511676Sjpk return (B_FALSE); 6521676Sjpk 6531676Sjpk bsllow(sl); /* assumed: sets compartments to all zeroes */ 6541676Sjpk LCLASS_SET((_bslabel_impl_t *)sl, tt1->tag_sl); 6551676Sjpk bcopy(tt1->tag_cat, &((_bslabel_impl_t *)sl)->compartments, 6561676Sjpk tt1->tag_length - TSOL_TT1_MIN_LENGTH); 6571676Sjpk return (B_TRUE); 6581676Sjpk } 6591676Sjpk 6601676Sjpk /* 6611676Sjpk * Parse the CIPSO label in the incoming packet and construct a ts_label_t 6621676Sjpk * that reflects the CIPSO label and attach it to the dblk cred. Later as 6631676Sjpk * the mblk flows up through the stack any code that needs to examine the 6641676Sjpk * packet label can inspect the label from the dblk cred. This function is 6651676Sjpk * called right in ip_rput for all packets, i.e. locally destined and 6661676Sjpk * to be forwarded packets. The forwarding path needs to examine the label 6671676Sjpk * to determine how to forward the packet. 6681676Sjpk * 6691676Sjpk * For IPv4, IP header options have been pulled up, but other headers might not 6701676Sjpk * have been. For IPv6, any hop-by-hop options have been pulled up, but any 6711676Sjpk * other headers might not be present. 6721676Sjpk */ 6731676Sjpk boolean_t 6741676Sjpk tsol_get_pkt_label(mblk_t *mp, int version) 6751676Sjpk { 6761676Sjpk tsol_tpc_t *src_rhtp; 6771676Sjpk uchar_t *opt_ptr = NULL; 6781676Sjpk const ipha_t *ipha; 6791676Sjpk bslabel_t sl; 6801676Sjpk uint32_t doi; 6811676Sjpk tsol_ip_label_t label_type; 6821676Sjpk const cipso_option_t *co; 6831676Sjpk const void *src; 6841676Sjpk const ip6_t *ip6h; 685*8778SErik.Nordmark@Sun.COM cred_t *credp; 686*8778SErik.Nordmark@Sun.COM pid_t cpid; 6871676Sjpk 6881676Sjpk ASSERT(DB_TYPE(mp) == M_DATA); 6891676Sjpk 6901676Sjpk if (version == IPV4_VERSION) { 6911676Sjpk ipha = (const ipha_t *)mp->b_rptr; 6921676Sjpk src = &ipha->ipha_src; 6931676Sjpk label_type = tsol_get_option(mp, &opt_ptr); 6941676Sjpk } else { 6951676Sjpk uchar_t *after_secopt; 6961676Sjpk boolean_t hbh_needed; 6971676Sjpk const uchar_t *ip6hbh; 6981676Sjpk size_t optlen; 6991676Sjpk 7001676Sjpk label_type = OPT_NONE; 7011676Sjpk ip6h = (const ip6_t *)mp->b_rptr; 7021676Sjpk src = &ip6h->ip6_src; 7031676Sjpk if (ip6h->ip6_nxt == IPPROTO_HOPOPTS) { 7041676Sjpk ip6hbh = (const uchar_t *)&ip6h[1]; 7051676Sjpk optlen = (ip6hbh[1] + 1) << 3; 7061676Sjpk ASSERT(ip6hbh + optlen <= mp->b_wptr); 7071676Sjpk opt_ptr = tsol_find_secopt_v6(ip6hbh, optlen, 7081676Sjpk &after_secopt, &hbh_needed); 7091676Sjpk /* tsol_find_secopt_v6 guarantees some sanity */ 7101676Sjpk if (opt_ptr != NULL && 7111676Sjpk (optlen = opt_ptr[1]) >= 8) { 7121676Sjpk opt_ptr += 2; 7131676Sjpk bcopy(opt_ptr, &doi, sizeof (doi)); 7141676Sjpk doi = ntohl(doi); 7151676Sjpk if (doi == IP6LS_DOI_V4 && 7161676Sjpk opt_ptr[4] == IP6LS_TT_V4 && 7171676Sjpk opt_ptr[5] <= optlen - 4 && 7181676Sjpk opt_ptr[7] <= optlen - 6) { 7191676Sjpk opt_ptr += sizeof (doi) + 2; 7201676Sjpk label_type = OPT_CIPSO; 7211676Sjpk } 7221676Sjpk } 7231676Sjpk } 7241676Sjpk } 7251676Sjpk 7261676Sjpk switch (label_type) { 7271676Sjpk case OPT_CIPSO: 7281676Sjpk /* 7291676Sjpk * Convert the CIPSO label to the internal format 7301676Sjpk * and attach it to the dblk cred. 7311676Sjpk * Validity checks based on restrictions defined in 7321676Sjpk * COMMERCIAL IP SECURITY OPTION (CIPSO 2.2) 7331676Sjpk * (draft-ietf-cipso-ipsecurity) 7341676Sjpk */ 7351676Sjpk if (version == IPV6_VERSION && ip6opt_ls == 0) 7361676Sjpk return (B_FALSE); 7371676Sjpk co = (const struct cipso_option *)opt_ptr; 7381676Sjpk if ((co->cipso_length < 7391676Sjpk TSOL_CIPSO_TAG_OFFSET + TSOL_TT1_MIN_LENGTH) || 7401676Sjpk (co->cipso_length > IP_MAX_OPT_LENGTH)) 7411676Sjpk return (B_FALSE); 7421676Sjpk bcopy(co->cipso_doi, &doi, sizeof (doi)); 7431676Sjpk doi = ntohl(doi); 7441676Sjpk if (!cipso_to_sl(opt_ptr, &sl)) 7451676Sjpk return (B_FALSE); 7461676Sjpk setbltype(&sl, SUN_SL_ID); 7471676Sjpk break; 7481676Sjpk 7491676Sjpk case OPT_NONE: 7501676Sjpk /* 7511676Sjpk * Handle special cases that are not currently labeled, even 7521676Sjpk * though the sending system may otherwise be configured as 7531676Sjpk * labeled. 7541676Sjpk * - IGMP 7551676Sjpk * - IPv4 ICMP Router Discovery 7561676Sjpk * - IPv6 Neighbor Discovery 7571676Sjpk */ 7581676Sjpk if (version == IPV4_VERSION) { 7591676Sjpk if (ipha->ipha_protocol == IPPROTO_IGMP) 7601676Sjpk return (B_TRUE); 7611676Sjpk if (ipha->ipha_protocol == IPPROTO_ICMP) { 7621676Sjpk const struct icmp *icmp = (const struct icmp *) 7631676Sjpk (mp->b_rptr + IPH_HDR_LENGTH(ipha)); 7641676Sjpk 7651676Sjpk if ((uchar_t *)icmp > mp->b_wptr) { 7661676Sjpk if (!pullupmsg(mp, 7671676Sjpk (uchar_t *)icmp - mp->b_rptr + 1)) 7681676Sjpk return (B_FALSE); 7691676Sjpk icmp = (const struct icmp *) 7701676Sjpk (mp->b_rptr + 7711676Sjpk IPH_HDR_LENGTH(ipha)); 7721676Sjpk } 7731676Sjpk if (icmp->icmp_type == ICMP_ROUTERADVERT || 7741676Sjpk icmp->icmp_type == ICMP_ROUTERSOLICIT) 7751676Sjpk return (B_TRUE); 7761676Sjpk } 7771676Sjpk src = &ipha->ipha_src; 7781676Sjpk } else { 7791676Sjpk if (ip6h->ip6_nxt == IPPROTO_ICMPV6) { 7801676Sjpk const icmp6_t *icmp6 = (const icmp6_t *) 7811676Sjpk (mp->b_rptr + IPV6_HDR_LEN); 7821676Sjpk 7831676Sjpk if ((uchar_t *)icmp6 + ICMP6_MINLEN > 7841676Sjpk mp->b_wptr) { 7851676Sjpk if (!pullupmsg(mp, 7861676Sjpk (uchar_t *)icmp6 - mp->b_rptr + 7871676Sjpk ICMP6_MINLEN)) 7881676Sjpk return (B_FALSE); 7891676Sjpk icmp6 = (const icmp6_t *) 7901676Sjpk (mp->b_rptr + IPV6_HDR_LEN); 7911676Sjpk } 7921676Sjpk if (icmp6->icmp6_type >= MLD_LISTENER_QUERY && 7931676Sjpk icmp6->icmp6_type <= ICMP6_MAX_INFO_TYPE) 7941676Sjpk return (B_TRUE); 7951676Sjpk } 7961676Sjpk src = &ip6h->ip6_src; 7971676Sjpk } 7981676Sjpk 7991676Sjpk /* 8001676Sjpk * Look up the tnrhtp database and get the implicit label 8011676Sjpk * that is associated with this unlabeled host and attach 8021676Sjpk * it to the packet. 8031676Sjpk */ 8041676Sjpk if ((src_rhtp = find_tpc(src, version, B_FALSE)) == NULL) 8051676Sjpk return (B_FALSE); 8061676Sjpk 8071676Sjpk /* If the sender is labeled, drop the unlabeled packet. */ 8081676Sjpk if (src_rhtp->tpc_tp.host_type != UNLABELED) { 8091676Sjpk TPC_RELE(src_rhtp); 8101676Sjpk pr_addr_dbg("unlabeled packet forged from %s\n", 8111676Sjpk version == IPV4_VERSION ? AF_INET : AF_INET6, src); 8121676Sjpk return (B_FALSE); 8131676Sjpk } 8141676Sjpk 8151676Sjpk sl = src_rhtp->tpc_tp.tp_def_label; 8161676Sjpk setbltype(&sl, SUN_SL_ID); 8171676Sjpk doi = src_rhtp->tpc_tp.tp_doi; 8181676Sjpk TPC_RELE(src_rhtp); 8191676Sjpk break; 8201676Sjpk 8211676Sjpk default: 8221676Sjpk return (B_FALSE); 8231676Sjpk } 8241676Sjpk 8251676Sjpk /* Make sure no other thread is messing with this mblk */ 8261676Sjpk ASSERT(DB_REF(mp) == 1); 827*8778SErik.Nordmark@Sun.COM /* Preserve db_cpid */ 828*8778SErik.Nordmark@Sun.COM credp = msg_extractcred(mp, &cpid); 829*8778SErik.Nordmark@Sun.COM if (credp == NULL) { 830*8778SErik.Nordmark@Sun.COM credp = newcred_from_bslabel(&sl, doi, KM_NOSLEEP); 831*8778SErik.Nordmark@Sun.COM if (credp == NULL) 8321676Sjpk return (B_FALSE); 833*8778SErik.Nordmark@Sun.COM mblk_setcred(mp, credp, cpid); 8341676Sjpk } else { 8351676Sjpk cred_t *newcr; 8361676Sjpk 837*8778SErik.Nordmark@Sun.COM newcr = copycred_from_bslabel(credp, &sl, doi, 8381676Sjpk KM_NOSLEEP); 839*8778SErik.Nordmark@Sun.COM crfree(credp); 8401676Sjpk if (newcr == NULL) 8411676Sjpk return (B_FALSE); 842*8778SErik.Nordmark@Sun.COM mblk_setcred(mp, newcr, cpid); 843*8778SErik.Nordmark@Sun.COM credp = newcr; 8441676Sjpk } 8451676Sjpk 8461676Sjpk /* 8471676Sjpk * If the source was unlabeled, then flag as such, 8481676Sjpk * while remembering that CIPSO routers add headers. 8491676Sjpk */ 850*8778SErik.Nordmark@Sun.COM if (label_type == OPT_NONE) { 851*8778SErik.Nordmark@Sun.COM crgetlabel(credp)->tsl_flags |= TSLF_UNLABELED; 852*8778SErik.Nordmark@Sun.COM } else if (label_type == OPT_CIPSO) { 8531676Sjpk if ((src_rhtp = find_tpc(src, version, B_FALSE)) == NULL) 8541676Sjpk return (B_FALSE); 8551676Sjpk if (src_rhtp->tpc_tp.host_type == UNLABELED) 856*8778SErik.Nordmark@Sun.COM crgetlabel(credp)->tsl_flags |= TSLF_UNLABELED; 8571676Sjpk TPC_RELE(src_rhtp); 8581676Sjpk } 8591676Sjpk 8601676Sjpk return (B_TRUE); 8611676Sjpk } 8621676Sjpk 8631676Sjpk /* 8641676Sjpk * This routine determines whether the given packet should be accepted locally. 8651676Sjpk * It does a range/set check on the packet's label by looking up the given 8661676Sjpk * address in the remote host database. 8671676Sjpk */ 8681676Sjpk boolean_t 8691676Sjpk tsol_receive_local(const mblk_t *mp, const void *addr, uchar_t version, 8701676Sjpk boolean_t shared_addr, const conn_t *connp) 8711676Sjpk { 8721676Sjpk const cred_t *credp; 8731676Sjpk ts_label_t *plabel, *conn_plabel; 8741676Sjpk tsol_tpc_t *tp; 8751676Sjpk boolean_t retv; 8761676Sjpk const bslabel_t *label, *conn_label; 8771676Sjpk 8781676Sjpk /* 8791676Sjpk * The cases in which this can happen are: 8801676Sjpk * - IPv6 Router Alert, where ip_rput_data_v6 deliberately skips 8811676Sjpk * over the label attachment process. 8821676Sjpk * - MLD output looped-back to ourselves. 8831676Sjpk * - IPv4 Router Discovery, where tsol_get_pkt_label intentionally 8841676Sjpk * avoids the labeling process. 8851676Sjpk * We trust that all valid paths in the code set the cred pointer when 8861676Sjpk * needed. 8871676Sjpk */ 888*8778SErik.Nordmark@Sun.COM if ((credp = msg_getcred(mp, NULL)) == NULL) 8891676Sjpk return (B_TRUE); 8901676Sjpk 8911676Sjpk /* 8921676Sjpk * If this packet is from the inside (not a remote host) and has the 8931676Sjpk * same zoneid as the selected destination, then no checks are 8941676Sjpk * necessary. Membership in the zone is enough proof. This is 8951676Sjpk * intended to be a hot path through this function. 8961676Sjpk */ 8971676Sjpk if (!crisremote(credp) && 8981676Sjpk crgetzone(credp) == crgetzone(connp->conn_cred)) 8991676Sjpk return (B_TRUE); 9001676Sjpk 9011676Sjpk plabel = crgetlabel(credp); 9021676Sjpk conn_plabel = crgetlabel(connp->conn_cred); 9031676Sjpk ASSERT(plabel != NULL && conn_plabel != NULL); 9041676Sjpk 9051676Sjpk label = label2bslabel(plabel); 9061676Sjpk conn_label = label2bslabel(crgetlabel(connp->conn_cred)); 9071676Sjpk 9081676Sjpk /* 9091676Sjpk * MLPs are always validated using the range and set of the local 9101676Sjpk * address, even when the remote host is unlabeled. 9111676Sjpk */ 9121676Sjpk if (connp->conn_mlp_type == mlptBoth || 9131676Sjpk /* LINTED: no consequent */ 9141676Sjpk connp->conn_mlp_type == (shared_addr ? mlptShared : mlptPrivate)) { 9151676Sjpk ; 9161676Sjpk 9171676Sjpk /* 9181676Sjpk * If this is a packet from an unlabeled sender, then we must apply 9191676Sjpk * different rules. If the label is equal to the zone's label, then 9201676Sjpk * it's allowed. If it's not equal, but the zone is either the global 9211676Sjpk * zone or the label is dominated by the zone's label, then allow it 9221676Sjpk * as long as it's in the range configured for the destination. 9231676Sjpk */ 9241676Sjpk } else if (plabel->tsl_flags & TSLF_UNLABELED) { 9251676Sjpk if (plabel->tsl_doi == conn_plabel->tsl_doi && 9261676Sjpk blequal(label, conn_label)) 9271676Sjpk return (B_TRUE); 9281676Sjpk 9293448Sdh155122 /* 9303448Sdh155122 * conn_zoneid is global for an exclusive stack, thus we use 9313448Sdh155122 * conn_cred to get the zoneid 9323448Sdh155122 */ 9331676Sjpk if (!connp->conn_mac_exempt || 9343448Sdh155122 (crgetzoneid(connp->conn_cred) != GLOBAL_ZONEID && 9351676Sjpk (plabel->tsl_doi != conn_plabel->tsl_doi || 9361676Sjpk !bldominates(conn_label, label)))) { 9371676Sjpk DTRACE_PROBE3( 9381676Sjpk tx__ip__log__drop__receivelocal__mac_unl, 9391676Sjpk char *, 9401676Sjpk "unlabeled packet mp(1) fails mac for conn(2)", 9411676Sjpk mblk_t *, mp, conn_t *, connp); 9421676Sjpk return (B_FALSE); 9431676Sjpk } 9441676Sjpk 9451676Sjpk /* 9464448Skp158701 * If this is a packet from a labeled sender, verify the 9474448Skp158701 * label on the packet matches the connection label. 9481676Sjpk */ 9494448Skp158701 } else { 9504448Skp158701 if (plabel->tsl_doi != conn_plabel->tsl_doi || 9514448Skp158701 !blequal(label, conn_label)) { 9524448Skp158701 DTRACE_PROBE3(tx__ip__log__drop__receivelocal__mac__slp, 9534448Skp158701 char *, 9544448Skp158701 "packet mp(1) failed label match to SLP conn(2)", 9554448Skp158701 mblk_t *, mp, conn_t *, connp); 9564448Skp158701 return (B_FALSE); 9574448Skp158701 } 9581676Sjpk /* 9594448Skp158701 * No further checks will be needed if this is a zone- 9604448Skp158701 * specific address because (1) The process for bringing up 9614448Skp158701 * the interface ensures the zone's label is within the zone- 9624448Skp158701 * specific address's valid label range; (2) For cases where 9634448Skp158701 * the conn is bound to the unspecified addresses, ip fanout 9644448Skp158701 * logic ensures conn's zoneid equals the dest addr's zoneid; 9654448Skp158701 * (3) Mac-exempt and mlp logic above already handle all 9664448Skp158701 * cases where the zone label may not be the same as the 9674448Skp158701 * conn label. 9681676Sjpk */ 9694448Skp158701 if (!shared_addr) 9701676Sjpk return (B_TRUE); 9711676Sjpk } 9721676Sjpk 9731676Sjpk tp = find_tpc(addr, version, B_FALSE); 9741676Sjpk if (tp == NULL) { 9751676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__no__tnr, 9761676Sjpk char *, "dropping mp(1), host(2) lacks entry", 9771676Sjpk mblk_t *, mp, void *, addr); 9781676Sjpk return (B_FALSE); 9791676Sjpk } 9801676Sjpk 9811676Sjpk /* 9821676Sjpk * The local host address should not be unlabeled at this point. The 9831676Sjpk * only way this can happen is that the destination isn't unicast. We 9841676Sjpk * assume that the packet should not have had a label, and thus should 9851676Sjpk * have been handled by the TSLF_UNLABELED logic above. 9861676Sjpk */ 9871676Sjpk if (tp->tpc_tp.host_type == UNLABELED) { 9881676Sjpk retv = B_FALSE; 9891676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__flag, char *, 9901676Sjpk "mp(1) unlabeled source, but tp is not unlabeled.", 9911676Sjpk mblk_t *, mp, tsol_tpc_t *, tp); 9921676Sjpk 9931676Sjpk } else if (tp->tpc_tp.host_type != SUN_CIPSO) { 9941676Sjpk retv = B_FALSE; 9951676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__tptype, char *, 9961676Sjpk "delivering mp(1), found unrecognized tpc(2) type.", 9971676Sjpk mblk_t *, mp, tsol_tpc_t *, tp); 9981676Sjpk 9991676Sjpk } else if (plabel->tsl_doi != tp->tpc_tp.tp_doi) { 10001676Sjpk retv = B_FALSE; 10011676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__mac, char *, 10021676Sjpk "mp(1) could not be delievered to tp(2), doi mismatch", 10031676Sjpk mblk_t *, mp, tsol_tpc_t *, tp); 10041676Sjpk 10051676Sjpk } else if (!_blinrange(label, &tp->tpc_tp.tp_sl_range_cipso) && 10061676Sjpk !blinlset(label, tp->tpc_tp.tp_sl_set_cipso)) { 10071676Sjpk retv = B_FALSE; 10081676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__mac, char *, 10091676Sjpk "mp(1) could not be delievered to tp(2), bad mac", 10101676Sjpk mblk_t *, mp, tsol_tpc_t *, tp); 10111676Sjpk } else { 10121676Sjpk retv = B_TRUE; 10131676Sjpk } 10141676Sjpk 10151676Sjpk TPC_RELE(tp); 10161676Sjpk 10171676Sjpk return (retv); 10181676Sjpk } 10191676Sjpk 10201676Sjpk boolean_t 10211676Sjpk tsol_can_accept_raw(mblk_t *mp, boolean_t check_host) 10221676Sjpk { 10231676Sjpk ts_label_t *plabel = NULL; 10241676Sjpk tsol_tpc_t *src_rhtp, *dst_rhtp; 10251676Sjpk boolean_t retv; 1026*8778SErik.Nordmark@Sun.COM cred_t *credp; 10271676Sjpk 1028*8778SErik.Nordmark@Sun.COM credp = msg_getcred(mp, NULL); 1029*8778SErik.Nordmark@Sun.COM if (credp != NULL) 1030*8778SErik.Nordmark@Sun.COM plabel = crgetlabel(credp); 10311676Sjpk 10321676Sjpk /* We are bootstrapping or the internal template was never deleted */ 10331676Sjpk if (plabel == NULL) 10341676Sjpk return (B_TRUE); 10351676Sjpk 10361676Sjpk if (IPH_HDR_VERSION(mp->b_rptr) == IPV4_VERSION) { 10371676Sjpk ipha_t *ipha = (ipha_t *)mp->b_rptr; 10381676Sjpk 10391676Sjpk src_rhtp = find_tpc(&ipha->ipha_src, IPV4_VERSION, 10401676Sjpk B_FALSE); 10411676Sjpk if (src_rhtp == NULL) 10421676Sjpk return (B_FALSE); 10431676Sjpk dst_rhtp = find_tpc(&ipha->ipha_dst, IPV4_VERSION, 10441676Sjpk B_FALSE); 10451676Sjpk } else { 10461676Sjpk ip6_t *ip6h = (ip6_t *)mp->b_rptr; 10471676Sjpk 10481676Sjpk src_rhtp = find_tpc(&ip6h->ip6_src, IPV6_VERSION, 10491676Sjpk B_FALSE); 10501676Sjpk if (src_rhtp == NULL) 10511676Sjpk return (B_FALSE); 10521676Sjpk dst_rhtp = find_tpc(&ip6h->ip6_dst, IPV6_VERSION, 10531676Sjpk B_FALSE); 10541676Sjpk } 10551676Sjpk if (dst_rhtp == NULL) { 10561676Sjpk TPC_RELE(src_rhtp); 10571676Sjpk return (B_FALSE); 10581676Sjpk } 10591676Sjpk 10601676Sjpk if (label2doi(plabel) != src_rhtp->tpc_tp.tp_doi) { 10611676Sjpk retv = B_FALSE; 10621676Sjpk 10631676Sjpk /* 10641676Sjpk * Check that the packet's label is in the correct range for labeled 10651676Sjpk * sender, or is equal to the default label for unlabeled sender. 10661676Sjpk */ 10671676Sjpk } else if ((src_rhtp->tpc_tp.host_type != UNLABELED && 10681676Sjpk !_blinrange(label2bslabel(plabel), 10691676Sjpk &src_rhtp->tpc_tp.tp_sl_range_cipso) && 10701676Sjpk !blinlset(label2bslabel(plabel), 10711676Sjpk src_rhtp->tpc_tp.tp_sl_set_cipso)) || 10721676Sjpk (src_rhtp->tpc_tp.host_type == UNLABELED && 10731676Sjpk !blequal(&plabel->tsl_label, &src_rhtp->tpc_tp.tp_def_label))) { 10741676Sjpk retv = B_FALSE; 10751676Sjpk 10761676Sjpk } else if (check_host) { 10771676Sjpk retv = B_TRUE; 10781676Sjpk 10791676Sjpk /* 10801676Sjpk * Until we have SL range in the Zone structure, pass it 10811676Sjpk * when our own address lookup returned an internal entry. 10821676Sjpk */ 10831676Sjpk } else switch (dst_rhtp->tpc_tp.host_type) { 10841676Sjpk case UNLABELED: 10851676Sjpk retv = B_TRUE; 10861676Sjpk break; 10871676Sjpk 10881676Sjpk case SUN_CIPSO: 10891676Sjpk retv = _blinrange(label2bslabel(plabel), 10901676Sjpk &dst_rhtp->tpc_tp.tp_sl_range_cipso) || 10911676Sjpk blinlset(label2bslabel(plabel), 10921676Sjpk dst_rhtp->tpc_tp.tp_sl_set_cipso); 10931676Sjpk break; 10941676Sjpk 10951676Sjpk default: 10961676Sjpk retv = B_FALSE; 10971676Sjpk } 10981676Sjpk TPC_RELE(src_rhtp); 10991676Sjpk TPC_RELE(dst_rhtp); 11001676Sjpk return (retv); 11011676Sjpk } 11021676Sjpk 11031676Sjpk /* 11041676Sjpk * This routine determines whether a response to a failed packet delivery or 11051676Sjpk * connection should be sent back. By default, the policy is to allow such 11061676Sjpk * messages to be sent at all times, as these messages reveal little useful 11071676Sjpk * information and are healthy parts of TCP/IP networking. 11081676Sjpk * 11091676Sjpk * If tsol_strict_error is set, then we do strict tests: if the packet label is 11101676Sjpk * within the label range/set of this host/zone, return B_TRUE; otherwise 11111676Sjpk * return B_FALSE, which causes the packet to be dropped silently. 11121676Sjpk * 11131676Sjpk * Note that tsol_get_pkt_label will cause the packet to drop if the sender is 11141676Sjpk * marked as labeled in the remote host database, but the packet lacks a label. 11151676Sjpk * This means that we don't need to do a lookup on the source; the 11161676Sjpk * TSLF_UNLABELED flag is sufficient. 11171676Sjpk */ 11181676Sjpk boolean_t 11191676Sjpk tsol_can_reply_error(const mblk_t *mp) 11201676Sjpk { 11211676Sjpk ts_label_t *plabel = NULL; 11221676Sjpk tsol_tpc_t *rhtp; 11231676Sjpk const ipha_t *ipha; 11241676Sjpk const ip6_t *ip6h; 11251676Sjpk boolean_t retv; 11261676Sjpk bslabel_t *pktbs; 1127*8778SErik.Nordmark@Sun.COM cred_t *credp; 11281676Sjpk 11291676Sjpk /* Caller must pull up at least the IP header */ 11301676Sjpk ASSERT(MBLKL(mp) >= (IPH_HDR_VERSION(mp->b_rptr) == IPV4_VERSION ? 11311676Sjpk sizeof (*ipha) : sizeof (*ip6h))); 11321676Sjpk 11331676Sjpk if (!tsol_strict_error) 11341676Sjpk return (B_TRUE); 11351676Sjpk 1136*8778SErik.Nordmark@Sun.COM credp = msg_getcred(mp, NULL); 1137*8778SErik.Nordmark@Sun.COM if (credp != NULL) 1138*8778SErik.Nordmark@Sun.COM plabel = crgetlabel(credp); 11391676Sjpk 11401676Sjpk /* We are bootstrapping or the internal template was never deleted */ 11411676Sjpk if (plabel == NULL) 11421676Sjpk return (B_TRUE); 11431676Sjpk 11441676Sjpk if (IPH_HDR_VERSION(mp->b_rptr) == IPV4_VERSION) { 11451676Sjpk ipha = (const ipha_t *)mp->b_rptr; 11461676Sjpk rhtp = find_tpc(&ipha->ipha_dst, IPV4_VERSION, B_FALSE); 11471676Sjpk } else { 11481676Sjpk ip6h = (const ip6_t *)mp->b_rptr; 11491676Sjpk rhtp = find_tpc(&ip6h->ip6_dst, IPV6_VERSION, B_FALSE); 11501676Sjpk } 11511676Sjpk 11521676Sjpk if (rhtp == NULL || label2doi(plabel) != rhtp->tpc_tp.tp_doi) { 11531676Sjpk retv = B_FALSE; 11541676Sjpk } else { 11551676Sjpk /* 11561676Sjpk * If we're in the midst of forwarding, then the destination 11571676Sjpk * address might not be labeled. In that case, allow unlabeled 11581676Sjpk * packets through only if the default label is the same, and 11591676Sjpk * labeled ones if they dominate. 11601676Sjpk */ 11611676Sjpk pktbs = label2bslabel(plabel); 11621676Sjpk switch (rhtp->tpc_tp.host_type) { 11631676Sjpk case UNLABELED: 11641676Sjpk if (plabel->tsl_flags & TSLF_UNLABELED) { 11651676Sjpk retv = blequal(pktbs, 11661676Sjpk &rhtp->tpc_tp.tp_def_label); 11671676Sjpk } else { 11681676Sjpk retv = bldominates(pktbs, 11691676Sjpk &rhtp->tpc_tp.tp_def_label); 11701676Sjpk } 11711676Sjpk break; 11721676Sjpk 11731676Sjpk case SUN_CIPSO: 11741676Sjpk retv = _blinrange(pktbs, 11751676Sjpk &rhtp->tpc_tp.tp_sl_range_cipso) || 11761676Sjpk blinlset(pktbs, rhtp->tpc_tp.tp_sl_set_cipso); 11771676Sjpk break; 11781676Sjpk 11791676Sjpk default: 11801676Sjpk retv = B_FALSE; 11811676Sjpk break; 11821676Sjpk } 11831676Sjpk } 11841676Sjpk 11851676Sjpk if (rhtp != NULL) 11861676Sjpk TPC_RELE(rhtp); 11871676Sjpk 11881676Sjpk return (retv); 11891676Sjpk } 11901676Sjpk 11911676Sjpk /* 11921676Sjpk * Finds the zone associated with the given packet. Returns GLOBAL_ZONEID if 11931676Sjpk * the zone cannot be located. 11941676Sjpk * 11951676Sjpk * This is used by the classifier when the packet matches an ALL_ZONES IRE, and 11961676Sjpk * there's no MLP defined. 11973448Sdh155122 * 11983448Sdh155122 * Note that we assume that this is only invoked in the ALL_ZONES case. 11993448Sdh155122 * Handling other cases would require handle exclusive stack zones where either 12003448Sdh155122 * this routine or the callers would have to map from 12013448Sdh155122 * the zoneid (zone->zone_id) to what IP uses in conn_zoneid etc. 12021676Sjpk */ 12031676Sjpk zoneid_t 12041676Sjpk tsol_packet_to_zoneid(const mblk_t *mp) 12051676Sjpk { 1206*8778SErik.Nordmark@Sun.COM cred_t *cr = msg_getcred(mp, NULL); 12071676Sjpk zone_t *zone; 12081676Sjpk ts_label_t *label; 12091676Sjpk 12101676Sjpk if (cr != NULL) { 12111676Sjpk if ((label = crgetlabel(cr)) != NULL) { 12121676Sjpk zone = zone_find_by_label(label); 12131676Sjpk if (zone != NULL) { 12141676Sjpk zoneid_t zoneid = zone->zone_id; 12151676Sjpk 12161676Sjpk zone_rele(zone); 12171676Sjpk return (zoneid); 12181676Sjpk } 12191676Sjpk } 12201676Sjpk } 12211676Sjpk return (GLOBAL_ZONEID); 12221676Sjpk } 12231676Sjpk 12241676Sjpk int 12251676Sjpk tsol_ire_match_gwattr(ire_t *ire, const ts_label_t *tsl) 12261676Sjpk { 12271676Sjpk int error = 0; 12281676Sjpk tsol_ire_gw_secattr_t *attrp = NULL; 12291676Sjpk tsol_tnrhc_t *gw_rhc = NULL; 12301676Sjpk tsol_gcgrp_t *gcgrp = NULL; 12311676Sjpk tsol_gc_t *gc = NULL; 12321676Sjpk in_addr_t ga_addr4; 12331676Sjpk void *paddr = NULL; 12341676Sjpk 12351676Sjpk /* Not in Trusted mode or IRE is local/loopback/broadcast/interface */ 12361676Sjpk if (!is_system_labeled() || 12371676Sjpk (ire->ire_type & (IRE_LOCAL | IRE_LOOPBACK | IRE_BROADCAST | 12381676Sjpk IRE_INTERFACE))) 12391676Sjpk goto done; 12401676Sjpk 12411676Sjpk /* 12421676Sjpk * If we don't have a label to compare with, or the IRE does not 12431676Sjpk * contain any gateway security attributes, there's not much that 12441676Sjpk * we can do. We let the former case pass, and the latter fail, 12451676Sjpk * since the IRE doesn't qualify for a match due to the lack of 12461676Sjpk * security attributes. 12471676Sjpk */ 12481676Sjpk if (tsl == NULL || ire->ire_gw_secattr == NULL) { 12491676Sjpk if (tsl != NULL) { 12506596Skp158701 DTRACE_PROBE3(tx__ip__log__drop__irematch__nogwsec, 12516596Skp158701 char *, 12526596Skp158701 "ire(1) lacks ire_gw_secattr matching label(2)", 12536596Skp158701 ire_t *, ire, ts_label_t *, tsl); 12541676Sjpk error = EACCES; 12551676Sjpk } 12561676Sjpk goto done; 12571676Sjpk } 12581676Sjpk 12591676Sjpk attrp = ire->ire_gw_secattr; 12601676Sjpk 12611676Sjpk /* 12621676Sjpk * The possible lock order scenarios related to the tsol gateway 12631676Sjpk * attribute locks are documented at the beginning of ip.c in the 12641676Sjpk * lock order scenario section. 12651676Sjpk */ 12661676Sjpk mutex_enter(&attrp->igsa_lock); 12671676Sjpk 12681676Sjpk /* 12691676Sjpk * Depending on the IRE type (prefix vs. cache), we seek the group 12701676Sjpk * structure which contains all security credentials of the gateway. 12711676Sjpk * A prefix IRE is associated with at most one gateway credential, 12721676Sjpk * while a cache IRE is associated with every credentials that the 12731676Sjpk * gateway has. 12741676Sjpk */ 12751676Sjpk if ((gc = attrp->igsa_gc) != NULL) { /* prefix */ 12761676Sjpk gcgrp = gc->gc_grp; 12771676Sjpk ASSERT(gcgrp != NULL); 12781676Sjpk rw_enter(&gcgrp->gcgrp_rwlock, RW_READER); 12791676Sjpk } else if ((gcgrp = attrp->igsa_gcgrp) != NULL) { /* cache */ 12801676Sjpk rw_enter(&gcgrp->gcgrp_rwlock, RW_READER); 12811676Sjpk gc = gcgrp->gcgrp_head; 12821676Sjpk if (gc == NULL) { 12831676Sjpk /* gc group is empty, so the drop lock now */ 12841676Sjpk ASSERT(gcgrp->gcgrp_count == 0); 12851676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 12861676Sjpk gcgrp = NULL; 12871676Sjpk } 12881676Sjpk } 12891676Sjpk 12901676Sjpk if (gcgrp != NULL) 12911676Sjpk GCGRP_REFHOLD(gcgrp); 12921676Sjpk 12931676Sjpk if ((gw_rhc = attrp->igsa_rhc) != NULL) { 12941676Sjpk /* 12951676Sjpk * If our cached entry has grown stale, then discard it so we 12961676Sjpk * can get a new one. 12971676Sjpk */ 12981676Sjpk if (gw_rhc->rhc_invalid || gw_rhc->rhc_tpc->tpc_invalid) { 12991676Sjpk TNRHC_RELE(gw_rhc); 13001676Sjpk attrp->igsa_rhc = gw_rhc = NULL; 13011676Sjpk } else { 13021676Sjpk TNRHC_HOLD(gw_rhc) 13031676Sjpk } 13041676Sjpk } 13051676Sjpk 13061676Sjpk /* Last attempt at loading the template had failed; try again */ 13071676Sjpk if (gw_rhc == NULL) { 13081676Sjpk if (gcgrp != NULL) { 13091676Sjpk tsol_gcgrp_addr_t *ga = &gcgrp->gcgrp_addr; 13101676Sjpk 13111676Sjpk if (ire->ire_ipversion == IPV4_VERSION) { 13121676Sjpk ASSERT(ga->ga_af == AF_INET); 13131676Sjpk IN6_V4MAPPED_TO_IPADDR(&ga->ga_addr, ga_addr4); 13141676Sjpk paddr = &ga_addr4; 13151676Sjpk } else { 13161676Sjpk ASSERT(ga->ga_af == AF_INET6); 13171676Sjpk paddr = &ga->ga_addr; 13181676Sjpk } 13191676Sjpk } else if (ire->ire_ipversion == IPV6_VERSION && 13201676Sjpk !IN6_IS_ADDR_UNSPECIFIED(&ire->ire_gateway_addr_v6)) { 13211676Sjpk paddr = &ire->ire_gateway_addr_v6; 13221676Sjpk } else if (ire->ire_ipversion == IPV4_VERSION && 13231676Sjpk ire->ire_gateway_addr != INADDR_ANY) { 13241676Sjpk paddr = &ire->ire_gateway_addr; 13251676Sjpk } 13261676Sjpk 13271676Sjpk /* We've found a gateway address to do the template lookup */ 13281676Sjpk if (paddr != NULL) { 13291676Sjpk ASSERT(gw_rhc == NULL); 13303292Skp158701 gw_rhc = find_rhc(paddr, ire->ire_ipversion, B_FALSE); 13311676Sjpk if (gw_rhc != NULL) { 13321676Sjpk /* 13331676Sjpk * Note that if the lookup above returned an 13341676Sjpk * internal template, we'll use it for the 13351676Sjpk * time being, and do another lookup next 13361676Sjpk * time around. 13371676Sjpk */ 13381676Sjpk /* Another thread has loaded the template? */ 13391676Sjpk if (attrp->igsa_rhc != NULL) { 13401676Sjpk TNRHC_RELE(gw_rhc) 13411676Sjpk /* reload, it could be different */ 13421676Sjpk gw_rhc = attrp->igsa_rhc; 13431676Sjpk } else { 13441676Sjpk attrp->igsa_rhc = gw_rhc; 13451676Sjpk } 13461676Sjpk /* 13471676Sjpk * Hold an extra reference just like we did 13481676Sjpk * above prior to dropping the igsa_lock. 13491676Sjpk */ 13501676Sjpk TNRHC_HOLD(gw_rhc) 13511676Sjpk } 13521676Sjpk } 13531676Sjpk } 13541676Sjpk 13551676Sjpk mutex_exit(&attrp->igsa_lock); 13561676Sjpk /* Gateway template not found */ 13571676Sjpk if (gw_rhc == NULL) { 13581676Sjpk /* 13591676Sjpk * If destination address is directly reachable through an 13601676Sjpk * interface rather than through a learned route, pass it. 13611676Sjpk */ 13621676Sjpk if (paddr != NULL) { 13631676Sjpk DTRACE_PROBE3( 13641676Sjpk tx__ip__log__drop__irematch__nogwtmpl, char *, 13651676Sjpk "ire(1), label(2) off-link with no gw_rhc", 13661676Sjpk ire_t *, ire, ts_label_t *, tsl); 13671676Sjpk error = EINVAL; 13681676Sjpk } 13691676Sjpk goto done; 13701676Sjpk } 13711676Sjpk 13721676Sjpk if (gc != NULL) { 13731676Sjpk tsol_gcdb_t *gcdb; 13741676Sjpk /* 13751676Sjpk * In the case of IRE_CACHE we've got one or more gateway 13761676Sjpk * security credentials to compare against the passed in label. 13771676Sjpk * Perform label range comparison against each security 13781676Sjpk * credential of the gateway. In the case of a prefix ire 13791676Sjpk * we need to match against the security attributes of 13801676Sjpk * just the route itself, so the loop is executed only once. 13811676Sjpk */ 13821676Sjpk ASSERT(gcgrp != NULL); 13831676Sjpk do { 13841676Sjpk gcdb = gc->gc_db; 13851676Sjpk if (tsl->tsl_doi == gcdb->gcdb_doi && 13861676Sjpk _blinrange(&tsl->tsl_label, &gcdb->gcdb_slrange)) 13871676Sjpk break; 13881676Sjpk if (ire->ire_type == IRE_CACHE) 13891676Sjpk gc = gc->gc_next; 13901676Sjpk else 13911676Sjpk gc = NULL; 13921676Sjpk } while (gc != NULL); 13931676Sjpk 13941676Sjpk if (gc == NULL) { 13951676Sjpk DTRACE_PROBE3( 13961676Sjpk tx__ip__log__drop__irematch__nogcmatched, 13971676Sjpk char *, "ire(1), tsl(2): all gc failed match", 13981676Sjpk ire_t *, ire, ts_label_t *, tsl); 13991676Sjpk error = EACCES; 14001676Sjpk } 14011676Sjpk } else { 14021676Sjpk /* 14031676Sjpk * We didn't find any gateway credentials in the IRE 14041676Sjpk * attributes; fall back to the gateway's template for 14051676Sjpk * label range checks, if we are required to do so. 14061676Sjpk */ 14071676Sjpk ASSERT(gw_rhc != NULL); 14081676Sjpk switch (gw_rhc->rhc_tpc->tpc_tp.host_type) { 14091676Sjpk case SUN_CIPSO: 14106596Skp158701 if (tsl->tsl_doi != gw_rhc->rhc_tpc->tpc_tp.tp_doi || 14111676Sjpk (!_blinrange(&tsl->tsl_label, 14126596Skp158701 &gw_rhc->rhc_tpc->tpc_tp.tp_sl_range_cipso) && 14131676Sjpk !blinlset(&tsl->tsl_label, 14141676Sjpk gw_rhc->rhc_tpc->tpc_tp.tp_sl_set_cipso))) { 14151676Sjpk error = EACCES; 14161676Sjpk DTRACE_PROBE4( 14171676Sjpk tx__ip__log__drop__irematch__deftmpl, 14181676Sjpk char *, "ire(1), tsl(2), gw_rhc(3) " 14191676Sjpk "failed match (cipso gw)", 14201676Sjpk ire_t *, ire, ts_label_t *, tsl, 14211676Sjpk tsol_tnrhc_t *, gw_rhc); 14221676Sjpk } 14231676Sjpk break; 14241676Sjpk 14251676Sjpk case UNLABELED: 14266596Skp158701 if (tsl->tsl_doi != gw_rhc->rhc_tpc->tpc_tp.tp_doi || 14271676Sjpk (!_blinrange(&tsl->tsl_label, 14281676Sjpk &gw_rhc->rhc_tpc->tpc_tp.tp_gw_sl_range) && 14291676Sjpk !blinlset(&tsl->tsl_label, 14301676Sjpk gw_rhc->rhc_tpc->tpc_tp.tp_gw_sl_set))) { 14311676Sjpk error = EACCES; 14321676Sjpk DTRACE_PROBE4( 14331676Sjpk tx__ip__log__drop__irematch__deftmpl, 14341676Sjpk char *, "ire(1), tsl(2), gw_rhc(3) " 14351676Sjpk "failed match (unlabeled gw)", 14361676Sjpk ire_t *, ire, ts_label_t *, tsl, 14371676Sjpk tsol_tnrhc_t *, gw_rhc); 14381676Sjpk } 14391676Sjpk break; 14401676Sjpk } 14411676Sjpk } 14421676Sjpk 14431676Sjpk done: 14441676Sjpk 14451676Sjpk if (gcgrp != NULL) { 14461676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 14471676Sjpk GCGRP_REFRELE(gcgrp); 14481676Sjpk } 14491676Sjpk 14501676Sjpk if (gw_rhc != NULL) 14511676Sjpk TNRHC_RELE(gw_rhc) 14521676Sjpk 14531676Sjpk return (error); 14541676Sjpk } 14551676Sjpk 14561676Sjpk /* 14571676Sjpk * Performs label accreditation checks for packet forwarding. 14581676Sjpk * 14591676Sjpk * Returns a pointer to the modified mblk if allowed for forwarding, 14601676Sjpk * or NULL if the packet must be dropped. 14611676Sjpk */ 14621676Sjpk mblk_t * 14631676Sjpk tsol_ip_forward(ire_t *ire, mblk_t *mp) 14641676Sjpk { 14651676Sjpk tsol_ire_gw_secattr_t *attrp = NULL; 14661676Sjpk ipha_t *ipha; 14671676Sjpk ip6_t *ip6h; 14681676Sjpk const void *pdst; 14691676Sjpk const void *psrc; 14701676Sjpk boolean_t off_link; 14711676Sjpk tsol_tpc_t *dst_rhtp, *gw_rhtp; 14721676Sjpk tsol_ip_label_t label_type; 14731676Sjpk uchar_t *opt_ptr = NULL; 14741676Sjpk ts_label_t *tsl; 14751676Sjpk uint8_t proto; 14761676Sjpk int af, adjust; 14771676Sjpk uint16_t iplen; 14782535Ssangeeta boolean_t need_tpc_rele = B_FALSE; 14792535Ssangeeta ipaddr_t *gw; 14803448Sdh155122 ip_stack_t *ipst = ire->ire_ipst; 1481*8778SErik.Nordmark@Sun.COM cred_t *credp; 14821676Sjpk 14831676Sjpk ASSERT(ire != NULL && mp != NULL); 14841676Sjpk ASSERT(ire->ire_stq != NULL); 14851676Sjpk 14861676Sjpk af = (ire->ire_ipversion == IPV4_VERSION) ? AF_INET : AF_INET6; 14871676Sjpk 14881676Sjpk if (IPH_HDR_VERSION(mp->b_rptr) == IPV4_VERSION) { 14891676Sjpk ASSERT(ire->ire_ipversion == IPV4_VERSION); 14901676Sjpk ipha = (ipha_t *)mp->b_rptr; 14911676Sjpk psrc = &ipha->ipha_src; 14921676Sjpk pdst = &ipha->ipha_dst; 14931676Sjpk proto = ipha->ipha_protocol; 14941676Sjpk 14952535Ssangeeta /* 14962535Ssangeeta * off_link is TRUE if destination not directly reachable. 14972535Ssangeeta * Surya note: we avoid creation of per-dst IRE_CACHE entries 14982535Ssangeeta * for forwarded packets, so we set off_link to be TRUE 14992535Ssangeeta * if the packet dst is different from the ire_addr of 15002535Ssangeeta * the ire for the nexthop. 15012535Ssangeeta */ 15022535Ssangeeta off_link = ((ipha->ipha_dst != ire->ire_addr) || 15032535Ssangeeta (ire->ire_gateway_addr != INADDR_ANY)); 15041676Sjpk } else { 15051676Sjpk ASSERT(ire->ire_ipversion == IPV6_VERSION); 15061676Sjpk ip6h = (ip6_t *)mp->b_rptr; 15071676Sjpk psrc = &ip6h->ip6_src; 15081676Sjpk pdst = &ip6h->ip6_dst; 15091676Sjpk proto = ip6h->ip6_nxt; 15101676Sjpk 15111676Sjpk if (proto != IPPROTO_TCP && proto != IPPROTO_UDP && 15121676Sjpk proto != IPPROTO_ICMPV6) { 15131676Sjpk uint8_t *nexthdrp; 15141676Sjpk uint16_t hdr_len; 15151676Sjpk 15161676Sjpk if (!ip_hdr_length_nexthdr_v6(mp, ip6h, &hdr_len, 15171676Sjpk &nexthdrp)) { 15181676Sjpk /* malformed packet; drop it */ 15191676Sjpk return (NULL); 15201676Sjpk } 15211676Sjpk proto = *nexthdrp; 15221676Sjpk } 15231676Sjpk 15241676Sjpk /* destination not directly reachable? */ 15251676Sjpk off_link = !IN6_IS_ADDR_UNSPECIFIED(&ire->ire_gateway_addr_v6); 15261676Sjpk } 15271676Sjpk 1528*8778SErik.Nordmark@Sun.COM if ((tsl = msg_getlabel(mp)) == NULL) 15291676Sjpk return (mp); 15301676Sjpk 15311676Sjpk label_type = tsol_get_option(mp, &opt_ptr); 15321676Sjpk 15331676Sjpk ASSERT(psrc != NULL && pdst != NULL); 15341676Sjpk dst_rhtp = find_tpc(pdst, ire->ire_ipversion, B_FALSE); 15351676Sjpk 15361676Sjpk if (dst_rhtp == NULL) { 15371676Sjpk /* 15381676Sjpk * Without a template we do not know if forwarding 15391676Sjpk * violates MAC 15401676Sjpk */ 15411676Sjpk DTRACE_PROBE3(tx__ip__log__drop__forward__nodst, char *, 15421676Sjpk "mp(1) dropped, no template for destination ip4|6(2)", 15431676Sjpk mblk_t *, mp, void *, pdst); 15441676Sjpk return (NULL); 15451676Sjpk } 15461676Sjpk 15471676Sjpk /* 15481676Sjpk * Gateway template must have existed for off-link destinations, 15491676Sjpk * since tsol_ire_match_gwattr has ensured such condition. 15501676Sjpk */ 15512535Ssangeeta if (ire->ire_ipversion == IPV4_VERSION && off_link) { 15522535Ssangeeta /* 15532535Ssangeeta * Surya note: first check if we can get the gw_rhtp from 15542535Ssangeeta * the ire_gw_secattr->igsa_rhc; if this is null, then 15552535Ssangeeta * do a lookup based on the ire_addr (address of gw) 15562535Ssangeeta */ 15572535Ssangeeta if (ire->ire_gw_secattr != NULL && 15582535Ssangeeta ire->ire_gw_secattr->igsa_rhc != NULL) { 15592535Ssangeeta attrp = ire->ire_gw_secattr; 15602535Ssangeeta gw_rhtp = attrp->igsa_rhc->rhc_tpc; 15612535Ssangeeta } else { 15622535Ssangeeta /* 15632535Ssangeeta * use the ire_addr if this is the IRE_CACHE of nexthop 15642535Ssangeeta */ 15652535Ssangeeta gw = (ire->ire_gateway_addr == NULL? &ire->ire_addr : 15662535Ssangeeta &ire->ire_gateway_addr); 15672535Ssangeeta gw_rhtp = find_tpc(gw, ire->ire_ipversion, B_FALSE); 15682535Ssangeeta need_tpc_rele = B_TRUE; 15692535Ssangeeta } 15702535Ssangeeta if (gw_rhtp == NULL) { 15712535Ssangeeta DTRACE_PROBE3(tx__ip__log__drop__forward__nogw, char *, 15722535Ssangeeta "mp(1) dropped, no gateway in ire attributes(2)", 15732535Ssangeeta mblk_t *, mp, tsol_ire_gw_secattr_t *, attrp); 15742535Ssangeeta mp = NULL; 15752535Ssangeeta goto keep_label; 15762535Ssangeeta } 15772535Ssangeeta } 15782535Ssangeeta if (ire->ire_ipversion == IPV6_VERSION && 15792535Ssangeeta ((attrp = ire->ire_gw_secattr) == NULL || attrp->igsa_rhc == NULL || 15801676Sjpk (gw_rhtp = attrp->igsa_rhc->rhc_tpc) == NULL) && off_link) { 15811676Sjpk DTRACE_PROBE3(tx__ip__log__drop__forward__nogw, char *, 15821676Sjpk "mp(1) dropped, no gateway in ire attributes(2)", 15831676Sjpk mblk_t *, mp, tsol_ire_gw_secattr_t *, attrp); 15841676Sjpk mp = NULL; 15851676Sjpk goto keep_label; 15861676Sjpk } 15871676Sjpk 15881676Sjpk /* 15891676Sjpk * Check that the label for the packet is acceptable 15901676Sjpk * by destination host; otherwise, drop it. 15911676Sjpk */ 15921676Sjpk switch (dst_rhtp->tpc_tp.host_type) { 15931676Sjpk case SUN_CIPSO: 15941676Sjpk if (tsl->tsl_doi != dst_rhtp->tpc_tp.tp_doi || 15951676Sjpk (!_blinrange(&tsl->tsl_label, 15961676Sjpk &dst_rhtp->tpc_tp.tp_sl_range_cipso) && 15971676Sjpk !blinlset(&tsl->tsl_label, 15981676Sjpk dst_rhtp->tpc_tp.tp_sl_set_cipso))) { 15991676Sjpk DTRACE_PROBE4(tx__ip__log__drop__forward__mac, char *, 16001676Sjpk "labeled packet mp(1) dropped, label(2) fails " 16011676Sjpk "destination(3) accredation check", 16021676Sjpk mblk_t *, mp, ts_label_t *, tsl, 16031676Sjpk tsol_tpc_t *, dst_rhtp); 16041676Sjpk mp = NULL; 16051676Sjpk goto keep_label; 16061676Sjpk } 16071676Sjpk break; 16081676Sjpk 16091676Sjpk 16101676Sjpk case UNLABELED: 16111676Sjpk if (tsl->tsl_doi != dst_rhtp->tpc_tp.tp_doi || 16121676Sjpk !blequal(&dst_rhtp->tpc_tp.tp_def_label, 16131676Sjpk &tsl->tsl_label)) { 16141676Sjpk DTRACE_PROBE4(tx__ip__log__drop__forward__mac, char *, 16151676Sjpk "unlabeled packet mp(1) dropped, label(2) fails " 16161676Sjpk "destination(3) accredation check", 16171676Sjpk mblk_t *, mp, ts_label_t *, tsl, 16181676Sjpk tsol_tpc_t *, dst_rhtp); 16191676Sjpk mp = NULL; 16201676Sjpk goto keep_label; 16211676Sjpk } 16221676Sjpk break; 16231676Sjpk } 16241676Sjpk if (label_type == OPT_CIPSO) { 16251676Sjpk /* 16261676Sjpk * We keep the label on any of the following cases: 16271676Sjpk * 16281676Sjpk * 1. The destination is labeled (on/off-link). 16291676Sjpk * 2. The unlabeled destination is off-link, 16301676Sjpk * and the next hop gateway is labeled. 16311676Sjpk */ 16321676Sjpk if (dst_rhtp->tpc_tp.host_type != UNLABELED || 16331676Sjpk (off_link && 16341676Sjpk gw_rhtp->tpc_tp.host_type != UNLABELED)) 16351676Sjpk goto keep_label; 16361676Sjpk 16371676Sjpk /* 16381676Sjpk * Strip off the CIPSO option from the packet because: the 16391676Sjpk * unlabeled destination host is directly reachable through 16401676Sjpk * an interface (on-link); or, the unlabeled destination host 16411676Sjpk * is not directly reachable (off-link), and the next hop 16421676Sjpk * gateway is unlabeled. 16431676Sjpk */ 16441676Sjpk adjust = (af == AF_INET) ? tsol_remove_secopt(ipha, MBLKL(mp)) : 16451676Sjpk tsol_remove_secopt_v6(ip6h, MBLKL(mp)); 16461676Sjpk 16471676Sjpk ASSERT(adjust <= 0); 16481676Sjpk if (adjust != 0) { 16491676Sjpk 16501676Sjpk /* adjust is negative */ 16511676Sjpk ASSERT((mp->b_wptr + adjust) >= mp->b_rptr); 16521676Sjpk mp->b_wptr += adjust; 16531676Sjpk 16541676Sjpk if (af == AF_INET) { 16551676Sjpk ipha = (ipha_t *)mp->b_rptr; 16561676Sjpk iplen = ntohs(ipha->ipha_length) + adjust; 16571676Sjpk ipha->ipha_length = htons(iplen); 16581676Sjpk ipha->ipha_hdr_checksum = 0; 16591676Sjpk ipha->ipha_hdr_checksum = ip_csum_hdr(ipha); 16601676Sjpk } 16611676Sjpk DTRACE_PROBE3(tx__ip__log__info__forward__adjust, 16621676Sjpk char *, 16631676Sjpk "mp(1) adjusted(2) for CIPSO option removal", 16641676Sjpk mblk_t *, mp, int, adjust); 16651676Sjpk } 16661676Sjpk goto keep_label; 16671676Sjpk } 16681676Sjpk 16691676Sjpk ASSERT(label_type == OPT_NONE); 16701676Sjpk ASSERT(dst_rhtp != NULL); 16711676Sjpk 16721676Sjpk /* 16731676Sjpk * We need to add CIPSO option if the destination or the next hop 16741676Sjpk * gateway is labeled. Otherwise, pass the packet as is. 16751676Sjpk */ 16761676Sjpk if (dst_rhtp->tpc_tp.host_type == UNLABELED && 16771676Sjpk (!off_link || gw_rhtp->tpc_tp.host_type == UNLABELED)) 16781676Sjpk goto keep_label; 16791676Sjpk 1680*8778SErik.Nordmark@Sun.COM 1681*8778SErik.Nordmark@Sun.COM credp = msg_getcred(mp, NULL); 16821676Sjpk if ((af == AF_INET && 1683*8778SErik.Nordmark@Sun.COM tsol_check_label(credp, &mp, B_FALSE, ipst) != 0) || 16841676Sjpk (af == AF_INET6 && 1685*8778SErik.Nordmark@Sun.COM tsol_check_label_v6(credp, &mp, B_FALSE, ipst) != 0)) { 16861676Sjpk mp = NULL; 16871676Sjpk goto keep_label; 16881676Sjpk } 16891676Sjpk 16906596Skp158701 if (af == AF_INET) { 16916596Skp158701 ipha = (ipha_t *)mp->b_rptr; 16926596Skp158701 ipha->ipha_hdr_checksum = 0; 16936596Skp158701 ipha->ipha_hdr_checksum = ip_csum_hdr(ipha); 16941676Sjpk } 16951676Sjpk 16961676Sjpk keep_label: 16971676Sjpk TPC_RELE(dst_rhtp); 16982535Ssangeeta if (need_tpc_rele && gw_rhtp != NULL) 16992535Ssangeeta TPC_RELE(gw_rhtp); 17001676Sjpk return (mp); 17011676Sjpk } 17021676Sjpk 17031676Sjpk /* 17044564Swy83408 * Name: tsol_pmtu_adjust() 17054564Swy83408 * 17064564Swy83408 * Returns the adjusted mtu after removing security option. 17074564Swy83408 * Removes/subtracts the option if the packet's cred indicates an unlabeled 17084564Swy83408 * sender or if pkt_diff indicates this system enlarged the packet. 17094564Swy83408 */ 17104564Swy83408 uint32_t 17114564Swy83408 tsol_pmtu_adjust(mblk_t *mp, uint32_t mtu, int pkt_diff, int af) 17124564Swy83408 { 17134564Swy83408 int label_adj = 0; 17144564Swy83408 uint32_t min_mtu = IP_MIN_MTU; 17154564Swy83408 tsol_tpc_t *src_rhtp; 17164564Swy83408 void *src; 17174564Swy83408 17184564Swy83408 /* 17194564Swy83408 * Note: label_adj is non-positive, indicating the number of 17204564Swy83408 * bytes removed by removing the security option from the 17214564Swy83408 * header. 17224564Swy83408 */ 17234564Swy83408 if (af == AF_INET6) { 17244564Swy83408 ip6_t *ip6h; 17254564Swy83408 17264564Swy83408 min_mtu = IPV6_MIN_MTU; 17274564Swy83408 ip6h = (ip6_t *)mp->b_rptr; 17284564Swy83408 src = &ip6h->ip6_src; 17294564Swy83408 if ((src_rhtp = find_tpc(src, IPV6_VERSION, B_FALSE)) == NULL) 17304564Swy83408 return (mtu); 17314564Swy83408 if (pkt_diff > 0 || src_rhtp->tpc_tp.host_type == UNLABELED) { 17324564Swy83408 label_adj = tsol_remove_secopt_v6( 17334564Swy83408 (ip6_t *)mp->b_rptr, MBLKL(mp)); 17344564Swy83408 } 17354564Swy83408 } else { 17364564Swy83408 ipha_t *ipha; 17374564Swy83408 17384564Swy83408 ASSERT(af == AF_INET); 17394564Swy83408 ipha = (ipha_t *)mp->b_rptr; 17404564Swy83408 src = &ipha->ipha_src; 17414564Swy83408 if ((src_rhtp = find_tpc(src, IPV4_VERSION, B_FALSE)) == NULL) 17424564Swy83408 return (mtu); 17434564Swy83408 if (pkt_diff > 0 || src_rhtp->tpc_tp.host_type == UNLABELED) 17444564Swy83408 label_adj = tsol_remove_secopt( 17454564Swy83408 (ipha_t *)mp->b_rptr, MBLKL(mp)); 17464564Swy83408 } 17474564Swy83408 /* 17484564Swy83408 * Make pkt_diff non-negative and the larger of the bytes 17494564Swy83408 * previously added (if any) or just removed, since label 17504564Swy83408 * addition + subtraction may not be completely idempotent. 17514564Swy83408 */ 17524564Swy83408 if (pkt_diff < -label_adj) 17534564Swy83408 pkt_diff = -label_adj; 17544564Swy83408 if (pkt_diff > 0 && pkt_diff < mtu) 17554564Swy83408 mtu -= pkt_diff; 17564564Swy83408 17574564Swy83408 TPC_RELE(src_rhtp); 17584564Swy83408 return (MAX(mtu, min_mtu)); 17594564Swy83408 } 17604564Swy83408 17614564Swy83408 /* 17621676Sjpk * Name: tsol_rtsa_init() 17631676Sjpk * 17641676Sjpk * Normal: Sanity checks on the route security attributes provided by 17651676Sjpk * user. Convert it into a route security parameter list to 17661676Sjpk * be returned to caller. 17671676Sjpk * 17681676Sjpk * Output: EINVAL if bad security attributes in the routing message 17691676Sjpk * ENOMEM if unable to allocate data structures 17701676Sjpk * 0 otherwise. 17711676Sjpk * 17721676Sjpk * Note: On input, cp must point to the end of any addresses in 17731676Sjpk * the rt_msghdr_t structure. 17741676Sjpk */ 17751676Sjpk int 17761676Sjpk tsol_rtsa_init(rt_msghdr_t *rtm, tsol_rtsecattr_t *sp, caddr_t cp) 17771676Sjpk { 17781676Sjpk uint_t sacnt; 17791676Sjpk int err; 17801676Sjpk caddr_t lim; 17811676Sjpk tsol_rtsecattr_t *tp; 17821676Sjpk 17831676Sjpk ASSERT((cp >= (caddr_t)&rtm[1]) && sp != NULL); 17841676Sjpk 17851676Sjpk /* 17861676Sjpk * In theory, we could accept as many security attributes configured 17871676Sjpk * per route destination. However, the current design is limited 17881676Sjpk * such that at most only one set security attributes is allowed to 17891676Sjpk * be associated with a prefix IRE. We therefore assert for now. 17901676Sjpk */ 17911676Sjpk /* LINTED */ 17921676Sjpk ASSERT(TSOL_RTSA_REQUEST_MAX == 1); 17931676Sjpk 17941676Sjpk sp->rtsa_cnt = 0; 17951676Sjpk lim = (caddr_t)rtm + rtm->rtm_msglen; 17961676Sjpk ASSERT(cp <= lim); 17971676Sjpk 17981676Sjpk if ((lim - cp) < sizeof (rtm_ext_t) || 17991676Sjpk ((rtm_ext_t *)cp)->rtmex_type != RTMEX_GATEWAY_SECATTR) 18001676Sjpk return (0); 18011676Sjpk 18021676Sjpk if (((rtm_ext_t *)cp)->rtmex_len < sizeof (tsol_rtsecattr_t)) 18031676Sjpk return (EINVAL); 18041676Sjpk 18051676Sjpk cp += sizeof (rtm_ext_t); 18061676Sjpk 18071676Sjpk if ((lim - cp) < sizeof (*tp) || 18081676Sjpk (tp = (tsol_rtsecattr_t *)cp, (sacnt = tp->rtsa_cnt) == 0) || 18091676Sjpk (lim - cp) < TSOL_RTSECATTR_SIZE(sacnt)) 18101676Sjpk return (EINVAL); 18111676Sjpk 18121676Sjpk /* 18131676Sjpk * Trying to add route security attributes when system 18141676Sjpk * labeling service is not available, or when user supllies 18151676Sjpk * more than the maximum number of security attributes 18161676Sjpk * allowed per request. 18171676Sjpk */ 18181676Sjpk if ((sacnt > 0 && !is_system_labeled()) || 18191676Sjpk sacnt > TSOL_RTSA_REQUEST_MAX) 18201676Sjpk return (EINVAL); 18211676Sjpk 18221676Sjpk /* Ensure valid credentials */ 18231676Sjpk if ((err = rtsa_validate(&((tsol_rtsecattr_t *)cp)-> 18241676Sjpk rtsa_attr[0])) != 0) { 18251676Sjpk cp += sizeof (*sp); 18261676Sjpk return (err); 18271676Sjpk } 18281676Sjpk 18291676Sjpk bcopy(cp, sp, sizeof (*sp)); 18301676Sjpk cp += sizeof (*sp); 18311676Sjpk return (0); 18321676Sjpk } 18331676Sjpk 18341676Sjpk int 18351676Sjpk tsol_ire_init_gwattr(ire_t *ire, uchar_t ipversion, tsol_gc_t *gc, 18361676Sjpk tsol_gcgrp_t *gcgrp) 18371676Sjpk { 18381676Sjpk tsol_ire_gw_secattr_t *attrp; 18391676Sjpk boolean_t exists = B_FALSE; 18401676Sjpk in_addr_t ga_addr4; 18411676Sjpk void *paddr = NULL; 18421676Sjpk 18431676Sjpk ASSERT(ire != NULL); 18441676Sjpk 18451676Sjpk /* 18461676Sjpk * The only time that attrp can be NULL is when this routine is 18471676Sjpk * called for the first time during the creation/initialization 18481676Sjpk * of the corresponding IRE. It will only get cleared when the 18491676Sjpk * IRE is deleted. 18501676Sjpk */ 18511676Sjpk if ((attrp = ire->ire_gw_secattr) == NULL) { 18521676Sjpk attrp = ire_gw_secattr_alloc(KM_NOSLEEP); 18531676Sjpk if (attrp == NULL) 18541676Sjpk return (ENOMEM); 18551676Sjpk ire->ire_gw_secattr = attrp; 18561676Sjpk } else { 18571676Sjpk exists = B_TRUE; 18581676Sjpk mutex_enter(&attrp->igsa_lock); 18591676Sjpk 18601676Sjpk if (attrp->igsa_rhc != NULL) { 18611676Sjpk TNRHC_RELE(attrp->igsa_rhc); 18621676Sjpk attrp->igsa_rhc = NULL; 18631676Sjpk } 18641676Sjpk 18651676Sjpk if (attrp->igsa_gc != NULL) 18661676Sjpk GC_REFRELE(attrp->igsa_gc); 18671676Sjpk if (attrp->igsa_gcgrp != NULL) 18681676Sjpk GCGRP_REFRELE(attrp->igsa_gcgrp); 18691676Sjpk } 18701676Sjpk ASSERT(!exists || MUTEX_HELD(&attrp->igsa_lock)); 18711676Sjpk 18721676Sjpk /* 18731676Sjpk * References already held by caller and we keep them; 18741676Sjpk * note that both gc and gcgrp may be set to NULL to 18751676Sjpk * clear out igsa_gc and igsa_gcgrp, respectively. 18761676Sjpk */ 18771676Sjpk attrp->igsa_gc = gc; 18781676Sjpk attrp->igsa_gcgrp = gcgrp; 18791676Sjpk 18801676Sjpk if (gcgrp == NULL && gc != NULL) { 18811676Sjpk gcgrp = gc->gc_grp; 18821676Sjpk ASSERT(gcgrp != NULL); 18831676Sjpk } 18841676Sjpk 18851676Sjpk /* 18861676Sjpk * Intialize the template for gateway; we use the gateway's 18871676Sjpk * address found in either the passed in gateway credential 18881676Sjpk * or group pointer, or the ire_gateway_addr{_v6} field. 18891676Sjpk */ 18901676Sjpk if (gcgrp != NULL) { 18911676Sjpk tsol_gcgrp_addr_t *ga = &gcgrp->gcgrp_addr; 18921676Sjpk 18931676Sjpk /* 18941676Sjpk * Caller is holding a reference, and that we don't 18951676Sjpk * need to hold any lock to access the address. 18961676Sjpk */ 18971676Sjpk if (ipversion == IPV4_VERSION) { 18981676Sjpk ASSERT(ga->ga_af == AF_INET); 18991676Sjpk IN6_V4MAPPED_TO_IPADDR(&ga->ga_addr, ga_addr4); 19001676Sjpk paddr = &ga_addr4; 19011676Sjpk } else { 19021676Sjpk ASSERT(ga->ga_af == AF_INET6); 19031676Sjpk paddr = &ga->ga_addr; 19041676Sjpk } 19051676Sjpk } else if (ipversion == IPV6_VERSION && 19061676Sjpk !IN6_IS_ADDR_UNSPECIFIED(&ire->ire_gateway_addr_v6)) { 19071676Sjpk paddr = &ire->ire_gateway_addr_v6; 19081676Sjpk } else if (ipversion == IPV4_VERSION && 19091676Sjpk ire->ire_gateway_addr != INADDR_ANY) { 19101676Sjpk paddr = &ire->ire_gateway_addr; 19111676Sjpk } 19121676Sjpk 19131676Sjpk /* 19141676Sjpk * Lookup the gateway template; note that we could get an internal 19151676Sjpk * template here, which we cache anyway. During IRE matching, we'll 19161676Sjpk * try to update this gateway template cache and hopefully get a 19171676Sjpk * real one. 19181676Sjpk */ 19191676Sjpk if (paddr != NULL) { 19203292Skp158701 attrp->igsa_rhc = find_rhc(paddr, ipversion, B_FALSE); 19211676Sjpk } 19221676Sjpk 19231676Sjpk if (exists) 19241676Sjpk mutex_exit(&attrp->igsa_lock); 19251676Sjpk 19261676Sjpk return (0); 19271676Sjpk } 19281676Sjpk 19291676Sjpk /* 19301676Sjpk * This function figures the type of MLP that we'll be using based on the 19311676Sjpk * address that the user is binding and the zone. If the address is 19321676Sjpk * unspecified, then we're looking at both private and shared. If it's one 19331676Sjpk * of the zone's private addresses, then it's private only. If it's one 19341676Sjpk * of the global addresses, then it's shared only. 19351676Sjpk * 19361676Sjpk * If we can't figure out what it is, then return mlptSingle. That's actually 19371676Sjpk * an error case. 19383448Sdh155122 * 19393448Sdh155122 * The callers are assume to pass in zone->zone_id and not the zoneid that 19403448Sdh155122 * is stored in a conn_t (since the latter will be GLOBAL_ZONEID in an 19413448Sdh155122 * exclusive stack zone). 19421676Sjpk */ 19431676Sjpk mlp_type_t 19443448Sdh155122 tsol_mlp_addr_type(zoneid_t zoneid, uchar_t version, const void *addr, 19453448Sdh155122 ip_stack_t *ipst) 19461676Sjpk { 19471676Sjpk in_addr_t in4; 19481676Sjpk ire_t *ire; 19491676Sjpk ipif_t *ipif; 19501676Sjpk zoneid_t addrzone; 19513448Sdh155122 zoneid_t ip_zoneid; 19521676Sjpk 19531676Sjpk ASSERT(addr != NULL); 19541676Sjpk 19553448Sdh155122 /* 19563448Sdh155122 * For exclusive stacks we set the zoneid to zero 19573448Sdh155122 * to operate as if in the global zone for IRE and conn_t comparisons. 19583448Sdh155122 */ 19593448Sdh155122 if (ipst->ips_netstack->netstack_stackid != GLOBAL_NETSTACKID) 19603448Sdh155122 ip_zoneid = GLOBAL_ZONEID; 19613448Sdh155122 else 19623448Sdh155122 ip_zoneid = zoneid; 19633448Sdh155122 19641676Sjpk if (version == IPV6_VERSION && 19651676Sjpk IN6_IS_ADDR_V4MAPPED((const in6_addr_t *)addr)) { 19661676Sjpk IN6_V4MAPPED_TO_IPADDR((const in6_addr_t *)addr, in4); 19671676Sjpk addr = &in4; 19681676Sjpk version = IPV4_VERSION; 19691676Sjpk } 19701676Sjpk 19711676Sjpk if (version == IPV4_VERSION) { 19721676Sjpk in4 = *(const in_addr_t *)addr; 19733448Sdh155122 if (in4 == INADDR_ANY) { 19741676Sjpk return (mlptBoth); 19753448Sdh155122 } 19763448Sdh155122 ire = ire_cache_lookup(in4, ip_zoneid, NULL, ipst); 19771676Sjpk } else { 19783448Sdh155122 if (IN6_IS_ADDR_UNSPECIFIED((const in6_addr_t *)addr)) { 19791676Sjpk return (mlptBoth); 19803448Sdh155122 } 19813448Sdh155122 ire = ire_cache_lookup_v6(addr, ip_zoneid, NULL, ipst); 19821676Sjpk } 19831676Sjpk /* 19841676Sjpk * If we can't find the IRE, then we have to behave exactly like 19851676Sjpk * ip_bind_laddr{,_v6}. That means looking up the IPIF so that users 19861676Sjpk * can bind to addresses on "down" interfaces. 19871676Sjpk * 19881676Sjpk * If we can't find that either, then the bind is going to fail, so 19891676Sjpk * just give up. Note that there's a miniscule chance that the address 19901676Sjpk * is in transition, but we don't bother handling that. 19911676Sjpk */ 19921676Sjpk if (ire == NULL) { 19931676Sjpk if (version == IPV4_VERSION) 19941676Sjpk ipif = ipif_lookup_addr(*(const in_addr_t *)addr, NULL, 19953448Sdh155122 ip_zoneid, NULL, NULL, NULL, NULL, ipst); 19961676Sjpk else 19971676Sjpk ipif = ipif_lookup_addr_v6((const in6_addr_t *)addr, 19983448Sdh155122 NULL, ip_zoneid, NULL, NULL, NULL, NULL, ipst); 19993448Sdh155122 if (ipif == NULL) { 20001676Sjpk return (mlptSingle); 20013448Sdh155122 } 20021676Sjpk addrzone = ipif->ipif_zoneid; 20031676Sjpk ipif_refrele(ipif); 20041676Sjpk } else { 20051676Sjpk addrzone = ire->ire_zoneid; 20061676Sjpk ire_refrele(ire); 20071676Sjpk } 20081676Sjpk return (addrzone == ALL_ZONES ? mlptShared : mlptPrivate); 20091676Sjpk } 20101676Sjpk 20111676Sjpk /* 20121676Sjpk * Since we are configuring local interfaces, and we know trusted 20131676Sjpk * extension CDE requires local interfaces to be cipso host type in 20141676Sjpk * order to function correctly, we'll associate a cipso template 20151676Sjpk * to each local interface and let the interface come up. Configuring 20161676Sjpk * a local interface to be "unlabeled" host type is a configuration error. 20171676Sjpk * We'll override that error and make the interface host type to be cipso 20181676Sjpk * here. 20191676Sjpk * 20201676Sjpk * The code is optimized for the usual "success" case and unwinds things on 20211676Sjpk * error. We don't want to go to the trouble and expense of formatting the 20221676Sjpk * interface name for the usual case where everything is configured correctly. 20231676Sjpk */ 20241676Sjpk boolean_t 20251676Sjpk tsol_check_interface_address(const ipif_t *ipif) 20261676Sjpk { 20271676Sjpk tsol_tpc_t *tp; 20281676Sjpk char addrbuf[INET6_ADDRSTRLEN]; 20291676Sjpk int af; 20301676Sjpk const void *addr; 20311676Sjpk zone_t *zone; 20321676Sjpk ts_label_t *plabel; 20331676Sjpk const bslabel_t *label; 20341676Sjpk char ifbuf[LIFNAMSIZ + 10]; 20351676Sjpk const char *ifname; 20361676Sjpk boolean_t retval; 20371676Sjpk tsol_rhent_t rhent; 20383448Sdh155122 netstack_t *ns = ipif->ipif_ill->ill_ipst->ips_netstack; 20391676Sjpk 20401676Sjpk if (IN6_IS_ADDR_V4MAPPED(&ipif->ipif_v6lcl_addr)) { 20411676Sjpk af = AF_INET; 20421676Sjpk addr = &V4_PART_OF_V6(ipif->ipif_v6lcl_addr); 20431676Sjpk } else { 20441676Sjpk af = AF_INET6; 20451676Sjpk addr = &ipif->ipif_v6lcl_addr; 20461676Sjpk } 20471676Sjpk 20481676Sjpk tp = find_tpc(&ipif->ipif_v6lcl_addr, IPV6_VERSION, B_FALSE); 20493448Sdh155122 20503448Sdh155122 /* assumes that ALL_ZONES implies that there is no exclusive stack */ 20513448Sdh155122 if (ipif->ipif_zoneid == ALL_ZONES) { 20523448Sdh155122 zone = NULL; 20533448Sdh155122 } else if (ns->netstack_stackid == GLOBAL_NETSTACKID) { 20543448Sdh155122 /* Shared stack case */ 20553448Sdh155122 zone = zone_find_by_id(ipif->ipif_zoneid); 20563448Sdh155122 } else { 20573448Sdh155122 /* Exclusive stack case */ 20583448Sdh155122 zone = zone_find_by_id(crgetzoneid(ipif->ipif_ill->ill_credp)); 20593448Sdh155122 } 20601676Sjpk if (zone != NULL) { 20611676Sjpk plabel = zone->zone_slabel; 20621676Sjpk ASSERT(plabel != NULL); 20631676Sjpk label = label2bslabel(plabel); 20641676Sjpk } 20651676Sjpk 20661676Sjpk /* 20671676Sjpk * If it's CIPSO and an all-zones address, then we're done. 20681676Sjpk * If it's a CIPSO zone specific address, the zone's label 20691676Sjpk * must be in the range or set specified in the template. 20701676Sjpk * When the remote host entry is missing or the template 20711676Sjpk * type is incorrect for this interface, we create a 20721676Sjpk * CIPSO host entry in kernel and allow the interface to be 20731676Sjpk * brought up as CIPSO type. 20741676Sjpk */ 20751676Sjpk if (tp != NULL && ( 20761676Sjpk /* The all-zones case */ 20771676Sjpk (tp->tpc_tp.host_type == SUN_CIPSO && 20781676Sjpk tp->tpc_tp.tp_doi == default_doi && 20791676Sjpk ipif->ipif_zoneid == ALL_ZONES) || 20801676Sjpk /* The local-zone case */ 20811676Sjpk (zone != NULL && plabel->tsl_doi == tp->tpc_tp.tp_doi && 20821676Sjpk ((tp->tpc_tp.host_type == SUN_CIPSO && 20831676Sjpk (_blinrange(label, &tp->tpc_tp.tp_sl_range_cipso) || 20841676Sjpk blinlset(label, tp->tpc_tp.tp_sl_set_cipso))))))) { 20851676Sjpk if (zone != NULL) 20861676Sjpk zone_rele(zone); 20871676Sjpk TPC_RELE(tp); 20881676Sjpk return (B_TRUE); 20891676Sjpk } 20901676Sjpk 20911676Sjpk ifname = ipif->ipif_ill->ill_name; 20921676Sjpk if (ipif->ipif_id != 0) { 20931676Sjpk (void) snprintf(ifbuf, sizeof (ifbuf), "%s:%u", ifname, 20941676Sjpk ipif->ipif_id); 20951676Sjpk ifname = ifbuf; 20961676Sjpk } 20971676Sjpk (void) inet_ntop(af, addr, addrbuf, sizeof (addrbuf)); 20981676Sjpk 20991676Sjpk if (tp == NULL) { 21001676Sjpk cmn_err(CE_NOTE, "template entry for %s missing. Default to " 21011676Sjpk "CIPSO type for %s", ifname, addrbuf); 21021676Sjpk retval = B_TRUE; 21031676Sjpk } else if (tp->tpc_tp.host_type == UNLABELED) { 21041676Sjpk cmn_err(CE_NOTE, "template type for %s incorrectly configured. " 21051676Sjpk "Change to CIPSO type for %s", ifname, addrbuf); 21061676Sjpk retval = B_TRUE; 21071676Sjpk } else if (ipif->ipif_zoneid == ALL_ZONES) { 21081676Sjpk if (tp->tpc_tp.host_type != SUN_CIPSO) { 21091676Sjpk cmn_err(CE_NOTE, "%s failed: %s isn't set to CIPSO for " 21101676Sjpk "all-zones. Converted to CIPSO.", ifname, addrbuf); 21111676Sjpk retval = B_TRUE; 21121676Sjpk } else { 21131676Sjpk cmn_err(CE_NOTE, "%s failed: %s has wrong DOI %d " 21141676Sjpk "instead of %d", ifname, addrbuf, 21151676Sjpk tp->tpc_tp.tp_doi, default_doi); 21161676Sjpk retval = B_FALSE; 21171676Sjpk } 21181676Sjpk } else if (zone == NULL) { 21191676Sjpk cmn_err(CE_NOTE, "%s failed: zoneid %d unknown", 21201676Sjpk ifname, ipif->ipif_zoneid); 21211676Sjpk retval = B_FALSE; 21221676Sjpk } else if (plabel->tsl_doi != tp->tpc_tp.tp_doi) { 21231676Sjpk cmn_err(CE_NOTE, "%s failed: zone %s has DOI %d but %s has " 21241676Sjpk "DOI %d", ifname, zone->zone_name, plabel->tsl_doi, 21251676Sjpk addrbuf, tp->tpc_tp.tp_doi); 21261676Sjpk retval = B_FALSE; 21271676Sjpk } else { 21281676Sjpk cmn_err(CE_NOTE, "%s failed: zone %s label incompatible with " 21291676Sjpk "%s", ifname, zone->zone_name, addrbuf); 21301676Sjpk tsol_print_label(label, "zone label"); 21311676Sjpk retval = B_FALSE; 21321676Sjpk } 21331676Sjpk 21341676Sjpk if (zone != NULL) 21351676Sjpk zone_rele(zone); 21361676Sjpk if (tp != NULL) 21371676Sjpk TPC_RELE(tp); 21381676Sjpk if (retval) { 21391676Sjpk /* 21401676Sjpk * we've corrected a config error and let the interface 21411676Sjpk * come up as cipso. Need to insert an rhent. 21421676Sjpk */ 21431676Sjpk if ((rhent.rh_address.ta_family = af) == AF_INET) { 21441676Sjpk rhent.rh_prefix = 32; 21451676Sjpk rhent.rh_address.ta_addr_v4 = *(struct in_addr *)addr; 21461676Sjpk } else { 21471676Sjpk rhent.rh_prefix = 128; 21481676Sjpk rhent.rh_address.ta_addr_v6 = *(in6_addr_t *)addr; 21491676Sjpk } 21501676Sjpk (void) strcpy(rhent.rh_template, "cipso"); 21511676Sjpk if (tnrh_load(&rhent) != 0) { 21521676Sjpk cmn_err(CE_NOTE, "%s failed: Cannot insert CIPSO " 21531676Sjpk "template for local addr %s", ifname, addrbuf); 21541676Sjpk retval = B_FALSE; 21551676Sjpk } 21561676Sjpk } 21571676Sjpk return (retval); 21581676Sjpk } 2159