diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-10-07 18:40:30 +0200 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-10-07 18:40:30 +0200 |
commit | 5625dbd1b6cddb8b84d8a3d8c60f95eaaa49be66 (patch) | |
tree | 3071fa0c07fdc7bc1bc2fa93af302bd3df47d943 /plugins/imudp | |
parent | 92ec206279e29d12d3d44e51280485d641579e41 (diff) | |
download | rsyslog-5625dbd1b6cddb8b84d8a3d8c60f95eaaa49be66.tar.gz rsyslog-5625dbd1b6cddb8b84d8a3d8c60f95eaaa49be66.tar.xz rsyslog-5625dbd1b6cddb8b84d8a3d8c60f95eaaa49be66.zip |
bugfix and testbench improvements
- bugfix: solved potential (temporary) stall of messages when the queue was
almost empty and few new data added (caused testbench to sometimes hang!)
- fixed some race condition in testbench
- added more elaborate diagnostics to parts of the testbench
- solved a potential race inside the queue engine
Diffstat (limited to 'plugins/imudp')
-rw-r--r-- | plugins/imudp/imudp.c | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/plugins/imudp/imudp.c b/plugins/imudp/imudp.c index b9db1875..a393cf96 100644 --- a/plugins/imudp/imudp.c +++ b/plugins/imudp/imudp.c @@ -256,6 +256,7 @@ processSocket(int fd, struct sockaddr_storage *frominetPrev, int *pbIsPermitted, pMsg->bParseHOSTNAME = 1; MsgSetRcvFromStr(pMsg, fromHost, ustrlen(fromHost), &propFromHost); CHKiRet(MsgSetRcvFromIPStr(pMsg, fromHostIP, ustrlen(fromHostIP), &propFromHostIP)); +dbgprintf("XXX: submitting msg to queue\n"); CHKiRet(submitMsg(pMsg)); } } |