123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316 |
- /* $Id: readconf.c,v 1.11 2002/08/11 19:54:48 dijkstra Exp $ */
- /*
- * Copyright (c) 2001-2002 Willem Dijkstra
- * All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions
- * are met:
- *
- * - Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * - Redistributions in binary form must reproduce the above
- * copyright notice, this list of conditions and the following
- * disclaimer in the documentation and/or other materials provided
- * with the distribution.
- *
- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
- * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
- * COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
- * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
- * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
- * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
- * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
- * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
- * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
- * POSSIBILITY OF SUCH DAMAGE.
- *
- */
- #include <sys/queue.h>
- #include <stdarg.h>
- #include <stdio.h>
- #include <string.h>
- #include <assert.h>
- #include <limits.h>
- #include <fcntl.h>
- #include <unistd.h>
- #include "xmalloc.h"
- #include "lex.h"
- #include "error.h"
- #include "net.h"
- #include "data.h"
- __BEGIN_DECLS
- int read_mux(struct muxlist *mul, struct lex *);
- int read_source(struct sourcelist *sol, struct lex *);
- __END_DECLS
- /* mux <host> (port|:|,| ) <number> */
- int
- read_mux(struct muxlist *mul, struct lex *l)
- {
- struct mux *m;
- if (! SLIST_EMPTY(mul)) {
- warning("%s:%d: only one mux statement allowed",
- l->filename, l->cline);
- return 0;
- }
-
- lex_nexttoken(l);
- if (!lookup(l->token)) {
- warning("%s:%d: could not resolve '%s'",
- l->filename, l->cline, l->token );
- return 0;
- }
- m = add_mux(mul, lookup_address);
- m->ip = lookup_ip;
- /* check for port statement */
- lex_nexttoken(l);
- if (l->op == LXT_PORT || l->op == LXT_COLON || l->op == LXT_COMMA)
- lex_nexttoken(l);
- else {
- if (l->type != LXY_NUMBER) {
- lex_ungettoken(l);
- m->port = MONMUX_PORT;
- return 1;
- }
- }
- if (l->type != LXY_NUMBER) {
- parse_error(l, "<number>");
- return 0;
- }
- m->port = l->value;
- return 1;
- }
- /* source <host> { accept ... | write ... } */
- int
- read_source(struct sourcelist *sol, struct lex *l)
- {
- struct source *source;
- struct stream *stream;
- char sn[_POSIX2_LINE_MAX];
- char sa[_POSIX2_LINE_MAX];
- int st;
- /* get hostname */
- lex_nexttoken(l);
- if (!lookup(l->token)) {
- warning("%s:%d: could not resolve '%s'",
- l->filename, l->cline, l->token );
- return 0;
- }
- source = add_source(sol, lookup_address);
- source->ip = lookup_ip;
- EXPECT(l, LXT_BEGIN);
- while (lex_nexttoken(l)) {
- switch (l->op) {
- /* accept { cpu(x), ... } */
- case LXT_ACCEPT:
- EXPECT(l, LXT_BEGIN);
- while (lex_nexttoken(l) && l->op != LXT_END) {
- switch (l->op) {
- case LXT_CPU:
- case LXT_IF:
- case LXT_IO:
- case LXT_MEM:
- st = token2type(l->op);
- strncpy(&sn[0], l->token, _POSIX2_LINE_MAX);
- /* parse arg */
- lex_nexttoken(l);
- if (l->op == LXT_OPEN) {
- lex_nexttoken(l);
- if (l->op == LXT_CLOSE) {
- parse_error(l, "<stream argument>");
- return 0;
- }
- strncpy(&sa[0], l->token, _POSIX2_LINE_MAX);
- lex_nexttoken(l);
- if (l->op != LXT_CLOSE) {
- parse_error(l, ")");
- return 0;
- }
- } else {
- lex_ungettoken(l);
- sa[0]='\0';
- }
- if ((stream = add_source_stream(source, st, sa)) == NULL) {
- warning("%s:%d: stream %s(%s) redefined",
- l->filename, l->cline, sn, sa);
- return 0;
- }
- break; /* LXT_CPU/LXT_IF/LXT_IO/LXT_MEM */
- case LXT_COMMA:
- break;
- default:
- parse_error(l, "{cpu|mem|if|io}");
- return 0;
- break;
- }
- }
- break; /* LXT_ACCEPT */
- /* write cpu(0) in "filename" */
- case LXT_WRITE:
- lex_nexttoken(l);
- switch (l->op) {
- case LXT_CPU:
- case LXT_IF:
- case LXT_IO:
- case LXT_MEM:
- st = token2type(l->op);
- strncpy(&sn[0], l->token, _POSIX2_LINE_MAX);
-
- /* parse arg */
- lex_nexttoken(l);
- if (l->op == LXT_OPEN) {
- lex_nexttoken(l);
- if (l->op == LXT_CLOSE) {
- parse_error(l, "<stream argument>");
- return 0;
- }
- strncpy(&sa[0], l->token, _POSIX2_LINE_MAX);
- lex_nexttoken(l);
- if (l->op != LXT_CLOSE) {
- parse_error(l, ")");
- return 0;
- }
- } else {
- lex_ungettoken(l);
- sa[0]='\0';
- }
-
- EXPECT(l, LXT_IN);
- lex_nexttoken(l);
-
- if ((stream = find_source_stream(source, st, sa)) == NULL) {
- if (strlen(sa)) {
- warning("%s:%d: stream %s(%s) is not accepted for %s",
- l->filename, l->cline, sn, sa, source->name);
- return 0;
- } else {
- warning("%s:%d: stream %s is not accepted for %s",
- l->filename, l->cline, sn, source->name);
- return 0;
- }
- } else {
- int fd;
- /* try filename */
- if ((fd = open(l->token, O_RDWR | O_NONBLOCK, 0)) == -1) {
- warning("%s:%d: file '%s' cannot be opened",
- l->filename, l->cline, l->token);
- return 0;
- } else {
- close(fd);
- stream->file = xstrdup(l->token);
- }
- }
- break; /* LXT_CPU/LXT_IF/LXT_IO/LXT_MEM */
- default:
- parse_error(l, "{cpu|mem|if|io}");
- return 0;
- break;
- }
- break; /* LXT_WRITE */
- case LXT_END:
- return 1;
- default:
- parse_error(l, "accept|write");
- return 0;
- }
- }
- warning("%s:%d: missing close brace on source statement",
- l->filename, l->cline);
- return 0;
- }
- /* Read monmux.conf */
- int
- read_config_file(struct muxlist *mul,
- struct sourcelist *sol,
- const char *filename)
- {
- struct lex *l;
- struct source *source;
- struct stream *stream;
- SLIST_INIT(mul);
- SLIST_INIT(sol);
- if ((l = open_lex(filename)) == NULL)
- return 0;
-
- info("reading configfile '%s'", filename);
- while (lex_nexttoken(l)) {
- /* expecting keyword now */
- switch (l->op) {
- case LXT_MUX:
- if (!read_mux(mul, l))
- return 0;
- break;
- case LXT_SOURCE:
- if (!read_source(sol, l))
- return 0;
- break;
- default:
- parse_error(l, "mux|source" );
- return 0;
- break;
- }
- }
-
- /* sanity checks */
- if (SLIST_EMPTY(mul)) {
- warning("%s: no mux statement seen",
- l->filename);
- return 0;
- }
- if (SLIST_EMPTY(sol)) {
- warning("%s: no source section seen",
- l->filename);
- return 0;
- } else {
- SLIST_FOREACH(source, sol, sources) {
- if (SLIST_EMPTY(&source->sl)) {
- warning("%s: no streams accepted for source '%s'",
- l->filename, source->name);
- return 0;
- } else {
- SLIST_FOREACH(stream, &source->sl, streams) {
- if (stream->file == NULL) {
- warning("%s: no filename specified for stream '%s(%s)' in source '%s'",
- l->filename, type2str(stream->type), stream->args, source->name);
- return 0;
- }
- }
- }
- }
- }
-
- close_lex(l);
-
- return 1;
- }
|