/******************************************************************************
Copyright (c) 1995, 1996 Xerox Corporation. All rights reserved.
Portions of this code were written by Stephen White, aka ghond.
Use and copying of this software and preparation of derivative works based
upon this software are permitted. Any distribution of this software or
derivative works must comply with all applicable United States export
control laws. This software is made available AS IS, and Xerox Corporation
makes no warranty about the software, its performance or its conformity to
any specification. Any person obtaining a copy of this software is requested
to send their name and post office or electronic mail address to:
Pavel Curtis
Xerox PARC
3333 Coyote Hill Rd.
Palo Alto, CA 94304
Pavel@Xerox.Com
*****************************************************************************/
/*****************************************************************************
* Routines for use by non-DB modules with persistent state stored in the DB
*****************************************************************************/
#include "my-ctype.h"
#include <float.h>
#include "my-stdarg.h"
#include "my-stdio.h"
#include "my-stdlib.h"
#include "db_io.h"
#include "db_private.h"
#include "exceptions.h"
#include "list.h"
#include "log.h"
#include "numbers.h"
#include "parser.h"
#include "storage.h"
#include "streams.h"
#include "structures.h"
#include "unparse.h"
#include "version.h"
/*********** Input ***********/
static FILE *input;
void
dbpriv_set_dbio_input(FILE *f)
{
input = f;
}
void
dbio_read_line(char *s, int n)
{
fgets(s, n, input);
}
int
dbio_scanf(const char *format, ...)
{
va_list args;
int count;
const char *ptr;
va_start(args, format);
/* The following line would be nice, but unfortunately those darlings on
* the ANSI C committee apparently didn't feel it worthwhile to include
* support for functions wrapping `scanf' *even though* they included
* symmetric such support for functions wrapping `printf'. (*sigh*)
* Fortunately, we only use a small fraction of the full functionality of
* scanf in the server, so it's not unbearably unpleasant to have to
* reimplement it here.
*/
/* count = vfscanf(input, format, args); */
count = 0;
for (ptr = format; *ptr; ptr++) {
int c, n, *ip;
unsigned *up;
char *cp;
if (isspace(*ptr)) {
do
c = fgetc(input);
while (isspace(c));
ungetc(c, input);
} else if (*ptr != '%') {
do
c = fgetc(input);
while (isspace(c));
if (c == EOF)
return count ? count : EOF;
else if (c != *ptr) {
ungetc(c, input);
return count;
}
} else
switch (*++ptr) {
case 'd':
ip = va_arg(args, int *);
n = fscanf(input, "%d", ip);
goto finish;
case 'u':
up = va_arg(args, unsigned *);
n = fscanf(input, "%u", up);
goto finish;
case 'c':
cp = va_arg(args, char *);
n = fscanf(input, "%c", cp);
finish:
if (n == 1)
count++;
else if (n == 0)
return count;
else /* n == EOF */
return count ? count : EOF;
break;
default:
panic("DBIO_SCANF: Unsupported directive!");
}
}
va_end(args);
return count;
}
int
dbio_read_num(void)
{
char s[20];
char *p;
int i;
fgets(s, 20, input);
i = strtol(s, &p, 10);
if (isspace(*s) || *p != '\n')
errlog("DBIO_READ_NUM: Bad number: \"%s\" at file pos. %ld\n",
s, ftell(input));
return i;
}
double
dbio_read_float(void)
{
char s[40];
char *p;
double d;
fgets(s, 40, input);
d = strtod(s, &p);
if (isspace(*s) || *p != '\n')
errlog("DBIO_READ_FLOAT: Bad number: \"%s\" at file pos. %ld\n",
s, ftell(input));
return d;
}
Objid
dbio_read_objid(void)
{
return dbio_read_num();
}
const char *
dbio_read_string(void)
{
static Stream *str = 0;
static char buffer[1024];
int len, used_stream = 0;
if (str == 0)
str = new_stream(1024);
try_again:
fgets(buffer, sizeof(buffer), input);
len = strlen(buffer);
if (len == sizeof(buffer) - 1 && buffer[len - 1] != '\n') {
stream_add_string(str, buffer);
used_stream = 1;
goto try_again;
}
if (buffer[len - 1] == '\n')
buffer[len - 1] = '\0';
if (used_stream) {
stream_add_string(str, buffer);
return reset_stream(str);
} else
return buffer;
}
Var
dbio_read_var(void)
{
Var r;
int i, l = dbio_read_num();
if (l == (int) TYPE_ANY && dbio_input_version == DBV_Prehistory)
l = TYPE_NONE; /* Old encoding for VM's empty temp register
* and any as-yet unassigned variables.
*/
r.type = (var_type) l;
switch (l) {
case TYPE_CLEAR:
case TYPE_NONE:
break;
case TYPE_STR:
r.v.str = str_dup(dbio_read_string());
break;
case TYPE_OBJ:
case TYPE_ERR:
case TYPE_INT:
case TYPE_CATCH:
case TYPE_FINALLY:
r.v.num = dbio_read_num();
break;
case TYPE_FLOAT:
r = new_float(dbio_read_float());
break;
case TYPE_LIST:
l = dbio_read_num();
r = new_list(l);
for (i = 0; i < l; i++)
r.v.list[i + 1] = dbio_read_var();
break;
default:
errlog("DBIO_READ_VAR: Unknown type (%d) at DB file pos. %ld\n",
l, ftell(input));
r = zero;
break;
}
return r;
}
struct state {
char prev_char;
const char *(*fmtr)(void *);
void *data;
};
static const char *
program_name(struct state *s)
{
if (!s->fmtr)
return s->data;
else
return (*s->fmtr)(s->data);
}
static void
my_error(void *data, const char *msg)
{
errlog("PARSER: Error in %s:\n", program_name(data));
errlog(" %s\n", msg);
}
static void
my_warning(void *data, const char *msg)
{
oklog("PARSER: Warning in %s:\n", program_name(data));
oklog(" %s\n", msg);
}
static int
my_getc(void *data)
{
struct state *s = data;
int c;
c = fgetc(input);
if (c == '.' && s->prev_char == '\n') {
/* end-of-verb marker in DB */
c = fgetc(input); /* skip next newline */
return EOF;
}
if (c == EOF)
my_error(data, "Unexpected EOF");
s->prev_char = c;
return c;
}
static Parser_Client parser_client = { my_error, my_warning, my_getc };
Program *
dbio_read_program(DB_Version version, const char *(*fmtr)(void *), void *data)
{
struct state s;
s.prev_char = '\n';
s.fmtr = fmtr;
s.data = data;
return parse_program(version, parser_client, &s);
}
/*********** Output ***********/
Exception dbpriv_dbio_failed;
static FILE *output;
void
dbpriv_set_dbio_output(FILE *f)
{
output = f;
}
void
dbio_printf(const char *format, ...)
{
va_list args;
va_start(args, format);
if (vfprintf(output, format, args) < 0)
RAISE(dbpriv_dbio_failed, 0);
va_end(args);
}
void
dbio_write_num(int n)
{
dbio_printf("%d\n", n);
}
void
dbio_write_float(double d)
{
static const char *fmt = 0;
static char buffer[10];
if (!fmt) {
sprintf(buffer, "%%.%dg\n", DBL_DIG + 4);
fmt = buffer;
}
dbio_printf(fmt, d);
}
void
dbio_write_objid(Objid oid)
{
dbio_write_num(oid);
}
void
dbio_write_string(const char *s)
{
dbio_printf("%s\n", s ? s : "");
}
void
dbio_write_var(Var v)
{
int i;
dbio_write_num((int) v.type);
switch (v.type) {
case TYPE_CLEAR:
case TYPE_NONE:
break;
case TYPE_STR:
dbio_write_string(v.v.str);
break;
case TYPE_OBJ:
case TYPE_ERR:
case TYPE_INT:
case TYPE_CATCH:
case TYPE_FINALLY:
dbio_write_num(v.v.num);
break;
case TYPE_FLOAT:
dbio_write_float(*v.v.fnum);
break;
case TYPE_LIST:
dbio_write_num(v.v.list[0].v.num);
for (i = 0; i < v.v.list[0].v.num; i++)
dbio_write_var(v.v.list[i + 1]);
break;
}
}
static void
receiver(void *data, const char *line)
{
dbio_printf("%s\n", line);
}
void
dbio_write_program(Program *program)
{
unparse_program(program, receiver, 0, 1, 0, MAIN_VECTOR);
dbio_printf(".\n");
}
void
dbio_write_forked_program(Program *program, int f_index)
{
unparse_program(program, receiver, 0, 1, 0, f_index);
dbio_printf(".\n");
}
char rcsid_db_io[] = "$Id: db_io.c,v 2.5 1996/03/19 07:16:12 pavel Exp $";
/* $Log: db_io.c,v $
* Revision 2.5 1996/03/19 07:16:12 pavel
* Increased precision of floating-point numbers printed in the DB file.
* Release 1.8.0p2.
*
* Revision 2.4 1996/03/10 01:04:16 pavel
* Increased the precision of printed floating-point numbers by two digits.
* Release 1.8.0.
*
* Revision 2.3 1996/02/08 07:19:15 pavel
* Renamed err/logf() to errlog/oklog() and TYPE_NUM to TYPE_INT. Added
* dbio_read/write_float(). Updated copyright notice for 1996.
* Release 1.8.0beta1.
*
* Revision 2.2 1995/12/28 00:44:51 pavel
* Added support for receiving MOO-compilation warnings during loading and for
* printing useful error and warning messages in the log.
* Release 1.8.0alpha3.
*
* Revision 2.1 1995/12/11 07:59:50 pavel
* Fixed broken #includes. Removed another silly use of `unsigned'.
*
* Release 1.8.0alpha2.
*
* Revision 2.0 1995/11/30 04:20:10 pavel
* New baseline version, corresponding to release 1.8.0alpha1.
*
* Revision 1.1 1995/11/30 04:19:56 pavel
* Initial revision
*/