|
DataMuseum.dkPresents historical artifacts from the history of: DKUUG/EUUG Conference tapes |
This is an automatic "excavation" of a thematic subset of
See our Wiki for more about DKUUG/EUUG Conference tapes Excavated with: AutoArchaeologist - Free & Open Source Software. |
top - metrics - downloadIndex: T u
Length: 6356 (0x18d4)
Types: TextFile
Names: »ubcx25.c«
└─⟦3d0c2be1b⟧ Bits:30001254 ISODE-5.0 Tape
└─⟦eba4602b1⟧ »./isode-5.0.tar.Z«
└─⟦d3ac74d73⟧
└─⟦this⟧ »isode-5.0/compat/ubcx25.c«
/* ubcx25.c - X.25 abstractions for UBC X25 */
#ifndef lint
static char *rcsid = "$Header: /f/osi/compat/RCS/ubcx25.c,v 6.0 89/03/18 23:25:56 mrose Rel $";
#endif
/*
* $Header: /f/osi/compat/RCS/ubcx25.c,v 6.0 89/03/18 23:25:56 mrose Rel $
*
* Contributed by Julian Onions, Nottingham University in the UK
*
*
* $Log: ubcx25.c,v $
* Revision 6.0 89/03/18 23:25:56 mrose
* Release 5.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
#define X25_PACKETSIZE 128
/* \f
*/
int start_x25_client (local)
struct NSAPaddr *local;
{
int sd, pgrp;
if (local != NULLNA)
local -> na_type = NA_X25;
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;
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_type = NA_X25;
if (local != NULLNA && local -> na_dtelen == 0)
{
(void) strcpy (local -> na_dte, x25_local_dte);
local -> na_dtelen = strlen(x25_local_dte);
}
(void) gen2if (local, sck, ADDR_LISTEN);
if (bind (sd, sck, sizeof(CONN_DB)) != NOTOK) {
#ifdef notyet /* not sure these are supported ... */
if (opt1)
(void) setsockopt (sd, SOL_SOCKET, opt1, NULLCP, 0);
if (opt2)
(void) setsockopt (sd, SOL_SOCKET, opt2, NULLCP, 0);
#endif
(void) listen (sd, backlog);
return sd;
}
(void) close (sd);
return NOTOK;
}
/* \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_type != NA_X25)
{
SLOG (compat_log, LLOG_EXCEPTIONS, NULLCP,
("Invalid type na%d", remote->na_type));
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
#endif
#endif