outchannel.c for 0.9.0 forgotten

1 files changed, 274 insertions, 0 deletions

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 <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <ctype.h>
+#include <assert.h>
+#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:
+ */