Back to index

glibc  2.9
Classes | Defines | Typedefs | Functions | Variables
svc_udp.c File Reference
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <rpc/rpc.h>
#include <sys/socket.h>
#include <errno.h>
#include <libintl.h>

Go to the source code of this file.

Classes

struct  svcudp_data
struct  cache_node
struct  udp_cache

Defines

#define rpc_buffer(xprt)   ((xprt)->xp_p1)
#define MAX(a, b)   ((a > b) ? a : b)
#define su_data(xprt)   ((struct svcudp_data *)(xprt->xp_p2))
#define SPARSENESS   4 /* 75% sparse */
#define CACHE_PERROR(msg)   (void) __fxprintf(NULL, "%s\n", msg)
#define ALLOC(type, size)   (type *) mem_alloc((unsigned) (sizeof(type) * (size)))
#define CALLOC(type, size)   (type *) calloc (sizeof (type), size)
#define CACHE_LOC(transp, xid)   (xid % (SPARSENESS*((struct udp_cache *) su_data(transp)->su_cache)->uc_size))
#define EQADDR(a1, a2)   (memcmp((char*)&a1, (char*)&a2, sizeof(a1)) == 0)

Typedefs

typedef struct cache_nodecache_ptr

Functions

static bool_t svcudp_recv (SVCXPRT *, struct rpc_msg *)
static bool_t svcudp_reply (SVCXPRT *, struct rpc_msg *)
static enum xprt_stat svcudp_stat (SVCXPRT *)
static bool_t svcudp_getargs (SVCXPRT *, xdrproc_t, caddr_t)
static bool_t svcudp_freeargs (SVCXPRT *, xdrproc_t, caddr_t)
static void svcudp_destroy (SVCXPRT *)
static int cache_get (SVCXPRT *, struct rpc_msg *, char **replyp, u_long *replylenp)
static void cache_set (SVCXPRT *xprt, u_long replylen)
SVCXPRTsvcudp_bufcreate (int sock, u_int sendsz, u_int recvsz)
SVCXPRTsvcudp_create (int sock)
int svcudp_enablecache (SVCXPRT *transp, u_long size)

Variables

static struct xp_ops

Class Documentation

struct svcudp_data

Definition at line 88 of file svc_udp.c.

Class Members
char * su_cache
u_int su_iosz
char su_verfbody
XDR su_xdrs
u_long su_xid
struct cache_node

Definition at line 417 of file svc_udp.c.

Collaboration diagram for cache_node:
Class Members
cache_ptr cache_next
u_long cache_proc
u_long cache_prog
char * cache_reply
u_long cache_replylen
u_long cache_vers
u_long cache_xid
struct udp_cache

Definition at line 443 of file svc_udp.c.

Collaboration diagram for udp_cache:
Class Members
cache_ptr * uc_entries
cache_ptr * uc_fifo
u_long uc_nextvictim
u_long uc_proc
u_long uc_prog
u_long uc_size
u_long uc_vers

Define Documentation

#define ALLOC (   type,
  size 
)    (type *) mem_alloc((unsigned) (sizeof(type) * (size)))

Definition at line 407 of file svc_udp.c.

#define CACHE_LOC (   transp,
  xid 
)    (xid % (SPARSENESS*((struct udp_cache *) su_data(transp)->su_cache)->uc_size))

Definition at line 459 of file svc_udp.c.

#define CACHE_PERROR (   msg)    (void) __fxprintf(NULL, "%s\n", msg)

Definition at line 404 of file svc_udp.c.

#define CALLOC (   type,
  size 
)    (type *) calloc (sizeof (type), size)

Definition at line 410 of file svc_udp.c.

#define EQADDR (   a1,
  a2 
)    (memcmp((char*)&a1, (char*)&a2, sizeof(a1)) == 0)
#define MAX (   a,
  b 
)    ((a > b) ? a : b)

Definition at line 61 of file svc_udp.c.

#define rpc_buffer (   xprt)    ((xprt)->xp_p1)

Definition at line 59 of file svc_udp.c.

#define SPARSENESS   4 /* 75% sparse */

Definition at line 402 of file svc_udp.c.

#define su_data (   xprt)    ((struct svcudp_data *)(xprt->xp_p2))

Definition at line 96 of file svc_udp.c.


Typedef Documentation

typedef struct cache_node* cache_ptr

Definition at line 416 of file svc_udp.c.


Function Documentation

static int cache_get ( SVCXPRT xprt,
struct rpc_msg msg,
char **  replyp,
u_long replylenp 
) [static]

Definition at line 581 of file svc_udp.c.

{
  u_int loc;
  cache_ptr ent;
  struct svcudp_data *su = su_data (xprt);
  struct udp_cache *uc = (struct udp_cache *) su->su_cache;

#define EQADDR(a1, a2)      (memcmp((char*)&a1, (char*)&a2, sizeof(a1)) == 0)

  loc = CACHE_LOC (xprt, su->su_xid);
  for (ent = uc->uc_entries[loc]; ent != NULL; ent = ent->cache_next)
    {
      if (ent->cache_xid == su->su_xid &&
         ent->cache_proc == uc->uc_proc &&
         ent->cache_vers == uc->uc_vers &&
         ent->cache_prog == uc->uc_prog &&
         EQADDR (ent->cache_addr, uc->uc_addr))
       {
         *replyp = ent->cache_reply;
         *replylenp = ent->cache_replylen;
         return 1;
       }
    }
  /*
   * Failed to find entry
   * Remember a few things so we can do a set later
   */
  uc->uc_proc = msg->rm_call.cb_proc;
  uc->uc_vers = msg->rm_call.cb_vers;
  uc->uc_prog = msg->rm_call.cb_prog;
  memcpy (&uc->uc_addr, &xprt->xp_raddr, sizeof (uc->uc_addr));
  return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

static void cache_set ( SVCXPRT xprt,
u_long  replylen 
) [static]

Definition at line 510 of file svc_udp.c.

{
  cache_ptr victim;
  cache_ptr *vicp;
  struct svcudp_data *su = su_data (xprt);
  struct udp_cache *uc = (struct udp_cache *) su->su_cache;
  u_int loc;
  char *newbuf;

  /*
   * Find space for the new entry, either by
   * reusing an old entry, or by mallocing a new one
   */
  victim = uc->uc_fifo[uc->uc_nextvictim];
  if (victim != NULL)
    {
      loc = CACHE_LOC (xprt, victim->cache_xid);
      for (vicp = &uc->uc_entries[loc];
          *vicp != NULL && *vicp != victim;
          vicp = &(*vicp)->cache_next)
       ;
      if (*vicp == NULL)
       {
         CACHE_PERROR (_("cache_set: victim not found"));
         return;
       }
      *vicp = victim->cache_next;  /* remote from cache */
      newbuf = victim->cache_reply;
    }
  else
    {
      victim = ALLOC (struct cache_node, 1);
      if (victim == NULL)
       {
         CACHE_PERROR (_("cache_set: victim alloc failed"));
         return;
       }
      newbuf = mem_alloc (su->su_iosz);
      if (newbuf == NULL)
       {
         mem_free (victim, sizeof (struct cache_node));
         CACHE_PERROR (_("cache_set: could not allocate new rpc_buffer"));
         return;
       }
    }

  /*
   * Store it away
   */
  victim->cache_replylen = replylen;
  victim->cache_reply = rpc_buffer (xprt);
  rpc_buffer (xprt) = newbuf;
  INTUSE(xdrmem_create) (&(su->su_xdrs), rpc_buffer (xprt), su->su_iosz,
                      XDR_ENCODE);
  victim->cache_xid = su->su_xid;
  victim->cache_proc = uc->uc_proc;
  victim->cache_vers = uc->uc_vers;
  victim->cache_prog = uc->uc_prog;
  victim->cache_addr = uc->uc_addr;
  loc = CACHE_LOC (xprt, victim->cache_xid);
  victim->cache_next = uc->uc_entries[loc];
  uc->uc_entries[loc] = victim;
  uc->uc_fifo[uc->uc_nextvictim++] = victim;
  uc->uc_nextvictim %= uc->uc_size;
}

Here is the call graph for this function:

Here is the caller graph for this function:

SVCXPRT* svcudp_bufcreate ( int  sock,
u_int  sendsz,
u_int  recvsz 
)

Definition at line 112 of file svc_udp.c.

{
  bool_t madesock = FALSE;
  SVCXPRT *xprt;
  struct svcudp_data *su;
  struct sockaddr_in addr;
  socklen_t len = sizeof (struct sockaddr_in);
  int pad;
  void *buf;

  if (sock == RPC_ANYSOCK)
    {
      if ((sock = __socket (AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0)
       {
         perror (_("svcudp_create: socket creation problem"));
         return (SVCXPRT *) NULL;
       }
      madesock = TRUE;
    }
  __bzero ((char *) &addr, sizeof (addr));
  addr.sin_family = AF_INET;
  if (bindresvport (sock, &addr))
    {
      addr.sin_port = 0;
      (void) __bind (sock, (struct sockaddr *) &addr, len);
    }
  if (__getsockname (sock, (struct sockaddr *) &addr, &len) != 0)
    {
      perror (_("svcudp_create - cannot getsockname"));
      if (madesock)
       (void) __close (sock);
      return (SVCXPRT *) NULL;
    }
  xprt = (SVCXPRT *) mem_alloc (sizeof (SVCXPRT));
  su = (struct svcudp_data *) mem_alloc (sizeof (*su));
  buf = mem_alloc (((MAX (sendsz, recvsz) + 3) / 4) * 4);
  if (xprt == NULL || su == NULL || buf == NULL)
    {
      (void) __fxprintf (NULL, "%s: %s",
                      "svcudp_create",  _("out of memory\n"));
      mem_free (xprt, sizeof (SVCXPRT));
      mem_free (su, sizeof (*su));
      mem_free (buf, ((MAX (sendsz, recvsz) + 3) / 4) * 4);
      return NULL;
    }
  su->su_iosz = ((MAX (sendsz, recvsz) + 3) / 4) * 4;
  rpc_buffer (xprt) = buf;
  INTUSE(xdrmem_create) (&(su->su_xdrs), rpc_buffer (xprt), su->su_iosz,
                      XDR_DECODE);
  su->su_cache = NULL;
  xprt->xp_p2 = (caddr_t) su;
  xprt->xp_verf.oa_base = su->su_verfbody;
  xprt->xp_ops = &svcudp_op;
  xprt->xp_port = ntohs (addr.sin_port);
  xprt->xp_sock = sock;

#ifdef IP_PKTINFO
  if ((sizeof (struct iovec) + sizeof (struct msghdr)
       + sizeof(struct cmsghdr) + sizeof (struct in_pktinfo))
      > sizeof (xprt->xp_pad))
    {
      (void) __fxprintf (NULL,"%s", _("\
svcudp_create: xp_pad is too small for IP_PKTINFO\n"));
      return NULL;
    }
  pad = 1;
  if (__setsockopt (sock, SOL_IP, IP_PKTINFO, (void *) &pad,
                  sizeof (pad)) == 0)
    /* Set the padding to all 1s. */
    pad = 0xff;
  else
#endif
    /* Clear the padding. */
    pad = 0;
  memset (&xprt->xp_pad [0], pad, sizeof (xprt->xp_pad));

  xprt_register (xprt);
  return xprt;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Definition at line 196 of file svc_udp.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static void svcudp_destroy ( SVCXPRT xprt) [static]

Definition at line 380 of file svc_udp.c.

{
  struct svcudp_data *su = su_data (xprt);

  xprt_unregister (xprt);
  (void) __close (xprt->xp_sock);
  XDR_DESTROY (&(su->su_xdrs));
  mem_free (rpc_buffer (xprt), su->su_iosz);
  mem_free ((caddr_t) su, sizeof (struct svcudp_data));
  mem_free ((caddr_t) xprt, sizeof (SVCXPRT));
}

Here is the call graph for this function:

int svcudp_enablecache ( SVCXPRT transp,
u_long  size 
)

Definition at line 468 of file svc_udp.c.

{
  struct svcudp_data *su = su_data (transp);
  struct udp_cache *uc;

  if (su->su_cache != NULL)
    {
      CACHE_PERROR (_("enablecache: cache already enabled"));
      return 0;
    }
  uc = ALLOC (struct udp_cache, 1);
  if (uc == NULL)
    {
      CACHE_PERROR (_("enablecache: could not allocate cache"));
      return 0;
    }
  uc->uc_size = size;
  uc->uc_nextvictim = 0;
  uc->uc_entries = CALLOC (cache_ptr, size * SPARSENESS);
  if (uc->uc_entries == NULL)
    {
      mem_free (uc, sizeof (struct udp_cache));
      CACHE_PERROR (_("enablecache: could not allocate cache data"));
      return 0;
    }
  uc->uc_fifo = CALLOC (cache_ptr, size);
  if (uc->uc_fifo == NULL)
    {
      mem_free (uc->uc_entries, size * SPARSENESS);
      mem_free (uc, sizeof (struct udp_cache));
      CACHE_PERROR (_("enablecache: could not allocate cache fifo"));
      return 0;
    }
  su->su_cache = (char *) uc;
  return 1;
}
static bool_t svcudp_freeargs ( SVCXPRT xprt,
xdrproc_t  xdr_args,
caddr_t  args_ptr 
) [static]

Definition at line 368 of file svc_udp.c.

{
  XDR *xdrs = &(su_data (xprt)->su_xdrs);

  xdrs->x_op = XDR_FREE;
  return (*xdr_args) (xdrs, args_ptr);
}
static bool_t svcudp_getargs ( SVCXPRT xprt,
xdrproc_t  xdr_args,
caddr_t  args_ptr 
) [static]

Definition at line 358 of file svc_udp.c.

{

  return (*xdr_args) (&(su_data (xprt)->su_xdrs), args_ptr);
}
static bool_t svcudp_recv ( SVCXPRT xprt,
struct rpc_msg msg 
) [static]

Definition at line 212 of file svc_udp.c.

{
  struct svcudp_data *su = su_data (xprt);
  XDR *xdrs = &(su->su_xdrs);
  int rlen;
  char *reply;
  u_long replylen;
  socklen_t len;

  /* It is very tricky when you have IP aliases. We want to make sure
     that we are sending the packet from the IP address where the
     incoming packet is addressed to. H.J. */
#ifdef IP_PKTINFO
  struct iovec *iovp;
  struct msghdr *mesgp;
#endif

again:
  /* FIXME -- should xp_addrlen be a size_t?  */
  len = (socklen_t) sizeof(struct sockaddr_in);
#ifdef IP_PKTINFO
  iovp = (struct iovec *) &xprt->xp_pad [0];
  mesgp = (struct msghdr *) &xprt->xp_pad [sizeof (struct iovec)];
  if (mesgp->msg_iovlen)
    {
      iovp->iov_base = rpc_buffer (xprt);
      iovp->iov_len = su->su_iosz;
      mesgp->msg_iov = iovp;
      mesgp->msg_iovlen = 1;
      mesgp->msg_name = &(xprt->xp_raddr);
      mesgp->msg_namelen = len;
      mesgp->msg_control = &xprt->xp_pad [sizeof (struct iovec)
                                     + sizeof (struct msghdr)];
      mesgp->msg_controllen = sizeof(xprt->xp_pad)
                           - sizeof (struct iovec) - sizeof (struct msghdr);
      rlen = __recvmsg (xprt->xp_sock, mesgp, 0);
      if (rlen >= 0)
       {
         struct cmsghdr *cmsg;
         len = mesgp->msg_namelen;
         cmsg = CMSG_FIRSTHDR (mesgp);
         if (cmsg == NULL
             || CMSG_NXTHDR (mesgp, cmsg) != NULL
             || cmsg->cmsg_level != SOL_IP
             || cmsg->cmsg_type != IP_PKTINFO
             || cmsg->cmsg_len < (sizeof (struct cmsghdr)
                               + sizeof (struct in_pktinfo)))
           {
             /* Not a simple IP_PKTINFO, ignore it.  */
             mesgp->msg_control = NULL;
             mesgp->msg_controllen = 0;
           }
         else
           {
             /* It was a simple IP_PKTIFO as we expected, discard the
               interface field.  */
             struct in_pktinfo *pkti = (struct in_pktinfo *) CMSG_DATA (cmsg);
             pkti->ipi_ifindex = 0;
           }
       }
    }
  else
#endif
    rlen = __recvfrom (xprt->xp_sock, rpc_buffer (xprt),
                     (int) su->su_iosz, 0,
                     (struct sockaddr *) &(xprt->xp_raddr), &len);
  xprt->xp_addrlen = len;
  if (rlen == -1 && errno == EINTR)
    goto again;
  if (rlen < 16)            /* < 4 32-bit ints? */
    return FALSE;
  xdrs->x_op = XDR_DECODE;
  XDR_SETPOS (xdrs, 0);
  if (!INTUSE(xdr_callmsg) (xdrs, msg))
    return FALSE;
  su->su_xid = msg->rm_xid;
  if (su->su_cache != NULL)
    {
      if (cache_get (xprt, msg, &reply, &replylen))
       {
#ifdef IP_PKTINFO
         if (mesgp->msg_iovlen)
           {
             iovp->iov_base = reply;
             iovp->iov_len = replylen;
             (void) __sendmsg (xprt->xp_sock, mesgp, 0);
           }
         else
#endif
           (void) __sendto (xprt->xp_sock, reply, (int) replylen, 0,
                          (struct sockaddr *) &xprt->xp_raddr, len);
         return TRUE;
       }
    }
  return TRUE;
}

Here is the call graph for this function:

static bool_t svcudp_reply ( SVCXPRT xprt,
struct rpc_msg msg 
) [static]

Definition at line 312 of file svc_udp.c.

{
  struct svcudp_data *su = su_data (xprt);
  XDR *xdrs = &(su->su_xdrs);
  int slen, sent;
  bool_t stat = FALSE;
#ifdef IP_PKTINFO
  struct iovec *iovp;
  struct msghdr *mesgp;
#endif

  xdrs->x_op = XDR_ENCODE;
  XDR_SETPOS (xdrs, 0);
  msg->rm_xid = su->su_xid;
  if (INTUSE(xdr_replymsg) (xdrs, msg))
    {
      slen = (int) XDR_GETPOS (xdrs);
#ifdef IP_PKTINFO
      mesgp = (struct msghdr *) &xprt->xp_pad [sizeof (struct iovec)];
      if (mesgp->msg_iovlen)
       {
         iovp = (struct iovec *) &xprt->xp_pad [0];
         iovp->iov_base = rpc_buffer (xprt);
         iovp->iov_len = slen;
         sent = __sendmsg (xprt->xp_sock, mesgp, 0);
       }
      else
#endif
       sent = __sendto (xprt->xp_sock, rpc_buffer (xprt), slen, 0,
                      (struct sockaddr *) &(xprt->xp_raddr),
                      xprt->xp_addrlen);
      if (sent == slen)
       {
         stat = TRUE;
         if (su->su_cache && slen >= 0)
           {
             cache_set (xprt, (u_long) slen);
           }
       }
    }
  return stat;
}

Here is the call graph for this function:

static enum xprt_stat svcudp_stat ( SVCXPRT xprt) [static]

Definition at line 204 of file svc_udp.c.

{

  return XPRT_IDLE;
}

Variable Documentation

struct xp_ops [static]
Initial value:

Definition at line 71 of file svc_udp.c.