lib/libc/rpc/mt_misc.c

   1 /* @(#)mt_misc.c        1.24    93/04/29 SMI */
   2 /* $NetBSD: mt_misc.c,v 1.1 2000/06/02 23:11:11 fvdl Exp $ */
   3 /* $FreeBSD: src/lib/libc/rpc/mt_misc.c,v 1.7 2006/02/27 22:10:59 deischen Exp $ */
   4 /* $DragonFly$ */
   5
   6 #include "namespace.h"
   7 #include "reentrant.h"
   8 #include <rpc/rpc.h>
   9 #include <sys/time.h>
  10 #include <stdlib.h>
  11 #include <string.h>
  12 #include "un-namespace.h"
  13 #include "mt_misc.h"
  14
  15 /* Take these objects out of the application namespace. */
  16 #define svc_lock                __svc_lock
  17 #define svc_fd_lock             __svc_fd_lock
  18 #define rpcbaddr_cache_lock     __rpcbaddr_cache_lock
  19 #define authdes_ops_lock        __authdes_ops_lock
  20 #define authnone_lock           __authnone_lock
  21 #define authsvc_lock            __authsvc_lock
  22 #define clnt_fd_lock            __clnt_fd_lock
  23 #define clntraw_lock            __clntraw_lock
  24 #define dupreq_lock             __dupreq_lock
  25 #define loopnconf_lock          __loopnconf_lock
  26 #define ops_lock                __ops_lock
  27 #define proglst_lock            __proglst_lock
  28 #define rpcsoc_lock             __rpcsoc_lock
  29 #define svcraw_lock             __svcraw_lock
  30 #define tsd_lock                __tsd_lock
  31 #define xprtlist_lock           __xprtlist_lock
  32
  33 /* protects the services list (svc.c) */
  34 pthread_rwlock_t        svc_lock = PTHREAD_RWLOCK_INITIALIZER;
  35
  36 /* protects svc_fdset and the xports[] array */
  37 pthread_rwlock_t        svc_fd_lock = PTHREAD_RWLOCK_INITIALIZER;
  38
  39 /* protects the RPCBIND address cache */
  40 pthread_rwlock_t        rpcbaddr_cache_lock = PTHREAD_RWLOCK_INITIALIZER;
  41
  42 /* serializes authdes ops initializations */
  43 pthread_mutex_t authdes_ops_lock = PTHREAD_MUTEX_INITIALIZER;
  44
  45 /* protects des stats list */
  46 pthread_mutex_t svcauthdesstats_lock = PTHREAD_MUTEX_INITIALIZER;
  47
  48 /* auth_none.c serialization */
  49 pthread_mutex_t authnone_lock = PTHREAD_MUTEX_INITIALIZER;
  50
  51 /* protects the Auths list (svc_auth.c) */
  52 pthread_mutex_t authsvc_lock = PTHREAD_MUTEX_INITIALIZER;
  53
  54 /* protects client-side fd lock array */
  55 pthread_mutex_t clnt_fd_lock = PTHREAD_MUTEX_INITIALIZER;
  56
  57 /* clnt_raw.c serialization */
  58 pthread_mutex_t clntraw_lock = PTHREAD_MUTEX_INITIALIZER;
  59
  60 /* dupreq variables (svc_dg.c) */
  61 pthread_mutex_t dupreq_lock = PTHREAD_MUTEX_INITIALIZER;
  62
  63 /* loopnconf (rpcb_clnt.c) */
  64 pthread_mutex_t loopnconf_lock = PTHREAD_MUTEX_INITIALIZER;
  65
  66 /* serializes ops initializations */
  67 pthread_mutex_t ops_lock = PTHREAD_MUTEX_INITIALIZER;
  68
  69 /* protects proglst list (svc_simple.c) */
  70 pthread_mutex_t proglst_lock = PTHREAD_MUTEX_INITIALIZER;
  71
  72 /* serializes clnt_com_create() (rpc_soc.c) */
  73 pthread_mutex_t rpcsoc_lock = PTHREAD_MUTEX_INITIALIZER;
  74
  75 /* svc_raw.c serialization */
  76 pthread_mutex_t svcraw_lock = PTHREAD_MUTEX_INITIALIZER;
  77
  78 /* protects TSD key creation */
  79 pthread_mutex_t tsd_lock = PTHREAD_MUTEX_INITIALIZER;
  80
  81 /* xprtlist (svc_generic.c) */
  82 pthread_mutex_t xprtlist_lock = PTHREAD_MUTEX_INITIALIZER;
  83
  84 #undef  rpc_createerr
  85
  86 struct rpc_createerr rpc_createerr;
  87
  88 struct rpc_createerr *
  89 __rpc_createerr(void)
  90 {
  91         static thread_key_t rce_key = 0;
  92         struct rpc_createerr *rce_addr = 0;
  93
  94         if (thr_main())
  95                 return (&rpc_createerr);
  96         if ((rce_addr =
  97             (struct rpc_createerr *)thr_getspecific(rce_key)) != 0) {
  98                 mutex_lock(&tsd_lock);
  99                 if (thr_keycreate(&rce_key, free) != 0) {
 100                         mutex_unlock(&tsd_lock);
 101                         return (&rpc_createerr);
 102                 }
 103                 mutex_unlock(&tsd_lock);
 104         }
 105         if (!rce_addr) {
 106                 rce_addr = (struct rpc_createerr *)
 107                         malloc(sizeof (struct rpc_createerr));
 108                 if (thr_setspecific(rce_key, (void *) rce_addr) != 0) {
 109                         if (rce_addr)
 110                                 free(rce_addr);
 111                         return (&rpc_createerr);
 112                 }
 113                 memset(rce_addr, 0, sizeof (struct rpc_createerr));
 114                 return (rce_addr);
 115         }
 116         return (rce_addr);
 117 }