123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253 |
- /* $Id: readconf.c,v 1.20 2004/03/20 15:46:27 dijkstra Exp $ */
- /*
- * Copyright (c) 2001-2004 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 <string.h>
- #include "data.h"
- #include "error.h"
- #include "lex.h"
- #include "net.h"
- #include "symon.h"
- #include "xmalloc.h"
- __BEGIN_DECLS
- int read_host_port(struct muxlist *, struct mux *, struct lex *);
- int read_symon_args(struct mux *, struct lex *);
- int read_monitor(struct muxlist *, struct lex *);
- __END_DECLS
- const char *default_symux_port = SYMUX_PORT;
- /* <hostname> (port|:|,| ) <number> */
- int
- read_host_port(struct muxlist * mul, struct mux * mux, struct lex * l)
- {
- char muxname[_POSIX2_LINE_MAX];
- lex_nexttoken(l);
- if (!getip(l->token)) {
- warning("%.200s:%d: could not resolve '%.200s'",
- l->filename, l->cline, l->token);
- return 0;
- }
- mux->addr = xstrdup((const char *) &res_host);
- /* check for port statement */
- if (!lex_nexttoken(l))
- return 1;
- if (l->op == LXT_PORT || l->op == LXT_COMMA)
- lex_nexttoken(l);
- if (l->type != LXY_NUMBER) {
- lex_ungettoken(l);
- mux->port = xstrdup(default_symux_port);
- } else {
- mux->port = xstrdup((const char *) l->token);
- }
- bzero(&muxname, sizeof(muxname));
- snprintf(&muxname[0], sizeof(muxname), "%s %s", mux->addr, mux->port);
- if (rename_mux(mul, mux, muxname) == NULL) {
- warning("%.200s:%d: monitored data for host '%.200s' has already been specified",
- l->filename, l->cline, muxname);
- return 0;
- }
- return 1;
- }
- /* parse "<cpu(arg)|mem|if(arg)|io(arg)|debug|pf|proc(arg)>", end condition == "}" */
- int
- read_symon_args(struct mux * mux, struct lex * l)
- {
- char sn[_POSIX2_LINE_MAX];
- char sa[_POSIX2_LINE_MAX];
- int st;
- 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_IO1:
- case LXT_MEM:
- case LXT_PF:
- case LXT_MBUF:
- case LXT_DEBUG:
- case LXT_PROC:
- case LXT_SENSOR:
- 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 (strlen(sa) > (SYMON_PS_ARGLEN - 1)) {
- warning("%.200s:%d: argument '%.200s' too long for network format, "
- "will send leading " SYMON_PS_ARGLENSTR " chars only",
- l->filename, l->cline, sa);
- }
- if ((add_mux_stream(mux, st, sa)) == NULL) {
- warning("%.200s:%d: stream %.200s(%.200s) redefined",
- l->filename, l->cline, sn, sa);
- return 0;
- }
- break; /* LXT_CPU/IF/IO/IO1/MEM/PF/MBUF/DEBUG/PROC/SENSOR */
- case LXT_COMMA:
- break;
- default:
- parse_error(l, "{cpu|mem|if|io|pf|debug|sensor}");
- return 0;
- break;
- }
- }
- return 1;
- }
- /* parse monitor <args> stream [to] <host>:<port> */
- int
- read_monitor(struct muxlist * mul, struct lex * l)
- {
- struct mux *mux;
- mux = add_mux(mul, SYMON_UNKMUX);
- /* parse [stream(streamarg)]+ */
- if (!read_symon_args(mux, l))
- return 0;
- lex_nexttoken(l);
- /* parse [every x seconds]? */
- if (l->op == LXT_EVERY) {
- lex_nexttoken(l);
- if (l->op == LXT_SECOND) {
- symon_interval = 1;
- } else if (l->type == LXY_NUMBER) {
- symon_interval = l->value;
- lex_nexttoken(l);
- if (l->op != LXT_SECONDS) {
- parse_error(l, "seconds");
- }
- } else {
- parse_error(l, "<number> ");
- return 0;
- }
- lex_nexttoken(l);
- }
- /* parse [stream to] */
- if (l->op != LXT_STREAM) {
- parse_error(l, "stream");
- return 0;
- }
- lex_nexttoken(l);
- if (l->op != LXT_TO)
- lex_ungettoken(l);
- /* parse [host [port]?] */
- return read_host_port(mul, mux, l);
- }
- /* Read symon.conf */
- int
- read_config_file(struct muxlist *muxlist, char *filename)
- {
- struct lex *l;
- struct mux *mux;
- SLIST_INIT(muxlist);
- l = open_lex(filename);
- while (lex_nexttoken(l)) {
- /* expecting keyword now */
- switch (l->op) {
- case LXT_MONITOR:
- if (!read_monitor(muxlist, l))
- return 0;
- break;
- default:
- parse_error(l, "monitor");
- return 0;
- break;
- }
- }
- /* sanity checks */
- SLIST_FOREACH(mux, muxlist, muxes) {
- if (strncmp(SYMON_UNKMUX, mux->name, sizeof(SYMON_UNKMUX)) == 0) {
- /* mux was not initialised for some reason */
- return 0;
- }
- if (SLIST_EMPTY(&mux->sl)) {
- warning("%.200s: no monitors selected for mux '%.200s'",
- l->filename, mux->name);
- return 0;
- }
- }
- if (symon_interval < SYMON_DEFAULT_INTERVAL) {
- warning("%.200s: monitoring set to every %d s", l->filename, symon_interval);
- }
- close_lex(l);
- return 1;
- }
|