From b14349ab99423a429bf1964fb0580acf95d6444f Mon Sep 17 00:00:00 2001 From: Rainer Gerhards Date: Mon, 27 Jun 2005 16:11:35 +0000 Subject: outchannel.c for 0.9.0 forgotten --- outchannel.c | 274 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 274 insertions(+) create mode 100644 outchannel.c (limited to 'outchannel.c') diff --git a/outchannel.c b/outchannel.c new file mode 100644 index 00000000..7bae91ad --- /dev/null +++ b/outchannel.c @@ -0,0 +1,274 @@ +/* This is the output channel processing code of rsyslog. + * Output channels - in the long term - will define how + * messages will be sent to whatever file or other medium. + * Currently, they mainly provide a way to store some file-related + * information (most importantly the maximum file size allowed). + * Please see syslogd.c for license information. + * This code is placed under the GPL. + * begun 2005-06-21 rgerhards + */ +#ifdef __FreeBSD__ +#define BSD +#endif + +#include +#include +#include +#include +#include +#include "liblogging-stub.h" +#include "stringbuf.h" +#include "outchannel.h" +#include "syslogd.h" + +static struct outchannel *ochRoot = NULL; /* the root of the outchannel list */ +static struct outchannel *ochLast = NULL; /* points to the last element of the outchannel list */ + +/* Constructs a outchannel list object. Returns pointer to it + * or NULL (if it fails). + */ +struct outchannel* ochConstruct(void) +{ + struct outchannel *pOch; + if((pOch = calloc(1, sizeof(struct outchannel))) == NULL) + return NULL; + + /* basic initialisaion is done via calloc() - need to + * initialize only values != 0. */ + + if(ochLast == NULL) + { /* we are the first element! */ + ochRoot = ochLast = pOch; + } + else + { + ochLast->pNext = pOch; + ochLast = pOch; + } + + return(pOch); +} + + +/* skips the next comma and any whitespace + * in front and after it. + */ +static void skip_Comma(char **pp) +{ + register char *p; + + assert(pp != NULL); + assert(*pp != NULL); + + p = *pp; + while(isspace(*p)) + ++p; + if(*p == ',') + ++p; + while(isspace(*p)) + ++p; + *pp = p; +} + +/* helper to ochAddLine. Parses a comma-delimited field + * The field is delimited by SP or comma. Leading whitespace + * is "eaten" and does not become part of the field content. + * returns: 0 - ok, 1 - failure + */ +static int get_Field(char **pp, char **pField) +{ + register char *p; + sbStrBObj *pStrB; + + assert(pp != NULL); + assert(*pp != NULL); + assert(pField != NULL); + + skip_Comma(pp); + p = *pp; + + if((pStrB = sbStrBConstruct()) == NULL) + return 1; + sbStrBSetAllocIncrement(pStrB, 32); + + /* copy the field */ + while(*p && *p != ' ' && *p != ',') { + sbStrBAppendChar(pStrB, *p++); + } + + *pp = p; + *pField = sbStrBFinish(pStrB); + + return 0; +} + + +/* helper to ochAddLine. Parses a off_t type from the + * input line. + * returns: 0 - ok, 1 - failure + */ +static int get_off_t(char **pp, off_t *pOff_t) +{ + register char *p; + off_t val; + + assert(pp != NULL); + assert(*pp != NULL); + assert(pOff_t != NULL); + + skip_Comma(pp); + p = *pp; + + val = 0; + while(*p && isdigit(*p)) { + val = val * 10 + (*p - '0'); + ++p; + } + + *pp = p; + *pOff_t = val; + + return 0; +} + + +/* helper to ochAddLine. Parses everything from the + * current position to the end of line and returns it + * to the caller. Leading white space is removed, but + * not trailing. + * returns: 0 - ok, 1 - failure + */ +static int get_restOfLine(char **pp, char **pBuf) +{ + register char *p; + sbStrBObj *pStrB; + + assert(pp != NULL); + assert(*pp != NULL); + assert(pBuf != NULL); + + skip_Comma(pp); + p = *pp; + + if((pStrB = sbStrBConstruct()) == NULL) + return 1; + sbStrBSetAllocIncrement(pStrB, 32); + + /* copy the field */ + while(*p) { + sbStrBAppendChar(pStrB, *p++); + } + + *pp = p; + *pBuf = sbStrBFinish(pStrB); + + return 0; +} + + +/* Add a new outchannel line + * returns pointer to new object if it succeeds, NULL otherwise. + * An outchannel line is primarily a set of fields delemited by commas. + * There might be some whitespace between the field (but not within) + * and the commas. This can be removed. + */ +struct outchannel *ochAddLine(char* pName, char** ppRestOfConfLine) +{ + struct outchannel *pOch; + char *p; + + assert(pName != NULL); + assert(ppRestOfConfLine != NULL); + + if((pOch = ochConstruct()) == NULL) + return NULL; + + pOch->iLenName = strlen(pName); + pOch->pszName = (char*) malloc(sizeof(char) * (pOch->iLenName + 1)); + if(pOch->pszName == NULL) { + dprintf("ochAddLine could not alloc memory for outchannel name!"); + pOch->iLenName = 0; + return NULL; + /* I know - we create a memory leak here - but I deem + * it acceptable as it is a) a very small leak b) very + * unlikely to happen. rgerhards 2004-11-17 + */ + } + memcpy(pOch->pszName, pName, pOch->iLenName + 1); + + /* now actually parse the line */ + p = *ppRestOfConfLine; + assert(p != NULL); + + /* get params */ + get_Field(&p, &pOch->pszFileTemplate); + if(*p) get_off_t(&p, &pOch->uSizeLimit); + if(*p) get_restOfLine(&p, &pOch->cmdOnSizeLimit); + + *ppRestOfConfLine = p; + return(pOch); +} + + +/* Find a outchannel object based on name. Search + * currently is case-senstive (should we change?). + * returns pointer to outchannel object if found and + * NULL otherwise. + * rgerhards 2004-11-17 + */ +struct outchannel *ochFind(char *pName, int iLenName) +{ + struct outchannel *pOch; + + assert(pName != NULL); + + pOch = ochRoot; + while(pOch != NULL && + !(pOch->iLenName == iLenName && + !strcmp(pOch->pszName, pName) + )) + { + pOch = pOch->pNext; + } + return(pOch); +} + +/* Destroy the outchannel structure. This is for de-initialization + * at program end. Everything is deleted. + * rgerhards 2005-02-22 + */ +void ochDeleteAll(void) +{ + struct outchannel *pOch, *pOchDel; + + pOch = ochRoot; + while(pOch != NULL) { + dprintf("Delete Outchannel: Name='%s'\n ", pOch->pszName == NULL? "NULL" : pOch->pszName); + pOchDel = pOch; + pOch = pOch->pNext; + if(pOchDel->pszName != NULL) + free(pOchDel->pszName); + free(pOchDel); + } +} + + +/* Print the outchannel structure. This is more or less a + * debug or test aid, but anyhow I think it's worth it... + */ +void ochPrintList(void) +{ + struct outchannel *pOch; + + pOch = ochRoot; + while(pOch != NULL) { + dprintf("Outchannel: Name='%s'\n", pOch->pszName == NULL? "NULL" : pOch->pszName); + dprintf("\tFile Template: '%s'\n", pOch->pszFileTemplate == NULL ? "NULL" : pOch->pszFileTemplate); + dprintf("\tMax Size.....: %lu\n", pOch->uSizeLimit); + dprintf("\tOnSizeLimtCmd: '%s'\n", pOch->cmdOnSizeLimit == NULL ? "NULL" : pOch->cmdOnSizeLimit); + pOch = pOch->pNext; /* done, go next */ + } +} +/* + * vi:set ai: + */ -- cgit