home *** CD-ROM | disk | FTP | other *** search
/ QRZ! Ham Radio 6 / QRZ Ham Radio Callsign Database - Volume 6.iso / pc / files / amiga / rhinosrc.lha / socket.c < prev    next >
Encoding:
C/C++ Source or Header  |  1993-06-23  |  13.9 KB  |  682 lines
  1. /* Application programming interface routines - based loosely on the
  2.  * "socket" model in Berkeley UNIX.
  3.  *
  4.  * Copyright 1991 Phil Karn, KA9Q
  5.  */
  6. #include <stdio.h>
  7. #ifdef    __STDC__
  8. #include <stdarg.h>
  9. #endif
  10. #include <errno.h>
  11. #include "global.h"
  12. #include "mbuf.h"
  13. #include "netuser.h"
  14. #include "proc.h"
  15. #include "lzw.h"
  16. #include "usock.h"
  17. #include "socket.h"
  18.  
  19. char *Socktypes[] = {
  20.     "Not Used",
  21.     "TCP",
  22.     "UDP",
  23.     "AX25 I",
  24.     "AX25 UI",
  25.     "Raw IP",
  26.     "NETROM3",
  27.     "NETROM",
  28.     "Loc St",
  29.     "Loc Dg"
  30. };
  31. char *Sock_errlist[] = {
  32.     "operation would block",
  33.     "not connected",
  34.     "socket type not supported",
  35.     "address family not supported",
  36.     "is connected",
  37.     "operation not supported",
  38.     "alarm",
  39.     "abort",
  40.     "interrupt",
  41.     "connection refused",
  42.     "message size",
  43.     "address in use"
  44. };
  45.  
  46. char Badsocket[] = "Bad socket";
  47. struct usock **Usock;        /* Socket entry array */
  48.  
  49. /* Initialize user socket array */
  50. void
  51. sockinit()
  52. {
  53.     if(Usock != (struct usock **)NULL)
  54.         return;    /* Already initialized */
  55.     Usock = (struct usock **)callocw(Nsock,sizeof(struct usock *));
  56. }
  57.  
  58. /* Create a user socket, return socket index
  59.  * The mapping to actual protocols is as follows:
  60.  *        
  61.  *        
  62.  * ADDRESS FAMILY    Stream        Datagram    Raw        Seq. Packet
  63.  *
  64.  * AF_INET        TCP        UDP        IP
  65.  * AF_AX25        I-frames    UI-frames
  66.  * AF_NETROM                        NET/ROM L3  NET/ROM L4
  67.  * AF_LOCAL        stream loopback    packet loopback
  68.  */
  69. int
  70. socket(af,type,protocol)
  71. int af;        /* Address family */
  72. int type;    /* Stream or datagram */
  73. int protocol;    /* Used for raw IP sockets */
  74. {
  75.     register struct usock *up;
  76.     struct socklink *sp;
  77.     int s;
  78.  
  79.     for(s=0;s<Nsock;s++)
  80.         if(Usock[s] == NULLUSOCK)
  81.             break;
  82.     if(s == Nsock){
  83.         errno = EMFILE;
  84.         return -1;
  85.     }
  86.     Usock[s] = up = (struct usock *)calloc(1,sizeof(struct usock));
  87.  
  88.     s += Nfiles;
  89.     up->index = s;
  90.     up->refcnt = 1;
  91.     errno = 0;
  92.     up->rdysock = -1;
  93.     up->owner = Curproc;
  94.     switch(af){
  95.     case AF_LOCAL:
  96.         switch(type){
  97.         case SOCK_STREAM:
  98.             up->type = TYPE_LOCAL_STREAM;
  99.             break;
  100.         case SOCK_DGRAM:
  101.             up->type = TYPE_LOCAL_DGRAM;
  102.             break;
  103.         default:
  104.             errno = ESOCKTNOSUPPORT;
  105.             break;
  106.         }
  107.         break;
  108.     case AF_AX25:
  109.         switch(type){
  110.         case SOCK_STREAM:
  111.             up->type = TYPE_AX25I;
  112.             break;
  113.         case SOCK_DGRAM:
  114.             up->type = TYPE_AX25UI;
  115.             break;
  116.         default:
  117.             errno = ESOCKTNOSUPPORT;
  118.             break;
  119.         }
  120.         break;
  121.     case AF_NETROM:
  122.         switch(type){
  123.         case SOCK_RAW:
  124.             up->type = TYPE_NETROML3;
  125.             break;
  126.         case SOCK_SEQPACKET:
  127.             up->type = TYPE_NETROML4;
  128.             break;
  129.         default:
  130.             errno = ESOCKTNOSUPPORT;
  131.             break;
  132.         }
  133.         break;
  134.     case AF_INET:
  135.         switch(type){
  136.         case SOCK_STREAM:
  137.             up->type = TYPE_TCP;
  138.             break;
  139.         case SOCK_DGRAM:
  140.             up->type = TYPE_UDP;
  141.             break;
  142.         case SOCK_RAW:
  143.             up->type = TYPE_RAW;
  144.             break;
  145.         default:
  146.             errno = ESOCKTNOSUPPORT;
  147.             break;
  148.         }
  149.         break;
  150.     default:
  151.         errno = EAFNOSUPPORT;
  152.         break;
  153.     }
  154.     /* Look for entry in protocol table */
  155.     for(sp = Socklink;sp->type != -1;sp++){
  156.         if(up->type == sp->type)
  157.             break;
  158.     }
  159.     up->sp = sp;
  160.     if(sp->type == -1 || sp->socket == NULLFP
  161.       ||(*sp->socket)(up,protocol) == -1){
  162.         errno = ESOCKTNOSUPPORT;
  163.         return -1;
  164.     }
  165.     return s;
  166. }
  167.  
  168. /* Attach a local address/port to a socket. If not issued before a connect
  169.  * or listen, will be issued automatically
  170.  */
  171. int
  172. bind(s,name,namelen)
  173. int s;        /* Socket index */
  174. char *name;    /* Local name */
  175. int namelen;    /* Length of name */
  176. {
  177.     register struct usock *up;
  178.     struct socklink *sp;
  179.  
  180.     if((up = itop(s)) == NULLUSOCK){
  181.         errno = EBADF;
  182.         return -1;
  183.     }
  184.     if(name == NULLCHAR){
  185.         errno = EFAULT;
  186.         return -1;
  187.     }
  188.     if(up->name != NULLCHAR){
  189.         /* Bind has already been issued */
  190.         errno = EINVAL;
  191.         return -1;
  192.     }
  193.     sp = up->sp;
  194.     if(sp->check != NULLFP && (*sp->check)(name,namelen) == -1){
  195.         /* Incorrect length or family for chosen protocol */
  196.         errno = EAFNOSUPPORT;
  197.         return -1;    
  198.     }
  199.     /* Stash name in an allocated block */
  200.     up->namelen = namelen;
  201.     up->name = mallocw(namelen);
  202.     memcpy(up->name,name,namelen);
  203.  
  204.     /* a bind routine is optional - don't fail if it isn't present */
  205.     if(sp->bind != NULLFP && (*sp->bind)(up) == -1){
  206.         errno = EOPNOTSUPP;
  207.         return -1;
  208.     }
  209.     return 0;
  210. }
  211. /* Post a listen on a socket */
  212. int
  213. listen(s,backlog)
  214. int s;        /* Socket index */
  215. int backlog;    /* 0 for a single connection, !=0 for multiple connections */
  216. {
  217.     register struct usock *up;
  218.     struct socklink *sp;
  219.  
  220.     if((up = itop(s)) == NULLUSOCK){
  221.         errno = EBADF;
  222.         return -1;
  223.     }
  224.     if(up->cb.p != NULLCHAR){
  225.         errno = EISCONN;
  226.         return -1;
  227.     }
  228.     sp = up->sp;
  229.     /* Fail if listen routine isn't present */
  230.     if(sp->listen == NULLFP || (*sp->listen)(up,backlog) == -1){
  231.         errno = EOPNOTSUPP;
  232.         return -1;
  233.     }
  234.     return 0;
  235. }
  236. /* Initiate active open. For datagram sockets, merely bind the remote address. */
  237. int
  238. connect(s,peername,peernamelen)
  239. int s;            /* Socket index */
  240. char *peername;        /* Peer name */
  241. int peernamelen;    /* Length of peer name */
  242. {
  243.     register struct usock *up;
  244.     struct socklink *sp;
  245.  
  246.     if((up = itop(s)) == NULLUSOCK){
  247.         errno = EBADF;
  248.         return -1;
  249.     }
  250.     if(peername == NULLCHAR){
  251.         /* Connect must specify a remote address */
  252.         errno = EFAULT;
  253.         return -1;
  254.     }
  255.     sp = up->sp;
  256.     /* Check name format, if checking routine is available */
  257.     if(sp->check != NULLFP && (*sp->check)(peername,peernamelen) == -1){
  258.         errno = EAFNOSUPPORT;
  259.         return -1;
  260.     }
  261.     if(up->peername != NULLCHAR)
  262.         free(up->peername);
  263.     up->peername = mallocw(peernamelen);
  264.     memcpy(up->peername,peername,peernamelen);
  265.     up->peernamelen = peernamelen;
  266.  
  267.     /* a connect routine is optional - don't fail if it isn't present */
  268.     if(sp->connect != NULLFP && (*sp->connect)(up) == -1){
  269.         return -1;
  270.     }
  271.     return 0;
  272. }
  273. /* Wait for a connection. Valid only for connection-oriented sockets. */
  274. int
  275. accept(s,peername,peernamelen)
  276. int s;            /* Socket index */
  277. char *peername;        /* Peer name */
  278. int *peernamelen;    /* Length of peer name */
  279. {
  280.     int i;
  281.     register struct usock *up;
  282.     struct socklink *sp;
  283.  
  284.     if((up = itop(s)) == NULLUSOCK){
  285.         errno = EBADF;
  286.         return -1;
  287.     }
  288.     if(up->cb.p == NULLCHAR){
  289.         errno = EOPNOTSUPP;
  290.         return -1;
  291.     }
  292.     sp = up->sp;
  293.     /* Fail if accept flag isn't set */
  294.     if(sp->accept == FALSE){
  295.         errno = EOPNOTSUPP;
  296.         return -1;
  297.     }
  298.     /* Wait for the state-change upcall routine to signal us */
  299.     while(up->cb.p != NULLCHAR && up->rdysock == -1){
  300.         if(up->noblock){
  301.             errno = EWOULDBLOCK;
  302.             return -1;
  303.         } else if((errno = pwait(up)) != 0){
  304.             return -1;
  305.         }
  306.     }
  307.     if(up->cb.p == NULLCHAR){
  308.         /* Blown away */
  309.         errno = EBADF;
  310.         return -1;
  311.     }
  312.     i = up->rdysock;
  313.     up->rdysock = -1;
  314.  
  315.     up = itop(i);
  316.     if(peername != NULLCHAR && peernamelen != NULL){
  317.         *peernamelen = min(up->peernamelen,*peernamelen);
  318.         memcpy(peername,up->peername,*peernamelen);
  319.     }
  320.     return i;
  321. }
  322. /* Low-level receive routine. Passes mbuf back to user; more efficient than
  323.  * higher-level functions recv() and recvfrom(). Datagram sockets ignore
  324.  * the len parameter.
  325.  */
  326. int
  327. recv_mbuf(s,bpp,flags,from,fromlen)
  328. int s;            /* Socket index */
  329. struct mbuf **bpp;    /* Place to stash receive buffer */
  330. int flags;        /* Unused; will control out-of-band data, etc */
  331. char *from;        /* Peer address (only for datagrams) */
  332. int *fromlen;        /* Length of peer address */
  333. {
  334.     register struct usock *up;
  335.     struct socklink *sp;
  336.  
  337.     if((up = itop(s)) == NULLUSOCK){
  338.         errno = EBADF;
  339.         return -1;
  340.     }
  341.     if(up->ibuf != NULLBUF){/* Rhialto */
  342.         int cnt;
  343.         /* Return input buffer */
  344.         cnt = len_p(up->ibuf);
  345.         if(bpp != NULLBUFP)
  346.             *bpp = up->ibuf;
  347.         else
  348.             free_p(up->ibuf);
  349.         up->ibuf = NULLBUF;        
  350.         return cnt;
  351.     }
  352.     sp = up->sp;
  353.     /* Fail if recv routine isn't present */
  354.     if(sp->recv == NULLFP){
  355.         errno = EOPNOTSUPP;
  356.         return -1;
  357.     }
  358.     return (*sp->recv)(up,bpp,from,fromlen);
  359. }
  360. /* Low level send routine; user supplies mbuf for transmission. More
  361.  * efficient than send() or sendto(), the higher level interfaces.
  362.  * The "to" and "tolen" parameters are ignored on connection-oriented
  363.  * sockets.
  364.  *
  365.  * In case of error, bp is freed so the caller doesn't have to worry about it.
  366.  */
  367. int
  368. send_mbuf(s,bp,flags,to,tolen)
  369. int s;            /* Socket index */
  370. struct mbuf *bp;    /* Buffer to send */
  371. int flags;        /* not currently used */
  372. char *to;        /* Destination, only for datagrams */
  373. int tolen;        /* Length of destination */
  374. {
  375.     register struct usock *up;
  376.     int cnt;
  377.     struct socklink *sp;
  378.  
  379.     if((up = itop(s)) == NULLUSOCK){
  380.         free_p(bp);
  381.         errno = EBADF;
  382.         return -1;
  383.     }
  384.     sp = up->sp;
  385.     /* Fail if send routine isn't present (shouldn't happen) */
  386.     if(sp->send == NULLFP){
  387.         free_p(bp);
  388.         return -1;
  389.     }
  390.     /* If remote address is supplied, check it */
  391.     if(to != NULLCHAR && (sp->check != NULLFP)
  392.      && (*sp->check)(to,tolen) == -1){
  393.         errno = EAFNOSUPPORT;
  394.         return -1;
  395.     }
  396.     /* The proto send routine is expected to free the buffer
  397.      * we pass it even if the send fails
  398.      */
  399.     if((cnt = (*sp->send)(up,bp,to)) == -1){
  400.         errno = EOPNOTSUPP;
  401.         return -1;
  402.     }
  403.     return cnt;
  404. }
  405. /* Return local name passed in an earlier bind() call */
  406. int
  407. getsockname(s,name,namelen)
  408. int s;        /* Socket index */
  409. char *name;    /* Place to stash name */
  410. int *namelen;    /* Length of same */
  411. {
  412.     register struct usock *up;
  413.  
  414.     if((up = itop(s)) == NULLUSOCK){
  415.         errno = EBADF;
  416.         return -1;
  417.     }
  418.     if(name == NULLCHAR || namelen == (int *)NULL){
  419.         errno = EFAULT;
  420.         return -1;
  421.     }
  422.     if(up->name == NULLCHAR){
  423.         /* Not bound yet */
  424.         *namelen = 0;
  425.         return 0;
  426.     }
  427.     if(up->name != NULLCHAR){
  428.         *namelen = min(*namelen,up->namelen);
  429.         memcpy(name,up->name,*namelen);
  430.     }
  431.     return 0;
  432. }
  433. /* Get remote name, returning result of earlier connect() call. */
  434. int
  435. getpeername(s,peername,peernamelen)
  436. int s;            /* Socket index */
  437. char *peername;        /* Place to stash name */
  438. int *peernamelen;    /* Length of same */
  439. {
  440.     register struct usock *up;
  441.  
  442.     if((up = itop(s)) == NULLUSOCK){
  443.         errno = EBADF;
  444.         return -1;
  445.     }
  446.     if(up->peername == NULLCHAR){
  447.         errno = ENOTCONN;
  448.         return -1;
  449.     }
  450.     if(peername == NULLCHAR || peernamelen == (int *)NULL){
  451.         errno = EFAULT;
  452.         return -1;
  453.     }
  454.     *peernamelen = min(*peernamelen,up->peernamelen);
  455.     memcpy(peername,up->peername,*peernamelen);
  456.     return 0;
  457. }
  458. /* Return length of protocol queue, either send or receive. */
  459. int
  460. socklen(s,rtx)
  461. int s;        /* Socket index */
  462. int rtx;    /* 0 = receive queue, 1 = transmit queue */
  463. {
  464.     register struct usock *up;
  465.     struct socklink *sp;
  466.     int len = -1;
  467.  
  468.     if((up = itop(s)) == NULLUSOCK){
  469.         errno = EBADF;
  470.         return -1;
  471.     }
  472.     if(up->cb.p == NULLCHAR){
  473.         errno = ENOTCONN;
  474.         return -1;
  475.     }
  476.     if(rtx < 0 || rtx > 1){
  477.         errno = EINVAL;
  478.         return -1;
  479.     }
  480.     sp = up->sp;
  481.     /* Fail if qlen routine isn't present */
  482.     if(sp->qlen == NULLFP || (len = (*sp->qlen)(up,rtx)) == -1){
  483.         errno = EOPNOTSUPP;
  484.         return -1;
  485.     }
  486.     return len;
  487. }
  488. /* Force retransmission. Valid only for connection-oriented sockets. */
  489. int
  490. sockkick(s)
  491. int s;    /* Socket index */
  492. {
  493.     register struct usock *up;
  494.     struct socklink *sp;
  495.  
  496.     if((up = itop(s)) == NULLUSOCK){
  497.         errno = EBADF;
  498.         return -1;
  499.     }
  500.     sp = up->sp;
  501.     /* Fail if kick routine isn't present */
  502.     if(sp->kick == NULLFP){
  503.         errno = EOPNOTSUPP;
  504.         return -1;
  505.     }
  506.      if((*sp->kick)(up) == -1)
  507.         return -1;
  508.     return 0;
  509. }
  510.  
  511. /* Change owner of socket, return previous owner */
  512. struct proc *
  513. sockowner(s,newowner)
  514. int s;            /* Socket index */
  515. struct proc *newowner;    /* Process table address of new owner */
  516. {
  517.     register struct usock *up;
  518.     struct proc *pp;
  519.  
  520.     if((up = itop(s)) == NULLUSOCK){
  521.         errno = EBADF;
  522.         return NULLPROC;
  523.     }
  524.     pp = up->owner;
  525.     if(newowner != NULLPROC)
  526.         up->owner = newowner;
  527.     return pp;
  528. }
  529. /* Close down a socket three ways. Type 0 means "no more receives"; this
  530.  * replaces the incoming data upcall with a routine that discards further
  531.  * data. Type 1 means "no more sends", and obviously corresponds to sending
  532.  * a TCP FIN. Type 2 means "no more receives or sends". This I interpret
  533.  * as "abort the connection".
  534.  */
  535. int
  536. shutdown(s,how)
  537. int s;        /* Socket index */
  538. int how;    /* (see above) */
  539. {
  540.     register struct usock *up;
  541.     struct socklink *sp;
  542.  
  543.     if((up = itop(s)) == NULLUSOCK){
  544.         errno = EBADF;
  545.         return -1;
  546.     }
  547.     if(up->cb.p == NULLCHAR){
  548.         errno = ENOTCONN;
  549.         return -1;
  550.     }
  551.     sp = up->sp;
  552.     /* Just close the socket if special shutdown routine not present */
  553.     if(sp->shut == NULLFP){
  554.         close_s(s);
  555.     } else if((*sp->shut)(up,how) == -1){
  556.         return -1;
  557.     }
  558.     psignal(up,0);
  559.     return 0;
  560. }
  561. /* Close a socket, freeing it for reuse. Try to do a graceful close on a
  562.  * TCP socket, if possible
  563.  */
  564. int
  565. close_s(s)
  566. int s;        /* Socket index */
  567. {
  568.     register struct usock *up;
  569.     struct socklink *sp;
  570.  
  571.     if((up = itop(s)) == NULLUSOCK){
  572.         errno = EBADF;
  573.         return -1;
  574.     }
  575.     if(--up->refcnt > 0)
  576.         return 0;    /* Others are still using it */
  577.     /* Call proto-specific close routine if there is one */
  578.     if((sp = up->sp) != NULL && sp->close != NULLFP)
  579.         (*sp->close)(up);
  580.  
  581.     free(up->name);
  582.     free(up->peername);
  583.     if(up->ibuf != NULLBUF){/* Rhialto */
  584.         free_p(up->ibuf);
  585.         up->ibuf = NULLBUF;        
  586.     }
  587.  
  588.     psignal(up,0);    /* Wake up anybody doing an accept() or recv() */
  589.     Usock[up->index - Nfiles] = NULLUSOCK;
  590.     free(up);
  591.     return 0;
  592. }
  593. /* Increment reference count for specified socket */
  594. int
  595. usesock(s)
  596. int s;
  597. {
  598.     struct usock *up;
  599.  
  600.     if((up = itop(s)) == NULLUSOCK){
  601.         errno = EBADF;
  602.         return -1;
  603.     }
  604.     up->refcnt++;
  605.     return 0;
  606. }
  607. /* Blow away all sockets belonging to a certain process. Used by killproc(). */
  608. void
  609. freesock(pp)
  610. struct proc *pp;
  611. {
  612.     register struct usock *up;
  613.     register int i;
  614.  
  615.     for(i=Nfiles;i < Nsock+Nfiles;i++){
  616.         up = itop(i);
  617.         if(up != NULLUSOCK && up->type != NOTUSED && up->owner == pp)
  618.             shutdown(i,2);
  619.     }
  620. }
  621. /* Set Internet type-of-service to be used */
  622. int
  623. settos(s,tos)
  624. int s,tos;
  625. {
  626.     struct usock *up;
  627.  
  628.     if((up = itop(s)) == NULLUSOCK){
  629.         errno = EBADF;
  630.         return -1;
  631.     }
  632.     up->tos = tos;
  633.     return 0;
  634. }
  635.  
  636. /* Return a pair of mutually connected sockets in sv[0] and sv[1] */
  637. int
  638. socketpair(af,type,protocol,sv)
  639. int af;
  640. int type;
  641. int protocol;
  642. int sv[];
  643. {
  644.     struct usock *up0, *up1;
  645.     if(sv == NULLINT){
  646.         errno = EFAULT;
  647.         return -1;
  648.     }
  649.     if(af != AF_LOCAL){
  650.         errno = EAFNOSUPPORT;
  651.         return -1;
  652.     }
  653.     if(type != SOCK_STREAM && type != SOCK_DGRAM){
  654.         errno = ESOCKTNOSUPPORT;
  655.         return -1;
  656.     }
  657.     if((sv[0] = socket(af,type,protocol)) == -1)
  658.         return -1;
  659.     if((sv[1] = socket(af,type,protocol)) == -1){
  660.         close_s(sv[0]);
  661.         return -1;
  662.     }
  663.     up0 = itop(sv[0]);
  664.     up1 = itop(sv[1]);
  665.     up0->cb.local->peer = up1;
  666.     up1->cb.local->peer = up0;
  667.     return sv[1];
  668. }
  669. /* Return end-of-line convention for socket */
  670. char *
  671. eolseq(s)
  672. int s;
  673. {
  674.     struct usock *up;
  675.  
  676.     if((up = itop(s)) == NULLUSOCK){
  677.         errno = EBADF;
  678.         return NULLCHAR;
  679.     }
  680.     return up->sp->eol;
  681. }
  682.