added capability for concurrent access to the msg class. Can be dynamically

    activated. If active, locking is employed.

1 files changed, 5 insertions, 0 deletions

diff --git a/syslogd.c b/syslogd.c
index abb6d16b..28060db9 100644
--- a/syslogd.c
+++ b/syslogd.c
@@ -2338,6 +2338,7 @@ logmsg(int pri, msg_t *pMsg, int flags)
 	 */
 	
 	pMsg->msgFlags = flags;
+	MsgPrepareEnqueue(pMsg);
 	queueEnqObj(pMsgQueue, (void*) pMsg);
 }
 
@@ -3349,6 +3350,10 @@ init(void)
 		pDfltProgNameCmp = NULL;
 	}
 
+	/* switch the message object to threaded operation, if necessary */
+	// TODO: handle the "if" part above ;)
+	MsgEnableThreadSafety();
+
 	/* create message queue */
 	CHKiRet_Hdlr(queueConstruct(&pMsgQueue, MainMsgQueType, iMainMsgQueueSize, msgConsumer)) {
 		/* no queue is fatal, we need to give up in that case... */