summaryrefslogtreecommitdiffstats
path: root/syslogd.c
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2008-03-14 11:04:36 +0000
committerRainer Gerhards <rgerhards@adiscon.com>2008-03-14 11:04:36 +0000
commitfdfcb2a8f953cc91abbe628366e3f5474a101670 (patch)
tree9dae7bb09bd99a7f98cc9edb609c48ce09b07013 /syslogd.c
parentde0665a4755140715ad9d95098f6b3a7ff713bd2 (diff)
downloadrsyslog-fdfcb2a8f953cc91abbe628366e3f5474a101670.tar.gz
rsyslog-fdfcb2a8f953cc91abbe628366e3f5474a101670.tar.xz
rsyslog-fdfcb2a8f953cc91abbe628366e3f5474a101670.zip
added advanced flow control for congestion cases (mode depending on message
source and its capablity to be delayed without bad side effects)
Diffstat (limited to 'syslogd.c')
-rw-r--r--syslogd.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/syslogd.c b/syslogd.c
index e50e4727..6ecf5865 100644
--- a/syslogd.c
+++ b/syslogd.c
@@ -1543,7 +1543,7 @@ submitMsg(msg_t *pMsg)
ISOBJ_TYPE_assert(pMsg, msg);
MsgPrepareEnqueue(pMsg);
- queueEnqObj(pMsgQueue, (void*) pMsg);
+ queueEnqObj(pMsgQueue, pMsg->flowCtlType, (void*) pMsg);
RETiRet;
}
@@ -1640,7 +1640,7 @@ logmsg(msg_t *pMsg, int flags)
pMsg->msgFlags = flags;
MsgPrepareEnqueue(pMsg);
- queueEnqObj(pMsgQueue, (void*) pMsg);
+ queueEnqObj(pMsgQueue, pMsg->flowCtlType, (void*) pMsg);
ENDfunc
}