Telnet服务器

开发平台：
Unix_Linux

io.c：源码内容
							/* $Id: io.c,v 1.1 2000/01/15 01:45:37 edwardc Exp $ */
/* Copyright 1992	Yongguang Zhang	*/
#ifndef lint
static char *rcs_id="$Id: io.c,v 1.1 2000/01/15 01:45:37 edwardc Exp $";
#endif /* lint */
#include "config.h"
#include "io.h"
static char *dummy(s) char *s; { return (s); }
static int dummy_init() { return (0); }
/* all implemented modules for io streams are listed here */
struct mod_def {
	char *name;
	char *(*func)();	/* conversion function */
	int (*f_init)();	/* initialization function */
	int needarg;		/* need arguments? */
} moduleTable[] = {
  {	"gb2hz",	gb2hz,		gb2hz_init,	0,	},
  {	"hz2gb",	hz2gb,		hz2gb_init,	0,	},
  {	"gb2big",	gb2big,		gb2big_init,	0,	},
  {	"big2gb",	big2gb,		big2gb_init,	0,	},
  {	"log",		io_log,		log_init,	1,	},
  {	"dummy",	dummy,		dummy_init,	0,	},
  {	"",		dummy,		dummy_init,	0,	},
  {	NULL,		dummy,		dummy_init,	0,	}
};
/* input/output stream */
struct io_stream {
	struct io_module {
		char *(*func)();	/* the conversion function */
		int inst;		/* instant number for the function */
	} st[MAX_MODULE];
	int len;			/* number of modules in the stream */
} in_stream, out_stream;
static int stream_init (str, pstream)
     char *str;
     struct io_stream *pstream;
{
  char *pstr = str;
  char *name, *arg;
  int more_module, has_arg;
  struct mod_def *pmod;
  int inst;
	pstream->len = 0;
	if ( (!pstr) || (! *pstr) || ((*pstr == '-') && (*(pstr+1) == '')) )
		return (0);
	do {
		/*
		 * A stream definition string looks like:
		 *    <stream>  ::=  <module> { ':' <module> }
		 *    <module>  ::=  <module_name> [ '(' <arguments> ')' ]
		 */
		name = pstr;
		for (; (*pstr && (*pstr != ':')); pstr++)
			/* empty */ ;
		more_module = (*pstr == ':') ? 1 : 0;	/* more modules? */
		*pstr++ = '';		/* null-terminate the module */
		for (arg = name; (*arg) && (*arg != '('); arg++)
			/* empty */ ;
		has_arg = ((*arg == '(') ? 1 : 0);	/* has arguments? */
		*arg++ = '';		/* null-terminate the module_name */
		/* search for the name in the module table */
		for (pmod = moduleTable; pmod->name; pmod++)
			if (strcmp (name, pmod->name) == 0)
				break;
		if (! pmod->name) {	/* not found */
			fprintf (stderr, "no such module "%s"n", name);
			return (-1);
		}
		if (pmod->needarg != has_arg) {
			fprintf (stderr, ""%s:%s" argument mismatchn",
				 name, arg);
			return (-1);
		}
		pstream->st[pstream->len].func = pmod->func;
		if (pmod->needarg) {
			/* remember that arg end with a ')' */
			arg[strlen(arg) - 1] = '';
			inst = (*pmod->f_init)(arg);
		} else
			inst = (*pmod->f_init)(NULL);
		if (inst < 0) {
			fprintf (stderr, "fail to initialize "%s"n", name);
			return (-1);
		}
		pstream->st[pstream->len].inst = inst;
		pstream->len++;
	} while (more_module);
	return (0);
}
int in_stream_setup (idef)
     char *idef;
{
  char defstr[256];
	strcpy (defstr, (idef ? idef : ""));
	return (stream_init (defstr, &in_stream));
}
int out_stream_setup (odef)
     char *odef;
{
  char defstr[256];
	strcpy (defstr, (odef ? odef : ""));
	return (stream_init (defstr, &out_stream));
} 
/*
 * Conversion buffer.  One for both directions.  They are in different
 * address space anyway.  Set the area to be at the middle of the buffer.
 * Just play safe
 */
static char conv_buf[BUFSIZ*3];
static char *buf = conv_buf + BUFSIZ;
/* pty --> stdout, do out_stream */
int stream_write (fd,s,len)
     int fd;
     char *s;
     int len;
{
  int i;
  char *p = buf;		/* point to the buffer for conversion */
	bcopy (s, p, len);	/* copy in */
	for (i = 0; i < out_stream.len; i++)
		p = (* out_stream.st[i].func)(p, &len, out_stream.st[i].inst);
	return ((len != 0) ? write (fd, p, len) : 0);
}
/* stdin --> pty, do in_stream */
int stream_read (fd,s,len)
     int fd;
     char *s;
     int len;
{
  int i, cc;
  char *p = buf;		/* point to the buffer for conversion */
	cc = read (fd, p, len);
	if (cc <= 0)
		return (-1);
	for (i = 0; i < in_stream.len; i++)
		p = (* in_stream.st[i].func)(p, &cc, in_stream.st[i].inst);
	if (cc != 0)
		bcopy (p, s, cc);	/* copy out */
	return (cc);
}
char *hzconvert (s, plen, psaved, dbcvrt)
     char *s;
     int *plen;
     char *psaved;		/* unprocessed char buffer pointer */
     void (*dbcvrt)();		/* 2-byte conversion func for a hanzi */
{
  char *p, *pend;
	if (*plen == 0)
		return (s);
        if (*psaved) {			/* previous buffered char */
                *(--s) = *psaved;	/* put the unprocessed char down */
		(*plen) ++;
		*psaved = 0;		/* clean this char buffer */
        }
	p = s;  pend = s + (*plen);	/* begin/end of the buffer string */
	while (p < pend) {
		if ((*p) & 0x80)	/* hi-bit on: hanzi */
			if (p < pend-1) 	/* not the last one */
				dbcvrt (p++);
			else {			/* the end of string */
				*psaved = *p;	/* save the unprocessed char */
				(*plen) --;
				break;
			}
		p++;
        }
        return (s);
}

						