1 /* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License (the "License"). 6 * You may not use this file except in compliance with the License. 7 * 8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 9 * or http://www.opensolaris.org/os/licensing. 10 * See the License for the specific language governing permissions 11 * and limitations under the License. 12 * 13 * When distributing Covered Code, include this CDDL HEADER in each 14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 15 * If applicable, add the following below this CDDL HEADER, with the 16 * fields enclosed by brackets "[]" replaced with your own identifying 17 * information: Portions Copyright [yyyy] [name of copyright owner] 18 * 19 * CDDL HEADER END 20 */ 21 /* 22 * Copyright 2009 Sun Microsystems, Inc. All rights reserved. 23 * Use is subject to license terms. 24 */ 25 26 #include <sys/types.h> 27 #include <sys/ksynch.h> 28 #include <sys/cmn_err.h> 29 #include <sys/kmem.h> 30 #include <sys/stat.h> 31 #include <sys/file.h> 32 #include <sys/cred.h> 33 #include <sys/conf.h> 34 #include <sys/modctl.h> 35 #include <sys/errno.h> 36 37 #include <sys/unistat/spcs_s.h> 38 #include <sys/unistat/spcs_s_k.h> 39 #include <sys/unistat/spcs_errors.h> 40 41 #ifdef _SunOS_2_6 42 /* 43 * on 2.6 both dki_lock.h and rpc/types.h define bool_t so we 44 * define enum_t here as it is all we need from rpc/types.h 45 * anyway and make it look like we included it. Yuck. 46 */ 47 #define _RPC_TYPES_H 48 typedef int enum_t; 49 #else 50 #ifndef DS_DDICT 51 #include <rpc/types.h> 52 #endif 53 #endif /* _SunOS_2_6 */ 54 55 #ifndef DS_DDICT 56 #include <rpc/auth.h> 57 #include <rpc/svc.h> 58 #include <rpc/xdr.h> 59 #else 60 #include "../contract.h" 61 #endif 62 63 #include <sys/ddi.h> 64 65 #include <sys/nsc_thread.h> 66 #include <sys/nsctl/nsctl.h> 67 68 #include <sys/nsctl/nsvers.h> 69 70 #include "rdc_io.h" 71 #include "rdc_stub.h" 72 #include "rdc_ioctl.h" 73 #include "rdcsrv.h" 74 75 #if defined(_SunOS_5_6) || defined(_SunOS_5_7) 76 static void rdcsrv_xprtclose(const SVCXPRT *xprt); 77 #else /* SunOS 5.8 or later */ 78 /* 79 * SunOS 5.8 or later. 80 * 81 * RDC callout table 82 * 83 * This table is used by svc_getreq to dispatch a request with a given 84 * prog/vers pair to an approriate service provider. 85 */ 86 87 static SVC_CALLOUT rdcsrv_sc[] = { 88 { RDC_PROGRAM, RDC_VERS_MIN, RDC_VERS_MAX, rdcstub_dispatch } 89 }; 90 91 static SVC_CALLOUT_TABLE rdcsrv_sct = { 92 sizeof (rdcsrv_sc) / sizeof (rdcsrv_sc[0]), FALSE, rdcsrv_sc 93 }; 94 #endif /* SunOS 5.8 or later */ 95 96 static kmutex_t rdcsrv_lock; 97 98 static int rdcsrv_dup_error; 99 static int rdcsrv_registered; 100 static int rdcsrv_closing; 101 static int rdcsrv_refcnt; 102 long rdc_svc_count = 0; 103 static rdcsrv_t *rdcsrv_disptab; 104 105 /* 106 * Solaris module setup. 107 */ 108 109 extern struct mod_ops mod_miscops; 110 111 static struct modlmisc modlmisc = { 112 &mod_miscops, /* Type of module */ 113 "nws:Remote Mirror kRPC:" ISS_VERSION_STR 114 }; 115 116 static struct modlinkage modlinkage = { 117 MODREV_1, 118 &modlmisc, 119 NULL 120 }; 121 122 123 int 124 _init(void) 125 { 126 int rc; 127 128 mutex_init(&rdcsrv_lock, NULL, MUTEX_DRIVER, NULL); 129 130 if ((rc = mod_install(&modlinkage)) != DDI_SUCCESS) 131 mutex_destroy(&rdcsrv_lock); 132 133 return (rc); 134 } 135 136 137 int 138 _fini(void) 139 { 140 int rc; 141 142 if ((rc = mod_remove(&modlinkage)) == DDI_SUCCESS) 143 mutex_destroy(&rdcsrv_lock); 144 145 return (rc); 146 } 147 148 149 int 150 _info(struct modinfo *modinfop) 151 { 152 return (mod_info(&modlinkage, modinfop)); 153 } 154 155 156 /* 157 * RDC kRPC server stub. 158 */ 159 160 void 161 rdcsrv_noproc(void) 162 { 163 ; 164 } 165 166 167 static int 168 rdcsrv_dispdup(struct svc_req *req, SVCXPRT *xprt) 169 { 170 rdc_disptab_t *disp; 171 struct dupreq *dr; 172 rdcsrv_t *srvp; 173 void (*fn)(); 174 int dupstat; 175 176 srvp = &rdcsrv_disptab[req->rq_vers - RDC_VERS_MIN]; 177 disp = &srvp->disptab[req->rq_proc]; 178 fn = disp->dispfn; 179 180 dupstat = SVC_DUP(xprt, req, 0, 0, &dr); 181 182 switch (dupstat) { 183 case DUP_ERROR: 184 /* svcerr_systemerr does a freeargs */ 185 svcerr_systemerr(xprt); 186 rdcsrv_dup_error++; 187 break; 188 189 case DUP_INPROGRESS: 190 rdcsrv_dup_error++; 191 break; 192 193 case DUP_NEW: 194 case DUP_DROP: 195 (*fn)(xprt, req); 196 SVC_DUPDONE(xprt, dr, 0, 0, DUP_DONE); 197 break; 198 199 case DUP_DONE: 200 break; 201 } 202 203 return (dupstat); 204 } 205 206 207 /* 208 * rdcsrv_dispatch is the dispatcher routine for the RDC RPC protocol 209 */ 210 void 211 rdcsrv_dispatch(struct svc_req *req, SVCXPRT *xprt) 212 { 213 rdc_disptab_t *disp; 214 rdcsrv_t *srvp; 215 216 mutex_enter(&rdcsrv_lock); 217 rdcsrv_refcnt++; 218 219 if (!rdcsrv_registered || rdcsrv_closing || !rdcsrv_disptab) { 220 mutex_exit(&rdcsrv_lock); 221 goto outdisp; 222 } 223 224 mutex_exit(&rdcsrv_lock); 225 226 if ((req->rq_vers < RDC_VERS_MIN) || (req->rq_vers > RDC_VERS_MAX)) { 227 svcerr_noproc(xprt); 228 cmn_err(CE_NOTE, "!rdcsrv_dispatch: unknown version %d", 229 req->rq_vers); 230 /* svcerr_noproc does a freeargs on xprt */ 231 goto done; 232 } 233 234 srvp = &rdcsrv_disptab[req->rq_vers - RDC_VERS_MIN]; 235 disp = &srvp->disptab[req->rq_proc]; 236 237 if (req->rq_proc >= srvp->nprocs || 238 disp->dispfn == rdcsrv_noproc) { 239 svcerr_noproc(xprt); 240 cmn_err(CE_NOTE, "!rdcsrv_dispatch: bad proc number %d", 241 req->rq_proc); 242 /* svcerr_noproc does a freeargs on xprt */ 243 goto done; 244 } else if (disp->clone) { 245 switch (rdcsrv_dispdup(req, xprt)) { 246 case DUP_ERROR: 247 goto done; 248 /* NOTREACHED */ 249 case DUP_INPROGRESS: 250 goto outdisp; 251 /* NOTREACHED */ 252 default: 253 break; 254 } 255 } else { 256 (*disp->dispfn)(xprt, req); 257 rdc_svc_count++; 258 } 259 260 outdisp: 261 if (!SVC_FREEARGS(xprt, (xdrproc_t)0, (caddr_t)0)) 262 cmn_err(CE_NOTE, "!rdcsrv_dispatch: bad freeargs"); 263 done: 264 mutex_enter(&rdcsrv_lock); 265 rdcsrv_refcnt--; 266 mutex_exit(&rdcsrv_lock); 267 } 268 269 270 static int 271 rdcsrv_create(file_t *fp, rdc_svc_args_t *args, int mode) 272 { 273 /*LINTED*/ 274 int rc, error = 0; 275 /*LINTED*/ 276 rpcvers_t vers; 277 struct netbuf addrmask; 278 279 #if defined(_SunOS_5_6) || defined(_SunOS_5_7) 280 SVCXPRT *xprt; 281 #else 282 SVCMASTERXPRT *xprt; 283 #endif 284 STRUCT_HANDLE(rdc_svc_args, uap); 285 286 STRUCT_SET_HANDLE(uap, mode, args); 287 288 addrmask.len = STRUCT_FGET(uap, addrmask.len); 289 addrmask.maxlen = STRUCT_FGET(uap, addrmask.maxlen); 290 addrmask.buf = kmem_alloc(addrmask.maxlen, KM_SLEEP); 291 error = ddi_copyin(STRUCT_FGETP(uap, addrmask.buf), addrmask.buf, 292 addrmask.len, mode); 293 if (error) { 294 kmem_free(addrmask.buf, addrmask.maxlen); 295 #ifdef DEBUG 296 cmn_err(CE_WARN, "!addrmask copyin failed %p", (void *) args); 297 #endif 298 return (error); 299 } 300 301 /* 302 * Set rdcstub's dispatch handle to rdcsrv_dispatch 303 */ 304 rdcstub_set_dispatch(rdcsrv_dispatch); 305 306 /* 307 * Create a transport endpoint and create one kernel thread to run the 308 * rdc service loop 309 */ 310 #if defined(_SunOS_5_6) || defined(_SunOS_5_7) 311 error = svc_tli_kcreate(fp, RDC_RPC_MAX, 312 STRUCT_FGETP(uap, netid), &addrmask, STRUCT_FGET(uap, nthr), &xprt); 313 #else 314 { 315 #if defined(_SunOS_5_8) 316 struct svcpool_args p; 317 p.id = RDC_SVCPOOL_ID; 318 p.maxthreads = STRUCT_FGET(uap, nthr); 319 p.redline = 0; 320 p.qsize = 0; 321 p.timeout = 0; 322 p.stksize = 0; 323 p.max_same_xprt = 0; 324 325 error = svc_pool_create(&p); 326 if (error) { 327 cmn_err(CE_NOTE, 328 "!rdcsrv_create: svc_pool_create failed %d", error); 329 return (error); 330 } 331 #endif 332 error = svc_tli_kcreate(fp, RDC_RPC_MAX, 333 STRUCT_FGETP(uap, netid), &addrmask, 334 &xprt, &rdcsrv_sct, NULL, RDC_SVCPOOL_ID, FALSE); 335 } 336 #endif 337 338 if (error) { 339 cmn_err(CE_NOTE, "!rdcsrv_create: svc_tli_kcreate failed %d", 340 error); 341 return (error); 342 } 343 344 #if defined(_SunOS_5_6) || defined(_SunOS_5_7) 345 if (xprt == NULL) { 346 cmn_err(CE_NOTE, "!xprt in rdcsrv_create is NULL"); 347 } else { 348 /* 349 * Register a cleanup routine in case the transport gets 350 * destroyed. If the registration fails for some reason, 351 * it means that the transport is already being destroyed. 352 * This shouldn't happen, but it's probably not worth a 353 * panic. 354 */ 355 if (!svc_control(xprt, SVCSET_CLOSEPROC, 356 (void *)rdcsrv_xprtclose)) { 357 cmn_err( 358 #ifdef DEBUG 359 CE_PANIC, 360 #else 361 CE_WARN, 362 #endif 363 "!rdcsrv_create: couldn't set xprt callback"); 364 365 error = EBADF; 366 goto done; 367 } 368 } 369 370 for (vers = RDC_VERS_MIN; vers <= RDC_VERS_MAX; vers++) { 371 rc = svc_register(xprt, (ulong_t)RDC_PROGRAM, vers, 372 rdcstub_dispatch, 0); 373 if (!rc) { 374 cmn_err(CE_NOTE, 375 "!rdcsrv_create: svc_register(%d, %lu) failed", 376 RDC_PROGRAM, vers); 377 378 if (!error) { 379 error = EBADF; 380 } 381 } 382 } 383 #endif /* 5.6 or 5.7 */ 384 385 if (!error) { 386 /* mark as registered with the kRPC subsystem */ 387 rdcsrv_registered = 1; 388 } 389 390 done: 391 return (error); 392 } 393 394 395 #if defined(_SunOS_5_6) || defined(_SunOS_5_7) 396 /* 397 * Callback routine for when a transport is closed. 398 */ 399 static void 400 rdcsrv_xprtclose(const SVCXPRT *xprt) 401 { 402 } 403 #endif 404 405 406 /* 407 * Private interface from the main RDC module. 408 */ 409 410 int 411 rdcsrv_load(file_t *fp, rdcsrv_t *disptab, rdc_svc_args_t *args, int mode) 412 { 413 int rc = 0; 414 415 mutex_enter(&rdcsrv_lock); 416 417 rc = rdcsrv_create(fp, args, mode); 418 if (rc == 0) { 419 rdcsrv_disptab = disptab; 420 } 421 422 mutex_exit(&rdcsrv_lock); 423 return (rc); 424 } 425 426 427 void 428 rdcsrv_unload(void) 429 { 430 mutex_enter(&rdcsrv_lock); 431 432 /* Unset rdcstub's dispatch handle */ 433 rdcstub_unset_dispatch(); 434 435 rdcsrv_closing = 1; 436 437 while (rdcsrv_refcnt > 0) { 438 mutex_exit(&rdcsrv_lock); 439 delay(drv_usectohz(25)); 440 mutex_enter(&rdcsrv_lock); 441 } 442 443 rdcsrv_closing = 0; 444 rdcsrv_disptab = 0; 445 446 mutex_exit(&rdcsrv_lock); 447 } 448