1 files changed, 15 insertions, 2 deletions
diff --git a/runtime/org.eclipse.etrice.runtime.c/src/common/messaging/etMessageService.h b/runtime/org.eclipse.etrice.runtime.c/src/common/messaging/etMessageService.h
index 0303bbf0c..f91cb3f82 100644
--- a/runtime/org.eclipse.etrice.runtime.c/src/common/messaging/etMessageService.h
+++ b/runtime/org.eclipse.etrice.runtime.c/src/common/messaging/etMessageService.h
@@ -17,6 +17,8 @@
 #include "etDatatypes.h"
 #include "messaging/etMessageQueue.h"
 #include "messaging/etMessageReceiver.h"
+#include "platform/etPlatform.h"
+
 
 typedef struct etBuffer{
 	etUInt8 *buffer;
@@ -29,20 +31,31 @@ typedef struct etMessageService {
 	etMessageQueue messagePool;
 	etBuffer messageBuffer;
 	etDispatcherReceiveMessage msgDispatcher;
+	etThread thread;
+	etMutex poolMutex;
+	etMutex queueMutex;
+	etSema executionSemaphore; /* sempahore for waiting and waking up the execution */
 } etMessageService;
 
+
+/* lifecycle functions to startup, execute and shutdown the message service */
 void etMessageService_init(etMessageService* self, etUInt8* buffer, etUInt16 maxBlocks, etUInt16 blockSize, etDispatcherReceiveMessage msgDispatcher);
+void etMessageService_start(etMessageService* self);
+void etMessageService_execute(etMessageService* self);
+void etMessageService_stop(etMessageService* self);
+void etMessageService_destroy(etMessageService* self);
 
+/* initialization of message pool */
 void etMessageService_initMessagePool(etMessageService* self);
 
+/* message queue interface for push and pop messages */
 void etMessageService_pushMessage(etMessageService* self, etMessage* msg);
 etMessage* etMessageService_popMessage(etMessageService* self);
 
+/* message pool interface to get and return (push and pop) messages */
 etMessage* etMessageService_getMessageBuffer(etMessageService* self, etUInt16 size);
 void etMessageService_returnMessageBuffer(etMessageService* self, etMessage* buffer);
 
-void etMessageService_execute(etMessageService* self);
-
 /* functions for debug and service information  */
 etInt16 etMessageService_getMessagePoolLowWaterMark(etMessageService* self);