This is client.c in view mode; [Download] [Up]
/* client.c - connect to a server */
#ifndef lint
static char ident[] = "@(#)$Id: client.c,v 1.1.1.2 1991/04/28 03:57:40 karl Exp $";
#endif lint
#if defined(BSD42) || defined(SOCKETS)
#include "../h/strings.h"
#include <stdio.h>
#include "mts.h"
#include <errno.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
# ifndef hpux /* Doesn't exist on HP-UX (SYS V?) */
#include <arpa/inet.h>
# endif hpux
#ifdef SYS5
#define u_short ushort
#endif SYS5
#define NOTOK (-1)
#define OK 0
#define DONE 1
#define TRUE 1
#define FALSE 0
#define OOPS1 (-2)
#define OOPS2 (-3)
#define MAXARGS 1000
#define MAXNETS 5
#define MAXHOSTS 25
/* */
extern int errno;
extern int sys_nerr;
extern char *sys_errlist[];
struct addrent {
int a_addrtype; /* assumes AF_INET for inet_netof () */
union {
int un_net;
char un_addr[14];
} un;
#define a_net un.un_net
#define a_addr un.un_addr
};
static struct addrent *ne, *nz;
static struct addrent nets[MAXNETS];
static struct addrent *he, *hz;
static struct addrent hosts[MAXHOSTS];
static char *getcpy (), **copyip (), **brkstring ();
static brkany();
static int rcaux(), getport(), inet();
/* */
int client (args, protocol, service, rproto, response)
char *args,
*protocol,
*service,
*response;
int rproto;
{
int sd;
register char **ap;
char *arguments[MAXARGS];
register struct hostent *hp;
#ifndef BIND
register struct netent *np;
#endif BIND
register struct servent *sp;
if ((sp = getservbyname (service, protocol)) == NULL) {
(void) sprintf (response, "%s/%s: unknown service", protocol, service);
return NOTOK;
}
ap = arguments;
if (args != NULL && *args != NULL)
ap = copyip (brkstring (getcpy (args), " ", "\n"), ap);
else
if (servers != NULL && *servers != NULL)
ap = copyip (brkstring (getcpy (servers), " ", "\n"), ap);
if (ap == arguments) {
*ap++ = getcpy ("localhost");
*ap = NULL;
}
nz = (ne = nets) + sizeof nets / sizeof nets[0];
hz = (he = hosts) + sizeof hosts / sizeof hosts[0];
for (ap = arguments; *ap; ap++) {
if (**ap == '\01') {
#ifndef BIND
if (np = getnetbyname (*ap + 1)) {
sethostent (1);
while (hp = gethostent ())
if (np -> n_addrtype == hp -> h_addrtype
&& inet (hp, np -> n_net)) {
switch (sd = rcaux (sp, hp, rproto, response)) {
case NOTOK:
continue;
case OOPS1:
break;
case OOPS2:
return NOTOK;
default:
return sd;
}
break;
}
}
#endif not BIND
continue;
}
if (hp = gethostbyname (*ap)) {
switch (sd = rcaux (sp, hp, rproto, response)) {
case NOTOK:
case OOPS1:
break;
case OOPS2:
return NOTOK;
default:
return sd;
}
continue;
}
}
(void) strcpy (response, "no servers available");
return NOTOK;
}
/* */
static int rcaux (sp, hp, rproto, response)
register struct servent *sp;
register struct hostent *hp;
int rproto;
register char *response;
{
int sd;
struct in_addr in;
register struct addrent *ap;
struct sockaddr_in in_socket;
register struct sockaddr_in *isock = &in_socket;
for (ap = nets; ap < ne; ap++)
if (ap -> a_addrtype == hp -> h_addrtype && inet (hp, ap -> a_net))
return NOTOK;
for (ap = hosts; ap < he; ap++)
if (ap -> a_addrtype == hp -> h_addrtype
&& bcmp (ap -> a_addr, hp -> h_addr, hp -> h_length) == 0)
return NOTOK;
if ((sd = getport (rproto, hp -> h_addrtype, response)) == NOTOK)
return OOPS2;
bzero ((char *) isock, sizeof *isock);
isock -> sin_family = hp -> h_addrtype;
isock -> sin_port = sp -> s_port;
bcopy (hp -> h_addr, (char *) &isock -> sin_addr, hp -> h_length);
if (connect (sd, (struct sockaddr *) isock, sizeof *isock) == NOTOK)
switch (errno) {
case ENETDOWN:
case ENETUNREACH:
(void) close (sd);
if (ne < nz) {
ne -> a_addrtype = hp -> h_addrtype;
bcopy (hp -> h_addr, (char *) &in, sizeof in);
ne -> a_net = inet_netof (in);
ne++;
}
return OOPS1;
case ETIMEDOUT:
case ECONNREFUSED:
default:
(void) close (sd);
if (he < hz) {
he -> a_addrtype = hp -> h_addrtype;
bcopy (hp -> h_addr, he -> a_addr, hp -> h_length);
he++;
}
return NOTOK;
}
return sd;
}
/* */
static int getport (rproto, addrtype, response)
int rproto,
addrtype;
register char *response;
{
int sd,
port;
struct sockaddr_in in_socket,
*isock = &in_socket;
if (rproto && addrtype != AF_INET) {
(void) sprintf (response, "reserved ports not supported for af=%d",
addrtype);
errno = ENOPROTOOPT;
return NOTOK;
}
if ((sd = socket (AF_INET, SOCK_STREAM, 0)) == NOTOK) {
(void) sprintf (response, "unable to create socket: %s",
errno > 0 && errno < sys_nerr ? sys_errlist[errno]
: "unknown error");
return NOTOK;
}
if (!rproto)
return sd;
bzero ((char *) isock, sizeof *isock);
isock -> sin_family = addrtype;
for (port = IPPORT_RESERVED - 1;;) {
isock -> sin_port = htons ((u_short) port);
if (bind (sd, (struct sockaddr *) isock, sizeof *isock) != NOTOK)
return sd;
switch (errno) {
case EADDRINUSE:
case EADDRNOTAVAIL:
if (--port <= IPPORT_RESERVED / 2) {
(void) strcpy (response, "ports available");
return NOTOK;
}
break;
default:
(void) sprintf (response, "unable to bind socket: %s",
errno > 0 && errno < sys_nerr ? sys_errlist[errno]
: "unknown error");
return NOTOK;
}
}
}
/* */
static int inet (hp, net)
register struct hostent *hp;
int net;
{
struct in_addr in;
bcopy (hp -> h_addr, (char *) &in, sizeof in);
return (inet_netof (in) == net);
}
/* */
/* static copies of three MH subroutines... (sigh) */
char *malloc ();
static char *broken[MAXARGS + 1];
static char **brkstring (strg, brksep, brkterm)
register char *strg;
register char *brksep,
*brkterm;
{
register int bi;
register char c,
*sp;
sp = strg;
for (bi = 0; bi < MAXARGS; bi++) {
while (brkany (c = *sp, brksep))
*sp++ = 0;
if (!c || brkany (c, brkterm)) {
*sp = 0;
broken[bi] = 0;
return broken;
}
broken[bi] = sp;
while ((c = *++sp) && !brkany (c, brksep) && !brkany (c, brkterm))
continue;
}
broken[MAXARGS] = 0;
return broken;
}
static brkany (chr, strg)
register char chr,
*strg;
{
register char *sp;
if (strg)
for (sp = strg; *sp; sp++)
if (chr == *sp)
return 1;
return 0;
}
static char **copyip (p, q)
register char **p,
**q;
{
while (*p)
*q++ = *p++;
*q = 0;
return q;
}
static char *getcpy (str)
register char *str;
{
register char *cp;
if ((cp = malloc ((unsigned) (strlen (str) + 1))) == NULL)
return NULL;
(void) strcpy (cp, str);
return cp;
}
#endif BSD42 or SOCKETS
These are the contents of the former NiCE NeXT User Group NeXTSTEP/OpenStep software archive, currently hosted by Netfuture.ch.