Aren/NetBSD
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

PR/37864: Wolfgang Stukenbrock: when requesting TCP rcp-service port numbers

Browse Source 
UDP is used
This commit is contained in:
christos 2008-01-25 19:43:53 +00:00
parent 3a35c33b92
commit a1e4f75af9
1 changed files with 32 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
lib/libc/rpc/pmap_getport.c
View File

@ -1,4 +1,4 @@
/* $NetBSD: pmap_getport.c,v 1.16 2000/07/06 03:10:34 christos Exp $ */
/* $NetBSD: pmap_getport.c,v 1.17 2008/01/25 19:43:53 christos Exp $ */
/*
* Sun RPC is a product of Sun Microsystems, Inc. and is provided for
@ -35,7 +35,7 @@
static char *sccsid = "@(#)pmap_getport.c 1.9 87/08/11 Copyr 1984 Sun Micro";
static char *sccsid = "@(#)pmap_getport.c 2.2 88/08/01 4.0 RPCSRC";
#else
__RCSID("$NetBSD: pmap_getport.c,v 1.16 2000/07/06 03:10:34 christos Exp $");
__RCSID("$NetBSD: pmap_getport.c,v 1.17 2008/01/25 19:43:53 christos Exp $");
#endif
#endif
@ -72,6 +72,21 @@ static const struct timeval tottimeout = { 60, 0 };
* Calls the pmap service remotely to do the lookup.
* Returns 0 if no map exists.
*/
static void
remote_pmap_getport(CLIENT *client, struct pmap *parms, u_short *port)
{
if (CLNT_CALL(client, (rpcproc_t)PMAPPROC_GETPORT, (xdrproc_t)xdr_pmap,
parms, (xdrproc_t)xdr_u_short, port, tottimeout) != RPC_SUCCESS) {
rpc_createerr.cf_stat = RPC_PMAPFAILURE;
clnt_geterr(client, &rpc_createerr.cf_error);
} else if (*port == 0) {
rpc_createerr.cf_stat = RPC_PROGNOTREGISTERED;
clnt_geterr(client, &rpc_createerr.cf_error);
}
CLNT_DESTROY(client);
}
u_short
pmap_getport(address, program, version, protocol)
struct sockaddr_in *address;
@ -86,24 +101,22 @@ pmap_getport(address, program, version, protocol)
_DIAGASSERT(address != NULL);
parms.pm_prog = program;
parms.pm_vers = version;
parms.pm_prot = protocol;
parms.pm_port = 0; /* not needed or used */
address->sin_port = htons(PMAPPORT);
client = clntudp_bufcreate(address, PMAPPROG,
PMAPVERS, timeout, &sock, RPCSMALLMSGSIZE, RPCSMALLMSGSIZE);
if (client != NULL) {
parms.pm_prog = program;
parms.pm_vers = version;
parms.pm_prot = protocol;
parms.pm_port = 0; /* not needed or used */
if (CLNT_CALL(client, (rpcproc_t)PMAPPROC_GETPORT,
(xdrproc_t)xdr_pmap,
&parms, (xdrproc_t)xdr_u_short, &port, tottimeout) !=
RPC_SUCCESS){
rpc_createerr.cf_stat = RPC_PMAPFAILURE;
clnt_geterr(client, &rpc_createerr.cf_error);
} else if (port == 0) {
rpc_createerr.cf_stat = RPC_PROGNOTREGISTERED;
}
CLNT_DESTROY(client);
if (protocol == IPPROTO_TCP) {
client = clnttcp_create(address, PMAPPROG, PMAPVERS, &sock, 0, 0);
if (client != NULL)
remote_pmap_getport(client, &parms, &port);
}
if (port == 0) {
client = clntudp_bufcreate(address, PMAPPROG, PMAPVERS, timeout,
&sock, RPCSMALLMSGSIZE, RPCSMALLMSGSIZE);
if (client != NULL)
remote_pmap_getport(client, &parms, &port);
}
address->sin_port = 0;
return (port);