home *** CD-ROM | disk | FTP | other *** search
/ Fresh Fish 8 / FreshFishVol8-CD2.bin / bbs / comm / amitcp-3.0ß2.lha / AmiTCP / src / util / portmap / portmap.c next >
C/C++ Source or Header  |  1994-05-03  |  12KB  |  498 lines
  1. RCS_ID_C="$Id: portmap.c,v 3.9 1994/05/02 19:52:55 jraja Exp $";
  2. /*
  3.  * portmap.c -- implements the program, version to port number mapping for rpc
  4.  */
  5.  
  6. #include "portmap_rev.h"
  7.  
  8. static const char version[] = VERSTAG
  9. " Copyright © 1994 AmiTCP/IP Group, <amitcp-group@hut.fi>\n"
  10. "Helsinki University of Technology, Finland.\n"
  11. "Copyright © 1990 The Regents of the University of California.\n"
  12. "All rights reserved.\n";
  13.  
  14. /****** netutil.doc/portmap *************************************************
  15.     NAME
  16.         portmap - DARPA port to RPC program number mapper
  17.  
  18.     SYNOPSIS
  19.         AmiTCP:bin/portmap
  20.  
  21.     DESCRIPTION
  22.         `portmap' is a server that converts RPC program numbers into DARPA
  23.         protocol port numbers.  It must be running in order to make RPC
  24.         calls.  When an RPC server is started, it will tell `portmap' what
  25.         port number it is listening to, and what RPC program numbers it is
  26.         prepared to serve.  When a client wishes to make an RPC call to a
  27.         given program number, it will first contact `portmap' on the
  28.         server machine to determine the port number where RPC packets
  29.         should be sent.  Normally, standard RPC servers are started by
  30.         `inetd', so `portmap' must be started before `inetd' is invoked.
  31.  
  32.     SEE ALSO
  33.         netutil.doc/rpcinfo
  34.  
  35.     BUGS
  36.         If `portmap' crashes, all servers must be restarted.
  37.  
  38. *****************************************************************************
  39. * 
  40. */
  41.  
  42. /*
  43.  * @(#)portmap.c 5.4 (Berkeley) 4/19/91
  44.  * @(#)portmap.c 2.3 88/08/11 4.0 RPCSRC
  45.  * @(#)portmap.c 1.32 87/08/06 Copyr 1984 Sun Micro";
  46.  */
  47.  
  48. #include <rpc/rpc.h>
  49. #include <rpc/pmap_prot.h>
  50. #include <sys/syslog.h>
  51. #include <sys/socket.h>
  52. #include <sys/ioctl.h>
  53. #include <netdb.h>
  54. #include <errno.h>
  55. #include <stdio.h>
  56. #include <stdlib.h>
  57. #include <string.h>
  58. #include <signal.h>
  59.  
  60. void reg_service(struct svc_req *rqstp, SVCXPRT *xprt);
  61. static void callit(struct svc_req *rqstp, SVCXPRT *xprt);
  62.  
  63. struct pmaplist *pmaplist;
  64. int debugging = 0;
  65.  
  66. main(int argc, char **argv)
  67. {
  68.     SVCXPRT *xprt;
  69.     int sock, c;
  70.     struct sockaddr_in addr = { 0 };
  71.     int len = sizeof(struct sockaddr_in);
  72.     register struct pmaplist *pml;
  73.  
  74.     signal(SIGINT, SIG_IGN); /* Prevent ANSI Signal handling */
  75.  
  76.     while ((c = getopt(argc, argv, "d")) != EOF) {
  77.         switch (c) {
  78.  
  79.         case 'd':
  80.             debugging = 1;
  81.             break;
  82.  
  83.         default:
  84.             (void) fprintf(stderr, "usage: %s [-d]\n", argv[0]);
  85.             exit(1);
  86.         }
  87.     }
  88.  
  89.     openlog("portmap", debugging ? LOG_PID | LOG_PERROR : LOG_PID,
  90.         LOG_DAEMON);
  91. #ifndef amigados
  92.     if (!debugging && daemon(0, 0)) {
  93.         (void) fprintf(stderr, "portmap: fork: %s", strerror(errno));
  94.         exit(1);
  95.     }
  96. #else
  97.     /*
  98.      * We could probably detach here, but don't bother now...
  99.      */
  100. #endif
  101.  
  102.     if ((sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0) {
  103.         syslog(LOG_ERR, "cannot create udp socket: %m");
  104.         exit(1);
  105.     }
  106.  
  107.     addr.sin_addr.s_addr = 0;
  108.     addr.sin_family = AF_INET;
  109.     addr.sin_port = htons(PMAPPORT);
  110.     if (bind(sock, (struct sockaddr *)&addr, len) != 0) {
  111.         syslog(LOG_ERR, "cannot bind udp: %m");
  112.         exit(1);
  113.     }
  114.  
  115.     if ((xprt = svcudp_create(sock)) == (SVCXPRT *)NULL) {
  116.         syslog(LOG_ERR, "couldn't do udp_create");
  117.         exit(1);
  118.     }
  119.     /* make an entry for ourself */
  120.     pml = (struct pmaplist *)malloc((u_int)sizeof(struct pmaplist));
  121.     pml->pml_next = 0;
  122.     pml->pml_map.pm_prog = PMAPPROG;
  123.     pml->pml_map.pm_vers = PMAPVERS;
  124.     pml->pml_map.pm_prot = IPPROTO_UDP;
  125.     pml->pml_map.pm_port = PMAPPORT;
  126.     pmaplist = pml;
  127.  
  128.     if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) {
  129.         syslog(LOG_ERR, "cannot create tcp socket: %m");
  130.         exit(1);
  131.     }
  132.     if (bind(sock, (struct sockaddr *)&addr, len) != 0) {
  133.         syslog(LOG_ERR, "cannot bind udp: %m");
  134.         exit(1);
  135.     }
  136.     if ((xprt = svctcp_create(sock, RPCSMALLMSGSIZE, RPCSMALLMSGSIZE))
  137.         == (SVCXPRT *)NULL) {
  138.         syslog(LOG_ERR, "couldn't do tcp_create");
  139.         exit(1);
  140.     }
  141.     /* make an entry for ourself */
  142.     pml = (struct pmaplist *)malloc((u_int)sizeof(struct pmaplist));
  143.     pml->pml_map.pm_prog = PMAPPROG;
  144.     pml->pml_map.pm_vers = PMAPVERS;
  145.     pml->pml_map.pm_prot = IPPROTO_TCP;
  146.     pml->pml_map.pm_port = PMAPPORT;
  147.     pml->pml_next = pmaplist;
  148.     pmaplist = pml;
  149.  
  150.     (void)svc_register(xprt, PMAPPROG, PMAPVERS, reg_service, FALSE);
  151.  
  152.     svc_run();
  153.     syslog(LOG_ERR, "svc_run returned unexpectedly");
  154.     exit(0);
  155. }
  156.  
  157. /*
  158.  * Overrides the strlib perror
  159.  */
  160. void
  161. perror(const char *what)
  162. {
  163.     syslog(LOG_ERR, "%s: %m", what);
  164. }
  165.  
  166. static struct pmaplist *
  167. find_service(u_long prog, u_long vers, u_long prot)
  168. {
  169.     register struct pmaplist *hit = NULL;
  170.     register struct pmaplist *pml;
  171.  
  172.     for (pml = pmaplist; pml != NULL; pml = pml->pml_next) {
  173.         if ((pml->pml_map.pm_prog != prog) ||
  174.             (pml->pml_map.pm_prot != prot))
  175.             continue;
  176.         hit = pml;
  177.         if (pml->pml_map.pm_vers == vers)
  178.             break;
  179.     }
  180.     return (hit);
  181. }
  182.  
  183. /* 
  184.  * 1 OK, 0 not
  185.  */
  186. void
  187. reg_service(struct svc_req *rqstp, SVCXPRT *xprt)
  188. {
  189.     struct pmap reg;
  190.     struct pmaplist *pml, *prevpml, *fnd;
  191.     int ans, port;
  192.     caddr_t t;
  193.     
  194.     if (debugging)
  195.         (void) fprintf(stderr, "server: about do a switch\n");
  196.     switch (rqstp->rq_proc) {
  197.  
  198.     case PMAPPROC_NULL:
  199.         /*
  200.          * Null proc call
  201.          */
  202.         if (!svc_sendreply(xprt, xdr_void, (caddr_t)0) && debugging) {
  203.             exit(20);
  204.         }
  205.         break;
  206.  
  207.     case PMAPPROC_SET:
  208.         /*
  209.          * Set a program,version to port mapping
  210.          */
  211.         if (!svc_getargs(xprt, xdr_pmap, ®))
  212.             svcerr_decode(xprt);
  213.         else {
  214.             /*
  215.              * check to see if already used
  216.              * find_service returns a hit even if
  217.              * the versions don't match, so check for it
  218.              */
  219.             fnd = find_service(reg.pm_prog, reg.pm_vers, reg.pm_prot);
  220.             if (fnd && fnd->pml_map.pm_vers == reg.pm_vers) {
  221.                 if (fnd->pml_map.pm_port == reg.pm_port) {
  222.                     ans = 1;
  223.                     goto done;
  224.                 }
  225.                 else {
  226.                     ans = 0;
  227.                     goto done;
  228.                 }
  229.             } else {
  230.                 /* 
  231.                  * add to END of list
  232.                  */
  233.                 pml = (struct pmaplist *)
  234.                     malloc((u_int)sizeof(struct pmaplist));
  235.                 pml->pml_map = reg;
  236.                 pml->pml_next = 0;
  237.                 if (pmaplist == 0) {
  238.                     pmaplist = pml;
  239.                 } else {
  240.                     for (fnd= pmaplist; fnd->pml_next != 0;
  241.                         fnd = fnd->pml_next);
  242.                     fnd->pml_next = pml;
  243.                 }
  244.                 ans = 1;
  245.             }
  246.         done:
  247.             if ((!svc_sendreply(xprt, xdr_long, (caddr_t)&ans)) &&
  248.                 debugging) {
  249.                 (void) fprintf(stderr, "svc_sendreply\n");
  250.                 exit(20);
  251.             }
  252.         }
  253.         break;
  254.  
  255.     case PMAPPROC_UNSET:
  256.         /*
  257.          * Remove a program,version to port mapping.
  258.          */
  259.         if (!svc_getargs(xprt, xdr_pmap, ®))
  260.             svcerr_decode(xprt);
  261.         else {
  262.             ans = 0;
  263.             for (prevpml = NULL, pml = pmaplist; pml != NULL; ) {
  264.                 if ((pml->pml_map.pm_prog != reg.pm_prog) ||
  265.                     (pml->pml_map.pm_vers != reg.pm_vers)) {
  266.                     /* both pml & prevpml move forwards */
  267.                     prevpml = pml;
  268.                     pml = pml->pml_next;
  269.                     continue;
  270.                 }
  271.                 /* found it; pml moves forward, prevpml stays */
  272.                 ans = 1;
  273.                 t = (caddr_t)pml;
  274.                 pml = pml->pml_next;
  275.                 if (prevpml == NULL)
  276.                     pmaplist = pml;
  277.                 else
  278.                     prevpml->pml_next = pml;
  279.                 free(t);
  280.             }
  281.             if ((!svc_sendreply(xprt, xdr_long, (caddr_t)&ans)) &&
  282.                 debugging) {
  283.                 (void) fprintf(stderr, "svc_sendreply\n");
  284.                 exit(20);
  285.             }
  286.         }
  287.         break;
  288.  
  289.     case PMAPPROC_GETPORT:
  290.         /*
  291.          * Lookup the mapping for a program,version and return its port
  292.          */
  293.         if (!svc_getargs(xprt, xdr_pmap, ®))
  294.             svcerr_decode(xprt);
  295.         else {
  296.             fnd = find_service(reg.pm_prog, reg.pm_vers, reg.pm_prot);
  297.             if (fnd)
  298.                 port = fnd->pml_map.pm_port;
  299.             else
  300.                 port = 0;
  301.             if ((!svc_sendreply(xprt, xdr_long, (caddr_t)&port)) &&
  302.                 debugging) {
  303.                 (void) fprintf(stderr, "svc_sendreply\n");
  304.                 exit(20);
  305.             }
  306.         }
  307.         break;
  308.  
  309.     case PMAPPROC_DUMP:
  310.         /*
  311.          * Return the current set of mapped program,version
  312.          */
  313.         if (!svc_getargs(xprt, xdr_void, NULL))
  314.             svcerr_decode(xprt);
  315.         else {
  316.             if ((!svc_sendreply(xprt, xdr_pmaplist,
  317.                 (caddr_t)&pmaplist)) && debugging) {
  318.                 (void) fprintf(stderr, "svc_sendreply\n");
  319.                 exit(20);
  320.             }
  321.         }
  322.         break;
  323.  
  324.     case PMAPPROC_CALLIT:
  325.         /*
  326.          * Calls a procedure on the local machine.  If the requested
  327.          * procedure is not registered this procedure does not return
  328.          * error information!!
  329.          * This procedure is only supported on rpc/udp and calls via 
  330.          * rpc/udp.  It passes null authentication parameters.
  331.          */
  332.         callit(rqstp, xprt);
  333.         break;
  334.  
  335.     default:
  336.         svcerr_noproc(