rpc.h File Reference

#include <rpc/types.h>
#include "winsock2.h"
#include <rpc/xdr.h>
#include <rpc/auth.h>
#include <rpc/clnt.h>
#include <rpc/rpc_msg.h>
#include <rpc/auth_unix.h>
#include <rpc/auth_des.h>
#include <rpc/svc_auth.h>
#include <rpc/svc.h>
#include <rpc/pmap_clnt.h>
#include <rpc/pmap_prot.h>
#include <rpc/rpcb_clnt.h>
#include <rpc/rpcent.h>

Include dependency graph for rpc.h:

Go to the source code of this file.

Macros
#define	UDPMSGSIZE   8800

Functions
__BEGIN_DECLS int	get_myaddress (struct sockaddr_in *)
int	bindresvport (SOCKET, struct sockaddr_in *) __THROW
int	registerrpc (int, int, int, char *(*)(char [UDPMSGSIZE]), xdrproc_t, xdrproc_t)
int	callrpc (const char *, int, int, int, xdrproc_t, void *, xdrproc_t, void *)
int	getrpcport (char *, int, int, int)
char *	taddr2uaddr (const struct netconfig *, const struct netbuf *)
struct netbuf *	uaddr2taddr (const struct netconfig *, const char *)
void	freeuaddr (char *)
void	freenetbuf (struct netbuf *)
int	bindresvport_sa (SOCKET, struct sockaddr *)
__END_DECLS __BEGIN_DECLS SOCKET	__rpc_nconf2fd (const struct netconfig *)
int	__rpc_nconf2sockinfo (const struct netconfig *, struct __rpc_sockinfo *)
int	__rpc_fd2sockinfo (SOCKET, struct __rpc_sockinfo *)
u_int	__rpc_get_t_size (int, int, int)

Macro Definition Documentation

UDPMSGSIZE

#define UDPMSGSIZE   8800

Definition at line 80 of file rpc.h.

Function Documentation

__rpc_fd2sockinfo()

int __rpc_fd2sockinfo	(	SOCKET	,
		struct __rpc_sockinfo *
	)

Definition at line 481 of file rpc_generic.c.

{
    socklen_t len;
    int type, proto;
    struct sockaddr_storage ss;

#ifdef _WIN32
    WSAPROTOCOL_INFO proto_info;
    int proto_info_size = sizeof(proto_info);
    if (getsockopt(fd, SOL_SOCKET, SO_PROTOCOL_INFO, (char *)&proto_info, &proto_info_size) == SOCKET_ERROR) {
#ifndef __REACTOS__
        int err = WSAGetLastError();
#endif
        return 0;
    }
    len = proto_info.iMaxSockAddr;
    ss.ss_family = (ADDRESS_FAMILY)proto_info.iAddressFamily;
#else
    len = sizeof ss;
    if (getsockname(fd, (struct sockaddr *)&ss, &len) == SOCKET_ERROR) {
        return 0;
    }
#endif
    sip->si_alen = len;

    len = sizeof type;
    if (getsockopt(fd, SOL_SOCKET, SO_TYPE, (char *)&type, &len) == SOCKET_ERROR) {
#ifndef __REACTOS__
        int err = WSAGetLastError();
#endif
        return 0;
    }

    /* XXX */
#ifdef AF_LOCAL
    if (ss.ss_family != AF_LOCAL) {
#endif
        if (type == SOCK_STREAM)
            proto = IPPROTO_TCP;
        else if (type == SOCK_DGRAM)
            proto = IPPROTO_UDP;
        else
            return 0;
#ifdef AF_LOCAL
    } else
        proto = 0;
#endif

    sip->si_af = ss.ss_family;
    sip->si_proto = proto;
    sip->si_socktype = type;

    return 1;
}

Referenced by __rpcgettp(), clnt_dg_create(), clnt_tli_create(), clnt_vc_create(), makefd_xprt(), rendezvous_request(), rpc_reg(), svc_dg_create(), svc_tli_create(), and svc_vc_create().

__rpc_get_t_size()

u_int __rpc_get_t_size	(	int	,
		int	,
		int
	)

Definition at line 139 of file rpc_generic.c.

{
    int maxsize, defsize;

    maxsize = 256 * 1024;   /* XXX */
    switch (proto) {
    case IPPROTO_TCP:
        defsize = 1024 * 1024;  /* XXX */
        break;
    case IPPROTO_UDP:
        defsize = UDPMSGSIZE;
        break;
    default:
        defsize = RPC_MAXDATASIZE;
        break;
    }
    if (size == 0)
        return defsize;
#if 1
    /* cbodley- give us the size we ask for, or we'll get fragmented! */
    return (u_int)size;
#else
    /* Check whether the value is within the upper max limit */
    return (size > maxsize ? (u_int)maxsize : (u_int)size);
#endif
}

Referenced by clnt_dg_create(), clnt_vc_create(), local_rpcb(), rpc_broadcast_exp(), rpc_reg(), svc_dg_create(), and svc_vc_create().

__rpc_nconf2fd()

__END_DECLS __BEGIN_DECLS SOCKET __rpc_nconf2fd

(

const struct netconfig *

)

Definition at line 562 of file rpc_generic.c.

{
    struct __rpc_sockinfo si;
    SOCKET fd;

    if (!__rpc_nconf2sockinfo(nconf, &si))
        return 0;

    if ((fd = socket(si.si_af, si.si_socktype, si.si_proto)) != INVALID_SOCKET &&
        si.si_af == AF_INET6) {
        int val = 1;

        setsockopt(fd, SOL_IPV6, IPV6_V6ONLY, (const char *)&val, sizeof(val));
    }
    return fd;
}

Referenced by clnt_tli_create(), and svc_tli_create().

__rpc_nconf2sockinfo()

int __rpc_nconf2sockinfo	(	const struct netconfig *	,
		struct __rpc_sockinfo *
	)

Definition at line 540 of file rpc_generic.c.

{
    int i;

    for (i = 0; i < (sizeof na_cvt) / (sizeof (struct netid_af)); i++)
        if (strcmp(na_cvt[i].netid, nconf->nc_netid) == 0 || (
            strcmp(nconf->nc_netid, "unix") == 0 &&
            strcmp(na_cvt[i].netid, "local") == 0)) {
            sip->si_af = na_cvt[i].af;
            sip->si_proto = na_cvt[i].protocol;
            sip->si_socktype =
                __rpc_seman2socktype((int)nconf->nc_semantics);
            if (sip->si_socktype == -1)
                return 0;
            sip->si_alen = __rpc_get_a_size(sip->si_af);
            return 1;
        }

    return 0;
}

Referenced by __rpc_nconf2fd(), getclnthandle(), rpc_broadcast_exp(), svc_tli_create(), taddr2uaddr(), and uaddr2taddr().

bindresvport()

int bindresvport	(	SOCKET	,
		struct sockaddr_in *
	)

Definition at line 53 of file bindresvport.c.

{
        return bindresvport_sa(sd, (struct sockaddr *)sin);
}

Referenced by clnt_tli_create(), and svc_tli_create().

bindresvport_sa()

int bindresvport_sa	(	SOCKET	,
		struct sockaddr *
	)

Definition at line 161 of file bindresvport.c.

{
#ifdef IPV6_PORTRANGE
    int old;
#endif
    int error, af;
    struct sockaddr_storage myaddr;
    struct sockaddr_in *sin;
#ifdef INET6
    struct sockaddr_in6 *sin6;
#endif
    int proto, portrange, portlow;
    u_int16_t *portp;
    socklen_t salen;
#ifdef _WIN32
        WSAPROTOCOL_INFO proto_info;
        int proto_info_size = sizeof(proto_info);
#endif

    if (sa == NULL) {
        salen = sizeof(myaddr);
        sa = (struct sockaddr *)&myaddr;

#ifdef _WIN32
        memset(sa, 0, salen);
        if (error = getsockopt(sd, SOL_SOCKET, SO_PROTOCOL_INFO, (char *)&proto_info, &proto_info_size) == SOCKET_ERROR) {
#ifndef __REACTOS__
            int sockerr = WSAGetLastError();
#endif
            return -1;
        }
        af = proto_info.iAddressFamily;
#else
        if (getsockname(sd, sa, &salen) == -1)
            return -1;  /* errno is correctly set */

        af = sa->sa_family;
        memset(sa, 0, salen);
#endif
    } else
        af = sa->sa_family;

    switch (af) {
    case AF_INET:
        proto = IPPROTO_IP;
        portrange = IP_PORTRANGE;
        portlow = IP_PORTRANGE_LOW;
        sin = (struct sockaddr_in *)sa;
        salen = sizeof(struct sockaddr_in);
        portp = &sin->sin_port;
        break;
#ifdef INET6
    case AF_INET6:
        proto = IPPROTO_IPV6;
#ifdef IPV6_PORTRANGE
        portrange = IPV6_PORTRANGE;
        portlow = IPV6_PORTRANGE_LOW;
#endif
        sin6 = (struct sockaddr_in6 *)sa;
        salen = sizeof(struct sockaddr_in6);
        portp = &sin6->sin6_port;
        break;
#endif /* INET6 */
    default:
        errno = WSAEPFNOSUPPORT;
        return (-1);
    }
    sa->sa_family = (ADDRESS_FAMILY) af;

#ifdef IPV6_PORTRANGE
    if (*portp == 0) {
        socklen_t oldlen = sizeof(old);

        error = getsockopt(sd, proto, portrange, &old, &oldlen);
        if (error < 0)
            return (error);

        error = setsockopt(sd, proto, portrange, &portlow,
            sizeof(portlow));
        if (error < 0)
            return (error);
    }
#endif

    error = bind(sd, sa, salen);
    if (error) {
#ifndef __REACTOS__
        int err = WSAGetLastError();
#endif
    }

#ifdef IPV6_PORTRANGE
    if (*portp == 0) {
        int saved_errno = errno;

        if (error < 0) {
            if (setsockopt(sd, proto, portrange, &old,
                sizeof(old)) < 0)
                errno = saved_errno;
            return (error);
        }

        if (sa != (struct sockaddr *)&myaddr) {
            /* Hmm, what did the kernel assign? */
            if (getsockname(sd, sa, &salen) < 0)
                errno = saved_errno;
            return (error);
        }
    }
#endif
    return (error);
}

Referenced by bindresvport(), and clnt_dg_create().

callrpc()

int callrpc	(	const char *	,
		int	,
		int	,
		int	,
		xdrproc_t	,
		void *	,
		xdrproc_t	,
		void *
	)

freenetbuf()

void freenetbuf

(

struct netbuf *

)

Definition at line 633 of file rpc_generic.c.

{
    if (nbuf) {
        free(nbuf->buf);
        free(nbuf);
    }
}

Referenced by get_client_for_netaddr().

freeuaddr()

void freeuaddr

(

char *

)

Definition at line 628 of file rpc_generic.c.

{
    free(uaddr);
}

Referenced by nfs41_server_resolve().

get_myaddress()

__BEGIN_DECLS int get_myaddress

(

struct sockaddr_in *

)

getrpcport()

int getrpcport	(	char *	,
		int	,
		int	,
		int
	)

Definition at line 47 of file getrpcport.c.

{
    struct sockaddr_in addr;
    struct hostent *hp;

    assert(host != NULL);

    if ((hp = gethostbyname(host)) == NULL)
        return (0);
    memset(&addr, 0, sizeof(addr));
    addr.sin_family = AF_INET;
    addr.sin_port =  0;
    if (hp->h_length > sizeof(addr))
      hp->h_length = sizeof(addr);
    memcpy(&addr.sin_addr.s_addr, hp->h_addr, (size_t)hp->h_length);
    /* Inconsistent interfaces need casts! :-( */
    return (pmap_getport(&addr, (u_long)prognum, (u_long)versnum, 
        (u_int)proto));
}

registerrpc()

int registerrpc	(	int	,
		int	,
		int	,
		char *	*)(char[UDPMSGSIZE],
		xdrproc_t	,
		xdrproc_t
	)

taddr2uaddr()

char* taddr2uaddr	(	const struct netconfig *	,
		const struct netbuf *
	)

Definition at line 609 of file rpc_generic.c.

{
    struct __rpc_sockinfo si;

    if (!__rpc_nconf2sockinfo(nconf, &si))
        return NULL;
    return __rpc_taddr2uaddr_af(si.si_af, nbuf);
}

Referenced by cache_get(), cache_set(), getclnthandle(), nfs41_server_resolve(), and rpcb_set().

uaddr2taddr()

struct netbuf* uaddr2taddr	(	const struct netconfig *	,
		const char *
	)

Definition at line 619 of file rpc_generic.c.

{
    struct __rpc_sockinfo si;
    
    if (!__rpc_nconf2sockinfo(nconf, &si))
        return NULL;
    return __rpc_uaddr2taddr_af(si.si_af, uaddr);
}

Referenced by __rpcb_findaddr_timed(), get_client_for_netaddr(), pmap_set(), and rpc_broadcast_exp().