---

rpc_host.cc

Go to the documentation of this file.

#include "rcs_defs.hh"          /* EXTERN_C_STD_HEADERS  */

#ifdef EXTERN_C_STD_HEADERS
extern "C"
{
#endif
#include <string.h>
#include <stdlib.h>

#include <rpc/rpc.h>            /* CLIENT */
#ifdef __MSDOS__
#include <rpc/p_prot.h>
#include <rpc/p_clnt.h>
#include <rpc/clnt.h>
#include <netinet/in.h>         /* struct sockaddr_in */
#else
#include <rpc/pmap_prot.h>

#ifndef sunos4
#include <rpc/pmap_clnt.h>
#else
  extern bool_t pmap_set ();
  extern bool_t pmap_unset ();
  extern struct pmaplist *pmap_getmaps (struct sockaddr_in *);
  enum clnt_stat pmap_rmtcall ();
  enum clnt_stat clnt_broadcast ();
  extern u_short pmap_getport ();

#endif
#endif

#include <sys/types.h>          /* u_short (needed by socket.h) */
  /* u_char (needed by netinet/in.h) */
#ifdef VXWORKS
#include <hostLib.h>            /* getHostByName() */
#include <rpcLib.h>             /* rpcTaskInit() */
#else
#include <netdb.h>              /* gethostbyname(), struct hostent */
#endif
#include <sys/socket.h>         /* AF_INET,sockaddr_in  */

#ifdef EXTERN_C_STD_HEADERS
}
#endif

#include "rpc_host.hh"
#include "rcs_prnt.hh"          /* rcs_print_error() */

RPC_HOST::RPC_HOST (char *host_name)
{
  name = NULL;
  socket_address = NULL;
#ifndef VXWORKS
  host_entry = NULL;
#endif
  name = (char *) malloc (strlen (host_name) + 1);
  if (NULL != name)
    {
      strcpy (name, host_name);
    }
  else
    {
      rcs_print_error ("RPC_HOST: Couldn't malloc space for name.\n");
      return;
    }

#ifndef VXWORKS
  host_entry = gethostbyname (name);
  if (NULL == host_entry)
    {
      rcs_print_error ("RPC_HOST: Error from gethostbyname. \n");
      return;
    }
  socket_address = new sockaddr_in;
  if (NULL != socket_address)
    {
#ifdef __MSDOS__
      socket_address->sin_addr.s_addr =
        *((u_long *) host_entry->h_addr_list[0]);
#else
      socket_address->sin_addr.s_addr = *((int *) host_entry->h_addr_list[0]);
#endif
      socket_address->sin_family = host_entry->h_addrtype;
    }
#else
  rpcTaskInit ();
  socket_address = new sockaddr_in;
  if (NULL != socket_address)
    {
      socket_address->sin_addr.s_addr = hostGetByName (name);
      if (socket_address->sin_addr.s_addr == ERROR)
        {
          rcs_print_error ("RPC_HOST: Couldn't get host address for (%s).\n",
                           name);
          delete socket_address;
          socket_address = NULL;
          return;
        }
      socket_address->sin_family = AF_INET;
    }
#endif
}


RPC_HOST::~RPC_HOST ()
{
  if (NULL != name)
    {
      free (name);
      name = NULL;
    }
  if (NULL != socket_address)
    {
      delete socket_address;
      socket_address = NULL;
    }
}

int
RPC_HOST::check_if_prog_registered (unsigned long prog)
{
  if (NULL == socket_address)
    {
      return -1;
    }
#ifdef MSDOS
  pmap_entry = (pmaplist RCS_FAR *) pmap_getmaps (
                                                  ((sockaddr_in far *)
                                                   socket_address));
#else
  pmap_entry = (pmaplist RCS_FAR *) pmap_getmaps (socket_address);
#endif
  if (NULL == pmap_entry)
    {
      return (-1);
    }
  int retval = 0;
  while (NULL != pmap_entry)
    {
      pmaplist *next_entry;
      if (pmap_entry->pml_map.pm_prog == prog &&
          pmap_entry->pml_map.pm_prot == IPPROTO_TCP)
        {
          retval = 1;
        }
      next_entry = pmap_entry->pml_next;
      delete pmap_entry;
      pmap_entry = next_entry;
    }
  return retval;
}

---