1 /* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License (the "License"). 6 * You may not use this file except in compliance with the License. 7 * 8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 9 * or http://www.opensolaris.org/os/licensing. 10 * See the License for the specific language governing permissions 11 * and limitations under the License. 12 * 13 * When distributing Covered Code, include this CDDL HEADER in each 14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 15 * If applicable, add the following below this CDDL HEADER, with the 16 * fields enclosed by brackets "[]" replaced with your own identifying 17 * information: Portions Copyright [yyyy] [name of copyright owner] 18 * 19 * CDDL HEADER END 20 */ 21 /* 22 * Copyright 2009 Sun Microsystems, Inc. All rights reserved. 23 * Use is subject to license terms. 24 * Copyright 2012, Nexenta Systems, Inc. All rights reserved. 25 */ 26 27 /* 28 * Copyright 2019 Joyent, Inc. 29 */ 30 31 /* 32 * Data-Link Services Module 33 */ 34 35 #include <sys/strsun.h> 36 #include <sys/vlan.h> 37 #include <sys/dld_impl.h> 38 #include <sys/mac_client_priv.h> 39 40 int 41 dls_open(dls_link_t *dlp, dls_dl_handle_t ddh, dld_str_t *dsp) 42 { 43 zoneid_t zid = getzoneid(); 44 boolean_t local; 45 int err; 46 47 /* 48 * Check whether this client belongs to the zone of this dlp. Note that 49 * a global zone client is allowed to open a local zone dlp. 50 */ 51 if (zid != GLOBAL_ZONEID && dlp->dl_zid != zid) 52 return (ENOENT); 53 54 /* 55 * mac_start() is required for non-legacy MACs to show accurate 56 * kstats even before the interface is brought up. For legacy 57 * drivers, this is not needed. Further, calling mac_start() for 58 * legacy drivers would make the shared-lower-stream to stay in 59 * the DL_IDLE state, which in turn causes performance regression. 60 */ 61 if (!mac_capab_get(dlp->dl_mh, MAC_CAPAB_LEGACY, NULL) && 62 ((err = mac_start(dlp->dl_mh)) != 0)) { 63 return (err); 64 } 65 66 local = (zid == dlp->dl_zid); 67 dlp->dl_zone_ref += (local ? 1 : 0); 68 69 /* 70 * Cache a copy of the MAC interface handle, a pointer to the 71 * immutable MAC info. 72 */ 73 dsp->ds_dlp = dlp; 74 dsp->ds_mh = dlp->dl_mh; 75 dsp->ds_mch = dlp->dl_mch; 76 dsp->ds_mip = dlp->dl_mip; 77 dsp->ds_ddh = ddh; 78 dsp->ds_local = local; 79 80 ASSERT(MAC_PERIM_HELD(dsp->ds_mh)); 81 return (0); 82 } 83 84 void 85 dls_close(dld_str_t *dsp) 86 { 87 dls_link_t *dlp = dsp->ds_dlp; 88 dls_multicst_addr_t *p; 89 dls_multicst_addr_t *nextp; 90 91 ASSERT(dsp->ds_datathr_cnt == 0); 92 ASSERT(MAC_PERIM_HELD(dsp->ds_mh)); 93 94 if (dsp->ds_local) 95 dlp->dl_zone_ref--; 96 dsp->ds_local = B_FALSE; 97 98 /* 99 * Walk the list of multicast addresses, disabling each at the MAC. 100 * Note that we must remove multicast address before 101 * mac_unicast_remove() (called by dls_active_clear()) because 102 * mac_multicast_remove() relies on the unicast flows on the mac 103 * client. 104 */ 105 for (p = dsp->ds_dmap; p != NULL; p = nextp) { 106 (void) mac_multicast_remove(dsp->ds_mch, p->dma_addr); 107 nextp = p->dma_nextp; 108 kmem_free(p, sizeof (dls_multicst_addr_t)); 109 } 110 dsp->ds_dmap = NULL; 111 112 dls_active_clear(dsp, B_TRUE); 113 114 /* 115 * If the dld_str_t is bound then unbind it. 116 */ 117 if (dsp->ds_dlstate == DL_IDLE) { 118 dls_unbind(dsp); 119 dsp->ds_dlstate = DL_UNBOUND; 120 } 121 122 /* 123 * If the MAC has been set in promiscuous mode then disable it. 124 * This needs to be done before resetting ds_rx. 125 */ 126 (void) dls_promisc(dsp, 0); 127 128 /* 129 * At this point we have cutoff inbound packet flow from the mac 130 * for this 'dsp'. The dls_link_remove above cut off packets meant 131 * for us and waited for upcalls to finish. Similarly the dls_promisc 132 * reset above waited for promisc callbacks to finish. Now we can 133 * safely reset ds_rx to NULL 134 */ 135 dsp->ds_rx = NULL; 136 dsp->ds_rx_arg = NULL; 137 138 dsp->ds_dlp = NULL; 139 140 if (!mac_capab_get(dsp->ds_mh, MAC_CAPAB_LEGACY, NULL)) 141 mac_stop(dsp->ds_mh); 142 143 /* 144 * Release our reference to the dls_link_t allowing that to be 145 * destroyed if there are no more dls_impl_t. 146 */ 147 dls_link_rele(dlp); 148 } 149 150 int 151 dls_bind(dld_str_t *dsp, uint32_t sap) 152 { 153 uint32_t dls_sap; 154 155 ASSERT(MAC_PERIM_HELD(dsp->ds_mh)); 156 157 /* 158 * Check to see the value is legal for the media type. 159 */ 160 if (!mac_sap_verify(dsp->ds_mh, sap, &dls_sap)) 161 return (EINVAL); 162 163 if (dsp->ds_promisc & DLS_PROMISC_SAP) 164 dls_sap = DLS_SAP_PROMISC; 165 166 /* 167 * Set up the dld_str_t to mark it as able to receive packets. 168 */ 169 dsp->ds_sap = sap; 170 171 /* 172 * The MAC layer does the VLAN demultiplexing and will only pass up 173 * untagged packets to non-promiscuous primary MAC clients. In order to 174 * support the binding to the VLAN SAP which is required by DLPI, dls 175 * needs to get a copy of all tagged packets when the client binds to 176 * the VLAN SAP. We do this by registering a separate promiscuous 177 * callback for each dls client binding to that SAP. 178 * 179 * Note: even though there are two promiscuous handles in dld_str_t, 180 * ds_mph is for the regular promiscuous mode, ds_vlan_mph is the handle 181 * to receive VLAN pkt when promiscuous mode is not on. Only one of 182 * them can be non-NULL at the same time, to avoid receiving dup copies 183 * of pkts. 184 */ 185 if (sap == ETHERTYPE_VLAN && dsp->ds_promisc == 0) { 186 int err; 187 188 if (dsp->ds_vlan_mph != NULL) 189 return (EINVAL); 190 err = mac_promisc_add(dsp->ds_mch, 191 MAC_CLIENT_PROMISC_ALL, dls_rx_vlan_promisc, dsp, 192 &dsp->ds_vlan_mph, MAC_PROMISC_FLAGS_NO_PHYS); 193 194 if (err == 0 && dsp->ds_nonip && 195 dsp->ds_dlp->dl_nonip_cnt++ == 0) 196 mac_rx_bypass_disable(dsp->ds_mch); 197 198 return (err); 199 } 200 201 /* 202 * Now bind the dld_str_t by adding it into the hash table in the 203 * dls_link_t. 204 */ 205 dls_link_add(dsp->ds_dlp, dls_sap, dsp); 206 if (dsp->ds_nonip && dsp->ds_dlp->dl_nonip_cnt++ == 0) 207 mac_rx_bypass_disable(dsp->ds_mch); 208 209 return (0); 210 } 211 212 void 213 dls_unbind(dld_str_t *dsp) 214 { 215 ASSERT(MAC_PERIM_HELD(dsp->ds_mh)); 216 217 if (dsp->ds_nonip && --dsp->ds_dlp->dl_nonip_cnt == 0) 218 mac_rx_bypass_enable(dsp->ds_mch); 219 220 /* 221 * A VLAN SAP does not actually add itself to the STREAM head today. 222 * While we initially set up a VLAN handle below, it's possible that 223 * something else will have come in and clobbered it. 224 */ 225 if (dsp->ds_sap == ETHERTYPE_VLAN) { 226 if (dsp->ds_vlan_mph != NULL) { 227 mac_promisc_remove(dsp->ds_vlan_mph); 228 dsp->ds_vlan_mph = NULL; 229 } 230 return; 231 } 232 233 /* 234 * Unbind the dld_str_t by removing it from the hash table in the 235 * dls_link_t. 236 */ 237 dls_link_remove(dsp->ds_dlp, dsp); 238 dsp->ds_sap = 0; 239 } 240 241 /* 242 * In order to prevent promiscuous-mode processing with dsp->ds_promisc 243 * set to inaccurate values, this function sets dsp->ds_promisc with new 244 * flags. For enabling (mac_promisc_add), the flags are set prior to the 245 * actual enabling. For disabling (mac_promisc_remove), the flags are set 246 * after the actual disabling. 247 */ 248 int 249 dls_promisc(dld_str_t *dsp, uint32_t new_flags) 250 { 251 int err = 0; 252 uint32_t old_flags = dsp->ds_promisc; 253 mac_client_promisc_type_t mptype = MAC_CLIENT_PROMISC_ALL; 254 255 ASSERT(MAC_PERIM_HELD(dsp->ds_mh)); 256 ASSERT(!(new_flags & ~(DLS_PROMISC_SAP | DLS_PROMISC_MULTI | 257 DLS_PROMISC_PHYS))); 258 259 /* 260 * If the user has only requested DLS_PROMISC_MULTI then we need to make 261 * sure that they don't see all packets. 262 */ 263 if (new_flags == DLS_PROMISC_MULTI) 264 mptype = MAC_CLIENT_PROMISC_MULTI; 265 266 if (dsp->ds_promisc == 0 && new_flags != 0) { 267 /* 268 * If only DLS_PROMISC_SAP, we don't turn on the 269 * physical promisc mode 270 */ 271 dsp->ds_promisc = new_flags; 272 err = mac_promisc_add(dsp->ds_mch, mptype, 273 dls_rx_promisc, dsp, &dsp->ds_mph, 274 (new_flags != DLS_PROMISC_SAP) ? 0 : 275 MAC_PROMISC_FLAGS_NO_PHYS); 276 if (err != 0) { 277 dsp->ds_promisc = old_flags; 278 return (err); 279 } 280 281 /* Remove vlan promisc handle to avoid sending dup copy up */ 282 if (dsp->ds_vlan_mph != NULL) { 283 mac_promisc_remove(dsp->ds_vlan_mph); 284 dsp->ds_vlan_mph = NULL; 285 } 286 } else if (dsp->ds_promisc != 0 && new_flags == 0) { 287 ASSERT(dsp->ds_mph != NULL); 288 289 mac_promisc_remove(dsp->ds_mph); 290 dsp->ds_promisc = new_flags; 291 dsp->ds_mph = NULL; 292 293 if (dsp->ds_sap == ETHERTYPE_VLAN && 294 dsp->ds_dlstate != DL_UNBOUND) { 295 if (dsp->ds_vlan_mph != NULL) 296 return (EINVAL); 297 err = mac_promisc_add(dsp->ds_mch, 298 MAC_CLIENT_PROMISC_ALL, dls_rx_vlan_promisc, dsp, 299 &dsp->ds_vlan_mph, MAC_PROMISC_FLAGS_NO_PHYS); 300 } 301 } else if (dsp->ds_promisc == DLS_PROMISC_SAP && new_flags != 0 && 302 new_flags != dsp->ds_promisc) { 303 /* 304 * If the old flag is PROMISC_SAP, but the current flag has 305 * changed to some new non-zero value, we need to turn the 306 * physical promiscuous mode. 307 */ 308 ASSERT(dsp->ds_mph != NULL); 309 mac_promisc_remove(dsp->ds_mph); 310 /* Honors both after-remove and before-add semantics! */ 311 dsp->ds_promisc = new_flags; 312 err = mac_promisc_add(dsp->ds_mch, mptype, 313 dls_rx_promisc, dsp, &dsp->ds_mph, 0); 314 if (err != 0) 315 dsp->ds_promisc = old_flags; 316 } else { 317 /* No adding or removing, but record the new flags anyway. */ 318 dsp->ds_promisc = new_flags; 319 } 320 321 return (err); 322 } 323 324 int 325 dls_multicst_add(dld_str_t *dsp, const uint8_t *addr) 326 { 327 int err; 328 dls_multicst_addr_t **pp; 329 dls_multicst_addr_t *p; 330 uint_t addr_length; 331 332 ASSERT(MAC_PERIM_HELD(dsp->ds_mh)); 333 334 /* 335 * Check whether the address is in the list of enabled addresses for 336 * this dld_str_t. 337 */ 338 addr_length = dsp->ds_mip->mi_addr_length; 339 340 /* 341 * Protect against concurrent access of ds_dmap by data threads using 342 * ds_rw_lock. The mac perimeter serializes the dls_multicst_add and 343 * remove operations. Dropping the ds_rw_lock across mac calls is thus 344 * ok and is also required by the locking protocol. 345 */ 346 rw_enter(&dsp->ds_rw_lock, RW_WRITER); 347 for (pp = &(dsp->ds_dmap); (p = *pp) != NULL; pp = &(p->dma_nextp)) { 348 if (bcmp(addr, p->dma_addr, addr_length) == 0) { 349 /* 350 * It is there so there's nothing to do. 351 */ 352 err = 0; 353 goto done; 354 } 355 } 356 357 /* 358 * Allocate a new list item and add it to the list. 359 */ 360 p = kmem_zalloc(sizeof (dls_multicst_addr_t), KM_SLEEP); 361 bcopy(addr, p->dma_addr, addr_length); 362 *pp = p; 363 rw_exit(&dsp->ds_rw_lock); 364 365 /* 366 * Enable the address at the MAC. 367 */ 368 err = mac_multicast_add(dsp->ds_mch, addr); 369 if (err == 0) 370 return (0); 371 372 /* Undo the operation as it has failed */ 373 rw_enter(&dsp->ds_rw_lock, RW_WRITER); 374 ASSERT(*pp == p && p->dma_nextp == NULL); 375 *pp = NULL; 376 kmem_free(p, sizeof (dls_multicst_addr_t)); 377 done: 378 rw_exit(&dsp->ds_rw_lock); 379 return (err); 380 } 381 382 int 383 dls_multicst_remove(dld_str_t *dsp, const uint8_t *addr) 384 { 385 dls_multicst_addr_t **pp; 386 dls_multicst_addr_t *p; 387 uint_t addr_length; 388 389 ASSERT(MAC_PERIM_HELD(dsp->ds_mh)); 390 391 /* 392 * Find the address in the list of enabled addresses for this 393 * dld_str_t. 394 */ 395 addr_length = dsp->ds_mip->mi_addr_length; 396 397 /* 398 * Protect against concurrent access to ds_dmap by data threads using 399 * ds_rw_lock. The mac perimeter serializes the dls_multicst_add and 400 * remove operations. Dropping the ds_rw_lock across mac calls is thus 401 * ok and is also required by the locking protocol. 402 */ 403 rw_enter(&dsp->ds_rw_lock, RW_WRITER); 404 for (pp = &(dsp->ds_dmap); (p = *pp) != NULL; pp = &(p->dma_nextp)) { 405 if (bcmp(addr, p->dma_addr, addr_length) == 0) 406 break; 407 } 408 409 /* 410 * If we walked to the end of the list then the given address is 411 * not currently enabled for this dld_str_t. 412 */ 413 if (p == NULL) { 414 rw_exit(&dsp->ds_rw_lock); 415 return (ENOENT); 416 } 417 418 /* 419 * Remove the address from the list. 420 */ 421 *pp = p->dma_nextp; 422 rw_exit(&dsp->ds_rw_lock); 423 424 /* 425 * Disable the address at the MAC. 426 */ 427 mac_multicast_remove(dsp->ds_mch, addr); 428 kmem_free(p, sizeof (dls_multicst_addr_t)); 429 return (0); 430 } 431 432 mblk_t * 433 dls_header(dld_str_t *dsp, const uint8_t *addr, uint16_t sap, uint_t pri, 434 mblk_t **payloadp) 435 { 436 uint16_t vid; 437 size_t extra_len; 438 uint16_t mac_sap; 439 mblk_t *mp, *payload; 440 boolean_t is_ethernet = (dsp->ds_mip->mi_media == DL_ETHER); 441 struct ether_vlan_header *evhp; 442 443 vid = mac_client_vid(dsp->ds_mch); 444 payload = (payloadp == NULL) ? NULL : (*payloadp); 445 446 /* 447 * In the case of Ethernet, we need to tell mac_header() if we need 448 * extra room beyond the Ethernet header for a VLAN header. We'll 449 * need to add a VLAN header if this isn't an ETHERTYPE_VLAN listener 450 * (because such streams will be handling VLAN headers on their own) 451 * and one of the following conditions is satisfied: 452 * 453 * - This is a VLAN stream 454 * - This is a physical stream, the priority is not 0, and user 455 * priority tagging is allowed. 456 */ 457 if (is_ethernet && sap != ETHERTYPE_VLAN && 458 (vid != VLAN_ID_NONE || 459 (pri != 0 && dsp->ds_dlp->dl_tagmode != LINK_TAGMODE_VLANONLY))) { 460 extra_len = sizeof (struct ether_vlan_header) - 461 sizeof (struct ether_header); 462 mac_sap = ETHERTYPE_VLAN; 463 } else { 464 extra_len = 0; 465 mac_sap = sap; 466 } 467 468 mp = mac_header(dsp->ds_mh, addr, mac_sap, payload, extra_len); 469 if (mp == NULL) 470 return (NULL); 471 472 if ((vid == VLAN_ID_NONE && (pri == 0 || 473 dsp->ds_dlp->dl_tagmode == LINK_TAGMODE_VLANONLY)) || !is_ethernet) 474 return (mp); 475 476 /* 477 * Fill in the tag information. 478 */ 479 ASSERT(MBLKL(mp) == sizeof (struct ether_header)); 480 if (extra_len != 0) { 481 mp->b_wptr += extra_len; 482 evhp = (struct ether_vlan_header *)mp->b_rptr; 483 evhp->ether_tci = htons(VLAN_TCI(pri, ETHER_CFI, vid)); 484 evhp->ether_type = htons(sap); 485 } else { 486 /* 487 * The stream is ETHERTYPE_VLAN listener, so its VLAN tag is 488 * in the payload. Update the priority. 489 */ 490 struct ether_vlan_extinfo *extinfo; 491 size_t len = sizeof (struct ether_vlan_extinfo); 492 493 ASSERT(sap == ETHERTYPE_VLAN); 494 ASSERT(payload != NULL); 495 496 if ((DB_REF(payload) > 1) || (MBLKL(payload) < len)) { 497 mblk_t *newmp; 498 499 /* 500 * Because some DLS consumers only check the db_ref 501 * count of the first mblk, we pullup 'payload' into 502 * a single mblk. 503 */ 504 newmp = msgpullup(payload, -1); 505 if ((newmp == NULL) || (MBLKL(newmp) < len)) { 506 freemsg(newmp); 507 freemsg(mp); 508 return (NULL); 509 } else { 510 freemsg(payload); 511 *payloadp = payload = newmp; 512 } 513 } 514 515 extinfo = (struct ether_vlan_extinfo *)payload->b_rptr; 516 extinfo->ether_tci = htons(VLAN_TCI(pri, ETHER_CFI, 517 VLAN_ID(ntohs(extinfo->ether_tci)))); 518 } 519 return (mp); 520 } 521 522 void 523 dls_rx_set(dld_str_t *dsp, dls_rx_t rx, void *arg) 524 { 525 mutex_enter(&dsp->ds_lock); 526 dsp->ds_rx = rx; 527 dsp->ds_rx_arg = arg; 528 mutex_exit(&dsp->ds_lock); 529 } 530 531 static boolean_t 532 dls_accept_common(dld_str_t *dsp, mac_header_info_t *mhip, dls_rx_t *ds_rx, 533 void **ds_rx_arg, boolean_t promisc, boolean_t promisc_loopback) 534 { 535 dls_multicst_addr_t *dmap; 536 size_t addr_length = dsp->ds_mip->mi_addr_length; 537 538 /* 539 * We must not accept packets if the dld_str_t is not marked as bound 540 * or is being removed. 541 */ 542 if (dsp->ds_dlstate != DL_IDLE) 543 goto refuse; 544 545 if (dsp->ds_promisc != 0) { 546 /* 547 * Filter out packets that arrived from the data path 548 * (i_dls_link_rx) when promisc mode is on. We need to correlate 549 * the ds_promisc flags with the mac header destination type. If 550 * only DLS_PROMISC_MULTI is enabled, we need to only reject 551 * multicast packets as those are the only ones which filter up 552 * the promiscuous path. If we have DLS_PROMISC_PHYS or 553 * DLS_PROMISC_SAP set, then we know that we'll be seeing 554 * everything, so we should drop it now. 555 */ 556 if (!promisc && !(dsp->ds_promisc == DLS_PROMISC_MULTI && 557 mhip->mhi_dsttype != MAC_ADDRTYPE_MULTICAST)) 558 goto refuse; 559 /* 560 * If the dls_impl_t is in 'all physical' mode then 561 * always accept. 562 */ 563 if (dsp->ds_promisc & DLS_PROMISC_PHYS) 564 goto accept; 565 566 /* 567 * Loopback packets i.e. packets sent out by DLS on a given 568 * mac end point, will be accepted back by DLS on loopback 569 * from the mac, only in the 'all physical' mode which has been 570 * covered by the previous check above 571 */ 572 if (promisc_loopback) 573 goto refuse; 574 } 575 576 switch (mhip->mhi_dsttype) { 577 case MAC_ADDRTYPE_UNICAST: 578 case MAC_ADDRTYPE_BROADCAST: 579 /* 580 * We can accept unicast and broadcast packets because 581 * filtering is already done by the mac layer. 582 */ 583 goto accept; 584 case MAC_ADDRTYPE_MULTICAST: 585 /* 586 * Additional filtering is needed for multicast addresses 587 * because different streams may be interested in different 588 * addresses. 589 */ 590 if (dsp->ds_promisc & DLS_PROMISC_MULTI) 591 goto accept; 592 593 rw_enter(&dsp->ds_rw_lock, RW_READER); 594 for (dmap = dsp->ds_dmap; dmap != NULL; 595 dmap = dmap->dma_nextp) { 596 if (memcmp(mhip->mhi_daddr, dmap->dma_addr, 597 addr_length) == 0) { 598 rw_exit(&dsp->ds_rw_lock); 599 goto accept; 600 } 601 } 602 rw_exit(&dsp->ds_rw_lock); 603 break; 604 } 605 606 refuse: 607 return (B_FALSE); 608 609 accept: 610 /* 611 * the returned ds_rx and ds_rx_arg will always be in sync. 612 */ 613 mutex_enter(&dsp->ds_lock); 614 *ds_rx = dsp->ds_rx; 615 *ds_rx_arg = dsp->ds_rx_arg; 616 mutex_exit(&dsp->ds_lock); 617 618 return (B_TRUE); 619 } 620 621 /* ARGSUSED */ 622 boolean_t 623 dls_accept(dld_str_t *dsp, mac_header_info_t *mhip, dls_rx_t *ds_rx, 624 void **ds_rx_arg) 625 { 626 return (dls_accept_common(dsp, mhip, ds_rx, ds_rx_arg, B_FALSE, 627 B_FALSE)); 628 } 629 630 boolean_t 631 dls_accept_promisc(dld_str_t *dsp, mac_header_info_t *mhip, dls_rx_t *ds_rx, 632 void **ds_rx_arg, boolean_t loopback) 633 { 634 return (dls_accept_common(dsp, mhip, ds_rx, ds_rx_arg, B_TRUE, 635 loopback)); 636 } 637 638 int 639 dls_mac_active_set(dls_link_t *dlp) 640 { 641 int err = 0; 642 643 /* 644 * First client; add the primary unicast address. 645 */ 646 if (dlp->dl_nactive == 0) { 647 /* 648 * First client; add the primary unicast address. 649 */ 650 mac_diag_t diag; 651 652 /* request the primary MAC address */ 653 if ((err = mac_unicast_add(dlp->dl_mch, NULL, 654 MAC_UNICAST_PRIMARY | MAC_UNICAST_TAG_DISABLE | 655 MAC_UNICAST_DISABLE_TX_VID_CHECK, &dlp->dl_mah, 0, 656 &diag)) != 0) { 657 return (err); 658 } 659 660 /* 661 * Set the function to start receiving packets. 662 */ 663 mac_rx_set(dlp->dl_mch, i_dls_link_rx, dlp); 664 } 665 dlp->dl_nactive++; 666 return (0); 667 } 668 669 void 670 dls_mac_active_clear(dls_link_t *dlp) 671 { 672 if (--dlp->dl_nactive == 0) { 673 ASSERT(dlp->dl_mah != NULL); 674 (void) mac_unicast_remove(dlp->dl_mch, dlp->dl_mah); 675 dlp->dl_mah = NULL; 676 mac_rx_clear(dlp->dl_mch); 677 } 678 } 679 680 int 681 dls_active_set(dld_str_t *dsp) 682 { 683 int err = 0; 684 685 ASSERT(MAC_PERIM_HELD(dsp->ds_mh)); 686 687 if (dsp->ds_passivestate == DLD_PASSIVE) 688 return (0); 689 690 /* If we're already active, then there's nothing more to do. */ 691 if ((dsp->ds_nactive == 0) && 692 ((err = dls_mac_active_set(dsp->ds_dlp)) != 0)) { 693 /* except for ENXIO all other errors are mapped to EBUSY */ 694 if (err != ENXIO) 695 return (EBUSY); 696 return (err); 697 } 698 699 dsp->ds_passivestate = DLD_ACTIVE; 700 dsp->ds_nactive++; 701 return (0); 702 } 703 704 /* 705 * Note that dls_active_set() is called whenever an active operation 706 * (DL_BIND_REQ, DL_ENABMULTI_REQ ...) is processed and 707 * dls_active_clear(dsp, B_FALSE) is called whenever the active operation 708 * is being undone (DL_UNBIND_REQ, DL_DISABMULTI_REQ ...). In some cases, 709 * a stream is closed without every active operation being undone and we 710 * need to clear all the "active" states by calling 711 * dls_active_clear(dsp, B_TRUE). 712 */ 713 void 714 dls_active_clear(dld_str_t *dsp, boolean_t all) 715 { 716 ASSERT(MAC_PERIM_HELD(dsp->ds_mh)); 717 718 if (dsp->ds_passivestate == DLD_PASSIVE) 719 return; 720 721 if (all && dsp->ds_nactive == 0) 722 return; 723 724 ASSERT(dsp->ds_nactive > 0); 725 726 dsp->ds_nactive -= (all ? dsp->ds_nactive : 1); 727 if (dsp->ds_nactive != 0) 728 return; 729 730 ASSERT(dsp->ds_passivestate == DLD_ACTIVE); 731 dls_mac_active_clear(dsp->ds_dlp); 732 dsp->ds_passivestate = DLD_UNINITIALIZED; 733 } 734