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 /* 228778SErik.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; 6858778SErik.Nordmark@Sun.COM cred_t *credp; 6868778SErik.Nordmark@Sun.COM pid_t cpid; 6871676Sjpk 6881676Sjpk ASSERT(DB_TYPE(mp) == M_DATA); 6891676Sjpk 690*9710SKen.Powell@Sun.COM if (mp->b_cont != NULL && !pullupmsg(mp, -1)) 691*9710SKen.Powell@Sun.COM return (B_FALSE); 692*9710SKen.Powell@Sun.COM 6931676Sjpk if (version == IPV4_VERSION) { 6941676Sjpk ipha = (const ipha_t *)mp->b_rptr; 6951676Sjpk src = &ipha->ipha_src; 6961676Sjpk label_type = tsol_get_option(mp, &opt_ptr); 6971676Sjpk } else { 6981676Sjpk uchar_t *after_secopt; 6991676Sjpk boolean_t hbh_needed; 7001676Sjpk const uchar_t *ip6hbh; 7011676Sjpk size_t optlen; 7021676Sjpk 7031676Sjpk label_type = OPT_NONE; 7041676Sjpk ip6h = (const ip6_t *)mp->b_rptr; 7051676Sjpk src = &ip6h->ip6_src; 7061676Sjpk if (ip6h->ip6_nxt == IPPROTO_HOPOPTS) { 7071676Sjpk ip6hbh = (const uchar_t *)&ip6h[1]; 7081676Sjpk optlen = (ip6hbh[1] + 1) << 3; 7091676Sjpk ASSERT(ip6hbh + optlen <= mp->b_wptr); 7101676Sjpk opt_ptr = tsol_find_secopt_v6(ip6hbh, optlen, 7111676Sjpk &after_secopt, &hbh_needed); 7121676Sjpk /* tsol_find_secopt_v6 guarantees some sanity */ 7131676Sjpk if (opt_ptr != NULL && 7141676Sjpk (optlen = opt_ptr[1]) >= 8) { 7151676Sjpk opt_ptr += 2; 7161676Sjpk bcopy(opt_ptr, &doi, sizeof (doi)); 7171676Sjpk doi = ntohl(doi); 7181676Sjpk if (doi == IP6LS_DOI_V4 && 7191676Sjpk opt_ptr[4] == IP6LS_TT_V4 && 7201676Sjpk opt_ptr[5] <= optlen - 4 && 7211676Sjpk opt_ptr[7] <= optlen - 6) { 7221676Sjpk opt_ptr += sizeof (doi) + 2; 7231676Sjpk label_type = OPT_CIPSO; 7241676Sjpk } 7251676Sjpk } 7261676Sjpk } 7271676Sjpk } 7281676Sjpk 7291676Sjpk switch (label_type) { 7301676Sjpk case OPT_CIPSO: 7311676Sjpk /* 7321676Sjpk * Convert the CIPSO label to the internal format 7331676Sjpk * and attach it to the dblk cred. 7341676Sjpk * Validity checks based on restrictions defined in 7351676Sjpk * COMMERCIAL IP SECURITY OPTION (CIPSO 2.2) 7361676Sjpk * (draft-ietf-cipso-ipsecurity) 7371676Sjpk */ 7381676Sjpk if (version == IPV6_VERSION && ip6opt_ls == 0) 7391676Sjpk return (B_FALSE); 7401676Sjpk co = (const struct cipso_option *)opt_ptr; 7411676Sjpk if ((co->cipso_length < 7421676Sjpk TSOL_CIPSO_TAG_OFFSET + TSOL_TT1_MIN_LENGTH) || 7431676Sjpk (co->cipso_length > IP_MAX_OPT_LENGTH)) 7441676Sjpk return (B_FALSE); 7451676Sjpk bcopy(co->cipso_doi, &doi, sizeof (doi)); 7461676Sjpk doi = ntohl(doi); 7471676Sjpk if (!cipso_to_sl(opt_ptr, &sl)) 7481676Sjpk return (B_FALSE); 7491676Sjpk setbltype(&sl, SUN_SL_ID); 7501676Sjpk break; 7511676Sjpk 7521676Sjpk case OPT_NONE: 7531676Sjpk /* 7541676Sjpk * Handle special cases that are not currently labeled, even 7551676Sjpk * though the sending system may otherwise be configured as 7561676Sjpk * labeled. 7571676Sjpk * - IGMP 7581676Sjpk * - IPv4 ICMP Router Discovery 7591676Sjpk * - IPv6 Neighbor Discovery 7601676Sjpk */ 7611676Sjpk if (version == IPV4_VERSION) { 7621676Sjpk if (ipha->ipha_protocol == IPPROTO_IGMP) 7631676Sjpk return (B_TRUE); 7641676Sjpk if (ipha->ipha_protocol == IPPROTO_ICMP) { 7651676Sjpk const struct icmp *icmp = (const struct icmp *) 7661676Sjpk (mp->b_rptr + IPH_HDR_LENGTH(ipha)); 7671676Sjpk 7681676Sjpk if ((uchar_t *)icmp > mp->b_wptr) { 7691676Sjpk if (!pullupmsg(mp, 7701676Sjpk (uchar_t *)icmp - mp->b_rptr + 1)) 7711676Sjpk return (B_FALSE); 7721676Sjpk icmp = (const struct icmp *) 7731676Sjpk (mp->b_rptr + 7741676Sjpk IPH_HDR_LENGTH(ipha)); 7751676Sjpk } 7761676Sjpk if (icmp->icmp_type == ICMP_ROUTERADVERT || 7771676Sjpk icmp->icmp_type == ICMP_ROUTERSOLICIT) 7781676Sjpk return (B_TRUE); 7791676Sjpk } 7801676Sjpk src = &ipha->ipha_src; 7811676Sjpk } else { 7821676Sjpk if (ip6h->ip6_nxt == IPPROTO_ICMPV6) { 7831676Sjpk const icmp6_t *icmp6 = (const icmp6_t *) 7841676Sjpk (mp->b_rptr + IPV6_HDR_LEN); 7851676Sjpk 7861676Sjpk if ((uchar_t *)icmp6 + ICMP6_MINLEN > 7871676Sjpk mp->b_wptr) { 7881676Sjpk if (!pullupmsg(mp, 7891676Sjpk (uchar_t *)icmp6 - mp->b_rptr + 7901676Sjpk ICMP6_MINLEN)) 7911676Sjpk return (B_FALSE); 7921676Sjpk icmp6 = (const icmp6_t *) 7931676Sjpk (mp->b_rptr + IPV6_HDR_LEN); 7941676Sjpk } 7951676Sjpk if (icmp6->icmp6_type >= MLD_LISTENER_QUERY && 7961676Sjpk icmp6->icmp6_type <= ICMP6_MAX_INFO_TYPE) 7971676Sjpk return (B_TRUE); 7981676Sjpk } 7991676Sjpk src = &ip6h->ip6_src; 8001676Sjpk } 8011676Sjpk 8021676Sjpk /* 8031676Sjpk * Look up the tnrhtp database and get the implicit label 8041676Sjpk * that is associated with this unlabeled host and attach 8051676Sjpk * it to the packet. 8061676Sjpk */ 8071676Sjpk if ((src_rhtp = find_tpc(src, version, B_FALSE)) == NULL) 8081676Sjpk return (B_FALSE); 8091676Sjpk 8101676Sjpk /* If the sender is labeled, drop the unlabeled packet. */ 8111676Sjpk if (src_rhtp->tpc_tp.host_type != UNLABELED) { 8121676Sjpk TPC_RELE(src_rhtp); 8131676Sjpk pr_addr_dbg("unlabeled packet forged from %s\n", 8141676Sjpk version == IPV4_VERSION ? AF_INET : AF_INET6, src); 8151676Sjpk return (B_FALSE); 8161676Sjpk } 8171676Sjpk 8181676Sjpk sl = src_rhtp->tpc_tp.tp_def_label; 8191676Sjpk setbltype(&sl, SUN_SL_ID); 8201676Sjpk doi = src_rhtp->tpc_tp.tp_doi; 8211676Sjpk TPC_RELE(src_rhtp); 8221676Sjpk break; 8231676Sjpk 8241676Sjpk default: 8251676Sjpk return (B_FALSE); 8261676Sjpk } 8271676Sjpk 8281676Sjpk /* Make sure no other thread is messing with this mblk */ 8291676Sjpk ASSERT(DB_REF(mp) == 1); 8308778SErik.Nordmark@Sun.COM /* Preserve db_cpid */ 8318778SErik.Nordmark@Sun.COM credp = msg_extractcred(mp, &cpid); 8328778SErik.Nordmark@Sun.COM if (credp == NULL) { 8338778SErik.Nordmark@Sun.COM credp = newcred_from_bslabel(&sl, doi, KM_NOSLEEP); 8341676Sjpk } else { 8351676Sjpk cred_t *newcr; 8361676Sjpk 8378778SErik.Nordmark@Sun.COM newcr = copycred_from_bslabel(credp, &sl, doi, 8381676Sjpk KM_NOSLEEP); 8398778SErik.Nordmark@Sun.COM crfree(credp); 8408778SErik.Nordmark@Sun.COM credp = newcr; 8411676Sjpk } 8429041SErik.Nordmark@Sun.COM if (credp == NULL) 8439041SErik.Nordmark@Sun.COM return (B_FALSE); 8449041SErik.Nordmark@Sun.COM mblk_setcred(mp, credp, cpid); 8459041SErik.Nordmark@Sun.COM crfree(credp); /* mblk has ref on cred */ 8461676Sjpk 8471676Sjpk /* 8481676Sjpk * If the source was unlabeled, then flag as such, 8491676Sjpk * while remembering that CIPSO routers add headers. 8501676Sjpk */ 8518778SErik.Nordmark@Sun.COM if (label_type == OPT_NONE) { 8528778SErik.Nordmark@Sun.COM crgetlabel(credp)->tsl_flags |= TSLF_UNLABELED; 8538778SErik.Nordmark@Sun.COM } else if (label_type == OPT_CIPSO) { 8541676Sjpk if ((src_rhtp = find_tpc(src, version, B_FALSE)) == NULL) 8551676Sjpk return (B_FALSE); 8561676Sjpk if (src_rhtp->tpc_tp.host_type == UNLABELED) 8578778SErik.Nordmark@Sun.COM crgetlabel(credp)->tsl_flags |= TSLF_UNLABELED; 8581676Sjpk TPC_RELE(src_rhtp); 8591676Sjpk } 8601676Sjpk 8611676Sjpk return (B_TRUE); 8621676Sjpk } 8631676Sjpk 8641676Sjpk /* 8651676Sjpk * This routine determines whether the given packet should be accepted locally. 8661676Sjpk * It does a range/set check on the packet's label by looking up the given 8671676Sjpk * address in the remote host database. 8681676Sjpk */ 8691676Sjpk boolean_t 8701676Sjpk tsol_receive_local(const mblk_t *mp, const void *addr, uchar_t version, 8711676Sjpk boolean_t shared_addr, const conn_t *connp) 8721676Sjpk { 8731676Sjpk const cred_t *credp; 8741676Sjpk ts_label_t *plabel, *conn_plabel; 8751676Sjpk tsol_tpc_t *tp; 8761676Sjpk boolean_t retv; 8771676Sjpk const bslabel_t *label, *conn_label; 8781676Sjpk 8791676Sjpk /* 8801676Sjpk * The cases in which this can happen are: 8811676Sjpk * - IPv6 Router Alert, where ip_rput_data_v6 deliberately skips 8821676Sjpk * over the label attachment process. 8831676Sjpk * - MLD output looped-back to ourselves. 8841676Sjpk * - IPv4 Router Discovery, where tsol_get_pkt_label intentionally 8851676Sjpk * avoids the labeling process. 8861676Sjpk * We trust that all valid paths in the code set the cred pointer when 8871676Sjpk * needed. 8881676Sjpk */ 8898778SErik.Nordmark@Sun.COM if ((credp = msg_getcred(mp, NULL)) == NULL) 8901676Sjpk return (B_TRUE); 8911676Sjpk 8921676Sjpk /* 8931676Sjpk * If this packet is from the inside (not a remote host) and has the 8941676Sjpk * same zoneid as the selected destination, then no checks are 8951676Sjpk * necessary. Membership in the zone is enough proof. This is 8961676Sjpk * intended to be a hot path through this function. 8971676Sjpk */ 8981676Sjpk if (!crisremote(credp) && 8991676Sjpk crgetzone(credp) == crgetzone(connp->conn_cred)) 9001676Sjpk return (B_TRUE); 9011676Sjpk 9021676Sjpk plabel = crgetlabel(credp); 9031676Sjpk conn_plabel = crgetlabel(connp->conn_cred); 9041676Sjpk ASSERT(plabel != NULL && conn_plabel != NULL); 9051676Sjpk 9061676Sjpk label = label2bslabel(plabel); 9071676Sjpk conn_label = label2bslabel(crgetlabel(connp->conn_cred)); 9081676Sjpk 9091676Sjpk /* 9101676Sjpk * MLPs are always validated using the range and set of the local 9111676Sjpk * address, even when the remote host is unlabeled. 9121676Sjpk */ 9131676Sjpk if (connp->conn_mlp_type == mlptBoth || 9141676Sjpk /* LINTED: no consequent */ 9151676Sjpk connp->conn_mlp_type == (shared_addr ? mlptShared : mlptPrivate)) { 9161676Sjpk ; 9171676Sjpk 9181676Sjpk /* 9191676Sjpk * If this is a packet from an unlabeled sender, then we must apply 9201676Sjpk * different rules. If the label is equal to the zone's label, then 9211676Sjpk * it's allowed. If it's not equal, but the zone is either the global 9221676Sjpk * zone or the label is dominated by the zone's label, then allow it 9231676Sjpk * as long as it's in the range configured for the destination. 9241676Sjpk */ 9251676Sjpk } else if (plabel->tsl_flags & TSLF_UNLABELED) { 9261676Sjpk if (plabel->tsl_doi == conn_plabel->tsl_doi && 9271676Sjpk blequal(label, conn_label)) 9281676Sjpk return (B_TRUE); 9291676Sjpk 9303448Sdh155122 /* 9313448Sdh155122 * conn_zoneid is global for an exclusive stack, thus we use 9323448Sdh155122 * conn_cred to get the zoneid 9333448Sdh155122 */ 9341676Sjpk if (!connp->conn_mac_exempt || 9353448Sdh155122 (crgetzoneid(connp->conn_cred) != GLOBAL_ZONEID && 9361676Sjpk (plabel->tsl_doi != conn_plabel->tsl_doi || 9371676Sjpk !bldominates(conn_label, label)))) { 9381676Sjpk DTRACE_PROBE3( 9391676Sjpk tx__ip__log__drop__receivelocal__mac_unl, 9401676Sjpk char *, 9411676Sjpk "unlabeled packet mp(1) fails mac for conn(2)", 9421676Sjpk mblk_t *, mp, conn_t *, connp); 9431676Sjpk return (B_FALSE); 9441676Sjpk } 9451676Sjpk 9461676Sjpk /* 9474448Skp158701 * If this is a packet from a labeled sender, verify the 9484448Skp158701 * label on the packet matches the connection label. 9491676Sjpk */ 9504448Skp158701 } else { 9514448Skp158701 if (plabel->tsl_doi != conn_plabel->tsl_doi || 9524448Skp158701 !blequal(label, conn_label)) { 9534448Skp158701 DTRACE_PROBE3(tx__ip__log__drop__receivelocal__mac__slp, 9544448Skp158701 char *, 9554448Skp158701 "packet mp(1) failed label match to SLP conn(2)", 9564448Skp158701 mblk_t *, mp, conn_t *, connp); 9574448Skp158701 return (B_FALSE); 9584448Skp158701 } 9591676Sjpk /* 9604448Skp158701 * No further checks will be needed if this is a zone- 9614448Skp158701 * specific address because (1) The process for bringing up 9624448Skp158701 * the interface ensures the zone's label is within the zone- 9634448Skp158701 * specific address's valid label range; (2) For cases where 9644448Skp158701 * the conn is bound to the unspecified addresses, ip fanout 9654448Skp158701 * logic ensures conn's zoneid equals the dest addr's zoneid; 9664448Skp158701 * (3) Mac-exempt and mlp logic above already handle all 9674448Skp158701 * cases where the zone label may not be the same as the 9684448Skp158701 * conn label. 9691676Sjpk */ 9704448Skp158701 if (!shared_addr) 9711676Sjpk return (B_TRUE); 9721676Sjpk } 9731676Sjpk 9741676Sjpk tp = find_tpc(addr, version, B_FALSE); 9751676Sjpk if (tp == NULL) { 9761676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__no__tnr, 9771676Sjpk char *, "dropping mp(1), host(2) lacks entry", 9781676Sjpk mblk_t *, mp, void *, addr); 9791676Sjpk return (B_FALSE); 9801676Sjpk } 9811676Sjpk 9821676Sjpk /* 9831676Sjpk * The local host address should not be unlabeled at this point. The 9841676Sjpk * only way this can happen is that the destination isn't unicast. We 9851676Sjpk * assume that the packet should not have had a label, and thus should 9861676Sjpk * have been handled by the TSLF_UNLABELED logic above. 9871676Sjpk */ 9881676Sjpk if (tp->tpc_tp.host_type == UNLABELED) { 9891676Sjpk retv = B_FALSE; 9901676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__flag, char *, 9911676Sjpk "mp(1) unlabeled source, but tp is not unlabeled.", 9921676Sjpk mblk_t *, mp, tsol_tpc_t *, tp); 9931676Sjpk 9941676Sjpk } else if (tp->tpc_tp.host_type != SUN_CIPSO) { 9951676Sjpk retv = B_FALSE; 9961676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__tptype, char *, 9971676Sjpk "delivering mp(1), found unrecognized tpc(2) type.", 9981676Sjpk mblk_t *, mp, tsol_tpc_t *, tp); 9991676Sjpk 10001676Sjpk } else if (plabel->tsl_doi != tp->tpc_tp.tp_doi) { 10011676Sjpk retv = B_FALSE; 10021676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__mac, char *, 10031676Sjpk "mp(1) could not be delievered to tp(2), doi mismatch", 10041676Sjpk mblk_t *, mp, tsol_tpc_t *, tp); 10051676Sjpk 10061676Sjpk } else if (!_blinrange(label, &tp->tpc_tp.tp_sl_range_cipso) && 10071676Sjpk !blinlset(label, tp->tpc_tp.tp_sl_set_cipso)) { 10081676Sjpk retv = B_FALSE; 10091676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__mac, char *, 10101676Sjpk "mp(1) could not be delievered to tp(2), bad mac", 10111676Sjpk mblk_t *, mp, tsol_tpc_t *, tp); 10121676Sjpk } else { 10131676Sjpk retv = B_TRUE; 10141676Sjpk } 10151676Sjpk 10161676Sjpk TPC_RELE(tp); 10171676Sjpk 10181676Sjpk return (retv); 10191676Sjpk } 10201676Sjpk 10211676Sjpk boolean_t 10221676Sjpk tsol_can_accept_raw(mblk_t *mp, boolean_t check_host) 10231676Sjpk { 10241676Sjpk ts_label_t *plabel = NULL; 10251676Sjpk tsol_tpc_t *src_rhtp, *dst_rhtp; 10261676Sjpk boolean_t retv; 10278778SErik.Nordmark@Sun.COM cred_t *credp; 10281676Sjpk 10298778SErik.Nordmark@Sun.COM credp = msg_getcred(mp, NULL); 10308778SErik.Nordmark@Sun.COM if (credp != NULL) 10318778SErik.Nordmark@Sun.COM plabel = crgetlabel(credp); 10321676Sjpk 10331676Sjpk /* We are bootstrapping or the internal template was never deleted */ 10341676Sjpk if (plabel == NULL) 10351676Sjpk return (B_TRUE); 10361676Sjpk 10371676Sjpk if (IPH_HDR_VERSION(mp->b_rptr) == IPV4_VERSION) { 10381676Sjpk ipha_t *ipha = (ipha_t *)mp->b_rptr; 10391676Sjpk 10401676Sjpk src_rhtp = find_tpc(&ipha->ipha_src, IPV4_VERSION, 10411676Sjpk B_FALSE); 10421676Sjpk if (src_rhtp == NULL) 10431676Sjpk return (B_FALSE); 10441676Sjpk dst_rhtp = find_tpc(&ipha->ipha_dst, IPV4_VERSION, 10451676Sjpk B_FALSE); 10461676Sjpk } else { 10471676Sjpk ip6_t *ip6h = (ip6_t *)mp->b_rptr; 10481676Sjpk 10491676Sjpk src_rhtp = find_tpc(&ip6h->ip6_src, IPV6_VERSION, 10501676Sjpk B_FALSE); 10511676Sjpk if (src_rhtp == NULL) 10521676Sjpk return (B_FALSE); 10531676Sjpk dst_rhtp = find_tpc(&ip6h->ip6_dst, IPV6_VERSION, 10541676Sjpk B_FALSE); 10551676Sjpk } 10561676Sjpk if (dst_rhtp == NULL) { 10571676Sjpk TPC_RELE(src_rhtp); 10581676Sjpk return (B_FALSE); 10591676Sjpk } 10601676Sjpk 10611676Sjpk if (label2doi(plabel) != src_rhtp->tpc_tp.tp_doi) { 10621676Sjpk retv = B_FALSE; 10631676Sjpk 10641676Sjpk /* 10651676Sjpk * Check that the packet's label is in the correct range for labeled 10661676Sjpk * sender, or is equal to the default label for unlabeled sender. 10671676Sjpk */ 10681676Sjpk } else if ((src_rhtp->tpc_tp.host_type != UNLABELED && 10691676Sjpk !_blinrange(label2bslabel(plabel), 10701676Sjpk &src_rhtp->tpc_tp.tp_sl_range_cipso) && 10711676Sjpk !blinlset(label2bslabel(plabel), 10721676Sjpk src_rhtp->tpc_tp.tp_sl_set_cipso)) || 10731676Sjpk (src_rhtp->tpc_tp.host_type == UNLABELED && 10741676Sjpk !blequal(&plabel->tsl_label, &src_rhtp->tpc_tp.tp_def_label))) { 10751676Sjpk retv = B_FALSE; 10761676Sjpk 10771676Sjpk } else if (check_host) { 10781676Sjpk retv = B_TRUE; 10791676Sjpk 10801676Sjpk /* 10811676Sjpk * Until we have SL range in the Zone structure, pass it 10821676Sjpk * when our own address lookup returned an internal entry. 10831676Sjpk */ 10841676Sjpk } else switch (dst_rhtp->tpc_tp.host_type) { 10851676Sjpk case UNLABELED: 10861676Sjpk retv = B_TRUE; 10871676Sjpk break; 10881676Sjpk 10891676Sjpk case SUN_CIPSO: 10901676Sjpk retv = _blinrange(label2bslabel(plabel), 10911676Sjpk &dst_rhtp->tpc_tp.tp_sl_range_cipso) || 10921676Sjpk blinlset(label2bslabel(plabel), 10931676Sjpk dst_rhtp->tpc_tp.tp_sl_set_cipso); 10941676Sjpk break; 10951676Sjpk 10961676Sjpk default: 10971676Sjpk retv = B_FALSE; 10981676Sjpk } 10991676Sjpk TPC_RELE(src_rhtp); 11001676Sjpk TPC_RELE(dst_rhtp); 11011676Sjpk return (retv); 11021676Sjpk } 11031676Sjpk 11041676Sjpk /* 11051676Sjpk * This routine determines whether a response to a failed packet delivery or 11061676Sjpk * connection should be sent back. By default, the policy is to allow such 11071676Sjpk * messages to be sent at all times, as these messages reveal little useful 11081676Sjpk * information and are healthy parts of TCP/IP networking. 11091676Sjpk * 11101676Sjpk * If tsol_strict_error is set, then we do strict tests: if the packet label is 11111676Sjpk * within the label range/set of this host/zone, return B_TRUE; otherwise 11121676Sjpk * return B_FALSE, which causes the packet to be dropped silently. 11131676Sjpk * 11141676Sjpk * Note that tsol_get_pkt_label will cause the packet to drop if the sender is 11151676Sjpk * marked as labeled in the remote host database, but the packet lacks a label. 11161676Sjpk * This means that we don't need to do a lookup on the source; the 11171676Sjpk * TSLF_UNLABELED flag is sufficient. 11181676Sjpk */ 11191676Sjpk boolean_t 11201676Sjpk tsol_can_reply_error(const mblk_t *mp) 11211676Sjpk { 11221676Sjpk ts_label_t *plabel = NULL; 11231676Sjpk tsol_tpc_t *rhtp; 11241676Sjpk const ipha_t *ipha; 11251676Sjpk const ip6_t *ip6h; 11261676Sjpk boolean_t retv; 11271676Sjpk bslabel_t *pktbs; 11288778SErik.Nordmark@Sun.COM cred_t *credp; 11291676Sjpk 11301676Sjpk /* Caller must pull up at least the IP header */ 11311676Sjpk ASSERT(MBLKL(mp) >= (IPH_HDR_VERSION(mp->b_rptr) == IPV4_VERSION ? 11321676Sjpk sizeof (*ipha) : sizeof (*ip6h))); 11331676Sjpk 11341676Sjpk if (!tsol_strict_error) 11351676Sjpk return (B_TRUE); 11361676Sjpk 11378778SErik.Nordmark@Sun.COM credp = msg_getcred(mp, NULL); 11388778SErik.Nordmark@Sun.COM if (credp != NULL) 11398778SErik.Nordmark@Sun.COM plabel = crgetlabel(credp); 11401676Sjpk 11411676Sjpk /* We are bootstrapping or the internal template was never deleted */ 11421676Sjpk if (plabel == NULL) 11431676Sjpk return (B_TRUE); 11441676Sjpk 11451676Sjpk if (IPH_HDR_VERSION(mp->b_rptr) == IPV4_VERSION) { 11461676Sjpk ipha = (const ipha_t *)mp->b_rptr; 11471676Sjpk rhtp = find_tpc(&ipha->ipha_dst, IPV4_VERSION, B_FALSE); 11481676Sjpk } else { 11491676Sjpk ip6h = (const ip6_t *)mp->b_rptr; 11501676Sjpk rhtp = find_tpc(&ip6h->ip6_dst, IPV6_VERSION, B_FALSE); 11511676Sjpk } 11521676Sjpk 11531676Sjpk if (rhtp == NULL || label2doi(plabel) != rhtp->tpc_tp.tp_doi) { 11541676Sjpk retv = B_FALSE; 11551676Sjpk } else { 11561676Sjpk /* 11571676Sjpk * If we're in the midst of forwarding, then the destination 11581676Sjpk * address might not be labeled. In that case, allow unlabeled 11591676Sjpk * packets through only if the default label is the same, and 11601676Sjpk * labeled ones if they dominate. 11611676Sjpk */ 11621676Sjpk pktbs = label2bslabel(plabel); 11631676Sjpk switch (rhtp->tpc_tp.host_type) { 11641676Sjpk case UNLABELED: 11651676Sjpk if (plabel->tsl_flags & TSLF_UNLABELED) { 11661676Sjpk retv = blequal(pktbs, 11671676Sjpk &rhtp->tpc_tp.tp_def_label); 11681676Sjpk } else { 11691676Sjpk retv = bldominates(pktbs, 11701676Sjpk &rhtp->tpc_tp.tp_def_label); 11711676Sjpk } 11721676Sjpk break; 11731676Sjpk 11741676Sjpk case SUN_CIPSO: 11751676Sjpk retv = _blinrange(pktbs, 11761676Sjpk &rhtp->tpc_tp.tp_sl_range_cipso) || 11771676Sjpk blinlset(pktbs, rhtp->tpc_tp.tp_sl_set_cipso); 11781676Sjpk break; 11791676Sjpk 11801676Sjpk default: 11811676Sjpk retv = B_FALSE; 11821676Sjpk break; 11831676Sjpk } 11841676Sjpk } 11851676Sjpk 11861676Sjpk if (rhtp != NULL) 11871676Sjpk TPC_RELE(rhtp); 11881676Sjpk 11891676Sjpk return (retv); 11901676Sjpk } 11911676Sjpk 11921676Sjpk /* 11931676Sjpk * Finds the zone associated with the given packet. Returns GLOBAL_ZONEID if 11941676Sjpk * the zone cannot be located. 11951676Sjpk * 11961676Sjpk * This is used by the classifier when the packet matches an ALL_ZONES IRE, and 11971676Sjpk * there's no MLP defined. 11983448Sdh155122 * 11993448Sdh155122 * Note that we assume that this is only invoked in the ALL_ZONES case. 12003448Sdh155122 * Handling other cases would require handle exclusive stack zones where either 12013448Sdh155122 * this routine or the callers would have to map from 12023448Sdh155122 * the zoneid (zone->zone_id) to what IP uses in conn_zoneid etc. 12031676Sjpk */ 12041676Sjpk zoneid_t 12051676Sjpk tsol_packet_to_zoneid(const mblk_t *mp) 12061676Sjpk { 12078778SErik.Nordmark@Sun.COM cred_t *cr = msg_getcred(mp, NULL); 12081676Sjpk zone_t *zone; 12091676Sjpk ts_label_t *label; 12101676Sjpk 12111676Sjpk if (cr != NULL) { 12121676Sjpk if ((label = crgetlabel(cr)) != NULL) { 12131676Sjpk zone = zone_find_by_label(label); 12141676Sjpk if (zone != NULL) { 12151676Sjpk zoneid_t zoneid = zone->zone_id; 12161676Sjpk 12171676Sjpk zone_rele(zone); 12181676Sjpk return (zoneid); 12191676Sjpk } 12201676Sjpk } 12211676Sjpk } 12221676Sjpk return (GLOBAL_ZONEID); 12231676Sjpk } 12241676Sjpk 12251676Sjpk int 12261676Sjpk tsol_ire_match_gwattr(ire_t *ire, const ts_label_t *tsl) 12271676Sjpk { 12281676Sjpk int error = 0; 12291676Sjpk tsol_ire_gw_secattr_t *attrp = NULL; 12301676Sjpk tsol_tnrhc_t *gw_rhc = NULL; 12311676Sjpk tsol_gcgrp_t *gcgrp = NULL; 12321676Sjpk tsol_gc_t *gc = NULL; 12331676Sjpk in_addr_t ga_addr4; 12341676Sjpk void *paddr = NULL; 12351676Sjpk 12361676Sjpk /* Not in Trusted mode or IRE is local/loopback/broadcast/interface */ 12371676Sjpk if (!is_system_labeled() || 12381676Sjpk (ire->ire_type & (IRE_LOCAL | IRE_LOOPBACK | IRE_BROADCAST | 12391676Sjpk IRE_INTERFACE))) 12401676Sjpk goto done; 12411676Sjpk 12421676Sjpk /* 12431676Sjpk * If we don't have a label to compare with, or the IRE does not 12441676Sjpk * contain any gateway security attributes, there's not much that 12451676Sjpk * we can do. We let the former case pass, and the latter fail, 12461676Sjpk * since the IRE doesn't qualify for a match due to the lack of 12471676Sjpk * security attributes. 12481676Sjpk */ 12491676Sjpk if (tsl == NULL || ire->ire_gw_secattr == NULL) { 12501676Sjpk if (tsl != NULL) { 12516596Skp158701 DTRACE_PROBE3(tx__ip__log__drop__irematch__nogwsec, 12526596Skp158701 char *, 12536596Skp158701 "ire(1) lacks ire_gw_secattr matching label(2)", 12546596Skp158701 ire_t *, ire, ts_label_t *, tsl); 12551676Sjpk error = EACCES; 12561676Sjpk } 12571676Sjpk goto done; 12581676Sjpk } 12591676Sjpk 12601676Sjpk attrp = ire->ire_gw_secattr; 12611676Sjpk 12621676Sjpk /* 12631676Sjpk * The possible lock order scenarios related to the tsol gateway 12641676Sjpk * attribute locks are documented at the beginning of ip.c in the 12651676Sjpk * lock order scenario section. 12661676Sjpk */ 12671676Sjpk mutex_enter(&attrp->igsa_lock); 12681676Sjpk 12691676Sjpk /* 12701676Sjpk * Depending on the IRE type (prefix vs. cache), we seek the group 12711676Sjpk * structure which contains all security credentials of the gateway. 12721676Sjpk * A prefix IRE is associated with at most one gateway credential, 12731676Sjpk * while a cache IRE is associated with every credentials that the 12741676Sjpk * gateway has. 12751676Sjpk */ 12761676Sjpk if ((gc = attrp->igsa_gc) != NULL) { /* prefix */ 12771676Sjpk gcgrp = gc->gc_grp; 12781676Sjpk ASSERT(gcgrp != NULL); 12791676Sjpk rw_enter(&gcgrp->gcgrp_rwlock, RW_READER); 12801676Sjpk } else if ((gcgrp = attrp->igsa_gcgrp) != NULL) { /* cache */ 12811676Sjpk rw_enter(&gcgrp->gcgrp_rwlock, RW_READER); 12821676Sjpk gc = gcgrp->gcgrp_head; 12831676Sjpk if (gc == NULL) { 12841676Sjpk /* gc group is empty, so the drop lock now */ 12851676Sjpk ASSERT(gcgrp->gcgrp_count == 0); 12861676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 12871676Sjpk gcgrp = NULL; 12881676Sjpk } 12891676Sjpk } 12901676Sjpk 12911676Sjpk if (gcgrp != NULL) 12921676Sjpk GCGRP_REFHOLD(gcgrp); 12931676Sjpk 12941676Sjpk if ((gw_rhc = attrp->igsa_rhc) != NULL) { 12951676Sjpk /* 12961676Sjpk * If our cached entry has grown stale, then discard it so we 12971676Sjpk * can get a new one. 12981676Sjpk */ 12991676Sjpk if (gw_rhc->rhc_invalid || gw_rhc->rhc_tpc->tpc_invalid) { 13001676Sjpk TNRHC_RELE(gw_rhc); 13011676Sjpk attrp->igsa_rhc = gw_rhc = NULL; 13021676Sjpk } else { 13031676Sjpk TNRHC_HOLD(gw_rhc) 13041676Sjpk } 13051676Sjpk } 13061676Sjpk 13071676Sjpk /* Last attempt at loading the template had failed; try again */ 13081676Sjpk if (gw_rhc == NULL) { 13091676Sjpk if (gcgrp != NULL) { 13101676Sjpk tsol_gcgrp_addr_t *ga = &gcgrp->gcgrp_addr; 13111676Sjpk 13121676Sjpk if (ire->ire_ipversion == IPV4_VERSION) { 13131676Sjpk ASSERT(ga->ga_af == AF_INET); 13141676Sjpk IN6_V4MAPPED_TO_IPADDR(&ga->ga_addr, ga_addr4); 13151676Sjpk paddr = &ga_addr4; 13161676Sjpk } else { 13171676Sjpk ASSERT(ga->ga_af == AF_INET6); 13181676Sjpk paddr = &ga->ga_addr; 13191676Sjpk } 13201676Sjpk } else if (ire->ire_ipversion == IPV6_VERSION && 13211676Sjpk !IN6_IS_ADDR_UNSPECIFIED(&ire->ire_gateway_addr_v6)) { 13221676Sjpk paddr = &ire->ire_gateway_addr_v6; 13231676Sjpk } else if (ire->ire_ipversion == IPV4_VERSION && 13241676Sjpk ire->ire_gateway_addr != INADDR_ANY) { 13251676Sjpk paddr = &ire->ire_gateway_addr; 13261676Sjpk } 13271676Sjpk 13281676Sjpk /* We've found a gateway address to do the template lookup */ 13291676Sjpk if (paddr != NULL) { 13301676Sjpk ASSERT(gw_rhc == NULL); 13313292Skp158701 gw_rhc = find_rhc(paddr, ire->ire_ipversion, B_FALSE); 13321676Sjpk if (gw_rhc != NULL) { 13331676Sjpk /* 13341676Sjpk * Note that if the lookup above returned an 13351676Sjpk * internal template, we'll use it for the 13361676Sjpk * time being, and do another lookup next 13371676Sjpk * time around. 13381676Sjpk */ 13391676Sjpk /* Another thread has loaded the template? */ 13401676Sjpk if (attrp->igsa_rhc != NULL) { 13411676Sjpk TNRHC_RELE(gw_rhc) 13421676Sjpk /* reload, it could be different */ 13431676Sjpk gw_rhc = attrp->igsa_rhc; 13441676Sjpk } else { 13451676Sjpk attrp->igsa_rhc = gw_rhc; 13461676Sjpk } 13471676Sjpk /* 13481676Sjpk * Hold an extra reference just like we did 13491676Sjpk * above prior to dropping the igsa_lock. 13501676Sjpk */ 13511676Sjpk TNRHC_HOLD(gw_rhc) 13521676Sjpk } 13531676Sjpk } 13541676Sjpk } 13551676Sjpk 13561676Sjpk mutex_exit(&attrp->igsa_lock); 13571676Sjpk /* Gateway template not found */ 13581676Sjpk if (gw_rhc == NULL) { 13591676Sjpk /* 13601676Sjpk * If destination address is directly reachable through an 13611676Sjpk * interface rather than through a learned route, pass it. 13621676Sjpk */ 13631676Sjpk if (paddr != NULL) { 13641676Sjpk DTRACE_PROBE3( 13651676Sjpk tx__ip__log__drop__irematch__nogwtmpl, char *, 13661676Sjpk "ire(1), label(2) off-link with no gw_rhc", 13671676Sjpk ire_t *, ire, ts_label_t *, tsl); 13681676Sjpk error = EINVAL; 13691676Sjpk } 13701676Sjpk goto done; 13711676Sjpk } 13721676Sjpk 13731676Sjpk if (gc != NULL) { 13741676Sjpk tsol_gcdb_t *gcdb; 13751676Sjpk /* 13761676Sjpk * In the case of IRE_CACHE we've got one or more gateway 13771676Sjpk * security credentials to compare against the passed in label. 13781676Sjpk * Perform label range comparison against each security 13791676Sjpk * credential of the gateway. In the case of a prefix ire 13801676Sjpk * we need to match against the security attributes of 13811676Sjpk * just the route itself, so the loop is executed only once. 13821676Sjpk */ 13831676Sjpk ASSERT(gcgrp != NULL); 13841676Sjpk do { 13851676Sjpk gcdb = gc->gc_db; 13861676Sjpk if (tsl->tsl_doi == gcdb->gcdb_doi && 13871676Sjpk _blinrange(&tsl->tsl_label, &gcdb->gcdb_slrange)) 13881676Sjpk break; 13891676Sjpk if (ire->ire_type == IRE_CACHE) 13901676Sjpk gc = gc->gc_next; 13911676Sjpk else 13921676Sjpk gc = NULL; 13931676Sjpk } while (gc != NULL); 13941676Sjpk 13951676Sjpk if (gc == NULL) { 13961676Sjpk DTRACE_PROBE3( 13971676Sjpk tx__ip__log__drop__irematch__nogcmatched, 13981676Sjpk char *, "ire(1), tsl(2): all gc failed match", 13991676Sjpk ire_t *, ire, ts_label_t *, tsl); 14001676Sjpk error = EACCES; 14011676Sjpk } 14021676Sjpk } else { 14031676Sjpk /* 14041676Sjpk * We didn't find any gateway credentials in the IRE 14051676Sjpk * attributes; fall back to the gateway's template for 14061676Sjpk * label range checks, if we are required to do so. 14071676Sjpk */ 14081676Sjpk ASSERT(gw_rhc != NULL); 14091676Sjpk switch (gw_rhc->rhc_tpc->tpc_tp.host_type) { 14101676Sjpk case SUN_CIPSO: 14116596Skp158701 if (tsl->tsl_doi != gw_rhc->rhc_tpc->tpc_tp.tp_doi || 14121676Sjpk (!_blinrange(&tsl->tsl_label, 14136596Skp158701 &gw_rhc->rhc_tpc->tpc_tp.tp_sl_range_cipso) && 14141676Sjpk !blinlset(&tsl->tsl_label, 14151676Sjpk gw_rhc->rhc_tpc->tpc_tp.tp_sl_set_cipso))) { 14161676Sjpk error = EACCES; 14171676Sjpk DTRACE_PROBE4( 14181676Sjpk tx__ip__log__drop__irematch__deftmpl, 14191676Sjpk char *, "ire(1), tsl(2), gw_rhc(3) " 14201676Sjpk "failed match (cipso gw)", 14211676Sjpk ire_t *, ire, ts_label_t *, tsl, 14221676Sjpk tsol_tnrhc_t *, gw_rhc); 14231676Sjpk } 14241676Sjpk break; 14251676Sjpk 14261676Sjpk case UNLABELED: 14276596Skp158701 if (tsl->tsl_doi != gw_rhc->rhc_tpc->tpc_tp.tp_doi || 14281676Sjpk (!_blinrange(&tsl->tsl_label, 14291676Sjpk &gw_rhc->rhc_tpc->tpc_tp.tp_gw_sl_range) && 14301676Sjpk !blinlset(&tsl->tsl_label, 14311676Sjpk gw_rhc->rhc_tpc->tpc_tp.tp_gw_sl_set))) { 14321676Sjpk error = EACCES; 14331676Sjpk DTRACE_PROBE4( 14341676Sjpk tx__ip__log__drop__irematch__deftmpl, 14351676Sjpk char *, "ire(1), tsl(2), gw_rhc(3) " 14361676Sjpk "failed match (unlabeled gw)", 14371676Sjpk ire_t *, ire, ts_label_t *, tsl, 14381676Sjpk tsol_tnrhc_t *, gw_rhc); 14391676Sjpk } 14401676Sjpk break; 14411676Sjpk } 14421676Sjpk } 14431676Sjpk 14441676Sjpk done: 14451676Sjpk 14461676Sjpk if (gcgrp != NULL) { 14471676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 14481676Sjpk GCGRP_REFRELE(gcgrp); 14491676Sjpk } 14501676Sjpk 14511676Sjpk if (gw_rhc != NULL) 14521676Sjpk TNRHC_RELE(gw_rhc) 14531676Sjpk 14541676Sjpk return (error); 14551676Sjpk } 14561676Sjpk 14571676Sjpk /* 14581676Sjpk * Performs label accreditation checks for packet forwarding. 14591676Sjpk * 14601676Sjpk * Returns a pointer to the modified mblk if allowed for forwarding, 14611676Sjpk * or NULL if the packet must be dropped. 14621676Sjpk */ 14631676Sjpk mblk_t * 14641676Sjpk tsol_ip_forward(ire_t *ire, mblk_t *mp) 14651676Sjpk { 14661676Sjpk tsol_ire_gw_secattr_t *attrp = NULL; 14671676Sjpk ipha_t *ipha; 14681676Sjpk ip6_t *ip6h; 14691676Sjpk const void *pdst; 14701676Sjpk const void *psrc; 14711676Sjpk boolean_t off_link; 14721676Sjpk tsol_tpc_t *dst_rhtp, *gw_rhtp; 14731676Sjpk tsol_ip_label_t label_type; 14741676Sjpk uchar_t *opt_ptr = NULL; 14751676Sjpk ts_label_t *tsl; 14761676Sjpk uint8_t proto; 14771676Sjpk int af, adjust; 14781676Sjpk uint16_t iplen; 14792535Ssangeeta boolean_t need_tpc_rele = B_FALSE; 14802535Ssangeeta ipaddr_t *gw; 14813448Sdh155122 ip_stack_t *ipst = ire->ire_ipst; 14828778SErik.Nordmark@Sun.COM cred_t *credp; 1483*9710SKen.Powell@Sun.COM pid_t pid; 14841676Sjpk 14851676Sjpk ASSERT(ire != NULL && mp != NULL); 14861676Sjpk ASSERT(ire->ire_stq != NULL); 14871676Sjpk 14881676Sjpk af = (ire->ire_ipversion == IPV4_VERSION) ? AF_INET : AF_INET6; 14891676Sjpk 14901676Sjpk if (IPH_HDR_VERSION(mp->b_rptr) == IPV4_VERSION) { 14911676Sjpk ASSERT(ire->ire_ipversion == IPV4_VERSION); 14921676Sjpk ipha = (ipha_t *)mp->b_rptr; 14931676Sjpk psrc = &ipha->ipha_src; 14941676Sjpk pdst = &ipha->ipha_dst; 14951676Sjpk proto = ipha->ipha_protocol; 14961676Sjpk 14972535Ssangeeta /* 14982535Ssangeeta * off_link is TRUE if destination not directly reachable. 14992535Ssangeeta * Surya note: we avoid creation of per-dst IRE_CACHE entries 15002535Ssangeeta * for forwarded packets, so we set off_link to be TRUE 15012535Ssangeeta * if the packet dst is different from the ire_addr of 15022535Ssangeeta * the ire for the nexthop. 15032535Ssangeeta */ 15042535Ssangeeta off_link = ((ipha->ipha_dst != ire->ire_addr) || 15052535Ssangeeta (ire->ire_gateway_addr != INADDR_ANY)); 15061676Sjpk } else { 15071676Sjpk ASSERT(ire->ire_ipversion == IPV6_VERSION); 15081676Sjpk ip6h = (ip6_t *)mp->b_rptr; 15091676Sjpk psrc = &ip6h->ip6_src; 15101676Sjpk pdst = &ip6h->ip6_dst; 15111676Sjpk proto = ip6h->ip6_nxt; 15121676Sjpk 15131676Sjpk if (proto != IPPROTO_TCP && proto != IPPROTO_UDP && 15141676Sjpk proto != IPPROTO_ICMPV6) { 15151676Sjpk uint8_t *nexthdrp; 15161676Sjpk uint16_t hdr_len; 15171676Sjpk 15181676Sjpk if (!ip_hdr_length_nexthdr_v6(mp, ip6h, &hdr_len, 15191676Sjpk &nexthdrp)) { 15201676Sjpk /* malformed packet; drop it */ 15211676Sjpk return (NULL); 15221676Sjpk } 15231676Sjpk proto = *nexthdrp; 15241676Sjpk } 15251676Sjpk 15261676Sjpk /* destination not directly reachable? */ 15271676Sjpk off_link = !IN6_IS_ADDR_UNSPECIFIED(&ire->ire_gateway_addr_v6); 15281676Sjpk } 15291676Sjpk 15308778SErik.Nordmark@Sun.COM if ((tsl = msg_getlabel(mp)) == NULL) 15311676Sjpk return (mp); 15321676Sjpk 15331676Sjpk label_type = tsol_get_option(mp, &opt_ptr); 15341676Sjpk 15351676Sjpk ASSERT(psrc != NULL && pdst != NULL); 15361676Sjpk dst_rhtp = find_tpc(pdst, ire->ire_ipversion, B_FALSE); 15371676Sjpk 15381676Sjpk if (dst_rhtp == NULL) { 15391676Sjpk /* 15401676Sjpk * Without a template we do not know if forwarding 15411676Sjpk * violates MAC 15421676Sjpk */ 15431676Sjpk DTRACE_PROBE3(tx__ip__log__drop__forward__nodst, char *, 15441676Sjpk "mp(1) dropped, no template for destination ip4|6(2)", 15451676Sjpk mblk_t *, mp, void *, pdst); 15461676Sjpk return (NULL); 15471676Sjpk } 15481676Sjpk 15491676Sjpk /* 15501676Sjpk * Gateway template must have existed for off-link destinations, 15511676Sjpk * since tsol_ire_match_gwattr has ensured such condition. 15521676Sjpk */ 15532535Ssangeeta if (ire->ire_ipversion == IPV4_VERSION && off_link) { 15542535Ssangeeta /* 15552535Ssangeeta * Surya note: first check if we can get the gw_rhtp from 15562535Ssangeeta * the ire_gw_secattr->igsa_rhc; if this is null, then 15572535Ssangeeta * do a lookup based on the ire_addr (address of gw) 15582535Ssangeeta */ 15592535Ssangeeta if (ire->ire_gw_secattr != NULL && 15602535Ssangeeta ire->ire_gw_secattr->igsa_rhc != NULL) { 15612535Ssangeeta attrp = ire->ire_gw_secattr; 15622535Ssangeeta gw_rhtp = attrp->igsa_rhc->rhc_tpc; 15632535Ssangeeta } else { 15642535Ssangeeta /* 15652535Ssangeeta * use the ire_addr if this is the IRE_CACHE of nexthop 15662535Ssangeeta */ 15672535Ssangeeta gw = (ire->ire_gateway_addr == NULL? &ire->ire_addr : 15682535Ssangeeta &ire->ire_gateway_addr); 15692535Ssangeeta gw_rhtp = find_tpc(gw, ire->ire_ipversion, B_FALSE); 15702535Ssangeeta need_tpc_rele = B_TRUE; 15712535Ssangeeta } 15722535Ssangeeta if (gw_rhtp == NULL) { 15732535Ssangeeta DTRACE_PROBE3(tx__ip__log__drop__forward__nogw, char *, 15742535Ssangeeta "mp(1) dropped, no gateway in ire attributes(2)", 15752535Ssangeeta mblk_t *, mp, tsol_ire_gw_secattr_t *, attrp); 15762535Ssangeeta mp = NULL; 15772535Ssangeeta goto keep_label; 15782535Ssangeeta } 15792535Ssangeeta } 15802535Ssangeeta if (ire->ire_ipversion == IPV6_VERSION && 15812535Ssangeeta ((attrp = ire->ire_gw_secattr) == NULL || attrp->igsa_rhc == NULL || 15821676Sjpk (gw_rhtp = attrp->igsa_rhc->rhc_tpc) == NULL) && off_link) { 15831676Sjpk DTRACE_PROBE3(tx__ip__log__drop__forward__nogw, char *, 15841676Sjpk "mp(1) dropped, no gateway in ire attributes(2)", 15851676Sjpk mblk_t *, mp, tsol_ire_gw_secattr_t *, attrp); 15861676Sjpk mp = NULL; 15871676Sjpk goto keep_label; 15881676Sjpk } 15891676Sjpk 15901676Sjpk /* 15911676Sjpk * Check that the label for the packet is acceptable 15921676Sjpk * by destination host; otherwise, drop it. 15931676Sjpk */ 15941676Sjpk switch (dst_rhtp->tpc_tp.host_type) { 15951676Sjpk case SUN_CIPSO: 15961676Sjpk if (tsl->tsl_doi != dst_rhtp->tpc_tp.tp_doi || 15971676Sjpk (!_blinrange(&tsl->tsl_label, 15981676Sjpk &dst_rhtp->tpc_tp.tp_sl_range_cipso) && 15991676Sjpk !blinlset(&tsl->tsl_label, 16001676Sjpk dst_rhtp->tpc_tp.tp_sl_set_cipso))) { 16011676Sjpk DTRACE_PROBE4(tx__ip__log__drop__forward__mac, char *, 16021676Sjpk "labeled packet mp(1) dropped, label(2) fails " 16031676Sjpk "destination(3) accredation check", 16041676Sjpk mblk_t *, mp, ts_label_t *, tsl, 16051676Sjpk tsol_tpc_t *, dst_rhtp); 16061676Sjpk mp = NULL; 16071676Sjpk goto keep_label; 16081676Sjpk } 16091676Sjpk break; 16101676Sjpk 16111676Sjpk 16121676Sjpk case UNLABELED: 16131676Sjpk if (tsl->tsl_doi != dst_rhtp->tpc_tp.tp_doi || 16141676Sjpk !blequal(&dst_rhtp->tpc_tp.tp_def_label, 16151676Sjpk &tsl->tsl_label)) { 16161676Sjpk DTRACE_PROBE4(tx__ip__log__drop__forward__mac, char *, 16171676Sjpk "unlabeled packet mp(1) dropped, label(2) fails " 16181676Sjpk "destination(3) accredation check", 16191676Sjpk mblk_t *, mp, ts_label_t *, tsl, 16201676Sjpk tsol_tpc_t *, dst_rhtp); 16211676Sjpk mp = NULL; 16221676Sjpk goto keep_label; 16231676Sjpk } 16241676Sjpk break; 16251676Sjpk } 16261676Sjpk if (label_type == OPT_CIPSO) { 16271676Sjpk /* 16281676Sjpk * We keep the label on any of the following cases: 16291676Sjpk * 16301676Sjpk * 1. The destination is labeled (on/off-link). 16311676Sjpk * 2. The unlabeled destination is off-link, 16321676Sjpk * and the next hop gateway is labeled. 16331676Sjpk */ 16341676Sjpk if (dst_rhtp->tpc_tp.host_type != UNLABELED || 16351676Sjpk (off_link && 16361676Sjpk gw_rhtp->tpc_tp.host_type != UNLABELED)) 16371676Sjpk goto keep_label; 16381676Sjpk 16391676Sjpk /* 16401676Sjpk * Strip off the CIPSO option from the packet because: the 16411676Sjpk * unlabeled destination host is directly reachable through 16421676Sjpk * an interface (on-link); or, the unlabeled destination host 16431676Sjpk * is not directly reachable (off-link), and the next hop 16441676Sjpk * gateway is unlabeled. 16451676Sjpk */ 16461676Sjpk adjust = (af == AF_INET) ? tsol_remove_secopt(ipha, MBLKL(mp)) : 16471676Sjpk tsol_remove_secopt_v6(ip6h, MBLKL(mp)); 16481676Sjpk 16491676Sjpk ASSERT(adjust <= 0); 16501676Sjpk if (adjust != 0) { 16511676Sjpk 16521676Sjpk /* adjust is negative */ 16531676Sjpk ASSERT((mp->b_wptr + adjust) >= mp->b_rptr); 16541676Sjpk mp->b_wptr += adjust; 16551676Sjpk 16561676Sjpk if (af == AF_INET) { 16571676Sjpk ipha = (ipha_t *)mp->b_rptr; 16581676Sjpk iplen = ntohs(ipha->ipha_length) + adjust; 16591676Sjpk ipha->ipha_length = htons(iplen); 16601676Sjpk ipha->ipha_hdr_checksum = 0; 16611676Sjpk ipha->ipha_hdr_checksum = ip_csum_hdr(ipha); 16621676Sjpk } 16631676Sjpk DTRACE_PROBE3(tx__ip__log__info__forward__adjust, 16641676Sjpk char *, 16651676Sjpk "mp(1) adjusted(2) for CIPSO option removal", 16661676Sjpk mblk_t *, mp, int, adjust); 16671676Sjpk } 16681676Sjpk goto keep_label; 16691676Sjpk } 16701676Sjpk 16711676Sjpk ASSERT(label_type == OPT_NONE); 16721676Sjpk ASSERT(dst_rhtp != NULL); 16731676Sjpk 16741676Sjpk /* 16751676Sjpk * We need to add CIPSO option if the destination or the next hop 16761676Sjpk * gateway is labeled. Otherwise, pass the packet as is. 16771676Sjpk */ 16781676Sjpk if (dst_rhtp->tpc_tp.host_type == UNLABELED && 16791676Sjpk (!off_link || gw_rhtp->tpc_tp.host_type == UNLABELED)) 16801676Sjpk goto keep_label; 16811676Sjpk 16828778SErik.Nordmark@Sun.COM 1683*9710SKen.Powell@Sun.COM credp = msg_getcred(mp, &pid); 16841676Sjpk if ((af == AF_INET && 1685*9710SKen.Powell@Sun.COM tsol_check_label(credp, &mp, B_FALSE, ipst, pid) != 0) || 16861676Sjpk (af == AF_INET6 && 1687*9710SKen.Powell@Sun.COM tsol_check_label_v6(credp, &mp, B_FALSE, ipst, pid) != 0)) { 16881676Sjpk mp = NULL; 16891676Sjpk goto keep_label; 16901676Sjpk } 16911676Sjpk 16926596Skp158701 if (af == AF_INET) { 16936596Skp158701 ipha = (ipha_t *)mp->b_rptr; 16946596Skp158701 ipha->ipha_hdr_checksum = 0; 16956596Skp158701 ipha->ipha_hdr_checksum = ip_csum_hdr(ipha); 16961676Sjpk } 16971676Sjpk 16981676Sjpk keep_label: 16991676Sjpk TPC_RELE(dst_rhtp); 17002535Ssangeeta if (need_tpc_rele && gw_rhtp != NULL) 17012535Ssangeeta TPC_RELE(gw_rhtp); 17021676Sjpk return (mp); 17031676Sjpk } 17041676Sjpk 17051676Sjpk /* 17064564Swy83408 * Name: tsol_pmtu_adjust() 17074564Swy83408 * 17084564Swy83408 * Returns the adjusted mtu after removing security option. 17094564Swy83408 * Removes/subtracts the option if the packet's cred indicates an unlabeled 17104564Swy83408 * sender or if pkt_diff indicates this system enlarged the packet. 17114564Swy83408 */ 17124564Swy83408 uint32_t 17134564Swy83408 tsol_pmtu_adjust(mblk_t *mp, uint32_t mtu, int pkt_diff, int af) 17144564Swy83408 { 17154564Swy83408 int label_adj = 0; 17164564Swy83408 uint32_t min_mtu = IP_MIN_MTU; 17174564Swy83408 tsol_tpc_t *src_rhtp; 17184564Swy83408 void *src; 17194564Swy83408 17204564Swy83408 /* 17214564Swy83408 * Note: label_adj is non-positive, indicating the number of 17224564Swy83408 * bytes removed by removing the security option from the 17234564Swy83408 * header. 17244564Swy83408 */ 17254564Swy83408 if (af == AF_INET6) { 17264564Swy83408 ip6_t *ip6h; 17274564Swy83408 17284564Swy83408 min_mtu = IPV6_MIN_MTU; 17294564Swy83408 ip6h = (ip6_t *)mp->b_rptr; 17304564Swy83408 src = &ip6h->ip6_src; 17314564Swy83408 if ((src_rhtp = find_tpc(src, IPV6_VERSION, B_FALSE)) == NULL) 17324564Swy83408 return (mtu); 17334564Swy83408 if (pkt_diff > 0 || src_rhtp->tpc_tp.host_type == UNLABELED) { 17344564Swy83408 label_adj = tsol_remove_secopt_v6( 17354564Swy83408 (ip6_t *)mp->b_rptr, MBLKL(mp)); 17364564Swy83408 } 17374564Swy83408 } else { 17384564Swy83408 ipha_t *ipha; 17394564Swy83408 17404564Swy83408 ASSERT(af == AF_INET); 17414564Swy83408 ipha = (ipha_t *)mp->b_rptr; 17424564Swy83408 src = &ipha->ipha_src; 17434564Swy83408 if ((src_rhtp = find_tpc(src, IPV4_VERSION, B_FALSE)) == NULL) 17444564Swy83408 return (mtu); 17454564Swy83408 if (pkt_diff > 0 || src_rhtp->tpc_tp.host_type == UNLABELED) 17464564Swy83408 label_adj = tsol_remove_secopt( 17474564Swy83408 (ipha_t *)mp->b_rptr, MBLKL(mp)); 17484564Swy83408 } 17494564Swy83408 /* 17504564Swy83408 * Make pkt_diff non-negative and the larger of the bytes 17514564Swy83408 * previously added (if any) or just removed, since label 17524564Swy83408 * addition + subtraction may not be completely idempotent. 17534564Swy83408 */ 17544564Swy83408 if (pkt_diff < -label_adj) 17554564Swy83408 pkt_diff = -label_adj; 17564564Swy83408 if (pkt_diff > 0 && pkt_diff < mtu) 17574564Swy83408 mtu -= pkt_diff; 17584564Swy83408 17594564Swy83408 TPC_RELE(src_rhtp); 17604564Swy83408 return (MAX(mtu, min_mtu)); 17614564Swy83408 } 17624564Swy83408 17634564Swy83408 /* 17641676Sjpk * Name: tsol_rtsa_init() 17651676Sjpk * 17661676Sjpk * Normal: Sanity checks on the route security attributes provided by 17671676Sjpk * user. Convert it into a route security parameter list to 17681676Sjpk * be returned to caller. 17691676Sjpk * 17701676Sjpk * Output: EINVAL if bad security attributes in the routing message 17711676Sjpk * ENOMEM if unable to allocate data structures 17721676Sjpk * 0 otherwise. 17731676Sjpk * 17741676Sjpk * Note: On input, cp must point to the end of any addresses in 17751676Sjpk * the rt_msghdr_t structure. 17761676Sjpk */ 17771676Sjpk int 17781676Sjpk tsol_rtsa_init(rt_msghdr_t *rtm, tsol_rtsecattr_t *sp, caddr_t cp) 17791676Sjpk { 17801676Sjpk uint_t sacnt; 17811676Sjpk int err; 17821676Sjpk caddr_t lim; 17831676Sjpk tsol_rtsecattr_t *tp; 17841676Sjpk 17851676Sjpk ASSERT((cp >= (caddr_t)&rtm[1]) && sp != NULL); 17861676Sjpk 17871676Sjpk /* 17881676Sjpk * In theory, we could accept as many security attributes configured 17891676Sjpk * per route destination. However, the current design is limited 17901676Sjpk * such that at most only one set security attributes is allowed to 17911676Sjpk * be associated with a prefix IRE. We therefore assert for now. 17921676Sjpk */ 17931676Sjpk /* LINTED */ 17941676Sjpk ASSERT(TSOL_RTSA_REQUEST_MAX == 1); 17951676Sjpk 17961676Sjpk sp->rtsa_cnt = 0; 17971676Sjpk lim = (caddr_t)rtm + rtm->rtm_msglen; 17981676Sjpk ASSERT(cp <= lim); 17991676Sjpk 18001676Sjpk if ((lim - cp) < sizeof (rtm_ext_t) || 18011676Sjpk ((rtm_ext_t *)cp)->rtmex_type != RTMEX_GATEWAY_SECATTR) 18021676Sjpk return (0); 18031676Sjpk 18041676Sjpk if (((rtm_ext_t *)cp)->rtmex_len < sizeof (tsol_rtsecattr_t)) 18051676Sjpk return (EINVAL); 18061676Sjpk 18071676Sjpk cp += sizeof (rtm_ext_t); 18081676Sjpk 18091676Sjpk if ((lim - cp) < sizeof (*tp) || 18101676Sjpk (tp = (tsol_rtsecattr_t *)cp, (sacnt = tp->rtsa_cnt) == 0) || 18111676Sjpk (lim - cp) < TSOL_RTSECATTR_SIZE(sacnt)) 18121676Sjpk return (EINVAL); 18131676Sjpk 18141676Sjpk /* 18151676Sjpk * Trying to add route security attributes when system 18161676Sjpk * labeling service is not available, or when user supllies 18171676Sjpk * more than the maximum number of security attributes 18181676Sjpk * allowed per request. 18191676Sjpk */ 18201676Sjpk if ((sacnt > 0 && !is_system_labeled()) || 18211676Sjpk sacnt > TSOL_RTSA_REQUEST_MAX) 18221676Sjpk return (EINVAL); 18231676Sjpk 18241676Sjpk /* Ensure valid credentials */ 18251676Sjpk if ((err = rtsa_validate(&((tsol_rtsecattr_t *)cp)-> 18261676Sjpk rtsa_attr[0])) != 0) { 18271676Sjpk cp += sizeof (*sp); 18281676Sjpk return (err); 18291676Sjpk } 18301676Sjpk 18311676Sjpk bcopy(cp, sp, sizeof (*sp)); 18321676Sjpk cp += sizeof (*sp); 18331676Sjpk return (0); 18341676Sjpk } 18351676Sjpk 18361676Sjpk int 18371676Sjpk tsol_ire_init_gwattr(ire_t *ire, uchar_t ipversion, tsol_gc_t *gc, 18381676Sjpk tsol_gcgrp_t *gcgrp) 18391676Sjpk { 18401676Sjpk tsol_ire_gw_secattr_t *attrp; 18411676Sjpk boolean_t exists = B_FALSE; 18421676Sjpk in_addr_t ga_addr4; 18431676Sjpk void *paddr = NULL; 18441676Sjpk 18451676Sjpk ASSERT(ire != NULL); 18461676Sjpk 18471676Sjpk /* 18481676Sjpk * The only time that attrp can be NULL is when this routine is 18491676Sjpk * called for the first time during the creation/initialization 18501676Sjpk * of the corresponding IRE. It will only get cleared when the 18511676Sjpk * IRE is deleted. 18521676Sjpk */ 18531676Sjpk if ((attrp = ire->ire_gw_secattr) == NULL) { 18541676Sjpk attrp = ire_gw_secattr_alloc(KM_NOSLEEP); 18551676Sjpk if (attrp == NULL) 18561676Sjpk return (ENOMEM); 18571676Sjpk ire->ire_gw_secattr = attrp; 18581676Sjpk } else { 18591676Sjpk exists = B_TRUE; 18601676Sjpk mutex_enter(&attrp->igsa_lock); 18611676Sjpk 18621676Sjpk if (attrp->igsa_rhc != NULL) { 18631676Sjpk TNRHC_RELE(attrp->igsa_rhc); 18641676Sjpk attrp->igsa_rhc = NULL; 18651676Sjpk } 18661676Sjpk 18671676Sjpk if (attrp->igsa_gc != NULL) 18681676Sjpk GC_REFRELE(attrp->igsa_gc); 18691676Sjpk if (attrp->igsa_gcgrp != NULL) 18701676Sjpk GCGRP_REFRELE(attrp->igsa_gcgrp); 18711676Sjpk } 18721676Sjpk ASSERT(!exists || MUTEX_HELD(&attrp->igsa_lock)); 18731676Sjpk 18741676Sjpk /* 18751676Sjpk * References already held by caller and we keep them; 18761676Sjpk * note that both gc and gcgrp may be set to NULL to 18771676Sjpk * clear out igsa_gc and igsa_gcgrp, respectively. 18781676Sjpk */ 18791676Sjpk attrp->igsa_gc = gc; 18801676Sjpk attrp->igsa_gcgrp = gcgrp; 18811676Sjpk 18821676Sjpk if (gcgrp == NULL && gc != NULL) { 18831676Sjpk gcgrp = gc->gc_grp; 18841676Sjpk ASSERT(gcgrp != NULL); 18851676Sjpk } 18861676Sjpk 18871676Sjpk /* 18881676Sjpk * Intialize the template for gateway; we use the gateway's 18891676Sjpk * address found in either the passed in gateway credential 18901676Sjpk * or group pointer, or the ire_gateway_addr{_v6} field. 18911676Sjpk */ 18921676Sjpk if (gcgrp != NULL) { 18931676Sjpk tsol_gcgrp_addr_t *ga = &gcgrp->gcgrp_addr; 18941676Sjpk 18951676Sjpk /* 18961676Sjpk * Caller is holding a reference, and that we don't 18971676Sjpk * need to hold any lock to access the address. 18981676Sjpk */ 18991676Sjpk if (ipversion == IPV4_VERSION) { 19001676Sjpk ASSERT(ga->ga_af == AF_INET); 19011676Sjpk IN6_V4MAPPED_TO_IPADDR(&ga->ga_addr, ga_addr4); 19021676Sjpk paddr = &ga_addr4; 19031676Sjpk } else { 19041676Sjpk ASSERT(ga->ga_af == AF_INET6); 19051676Sjpk paddr = &ga->ga_addr; 19061676Sjpk } 19071676Sjpk } else if (ipversion == IPV6_VERSION && 19081676Sjpk !IN6_IS_ADDR_UNSPECIFIED(&ire->ire_gateway_addr_v6)) { 19091676Sjpk paddr = &ire->ire_gateway_addr_v6; 19101676Sjpk } else if (ipversion == IPV4_VERSION && 19111676Sjpk ire->ire_gateway_addr != INADDR_ANY) { 19121676Sjpk paddr = &ire->ire_gateway_addr; 19131676Sjpk } 19141676Sjpk 19151676Sjpk /* 19161676Sjpk * Lookup the gateway template; note that we could get an internal 19171676Sjpk * template here, which we cache anyway. During IRE matching, we'll 19181676Sjpk * try to update this gateway template cache and hopefully get a 19191676Sjpk * real one. 19201676Sjpk */ 19211676Sjpk if (paddr != NULL) { 19223292Skp158701 attrp->igsa_rhc = find_rhc(paddr, ipversion, B_FALSE); 19231676Sjpk } 19241676Sjpk 19251676Sjpk if (exists) 19261676Sjpk mutex_exit(&attrp->igsa_lock); 19271676Sjpk 19281676Sjpk return (0); 19291676Sjpk } 19301676Sjpk 19311676Sjpk /* 19321676Sjpk * This function figures the type of MLP that we'll be using based on the 19331676Sjpk * address that the user is binding and the zone. If the address is 19341676Sjpk * unspecified, then we're looking at both private and shared. If it's one 19351676Sjpk * of the zone's private addresses, then it's private only. If it's one 19361676Sjpk * of the global addresses, then it's shared only. 19371676Sjpk * 19381676Sjpk * If we can't figure out what it is, then return mlptSingle. That's actually 19391676Sjpk * an error case. 19403448Sdh155122 * 19413448Sdh155122 * The callers are assume to pass in zone->zone_id and not the zoneid that 19423448Sdh155122 * is stored in a conn_t (since the latter will be GLOBAL_ZONEID in an 19433448Sdh155122 * exclusive stack zone). 19441676Sjpk */ 19451676Sjpk mlp_type_t 19463448Sdh155122 tsol_mlp_addr_type(zoneid_t zoneid, uchar_t version, const void *addr, 19473448Sdh155122 ip_stack_t *ipst) 19481676Sjpk { 19491676Sjpk in_addr_t in4; 19501676Sjpk ire_t *ire; 19511676Sjpk ipif_t *ipif; 19521676Sjpk zoneid_t addrzone; 19533448Sdh155122 zoneid_t ip_zoneid; 19541676Sjpk 19551676Sjpk ASSERT(addr != NULL); 19561676Sjpk 19573448Sdh155122 /* 19583448Sdh155122 * For exclusive stacks we set the zoneid to zero 19593448Sdh155122 * to operate as if in the global zone for IRE and conn_t comparisons. 19603448Sdh155122 */ 19613448Sdh155122 if (ipst->ips_netstack->netstack_stackid != GLOBAL_NETSTACKID) 19623448Sdh155122 ip_zoneid = GLOBAL_ZONEID; 19633448Sdh155122 else 19643448Sdh155122 ip_zoneid = zoneid; 19653448Sdh155122 19661676Sjpk if (version == IPV6_VERSION && 19671676Sjpk IN6_IS_ADDR_V4MAPPED((const in6_addr_t *)addr)) { 19681676Sjpk IN6_V4MAPPED_TO_IPADDR((const in6_addr_t *)addr, in4); 19691676Sjpk addr = &in4; 19701676Sjpk version = IPV4_VERSION; 19711676Sjpk } 19721676Sjpk 19731676Sjpk if (version == IPV4_VERSION) { 19741676Sjpk in4 = *(const in_addr_t *)addr; 19753448Sdh155122 if (in4 == INADDR_ANY) { 19761676Sjpk return (mlptBoth); 19773448Sdh155122 } 19783448Sdh155122 ire = ire_cache_lookup(in4, ip_zoneid, NULL, ipst); 19791676Sjpk } else { 19803448Sdh155122 if (IN6_IS_ADDR_UNSPECIFIED((const in6_addr_t *)addr)) { 19811676Sjpk return (mlptBoth); 19823448Sdh155122 } 19833448Sdh155122 ire = ire_cache_lookup_v6(addr, ip_zoneid, NULL, ipst); 19841676Sjpk } 19851676Sjpk /* 19861676Sjpk * If we can't find the IRE, then we have to behave exactly like 19871676Sjpk * ip_bind_laddr{,_v6}. That means looking up the IPIF so that users 19881676Sjpk * can bind to addresses on "down" interfaces. 19891676Sjpk * 19901676Sjpk * If we can't find that either, then the bind is going to fail, so 19911676Sjpk * just give up. Note that there's a miniscule chance that the address 19921676Sjpk * is in transition, but we don't bother handling that. 19931676Sjpk */ 19941676Sjpk if (ire == NULL) { 19951676Sjpk if (version == IPV4_VERSION) 19961676Sjpk ipif = ipif_lookup_addr(*(const in_addr_t *)addr, NULL, 19973448Sdh155122 ip_zoneid, NULL, NULL, NULL, NULL, ipst); 19981676Sjpk else 19991676Sjpk ipif = ipif_lookup_addr_v6((const in6_addr_t *)addr, 20003448Sdh155122 NULL, ip_zoneid, NULL, NULL, NULL, NULL, ipst); 20013448Sdh155122 if (ipif == NULL) { 20021676Sjpk return (mlptSingle); 20033448Sdh155122 } 20041676Sjpk addrzone = ipif->ipif_zoneid; 20051676Sjpk ipif_refrele(ipif); 20061676Sjpk } else { 20071676Sjpk addrzone = ire->ire_zoneid; 20081676Sjpk ire_refrele(ire); 20091676Sjpk } 20101676Sjpk return (addrzone == ALL_ZONES ? mlptShared : mlptPrivate); 20111676Sjpk } 20121676Sjpk 20131676Sjpk /* 20141676Sjpk * Since we are configuring local interfaces, and we know trusted 20151676Sjpk * extension CDE requires local interfaces to be cipso host type in 20161676Sjpk * order to function correctly, we'll associate a cipso template 20171676Sjpk * to each local interface and let the interface come up. Configuring 20181676Sjpk * a local interface to be "unlabeled" host type is a configuration error. 20191676Sjpk * We'll override that error and make the interface host type to be cipso 20201676Sjpk * here. 20211676Sjpk * 20221676Sjpk * The code is optimized for the usual "success" case and unwinds things on 20231676Sjpk * error. We don't want to go to the trouble and expense of formatting the 20241676Sjpk * interface name for the usual case where everything is configured correctly. 20251676Sjpk */ 20261676Sjpk boolean_t 20271676Sjpk tsol_check_interface_address(const ipif_t *ipif) 20281676Sjpk { 20291676Sjpk tsol_tpc_t *tp; 20301676Sjpk char addrbuf[INET6_ADDRSTRLEN]; 20311676Sjpk int af; 20321676Sjpk const void *addr; 20331676Sjpk zone_t *zone; 20341676Sjpk ts_label_t *plabel; 20351676Sjpk const bslabel_t *label; 20361676Sjpk char ifbuf[LIFNAMSIZ + 10]; 20371676Sjpk const char *ifname; 20381676Sjpk boolean_t retval; 20391676Sjpk tsol_rhent_t rhent; 20403448Sdh155122 netstack_t *ns = ipif->ipif_ill->ill_ipst->ips_netstack; 20411676Sjpk 20421676Sjpk if (IN6_IS_ADDR_V4MAPPED(&ipif->ipif_v6lcl_addr)) { 20431676Sjpk af = AF_INET; 20441676Sjpk addr = &V4_PART_OF_V6(ipif->ipif_v6lcl_addr); 20451676Sjpk } else { 20461676Sjpk af = AF_INET6; 20471676Sjpk addr = &ipif->ipif_v6lcl_addr; 20481676Sjpk } 20491676Sjpk 20501676Sjpk tp = find_tpc(&ipif->ipif_v6lcl_addr, IPV6_VERSION, B_FALSE); 20513448Sdh155122 20523448Sdh155122 /* assumes that ALL_ZONES implies that there is no exclusive stack */ 20533448Sdh155122 if (ipif->ipif_zoneid == ALL_ZONES) { 20543448Sdh155122 zone = NULL; 20553448Sdh155122 } else if (ns->netstack_stackid == GLOBAL_NETSTACKID) { 20563448Sdh155122 /* Shared stack case */ 20573448Sdh155122 zone = zone_find_by_id(ipif->ipif_zoneid); 20583448Sdh155122 } else { 20593448Sdh155122 /* Exclusive stack case */ 20603448Sdh155122 zone = zone_find_by_id(crgetzoneid(ipif->ipif_ill->ill_credp)); 20613448Sdh155122 } 20621676Sjpk if (zone != NULL) { 20631676Sjpk plabel = zone->zone_slabel; 20641676Sjpk ASSERT(plabel != NULL); 20651676Sjpk label = label2bslabel(plabel); 20661676Sjpk } 20671676Sjpk 20681676Sjpk /* 20691676Sjpk * If it's CIPSO and an all-zones address, then we're done. 20701676Sjpk * If it's a CIPSO zone specific address, the zone's label 20711676Sjpk * must be in the range or set specified in the template. 20721676Sjpk * When the remote host entry is missing or the template 20731676Sjpk * type is incorrect for this interface, we create a 20741676Sjpk * CIPSO host entry in kernel and allow the interface to be 20751676Sjpk * brought up as CIPSO type. 20761676Sjpk */ 20771676Sjpk if (tp != NULL && ( 20781676Sjpk /* The all-zones case */ 20791676Sjpk (tp->tpc_tp.host_type == SUN_CIPSO && 20801676Sjpk tp->tpc_tp.tp_doi == default_doi && 20811676Sjpk ipif->ipif_zoneid == ALL_ZONES) || 20821676Sjpk /* The local-zone case */ 20831676Sjpk (zone != NULL && plabel->tsl_doi == tp->tpc_tp.tp_doi && 20841676Sjpk ((tp->tpc_tp.host_type == SUN_CIPSO && 20851676Sjpk (_blinrange(label, &tp->tpc_tp.tp_sl_range_cipso) || 20861676Sjpk blinlset(label, tp->tpc_tp.tp_sl_set_cipso))))))) { 20871676Sjpk if (zone != NULL) 20881676Sjpk zone_rele(zone); 20891676Sjpk TPC_RELE(tp); 20901676Sjpk return (B_TRUE); 20911676Sjpk } 20921676Sjpk 20931676Sjpk ifname = ipif->ipif_ill->ill_name; 20941676Sjpk if (ipif->ipif_id != 0) { 20951676Sjpk (void) snprintf(ifbuf, sizeof (ifbuf), "%s:%u", ifname, 20961676Sjpk ipif->ipif_id); 20971676Sjpk ifname = ifbuf; 20981676Sjpk } 20991676Sjpk (void) inet_ntop(af, addr, addrbuf, sizeof (addrbuf)); 21001676Sjpk 21011676Sjpk if (tp == NULL) { 21021676Sjpk cmn_err(CE_NOTE, "template entry for %s missing. Default to " 21031676Sjpk "CIPSO type for %s", ifname, addrbuf); 21041676Sjpk retval = B_TRUE; 21051676Sjpk } else if (tp->tpc_tp.host_type == UNLABELED) { 21061676Sjpk cmn_err(CE_NOTE, "template type for %s incorrectly configured. " 21071676Sjpk "Change to CIPSO type for %s", ifname, addrbuf); 21081676Sjpk retval = B_TRUE; 21091676Sjpk } else if (ipif->ipif_zoneid == ALL_ZONES) { 21101676Sjpk if (tp->tpc_tp.host_type != SUN_CIPSO) { 21111676Sjpk cmn_err(CE_NOTE, "%s failed: %s isn't set to CIPSO for " 21121676Sjpk "all-zones. Converted to CIPSO.", ifname, addrbuf); 21131676Sjpk retval = B_TRUE; 21141676Sjpk } else { 21151676Sjpk cmn_err(CE_NOTE, "%s failed: %s has wrong DOI %d " 21161676Sjpk "instead of %d", ifname, addrbuf, 21171676Sjpk tp->tpc_tp.tp_doi, default_doi); 21181676Sjpk retval = B_FALSE; 21191676Sjpk } 21201676Sjpk } else if (zone == NULL) { 21211676Sjpk cmn_err(CE_NOTE, "%s failed: zoneid %d unknown", 21221676Sjpk ifname, ipif->ipif_zoneid); 21231676Sjpk retval = B_FALSE; 21241676Sjpk } else if (plabel->tsl_doi != tp->tpc_tp.tp_doi) { 21251676Sjpk cmn_err(CE_NOTE, "%s failed: zone %s has DOI %d but %s has " 21261676Sjpk "DOI %d", ifname, zone->zone_name, plabel->tsl_doi, 21271676Sjpk addrbuf, tp->tpc_tp.tp_doi); 21281676Sjpk retval = B_FALSE; 21291676Sjpk } else { 21301676Sjpk cmn_err(CE_NOTE, "%s failed: zone %s label incompatible with " 21311676Sjpk "%s", ifname, zone->zone_name, addrbuf); 21321676Sjpk tsol_print_label(label, "zone label"); 21331676Sjpk retval = B_FALSE; 21341676Sjpk } 21351676Sjpk 21361676Sjpk if (zone != NULL) 21371676Sjpk zone_rele(zone); 21381676Sjpk if (tp != NULL) 21391676Sjpk TPC_RELE(tp); 21401676Sjpk if (retval) { 21411676Sjpk /* 21421676Sjpk * we've corrected a config error and let the interface 21431676Sjpk * come up as cipso. Need to insert an rhent. 21441676Sjpk */ 21451676Sjpk if ((rhent.rh_address.ta_family = af) == AF_INET) { 21461676Sjpk rhent.rh_prefix = 32; 21471676Sjpk rhent.rh_address.ta_addr_v4 = *(struct in_addr *)addr; 21481676Sjpk } else { 21491676Sjpk rhent.rh_prefix = 128; 21501676Sjpk rhent.rh_address.ta_addr_v6 = *(in6_addr_t *)addr; 21511676Sjpk } 21521676Sjpk (void) strcpy(rhent.rh_template, "cipso"); 21531676Sjpk if (tnrh_load(&rhent) != 0) { 21541676Sjpk cmn_err(CE_NOTE, "%s failed: Cannot insert CIPSO " 21551676Sjpk "template for local addr %s", ifname, addrbuf); 21561676Sjpk retval = B_FALSE; 21571676Sjpk } 21581676Sjpk } 21591676Sjpk return (retval); 21601676Sjpk } 2161