386BSD 0.1 development

[unix-history] / usr / othersrc / contrib / isode / compat / ubcx25.c

/* ubcx25.c - X.25 abstractions for UBC X25 */

#ifndef lint
static char *rcsid = "$Header: /f/osi/compat/RCS/ubcx25.c,v 7.4 91/02/22 09:16:13 mrose Interim $";
#endif

/*
* $Header: /f/osi/compat/RCS/ubcx25.c,v 7.4 91/02/22 09:16:13 mrose Interim $
*
* Contributed by Julian Onions, Nottingham University in the UK
*
*
* $Log:        ubcx25.c,v $
* Revision 7.4  91/02/22  09:16:13  mrose
* Interim 6.8
* 
* Revision 7.3  91/01/14  13:33:53  mrose
* loader
* 
* Revision 7.2  90/07/09  14:32:28  mrose
* sync
* 
* Revision 7.1  89/12/07  01:08:02  mrose
* queued writes
* 
* Revision 7.0  89/11/23  21:23:47  mrose
* Release 6.0
* 
*/

/*
*                                NOTICE
*
*    Acquisition, use, and distribution of this module and related
*    materials are subject to the restrictions of a license agreement.
*    Consult the Preface in the User's Manual for the full terms of
*    this agreement.
*
*/


/* LINTLIBRARY */

#include <errno.h>
#include <stdio.h>
#include "general.h"
#include "manifest.h"
#include "tailor.h"
#include "tpkt.h"

/* \f   4.[23] UNIX: UBC X25 */

#ifdef  X25
#ifdef  UBC_X25

#include "x25.h"
#include <sys/uio.h>

#define         X25_MBIT        0x40
#define         X25_QBIT        0x80

/* \f */

int     start_x25_client (local)
struct NSAPaddr *local;
{
   int     sd, pgrp;

   if (local != NULLNA)
       local -> na_stack = NA_X25, local -> na_community = ts_comm_x25_default;
   if ((sd = socket (AF_CCITT, SOCK_STREAM, 0)) == NOTOK) {
       SLOG (compat_log, LLOG_EXCEPTIONS, "failed", ("socket"));
       return NOTOK; /* Error can be found in errno */
   }

   pgrp = getpid();
   if (ioctl(sd, SIOCSPGRP, &pgrp)) {
       SLOG (compat_log, LLOG_EXCEPTIONS, "failed", ("SIOCSPGRP"));
       return NOTOK; /* Error can be found in errno */
   }

   return sd;
}

/* \f */

int     start_x25_server (local, backlog, opt1, opt2)
struct NSAPaddr *local;
int     backlog,
       opt1,
       opt2;
{
   int     sd, pgrp;
#ifdef  notyet
#ifdef  BSD43
   int     onoff;
#endif
#endif
   CONN_DB     zsck;
   CONN_DB     *sck = &zsck;

   if ((sd = socket (AF_CCITT, SOCK_STREAM, 0)) == NOTOK) {
       SLOG (compat_log, LLOG_EXCEPTIONS, "failed", ("socket"));
       return NOTOK; /* Can't get an X.25 socket */
   }

   pgrp = getpid();
   if (ioctl(sd, SIOCSPGRP, &pgrp)) {
       SLOG (compat_log, LLOG_EXCEPTIONS, "failed", ("SIOCSPGRP"));
       return NOTOK; /* Error can be found in errno */
   }

   if (local != NULLNA) {
       local -> na_stack = NA_X25, local -> na_community = ts_comm_x25_default;
       if (local -> na_dtelen == 0) {
           (void) strcpy (local -> na_dte, x25_local_dte);
           local -> na_dtelen = strlen(x25_local_dte);
           if (local -> na_pidlen == 0 && *x25_local_pid)
               local -> na_pidlen =
                   str2sel (x25_local_pid, -1, local -> na_pid, NPSIZE);
       }
   }

   (void) gen2if (local, sck, ADDR_LISTEN);
   if (bind (sd, sck, sizeof(CONN_DB)) == NOTOK) {
       SLOG (compat_log, LLOG_EXCEPTIONS, "failed", ("bind"));
       (void) close_x25_socket (sd);
       return NOTOK;
   }


#ifdef  notyet          /* not sure if these are supported... */
#ifndef BSD43
   if (opt1)
       (void) setsockopt (sd, SOL_SOCKET, opt1, NULLCP, 0);
   if (opt2)
       (void) setsockopt (sd, SOL_SOCKET, opt2, NULLCP, 0);
#else
   onoff = 1;
   if (opt1)
       (void) setsockopt (sd, SOL_SOCKET, opt1, (char *)&onoff, sizeof onoff);
   if (opt2)
       (void) setsockopt (sd, SOL_SOCKET, opt2, (char *)&onoff, sizeof onoff);
#endif
#endif

   (void) listen (sd, backlog);

   return sd;
}

/* \f */

int     join_x25_client (fd, remote)
int     fd;
struct NSAPaddr *remote;
{
   CONN_DB     sck;
   int     len = sizeof sck;
   int         nfd;

   if((nfd = accept (fd, (struct sockaddr *) &sck, &len)) == NOTOK)
       return NOTOK;
   (void) if2gen (remote, &sck, ADDR_REMOTE);
   return nfd;
}

int     join_x25_server (fd, remote)
int     fd;
struct NSAPaddr *remote;
{
   CONN_DB zsck;
   CONN_DB *sck = &zsck;

   if (remote == NULLNA || remote -> na_stack != NA_X25)
   {
       SLOG (compat_log, LLOG_EXCEPTIONS, NULLCP,
             ("Invalid type na%d", remote->na_stack));
       return NOTOK;
   }
   (void) gen2if (remote, sck, ADDR_REMOTE);
   return connect (fd, sck, sizeof (CONN_DB));
}

int     read_x25_socket (fd, buffer, len)
int     fd, len;
char    *buffer;
{
   static u_char mode;
   static struct iovec iov[2] = {
       (char *)&mode, 1,
       "", 0
   };
   char        *p = buffer;
   int         cc, count = 0, total = len;

   do {
       iov[1].iov_base = p;
       iov[1].iov_len = total > X25_PACKETSIZE ? X25_PACKETSIZE : total;

       switch (cc = readv (fd, iov, 2)) {
               /*
                * for the -1,0 & 1 cases these returns should be ok
                * if it's the first time through, then they are valid anyway
                * later stages means the M bit is set so there must
                * be more data else someone is violating the
                * protocol badly.
                */

           case NOTOK:
           case 0:
               return cc;

           case 1:
               SLOG (compat_log, LLOG_EXCEPTIONS, NULLCP,
                     ("strange return from read_x25_socket"));
               return NOTOK;

           default:
               cc --;          /* discount the info byte */
               count += cc;
               p += cc;
               total -= cc;
       }
   } while (len > 0 && (mode & X25_MBIT));
   DLOG (compat_log, LLOG_DEBUG, ("X25 read, total %d/%d", count, len));

   return count;
}

#ifdef UBC_X25_WRITEV
/* God this all very bizarre - iovecs work on read but not write!! */

/*
* OK, this is due to a bug in UBC implementation. It may or may not
* be fixed in later versions. If writev allows you to write single
* bytes in the first vector then use this version. It's much more
* efficient.
*/

int     write_x25_socket (fd, buffer, len)
int     fd, len;
char    *buffer;
{
   static u_char mode;
   static struct iovec iov[2] = {
       (char *)&mode, 1,
       "", 0
       };
   int cc;
   char        *p = buffer;
   int         count, total = 0;

   do {
       count = len > X25_PACKETSIZE ? X25_PACKETSIZE : len;
       mode = len > X25_PACKETSIZE ? X25_MBIT : 0;
       iov[1].iov_base = p;
       iov[1].iov_len = count;
       switch (cc = writev (fd, iov, 2))
       {
           case NOTOK:
           case 0:
               return cc;

           case 1:
               SLOG (compat_log, LLOG_EXCEPTIONS, NULLCP,
                     ("strange return from write_x25_socket"));
               return NOTOK;

           default:
               cc --;
               len -= cc;
               p += cc;
               total += cc;
       }
   } while (len > 0);
   DLOG (compat_log, LLOG_DEBUG, ("X25 write, total %d/%d", total, len));
   return total;
}
#else
int     write_x25_socket (fd, buffer, len)
int     fd, len;
char    *buffer;
{
   char        mybuffer[X25_PACKETSIZE+1];
   char        *p = buffer;
   int         count, total = 0;
   int         cc;

   do {
       count = len > X25_PACKETSIZE ? X25_PACKETSIZE : len;
       mybuffer[0] = len > X25_PACKETSIZE ? X25_MBIT : 0;
       bcopy (p, &mybuffer[1], count);
       switch (cc = write (fd, mybuffer, count + 1))
       {
           case NOTOK:
           case 0:
               return cc;

           case 1:
               SLOG (compat_log, LLOG_EXCEPTIONS, NULLCP,
                     ("strange return from write_x25_socket"));
               return NOTOK;

           default:
               cc --;
               len -= cc;
               p += cc;
               total += cc;
       }
   } while (len > 0);
   DLOG (compat_log, LLOG_DEBUG, ("X25 write, total %d/%d", total, len));
   return total;
}
#endif

#else   /* UBC_X25 */
int     _ubcx25_stub2 () {};
#endif  /* UBC_X25 */
#else   /* X25 */
int     _ubcx25_stub () {};
#endif  /* X25 */