summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2005-06-27 16:11:35 +0000
committerRainer Gerhards <rgerhards@adiscon.com>2005-06-27 16:11:35 +0000
commitb14349ab99423a429bf1964fb0580acf95d6444f (patch)
tree2574c2d4907704a2d2e17c0f94de05309507f535
parent1e640499c09d6e010d1476e92c3932864ca97ced (diff)
downloadrsyslog-b14349ab99423a429bf1964fb0580acf95d6444f.tar.gz
rsyslog-b14349ab99423a429bf1964fb0580acf95d6444f.tar.xz
rsyslog-b14349ab99423a429bf1964fb0580acf95d6444f.zip
outchannel.c for 0.9.0 forgotten
-rw-r--r--outchannel.c274
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:
+ */