rpc_com.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Macros
#define	RPC_MAXDATASIZE   9000
#define	RPC_MAXADDRSIZE   1024
#define	__RPC_GETXID(now)

Functions
__BEGIN_DECLS u_int	__rpc_get_a_size (int)
int	__rpc_dtbsize (void)
int	_rpc_dtablesize (void)
struct netconfig *	__rpcgettp (int)
int	__rpc_get_default_domain (char **)
char *	__rpc_taddr2uaddr_af (int, const struct netbuf *)
struct netbuf *	__rpc_uaddr2taddr_af (int, const char *)
int	__rpc_fixup_addr (struct netbuf *, const struct netbuf *)
int	__rpc_sockinfo2netid (struct __rpc_sockinfo *, const char **)
int	__rpc_seman2socktype (int)
int	__rpc_socktype2seman (int)
void *	rpc_nullproc (CLIENT *)
int	__rpc_sockisbound (SOCKET)
struct netbuf *	__rpcb_findaddr (rpcprog_t, rpcvers_t, const struct netconfig *, const char *, CLIENT **)
bool_t	rpc_control (int, void *)
char *	_get_next_token (char *, int)

Macro Definition Documentation

__RPC_GETXID

#define __RPC_GETXID

(

now

)

Value:

    ((u_int32_t)getpid() ^ (u_int32_t)(now)->tv_sec ^ \
    (u_int32_t)(now)->tv_usec)

Definition at line 59 of file rpc_com.h.

RPC_MAXADDRSIZE

#define RPC_MAXADDRSIZE   1024

Definition at line 53 of file rpc_com.h.

RPC_MAXDATASIZE

#define RPC_MAXDATASIZE   9000

Definition at line 52 of file rpc_com.h.

Function Documentation

__rpc_dtbsize()

int __rpc_dtbsize

(

void

)

Definition at line 110 of file rpc_generic.c.

{
#ifdef _WIN32
    return (WINSOCK_HANDLE_HASH_SIZE);
#else
 
    static int tbsize;
    struct rlimit rl;
 
    if (tbsize) {
        return (tbsize);
    }
    if (getrlimit(RLIMIT_NOFILE, &rl) == 0) {
        return (tbsize = (int)rl.rlim_max);
    }
    /*
     * Something wrong.  I'll try to save face by returning a
     * pessimistic number.
     */
    return (32);
#endif
}

__rpc_fixup_addr()

int __rpc_fixup_addr	(	struct netbuf *	new,
		const struct netbuf *	svc
	)

Definition at line 883 of file rpc_generic.c.

{
#ifdef INET6
    struct sockaddr *sa_new, *sa_svc;
    struct sockaddr_in6 *sin6_new, *sin6_svc;
 
    sa_svc = (struct sockaddr *)svc->buf;
    sa_new = (struct sockaddr *)new->buf;
 
    if (sa_new->sa_family == sa_svc->sa_family &&
        sa_new->sa_family == AF_INET6) {
        sin6_new = (struct sockaddr_in6 *)new->buf;
        sin6_svc = (struct sockaddr_in6 *)svc->buf;
 
        if ((IN6_IS_ADDR_LINKLOCAL(&sin6_new->sin6_addr) &&
             IN6_IS_ADDR_LINKLOCAL(&sin6_svc->sin6_addr)) ||
            (IN6_IS_ADDR_SITELOCAL(&sin6_new->sin6_addr) &&
             IN6_IS_ADDR_SITELOCAL(&sin6_svc->sin6_addr))) {
            sin6_new->sin6_scope_id = sin6_svc->sin6_scope_id;
        }
    }
#endif
    return 1;
}

__rpc_get_a_size()

__BEGIN_DECLS u_int __rpc_get_a_size

(

int

af

)

Definition at line 172 of file rpc_generic.c.

{
    switch (af) {
    case AF_INET:
        return sizeof (struct sockaddr_in);
#ifdef INET6
    case AF_INET6:
        return sizeof (struct sockaddr_in6);
#endif
#ifdef AF_LOCAL
    case AF_LOCAL:
        return sizeof (struct sockaddr_un);
#endif
    default:
        break;
    }
    return ((u_int)RPC_MAXADDRSIZE);
}

Referenced by __rpc_nconf2sockinfo().

__rpc_get_default_domain()

int __rpc_get_default_domain

(

char **

domain

)

Definition at line 72 of file rpcdname.c.

{
    if ((*domain = get_default_domain()) != 0)
        return (0);
    return (-1);
}

__rpc_seman2socktype()

int __rpc_seman2socktype

(

int

semantics

)

Definition at line 842 of file rpc_generic.c.

{
    switch (semantics) {
    case NC_TPI_CLTS:
        return SOCK_DGRAM;
    case NC_TPI_COTS_ORD:
        return SOCK_STREAM;
    case NC_TPI_RAW:
        return SOCK_RAW;
    default:
        break;
    }
 
    return -1;
}

Referenced by __rpc_nconf2sockinfo().

__rpc_sockinfo2netid()

int __rpc_sockinfo2netid	(	struct __rpc_sockinfo *	sip,
		const char **	netid
	)

Definition at line 580 of file rpc_generic.c.

{
    int i;
    struct netconfig *nconf;
 
    nconf = getnetconfigent("local");
 
    for (i = 0; i < (sizeof na_cvt) / (sizeof (struct netid_af)); i++) {
        if (na_cvt[i].af == sip->si_af &&
            na_cvt[i].protocol == sip->si_proto) {
            if (strcmp(na_cvt[i].netid, "local") == 0 && nconf == NULL) {
                if (netid)
                    *netid = "unix";
            } else {
                if (netid)
                    *netid = na_cvt[i].netid;
            }
            if (nconf != NULL)
                freenetconfigent(nconf);
            return 1;
        }
    }
    if (nconf != NULL)
        freenetconfigent(nconf);
 
    return 0;
}

Referenced by __rpcgettp().

__rpc_sockisbound()

int __rpc_sockisbound

(

SOCKET

fd

)

Definition at line 909 of file rpc_generic.c.

{
    struct sockaddr_storage ss;
    union {
        struct sockaddr_in  sin;
        struct sockaddr_in6 sin6;
#ifdef AF_LOCAL
        struct sockaddr_un  usin;
#endif
    } u_addr;
    socklen_t slen;
 
    slen = sizeof (struct sockaddr_storage);
    if (getsockname(fd, (struct sockaddr *)(void *)&ss, &slen) == SOCKET_ERROR)
        return 0;
 
    switch (ss.ss_family) {
        case AF_INET:
            memcpy(&u_addr.sin, &ss, sizeof(u_addr.sin)); 
            return (u_addr.sin.sin_port != 0);
#ifdef INET6
        case AF_INET6:
            memcpy(&u_addr.sin6, &ss, sizeof(u_addr.sin6)); 
            return (u_addr.sin6.sin6_port != 0);
#endif
#ifdef AF_LOCAL
        case AF_LOCAL:
            /* XXX check this */
            memcpy(&u_addr.usin, &ss, sizeof(u_addr.usin)); 
            return (u_addr.usin.sun_path[0] != 0);
#endif
        default:
            break;
    }
 
    return 0;
}

__rpc_socktype2seman()

int __rpc_socktype2seman

(

int

socktype

)

Definition at line 859 of file rpc_generic.c.

{
    switch (socktype) {
    case SOCK_DGRAM:
        return NC_TPI_CLTS;
    case SOCK_STREAM:
        return NC_TPI_COTS_ORD;
    case SOCK_RAW:
        return NC_TPI_RAW;
    default:
        break;
    }
 
    return -1;
}

__rpc_taddr2uaddr_af()

char * __rpc_taddr2uaddr_af	(	int	af,
		const struct netbuf *	nbuf
	)

Definition at line 663 of file rpc_generic.c.

{
    char *ret;
    struct sockaddr_in *sin;
#ifdef AF_LOCAL
    struct sockaddr_un *sun;
#endif
    char namebuf[INET_ADDRSTRLEN];
#ifdef INET6
    struct sockaddr_in6 *sin6;
    char namebuf6[INET6_ADDRSTRLEN];
#endif
    u_int16_t port;
 
    if (nbuf->len <= 0)
        return NULL;
 
    switch (af) {
    case AF_INET:
#ifdef __REACTOS__ // CVE-2017-8779
        if (nbuf->len < sizeof(*sin)) {
            return NULL;
        }
#endif
        sin = nbuf->buf;
        if (inet_ntop(af, &sin->sin_addr, namebuf, sizeof namebuf)
            == NULL)
            return NULL;
        port = ntohs(sin->sin_port);
        if (asprintf(&ret, "%s.%u.%u", namebuf, ((u_int32_t)port) >> 8,
            port & 0xff) < 0)
            return NULL;
        break;
#ifdef INET6
    case AF_INET6:
#ifdef __REACTOS__ // CVE-2017-8779
        if (nbuf->len < sizeof(*sin6)) {
            return NULL;
        }
#endif
        sin6 = nbuf->buf;
        if (inet_ntop(af, &sin6->sin6_addr, namebuf6, sizeof namebuf6)
            == NULL)
            return NULL;
        port = ntohs(sin6->sin6_port);
        if (asprintf(&ret, "%s.%u.%u", namebuf6, ((u_int32_t)port) >> 8,
            port & 0xff) < 0)
            return NULL;
        break;
#endif
#ifdef AF_LOCAL
    case AF_LOCAL:
        sun = nbuf->buf;
        /*  if (asprintf(&ret, "%.*s", (int)(sun->sun_len -
            offsetof(struct sockaddr_un, sun_path)),
            sun->sun_path) < 0)*/
        if (asprintf(&ret, "%.*s", (int)(sizeof(*sun) -
                         offsetof(struct sockaddr_un, sun_path)),
                 sun->sun_path) < 0)
 
            return (NULL);
        break;
#endif
    default:
        return NULL;
    }
 
    return ret;
}

Referenced by taddr2uaddr().

__rpc_uaddr2taddr_af()

struct netbuf * __rpc_uaddr2taddr_af	(	int	af,
		const char *	uaddr
	)

Definition at line 734 of file rpc_generic.c.

{
    struct netbuf *ret = NULL;
    char *addrstr, *p;
    unsigned short port, portlo, porthi;
    struct sockaddr_in *sin;
#ifdef INET6
    struct sockaddr_in6 *sin6;
#endif
#ifdef AF_LOCAL
    struct sockaddr_un *sun;
#endif
 
    port = 0;
    sin = NULL;
#ifdef __REACTOS__ // CVE-2017-8779
    if (uaddr == NULL)
        return NULL;
#endif
    addrstr = strdup(uaddr);
    if (addrstr == NULL)
        return NULL;
 
    /*
     * AF_LOCAL addresses are expected to be absolute
     * pathnames, anything else will be AF_INET or AF_INET6.
     */
    if (*addrstr != '/') {
        p = strrchr(addrstr, '.');
        if (p == NULL)
            goto out;
        portlo = (unsigned)atoi(p + 1);
        *p = '\0';
 
        p = strrchr(addrstr, '.');
        if (p == NULL)
            goto out;
        porthi = (unsigned)atoi(p + 1);
        *p = '\0';
        port = (porthi << 8) | portlo;
    }
 
    ret = (struct netbuf *)malloc(sizeof *ret);
    if (ret == NULL)
        goto out;
    
    switch (af) {
    case AF_INET:
        sin = (struct sockaddr_in *)malloc(sizeof *sin);
        if (sin == NULL)
            goto out;
        memset(sin, 0, sizeof *sin);
        sin->sin_family = AF_INET;
        sin->sin_port = htons(port);
#ifndef __REACTOS__
        if (inet_pton(AF_INET, addrstr, &sin->sin_addr) <= 0) {
#else
        sin->sin_addr.S_un.S_addr = inet_addr(addrstr);
        if (sin->sin_addr.S_un.S_addr == INADDR_NONE) {
#endif
            free(sin);
            free(ret);
            ret = NULL;
            goto out;
        }
        ret->maxlen = ret->len = sizeof *sin;
        ret->buf = sin;
        break;
#ifdef INET6
    case AF_INET6:
        sin6 = (struct sockaddr_in6 *)malloc(sizeof *sin6);
        if (sin6 == NULL)
            goto out;
        memset(sin6, 0, sizeof *sin6);
        sin6->sin6_family = AF_INET6;
        sin6->sin6_port = htons(port);
        if (inet_pton(AF_INET6, addrstr, &sin6->sin6_addr) <= 0) {
            free(sin6);
            free(ret);
            ret = NULL;
            goto out;
        }
        ret->maxlen = ret->len = sizeof *sin6;
        ret->buf = sin6;
        break;
#endif
#ifdef AF_LOCAL
    case AF_LOCAL:
        sun = (struct sockaddr_un *)malloc(sizeof *sun);
        if (sun == NULL)
            goto out;
        memset(sun, 0, sizeof *sun);
        sun->sun_family = AF_LOCAL;
        strncpy(sun->sun_path, addrstr, sizeof(sun->sun_path) - 1);
        ret->len = SUN_LEN(sun);
        ret->maxlen = sizeof(struct sockaddr_un);
        ret->buf = sun;
        break;
#endif
    default:
        break;
    }
out:
    free(addrstr);
    return ret;
}

Referenced by uaddr2taddr().

__rpcb_findaddr()

struct netbuf * __rpcb_findaddr	(	rpcprog_t	,
		rpcvers_t	,
		const struct netconfig *	,
		const char *	,
		CLIENT **
	)

__rpcgettp()

struct netconfig * __rpcgettp

(

int

)

_get_next_token()

char * _get_next_token	(	char *	npp,
		int	token
	)

Definition at line 228 of file getnetpath.c.

{
    char  *cp;      /* char pointer */
    char  *np;      /* netpath pointer */
    char  *ep;      /* escape pointer */
 
    if ((cp = strchr(npp, token)) == NULL) {
    return (NULL);
    }
    /*
     * did find a token, but it might be escaped.
     */
    if ((cp > npp) && (cp[-1] == '\\')) {
        /* if slash was also escaped, carry on, otherwise find next token */
    if ((cp > npp + 1) && (cp[-2] != '\\')) {
        /* shift r-o-s  onto the escaped token */
        strcpy(&cp[-1], cp);    /* XXX: overlapping string copy */
        /*
         * Do a recursive call.
         * We don't know how many escaped tokens there might be.
         */
        return (_get_next_token(cp, token));
    }
    }
 
    *cp++ = '\0';       /* null-terminate token */
    /* get rid of any backslash escapes */
    ep = npp;
    while ((np = strchr(ep, '\\')) != 0) {
    if (np[1] == '\\')
        np++;
    strcpy(np, (ep = &np[1]));  /* XXX: overlapping string copy */
    }
    return (cp);        /* return ptr to r-o-s */
}

Referenced by _get_next_token(), getnetpath(), and parse_ncp().

_rpc_dtablesize()

int _rpc_dtablesize

(

void

)

Definition at line 48 of file rpc_dtablesize.c.

{
#ifdef _WIN32
    return FD_SETSIZE;
#else
    static int size;
 
    if (size == 0) {
        size = getdtablesize();
        if (size > FD_SETSIZE)
            size = FD_SETSIZE;
    }
    return (size);
#endif
}

Referenced by __rpc_get_time_offset().

rpc_control()

bool_t rpc_control	(	int	what,
		void *	arg
	)

Definition at line 784 of file svc.c.

{
  int val;
 
  switch (what)
    {
    case RPC_SVC_CONNMAXREC_SET:
      val = *(int *) arg;
      if (val <= 0)
    return FALSE;
      __svc_maxrec = val;
      return TRUE;
    case RPC_SVC_CONNMAXREC_GET:
      *(int *) arg = __svc_maxrec;
      return TRUE;
    default:
      break;
    }
  return FALSE;
}

rpc_nullproc()

void * rpc_nullproc

(

CLIENT *

clnt

)

Definition at line 447 of file rpc_generic.c.

{
    struct timeval TIMEOUT = {25, 0};
 
    if (clnt_call(clnt, NULLPROC, (xdrproc_t) xdr_void, NULL,
        (xdrproc_t) xdr_void, NULL, TIMEOUT) != RPC_SUCCESS) {
        return (NULL);
    }
    return ((void *) clnt);
}