1faa1795aSjb150015 /* 2faa1795aSjb150015 * CDDL HEADER START 3faa1795aSjb150015 * 4faa1795aSjb150015 * The contents of this file are subject to the terms of the 5faa1795aSjb150015 * Common Development and Distribution License (the "License"). 6faa1795aSjb150015 * You may not use this file except in compliance with the License. 7faa1795aSjb150015 * 8faa1795aSjb150015 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 9faa1795aSjb150015 * or http://www.opensolaris.org/os/licensing. 10faa1795aSjb150015 * See the License for the specific language governing permissions 11faa1795aSjb150015 * and limitations under the License. 12faa1795aSjb150015 * 13faa1795aSjb150015 * When distributing Covered Code, include this CDDL HEADER in each 14faa1795aSjb150015 * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 15faa1795aSjb150015 * If applicable, add the following below this CDDL HEADER, with the 16faa1795aSjb150015 * fields enclosed by brackets "[]" replaced with your own identifying 17faa1795aSjb150015 * information: Portions Copyright [yyyy] [name of copyright owner] 18faa1795aSjb150015 * 19faa1795aSjb150015 * CDDL HEADER END 20faa1795aSjb150015 */ 21faa1795aSjb150015 /* 22c5866007SKeyur Desai * Copyright (c) 2008, 2010, Oracle and/or its affiliates. All rights reserved. 23faa1795aSjb150015 */ 24faa1795aSjb150015 25faa1795aSjb150015 /* 26faa1795aSjb150015 * General Structures Layout 27faa1795aSjb150015 * ------------------------- 28faa1795aSjb150015 * 29faa1795aSjb150015 * This is a simplified diagram showing the relationship between most of the 30faa1795aSjb150015 * main structures. 31faa1795aSjb150015 * 32faa1795aSjb150015 * +-------------------+ 33faa1795aSjb150015 * | SMB_SERVER | 34faa1795aSjb150015 * +-------------------+ 35faa1795aSjb150015 * | 36faa1795aSjb150015 * | 37faa1795aSjb150015 * v 38faa1795aSjb150015 * +-------------------+ +-------------------+ +-------------------+ 39faa1795aSjb150015 * | SESSION |<----->| SESSION |......| SESSION | 40faa1795aSjb150015 * +-------------------+ +-------------------+ +-------------------+ 41faa1795aSjb150015 * | 42faa1795aSjb150015 * | 43faa1795aSjb150015 * v 44faa1795aSjb150015 * +-------------------+ +-------------------+ +-------------------+ 45faa1795aSjb150015 * | USER |<----->| USER |......| USER | 46faa1795aSjb150015 * +-------------------+ +-------------------+ +-------------------+ 47faa1795aSjb150015 * | 48faa1795aSjb150015 * | 49faa1795aSjb150015 * v 50faa1795aSjb150015 * +-------------------+ +-------------------+ +-------------------+ 51faa1795aSjb150015 * | TREE |<----->| TREE |......| TREE | 52faa1795aSjb150015 * +-------------------+ +-------------------+ +-------------------+ 53faa1795aSjb150015 * | | 54faa1795aSjb150015 * | | 55faa1795aSjb150015 * | v 56faa1795aSjb150015 * | +-------+ +-------+ +-------+ 57faa1795aSjb150015 * | | OFILE |<----->| OFILE |......| OFILE | 58faa1795aSjb150015 * | +-------+ +-------+ +-------+ 59faa1795aSjb150015 * | 60faa1795aSjb150015 * | 61faa1795aSjb150015 * v 62faa1795aSjb150015 * +-------+ +------+ +------+ 63faa1795aSjb150015 * | ODIR |<----->| ODIR |......| ODIR | 64faa1795aSjb150015 * +-------+ +------+ +------+ 65faa1795aSjb150015 * 66faa1795aSjb150015 * 67faa1795aSjb150015 * Module Interface Overview 68faa1795aSjb150015 * ------------------------- 69faa1795aSjb150015 * 70faa1795aSjb150015 * 71faa1795aSjb150015 * +===================================+ 72faa1795aSjb150015 * | smbd daemon | 73faa1795aSjb150015 * +===================================+ 74faa1795aSjb150015 * | | ^ 75faa1795aSjb150015 * | | | 76faa1795aSjb150015 * User | | | 77faa1795aSjb150015 * -----------|--------------|----------------|-------------------------------- 78faa1795aSjb150015 * Kernel | | | 79faa1795aSjb150015 * | | | 80faa1795aSjb150015 * | | | 81faa1795aSjb150015 * +=========|==============|================|=================+ 82faa1795aSjb150015 * | v v | | 83faa1795aSjb150015 * | +-----------+ +--------------------+ +------------------+ | 84faa1795aSjb150015 * | | IO | | Kernel Door Server | | User Door Servers| | 85faa1795aSjb150015 * | | Interface | | Interface | | Interface | | 86faa1795aSjb150015 * | +-----------+ +--------------------+ +------------------+ | 87faa1795aSjb150015 * | | | ^ ^ | 88faa1795aSjb150015 * | v v | | | +=========+ 89faa1795aSjb150015 * | +-----------------------------------+ | | | | 90faa1795aSjb150015 * | + SMB Server Management (this file) |<------------------| ZFS | 91faa1795aSjb150015 * | +-----------------------------------+ | | | | 92faa1795aSjb150015 * | | | | Module | 93faa1795aSjb150015 * | +-----------------------------------+ | | | | 94faa1795aSjb150015 * | + SMB Server Internal Layers |------+ | +=========+ 95faa1795aSjb150015 * | +-----------------------------------+ | 96faa1795aSjb150015 * | | 97faa1795aSjb150015 * | | 98faa1795aSjb150015 * +===========================================================+ 99faa1795aSjb150015 * 100faa1795aSjb150015 * 101faa1795aSjb150015 * Server State Machine 102faa1795aSjb150015 * -------------------- 103faa1795aSjb150015 * | 104faa1795aSjb150015 * | T0 105faa1795aSjb150015 * | 106faa1795aSjb150015 * v 107faa1795aSjb150015 * +-----------------------------+ 108faa1795aSjb150015 * | SMB_SERVER_STATE_CREATED | 109faa1795aSjb150015 * +-----------------------------+ 110faa1795aSjb150015 * | 111faa1795aSjb150015 * | T1 112faa1795aSjb150015 * | 113faa1795aSjb150015 * v 114faa1795aSjb150015 * +-----------------------------+ 115faa1795aSjb150015 * | SMB_SERVER_STATE_CONFIGURED | 116faa1795aSjb150015 * +-----------------------------+ 117faa1795aSjb150015 * | 118faa1795aSjb150015 * | T2 119faa1795aSjb150015 * | 120faa1795aSjb150015 * v 121faa1795aSjb150015 * +-----------------------------+ 1229fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * | SMB_SERVER_STATE_RUNNING / | 1239fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * | SMB_SERVER_STATE_STOPPING | 124faa1795aSjb150015 * +-----------------------------+ 125faa1795aSjb150015 * | 126faa1795aSjb150015 * | T3 127faa1795aSjb150015 * | 128faa1795aSjb150015 * v 129faa1795aSjb150015 * +-----------------------------+ 130faa1795aSjb150015 * | SMB_SERVER_STATE_DELETING | 131faa1795aSjb150015 * +-----------------------------+ 132faa1795aSjb150015 * | 133faa1795aSjb150015 * | 134faa1795aSjb150015 * | 135faa1795aSjb150015 * v 136faa1795aSjb150015 * 137faa1795aSjb150015 * States 138faa1795aSjb150015 * ------ 139faa1795aSjb150015 * 140faa1795aSjb150015 * SMB_SERVER_STATE_CREATED 141faa1795aSjb150015 * 142faa1795aSjb150015 * This is the state of the server just after creation. 143faa1795aSjb150015 * 144faa1795aSjb150015 * SMB_SERVER_STATE_CONFIGURED 145faa1795aSjb150015 * 146faa1795aSjb150015 * The server has been configured. 147faa1795aSjb150015 * 148faa1795aSjb150015 * SMB_SERVER_STATE_RUNNING 149faa1795aSjb150015 * 150faa1795aSjb150015 * The server has been started. While in this state the threads listening on 151faa1795aSjb150015 * the sockets car be started. The smbd daemon does so through an Ioctl: 152faa1795aSjb150015 * 153faa1795aSjb150015 * smb_drv_ioctl(SMB_IOC_NBT_LISTEN) --> smb_server_nbt_listen() 154faa1795aSjb150015 * smb_drv_ioctl(SMB_IOC_TCP_LISTEN) --> smb_server_nbt_listen() 155faa1795aSjb150015 * 156faa1795aSjb150015 * When a client establishes a connection the thread listening leaves 157faa1795aSjb150015 * temporarily the kernel. While in user space it creates a thread for the 158faa1795aSjb150015 * new session. It then returns to kernel with the result of the thread 159faa1795aSjb150015 * creation. If the creation failed the new session context is destroyed 160faa1795aSjb150015 * before returning listening. 161faa1795aSjb150015 * 162faa1795aSjb150015 * The new created thread enters the kernel though an Ioctl: 163faa1795aSjb150015 * 164faa1795aSjb150015 * smb_drv_ioctl(SMB_IOC_NBT_RECEIVE) --> smb_server_nbt_receive() 165faa1795aSjb150015 * smb_drv_ioctl(SMB_IOC_TCP_RECEIVE) --> smb_server_tcp_receive() 166faa1795aSjb150015 * 167faa1795aSjb150015 * SMB_SERVER_STATE_STOPPING 168faa1795aSjb150015 * 169faa1795aSjb150015 * The threads listening on the NBT and TCP sockets are being terminated. 170faa1795aSjb150015 * 171faa1795aSjb150015 * 172faa1795aSjb150015 * Transitions 173faa1795aSjb150015 * ----------- 174faa1795aSjb150015 * 175faa1795aSjb150015 * Transition T0 176faa1795aSjb150015 * 177faa1795aSjb150015 * The daemon smbd triggers its creation by opening the smbsrv device. If 178faa1795aSjb150015 * the zone where the daemon lives doesn't have an smb server yet it is 179faa1795aSjb150015 * created. 180faa1795aSjb150015 * 181faa1795aSjb150015 * smb_drv_open() --> smb_server_create() 182faa1795aSjb150015 * 183faa1795aSjb150015 * Transition T1 184faa1795aSjb150015 * 185faa1795aSjb150015 * This transition occurs in smb_server_configure(). It is triggered by the 186faa1795aSjb150015 * daemon through an Ioctl. 187faa1795aSjb150015 * 188faa1795aSjb150015 * smb_drv_ioctl(SMB_IOC_CONFIG) --> smb_server_configure() 189faa1795aSjb150015 * 190faa1795aSjb150015 * Transition T2 191faa1795aSjb150015 * 192faa1795aSjb150015 * This transition occurs in smb_server_start(). It is triggered by the 193faa1795aSjb150015 * daemon through an Ioctl. 194faa1795aSjb150015 * 195faa1795aSjb150015 * smb_drv_ioctl(SMB_IOC_START) --> smb_server_start() 196faa1795aSjb150015 * 197faa1795aSjb150015 * Transition T3 198faa1795aSjb150015 * 199faa1795aSjb150015 * This transition occurs in smb_server_delete(). It is triggered by the 200faa1795aSjb150015 * daemon when closing the smbsrv device 201faa1795aSjb150015 * 202faa1795aSjb150015 * smb_drv_close() --> smb_server_delete() 203faa1795aSjb150015 * 204faa1795aSjb150015 * Comments 205faa1795aSjb150015 * -------- 206faa1795aSjb150015 * 207faa1795aSjb150015 * This files assumes that there will one SMB server per zone. For now the 208faa1795aSjb150015 * smb server works only in global zone. There's nothing in this file preventing 209faa1795aSjb150015 * an smb server from being created in a non global zone. That limitation is 210faa1795aSjb150015 * enforced in user space. 211faa1795aSjb150015 */ 212faa1795aSjb150015 213faa1795aSjb150015 #include <sys/strsubr.h> 214faa1795aSjb150015 #include <sys/cmn_err.h> 215faa1795aSjb150015 #include <sys/priv.h> 216faa1795aSjb150015 #include <sys/socketvar.h> 217faa1795aSjb150015 #include <sys/zone.h> 218bbf6f00cSJordan Brown #include <netinet/in.h> 219bbf6f00cSJordan Brown #include <netinet/in_systm.h> 220bbf6f00cSJordan Brown #include <netinet/ip.h> 221bbf6f00cSJordan Brown #include <netinet/ip_icmp.h> 222bbf6f00cSJordan Brown #include <netinet/ip_var.h> 223bbf6f00cSJordan Brown #include <netinet/tcp.h> 224faa1795aSjb150015 #include <smbsrv/smb_kproto.h> 225bbf6f00cSJordan Brown #include <smbsrv/string.h> 226faa1795aSjb150015 #include <smbsrv/netbios.h> 227faa1795aSjb150015 #include <smbsrv/smb_fsops.h> 2283db3f65cSamw #include <smbsrv/smb_share.h> 2299fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States #include <smbsrv/smb_door.h> 2306537f381Sas200622 #include <smbsrv/smb_kstat.h> 231faa1795aSjb150015 2329fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States #define SMB_EVENT_TIMEOUT 45 /* seconds */ 2339fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 234faa1795aSjb150015 extern void smb_reply_notify_change_request(smb_request_t *); 235faa1795aSjb150015 236*148c5f43SAlan Wright static void smb_server_kstat_init(smb_server_t *); 237faa1795aSjb150015 static void smb_server_kstat_fini(smb_server_t *); 238faa1795aSjb150015 static void smb_server_timers(smb_thread_t *, void *); 239faa1795aSjb150015 static int smb_server_listen(smb_server_t *, smb_listener_daemon_t *, 2407f667e74Sjose borrego in_port_t, int, int); 2419fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static void smb_server_listen_fini(smb_listener_daemon_t *); 2429fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static kt_did_t smb_server_listener_tid(smb_listener_daemon_t *); 243faa1795aSjb150015 static int smb_server_lookup(smb_server_t **); 244faa1795aSjb150015 static void smb_server_release(smb_server_t *); 24529bd2886SAlan Wright static void smb_server_store_cfg(smb_server_t *, smb_ioc_cfg_t *); 2469fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static void smb_server_shutdown(smb_server_t *); 247faa1795aSjb150015 static int smb_server_fsop_start(smb_server_t *); 248faa1795aSjb150015 static void smb_server_fsop_stop(smb_server_t *); 2499fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static void smb_server_signal_listeners(smb_server_t *); 2509fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static void smb_event_cancel(smb_server_t *, uint32_t); 2519fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static void smb_event_notify(smb_server_t *, uint32_t); 2529fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static uint32_t smb_event_alloc_txid(void); 253faa1795aSjb150015 2549fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static void smb_server_disconnect_share(smb_session_list_t *, const char *); 2551fcced4cSJordan Brown static void smb_server_enum_private(smb_session_list_t *, smb_svcenum_t *); 2561fcced4cSJordan Brown static int smb_server_sesion_disconnect(smb_session_list_t *, const char *, 2571fcced4cSJordan Brown const char *); 2581fcced4cSJordan Brown static int smb_server_fclose(smb_session_list_t *, uint32_t); 259*148c5f43SAlan Wright static int smb_server_kstat_update(kstat_t *, int); 2601fcced4cSJordan Brown 2619fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States int smb_event_debug = 0; 2629fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 263faa1795aSjb150015 static smb_llist_t smb_servers; 264faa1795aSjb150015 265faa1795aSjb150015 /* 266faa1795aSjb150015 * ***************************************************************************** 267faa1795aSjb150015 * **************** Functions called from the device interface ***************** 268faa1795aSjb150015 * ***************************************************************************** 269faa1795aSjb150015 * 2701fcced4cSJordan Brown * These functions typically have to determine the relevant smb server 2711fcced4cSJordan Brown * to which the call applies. 272faa1795aSjb150015 */ 273faa1795aSjb150015 274faa1795aSjb150015 /* 275faa1795aSjb150015 * smb_server_svc_init 276faa1795aSjb150015 * 277c8ec8eeaSjose borrego * This function must be called from smb_drv_attach(). 278faa1795aSjb150015 */ 279faa1795aSjb150015 int 280faa1795aSjb150015 smb_server_svc_init(void) 281faa1795aSjb150015 { 282faa1795aSjb150015 int rc = 0; 283faa1795aSjb150015 284faa1795aSjb150015 while (rc == 0) { 2852c2961f8Sjose borrego if (rc = smb_mbc_init()) 2862c2961f8Sjose borrego continue; 287faa1795aSjb150015 if (rc = smb_vop_init()) 288faa1795aSjb150015 continue; 289faa1795aSjb150015 if (rc = smb_node_init()) 29021b7895dSjb150015 continue; 291faa1795aSjb150015 if (rc = smb_fem_init()) 29221b7895dSjb150015 continue; 293faa1795aSjb150015 if (rc = smb_notify_init()) 29421b7895dSjb150015 continue; 29521b7895dSjb150015 if (rc = smb_net_init()) 29621b7895dSjb150015 continue; 2979fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_init(); 298faa1795aSjb150015 smb_llist_constructor(&smb_servers, sizeof (smb_server_t), 299faa1795aSjb150015 offsetof(smb_server_t, sv_lnd)); 300faa1795aSjb150015 return (0); 301faa1795aSjb150015 } 3029fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 3039fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_fini(); 30421b7895dSjb150015 smb_net_fini(); 305faa1795aSjb150015 smb_notify_fini(); 306faa1795aSjb150015 smb_fem_fini(); 307faa1795aSjb150015 smb_node_fini(); 308faa1795aSjb150015 smb_vop_fini(); 3092c2961f8Sjose borrego smb_mbc_fini(); 310faa1795aSjb150015 return (rc); 311faa1795aSjb150015 } 312faa1795aSjb150015 313faa1795aSjb150015 /* 314faa1795aSjb150015 * smb_server_svc_fini 315faa1795aSjb150015 * 316faa1795aSjb150015 * This function must called from smb_drv_detach(). It will fail if servers 317faa1795aSjb150015 * still exist. 318faa1795aSjb150015 */ 319faa1795aSjb150015 int 320faa1795aSjb150015 smb_server_svc_fini(void) 321faa1795aSjb150015 { 322faa1795aSjb150015 int rc = EBUSY; 323faa1795aSjb150015 324faa1795aSjb150015 if (smb_llist_get_count(&smb_servers) == 0) { 3259fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_fini(); 32621b7895dSjb150015 smb_net_fini(); 327faa1795aSjb150015 smb_notify_fini(); 328faa1795aSjb150015 smb_fem_fini(); 329faa1795aSjb150015 smb_node_fini(); 330faa1795aSjb150015 smb_vop_fini(); 3312c2961f8Sjose borrego smb_mbc_fini(); 332faa1795aSjb150015 smb_llist_destructor(&smb_servers); 333faa1795aSjb150015 rc = 0; 334faa1795aSjb150015 } 335faa1795aSjb150015 return (rc); 336faa1795aSjb150015 } 337faa1795aSjb150015 338faa1795aSjb150015 /* 339faa1795aSjb150015 * smb_server_create 340faa1795aSjb150015 * 341faa1795aSjb150015 * This function will fail if there's already a server associated with the 342faa1795aSjb150015 * caller's zone. 343faa1795aSjb150015 */ 344faa1795aSjb150015 int 345faa1795aSjb150015 smb_server_create(void) 346faa1795aSjb150015 { 347faa1795aSjb150015 zoneid_t zid; 348faa1795aSjb150015 smb_server_t *sv; 349faa1795aSjb150015 350faa1795aSjb150015 zid = getzoneid(); 351faa1795aSjb150015 352faa1795aSjb150015 smb_llist_enter(&smb_servers, RW_WRITER); 353faa1795aSjb150015 sv = smb_llist_head(&smb_servers); 354faa1795aSjb150015 while (sv) { 3559fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_VALID(sv); 356faa1795aSjb150015 if (sv->sv_zid == zid) { 357faa1795aSjb150015 smb_llist_exit(&smb_servers); 35894fff790SAlan Wright return (EPERM); 359faa1795aSjb150015 } 360faa1795aSjb150015 sv = smb_llist_next(&smb_servers, sv); 361faa1795aSjb150015 } 362faa1795aSjb150015 363faa1795aSjb150015 sv = kmem_zalloc(sizeof (smb_server_t), KM_NOSLEEP); 364faa1795aSjb150015 if (sv == NULL) { 365faa1795aSjb150015 smb_llist_exit(&smb_servers); 366faa1795aSjb150015 return (ENOMEM); 367faa1795aSjb150015 } 368faa1795aSjb150015 3699fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_constructor(&sv->sv_opipe_list, sizeof (smb_opipe_t), 3709fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States offsetof(smb_opipe_t, p_lnd)); 3719fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 3729fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_constructor(&sv->sv_event_list, sizeof (smb_event_t), 3739fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States offsetof(smb_event_t, se_lnd)); 3749fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 375faa1795aSjb150015 smb_session_list_constructor(&sv->sv_nbt_daemon.ld_session_list); 376faa1795aSjb150015 smb_session_list_constructor(&sv->sv_tcp_daemon.ld_session_list); 377faa1795aSjb150015 378faa1795aSjb150015 sv->si_cache_request = kmem_cache_create("smb_request_cache", 379faa1795aSjb150015 sizeof (smb_request_t), 8, NULL, NULL, NULL, NULL, NULL, 0); 380faa1795aSjb150015 sv->si_cache_session = kmem_cache_create("smb_session_cache", 381faa1795aSjb150015 sizeof (smb_session_t), 8, NULL, NULL, NULL, NULL, NULL, 0); 382faa1795aSjb150015 sv->si_cache_user = kmem_cache_create("smb_user_cache", 383faa1795aSjb150015 sizeof (smb_user_t), 8, NULL, NULL, NULL, NULL, NULL, 0); 384faa1795aSjb150015 sv->si_cache_tree = kmem_cache_create("smb_tree_cache", 385faa1795aSjb150015 sizeof (smb_tree_t), 8, NULL, NULL, NULL, NULL, NULL, 0); 386faa1795aSjb150015 sv->si_cache_ofile = kmem_cache_create("smb_ofile_cache", 387faa1795aSjb150015 sizeof (smb_ofile_t), 8, NULL, NULL, NULL, NULL, NULL, 0); 388faa1795aSjb150015 sv->si_cache_odir = kmem_cache_create("smb_odir_cache", 389faa1795aSjb150015 sizeof (smb_odir_t), 8, NULL, NULL, NULL, NULL, NULL, 0); 3909fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States sv->si_cache_opipe = kmem_cache_create("smb_opipe_cache", 3919fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States sizeof (smb_opipe_t), 8, NULL, NULL, NULL, NULL, NULL, 0); 3929fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States sv->si_cache_event = kmem_cache_create("smb_event_cache", 3939fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States sizeof (smb_event_t), 8, NULL, NULL, NULL, NULL, NULL, 0); 394faa1795aSjb150015 395faa1795aSjb150015 smb_thread_init(&sv->si_thread_timers, 396faa1795aSjb150015 "smb_timers", smb_server_timers, sv, 397faa1795aSjb150015 NULL, NULL); 398faa1795aSjb150015 3996537f381Sas200622 sv->sv_pid = curproc->p_pid; 400*148c5f43SAlan Wright smb_srqueue_init(&sv->sv_srqueue); 401faa1795aSjb150015 4029fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_kdoor_init(); 4033db3f65cSamw smb_opipe_door_init(); 404*148c5f43SAlan Wright smb_server_kstat_init(sv); 405faa1795aSjb150015 406faa1795aSjb150015 mutex_init(&sv->sv_mutex, NULL, MUTEX_DEFAULT, NULL); 407faa1795aSjb150015 cv_init(&sv->sv_cv, NULL, CV_DEFAULT, NULL); 408faa1795aSjb150015 sv->sv_state = SMB_SERVER_STATE_CREATED; 409faa1795aSjb150015 sv->sv_magic = SMB_SERVER_MAGIC; 410faa1795aSjb150015 sv->sv_zid = zid; 411faa1795aSjb150015 412faa1795aSjb150015 smb_llist_insert_tail(&smb_servers, sv); 413faa1795aSjb150015 smb_llist_exit(&smb_servers); 414faa1795aSjb150015 return (0); 415faa1795aSjb150015 } 416faa1795aSjb150015 417faa1795aSjb150015 /* 418faa1795aSjb150015 * smb_server_delete 419faa1795aSjb150015 * 420faa1795aSjb150015 * This function will delete the server passed in. It will make sure that all 421faa1795aSjb150015 * activity associated that server has ceased before destroying it. 422faa1795aSjb150015 */ 423faa1795aSjb150015 int 424faa1795aSjb150015 smb_server_delete(void) 425faa1795aSjb150015 { 426faa1795aSjb150015 smb_server_t *sv; 4279fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States kt_did_t nbt_tid; 4289fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States kt_did_t tcp_tid; 429faa1795aSjb150015 int rc; 430faa1795aSjb150015 431faa1795aSjb150015 rc = smb_server_lookup(&sv); 432faa1795aSjb150015 if (rc != 0) 433faa1795aSjb150015 return (rc); 434faa1795aSjb150015 435faa1795aSjb150015 mutex_enter(&sv->sv_mutex); 436faa1795aSjb150015 switch (sv->sv_state) { 437faa1795aSjb150015 case SMB_SERVER_STATE_RUNNING: 4389fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States case SMB_SERVER_STATE_STOPPING: 4399fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States sv->sv_state = SMB_SERVER_STATE_STOPPING; 4409fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_signal_listeners(sv); 4419fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States nbt_tid = smb_server_listener_tid(&sv->sv_nbt_daemon); 4429fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States tcp_tid = smb_server_listener_tid(&sv->sv_tcp_daemon); 443faa1795aSjb150015 444faa1795aSjb150015 sv->sv_state = SMB_SERVER_STATE_DELETING; 445faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 4469fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 4479fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (nbt_tid != 0) 4489fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States thread_join(nbt_tid); 4499fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (tcp_tid != 0) 4509fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States thread_join(tcp_tid); 4519fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 4529fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_listen_fini(&sv->sv_nbt_daemon); 4539fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_listen_fini(&sv->sv_tcp_daemon); 454faa1795aSjb150015 mutex_enter(&sv->sv_mutex); 455faa1795aSjb150015 break; 456faa1795aSjb150015 case SMB_SERVER_STATE_CONFIGURED: 457faa1795aSjb150015 case SMB_SERVER_STATE_CREATED: 458faa1795aSjb150015 sv->sv_state = SMB_SERVER_STATE_DELETING; 459faa1795aSjb150015 break; 460faa1795aSjb150015 default: 4619fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_STATE_VALID(sv->sv_state); 462faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 463faa1795aSjb150015 smb_server_release(sv); 464faa1795aSjb150015 return (ENOTTY); 465faa1795aSjb150015 } 466faa1795aSjb150015 467faa1795aSjb150015 ASSERT(sv->sv_state == SMB_SERVER_STATE_DELETING); 468faa1795aSjb150015 469faa1795aSjb150015 sv->sv_refcnt--; 470faa1795aSjb150015 while (sv->sv_refcnt) 471faa1795aSjb150015 cv_wait(&sv->sv_cv, &sv->sv_mutex); 472faa1795aSjb150015 473faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 474faa1795aSjb150015 475faa1795aSjb150015 smb_llist_enter(&smb_servers, RW_WRITER); 476faa1795aSjb150015 smb_llist_remove(&smb_servers, sv); 477faa1795aSjb150015 smb_llist_exit(&smb_servers); 478faa1795aSjb150015 4799fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_shutdown(sv); 480faa1795aSjb150015 rw_destroy(&sv->sv_cfg_lock); 4813db3f65cSamw smb_opipe_door_fini(); 4829fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_kdoor_fini(); 483faa1795aSjb150015 smb_server_kstat_fini(sv); 4849fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_destructor(&sv->sv_opipe_list); 4859fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_destructor(&sv->sv_event_list); 4862c1b14e5Sjose borrego 487faa1795aSjb150015 kmem_cache_destroy(sv->si_cache_request); 488faa1795aSjb150015 kmem_cache_destroy(sv->si_cache_session); 489faa1795aSjb150015 kmem_cache_destroy(sv->si_cache_user); 490faa1795aSjb150015 kmem_cache_destroy(sv->si_cache_tree); 491faa1795aSjb150015 kmem_cache_destroy(sv->si_cache_ofile); 492faa1795aSjb150015 kmem_cache_destroy(sv->si_cache_odir); 4939fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States kmem_cache_destroy(sv->si_cache_opipe); 4949fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States kmem_cache_destroy(sv->si_cache_event); 495faa1795aSjb150015 496*148c5f43SAlan Wright smb_srqueue_destroy(&sv->sv_srqueue); 497*148c5f43SAlan Wright 498faa1795aSjb150015 smb_thread_destroy(&sv->si_thread_timers); 499faa1795aSjb150015 mutex_destroy(&sv->sv_mutex); 500faa1795aSjb150015 cv_destroy(&sv->sv_cv); 501faa1795aSjb150015 sv->sv_magic = 0; 502faa1795aSjb150015 kmem_free(sv, sizeof (smb_server_t)); 503faa1795aSjb150015 504faa1795aSjb150015 return (0); 505faa1795aSjb150015 } 506faa1795aSjb150015 507faa1795aSjb150015 /* 508faa1795aSjb150015 * smb_server_configure 509faa1795aSjb150015 */ 510faa1795aSjb150015 int 51129bd2886SAlan Wright smb_server_configure(smb_ioc_cfg_t *ioc) 512faa1795aSjb150015 { 513faa1795aSjb150015 int rc = 0; 514faa1795aSjb150015 smb_server_t *sv; 515faa1795aSjb150015 516faa1795aSjb150015 rc = smb_server_lookup(&sv); 517faa1795aSjb150015 if (rc) 518faa1795aSjb150015 return (rc); 519faa1795aSjb150015 520faa1795aSjb150015 mutex_enter(&sv->sv_mutex); 521faa1795aSjb150015 switch (sv->sv_state) { 522faa1795aSjb150015 case SMB_SERVER_STATE_CREATED: 52329bd2886SAlan Wright smb_server_store_cfg(sv, ioc); 524faa1795aSjb150015 sv->sv_state = SMB_SERVER_STATE_CONFIGURED; 525faa1795aSjb150015 break; 526faa1795aSjb150015 527faa1795aSjb150015 case SMB_SERVER_STATE_CONFIGURED: 52829bd2886SAlan Wright smb_server_store_cfg(sv, ioc); 529faa1795aSjb150015 break; 530faa1795aSjb150015 531faa1795aSjb150015 case SMB_SERVER_STATE_RUNNING: 5329fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States case SMB_SERVER_STATE_STOPPING: 533faa1795aSjb150015 rw_enter(&sv->sv_cfg_lock, RW_WRITER); 53429bd2886SAlan Wright smb_server_store_cfg(sv, ioc); 535faa1795aSjb150015 rw_exit(&sv->sv_cfg_lock); 536faa1795aSjb150015 break; 537faa1795aSjb150015 538faa1795aSjb150015 default: 5399fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_STATE_VALID(sv->sv_state); 540faa1795aSjb150015 rc = EFAULT; 541faa1795aSjb150015 break; 542faa1795aSjb150015 } 543faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 544faa1795aSjb150015 545faa1795aSjb150015 smb_server_release(sv); 546faa1795aSjb150015 547faa1795aSjb150015 return (rc); 548faa1795aSjb150015 } 549faa1795aSjb150015 550faa1795aSjb150015 /* 551faa1795aSjb150015 * smb_server_start 552faa1795aSjb150015 */ 553faa1795aSjb150015 int 55429bd2886SAlan Wright smb_server_start(smb_ioc_start_t *ioc) 555faa1795aSjb150015 { 556faa1795aSjb150015 int rc = 0; 557faa1795aSjb150015 smb_server_t *sv; 558faa1795aSjb150015 559faa1795aSjb150015 rc = smb_server_lookup(&sv); 560faa1795aSjb150015 if (rc) 561faa1795aSjb150015 return (rc); 562faa1795aSjb150015 563faa1795aSjb150015 mutex_enter(&sv->sv_mutex); 564faa1795aSjb150015 switch (sv->sv_state) { 565faa1795aSjb150015 case SMB_SERVER_STATE_CONFIGURED: 566bbf6f00cSJordan Brown smb_codepage_init(); 567faa1795aSjb150015 568faa1795aSjb150015 sv->sv_thread_pool = taskq_create("smb_workers", 569faa1795aSjb150015 sv->sv_cfg.skc_maxworkers, SMB_WORKER_PRIORITY, 570faa1795aSjb150015 sv->sv_cfg.skc_maxworkers, INT_MAX, 571faa1795aSjb150015 TASKQ_DYNAMIC|TASKQ_PREPOPULATE); 572faa1795aSjb150015 5737f667e74Sjose borrego sv->sv_session = smb_session_create(NULL, 0, sv, 0); 5748d96b23eSAlan Wright 5758d96b23eSAlan Wright if (sv->sv_thread_pool == NULL || sv->sv_session == NULL) { 576faa1795aSjb150015 rc = ENOMEM; 577faa1795aSjb150015 break; 578faa1795aSjb150015 } 579faa1795aSjb150015 580faa1795aSjb150015 if (rc = smb_server_fsop_start(sv)) 581faa1795aSjb150015 break; 582faa1795aSjb150015 ASSERT(sv->sv_lmshrd == NULL); 583*148c5f43SAlan Wright sv->sv_lmshrd = smb_kshare_door_init(ioc->lmshrd); 584faa1795aSjb150015 if (sv->sv_lmshrd == NULL) 585faa1795aSjb150015 break; 5869fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (rc = smb_kdoor_open(ioc->udoor)) { 5879fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cmn_err(CE_WARN, "Cannot open smbd door"); 588faa1795aSjb150015 break; 5899fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 59029bd2886SAlan Wright if (rc = smb_opipe_door_open(ioc->opipe)) { 5913db3f65cSamw cmn_err(CE_WARN, "Cannot open opipe door"); 592faa1795aSjb150015 break; 593faa1795aSjb150015 } 5949fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (rc = smb_thread_start(&sv->si_thread_timers)) 5959fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 596faa1795aSjb150015 sv->sv_state = SMB_SERVER_STATE_RUNNING; 597*148c5f43SAlan Wright sv->sv_start_time = gethrtime(); 598faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 599faa1795aSjb150015 smb_server_release(sv); 600*148c5f43SAlan Wright 601*148c5f43SAlan Wright smb_export_start(); 602faa1795aSjb150015 return (0); 603faa1795aSjb150015 default: 6049fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_STATE_VALID(sv->sv_state); 605faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 606faa1795aSjb150015 smb_server_release(sv); 607faa1795aSjb150015 return (ENOTTY); 608faa1795aSjb150015 } 609faa1795aSjb150015 6109fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_shutdown(sv); 611faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 612faa1795aSjb150015 smb_server_release(sv); 613faa1795aSjb150015 return (rc); 614faa1795aSjb150015 } 615faa1795aSjb150015 616faa1795aSjb150015 /* 6179fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * An smbd is shutting down. 6189fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States */ 6199fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States int 6209fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_stop(void) 6219fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 6229fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_t *sv; 6239fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States int rc; 6249fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6259fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if ((rc = smb_server_lookup(&sv)) != 0) 6269fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (rc); 6279fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6289fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_enter(&sv->sv_mutex); 6299fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States switch (sv->sv_state) { 6309fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States case SMB_SERVER_STATE_RUNNING: 6319fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States sv->sv_state = SMB_SERVER_STATE_STOPPING; 6329fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_signal_listeners(sv); 6339fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 6349fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States default: 6359fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_STATE_VALID(sv->sv_state); 6369fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 6379fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 6389fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_exit(&sv->sv_mutex); 6399fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6409fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_release(sv); 6419fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (0); 6429fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 6439fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6449fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States boolean_t 6459fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_is_stopping(void) 6469fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 6479fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_t *sv; 6489fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States boolean_t status; 6499fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6509fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (smb_server_lookup(&sv) != 0) 6519fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (B_TRUE); 6529fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6539fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_VALID(sv); 6549fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6559fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_enter(&sv->sv_mutex); 6569fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6579fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States switch (sv->sv_state) { 6589fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States case SMB_SERVER_STATE_STOPPING: 6599fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States case SMB_SERVER_STATE_DELETING: 6609fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States status = B_TRUE; 6619fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 6629fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States default: 6639fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States status = B_FALSE; 6649fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 6659fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 6669fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6679fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_exit(&sv->sv_mutex); 6689fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_release(sv); 6699fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (status); 6709fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 6719fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6729fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States int 6739fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_cancel_event(uint32_t txid) 6749fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 6759fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_t *sv; 6769fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States int rc; 6779fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6789fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if ((rc = smb_server_lookup(&sv)) == 0) { 6799fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_cancel(sv, txid); 6809fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_release(sv); 6819fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 6829fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6839fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (rc); 6849fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 6859fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6869fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States int 6879fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_notify_event(smb_ioc_event_t *ioc) 6889fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 6899fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_t *sv; 6909fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States int rc; 6919fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6929fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if ((rc = smb_server_lookup(&sv)) == 0) { 6939fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_notify(sv, ioc->txid); 6949fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_release(sv); 6959fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 6969fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6979fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (rc); 6989fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 6999fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 7009fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States /* 7019fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * SMB-over-NetBIOS (port 139) 702faa1795aSjb150015 * 7039fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * Traditional SMB service over NetBIOS, which requires that a NetBIOS 7049fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * session be established. 705faa1795aSjb150015 */ 706faa1795aSjb150015 int 70729bd2886SAlan Wright smb_server_nbt_listen(smb_ioc_listen_t *ioc) 708faa1795aSjb150015 { 709faa1795aSjb150015 smb_server_t *sv; 710faa1795aSjb150015 int rc; 711faa1795aSjb150015 712faa1795aSjb150015 rc = smb_server_lookup(&sv); 713faa1795aSjb150015 if (rc) 714faa1795aSjb150015 return (rc); 715faa1795aSjb150015 716faa1795aSjb150015 mutex_enter(&sv->sv_mutex); 717faa1795aSjb150015 switch (sv->sv_state) { 718faa1795aSjb150015 case SMB_SERVER_STATE_RUNNING: 719faa1795aSjb150015 if ((sv->sv_nbt_daemon.ld_kth != NULL) && 720faa1795aSjb150015 (sv->sv_nbt_daemon.ld_kth != curthread)) { 721faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 72208f0d8daSafshin salek ardakani - Sun Microsystems - Irvine United States smb_server_release(sv); 723faa1795aSjb150015 return (EACCES); 724faa1795aSjb150015 } else { 725faa1795aSjb150015 sv->sv_nbt_daemon.ld_kth = curthread; 726faa1795aSjb150015 sv->sv_nbt_daemon.ld_ktdid = curthread->t_did; 727faa1795aSjb150015 } 728faa1795aSjb150015 break; 7299fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States case SMB_SERVER_STATE_STOPPING: 7309fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_exit(&sv->sv_mutex); 7319fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_release(sv); 7329fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (ECANCELED); 733faa1795aSjb150015 default: 7349fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_STATE_VALID(sv->sv_state); 735faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 736faa1795aSjb150015 smb_server_release(sv); 737faa1795aSjb150015 return (EFAULT); 738faa1795aSjb150015 } 739faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 740faa1795aSjb150015 7417f667e74Sjose borrego /* 7427f667e74Sjose borrego * netbios must be ipv4 7437f667e74Sjose borrego */ 744a0aa776eSAlan Wright rc = smb_server_listen(sv, &sv->sv_nbt_daemon, IPPORT_NETBIOS_SSN, 74529bd2886SAlan Wright AF_INET, ioc->error); 746faa1795aSjb150015 747faa1795aSjb150015 mutex_enter(&sv->sv_mutex); 748faa1795aSjb150015 sv->sv_nbt_daemon.ld_kth = NULL; 749faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 750faa1795aSjb150015 751faa1795aSjb150015 smb_server_release(sv); 752faa1795aSjb150015 return (rc); 753faa1795aSjb150015 } 754faa1795aSjb150015 7559fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States /* 7569fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * SMB-over-TCP (port 445) 7579fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States */ 758faa1795aSjb150015 int 75929bd2886SAlan Wright smb_server_tcp_listen(smb_ioc_listen_t *ioc) 760faa1795aSjb150015 { 761faa1795aSjb150015 smb_server_t *sv; 762faa1795aSjb150015 int rc; 763faa1795aSjb150015 764faa1795aSjb150015 rc = smb_server_lookup(&sv); 765faa1795aSjb150015 if (rc) 766faa1795aSjb150015 return (rc); 767faa1795aSjb150015 768faa1795aSjb150015 mutex_enter(&sv->sv_mutex); 769faa1795aSjb150015 switch (sv->sv_state) { 770faa1795aSjb150015 case SMB_SERVER_STATE_RUNNING: 7719fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if ((sv->sv_tcp_daemon.ld_kth != NULL) && 772faa1795aSjb150015 (sv->sv_tcp_daemon.ld_kth != curthread)) { 773faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 77408f0d8daSafshin salek ardakani - Sun Microsystems - Irvine United States smb_server_release(sv); 775faa1795aSjb150015 return (EACCES); 776faa1795aSjb150015 } else { 777faa1795aSjb150015 sv->sv_tcp_daemon.ld_kth = curthread; 778faa1795aSjb150015 sv->sv_tcp_daemon.ld_ktdid = curthread->t_did; 779faa1795aSjb150015 } 780faa1795aSjb150015 break; 7819fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States case SMB_SERVER_STATE_STOPPING: 7829fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_exit(&sv->sv_mutex); 7839fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_release(sv); 7849fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (ECANCELED); 785faa1795aSjb150015 default: 7869fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_STATE_VALID(sv->sv_state); 787faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 78808f0d8daSafshin salek ardakani - Sun Microsystems - Irvine United States smb_server_release(sv); 789faa1795aSjb150015 return (EFAULT); 790faa1795aSjb150015 } 791faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 792faa1795aSjb150015 7937f667e74Sjose borrego if (sv->sv_cfg.skc_ipv6_enable) 7947f667e74Sjose borrego rc = smb_server_listen(sv, &sv->sv_tcp_daemon, 795a0aa776eSAlan Wright IPPORT_SMB, AF_INET6, ioc->error); 7967f667e74Sjose borrego else 7977f667e74Sjose borrego rc = smb_server_listen(sv, &sv->sv_tcp_daemon, 798a0aa776eSAlan Wright IPPORT_SMB, AF_INET, ioc->error); 7999fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 800faa1795aSjb150015 mutex_enter(&sv->sv_mutex); 801faa1795aSjb150015 sv->sv_tcp_daemon.ld_kth = NULL; 802faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 803faa1795aSjb150015 804faa1795aSjb150015 smb_server_release(sv); 805faa1795aSjb150015 return (rc); 806faa1795aSjb150015 } 807faa1795aSjb150015 808faa1795aSjb150015 /* 809faa1795aSjb150015 * smb_server_nbt_receive 810faa1795aSjb150015 */ 811faa1795aSjb150015 int 812faa1795aSjb150015 smb_server_nbt_receive(void) 813faa1795aSjb150015 { 814faa1795aSjb150015 int rc; 815faa1795aSjb150015 smb_server_t *sv; 816faa1795aSjb150015 81708f0d8daSafshin salek ardakani - Sun Microsystems - Irvine United States if ((rc = smb_server_lookup(&sv)) == 0) { 818faa1795aSjb150015 rc = smb_session_daemon(&sv->sv_nbt_daemon.ld_session_list); 819faa1795aSjb150015 smb_server_release(sv); 82008f0d8daSafshin salek ardakani - Sun Microsystems - Irvine United States } 821faa1795aSjb150015 822faa1795aSjb150015 return (rc); 823faa1795aSjb150015 } 824faa1795aSjb150015 825faa1795aSjb150015 /* 826faa1795aSjb150015 * smb_server_tcp_receive 827faa1795aSjb150015 */ 828faa1795aSjb150015 int 829faa1795aSjb150015 smb_server_tcp_receive(void) 830faa1795aSjb150015 { 831faa1795aSjb150015 int rc; 832faa1795aSjb150015 smb_server_t *sv; 833faa1795aSjb150015 83408f0d8daSafshin salek ardakani - Sun Microsystems - Irvine United States if ((rc = smb_server_lookup(&sv)) == 0) { 835faa1795aSjb150015 rc = smb_session_daemon(&sv->sv_tcp_daemon.ld_session_list); 836faa1795aSjb150015 smb_server_release(sv); 83708f0d8daSafshin salek ardakani - Sun Microsystems - Irvine United States } 838faa1795aSjb150015 839faa1795aSjb150015 return (rc); 840faa1795aSjb150015 } 841faa1795aSjb150015 842faa1795aSjb150015 int 84329bd2886SAlan Wright smb_server_set_gmtoff(smb_ioc_gmt_t *ioc) 844faa1795aSjb150015 { 845faa1795aSjb150015 int rc; 846faa1795aSjb150015 smb_server_t *sv; 847faa1795aSjb150015 84808f0d8daSafshin salek ardakani - Sun Microsystems - Irvine United States if ((rc = smb_server_lookup(&sv)) == 0) { 84929bd2886SAlan Wright sv->si_gmtoff = ioc->offset; 850faa1795aSjb150015 smb_server_release(sv); 85108f0d8daSafshin salek ardakani - Sun Microsystems - Irvine United States } 852faa1795aSjb150015 853faa1795aSjb150015 return (rc); 854faa1795aSjb150015 } 855faa1795aSjb150015 85629bd2886SAlan Wright int 8571fcced4cSJordan Brown smb_server_numopen(smb_ioc_opennum_t *ioc) 85829bd2886SAlan Wright { 85929bd2886SAlan Wright smb_server_t *sv; 86029bd2886SAlan Wright int rc; 86129bd2886SAlan Wright 86229bd2886SAlan Wright if ((rc = smb_server_lookup(&sv)) == 0) { 863*148c5f43SAlan Wright ioc->open_users = sv->sv_users; 864*148c5f43SAlan Wright ioc->open_trees = sv->sv_trees; 865*148c5f43SAlan Wright ioc->open_files = sv->sv_files + sv->sv_pipes; 86629bd2886SAlan Wright smb_server_release(sv); 86729bd2886SAlan Wright } 86829bd2886SAlan Wright return (rc); 86929bd2886SAlan Wright } 87029bd2886SAlan Wright 871faa1795aSjb150015 /* 8721fcced4cSJordan Brown * Enumerate objects within the server. The svcenum provides the 8731fcced4cSJordan Brown * enumeration context, i.e. what the caller want to get back. 8741fcced4cSJordan Brown */ 8751fcced4cSJordan Brown int 8761fcced4cSJordan Brown smb_server_enum(smb_ioc_svcenum_t *ioc) 8771fcced4cSJordan Brown { 8781fcced4cSJordan Brown smb_svcenum_t *svcenum = &ioc->svcenum; 8791fcced4cSJordan Brown smb_server_t *sv; 8801fcced4cSJordan Brown smb_session_list_t *se; 8811fcced4cSJordan Brown int rc; 8821fcced4cSJordan Brown 8831fcced4cSJordan Brown switch (svcenum->se_type) { 8841fcced4cSJordan Brown case SMB_SVCENUM_TYPE_USER: 8851fcced4cSJordan Brown case SMB_SVCENUM_TYPE_TREE: 8861fcced4cSJordan Brown case SMB_SVCENUM_TYPE_FILE: 8871fcced4cSJordan Brown break; 8881fcced4cSJordan Brown default: 8891fcced4cSJordan Brown return (EINVAL); 8901fcced4cSJordan Brown } 8911fcced4cSJordan Brown 8921fcced4cSJordan Brown if ((rc = smb_server_lookup(&sv)) != 0) 8931fcced4cSJordan Brown return (rc); 8941fcced4cSJordan Brown 8951fcced4cSJordan Brown svcenum->se_bavail = svcenum->se_buflen; 8961fcced4cSJordan Brown svcenum->se_bused = 0; 8971fcced4cSJordan Brown svcenum->se_nitems = 0; 8981fcced4cSJordan Brown 8991fcced4cSJordan Brown se = &sv->sv_nbt_daemon.ld_session_list; 9001fcced4cSJordan Brown smb_server_enum_private(se, svcenum); 9011fcced4cSJordan Brown 9021fcced4cSJordan Brown se = &sv->sv_tcp_daemon.ld_session_list; 9031fcced4cSJordan Brown smb_server_enum_private(se, svcenum); 9041fcced4cSJordan Brown 9051fcced4cSJordan Brown smb_server_release(sv); 9061fcced4cSJordan Brown return (0); 9071fcced4cSJordan Brown } 9081fcced4cSJordan Brown 9091fcced4cSJordan Brown /* 9101fcced4cSJordan Brown * Look for sessions to disconnect by client and user name. 9111fcced4cSJordan Brown */ 9121fcced4cSJordan Brown int 9131fcced4cSJordan Brown smb_server_session_close(smb_ioc_session_t *ioc) 9141fcced4cSJordan Brown { 9151fcced4cSJordan Brown smb_session_list_t *se; 9161fcced4cSJordan Brown smb_server_t *sv; 9171fcced4cSJordan Brown int nbt_cnt; 9181fcced4cSJordan Brown int tcp_cnt; 9191fcced4cSJordan Brown int rc; 9201fcced4cSJordan Brown 9211fcced4cSJordan Brown if ((rc = smb_server_lookup(&sv)) != 0) 9221fcced4cSJordan Brown return (rc); 9231fcced4cSJordan Brown 9241fcced4cSJordan Brown se = &sv->sv_nbt_daemon.ld_session_list; 9251fcced4cSJordan Brown nbt_cnt = smb_server_sesion_disconnect(se, ioc->client, ioc->username); 9261fcced4cSJordan Brown 9271fcced4cSJordan Brown se = &sv->sv_tcp_daemon.ld_session_list; 9281fcced4cSJordan Brown tcp_cnt = smb_server_sesion_disconnect(se, ioc->client, ioc->username); 9291fcced4cSJordan Brown 9301fcced4cSJordan Brown smb_server_release(sv); 9311fcced4cSJordan Brown 9321fcced4cSJordan Brown if ((nbt_cnt == 0) && (tcp_cnt == 0)) 9331fcced4cSJordan Brown return (ENOENT); 9341fcced4cSJordan Brown return (0); 9351fcced4cSJordan Brown } 9361fcced4cSJordan Brown 9371fcced4cSJordan Brown /* 9381fcced4cSJordan Brown * Close a file by uniqid. 9391fcced4cSJordan Brown */ 9401fcced4cSJordan Brown int 9411fcced4cSJordan Brown smb_server_file_close(smb_ioc_fileid_t *ioc) 9421fcced4cSJordan Brown { 9431fcced4cSJordan Brown uint32_t uniqid = ioc->uniqid; 9441fcced4cSJordan Brown smb_session_list_t *se; 9451fcced4cSJordan Brown smb_server_t *sv; 9461fcced4cSJordan Brown int rc; 9471fcced4cSJordan Brown 9481fcced4cSJordan Brown if ((rc = smb_server_lookup(&sv)) != 0) 9491fcced4cSJordan Brown return (rc); 9501fcced4cSJordan Brown 9511fcced4cSJordan Brown se = &sv->sv_nbt_daemon.ld_session_list; 9521fcced4cSJordan Brown rc = smb_server_fclose(se, uniqid); 9531fcced4cSJordan Brown 9541fcced4cSJordan Brown if (rc == ENOENT) { 9551fcced4cSJordan Brown se = &sv->sv_tcp_daemon.ld_session_list; 9561fcced4cSJordan Brown rc = smb_server_fclose(se, uniqid); 9571fcced4cSJordan Brown } 9581fcced4cSJordan Brown 9591fcced4cSJordan Brown smb_server_release(sv); 9601fcced4cSJordan Brown return (rc); 9611fcced4cSJordan Brown } 9621fcced4cSJordan Brown 9631fcced4cSJordan Brown /* 964faa1795aSjb150015 * These functions determine the relevant smb server to which the call apply. 965faa1795aSjb150015 */ 966faa1795aSjb150015 967faa1795aSjb150015 uint32_t 968faa1795aSjb150015 smb_server_get_session_count(void) 969faa1795aSjb150015 { 970faa1795aSjb150015 smb_server_t *sv; 971faa1795aSjb150015 uint32_t counter = 0; 972faa1795aSjb150015 973faa1795aSjb150015 if (smb_server_lookup(&sv)) 974faa1795aSjb150015 return (0); 975faa1795aSjb150015 976faa1795aSjb150015 rw_enter(&sv->sv_nbt_daemon.ld_session_list.se_lock, RW_READER); 977faa1795aSjb150015 counter = sv->sv_nbt_daemon.ld_session_list.se_act.count; 978faa1795aSjb150015 rw_exit(&sv->sv_nbt_daemon.ld_session_list.se_lock); 979faa1795aSjb150015 rw_enter(&sv->sv_tcp_daemon.ld_session_list.se_lock, RW_READER); 980faa1795aSjb150015 counter += sv->sv_tcp_daemon.ld_session_list.se_act.count; 981faa1795aSjb150015 rw_exit(&sv->sv_tcp_daemon.ld_session_list.se_lock); 982faa1795aSjb150015 983faa1795aSjb150015 smb_server_release(sv); 984faa1795aSjb150015 985faa1795aSjb150015 return (counter); 986faa1795aSjb150015 } 987faa1795aSjb150015 988faa1795aSjb150015 /* 989*148c5f43SAlan Wright * Gets the vnode of the specified share path. 990*148c5f43SAlan Wright * 991*148c5f43SAlan Wright * A hold on the returned vnode pointer is taken so the caller 992*148c5f43SAlan Wright * must call VN_RELE. 993*148c5f43SAlan Wright */ 994*148c5f43SAlan Wright int 995*148c5f43SAlan Wright smb_server_sharevp(const char *shr_path, vnode_t **vp) 996*148c5f43SAlan Wright { 997*148c5f43SAlan Wright smb_server_t *sv; 998*148c5f43SAlan Wright smb_request_t *sr; 999*148c5f43SAlan Wright smb_node_t *fnode = NULL; 1000*148c5f43SAlan Wright smb_node_t *dnode; 1001*148c5f43SAlan Wright char last_comp[MAXNAMELEN]; 1002*148c5f43SAlan Wright int rc = 0; 1003*148c5f43SAlan Wright 1004*148c5f43SAlan Wright ASSERT(shr_path); 1005*148c5f43SAlan Wright 1006*148c5f43SAlan Wright if ((rc = smb_server_lookup(&sv))) 1007*148c5f43SAlan Wright return (rc); 1008*148c5f43SAlan Wright 1009*148c5f43SAlan Wright mutex_enter(&sv->sv_mutex); 1010*148c5f43SAlan Wright switch (sv->sv_state) { 1011*148c5f43SAlan Wright case SMB_SERVER_STATE_RUNNING: 1012*148c5f43SAlan Wright break; 1013*148c5f43SAlan Wright default: 1014*148c5f43SAlan Wright mutex_exit(&sv->sv_mutex); 1015*148c5f43SAlan Wright smb_server_release(sv); 1016*148c5f43SAlan Wright return (ENOTACTIVE); 1017*148c5f43SAlan Wright } 1018*148c5f43SAlan Wright mutex_exit(&sv->sv_mutex); 1019*148c5f43SAlan Wright 1020*148c5f43SAlan Wright if ((sr = smb_request_alloc(sv->sv_session, 0)) == NULL) { 1021*148c5f43SAlan Wright smb_server_release(sv); 1022*148c5f43SAlan Wright return (ENOMEM); 1023*148c5f43SAlan Wright } 1024*148c5f43SAlan Wright sr->user_cr = kcred; 1025*148c5f43SAlan Wright 1026*148c5f43SAlan Wright rc = smb_pathname_reduce(sr, sr->user_cr, shr_path, 1027*148c5f43SAlan Wright NULL, NULL, &dnode, last_comp); 1028*148c5f43SAlan Wright 1029*148c5f43SAlan Wright if (rc == 0) { 1030*148c5f43SAlan Wright rc = smb_fsop_lookup(sr, sr->user_cr, SMB_FOLLOW_LINKS, 1031*148c5f43SAlan Wright sv->si_root_smb_node, dnode, last_comp, &fnode); 1032*148c5f43SAlan Wright smb_node_release(dnode); 1033*148c5f43SAlan Wright } 1034*148c5f43SAlan Wright 1035*148c5f43SAlan Wright smb_request_free(sr); 1036*148c5f43SAlan Wright smb_server_release(sv); 1037*148c5f43SAlan Wright 1038*148c5f43SAlan Wright if (rc != 0) 1039*148c5f43SAlan Wright return (rc); 1040*148c5f43SAlan Wright 1041*148c5f43SAlan Wright ASSERT(fnode->vp && fnode->vp->v_vfsp); 1042*148c5f43SAlan Wright 1043*148c5f43SAlan Wright VN_HOLD(fnode->vp); 1044*148c5f43SAlan Wright *vp = fnode->vp; 1045*148c5f43SAlan Wright 1046*148c5f43SAlan Wright smb_node_release(fnode); 1047*148c5f43SAlan Wright 1048*148c5f43SAlan Wright return (0); 1049*148c5f43SAlan Wright } 1050*148c5f43SAlan Wright 1051*148c5f43SAlan Wright 1052*148c5f43SAlan Wright /* 1053*148c5f43SAlan Wright * This is a special interface that will be utilized by ZFS to cause a share to 1054*148c5f43SAlan Wright * be added/removed. 1055*148c5f43SAlan Wright * 1056*148c5f43SAlan Wright * arg is either a lmshare_info_t or share_name from userspace. 1057*148c5f43SAlan Wright * It will need to be copied into the kernel. It is lmshare_info_t 1058*148c5f43SAlan Wright * for add operations and share_name for delete operations. 1059*148c5f43SAlan Wright */ 1060*148c5f43SAlan Wright int 1061*148c5f43SAlan Wright smb_server_share(void *arg, boolean_t add_share) 1062*148c5f43SAlan Wright { 1063*148c5f43SAlan Wright smb_server_t *sv; 1064*148c5f43SAlan Wright int rc; 1065*148c5f43SAlan Wright 1066*148c5f43SAlan Wright if ((rc = smb_server_lookup(&sv)) == 0) { 1067*148c5f43SAlan Wright mutex_enter(&sv->sv_mutex); 1068*148c5f43SAlan Wright switch (sv->sv_state) { 1069*148c5f43SAlan Wright case SMB_SERVER_STATE_RUNNING: 1070*148c5f43SAlan Wright mutex_exit(&sv->sv_mutex); 1071*148c5f43SAlan Wright (void) smb_kshare_upcall(sv->sv_lmshrd, arg, add_share); 1072*148c5f43SAlan Wright break; 1073*148c5f43SAlan Wright default: 1074*148c5f43SAlan Wright mutex_exit(&sv->sv_mutex); 1075*148c5f43SAlan Wright break; 1076*148c5f43SAlan Wright } 1077*148c5f43SAlan Wright smb_server_release(sv); 1078*148c5f43SAlan Wright } 1079*148c5f43SAlan Wright 1080*148c5f43SAlan Wright return (rc); 1081*148c5f43SAlan Wright } 1082*148c5f43SAlan Wright 1083*148c5f43SAlan Wright int 1084*148c5f43SAlan Wright smb_server_unshare(const char *sharename) 1085*148c5f43SAlan Wright { 1086*148c5f43SAlan Wright smb_server_t *sv; 1087*148c5f43SAlan Wright smb_session_list_t *slist; 1088*148c5f43SAlan Wright int rc; 1089*148c5f43SAlan Wright 1090*148c5f43SAlan Wright if ((rc = smb_server_lookup(&sv))) 1091*148c5f43SAlan Wright return (rc); 1092*148c5f43SAlan Wright 1093*148c5f43SAlan Wright mutex_enter(&sv->sv_mutex); 1094*148c5f43SAlan Wright switch (sv->sv_state) { 1095*148c5f43SAlan Wright case SMB_SERVER_STATE_RUNNING: 1096*148c5f43SAlan Wright case SMB_SERVER_STATE_STOPPING: 1097*148c5f43SAlan Wright break; 1098*148c5f43SAlan Wright default: 1099*148c5f43SAlan Wright mutex_exit(&sv->sv_mutex); 1100*148c5f43SAlan Wright smb_server_release(sv); 1101*148c5f43SAlan Wright return (ENOTACTIVE); 1102*148c5f43SAlan Wright } 1103*148c5f43SAlan Wright mutex_exit(&sv->sv_mutex); 1104*148c5f43SAlan Wright 1105*148c5f43SAlan Wright slist = &sv->sv_nbt_daemon.ld_session_list; 1106*148c5f43SAlan Wright smb_server_disconnect_share(slist, sharename); 1107*148c5f43SAlan Wright 1108*148c5f43SAlan Wright slist = &sv->sv_tcp_daemon.ld_session_list; 1109*148c5f43SAlan Wright smb_server_disconnect_share(slist, sharename); 1110*148c5f43SAlan Wright 1111*148c5f43SAlan Wright smb_server_release(sv); 1112*148c5f43SAlan Wright return (0); 1113*148c5f43SAlan Wright } 1114*148c5f43SAlan Wright 1115*148c5f43SAlan Wright /* 11169fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * Disconnect the specified share. 11179fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * Typically called when a share has been removed. 1118faa1795aSjb150015 */ 11192c1b14e5Sjose borrego static void 11209fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_disconnect_share(smb_session_list_t *slist, const char *sharename) 1121faa1795aSjb150015 { 11229fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_session_t *session; 11239fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 11249fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States rw_enter(&slist->se_lock, RW_READER); 11259fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 11269fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States session = list_head(&slist->se_act.lst); 11279fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States while (session) { 11289fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States ASSERT(session->s_magic == SMB_SESSION_MAGIC); 11299fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_rwx_rwenter(&session->s_lock, RW_READER); 11309fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States switch (session->s_state) { 11319fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States case SMB_SESSION_STATE_NEGOTIATED: 11329fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States case SMB_SESSION_STATE_OPLOCK_BREAKING: 11339fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States case SMB_SESSION_STATE_WRITE_RAW_ACTIVE: 11349fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_session_disconnect_share(session, sharename); 11359fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 11369fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States default: 11379fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 11389fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 11399fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_rwx_rwexit(&session->s_lock); 11409fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States session = list_next(&slist->se_act.lst, session); 11419fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 11429fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 11439fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States rw_exit(&slist->se_lock); 1144faa1795aSjb150015 } 1145faa1795aSjb150015 1146faa1795aSjb150015 /* 1147faa1795aSjb150015 * ***************************************************************************** 1148faa1795aSjb150015 * **************** Functions called from the internal layers ****************** 1149faa1795aSjb150015 * ***************************************************************************** 1150faa1795aSjb150015 * 1151faa1795aSjb150015 * These functions are provided the relevant smb server by the caller. 1152faa1795aSjb150015 */ 1153faa1795aSjb150015 1154faa1795aSjb150015 void 1155faa1795aSjb150015 smb_server_reconnection_check(smb_server_t *sv, smb_session_t *session) 1156faa1795aSjb150015 { 1157faa1795aSjb150015 ASSERT(sv == session->s_server); 1158faa1795aSjb150015 1159faa1795aSjb150015 smb_session_reconnection_check(&sv->sv_nbt_daemon.ld_session_list, 1160faa1795aSjb150015 session); 1161faa1795aSjb150015 smb_session_reconnection_check(&sv->sv_tcp_daemon.ld_session_list, 1162faa1795aSjb150015 session); 1163faa1795aSjb150015 } 1164faa1795aSjb150015 1165faa1795aSjb150015 void 1166faa1795aSjb150015 smb_server_get_cfg(smb_server_t *sv, smb_kmod_cfg_t *cfg) 1167faa1795aSjb150015 { 1168faa1795aSjb150015 rw_enter(&sv->sv_cfg_lock, RW_READER); 1169faa1795aSjb150015 bcopy(&sv->sv_cfg, cfg, sizeof (*cfg)); 1170faa1795aSjb150015 rw_exit(&sv->sv_cfg_lock); 1171faa1795aSjb150015 } 1172faa1795aSjb150015 1173faa1795aSjb150015 /* 1174*148c5f43SAlan Wright * 1175*148c5f43SAlan Wright */ 1176*148c5f43SAlan Wright void 1177*148c5f43SAlan Wright smb_server_inc_nbt_sess(smb_server_t *sv) 1178*148c5f43SAlan Wright { 1179*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1180*148c5f43SAlan Wright atomic_inc_32(&sv->sv_nbt_sess); 1181*148c5f43SAlan Wright } 1182*148c5f43SAlan Wright 1183*148c5f43SAlan Wright void 1184*148c5f43SAlan Wright smb_server_dec_nbt_sess(smb_server_t *sv) 1185*148c5f43SAlan Wright { 1186*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1187*148c5f43SAlan Wright atomic_dec_32(&sv->sv_nbt_sess); 1188*148c5f43SAlan Wright } 1189*148c5f43SAlan Wright 1190*148c5f43SAlan Wright void 1191*148c5f43SAlan Wright smb_server_inc_tcp_sess(smb_server_t *sv) 1192*148c5f43SAlan Wright { 1193*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1194*148c5f43SAlan Wright atomic_inc_32(&sv->sv_tcp_sess); 1195*148c5f43SAlan Wright } 1196*148c5f43SAlan Wright 1197*148c5f43SAlan Wright void 1198*148c5f43SAlan Wright smb_server_dec_tcp_sess(smb_server_t *sv) 1199*148c5f43SAlan Wright { 1200*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1201*148c5f43SAlan Wright atomic_dec_32(&sv->sv_tcp_sess); 1202*148c5f43SAlan Wright } 1203*148c5f43SAlan Wright 1204*148c5f43SAlan Wright void 1205*148c5f43SAlan Wright smb_server_inc_users(smb_server_t *sv) 1206*148c5f43SAlan Wright { 1207*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1208*148c5f43SAlan Wright atomic_inc_32(&sv->sv_users); 1209*148c5f43SAlan Wright } 1210*148c5f43SAlan Wright 1211*148c5f43SAlan Wright void 1212*148c5f43SAlan Wright smb_server_dec_users(smb_server_t *sv) 1213*148c5f43SAlan Wright { 1214*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1215*148c5f43SAlan Wright atomic_dec_32(&sv->sv_users); 1216*148c5f43SAlan Wright } 1217*148c5f43SAlan Wright 1218*148c5f43SAlan Wright void 1219*148c5f43SAlan Wright smb_server_inc_trees(smb_server_t *sv) 1220*148c5f43SAlan Wright { 1221*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1222*148c5f43SAlan Wright atomic_inc_32(&sv->sv_trees); 1223*148c5f43SAlan Wright } 1224*148c5f43SAlan Wright 1225*148c5f43SAlan Wright void 1226*148c5f43SAlan Wright smb_server_dec_trees(smb_server_t *sv) 1227*148c5f43SAlan Wright { 1228*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1229*148c5f43SAlan Wright atomic_dec_32(&sv->sv_trees); 1230*148c5f43SAlan Wright } 1231*148c5f43SAlan Wright 1232*148c5f43SAlan Wright void 1233*148c5f43SAlan Wright smb_server_inc_files(smb_server_t *sv) 1234*148c5f43SAlan Wright { 1235*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1236*148c5f43SAlan Wright atomic_inc_32(&sv->sv_files); 1237*148c5f43SAlan Wright } 1238*148c5f43SAlan Wright 1239*148c5f43SAlan Wright void 1240*148c5f43SAlan Wright smb_server_dec_files(smb_server_t *sv) 1241*148c5f43SAlan Wright { 1242*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1243*148c5f43SAlan Wright atomic_dec_32(&sv->sv_files); 1244*148c5f43SAlan Wright } 1245*148c5f43SAlan Wright 1246*148c5f43SAlan Wright void 1247*148c5f43SAlan Wright smb_server_inc_pipes(smb_server_t *sv) 1248*148c5f43SAlan Wright { 1249*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1250*148c5f43SAlan Wright atomic_inc_32(&sv->sv_pipes); 1251*148c5f43SAlan Wright } 1252*148c5f43SAlan Wright 1253*148c5f43SAlan Wright void 1254*148c5f43SAlan Wright smb_server_dec_pipes(smb_server_t *sv) 1255*148c5f43SAlan Wright { 1256*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1257*148c5f43SAlan Wright atomic_dec_32(&sv->sv_pipes); 1258*148c5f43SAlan Wright } 1259*148c5f43SAlan Wright 1260*148c5f43SAlan Wright void 1261*148c5f43SAlan Wright smb_server_add_rxb(smb_server_t *sv, int64_t value) 1262*148c5f43SAlan Wright { 1263*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1264*148c5f43SAlan Wright atomic_add_64(&sv->sv_rxb, value); 1265*148c5f43SAlan Wright } 1266*148c5f43SAlan Wright 1267*148c5f43SAlan Wright void 1268*148c5f43SAlan Wright smb_server_add_txb(smb_server_t *sv, int64_t value) 1269*148c5f43SAlan Wright { 1270*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1271*148c5f43SAlan Wright atomic_add_64(&sv->sv_txb, value); 1272*148c5f43SAlan Wright } 1273*148c5f43SAlan Wright 1274*148c5f43SAlan Wright void 1275*148c5f43SAlan Wright smb_server_inc_req(smb_server_t *sv) 1276*148c5f43SAlan Wright { 1277*148c5f43SAlan Wright SMB_SERVER_VALID(sv); 1278*148c5f43SAlan Wright atomic_inc_64(&sv->sv_nreq); 1279*148c5f43SAlan Wright } 1280*148c5f43SAlan Wright 1281*148c5f43SAlan Wright /* 1282faa1795aSjb150015 * ***************************************************************************** 1283faa1795aSjb150015 * *************************** Static Functions ******************************** 1284faa1795aSjb150015 * ***************************************************************************** 1285faa1795aSjb150015 */ 1286faa1795aSjb150015 1287faa1795aSjb150015 static void 1288faa1795aSjb150015 smb_server_timers(smb_thread_t *thread, void *arg) 1289faa1795aSjb150015 { 1290faa1795aSjb150015 smb_server_t *sv = (smb_server_t *)arg; 1291faa1795aSjb150015 1292faa1795aSjb150015 ASSERT(sv != NULL); 1293faa1795aSjb150015 1294faa1795aSjb150015 while (smb_thread_continue_timedwait(thread, 1 /* Seconds */)) { 1295faa1795aSjb150015 smb_session_timers(&sv->sv_nbt_daemon.ld_session_list); 1296faa1795aSjb150015 smb_session_timers(&sv->sv_tcp_daemon.ld_session_list); 1297faa1795aSjb150015 } 1298faa1795aSjb150015 } 1299faa1795aSjb150015 1300faa1795aSjb150015 /* 1301faa1795aSjb150015 * smb_server_kstat_init 1302faa1795aSjb150015 */ 1303*148c5f43SAlan Wright static void 1304faa1795aSjb150015 smb_server_kstat_init(smb_server_t *sv) 1305faa1795aSjb150015 { 1306*148c5f43SAlan Wright sv->sv_ksp = kstat_create_zone(SMBSRV_KSTAT_MODULE, sv->sv_zid, 1307*148c5f43SAlan Wright SMBSRV_KSTAT_STATISTICS, SMBSRV_KSTAT_CLASS, KSTAT_TYPE_RAW, 1308*148c5f43SAlan Wright sizeof (smbsrv_kstats_t), 0, sv->sv_zid); 1309faa1795aSjb150015 1310*148c5f43SAlan Wright if (sv->sv_ksp != NULL) { 1311*148c5f43SAlan Wright sv->sv_ksp->ks_update = smb_server_kstat_update; 1312*148c5f43SAlan Wright sv->sv_ksp->ks_private = sv; 1313*148c5f43SAlan Wright ((smbsrv_kstats_t *)sv->sv_ksp->ks_data)->ks_start_time = 1314*148c5f43SAlan Wright sv->sv_start_time; 1315*148c5f43SAlan Wright smb_dispatch_stats_init( 1316*148c5f43SAlan Wright ((smbsrv_kstats_t *)sv->sv_ksp->ks_data)->ks_reqs); 1317faa1795aSjb150015 kstat_install(sv->sv_ksp); 1318*148c5f43SAlan Wright } else { 1319*148c5f43SAlan Wright cmn_err(CE_WARN, "SMB Server: Statistics unavailable"); 1320faa1795aSjb150015 } 1321faa1795aSjb150015 } 1322faa1795aSjb150015 1323faa1795aSjb150015 /* 1324faa1795aSjb150015 * smb_server_kstat_fini 1325faa1795aSjb150015 */ 1326faa1795aSjb150015 static void 1327faa1795aSjb150015 smb_server_kstat_fini(smb_server_t *sv) 1328faa1795aSjb150015 { 1329*148c5f43SAlan Wright if (sv->sv_ksp != NULL) { 1330faa1795aSjb150015 kstat_delete(sv->sv_ksp); 1331faa1795aSjb150015 sv->sv_ksp = NULL; 1332*148c5f43SAlan Wright smb_dispatch_stats_fini(); 1333faa1795aSjb150015 } 1334faa1795aSjb150015 } 1335faa1795aSjb150015 1336*148c5f43SAlan Wright /* 1337*148c5f43SAlan Wright * smb_server_kstat_update 1338*148c5f43SAlan Wright */ 1339faa1795aSjb150015 static int 1340*148c5f43SAlan Wright smb_server_kstat_update(kstat_t *ksp, int rw) 1341faa1795aSjb150015 { 1342faa1795aSjb150015 smb_server_t *sv; 1343*148c5f43SAlan Wright smbsrv_kstats_t *ksd; 1344faa1795aSjb150015 1345*148c5f43SAlan Wright if (rw == KSTAT_READ) { 1346*148c5f43SAlan Wright sv = ksp->ks_private; 13479fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_VALID(sv); 1348*148c5f43SAlan Wright ksd = (smbsrv_kstats_t *)ksp->ks_data; 1349*148c5f43SAlan Wright /* 1350*148c5f43SAlan Wright * Counters 1351*148c5f43SAlan Wright */ 1352*148c5f43SAlan Wright ksd->ks_nbt_sess = sv->sv_nbt_sess; 1353*148c5f43SAlan Wright ksd->ks_tcp_sess = sv->sv_tcp_sess; 1354*148c5f43SAlan Wright ksd->ks_users = sv->sv_users; 1355*148c5f43SAlan Wright ksd->ks_trees = sv->sv_trees; 1356*148c5f43SAlan Wright ksd->ks_files = sv->sv_files; 1357*148c5f43SAlan Wright ksd->ks_pipes = sv->sv_pipes; 1358*148c5f43SAlan Wright /* 1359*148c5f43SAlan Wright * Throughput 1360*148c5f43SAlan Wright */ 1361*148c5f43SAlan Wright ksd->ks_txb = sv->sv_txb; 1362*148c5f43SAlan Wright ksd->ks_rxb = sv->sv_rxb; 1363*148c5f43SAlan Wright ksd->ks_nreq = sv->sv_nreq; 1364*148c5f43SAlan Wright /* 1365*148c5f43SAlan Wright * Busyness 1366*148c5f43SAlan Wright */ 1367*148c5f43SAlan Wright ksd->ks_maxreqs = sv->sv_cfg.skc_maxworkers; 1368*148c5f43SAlan Wright smb_srqueue_update(&sv->sv_srqueue, 1369*148c5f43SAlan Wright &ksd->ks_utilization); 1370*148c5f43SAlan Wright /* 1371*148c5f43SAlan Wright * Latency & Throughput of the requests 1372*148c5f43SAlan Wright */ 1373*148c5f43SAlan Wright smb_dispatch_stats_update(ksd->ks_reqs, 0, SMB_COM_NUM); 1374faa1795aSjb150015 return (0); 1375faa1795aSjb150015 } 1376*148c5f43SAlan Wright if (rw == KSTAT_WRITE) 1377*148c5f43SAlan Wright return (EACCES); 1378*148c5f43SAlan Wright 1379*148c5f43SAlan Wright return (EIO); 1380*148c5f43SAlan Wright } 1381faa1795aSjb150015 1382faa1795aSjb150015 /* 1383faa1795aSjb150015 * The mutex of the server must have been entered before calling this function. 1384faa1795aSjb150015 */ 1385faa1795aSjb150015 static void 13869fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_shutdown(smb_server_t *sv) 1387faa1795aSjb150015 { 13889fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_VALID(sv); 1389faa1795aSjb150015 13903db3f65cSamw smb_opipe_door_close(); 1391faa1795aSjb150015 smb_thread_stop(&sv->si_thread_timers); 13929fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_kdoor_close(); 1393*148c5f43SAlan Wright smb_kshare_door_fini(sv->sv_lmshrd); 13940dcb3379Sjb150015 sv->sv_lmshrd = NULL; 1395*148c5f43SAlan Wright smb_export_stop(); 1396faa1795aSjb150015 smb_server_fsop_stop(sv); 13978d96b23eSAlan Wright 1398faa1795aSjb150015 if (sv->sv_session) { 1399faa1795aSjb150015 smb_session_delete(sv->sv_session); 1400faa1795aSjb150015 sv->sv_session = NULL; 1401faa1795aSjb150015 } 14028d96b23eSAlan Wright 14038d96b23eSAlan Wright if (sv->sv_thread_pool) { 14048d96b23eSAlan Wright taskq_destroy(sv->sv_thread_pool); 14058d96b23eSAlan Wright sv->sv_thread_pool = NULL; 14068d96b23eSAlan Wright } 1407faa1795aSjb150015 } 1408faa1795aSjb150015 1409faa1795aSjb150015 static int 1410faa1795aSjb150015 smb_server_listen( 1411faa1795aSjb150015 smb_server_t *sv, 1412faa1795aSjb150015 smb_listener_daemon_t *ld, 1413faa1795aSjb150015 in_port_t port, 14147f667e74Sjose borrego int family, 1415faa1795aSjb150015 int pthread_create_error) 1416faa1795aSjb150015 { 14179fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States int rc = 0; 14180f1702c5SYu Xiangning ksocket_t s_so; 14199fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States uint32_t on; 14209fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States uint32_t off; 14219fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States uint32_t txbuf_size; 1422faa1795aSjb150015 smb_session_t *session; 1423faa1795aSjb150015 1424faa1795aSjb150015 if (pthread_create_error) { 1425faa1795aSjb150015 /* 1426faa1795aSjb150015 * Delete the last session created. The user space thread 1427faa1795aSjb150015 * creation failed. 1428faa1795aSjb150015 */ 1429faa1795aSjb150015 smb_session_list_delete_tail(&ld->ld_session_list); 1430faa1795aSjb150015 } 1431faa1795aSjb150015 1432faa1795aSjb150015 if (ld->ld_so == NULL) { 1433faa1795aSjb150015 /* First time listener */ 14347f667e74Sjose borrego if (family == AF_INET) { 14357f667e74Sjose borrego ld->ld_sin.sin_family = (uint32_t)family; 1436faa1795aSjb150015 ld->ld_sin.sin_port = htons(port); 1437faa1795aSjb150015 ld->ld_sin.sin_addr.s_addr = htonl(INADDR_ANY); 14387f667e74Sjose borrego } else { 14397f667e74Sjose borrego ld->ld_sin6.sin6_family = (uint32_t)family; 14407f667e74Sjose borrego ld->ld_sin6.sin6_port = htons(port); 14417f667e74Sjose borrego (void) memset(&ld->ld_sin6.sin6_addr.s6_addr, 0, 14427f667e74Sjose borrego sizeof (ld->ld_sin6.sin6_addr.s6_addr)); 14437f667e74Sjose borrego } 1444faa1795aSjb150015 14459fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States ld->ld_so = smb_socreate(family, SOCK_STREAM, 0); 14469fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (ld->ld_so == NULL) { 14479fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cmn_err(CE_WARN, "port %d: socket create failed", port); 14489fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (ENOMEM); 14499fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 14509fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 14519fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States off = 0; 14520f1702c5SYu Xiangning (void) ksocket_setsockopt(ld->ld_so, SOL_SOCKET, 1453fc724630SAlan Wright SO_MAC_EXEMPT, &off, sizeof (off), CRED()); 14549fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 14559fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States on = 1; 1456fc724630SAlan Wright (void) ksocket_setsockopt(ld->ld_so, SOL_SOCKET, 1457fc724630SAlan Wright SO_REUSEADDR, &on, sizeof (on), CRED()); 1458fc724630SAlan Wright 14597f667e74Sjose borrego if (family == AF_INET) { 14600f1702c5SYu Xiangning rc = ksocket_bind(ld->ld_so, 14610f1702c5SYu Xiangning (struct sockaddr *)&ld->ld_sin, 14620f1702c5SYu Xiangning sizeof (ld->ld_sin), CRED()); 14637f667e74Sjose borrego } else { 14647f667e74Sjose borrego rc = ksocket_bind(ld->ld_so, 14657f667e74Sjose borrego (struct sockaddr *)&ld->ld_sin6, 14667f667e74Sjose borrego sizeof (ld->ld_sin6), CRED()); 14677f667e74Sjose borrego } 14689fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 14699fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (rc != 0) { 14709fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cmn_err(CE_WARN, "port %d: bind failed (%d)", port, rc); 14719fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_listen_fini(ld); 14729fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (rc); 14739fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 14749fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 14750f1702c5SYu Xiangning rc = ksocket_listen(ld->ld_so, 20, CRED()); 1476faa1795aSjb150015 if (rc < 0) { 14779fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cmn_err(CE_WARN, "port %d: listen failed", port); 14789fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_listen_fini(ld); 1479faa1795aSjb150015 return (rc); 1480faa1795aSjb150015 } 1481faa1795aSjb150015 } 1482faa1795aSjb150015 1483faa1795aSjb150015 DTRACE_PROBE1(so__wait__accept, struct sonode *, ld->ld_so); 1484faa1795aSjb150015 1485faa1795aSjb150015 for (;;) { 14869fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (smb_server_is_stopping()) { 14879fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States rc = ECANCELED; 14889fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 14899fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 14909fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 14910f1702c5SYu Xiangning rc = ksocket_accept(ld->ld_so, NULL, NULL, &s_so, CRED()); 14929fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (rc != 0) 14939fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 14949fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 14959fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (smb_server_is_stopping()) { 14969fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_soshutdown(s_so); 14979fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_sodestroy(s_so); 14989fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States rc = ECANCELED; 14999fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 15009fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 1501faa1795aSjb150015 1502faa1795aSjb150015 DTRACE_PROBE1(so__accept, struct sonode *, s_so); 1503faa1795aSjb150015 15049fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States on = 1; 15059fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States (void) ksocket_setsockopt(s_so, IPPROTO_TCP, TCP_NODELAY, 15069fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States &on, sizeof (on), CRED()); 15079fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 15089fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States on = 1; 15099fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States (void) ksocket_setsockopt(s_so, SOL_SOCKET, SO_KEEPALIVE, 15109fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States &on, sizeof (on), CRED()); 15119fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 15129fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States txbuf_size = 128*1024; 15130f1702c5SYu Xiangning (void) ksocket_setsockopt(s_so, SOL_SOCKET, SO_SNDBUF, 15149fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States (const void *)&txbuf_size, sizeof (txbuf_size), CRED()); 15159fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 1516faa1795aSjb150015 /* 1517faa1795aSjb150015 * Create a session for this connection. 1518faa1795aSjb150015 */ 15197f667e74Sjose borrego session = smb_session_create(s_so, port, sv, family); 1520faa1795aSjb150015 if (session) { 15219fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_session_list_append(&ld->ld_session_list, session); 15229fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States rc = 0; 1523faa1795aSjb150015 break; 1524faa1795aSjb150015 } else { 1525faa1795aSjb150015 smb_soshutdown(s_so); 1526faa1795aSjb150015 smb_sodestroy(s_so); 1527faa1795aSjb150015 } 1528faa1795aSjb150015 } 15299fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 15309fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (rc != 0) 15319fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_listen_fini(ld); 15329fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 15339fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (rc); 15349fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 15359fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 15369fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static void 15379fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_listen_fini(smb_listener_daemon_t *ld) 15389fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 15399fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (ld->ld_so != NULL) { 1540faa1795aSjb150015 smb_session_list_signal(&ld->ld_session_list); 1541faa1795aSjb150015 smb_soshutdown(ld->ld_so); 1542faa1795aSjb150015 smb_sodestroy(ld->ld_so); 1543faa1795aSjb150015 ld->ld_so = NULL; 15449fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 1545faa1795aSjb150015 } 1546faa1795aSjb150015 15479fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static kt_did_t 15489fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_listener_tid(smb_listener_daemon_t *ld) 15499fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 15509fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States kt_did_t tid; 15519fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 15529fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (ld->ld_ktdid != 0) { 15539fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States tid = ld->ld_ktdid; 15549fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States ld->ld_ktdid = 0; 15559fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 15569fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 15579fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (tid); 1558faa1795aSjb150015 } 1559faa1795aSjb150015 1560faa1795aSjb150015 /* 1561faa1795aSjb150015 * smb_server_lookup 1562faa1795aSjb150015 * 1563faa1795aSjb150015 * This function tries to find the server associated with the zone of the 1564faa1795aSjb150015 * caller. 1565faa1795aSjb150015 */ 1566faa1795aSjb150015 static int 1567faa1795aSjb150015 smb_server_lookup(smb_server_t **psv) 1568faa1795aSjb150015 { 1569faa1795aSjb150015 zoneid_t zid; 1570faa1795aSjb150015 smb_server_t *sv; 1571faa1795aSjb150015 1572faa1795aSjb150015 zid = getzoneid(); 1573faa1795aSjb150015 1574faa1795aSjb150015 smb_llist_enter(&smb_servers, RW_READER); 1575faa1795aSjb150015 sv = smb_llist_head(&smb_servers); 1576faa1795aSjb150015 while (sv) { 15779fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_VALID(sv); 1578faa1795aSjb150015 if (sv->sv_zid == zid) { 1579faa1795aSjb150015 mutex_enter(&sv->sv_mutex); 1580faa1795aSjb150015 if (sv->sv_state != SMB_SERVER_STATE_DELETING) { 1581faa1795aSjb150015 sv->sv_refcnt++; 1582faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 1583faa1795aSjb150015 smb_llist_exit(&smb_servers); 1584faa1795aSjb150015 *psv = sv; 1585faa1795aSjb150015 return (0); 1586faa1795aSjb150015 } 1587faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 1588faa1795aSjb150015 break; 1589faa1795aSjb150015 } 1590faa1795aSjb150015 sv = smb_llist_next(&smb_servers, sv); 1591faa1795aSjb150015 } 1592faa1795aSjb150015 smb_llist_exit(&smb_servers); 1593faa1795aSjb150015 return (EPERM); 1594faa1795aSjb150015 } 1595faa1795aSjb150015 1596faa1795aSjb150015 /* 1597faa1795aSjb150015 * smb_server_release 1598faa1795aSjb150015 * 1599faa1795aSjb150015 * This function decrements the reference count of the server and signals its 1600faa1795aSjb150015 * condition variable if the state of the server is SMB_SERVER_STATE_DELETING. 1601faa1795aSjb150015 */ 1602faa1795aSjb150015 static void 1603faa1795aSjb150015 smb_server_release(smb_server_t *sv) 1604faa1795aSjb150015 { 16059fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_VALID(sv); 1606faa1795aSjb150015 1607faa1795aSjb150015 mutex_enter(&sv->sv_mutex); 1608faa1795aSjb150015 ASSERT(sv->sv_refcnt); 1609faa1795aSjb150015 sv->sv_refcnt--; 1610faa1795aSjb150015 if ((sv->sv_refcnt == 0) && (sv->sv_state == SMB_SERVER_STATE_DELETING)) 1611faa1795aSjb150015 cv_signal(&sv->sv_cv); 1612faa1795aSjb150015 mutex_exit(&sv->sv_mutex); 1613faa1795aSjb150015 } 1614faa1795aSjb150015 16151fcced4cSJordan Brown /* 16161fcced4cSJordan Brown * Enumerate the users associated with a session list. 16171fcced4cSJordan Brown */ 16181fcced4cSJordan Brown static void 16191fcced4cSJordan Brown smb_server_enum_private(smb_session_list_t *se, smb_svcenum_t *svcenum) 1620faa1795aSjb150015 { 16211fcced4cSJordan Brown smb_session_t *sn; 1622faa1795aSjb150015 smb_llist_t *ulist; 16231fcced4cSJordan Brown smb_user_t *user; 162429bd2886SAlan Wright int rc = 0; 1625faa1795aSjb150015 1626faa1795aSjb150015 rw_enter(&se->se_lock, RW_READER); 1627faa1795aSjb150015 sn = list_head(&se->se_act.lst); 16281fcced4cSJordan Brown 16291fcced4cSJordan Brown while (sn != NULL) { 1630faa1795aSjb150015 ASSERT(sn->s_magic == SMB_SESSION_MAGIC); 1631faa1795aSjb150015 ulist = &sn->s_user_list; 1632faa1795aSjb150015 smb_llist_enter(ulist, RW_READER); 1633faa1795aSjb150015 user = smb_llist_head(ulist); 16341fcced4cSJordan Brown 16351fcced4cSJordan Brown while (user != NULL) { 16361fcced4cSJordan Brown if (smb_user_hold(user)) { 16371fcced4cSJordan Brown rc = smb_user_enum(user, svcenum); 16381fcced4cSJordan Brown smb_user_release(user); 1639faa1795aSjb150015 } 16401fcced4cSJordan Brown 1641faa1795aSjb150015 user = smb_llist_next(ulist, user); 1642faa1795aSjb150015 } 16431fcced4cSJordan Brown 16441fcced4cSJordan Brown smb_llist_exit(ulist); 16451fcced4cSJordan Brown 16461fcced4cSJordan Brown if (rc != 0) 16471fcced4cSJordan Brown break; 16481fcced4cSJordan Brown 16491fcced4cSJordan Brown sn = list_next(&se->se_act.lst, sn); 16501fcced4cSJordan Brown } 16511fcced4cSJordan Brown 16521fcced4cSJordan Brown rw_exit(&se->se_lock); 16531fcced4cSJordan Brown } 16541fcced4cSJordan Brown 16551fcced4cSJordan Brown /* 16561fcced4cSJordan Brown * Disconnect sessions associated with the specified client and username. 16571fcced4cSJordan Brown * Empty strings are treated as wildcards. 16581fcced4cSJordan Brown */ 16591fcced4cSJordan Brown static int 16601fcced4cSJordan Brown smb_server_sesion_disconnect(smb_session_list_t *se, 16611fcced4cSJordan Brown const char *client, const char *name) 16621fcced4cSJordan Brown { 16631fcced4cSJordan Brown smb_session_t *sn; 16641fcced4cSJordan Brown smb_llist_t *ulist; 16651fcced4cSJordan Brown smb_user_t *user; 16661fcced4cSJordan Brown boolean_t match; 16671fcced4cSJordan Brown int count = 0; 16681fcced4cSJordan Brown 16691fcced4cSJordan Brown rw_enter(&se->se_lock, RW_READER); 16701fcced4cSJordan Brown sn = list_head(&se->se_act.lst); 16711fcced4cSJordan Brown 16721fcced4cSJordan Brown while (sn != NULL) { 16731fcced4cSJordan Brown ASSERT(sn->s_magic == SMB_SESSION_MAGIC); 16741fcced4cSJordan Brown 16751fcced4cSJordan Brown if ((*client != '\0') && (!smb_session_isclient(sn, client))) { 16761fcced4cSJordan Brown sn = list_next(&se->se_act.lst, sn); 16771fcced4cSJordan Brown continue; 16781fcced4cSJordan Brown } 16791fcced4cSJordan Brown 16801fcced4cSJordan Brown ulist = &sn->s_user_list; 16811fcced4cSJordan Brown smb_llist_enter(ulist, RW_READER); 16821fcced4cSJordan Brown user = smb_llist_head(ulist); 16831fcced4cSJordan Brown 16841fcced4cSJordan Brown while (user != NULL) { 16851fcced4cSJordan Brown if (smb_user_hold(user)) { 16861fcced4cSJordan Brown match = (*name == '\0'); 16871fcced4cSJordan Brown if (!match) 16881fcced4cSJordan Brown match = smb_user_namecmp(user, name); 16891fcced4cSJordan Brown 16901fcced4cSJordan Brown if (match) { 16911fcced4cSJordan Brown smb_llist_exit(ulist); 16921fcced4cSJordan Brown smb_user_logoff(user); 16931fcced4cSJordan Brown ++count; 16941fcced4cSJordan Brown smb_user_release(user); 16951fcced4cSJordan Brown smb_llist_enter(ulist, RW_READER); 16961fcced4cSJordan Brown user = smb_llist_head(ulist); 16971fcced4cSJordan Brown continue; 16981fcced4cSJordan Brown } 16991fcced4cSJordan Brown 17001fcced4cSJordan Brown smb_user_release(user); 17011fcced4cSJordan Brown } 17021fcced4cSJordan Brown 17031fcced4cSJordan Brown user = smb_llist_next(ulist, user); 17041fcced4cSJordan Brown } 17051fcced4cSJordan Brown 1706faa1795aSjb150015 smb_llist_exit(ulist); 1707b89a8333Snatalie li - Sun Microsystems - Irvine United States sn = list_next(&se->se_act.lst, sn); 1708faa1795aSjb150015 } 17091fcced4cSJordan Brown 1710faa1795aSjb150015 rw_exit(&se->se_lock); 17111fcced4cSJordan Brown return (count); 17121fcced4cSJordan Brown } 17131fcced4cSJordan Brown 17141fcced4cSJordan Brown /* 17151fcced4cSJordan Brown * Close a file by its unique id. 17161fcced4cSJordan Brown */ 17171fcced4cSJordan Brown static int 17181fcced4cSJordan Brown smb_server_fclose(smb_session_list_t *se, uint32_t uniqid) 17191fcced4cSJordan Brown { 17201fcced4cSJordan Brown smb_session_t *sn; 17211fcced4cSJordan Brown smb_llist_t *ulist; 17221fcced4cSJordan Brown smb_user_t *user; 17231fcced4cSJordan Brown int rc = ENOENT; 17241fcced4cSJordan Brown 17251fcced4cSJordan Brown rw_enter(&se->se_lock, RW_READER); 17261fcced4cSJordan Brown sn = list_head(&se->se_act.lst); 17271fcced4cSJordan Brown 17281fcced4cSJordan Brown while ((sn != NULL) && (rc == ENOENT)) { 17291fcced4cSJordan Brown ASSERT(sn->s_magic == SMB_SESSION_MAGIC); 17301fcced4cSJordan Brown ulist = &sn->s_user_list; 17311fcced4cSJordan Brown smb_llist_enter(ulist, RW_READER); 17321fcced4cSJordan Brown user = smb_llist_head(ulist); 17331fcced4cSJordan Brown 17341fcced4cSJordan Brown while ((user != NULL) && (rc == ENOENT)) { 17351fcced4cSJordan Brown if (smb_user_hold(user)) { 17361fcced4cSJordan Brown rc = smb_user_fclose(user, uniqid); 17371fcced4cSJordan Brown smb_user_release(user); 17381fcced4cSJordan Brown } 17391fcced4cSJordan Brown 17401fcced4cSJordan Brown user = smb_llist_next(ulist, user); 17411fcced4cSJordan Brown } 17421fcced4cSJordan Brown 17431fcced4cSJordan Brown smb_llist_exit(ulist); 17441fcced4cSJordan Brown sn = list_next(&se->se_act.lst, sn); 17451fcced4cSJordan Brown } 17461fcced4cSJordan Brown 17471fcced4cSJordan Brown rw_exit(&se->se_lock); 17481fcced4cSJordan Brown return (rc); 1749faa1795aSjb150015 } 1750faa1795aSjb150015 1751faa1795aSjb150015 static void 175229bd2886SAlan Wright smb_server_store_cfg(smb_server_t *sv, smb_ioc_cfg_t *ioc) 1753faa1795aSjb150015 { 175429bd2886SAlan Wright if (ioc->maxconnections == 0) 175529bd2886SAlan Wright ioc->maxconnections = 0xFFFFFFFF; 1756faa1795aSjb150015 1757faa1795aSjb150015 smb_session_correct_keep_alive_values( 175829bd2886SAlan Wright &sv->sv_nbt_daemon.ld_session_list, ioc->keepalive); 1759faa1795aSjb150015 smb_session_correct_keep_alive_values( 176029bd2886SAlan Wright &sv->sv_tcp_daemon.ld_session_list, ioc->keepalive); 1761faa1795aSjb150015 176229bd2886SAlan Wright sv->sv_cfg.skc_maxworkers = ioc->maxworkers; 176329bd2886SAlan Wright sv->sv_cfg.skc_maxconnections = ioc->maxconnections; 176429bd2886SAlan Wright sv->sv_cfg.skc_keepalive = ioc->keepalive; 176529bd2886SAlan Wright sv->sv_cfg.skc_restrict_anon = ioc->restrict_anon; 176629bd2886SAlan Wright sv->sv_cfg.skc_signing_enable = ioc->signing_enable; 176729bd2886SAlan Wright sv->sv_cfg.skc_signing_required = ioc->signing_required; 176829bd2886SAlan Wright sv->sv_cfg.skc_oplock_enable = ioc->oplock_enable; 176929bd2886SAlan Wright sv->sv_cfg.skc_sync_enable = ioc->sync_enable; 177029bd2886SAlan Wright sv->sv_cfg.skc_secmode = ioc->secmode; 177129bd2886SAlan Wright sv->sv_cfg.skc_ipv6_enable = ioc->ipv6_enable; 1772*148c5f43SAlan Wright sv->sv_cfg.skc_execflags = ioc->exec_flags; 1773*148c5f43SAlan Wright sv->sv_cfg.skc_version = ioc->version; 177429bd2886SAlan Wright (void) strlcpy(sv->sv_cfg.skc_nbdomain, ioc->nbdomain, 177529bd2886SAlan Wright sizeof (sv->sv_cfg.skc_nbdomain)); 177629bd2886SAlan Wright (void) strlcpy(sv->sv_cfg.skc_fqdn, ioc->fqdn, 177729bd2886SAlan Wright sizeof (sv->sv_cfg.skc_fqdn)); 177829bd2886SAlan Wright (void) strlcpy(sv->sv_cfg.skc_hostname, ioc->hostname, 177929bd2886SAlan Wright sizeof (sv->sv_cfg.skc_hostname)); 178029bd2886SAlan Wright (void) strlcpy(sv->sv_cfg.skc_system_comment, ioc->system_comment, 178129bd2886SAlan Wright sizeof (sv->sv_cfg.skc_system_comment)); 1782faa1795aSjb150015 } 1783faa1795aSjb150015 1784faa1795aSjb150015 static int 1785faa1795aSjb150015 smb_server_fsop_start(smb_server_t *sv) 1786faa1795aSjb150015 { 1787faa1795aSjb150015 int error; 1788faa1795aSjb150015 1789faa1795aSjb150015 error = smb_node_root_init(rootdir, sv, &sv->si_root_smb_node); 1790faa1795aSjb150015 if (error != 0) 1791faa1795aSjb150015 sv->si_root_smb_node = NULL; 1792faa1795aSjb150015 1793faa1795aSjb150015 return (error); 1794faa1795aSjb150015 } 1795faa1795aSjb150015 1796faa1795aSjb150015 static void 1797faa1795aSjb150015 smb_server_fsop_stop(smb_server_t *sv) 1798faa1795aSjb150015 { 1799faa1795aSjb150015 if (sv->si_root_smb_node != NULL) { 1800faa1795aSjb150015 smb_node_release(sv->si_root_smb_node); 1801faa1795aSjb150015 sv->si_root_smb_node = NULL; 1802faa1795aSjb150015 } 1803faa1795aSjb150015 } 18049fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18059fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static void 18069fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_signal_listeners(smb_server_t *sv) 18079fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 18089fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_VALID(sv); 18099fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States ASSERT(sv->sv_state == SMB_SERVER_STATE_STOPPING); 18109fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States ASSERT(MUTEX_HELD(&sv->sv_mutex)); 18119fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18129fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_cancel(sv, 0); 18139fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18149fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (sv->sv_nbt_daemon.ld_kth != NULL) { 18159fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States tsignal(sv->sv_nbt_daemon.ld_kth, SIGINT); 18169fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States sv->sv_nbt_daemon.ld_kth = NULL; 18179fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 18189fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18199fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (sv->sv_tcp_daemon.ld_kth != NULL) { 18209fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States tsignal(sv->sv_tcp_daemon.ld_kth, SIGINT); 18219fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States sv->sv_tcp_daemon.ld_kth = NULL; 18229fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 18239fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 18249fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18259fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_t * 18269fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_create(void) 18279fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 18289fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_t *sv; 18299fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_t *event; 18309fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18319fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (smb_server_is_stopping()) 18329fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (NULL); 18339fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18349fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (smb_server_lookup(&sv) != 0) { 18359fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cmn_err(CE_NOTE, "smb_event_create failed"); 18369fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (NULL); 18379fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 18389fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18399fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event = kmem_cache_alloc(sv->si_cache_event, KM_SLEEP); 18409fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18419fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States bzero(event, sizeof (smb_event_t)); 18429fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_init(&event->se_mutex, NULL, MUTEX_DEFAULT, NULL); 18439fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cv_init(&event->se_cv, NULL, CV_DEFAULT, NULL); 18449fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_magic = SMB_EVENT_MAGIC; 18459fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_txid = smb_event_alloc_txid(); 18469fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_server = sv; 18479fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18489fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_enter(&sv->sv_event_list, RW_WRITER); 18499fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_insert_tail(&sv->sv_event_list, event); 18509fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_exit(&sv->sv_event_list); 18519fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18529fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_release(sv); 18539fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (event); 18549fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 18559fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18569fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States void 18579fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_destroy(smb_event_t *event) 18589fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 18599fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_t *sv; 18609fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18619fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (event == NULL) 18629fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return; 18639fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18649fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_EVENT_VALID(event); 18659fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States ASSERT(event->se_waittime == 0); 18669fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18679fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (smb_server_lookup(&sv) != 0) 18689fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return; 18699fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18709fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_enter(&sv->sv_event_list, RW_WRITER); 18719fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_remove(&sv->sv_event_list, event); 18729fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_exit(&sv->sv_event_list); 18739fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18749fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_magic = (uint32_t)~SMB_EVENT_MAGIC; 18759fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cv_destroy(&event->se_cv); 18769fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_destroy(&event->se_mutex); 18779fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18789fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States kmem_cache_free(sv->si_cache_event, event); 18799fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_release(sv); 18809fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 18819fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18829fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States /* 18839fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * Get the txid for the specified event. 18849fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States */ 18859fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States uint32_t 18869fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_txid(smb_event_t *event) 18879fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 18889fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (event != NULL) { 18899fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_EVENT_VALID(event); 18909fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (event->se_txid); 18919fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 18929fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18939fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cmn_err(CE_NOTE, "smb_event_txid failed"); 18949fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return ((uint32_t)-1); 18959fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 18969fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 18979fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States /* 18989fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * Wait for event notification. 18999fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States */ 19009fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States int 19019fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_wait(smb_event_t *event) 19029fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 19039fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States int seconds = 1; 19049fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States int ticks; 19059fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19069fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (event == NULL) 19079fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (EINVAL); 19089fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19099fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_EVENT_VALID(event); 19109fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19119fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_enter(&event->se_mutex); 19129fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_waittime = 1; 19139fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_errno = 0; 19149fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19159fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States while (!(event->se_notified)) { 1916c5866007SKeyur Desai if (smb_event_debug && ((event->se_waittime % 30) == 0)) 19179fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cmn_err(CE_NOTE, "smb_event_wait[%d] (%d sec)", 19189fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_txid, event->se_waittime); 19199fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19209fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (event->se_errno != 0) 19219fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 19229fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19239fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (event->se_waittime > SMB_EVENT_TIMEOUT) { 19249fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_errno = ETIME; 19259fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 19269fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 19279fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19289fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States ticks = SEC_TO_TICK(seconds); 19299fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States (void) cv_reltimedwait(&event->se_cv, 19309fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States &event->se_mutex, (clock_t)ticks, TR_CLOCK_TICK); 19319fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States ++event->se_waittime; 19329fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 19339fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19349fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_waittime = 0; 19359fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_notified = B_FALSE; 19369fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cv_signal(&event->se_cv); 19379fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_exit(&event->se_mutex); 19389fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (event->se_errno); 19399fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 19409fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19419fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States /* 19429fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * If txid is non-zero, cancel the specified event. 19439fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * Otherwise, cancel all events. 19449fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States */ 19459fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static void 19469fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_cancel(smb_server_t *sv, uint32_t txid) 19479fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 19489fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_t *event; 19499fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_t *event_list; 19509fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19519fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_VALID(sv); 19529fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19539fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event_list = &sv->sv_event_list; 19549fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_enter(event_list, RW_WRITER); 19559fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19569fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event = smb_llist_head(event_list); 19579fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States while (event) { 19589fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_EVENT_VALID(event); 19599fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19609fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (txid == 0 || event->se_txid == txid) { 19619fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_enter(&event->se_mutex); 19629fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_errno = ECANCELED; 19639fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_notified = B_TRUE; 19649fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cv_signal(&event->se_cv); 19659fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_exit(&event->se_mutex); 19669fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19679fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (txid != 0) 19689fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 19699fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 19709fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19719fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event = smb_llist_next(event_list, event); 19729fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 19739fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19749fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_exit(event_list); 19759fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 19769fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19779fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States /* 19789fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * If txid is non-zero, notify the specified event. 19799fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * Otherwise, notify all events. 19809fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States */ 19819fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static void 19829fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_notify(smb_server_t *sv, uint32_t txid) 19839fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 19849fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_t *event; 19859fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_t *event_list; 19869fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19879fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_VALID(sv); 19889fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19899fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event_list = &sv->sv_event_list; 19909fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_enter(event_list, RW_READER); 19919fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19929fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event = smb_llist_head(event_list); 19939fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States while (event) { 19949fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_EVENT_VALID(event); 19959fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 19969fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (txid == 0 || event->se_txid == txid) { 19979fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_enter(&event->se_mutex); 19989fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event->se_notified = B_TRUE; 19999fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cv_signal(&event->se_cv); 20009fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_exit(&event->se_mutex); 20019fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 20029fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (txid != 0) 20039fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States break; 20049fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 20059fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 20069fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States event = smb_llist_next(event_list, event); 20079fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 20089fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 20099fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_llist_exit(event_list); 20109fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 20119fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 20129fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States /* 20139fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * Allocate a new transaction id (txid). 20149fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * 20159fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * 0 or -1 are not assigned because they are used to detect invalid 20169fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States * conditions or to indicate all open id's. 20179fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States */ 20189fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static uint32_t 20199fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_event_alloc_txid(void) 20209fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 20219fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static kmutex_t txmutex; 20229fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States static uint32_t txid; 20239fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States uint32_t txid_ret; 20249fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 20259fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_enter(&txmutex); 20269fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 20279fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States if (txid == 0) 20289fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States txid = ddi_get_lbolt() << 11; 20299fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 20309fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States do { 20319fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States ++txid; 20329fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } while (txid == 0 || txid == (uint32_t)-1); 20339fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 20349fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States txid_ret = txid; 20359fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_exit(&txmutex); 20369fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 20379fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (txid_ret); 20389fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 2039