summaryrefslogtreecommitdiffstats
path: root/stream.c
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2008-01-10 17:33:21 +0000
committerRainer Gerhards <rgerhards@adiscon.com>2008-01-10 17:33:21 +0000
commit68efb41220a834870681f293481655ed47e7b197 (patch)
tree7d86bb0fa5c08a02079f406267dff0bf49795a80 /stream.c
parent41f386f6abeff1577812a58ccd1d416a5389a85b (diff)
downloadrsyslog-68efb41220a834870681f293481655ed47e7b197.tar.gz
rsyslog-68efb41220a834870681f293481655ed47e7b197.tar.xz
rsyslog-68efb41220a834870681f293481655ed47e7b197.zip
- some cleanup
- implemented management function for worker thread 0 in order to change queue workers dynamically -- stage work
Diffstat (limited to 'stream.c')
-rw-r--r--stream.c5
1 files changed, 0 insertions, 5 deletions
diff --git a/stream.c b/stream.c
index 24c53313..740ca9fb 100644
--- a/stream.c
+++ b/stream.c
@@ -122,7 +122,6 @@ static rsRetVal strmCloseFile(strm_t *pThis)
pThis->pszCurrFName = NULL;
}
-dbgprintf("exit strmCloseFile, fd: %d\n", pThis->fd);
return iRet;
}
@@ -135,7 +134,6 @@ strmNextFile(strm_t *pThis)
{
DEFiRet;
-dbgprintf("strmNextFile, old num %d\n", pThis->iCurrFNum);
assert(pThis != NULL);
assert(pThis->iMaxFiles != 0);
assert(pThis->fd != -1);
@@ -582,7 +580,6 @@ rsRetVal strmRecordBegin(strm_t *pThis)
assert(pThis != NULL);
assert(pThis->bInRecord == 0);
pThis->bInRecord = 1;
-dbgprintf("strmRecordBegin set \n");
return RS_RET_OK;
}
@@ -592,10 +589,8 @@ rsRetVal strmRecordEnd(strm_t *pThis)
assert(pThis != NULL);
assert(pThis->bInRecord == 1);
-dbgprintf("strmRecordEnd in %d\n", iRet);
pThis->bInRecord = 0;
iRet = strmCheckNextOutputFile(pThis); /* check if we need to switch files */
-dbgprintf("strmRecordEnd out %d\n", iRet);
return iRet;
}