diff options
Diffstat (limited to 'sunrpc')
| -rw-r--r-- | sunrpc/Versions | 3 | ||||
| -rw-r--r-- | sunrpc/clnt_gen.c | 19 | ||||
| -rw-r--r-- | sunrpc/clnt_perr.c | 10 | ||||
| -rw-r--r-- | sunrpc/clnt_simp.c | 2 | ||||
| -rw-r--r-- | sunrpc/clnt_tcp.c | 15 | ||||
| -rw-r--r-- | sunrpc/clnt_udp.c | 15 | ||||
| -rw-r--r-- | sunrpc/clnt_unix.c | 15 | ||||
| -rw-r--r-- | sunrpc/pm_getport.c | 7 | ||||
| -rw-r--r-- | sunrpc/rpc/rpc.h | 24 | ||||
| -rw-r--r-- | sunrpc/rpc_thread.c | 85 |
10 files changed, 155 insertions, 40 deletions
diff --git a/sunrpc/Versions b/sunrpc/Versions index a1ab66e460..54b25df16f 100644 --- a/sunrpc/Versions +++ b/sunrpc/Versions @@ -110,6 +110,7 @@ libc { svc_getreq_common; svc_getreq_poll; svc_max_pollfd; svc_pollfd; } GLIBC_2.2.3 { - __rpc_thread_destroy; + __rpc_thread_destroy; __rpc_thread_svc_fdset; __rpc_thread_createerr; + __rpc_thread_svc_pollfd; __rpc_thread_svc_max_pollfd; } } diff --git a/sunrpc/clnt_gen.c b/sunrpc/clnt_gen.c index a4fefb57e5..27e027242b 100644 --- a/sunrpc/clnt_gen.c +++ b/sunrpc/clnt_gen.c @@ -87,7 +87,7 @@ clnt_create (const char *hostname, u_long prog, u_long vers, || h == NULL) if (herr != NETDB_INTERNAL || errno != ERANGE) { - rpc_createerr.cf_stat = RPC_UNKNOWNHOST; + get_rpc_createerr().cf_stat = RPC_UNKNOWNHOST; return NULL; } else @@ -102,8 +102,9 @@ clnt_create (const char *hostname, u_long prog, u_long vers, /* * Only support INET for now */ - rpc_createerr.cf_stat = RPC_SYSTEMERROR; - rpc_createerr.cf_error.re_errno = EAFNOSUPPORT; + struct rpc_createerr *ce = &get_rpc_createerr (); + ce->cf_stat = RPC_SYSTEMERROR; + ce->cf_error.re_errno = EAFNOSUPPORT; return NULL; } sin.sin_family = h->h_addrtype; @@ -117,8 +118,9 @@ clnt_create (const char *hostname, u_long prog, u_long vers, || p == NULL) if (errno != ERANGE) { - rpc_createerr.cf_stat = RPC_UNKNOWNPROTO; - rpc_createerr.cf_error.re_errno = EPFNOSUPPORT; + struct rpc_createerr *ce = &get_rpc_createerr (); + ce->cf_stat = RPC_UNKNOWNPROTO; + ce->cf_error.re_errno = EPFNOSUPPORT; return NULL; } else @@ -163,8 +165,11 @@ clnt_create (const char *hostname, u_long prog, u_long vers, #endif break; default: - rpc_createerr.cf_stat = RPC_SYSTEMERROR; - rpc_createerr.cf_error.re_errno = EPFNOSUPPORT; + { + struct rpc_createerr *ce = &get_rpc_createerr (); + ce->cf_stat = RPC_SYSTEMERROR; + ce->cf_error.re_errno = EPFNOSUPPORT; + } return (NULL); } return client; diff --git a/sunrpc/clnt_perr.c b/sunrpc/clnt_perr.c index 24b15c04c6..55d38153b9 100644 --- a/sunrpc/clnt_perr.c +++ b/sunrpc/clnt_perr.c @@ -292,22 +292,24 @@ clnt_spcreateerror (const char *msg) char *str = _buf (); char *cp; int len; + struct rpc_createerr *ce; if (str == NULL) return NULL; + ce = &get_rpc_createerr (); len = sprintf (str, "%s: ", msg); cp = str + len; - cp = stpcpy (cp, clnt_sperrno (rpc_createerr.cf_stat)); - switch (rpc_createerr.cf_stat) + cp = stpcpy (cp, clnt_sperrno (ce->cf_stat)); + switch (ce->cf_stat) { case RPC_PMAPFAILURE: cp = stpcpy (stpcpy (cp, " - "), - clnt_sperrno (rpc_createerr.cf_error.re_status)); + clnt_sperrno (ce->cf_error.re_status)); break; case RPC_SYSTEMERROR: cp = stpcpy (stpcpy (cp, " - "), - __strerror_r (rpc_createerr.cf_error.re_errno, + __strerror_r (ce->cf_error.re_errno, chrbuf, sizeof chrbuf)); break; default: diff --git a/sunrpc/clnt_simp.c b/sunrpc/clnt_simp.c index 03b65cdbc0..735f2edb9a 100644 --- a/sunrpc/clnt_simp.c +++ b/sunrpc/clnt_simp.c @@ -127,7 +127,7 @@ callrpc (const char *host, u_long prognum, u_long versnum, u_long procnum, server_addr.sin_port = 0; if ((crp->client = clntudp_create (&server_addr, (u_long) prognum, (u_long) versnum, timeout, &crp->socket)) == NULL) - return (int) rpc_createerr.cf_stat; + return (int) get_rpc_createerr().cf_stat; crp->valid = 1; crp->oldprognum = prognum; crp->oldversnum = versnum; diff --git a/sunrpc/clnt_tcp.c b/sunrpc/clnt_tcp.c index ad53d576d6..e3076524a7 100644 --- a/sunrpc/clnt_tcp.c +++ b/sunrpc/clnt_tcp.c @@ -123,17 +123,19 @@ clnttcp_create (struct sockaddr_in *raddr, u_long prog, u_long vers, h = (CLIENT *) mem_alloc (sizeof (*h)); if (h == NULL) { + struct rpc_createerr *ce = &get_rpc_createerr (); (void) fprintf (stderr, _("clnttcp_create: out of memory\n")); - rpc_createerr.cf_stat = RPC_SYSTEMERROR; - rpc_createerr.cf_error.re_errno = errno; + ce->cf_stat = RPC_SYSTEMERROR; + ce->cf_error.re_errno = errno; goto fooy; } /* ct = (struct ct_data *) mem_alloc (sizeof (*ct)); */ if (ct == NULL) { + struct rpc_createerr *ce = &get_rpc_createerr (); (void) fprintf (stderr, _("clnttcp_create: out of memory\n")); - rpc_createerr.cf_stat = RPC_SYSTEMERROR; - rpc_createerr.cf_error.re_errno = errno; + ce->cf_stat = RPC_SYSTEMERROR; + ce->cf_error.re_errno = errno; goto fooy; } @@ -163,8 +165,9 @@ clnttcp_create (struct sockaddr_in *raddr, u_long prog, u_long vers, || (__connect (*sockp, (struct sockaddr *) raddr, sizeof (*raddr)) < 0)) { - rpc_createerr.cf_stat = RPC_SYSTEMERROR; - rpc_createerr.cf_error.re_errno = errno; + struct rpc_createerr *ce = &get_rpc_createerr (); + ce->cf_stat = RPC_SYSTEMERROR; + ce->cf_error.re_errno = errno; if (*sockp >= 0) (void) __close (*sockp); goto fooy; diff --git a/sunrpc/clnt_udp.c b/sunrpc/clnt_udp.c index f951923052..bf98553b8d 100644 --- a/sunrpc/clnt_udp.c +++ b/sunrpc/clnt_udp.c @@ -128,9 +128,10 @@ clntudp_bufcreate (struct sockaddr_in *raddr, u_long program, u_long version, cl = (CLIENT *) mem_alloc (sizeof (CLIENT)); if (cl == NULL) { + struct rpc_createerr *ce = &get_rpc_createerr (); (void) fprintf (stderr, _("clntudp_create: out of memory\n")); - rpc_createerr.cf_stat = RPC_SYSTEMERROR; - rpc_createerr.cf_error.re_errno = errno; + ce->cf_stat = RPC_SYSTEMERROR; + ce->cf_error.re_errno = errno; goto fooy; } sendsz = ((sendsz + 3) / 4) * 4; @@ -138,9 +139,10 @@ clntudp_bufcreate (struct sockaddr_in *raddr, u_long program, u_long version, cu = (struct cu_data *) mem_alloc (sizeof (*cu) + sendsz + recvsz); if (cu == NULL) { + struct rpc_createerr *ce = &get_rpc_createerr (); (void) fprintf (stderr, _("clntudp_create: out of memory\n")); - rpc_createerr.cf_stat = RPC_SYSTEMERROR; - rpc_createerr.cf_error.re_errno = errno; + ce->cf_stat = RPC_SYSTEMERROR; + ce->cf_error.re_errno = errno; goto fooy; } cu->cu_outbuf = &cu->cu_inbuf[recvsz]; @@ -183,8 +185,9 @@ clntudp_bufcreate (struct sockaddr_in *raddr, u_long program, u_long version, *sockp = __socket (AF_INET, SOCK_DGRAM, IPPROTO_UDP); if (*sockp < 0) { - rpc_createerr.cf_stat = RPC_SYSTEMERROR; - rpc_createerr.cf_error.re_errno = errno; + struct rpc_createerr *ce = &get_rpc_createerr (); + ce->cf_stat = RPC_SYSTEMERROR; + ce->cf_error.re_errno = errno; goto fooy; } /* attempt to bind to prov port */ diff --git a/sunrpc/clnt_unix.c b/sunrpc/clnt_unix.c index 52806226fb..19356ad032 100644 --- a/sunrpc/clnt_unix.c +++ b/sunrpc/clnt_unix.c @@ -121,17 +121,19 @@ clntunix_create (struct sockaddr_un *raddr, u_long prog, u_long vers, h = (CLIENT *) mem_alloc (sizeof (*h)); if (h == NULL) { + struct rpc_createerr *ce = &get_rpc_createerr (); (void) fputs (_("clntunix_create: out of memory\n"), stderr); - rpc_createerr.cf_stat = RPC_SYSTEMERROR; - rpc_createerr.cf_error.re_errno = errno; + ce->cf_stat = RPC_SYSTEMERROR; + ce->cf_error.re_errno = errno; goto fooy; } /* ct = (struct ct_data *) mem_alloc (sizeof (*ct)); */ if (ct == NULL) { + struct rpc_createerr *ce = &get_rpc_createerr (); (void) fputs (_("clntunix_create: out of memory\n"), stderr); - rpc_createerr.cf_stat = RPC_SYSTEMERROR; - rpc_createerr.cf_error.re_errno = errno; + ce->cf_stat = RPC_SYSTEMERROR; + ce->cf_error.re_errno = errno; goto fooy; } @@ -145,8 +147,9 @@ clntunix_create (struct sockaddr_un *raddr, u_long prog, u_long vers, if (*sockp < 0 || __connect (*sockp, (struct sockaddr *) raddr, len) < 0) { - rpc_createerr.cf_stat = RPC_SYSTEMERROR; - rpc_createerr.cf_error.re_errno = errno; + struct rpc_createerr *ce = &get_rpc_createerr (); + ce->cf_stat = RPC_SYSTEMERROR; + ce->cf_error.re_errno = errno; if (*sockp != -1) __close (*sockp); goto fooy; diff --git a/sunrpc/pm_getport.c b/sunrpc/pm_getport.c index be3cb495a6..b86472ccdf 100644 --- a/sunrpc/pm_getport.c +++ b/sunrpc/pm_getport.c @@ -70,6 +70,7 @@ pmap_getport (address, program, version, protocol) PMAPVERS, timeout, &socket, RPCSMALLMSGSIZE, RPCSMALLMSGSIZE); if (client != (CLIENT *) NULL) { + struct rpc_createerr *ce = &get_rpc_createerr (); parms.pm_prog = program; parms.pm_vers = version; parms.pm_prot = protocol; @@ -78,12 +79,12 @@ pmap_getport (address, program, version, protocol) (caddr_t)&parms, (xdrproc_t)xdr_u_short, (caddr_t)&port, tottimeout) != RPC_SUCCESS) { - rpc_createerr.cf_stat = RPC_PMAPFAILURE; - clnt_geterr (client, &rpc_createerr.cf_error); + ce->cf_stat = RPC_PMAPFAILURE; + clnt_geterr (client, &ce->cf_error); } else if (port == 0) { - rpc_createerr.cf_stat = RPC_PROGNOTREGISTERED; + ce->cf_stat = RPC_PROGNOTREGISTERED; } CLNT_DESTROY (client); } diff --git a/sunrpc/rpc/rpc.h b/sunrpc/rpc/rpc.h index a966d2e231..5150abf687 100644 --- a/sunrpc/rpc/rpc.h +++ b/sunrpc/rpc/rpc.h @@ -67,4 +67,28 @@ /* routines for parsing /etc/rpc */ #include <rpc/netdb.h> /* structures and routines to parse /etc/rpc */ + +/* Global variables, protected for multi-threaded applications. */ +extern fd_set *__rpc_thread_svc_fdset (void) __attribute__ ((__const__)); +#define svc_fdset (*__rpc_thread_svc_fdset ()) + +extern struct rpc_createerr *__rpc_thread_createerr (void) + __attribute__ ((__const__)); +#define get_rpc_createerr() (*__rpc_thread_createerr ()) +/* The people who "engineered" RPC should bee punished for naming the + data structure and the variable the same. We cannot always define the + macro 'rpc_createerr' because this would prevent people from defining + object of type 'struct rpc_createerr'. So we leave it up to the user + to select transparent replacement also of this variable. */ +#ifdef _RPC_MT_VARS +# define rpc_createerr (*__rpc_thread_createerr ()) +#endif + +extern struct pollfd **__rpc_thread_svc_pollfd (void) + __attribute__ ((__const__)); +#define svc_pollfd (*__rpc_thread_svc_pollfd ()) + +extern int *__rpc_thread_svc_max_pollfd (void) __attribute__ ((__const__)); +#define svc_max_pollfd (*__rpc_thread_svc_max_pollfd ()) + #endif /* rpc/rpc.h */ diff --git a/sunrpc/rpc_thread.c b/sunrpc/rpc_thread.c index 0b004c403f..1fd1c143ea 100644 --- a/sunrpc/rpc_thread.c +++ b/sunrpc/rpc_thread.c @@ -14,6 +14,10 @@ static struct rpc_thread_variables __libc_tsd_RPC_VARS_mem; static struct rpc_thread_variables *__libc_tsd_RPC_VARS_data = &__libc_tsd_RPC_VARS_mem; + +/* This is the variable used for the first thread. */ +static struct rpc_thread_variables rpc_default; + /* * Task-variable destructor */ @@ -22,7 +26,7 @@ __rpc_thread_destroy (void) { struct rpc_thread_variables *tvp = __rpc_thread_variables(); - if (tvp != NULL) { + if (tvp != NULL && tvp != &rpc_default) { __rpc_thread_svc_cleanup (); __rpc_thread_clnt_cleanup (); __rpc_thread_key_cleanup (); @@ -37,19 +41,88 @@ __rpc_thread_destroy (void) } +/* + * Initialize RPC multi-threaded operation + */ +static void +rpc_thread_multi (void) +{ + __libc_tsd_set (RPC_VARS, &rpc_default); +} + + struct rpc_thread_variables * __rpc_thread_variables (void) { + __libc_once_define (static, once); struct rpc_thread_variables *tvp; tvp = __libc_tsd_get (RPC_VARS); if (tvp == NULL) { - tvp = calloc (1, sizeof *tvp); - if (tvp != NULL) - __libc_tsd_set (RPC_VARS, tvp); - else - tvp = __libc_tsd_RPC_VARS_data; + __libc_once (once, rpc_thread_multi); + tvp = __libc_tsd_get (RPC_VARS); + if (tvp == NULL) { + tvp = calloc (1, sizeof *tvp); + if (tvp != NULL) + __libc_tsd_set (RPC_VARS, tvp); + else + tvp = __libc_tsd_RPC_VARS_data; + } } return tvp; } + + +/* Global variables If we're single-threaded, or if this is the first + thread using the variable, use the existing global variable. This + provides backwards compatability for existing applications which + dynamically link against this code. */ +#undef svc_fdset +#undef rpc_createerr +#undef svc_pollfd +#undef svc_max_pollfd + +fd_set * +__rpc_thread_svc_fdset (void) +{ + struct rpc_thread_variables *tvp; + + tvp = __rpc_thread_variables (); + if (tvp == &rpc_default) + return &svc_fdset; + return &tvp->svc_fdset_s; +} + +struct rpc_createerr * +__rpc_thread_createerr (void) +{ + struct rpc_thread_variables *tvp; + + tvp = __rpc_thread_variables (); + if (tvp == &rpc_default) + return &rpc_createerr; + return &tvp->rpc_createerr_s; +} + +struct pollfd ** +__rpc_thread_svc_pollfd (void) +{ + struct rpc_thread_variables *tvp; + + tvp = __rpc_thread_variables (); + if (tvp == &rpc_default) + return &svc_pollfd; + return &tvp->svc_pollfd_s; +} + +int * +__rpc_thread_svc_max_pollfd (void) +{ + struct rpc_thread_variables *tvp; + + tvp = __rpc_thread_variables (); + if (tvp == &rpc_default) + return &svc_max_pollfd; + return &tvp->svc_max_pollfd_s; +} #endif /* _RPC_THREAD_SAFE_ */ |