diff options
| author | Thomas Schuetz | 2013-04-29 19:35:39 +0000 |
|---|---|---|
| committer | Thomas Schuetz | 2013-04-29 19:35:39 +0000 |
| commit | 8ab083b90fbf7f51e39ad6c9c7ef4cf7c92aae93 (patch) | |
| tree | 819b677c2c49951d13ba81ed1865689e4d0f56c5 | |
| parent | bdeb20297bf7a180e1ade30970f72696f40204c2 (diff) | |
| download | org.eclipse.etrice-8ab083b90fbf7f51e39ad6c9c7ef4cf7c92aae93.tar.gz org.eclipse.etrice-8ab083b90fbf7f51e39ad6c9c7ef4cf7c92aae93.tar.xz org.eclipse.etrice-8ab083b90fbf7f51e39ad6c9c7ef4cf7c92aae93.zip | |
[generator.c.reference] removed src-gen content from version control
19 files changed, 0 insertions, 2374 deletions
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/CommunicationProtocol.c b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/CommunicationProtocol.c deleted file mode 100644 index 9b9485362..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/CommunicationProtocol.c +++ /dev/null @@ -1,66 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Source File of ProtocolClass CommunicationProtocol
- *
- */
-
-#include "CommunicationProtocol.h"
-#include "debugging/etMSCLogger.h"
-
-
-/*--------------------- port methods */
-
-
-// getReplication
-etInt32 CommunicationProtocolReplPort_getReplication(const CommunicationProtocolReplPort* self) {
- return ((etReplPort*)self)->size;
-}
-
-
-
-void CommunicationProtocolConjPort_sendData(const CommunicationProtocolConjPort* self) {
- ET_MSC_LOGGER_SYNC_ENTRY("CommunicationProtocolConjPort", "sendData")
- etPort_sendMessage(self, CommunicationProtocol_IN_sendData, 0, NULL);
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void CommunicationProtocolConjReplPort_sendData_broadcast(const CommunicationProtocolConjReplPort* self) {
- int i;
- ET_MSC_LOGGER_SYNC_ENTRY("CommunicationProtocolConjReplPort", "sendData")
- for (i=0; i<((etReplPort*)self)->size; ++i) {
- etPort_sendMessage(((etPort*)&((etReplPort*)self)->ports[i]), CommunicationProtocol_IN_sendData, 0, NULL);
- }
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void CommunicationProtocolConjReplPort_sendData(const CommunicationProtocolConjReplPort* self, int idx) {
- ET_MSC_LOGGER_SYNC_ENTRY("CommunicationProtocolConjReplPort", "sendData")
- if (0<=idx && idx<((etReplPort*)self)->size) {
- etPort_sendMessage(((etPort*)&((etReplPort*)self)->ports[idx]), CommunicationProtocol_IN_sendData, 0, NULL);
- }
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-// getReplication
-etInt32 CommunicationProtocolConjReplPort_getReplication(const CommunicationProtocolConjReplPort* self) {
- return ((etReplPort*)self)->size;
-}
-
-
-
-/*--------------------- debug helpers */
-
-/* message names as strings for debugging (generate MSC) */
-static const char* const CommunicationProtocol_messageStrings[] = {"MIN", "sendData", "MAX"};
-
-const char* CommunicationProtocol_getMessageString(int msg_id) {
- if (msg_id<CommunicationProtocol_MSG_MIN || msg_id>CommunicationProtocol_MSG_MAX+1){
- /* id out of range */
- return "Message ID out of range";
- }
- else{
- return CommunicationProtocol_messageStrings[msg_id];
- }
-}
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/CommunicationProtocol.h b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/CommunicationProtocol.h deleted file mode 100644 index 77f25a011..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/CommunicationProtocol.h +++ /dev/null @@ -1,50 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Header File of ProtocolClass CommunicationProtocol
- *
- */
-
-#ifndef _COMMUNICATIONPROTOCOL_H_
-#define _COMMUNICATIONPROTOCOL_H_
-
-#include "etDatatypes.h"
-#include "modelbase/etPort.h"
-
-
-
-
-/* message IDs */
-enum CommunicationProtocol_msg_ids {
- CommunicationProtocol_MSG_MIN = 0,
- CommunicationProtocol_IN_sendData = 1,
- CommunicationProtocol_MSG_MAX = 2
-};
-
-/*--------------------- port structs and methods */
-typedef etPort CommunicationProtocolPort;
-typedef etReplPort CommunicationProtocolReplPort;
-
-
-
-
-etInt32 CommunicationProtocolReplPort_getReplication(const CommunicationProtocolReplPort* self);
-typedef etPort CommunicationProtocolConjPort;
-typedef etReplPort CommunicationProtocolConjReplPort;
-
-
-void CommunicationProtocolConjPort_sendData(const CommunicationProtocolConjPort* self);
-void CommunicationProtocolConjReplPort_sendData_broadcast(const CommunicationProtocolConjReplPort* self);
-void CommunicationProtocolConjReplPort_sendData(const CommunicationProtocolConjReplPort* self, int idx);
-
-
-etInt32 CommunicationProtocolConjReplPort_getReplication(const CommunicationProtocolConjReplPort* self);
-
-/*--------------------- debug helpers */
-
-/* get message string for message id */
-const char* CommunicationProtocol_getMessageString(int msg_id);
-
-
-#endif /* _COMMUNICATIONPROTOCOL_H_ */
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Fork.c b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Fork.c deleted file mode 100644 index 068663391..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Fork.c +++ /dev/null @@ -1,185 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Source File of ActorClass Fork
- *
- */
-
-#include "Fork.h"
-
-#include "modelbase/etActor.h"
-#include "debugging/etLogger.h"
-#include "debugging/etMSCLogger.h"
-#include "etUnit/etUnit.h"
-#include "platform/etMemory.h"
-
-#include "CommunicationProtocol.h"
-
-
-/* interface item IDs */
-enum interface_items {
- IFITEM_broadcast = 1,
- IFITEM_inport = 2
-};
-
-/* state IDs */
-enum state_ids {
- NO_STATE = 0,
- STATE_TOP = 1,
- STATE_Fork = 2
-};
-
-/* transition chains */
-enum chain_ids {
- CHAIN_TRANS_INITIAL_TO__Fork = 1,
- CHAIN_TRANS_tr0_FROM_Fork_TO_Fork_BY_sendDatainport_tr0 = 2
-};
-
-/* triggers */
-enum triggers {
- POLLING = 0,
- TRIG_inport__sendData = IFITEM_inport + EVT_SHIFT*CommunicationProtocol_IN_sendData
-};
-
-
-static void setState(Fork* self, int new_state) {
- self->state = (etInt16) new_state;
-}
-
-static int getState(Fork* self) {
- return self->state;
-}
-
-/* Entry and Exit Codes */
-
-/* Action Codes */
-static void action_TRANS_tr0_FROM_Fork_TO_Fork_BY_sendDatainport_tr0(Fork* self, const InterfaceItemBase* ifitem) {
- CommunicationProtocolConjReplPort_sendData_broadcast(&self->constData->broadcast) /* ORIG: broadcast.sendData() */;
-}
-
-/**
- * calls exit codes while exiting from the current state to one of its
- * parent states while remembering the history
- * @param current - the current state
- * @param to - the final parent state
- * @param handler - entry and exit codes are called only if not handler (for handler TransitionPoints)
- */
-static void exitTo(Fork* self, int current, int to, boolean handler) {
- while (current!=to) {
- switch (current) {
- case STATE_Fork:
- self->history[STATE_TOP] = STATE_Fork;
- current = STATE_TOP;
- break;
- }
- }
-}
-
-/**
- * calls action, entry and exit codes along a transition chain. The generic data are cast to typed data
- * matching the trigger of this chain. The ID of the final state is returned
- * @param chain - the chain ID
- * @param generic_data - the generic data pointer
- * @return the ID of the final state
- */
-static int executeTransitionChain(Fork* self, int chain, const InterfaceItemBase* ifitem, void* generic_data) {
- switch (chain) {
- case CHAIN_TRANS_INITIAL_TO__Fork:
- {
- return STATE_Fork;
- }
- case CHAIN_TRANS_tr0_FROM_Fork_TO_Fork_BY_sendDatainport_tr0:
- {
- action_TRANS_tr0_FROM_Fork_TO_Fork_BY_sendDatainport_tr0(self, ifitem);
- return STATE_Fork;
- }
- }
- return NO_STATE;
-}
-
-/**
- * calls entry codes while entering a state's history. The ID of the final leaf state is returned
- * @param state - the state which is entered
- * @param handler - entry code is executed if not handler
- * @return - the ID of the final leaf state
- */
-static int enterHistory(Fork* self, int state, boolean handler, boolean skip_entry) {
- while (TRUE) {
- switch (state) {
- case STATE_Fork:
- // in leaf state: return state id
- return STATE_Fork;
- case STATE_TOP:
- state = self->history[STATE_TOP];
- break;
- }
- skip_entry = FALSE;
- }
- //return NO_STATE; // required by CDT but detected as unreachable by JDT because of while (true)
-}
-
-static void Fork_executeInitTransition(Fork* self) {
- int chain = CHAIN_TRANS_INITIAL_TO__Fork;
- int next = executeTransitionChain(self, chain, NULL, NULL);
- next = enterHistory(self, next, FALSE, FALSE);
- setState(self, next);
-}
-
-/* receiveEvent contains the main implementation of the FSM */
-static void Fork_receiveEvent(Fork* self, InterfaceItemBase* ifitem, int evt, void* generic_data) {
- int trigger = ifitem->localId + EVT_SHIFT*evt;
- int chain = NOT_CAUGHT;
- int catching_state = NO_STATE;
- boolean is_handler = FALSE;
- boolean skip_entry = FALSE;
-
- if (!handleSystemEvent(ifitem, evt, generic_data)) {
- switch (getState(self)) {
- case STATE_Fork:
- switch(trigger) {
- case TRIG_inport__sendData:
- {
- chain = CHAIN_TRANS_tr0_FROM_Fork_TO_Fork_BY_sendDatainport_tr0;
- catching_state = STATE_TOP;
- }
- break;
- }
- break;
- }
- }
- if (chain != NOT_CAUGHT) {
- exitTo(self, getState(self), catching_state, is_handler);
- int next = executeTransitionChain(self, chain, ifitem, generic_data);
- next = enterHistory(self, next, is_handler, skip_entry);
- setState(self, next);
- }
-}
-
-//******************************************
-// END of generated code for FSM
-//******************************************
-
-void Fork_init(Fork* self){
- ET_MSC_LOGGER_SYNC_ENTRY("Fork", "init")
- self->state = STATE_TOP;
- {
- int i;
- for (i=0; i<FORK_HISTORY_SIZE; ++i)
- self->history[i] = NO_STATE;
- }
- Fork_executeInitTransition(self);
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-void Fork_receiveMessage(void* self, void* ifitem, const etMessage* msg){
- ET_MSC_LOGGER_SYNC_ENTRY("Fork", "_receiveMessage")
-
- Fork_receiveEvent(self, (etPort*)ifitem, msg->evtID, (void*)(((char*)msg)+MEM_CEIL(sizeof(etMessage))));
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-/*--------------------- operations ---------------------*/
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Fork.h b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Fork.h deleted file mode 100644 index db8779537..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Fork.h +++ /dev/null @@ -1,61 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Header File of ActorClass Fork
- *
- */
-
-#ifndef _FORK_H_
-#define _FORK_H_
-
-#include "etDatatypes.h"
-#include "messaging/etMessage.h"
-
-#include "CommunicationProtocol.h"
-
-
-typedef struct Fork Fork;
-
-/* const part of ActorClass (ROM) */
-typedef struct Fork_const {
- /* simple ports */
- const CommunicationProtocolPort inport;
-
- /* data receive ports */
-
- /* saps */
-
- /* replicated ports */
- const etReplPort broadcast;
-
- /* services */
-} Fork_const;
-
-
-/* constant for state machine data */
-#define FORK_HISTORY_SIZE 2
-
-/* variable part of ActorClass (RAM) */
-struct Fork {
- const Fork_const* const constData;
-
- /* data send ports */
-
- /*--------------------- attributes ---------------------*/
-
-
- /* state machine variables */
- etInt16 state;
- etInt16 history[FORK_HISTORY_SIZE];
-};
-
-void Fork_init(Fork* self);
-
-void Fork_receiveMessage(void* self, void* ifitem, const etMessage* msg);
-
-
-/*--------------------- operations ---------------------*/
-
-
-#endif /* _FORK_H_ */
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Join.c b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Join.c deleted file mode 100644 index f3a8650c8..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Join.c +++ /dev/null @@ -1,226 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Source File of ActorClass Join
- *
- */
-
-#include "Join.h"
-
-#include "modelbase/etActor.h"
-#include "debugging/etLogger.h"
-#include "debugging/etMSCLogger.h"
-#include "etUnit/etUnit.h"
-#include "platform/etMemory.h"
-
-#include "CommunicationProtocol.h"
-#include "SecurityProtocol.h"
-
-
-/* interface item IDs */
-enum interface_items {
- IFITEM_inport = 1,
- IFITEM_outport = 2,
- IFITEM_security = 3
-};
-
-/* state IDs */
-enum state_ids {
- NO_STATE = 0,
- STATE_TOP = 1,
- STATE_Count = 2,
- STATE_Done = 3
-};
-
-/* transition chains */
-enum chain_ids {
- CHAIN_TRANS_INITIAL_TO__Count = 1,
- CHAIN_TRANS_tr0_FROM_Count_TO_cp0_BY_pongsecurity = 2,
- CHAIN_TRANS_tr3_FROM_Count_TO_Count_BY_sendDatainport_tr3 = 3
-};
-
-/* triggers */
-enum triggers {
- POLLING = 0,
- TRIG_inport__sendData = IFITEM_inport + EVT_SHIFT*CommunicationProtocol_IN_sendData,
- TRIG_security__pong = IFITEM_security + EVT_SHIFT*SecurityProtocol_OUT_pong
-};
-
-
-static void setState(Join* self, int new_state) {
- self->state = (etInt16) new_state;
-}
-
-static int getState(Join* self) {
- return self->state;
-}
-
-/* Entry and Exit Codes */
-
-/* Action Codes */
-static void action_TRANS_INITIAL_TO__Count(Join* self) {
- self->counter /* ORIG: counter */=0;
-}
-static void action_TRANS_tr0_FROM_Count_TO_cp0_BY_pongsecurity(Join* self, const InterfaceItemBase* ifitem) {
- self->counter /* ORIG: counter */++;
- etLogger_logInfo("+++ Join: received pong +++");
-}
-static void action_TRANS_tr1_FROM_cp0_TO_Done(Join* self, const InterfaceItemBase* ifitem) {
- CommunicationProtocolConjPort_sendData(&self->constData->outport) /* ORIG: outport.sendData() */;
-}
-static void action_TRANS_tr3_FROM_Count_TO_Count_BY_sendDatainport_tr3(Join* self, const InterfaceItemBase* ifitem) {
- SecurityProtocolConjPort_ping(&self->constData->security) /* ORIG: security.ping() */;
- etLogger_logInfo("+++ Join: sent ping +++");
-}
-
-/**
- * calls exit codes while exiting from the current state to one of its
- * parent states while remembering the history
- * @param current - the current state
- * @param to - the final parent state
- * @param handler - entry and exit codes are called only if not handler (for handler TransitionPoints)
- */
-static void exitTo(Join* self, int current, int to, boolean handler) {
- while (current!=to) {
- switch (current) {
- case STATE_Count:
- self->history[STATE_TOP] = STATE_Count;
- current = STATE_TOP;
- break;
- case STATE_Done:
- self->history[STATE_TOP] = STATE_Done;
- current = STATE_TOP;
- break;
- }
- }
-}
-
-/**
- * calls action, entry and exit codes along a transition chain. The generic data are cast to typed data
- * matching the trigger of this chain. The ID of the final state is returned
- * @param chain - the chain ID
- * @param generic_data - the generic data pointer
- * @return the ID of the final state
- */
-static int executeTransitionChain(Join* self, int chain, const InterfaceItemBase* ifitem, void* generic_data) {
- switch (chain) {
- case CHAIN_TRANS_INITIAL_TO__Count:
- {
- action_TRANS_INITIAL_TO__Count(self);
- return STATE_Count;
- }
- case CHAIN_TRANS_tr0_FROM_Count_TO_cp0_BY_pongsecurity:
- {
- action_TRANS_tr0_FROM_Count_TO_cp0_BY_pongsecurity(self, ifitem);
- if (self->counter /* ORIG: counter */<10) {
- return STATE_Count;}
- else {
- action_TRANS_tr1_FROM_cp0_TO_Done(self, ifitem);
- return STATE_Done;}
- }
- case CHAIN_TRANS_tr3_FROM_Count_TO_Count_BY_sendDatainport_tr3:
- {
- action_TRANS_tr3_FROM_Count_TO_Count_BY_sendDatainport_tr3(self, ifitem);
- return STATE_Count;
- }
- }
- return NO_STATE;
-}
-
-/**
- * calls entry codes while entering a state's history. The ID of the final leaf state is returned
- * @param state - the state which is entered
- * @param handler - entry code is executed if not handler
- * @return - the ID of the final leaf state
- */
-static int enterHistory(Join* self, int state, boolean handler, boolean skip_entry) {
- while (TRUE) {
- switch (state) {
- case STATE_Count:
- // in leaf state: return state id
- return STATE_Count;
- case STATE_Done:
- // in leaf state: return state id
- return STATE_Done;
- case STATE_TOP:
- state = self->history[STATE_TOP];
- break;
- }
- skip_entry = FALSE;
- }
- //return NO_STATE; // required by CDT but detected as unreachable by JDT because of while (true)
-}
-
-static void Join_executeInitTransition(Join* self) {
- int chain = CHAIN_TRANS_INITIAL_TO__Count;
- int next = executeTransitionChain(self, chain, NULL, NULL);
- next = enterHistory(self, next, FALSE, FALSE);
- setState(self, next);
-}
-
-/* receiveEvent contains the main implementation of the FSM */
-static void Join_receiveEvent(Join* self, InterfaceItemBase* ifitem, int evt, void* generic_data) {
- int trigger = ifitem->localId + EVT_SHIFT*evt;
- int chain = NOT_CAUGHT;
- int catching_state = NO_STATE;
- boolean is_handler = FALSE;
- boolean skip_entry = FALSE;
-
- if (!handleSystemEvent(ifitem, evt, generic_data)) {
- switch (getState(self)) {
- case STATE_Count:
- switch(trigger) {
- case TRIG_security__pong:
- {
- chain = CHAIN_TRANS_tr0_FROM_Count_TO_cp0_BY_pongsecurity;
- catching_state = STATE_TOP;
- }
- break;
- case TRIG_inport__sendData:
- {
- chain = CHAIN_TRANS_tr3_FROM_Count_TO_Count_BY_sendDatainport_tr3;
- catching_state = STATE_TOP;
- }
- break;
- }
- break;
- case STATE_Done:
- break;
- }
- }
- if (chain != NOT_CAUGHT) {
- exitTo(self, getState(self), catching_state, is_handler);
- int next = executeTransitionChain(self, chain, ifitem, generic_data);
- next = enterHistory(self, next, is_handler, skip_entry);
- setState(self, next);
- }
-}
-
-//******************************************
-// END of generated code for FSM
-//******************************************
-
-void Join_init(Join* self){
- ET_MSC_LOGGER_SYNC_ENTRY("Join", "init")
- self->state = STATE_TOP;
- {
- int i;
- for (i=0; i<JOIN_HISTORY_SIZE; ++i)
- self->history[i] = NO_STATE;
- }
- Join_executeInitTransition(self);
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-void Join_receiveMessage(void* self, void* ifitem, const etMessage* msg){
- ET_MSC_LOGGER_SYNC_ENTRY("Join", "_receiveMessage")
-
- Join_receiveEvent(self, (etPort*)ifitem, msg->evtID, (void*)(((char*)msg)+MEM_CEIL(sizeof(etMessage))));
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-/*--------------------- operations ---------------------*/
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Join.h b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Join.h deleted file mode 100644 index 9ab937fec..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Join.h +++ /dev/null @@ -1,64 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Header File of ActorClass Join
- *
- */
-
-#ifndef _JOIN_H_
-#define _JOIN_H_
-
-#include "etDatatypes.h"
-#include "messaging/etMessage.h"
-
-#include "CommunicationProtocol.h"
-#include "SecurityProtocol.h"
-
-
-typedef struct Join Join;
-
-/* const part of ActorClass (ROM) */
-typedef struct Join_const {
- /* simple ports */
- const CommunicationProtocolConjPort outport;
- const SecurityProtocolConjPort security;
-
- /* data receive ports */
-
- /* saps */
-
- /* replicated ports */
- const etReplPort inport;
-
- /* services */
-} Join_const;
-
-
-/* constant for state machine data */
-#define JOIN_HISTORY_SIZE 2
-
-/* variable part of ActorClass (RAM) */
-struct Join {
- const Join_const* const constData;
-
- /* data send ports */
-
- /*--------------------- attributes ---------------------*/
- int32 counter;
-
-
- /* state machine variables */
- etInt16 state;
- etInt16 history[JOIN_HISTORY_SIZE];
-};
-
-void Join_init(Join* self);
-
-void Join_receiveMessage(void* self, void* ifitem, const etMessage* msg);
-
-
-/*--------------------- operations ---------------------*/
-
-
-#endif /* _JOIN_H_ */
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Redirect.c b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Redirect.c deleted file mode 100644 index f9575397f..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Redirect.c +++ /dev/null @@ -1,186 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Source File of ActorClass Redirect
- *
- */
-
-#include "Redirect.h"
-
-#include "modelbase/etActor.h"
-#include "debugging/etLogger.h"
-#include "debugging/etMSCLogger.h"
-#include "etUnit/etUnit.h"
-#include "platform/etMemory.h"
-
-#include "CommunicationProtocol.h"
-
-
-/* interface item IDs */
-enum interface_items {
- IFITEM_inport = 1,
- IFITEM_outport = 2
-};
-
-/* state IDs */
-enum state_ids {
- NO_STATE = 0,
- STATE_TOP = 1,
- STATE_Redirect = 2
-};
-
-/* transition chains */
-enum chain_ids {
- CHAIN_TRANS_INITIAL_TO__Redirect = 1,
- CHAIN_TRANS_tr0_FROM_Redirect_TO_Redirect_BY_sendDatainport_tr0 = 2
-};
-
-/* triggers */
-enum triggers {
- POLLING = 0,
- TRIG_inport__sendData = IFITEM_inport + EVT_SHIFT*CommunicationProtocol_IN_sendData
-};
-
-
-static void setState(Redirect* self, int new_state) {
- self->state = (etInt16) new_state;
-}
-
-static int getState(Redirect* self) {
- return self->state;
-}
-
-/* Entry and Exit Codes */
-
-/* Action Codes */
-static void action_TRANS_tr0_FROM_Redirect_TO_Redirect_BY_sendDatainport_tr0(Redirect* self, const InterfaceItemBase* ifitem) {
- CommunicationProtocolConjPort_sendData(&self->constData->outport) /* ORIG: outport.sendData() */;
- etLogger_logInfo("+++ Redirect: sendData +++");
-}
-
-/**
- * calls exit codes while exiting from the current state to one of its
- * parent states while remembering the history
- * @param current - the current state
- * @param to - the final parent state
- * @param handler - entry and exit codes are called only if not handler (for handler TransitionPoints)
- */
-static void exitTo(Redirect* self, int current, int to, boolean handler) {
- while (current!=to) {
- switch (current) {
- case STATE_Redirect:
- self->history[STATE_TOP] = STATE_Redirect;
- current = STATE_TOP;
- break;
- }
- }
-}
-
-/**
- * calls action, entry and exit codes along a transition chain. The generic data are cast to typed data
- * matching the trigger of this chain. The ID of the final state is returned
- * @param chain - the chain ID
- * @param generic_data - the generic data pointer
- * @return the ID of the final state
- */
-static int executeTransitionChain(Redirect* self, int chain, const InterfaceItemBase* ifitem, void* generic_data) {
- switch (chain) {
- case CHAIN_TRANS_INITIAL_TO__Redirect:
- {
- return STATE_Redirect;
- }
- case CHAIN_TRANS_tr0_FROM_Redirect_TO_Redirect_BY_sendDatainport_tr0:
- {
- action_TRANS_tr0_FROM_Redirect_TO_Redirect_BY_sendDatainport_tr0(self, ifitem);
- return STATE_Redirect;
- }
- }
- return NO_STATE;
-}
-
-/**
- * calls entry codes while entering a state's history. The ID of the final leaf state is returned
- * @param state - the state which is entered
- * @param handler - entry code is executed if not handler
- * @return - the ID of the final leaf state
- */
-static int enterHistory(Redirect* self, int state, boolean handler, boolean skip_entry) {
- while (TRUE) {
- switch (state) {
- case STATE_Redirect:
- // in leaf state: return state id
- return STATE_Redirect;
- case STATE_TOP:
- state = self->history[STATE_TOP];
- break;
- }
- skip_entry = FALSE;
- }
- //return NO_STATE; // required by CDT but detected as unreachable by JDT because of while (true)
-}
-
-static void Redirect_executeInitTransition(Redirect* self) {
- int chain = CHAIN_TRANS_INITIAL_TO__Redirect;
- int next = executeTransitionChain(self, chain, NULL, NULL);
- next = enterHistory(self, next, FALSE, FALSE);
- setState(self, next);
-}
-
-/* receiveEvent contains the main implementation of the FSM */
-static void Redirect_receiveEvent(Redirect* self, InterfaceItemBase* ifitem, int evt, void* generic_data) {
- int trigger = ifitem->localId + EVT_SHIFT*evt;
- int chain = NOT_CAUGHT;
- int catching_state = NO_STATE;
- boolean is_handler = FALSE;
- boolean skip_entry = FALSE;
-
- if (!handleSystemEvent(ifitem, evt, generic_data)) {
- switch (getState(self)) {
- case STATE_Redirect:
- switch(trigger) {
- case TRIG_inport__sendData:
- {
- chain = CHAIN_TRANS_tr0_FROM_Redirect_TO_Redirect_BY_sendDatainport_tr0;
- catching_state = STATE_TOP;
- }
- break;
- }
- break;
- }
- }
- if (chain != NOT_CAUGHT) {
- exitTo(self, getState(self), catching_state, is_handler);
- int next = executeTransitionChain(self, chain, ifitem, generic_data);
- next = enterHistory(self, next, is_handler, skip_entry);
- setState(self, next);
- }
-}
-
-//******************************************
-// END of generated code for FSM
-//******************************************
-
-void Redirect_init(Redirect* self){
- ET_MSC_LOGGER_SYNC_ENTRY("Redirect", "init")
- self->state = STATE_TOP;
- {
- int i;
- for (i=0; i<REDIRECT_HISTORY_SIZE; ++i)
- self->history[i] = NO_STATE;
- }
- Redirect_executeInitTransition(self);
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-void Redirect_receiveMessage(void* self, void* ifitem, const etMessage* msg){
- ET_MSC_LOGGER_SYNC_ENTRY("Redirect", "_receiveMessage")
-
- Redirect_receiveEvent(self, (etPort*)ifitem, msg->evtID, (void*)(((char*)msg)+MEM_CEIL(sizeof(etMessage))));
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-/*--------------------- operations ---------------------*/
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Redirect.h b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Redirect.h deleted file mode 100644 index 3c81933cb..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Redirect.h +++ /dev/null @@ -1,61 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Header File of ActorClass Redirect
- *
- */
-
-#ifndef _REDIRECT_H_
-#define _REDIRECT_H_
-
-#include "etDatatypes.h"
-#include "messaging/etMessage.h"
-
-#include "CommunicationProtocol.h"
-
-
-typedef struct Redirect Redirect;
-
-/* const part of ActorClass (ROM) */
-typedef struct Redirect_const {
- /* simple ports */
- const CommunicationProtocolPort inport;
- const CommunicationProtocolConjPort outport;
-
- /* data receive ports */
-
- /* saps */
-
- /* replicated ports */
-
- /* services */
-} Redirect_const;
-
-
-/* constant for state machine data */
-#define REDIRECT_HISTORY_SIZE 2
-
-/* variable part of ActorClass (RAM) */
-struct Redirect {
- const Redirect_const* const constData;
-
- /* data send ports */
-
- /*--------------------- attributes ---------------------*/
-
-
- /* state machine variables */
- etInt16 state;
- etInt16 history[REDIRECT_HISTORY_SIZE];
-};
-
-void Redirect_init(Redirect* self);
-
-void Redirect_receiveMessage(void* self, void* ifitem, const etMessage* msg);
-
-
-/*--------------------- operations ---------------------*/
-
-
-#endif /* _REDIRECT_H_ */
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/SecurityProtocol.c b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/SecurityProtocol.c deleted file mode 100644 index c1d8713b1..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/SecurityProtocol.c +++ /dev/null @@ -1,89 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Source File of ProtocolClass SecurityProtocol
- *
- */
-
-#include "SecurityProtocol.h"
-#include "debugging/etMSCLogger.h"
-
-
-/*--------------------- port methods */
-
-void SecurityProtocolPort_pong(const SecurityProtocolPort* self) {
- ET_MSC_LOGGER_SYNC_ENTRY("SecurityProtocolPort", "pong")
- etPort_sendMessage(self, SecurityProtocol_OUT_pong, 0, NULL);
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void SecurityProtocolReplPort_pong_broadcast(const SecurityProtocolReplPort* self) {
- int i;
- ET_MSC_LOGGER_SYNC_ENTRY("SecurityProtocolReplPort", "pong")
- for (i=0; i<((etReplPort*)self)->size; ++i) {
- etPort_sendMessage(((etPort*)&((etReplPort*)self)->ports[i]), SecurityProtocol_OUT_pong, 0, NULL);
- }
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void SecurityProtocolReplPort_pong(const SecurityProtocolReplPort* self, int idx) {
- ET_MSC_LOGGER_SYNC_ENTRY("SecurityProtocolReplPort", "pong")
- if (0<=idx && idx<((etReplPort*)self)->size) {
- etPort_sendMessage(((etPort*)&((etReplPort*)self)->ports[idx]), SecurityProtocol_OUT_pong, 0, NULL);
- }
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-// getReplication
-etInt32 SecurityProtocolReplPort_getReplication(const SecurityProtocolReplPort* self) {
- return ((etReplPort*)self)->size;
-}
-
-
-
-void SecurityProtocolConjPort_ping(const SecurityProtocolConjPort* self) {
- ET_MSC_LOGGER_SYNC_ENTRY("SecurityProtocolConjPort", "ping")
- etPort_sendMessage(self, SecurityProtocol_IN_ping, 0, NULL);
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void SecurityProtocolConjReplPort_ping_broadcast(const SecurityProtocolConjReplPort* self) {
- int i;
- ET_MSC_LOGGER_SYNC_ENTRY("SecurityProtocolConjReplPort", "ping")
- for (i=0; i<((etReplPort*)self)->size; ++i) {
- etPort_sendMessage(((etPort*)&((etReplPort*)self)->ports[i]), SecurityProtocol_IN_ping, 0, NULL);
- }
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void SecurityProtocolConjReplPort_ping(const SecurityProtocolConjReplPort* self, int idx) {
- ET_MSC_LOGGER_SYNC_ENTRY("SecurityProtocolConjReplPort", "ping")
- if (0<=idx && idx<((etReplPort*)self)->size) {
- etPort_sendMessage(((etPort*)&((etReplPort*)self)->ports[idx]), SecurityProtocol_IN_ping, 0, NULL);
- }
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-// getReplication
-etInt32 SecurityProtocolConjReplPort_getReplication(const SecurityProtocolConjReplPort* self) {
- return ((etReplPort*)self)->size;
-}
-
-
-
-/*--------------------- debug helpers */
-
-/* message names as strings for debugging (generate MSC) */
-static const char* const SecurityProtocol_messageStrings[] = {"MIN", "pong","ping", "MAX"};
-
-const char* SecurityProtocol_getMessageString(int msg_id) {
- if (msg_id<SecurityProtocol_MSG_MIN || msg_id>SecurityProtocol_MSG_MAX+1){
- /* id out of range */
- return "Message ID out of range";
- }
- else{
- return SecurityProtocol_messageStrings[msg_id];
- }
-}
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/SecurityProtocol.h b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/SecurityProtocol.h deleted file mode 100644 index 829f7f622..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/SecurityProtocol.h +++ /dev/null @@ -1,54 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Header File of ProtocolClass SecurityProtocol
- *
- */
-
-#ifndef _SECURITYPROTOCOL_H_
-#define _SECURITYPROTOCOL_H_
-
-#include "etDatatypes.h"
-#include "modelbase/etPort.h"
-
-
-
-
-/* message IDs */
-enum SecurityProtocol_msg_ids {
- SecurityProtocol_MSG_MIN = 0,
- SecurityProtocol_OUT_pong = 1,
- SecurityProtocol_IN_ping = 2,
- SecurityProtocol_MSG_MAX = 3
-};
-
-/*--------------------- port structs and methods */
-typedef etPort SecurityProtocolPort;
-typedef etReplPort SecurityProtocolReplPort;
-
-
-void SecurityProtocolPort_pong(const SecurityProtocolPort* self);
-void SecurityProtocolReplPort_pong_broadcast(const SecurityProtocolReplPort* self);
-void SecurityProtocolReplPort_pong(const SecurityProtocolReplPort* self, int idx);
-
-
-etInt32 SecurityProtocolReplPort_getReplication(const SecurityProtocolReplPort* self);
-typedef etPort SecurityProtocolConjPort;
-typedef etReplPort SecurityProtocolConjReplPort;
-
-
-void SecurityProtocolConjPort_ping(const SecurityProtocolConjPort* self);
-void SecurityProtocolConjReplPort_ping_broadcast(const SecurityProtocolConjReplPort* self);
-void SecurityProtocolConjReplPort_ping(const SecurityProtocolConjReplPort* self, int idx);
-
-
-etInt32 SecurityProtocolConjReplPort_getReplication(const SecurityProtocolConjReplPort* self);
-
-/*--------------------- debug helpers */
-
-/* get message string for message id */
-const char* SecurityProtocol_getMessageString(int msg_id);
-
-
-#endif /* _SECURITYPROTOCOL_H_ */
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Supervisor.c b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Supervisor.c deleted file mode 100644 index bfe78a39f..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Supervisor.c +++ /dev/null @@ -1,184 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Source File of ActorClass Supervisor
- *
- */
-
-#include "Supervisor.h"
-
-#include "modelbase/etActor.h"
-#include "debugging/etLogger.h"
-#include "debugging/etMSCLogger.h"
-#include "etUnit/etUnit.h"
-#include "platform/etMemory.h"
-
-#include "SecurityProtocol.h"
-
-
-/* interface item IDs */
-enum interface_items {
- IFITEM_application = 1
-};
-
-/* state IDs */
-enum state_ids {
- NO_STATE = 0,
- STATE_TOP = 1,
- STATE_PingPongActive = 2
-};
-
-/* transition chains */
-enum chain_ids {
- CHAIN_TRANS_INITIAL_TO__PingPongActive = 1,
- CHAIN_TRANS_tr0_FROM_PingPongActive_TO_PingPongActive_BY_pingapplication_tr0 = 2
-};
-
-/* triggers */
-enum triggers {
- POLLING = 0,
- TRIG_application__ping = IFITEM_application + EVT_SHIFT*SecurityProtocol_IN_ping
-};
-
-
-static void setState(Supervisor* self, int new_state) {
- self->state = (etInt16) new_state;
-}
-
-static int getState(Supervisor* self) {
- return self->state;
-}
-
-/* Entry and Exit Codes */
-
-/* Action Codes */
-static void action_TRANS_tr0_FROM_PingPongActive_TO_PingPongActive_BY_pingapplication_tr0(Supervisor* self, const InterfaceItemBase* ifitem) {
- SecurityProtocolPort_pong(&self->constData->application) /* ORIG: application.pong() */;
-}
-
-/**
- * calls exit codes while exiting from the current state to one of its
- * parent states while remembering the history
- * @param current - the current state
- * @param to - the final parent state
- * @param handler - entry and exit codes are called only if not handler (for handler TransitionPoints)
- */
-static void exitTo(Supervisor* self, int current, int to, boolean handler) {
- while (current!=to) {
- switch (current) {
- case STATE_PingPongActive:
- self->history[STATE_TOP] = STATE_PingPongActive;
- current = STATE_TOP;
- break;
- }
- }
-}
-
-/**
- * calls action, entry and exit codes along a transition chain. The generic data are cast to typed data
- * matching the trigger of this chain. The ID of the final state is returned
- * @param chain - the chain ID
- * @param generic_data - the generic data pointer
- * @return the ID of the final state
- */
-static int executeTransitionChain(Supervisor* self, int chain, const InterfaceItemBase* ifitem, void* generic_data) {
- switch (chain) {
- case CHAIN_TRANS_INITIAL_TO__PingPongActive:
- {
- return STATE_PingPongActive;
- }
- case CHAIN_TRANS_tr0_FROM_PingPongActive_TO_PingPongActive_BY_pingapplication_tr0:
- {
- action_TRANS_tr0_FROM_PingPongActive_TO_PingPongActive_BY_pingapplication_tr0(self, ifitem);
- return STATE_PingPongActive;
- }
- }
- return NO_STATE;
-}
-
-/**
- * calls entry codes while entering a state's history. The ID of the final leaf state is returned
- * @param state - the state which is entered
- * @param handler - entry code is executed if not handler
- * @return - the ID of the final leaf state
- */
-static int enterHistory(Supervisor* self, int state, boolean handler, boolean skip_entry) {
- while (TRUE) {
- switch (state) {
- case STATE_PingPongActive:
- // in leaf state: return state id
- return STATE_PingPongActive;
- case STATE_TOP:
- state = self->history[STATE_TOP];
- break;
- }
- skip_entry = FALSE;
- }
- //return NO_STATE; // required by CDT but detected as unreachable by JDT because of while (true)
-}
-
-static void Supervisor_executeInitTransition(Supervisor* self) {
- int chain = CHAIN_TRANS_INITIAL_TO__PingPongActive;
- int next = executeTransitionChain(self, chain, NULL, NULL);
- next = enterHistory(self, next, FALSE, FALSE);
- setState(self, next);
-}
-
-/* receiveEvent contains the main implementation of the FSM */
-static void Supervisor_receiveEvent(Supervisor* self, InterfaceItemBase* ifitem, int evt, void* generic_data) {
- int trigger = ifitem->localId + EVT_SHIFT*evt;
- int chain = NOT_CAUGHT;
- int catching_state = NO_STATE;
- boolean is_handler = FALSE;
- boolean skip_entry = FALSE;
-
- if (!handleSystemEvent(ifitem, evt, generic_data)) {
- switch (getState(self)) {
- case STATE_PingPongActive:
- switch(trigger) {
- case TRIG_application__ping:
- {
- chain = CHAIN_TRANS_tr0_FROM_PingPongActive_TO_PingPongActive_BY_pingapplication_tr0;
- catching_state = STATE_TOP;
- }
- break;
- }
- break;
- }
- }
- if (chain != NOT_CAUGHT) {
- exitTo(self, getState(self), catching_state, is_handler);
- int next = executeTransitionChain(self, chain, ifitem, generic_data);
- next = enterHistory(self, next, is_handler, skip_entry);
- setState(self, next);
- }
-}
-
-//******************************************
-// END of generated code for FSM
-//******************************************
-
-void Supervisor_init(Supervisor* self){
- ET_MSC_LOGGER_SYNC_ENTRY("Supervisor", "init")
- self->state = STATE_TOP;
- {
- int i;
- for (i=0; i<SUPERVISOR_HISTORY_SIZE; ++i)
- self->history[i] = NO_STATE;
- }
- Supervisor_executeInitTransition(self);
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-void Supervisor_receiveMessage(void* self, void* ifitem, const etMessage* msg){
- ET_MSC_LOGGER_SYNC_ENTRY("Supervisor", "_receiveMessage")
-
- Supervisor_receiveEvent(self, (etPort*)ifitem, msg->evtID, (void*)(((char*)msg)+MEM_CEIL(sizeof(etMessage))));
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-/*--------------------- operations ---------------------*/
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Supervisor.h b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Supervisor.h deleted file mode 100644 index 345e19a75..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Supervisor.h +++ /dev/null @@ -1,60 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Header File of ActorClass Supervisor
- *
- */
-
-#ifndef _SUPERVISOR_H_
-#define _SUPERVISOR_H_
-
-#include "etDatatypes.h"
-#include "messaging/etMessage.h"
-
-#include "SecurityProtocol.h"
-
-
-typedef struct Supervisor Supervisor;
-
-/* const part of ActorClass (ROM) */
-typedef struct Supervisor_const {
- /* simple ports */
- const SecurityProtocolPort application;
-
- /* data receive ports */
-
- /* saps */
-
- /* replicated ports */
-
- /* services */
-} Supervisor_const;
-
-
-/* constant for state machine data */
-#define SUPERVISOR_HISTORY_SIZE 2
-
-/* variable part of ActorClass (RAM) */
-struct Supervisor {
- const Supervisor_const* const constData;
-
- /* data send ports */
-
- /*--------------------- attributes ---------------------*/
-
-
- /* state machine variables */
- etInt16 state;
- etInt16 history[SUPERVISOR_HISTORY_SIZE];
-};
-
-void Supervisor_init(Supervisor* self);
-
-void Supervisor_receiveMessage(void* self, void* ifitem, const etMessage* msg);
-
-
-/*--------------------- operations ---------------------*/
-
-
-#endif /* _SUPERVISOR_H_ */
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Tester.c b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Tester.c deleted file mode 100644 index a54f8b503..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Tester.c +++ /dev/null @@ -1,199 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Source File of ActorClass Tester
- *
- */
-
-#include "Tester.h"
-
-#include "modelbase/etActor.h"
-#include "debugging/etLogger.h"
-#include "debugging/etMSCLogger.h"
-#include "etUnit/etUnit.h"
-#include "platform/etMemory.h"
-
-#include "CommunicationProtocol.h"
-
-
-/* interface item IDs */
-enum interface_items {
- IFITEM_outport = 1,
- IFITEM_inport = 2
-};
-
-/* state IDs */
-enum state_ids {
- NO_STATE = 0,
- STATE_TOP = 1,
- STATE_Started = 2,
- STATE_Done = 3
-};
-
-/* transition chains */
-enum chain_ids {
- CHAIN_TRANS_INITIAL_TO__Started = 1,
- CHAIN_TRANS_tr0_FROM_Started_TO_Done_BY_sendDatainport = 2
-};
-
-/* triggers */
-enum triggers {
- POLLING = 0,
- TRIG_inport__sendData = IFITEM_inport + EVT_SHIFT*CommunicationProtocol_IN_sendData
-};
-
-
-static void setState(Tester* self, int new_state) {
- self->state = (etInt16) new_state;
-}
-
-static int getState(Tester* self) {
- return self->state;
-}
-
-/* Entry and Exit Codes */
-static void entry_Started(Tester* self) {
- CommunicationProtocolConjPort_sendData(&self->constData->outport) /* ORIG: outport.sendData() */;
-}
-static void entry_Done(Tester* self) {
- etLogger_logInfo("+++ Test Done +++");
-}
-
-/* Action Codes */
-
-/**
- * calls exit codes while exiting from the current state to one of its
- * parent states while remembering the history
- * @param current - the current state
- * @param to - the final parent state
- * @param handler - entry and exit codes are called only if not handler (for handler TransitionPoints)
- */
-static void exitTo(Tester* self, int current, int to, boolean handler) {
- while (current!=to) {
- switch (current) {
- case STATE_Started:
- self->history[STATE_TOP] = STATE_Started;
- current = STATE_TOP;
- break;
- case STATE_Done:
- self->history[STATE_TOP] = STATE_Done;
- current = STATE_TOP;
- break;
- }
- }
-}
-
-/**
- * calls action, entry and exit codes along a transition chain. The generic data are cast to typed data
- * matching the trigger of this chain. The ID of the final state is returned
- * @param chain - the chain ID
- * @param generic_data - the generic data pointer
- * @return the ID of the final state
- */
-static int executeTransitionChain(Tester* self, int chain, const InterfaceItemBase* ifitem, void* generic_data) {
- switch (chain) {
- case CHAIN_TRANS_INITIAL_TO__Started:
- {
- return STATE_Started;
- }
- case CHAIN_TRANS_tr0_FROM_Started_TO_Done_BY_sendDatainport:
- {
- return STATE_Done;
- }
- }
- return NO_STATE;
-}
-
-/**
- * calls entry codes while entering a state's history. The ID of the final leaf state is returned
- * @param state - the state which is entered
- * @param handler - entry code is executed if not handler
- * @return - the ID of the final leaf state
- */
-static int enterHistory(Tester* self, int state, boolean handler, boolean skip_entry) {
- while (TRUE) {
- switch (state) {
- case STATE_Started:
- if (!(skip_entry || handler)) entry_Started(self);
- // in leaf state: return state id
- return STATE_Started;
- case STATE_Done:
- if (!(skip_entry || handler)) entry_Done(self);
- // in leaf state: return state id
- return STATE_Done;
- case STATE_TOP:
- state = self->history[STATE_TOP];
- break;
- }
- skip_entry = FALSE;
- }
- //return NO_STATE; // required by CDT but detected as unreachable by JDT because of while (true)
-}
-
-static void Tester_executeInitTransition(Tester* self) {
- int chain = CHAIN_TRANS_INITIAL_TO__Started;
- int next = executeTransitionChain(self, chain, NULL, NULL);
- next = enterHistory(self, next, FALSE, FALSE);
- setState(self, next);
-}
-
-/* receiveEvent contains the main implementation of the FSM */
-static void Tester_receiveEvent(Tester* self, InterfaceItemBase* ifitem, int evt, void* generic_data) {
- int trigger = ifitem->localId + EVT_SHIFT*evt;
- int chain = NOT_CAUGHT;
- int catching_state = NO_STATE;
- boolean is_handler = FALSE;
- boolean skip_entry = FALSE;
-
- if (!handleSystemEvent(ifitem, evt, generic_data)) {
- switch (getState(self)) {
- case STATE_Started:
- switch(trigger) {
- case TRIG_inport__sendData:
- {
- chain = CHAIN_TRANS_tr0_FROM_Started_TO_Done_BY_sendDatainport;
- catching_state = STATE_TOP;
- }
- break;
- }
- break;
- case STATE_Done:
- break;
- }
- }
- if (chain != NOT_CAUGHT) {
- exitTo(self, getState(self), catching_state, is_handler);
- int next = executeTransitionChain(self, chain, ifitem, generic_data);
- next = enterHistory(self, next, is_handler, skip_entry);
- setState(self, next);
- }
-}
-
-//******************************************
-// END of generated code for FSM
-//******************************************
-
-void Tester_init(Tester* self){
- ET_MSC_LOGGER_SYNC_ENTRY("Tester", "init")
- self->state = STATE_TOP;
- {
- int i;
- for (i=0; i<TESTER_HISTORY_SIZE; ++i)
- self->history[i] = NO_STATE;
- }
- Tester_executeInitTransition(self);
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-void Tester_receiveMessage(void* self, void* ifitem, const etMessage* msg){
- ET_MSC_LOGGER_SYNC_ENTRY("Tester", "_receiveMessage")
-
- Tester_receiveEvent(self, (etPort*)ifitem, msg->evtID, (void*)(((char*)msg)+MEM_CEIL(sizeof(etMessage))));
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-/*--------------------- operations ---------------------*/
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Tester.h b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Tester.h deleted file mode 100644 index 562d91082..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/Tester.h +++ /dev/null @@ -1,61 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Header File of ActorClass Tester
- *
- */
-
-#ifndef _TESTER_H_
-#define _TESTER_H_
-
-#include "etDatatypes.h"
-#include "messaging/etMessage.h"
-
-#include "CommunicationProtocol.h"
-
-
-typedef struct Tester Tester;
-
-/* const part of ActorClass (ROM) */
-typedef struct Tester_const {
- /* simple ports */
- const CommunicationProtocolConjPort outport;
- const CommunicationProtocolPort inport;
-
- /* data receive ports */
-
- /* saps */
-
- /* replicated ports */
-
- /* services */
-} Tester_const;
-
-
-/* constant for state machine data */
-#define TESTER_HISTORY_SIZE 2
-
-/* variable part of ActorClass (RAM) */
-struct Tester {
- const Tester_const* const constData;
-
- /* data send ports */
-
- /*--------------------- attributes ---------------------*/
-
-
- /* state machine variables */
- etInt16 state;
- etInt16 history[TESTER_HISTORY_SIZE];
-};
-
-void Tester_init(Tester* self);
-
-void Tester_receiveMessage(void* self, void* ifitem, const etMessage* msg);
-
-
-/*--------------------- operations ---------------------*/
-
-
-#endif /* _TESTER_H_ */
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1.c b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1.c deleted file mode 100644 index f1cf76fce..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1.c +++ /dev/null @@ -1,181 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Source File of Node node1 with SubSystem sys1
- *
- */
-
-#include "node1_sys1.h"
-
-/* include instances for all classes */
-#include "node1_sys1_Inst.h"
-#include "node1_sys1_Disp.h"
-
-#include "debugging/etLogger.h"
-#include "debugging/etMSCLogger.h"
-
-#include "platform/etTimer.h"
-#include "etRuntimeConfig.h"
-
-
-/* data for Node node1 with SubSytsem sys1 */
-typedef struct node1_sys1 {
- char *name;
- volatile int shutdownRequest;
-} node1_sys1;
-
-static node1_sys1 node1_sys1Inst = {"node1_sys1", 0};
-
-void node1_sys1_initActorInstances(void);
-void node1_sys1_constructActorInstances(void);
-
-static void node1_sys1_initMessageServices(void) {
- ET_MSC_LOGGER_SYNC_ENTRY("node1_sys1", "initMessageServices")
-
- /* filling all message service threads with data */
- msgService_PhysicalThread1.thread.stacksize = 1024;
- msgService_PhysicalThread1.thread.priority = 1;
- msgService_PhysicalThread1.thread.threadName = "PhysicalThread1";
- msgService_PhysicalThread1.thread.threadFunction = (etThreadFunction) etMessageService_execute;
- msgService_PhysicalThread1.thread.threadFunctionData = &msgService_PhysicalThread1;
-
-
- msgService_PhysicalThread2.thread.stacksize = 1024;
- msgService_PhysicalThread2.thread.priority = 5;
- msgService_PhysicalThread2.thread.threadName = "PhysicalThread2";
- msgService_PhysicalThread2.thread.threadFunction = (etThreadFunction) etMessageService_execute;
- msgService_PhysicalThread2.thread.threadFunctionData = &msgService_PhysicalThread2;
-
-
- msgService_PhysicalThread3.thread.stacksize = 1024;
- msgService_PhysicalThread3.thread.priority = 10;
- msgService_PhysicalThread3.thread.threadName = "PhysicalThread3";
- msgService_PhysicalThread3.thread.threadFunction = (etThreadFunction) etMessageService_execute;
- msgService_PhysicalThread3.thread.threadFunctionData = &msgService_PhysicalThread3;
-
- /* initialization of all message services */
- etMessageService_init(&msgService_PhysicalThread1, msgBuffer_PhysicalThread1, 50, 64, MsgDispatcher_PhysicalThread1_receiveMessage, MsgDispatcher_PhysicalThread1_execute, EXECMODE_BLOCKED);
- etMessageService_init(&msgService_PhysicalThread2, msgBuffer_PhysicalThread2, 50, 64, MsgDispatcher_PhysicalThread2_receiveMessage, MsgDispatcher_PhysicalThread2_execute, EXECMODE_BLOCKED);
- etMessageService_init(&msgService_PhysicalThread3, msgBuffer_PhysicalThread3, 50, 64, MsgDispatcher_PhysicalThread3_receiveMessage, MsgDispatcher_PhysicalThread3_execute, EXECMODE_BLOCKED);
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-static void node1_sys1_startMessageServices(void) {
- ET_MSC_LOGGER_SYNC_ENTRY("node1_sys1", "startMessageServices")
-
- etMessageService_start(&msgService_PhysicalThread1);
- etMessageService_start(&msgService_PhysicalThread2);
- etMessageService_start(&msgService_PhysicalThread3);
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-static void node1_sys1_stopMessageServices(void) {
- ET_MSC_LOGGER_SYNC_ENTRY("node1_sys1", "stopMessageServices")
-
- etMessageService_stop(&msgService_PhysicalThread1);
- etMessageService_stop(&msgService_PhysicalThread2);
- etMessageService_stop(&msgService_PhysicalThread3);
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-static void node1_sys1_destroyMessageServices(void) {
- ET_MSC_LOGGER_SYNC_ENTRY("node1_sys1", "destroyMessageServices")
-
- etMessageService_destroy(&msgService_PhysicalThread1);
- etMessageService_destroy(&msgService_PhysicalThread2);
- etMessageService_destroy(&msgService_PhysicalThread3);
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void node1_sys1_init(void) {
- ET_MSC_LOGGER_SYNC_ENTRY("node1_sys1", "init")
- etLogger_logInfoF("%s_init", node1_sys1Inst.name);
-
- /* construct all actors */
- node1_sys1_constructActorInstances();
-
- /* initialization of all message services */
- node1_sys1_initMessageServices();
-
- /* init all actors */
- node1_sys1_initActorInstances();
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void node1_sys1_start(void) {
- ET_MSC_LOGGER_SYNC_ENTRY("node1_sys1", "start")
- etLogger_logInfoF("%s_start", node1_sys1Inst.name);
- node1_sys1_startMessageServices();
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void node1_sys1_run(void) {
- ET_MSC_LOGGER_SYNC_ENTRY("node1_sys1", "run")
-
- etThread_sleep(1000);
-
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void node1_sys1_stop(void){
- ET_MSC_LOGGER_SYNC_ENTRY("node1_sys1", "stop")
- etLogger_logInfoF("%s_stop", node1_sys1Inst.name);
-
- node1_sys1_stopMessageServices();
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void node1_sys1_destroy(void){
- ET_MSC_LOGGER_SYNC_ENTRY("node1_sys1", "destroy")
- etLogger_logInfoF("%s_destroy", node1_sys1Inst.name);
-
- node1_sys1_destroyMessageServices();
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void node1_sys1_shutdown(void){
- ET_MSC_LOGGER_SYNC_ENTRY("node1_sys1", "shutdown")
- etLogger_logInfoF("%s_shutdown", node1_sys1Inst.name);
-
- node1_sys1Inst.shutdownRequest = 1;
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-
-void node1_sys1_constructActorInstances(void){
- ET_MSC_LOGGER_SYNC_ENTRY("node1_sys1", "constructActorInstances")
-
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-void node1_sys1_initActorInstances(void){
- ET_MSC_LOGGER_SYNC_ENTRY("node1_sys1", "initActorInstances")
-
- Tester_init(&_LS_sys1_tester);
- Fork_init(&_LS_sys1_fork);
- Redirect_init(&_LS_sys1_redirect1);
- Redirect_init(&_LS_sys1_redirect2);
- Redirect_init(&_LS_sys1_redirect3);
- Redirect_init(&_LS_sys1_redirect4);
- Redirect_init(&_LS_sys1_redirect5);
- Redirect_init(&_LS_sys1_redirect6);
- Redirect_init(&_LS_sys1_redirect7);
- Redirect_init(&_LS_sys1_redirect8);
- Redirect_init(&_LS_sys1_redirect9);
- Redirect_init(&_LS_sys1_redirect10);
- Join_init(&_LS_sys1_join);
- Supervisor_init(&_LS_sys1_supervisor);
-
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1.h b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1.h deleted file mode 100644 index 1cd6dd47b..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1.h +++ /dev/null @@ -1,30 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Header File of Node node1 with SubSystem sys1
- *
- */
-
-#ifndef _NODE1_SYS1_H_
-#define _NODE1_SYS1_H_
-
-
-
-/* lifecycle functions
- * init -> start -> run (loop) -> stop -> destroy
- */
-
-void node1_sys1_init(void); /* lifecycle init */
-void node1_sys1_start(void); /* lifecycle start */
-
-void node1_sys1_run(void); /* lifecycle run */
-
-void node1_sys1_stop(void); /* lifecycle stop */
-void node1_sys1_destroy(void); /* lifecycle destroy */
-
-void node1_sys1_shutdown(void); /* shutdown the dispatcher loop */
-
-
-#endif /* _NODE1_SYS1_H_ */
-
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1_Disp.h b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1_Disp.h deleted file mode 100644 index 689a3a516..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1_Disp.h +++ /dev/null @@ -1,235 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Dispatcher File of Node node1 with SubSystem sys1
- * - one generated message dispatcher (receiveMessage) for each MessageService (Thread)
- * - one generated execute dispatcher (execute) for each MessageService (Thread)
- */
-
-#include "messaging/etMessageReceiver.h"
-#include "debugging/etLogger.h"
-#include "debugging/etMSCLogger.h"
-
-
-
-/**
- * generated dispatch function all messages for the tread "PhysicalThread1"
- */
-static void MsgDispatcher_PhysicalThread1_receiveMessage(const etMessage* msg){
- ET_MSC_LOGGER_SYNC_ENTRY("MsgDispatcher_PhysicalThread1", "receiveMessage")
- switch(msg->address){
-
- /* interface items of /LS/sys1/tester */
- case 102:
- Tester_receiveMessage((void*)&_LS_sys1_tester,(etPort*)&_LS_sys1_tester_const.outport, msg);
- break;
- case 103:
- Tester_receiveMessage((void*)&_LS_sys1_tester,(etPort*)&_LS_sys1_tester_const.inport, msg);
- break;
- /* interface items of /LS/sys1/redirect3 */
- case 123:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect3,(etPort*)&_LS_sys1_redirect3_const.inport, msg);
- break;
- case 124:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect3,(etPort*)&_LS_sys1_redirect3_const.outport, msg);
- break;
- /* interface items of /LS/sys1/redirect4 */
- case 126:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect4,(etPort*)&_LS_sys1_redirect4_const.inport, msg);
- break;
- case 127:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect4,(etPort*)&_LS_sys1_redirect4_const.outport, msg);
- break;
- /* interface items of /LS/sys1/redirect5 */
- case 129:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect5,(etPort*)&_LS_sys1_redirect5_const.inport, msg);
- break;
- case 130:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect5,(etPort*)&_LS_sys1_redirect5_const.outport, msg);
- break;
- /* interface items of /LS/sys1/redirect6 */
- case 132:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect6,(etPort*)&_LS_sys1_redirect6_const.inport, msg);
- break;
- case 133:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect6,(etPort*)&_LS_sys1_redirect6_const.outport, msg);
- break;
- /* interface items of /LS/sys1/redirect7 */
- case 135:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect7,(etPort*)&_LS_sys1_redirect7_const.inport, msg);
- break;
- case 136:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect7,(etPort*)&_LS_sys1_redirect7_const.outport, msg);
- break;
- /* interface items of /LS/sys1/redirect8 */
- case 138:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect8,(etPort*)&_LS_sys1_redirect8_const.inport, msg);
- break;
- case 139:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect8,(etPort*)&_LS_sys1_redirect8_const.outport, msg);
- break;
- /* interface items of /LS/sys1/redirect9 */
- case 141:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect9,(etPort*)&_LS_sys1_redirect9_const.inport, msg);
- break;
- case 142:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect9,(etPort*)&_LS_sys1_redirect9_const.outport, msg);
- break;
- /* interface items of /LS/sys1/redirect10 */
- case 144:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect10,(etPort*)&_LS_sys1_redirect10_const.inport, msg);
- break;
- case 145:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect10,(etPort*)&_LS_sys1_redirect10_const.outport, msg);
- break;
-
- default:
- etLogger_logErrorF("MessageService_PhysicalThread1_receiveMessage: address %d does not exist ", msg->address);
- break;
- }
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-/**
- * generated execute function for all cyclic execute calls for the async or datadriven actor instances of thread "PhysicalThread1"
- */
-static void MsgDispatcher_PhysicalThread1_execute(void){
- /* nothing to execute -> empty function generated to satisfy interface of message service */
-}
-
-
-
-/**
- * generated dispatch function all messages for the tread "PhysicalThread2"
- */
-static void MsgDispatcher_PhysicalThread2_receiveMessage(const etMessage* msg){
- ET_MSC_LOGGER_SYNC_ENTRY("MsgDispatcher_PhysicalThread2", "receiveMessage")
- switch(msg->address){
-
- /* interface items of /LS/sys1/fork */
- case 105:
- Fork_receiveMessage((void*)&_LS_sys1_fork,(etPort*)&_LS_sys1_fork_const.broadcast.ports[0], msg);
- break;
- case 106:
- Fork_receiveMessage((void*)&_LS_sys1_fork,(etPort*)&_LS_sys1_fork_const.broadcast.ports[1], msg);
- break;
- case 107:
- Fork_receiveMessage((void*)&_LS_sys1_fork,(etPort*)&_LS_sys1_fork_const.broadcast.ports[2], msg);
- break;
- case 108:
- Fork_receiveMessage((void*)&_LS_sys1_fork,(etPort*)&_LS_sys1_fork_const.broadcast.ports[3], msg);
- break;
- case 109:
- Fork_receiveMessage((void*)&_LS_sys1_fork,(etPort*)&_LS_sys1_fork_const.broadcast.ports[4], msg);
- break;
- case 110:
- Fork_receiveMessage((void*)&_LS_sys1_fork,(etPort*)&_LS_sys1_fork_const.broadcast.ports[5], msg);
- break;
- case 111:
- Fork_receiveMessage((void*)&_LS_sys1_fork,(etPort*)&_LS_sys1_fork_const.broadcast.ports[6], msg);
- break;
- case 112:
- Fork_receiveMessage((void*)&_LS_sys1_fork,(etPort*)&_LS_sys1_fork_const.broadcast.ports[7], msg);
- break;
- case 113:
- Fork_receiveMessage((void*)&_LS_sys1_fork,(etPort*)&_LS_sys1_fork_const.broadcast.ports[8], msg);
- break;
- case 114:
- Fork_receiveMessage((void*)&_LS_sys1_fork,(etPort*)&_LS_sys1_fork_const.broadcast.ports[9], msg);
- break;
- case 115:
- Fork_receiveMessage((void*)&_LS_sys1_fork,(etPort*)&_LS_sys1_fork_const.inport, msg);
- break;
- /* interface items of /LS/sys1/redirect1 */
- case 117:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect1,(etPort*)&_LS_sys1_redirect1_const.inport, msg);
- break;
- case 118:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect1,(etPort*)&_LS_sys1_redirect1_const.outport, msg);
- break;
- /* interface items of /LS/sys1/redirect2 */
- case 120:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect2,(etPort*)&_LS_sys1_redirect2_const.inport, msg);
- break;
- case 121:
- Redirect_receiveMessage((void*)&_LS_sys1_redirect2,(etPort*)&_LS_sys1_redirect2_const.outport, msg);
- break;
- /* interface items of /LS/sys1/join */
- case 147:
- Join_receiveMessage((void*)&_LS_sys1_join,(etPort*)&_LS_sys1_join_const.inport.ports[0], msg);
- break;
- case 148:
- Join_receiveMessage((void*)&_LS_sys1_join,(etPort*)&_LS_sys1_join_const.inport.ports[1], msg);
- break;
- case 149:
- Join_receiveMessage((void*)&_LS_sys1_join,(etPort*)&_LS_sys1_join_const.inport.ports[2], msg);
- break;
- case 150:
- Join_receiveMessage((void*)&_LS_sys1_join,(etPort*)&_LS_sys1_join_const.inport.ports[3], msg);
- break;
- case 151:
- Join_receiveMessage((void*)&_LS_sys1_join,(etPort*)&_LS_sys1_join_const.inport.ports[4], msg);
- break;
- case 152:
- Join_receiveMessage((void*)&_LS_sys1_join,(etPort*)&_LS_sys1_join_const.inport.ports[5], msg);
- break;
- case 153:
- Join_receiveMessage((void*)&_LS_sys1_join,(etPort*)&_LS_sys1_join_const.inport.ports[6], msg);
- break;
- case 154:
- Join_receiveMessage((void*)&_LS_sys1_join,(etPort*)&_LS_sys1_join_const.inport.ports[7], msg);
- break;
- case 155:
- Join_receiveMessage((void*)&_LS_sys1_join,(etPort*)&_LS_sys1_join_const.inport.ports[8], msg);
- break;
- case 156:
- Join_receiveMessage((void*)&_LS_sys1_join,(etPort*)&_LS_sys1_join_const.inport.ports[9], msg);
- break;
- case 157:
- Join_receiveMessage((void*)&_LS_sys1_join,(etPort*)&_LS_sys1_join_const.outport, msg);
- break;
- case 158:
- Join_receiveMessage((void*)&_LS_sys1_join,(etPort*)&_LS_sys1_join_const.security, msg);
- break;
-
- default:
- etLogger_logErrorF("MessageService_PhysicalThread2_receiveMessage: address %d does not exist ", msg->address);
- break;
- }
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-/**
- * generated execute function for all cyclic execute calls for the async or datadriven actor instances of thread "PhysicalThread2"
- */
-static void MsgDispatcher_PhysicalThread2_execute(void){
- /* nothing to execute -> empty function generated to satisfy interface of message service */
-}
-
-
-
-/**
- * generated dispatch function all messages for the tread "PhysicalThread3"
- */
-static void MsgDispatcher_PhysicalThread3_receiveMessage(const etMessage* msg){
- ET_MSC_LOGGER_SYNC_ENTRY("MsgDispatcher_PhysicalThread3", "receiveMessage")
- switch(msg->address){
-
- /* interface items of /LS/sys1/supervisor */
- case 160:
- Supervisor_receiveMessage((void*)&_LS_sys1_supervisor,(etPort*)&_LS_sys1_supervisor_const.application, msg);
- break;
-
- default:
- etLogger_logErrorF("MessageService_PhysicalThread3_receiveMessage: address %d does not exist ", msg->address);
- break;
- }
- ET_MSC_LOGGER_SYNC_EXIT
-}
-
-/**
- * generated execute function for all cyclic execute calls for the async or datadriven actor instances of thread "PhysicalThread3"
- */
-static void MsgDispatcher_PhysicalThread3_execute(void){
- /* nothing to execute -> empty function generated to satisfy interface of message service */
-}
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1_Inst.h b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1_Inst.h deleted file mode 100644 index 4be471303..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1_Inst.h +++ /dev/null @@ -1,333 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * Instance File of Node node1 with SubSystem sys1
- * - instantiation of all actor instances and port instances
- * - configuration of data and connection of ports
- */
-
-#include "messaging/etMessageService.h"
-#include "platform/etMemory.h"
-
-/* include all used ActorClasses */
-#include "Join.h"
-#include "Redirect.h"
-#include "Tester.h"
-#include "Supervisor.h"
-#include "Fork.h"
-
-/* include all used ProtcolClasses */
-#include "SecurityProtocol.h"
-#include "CommunicationProtocol.h"
-
-/* instantiation of message services and message buffers */
-/* PhysicalThread1 */
-static uint8 msgBuffer_PhysicalThread1[50 * 64]; /* msgBuffer_<threadname>[<msgpoolsize> * <msgblocksize>] */
-static etMessageService msgService_PhysicalThread1;
-/* PhysicalThread2 */
-static uint8 msgBuffer_PhysicalThread2[50 * 64]; /* msgBuffer_<threadname>[<msgpoolsize> * <msgblocksize>] */
-static etMessageService msgService_PhysicalThread2;
-/* PhysicalThread3 */
-static uint8 msgBuffer_PhysicalThread3[50 * 64]; /* msgBuffer_<threadname>[<msgpoolsize> * <msgblocksize>] */
-static etMessageService msgService_PhysicalThread3;
-
-/* declarations of all ActorClass instances (const and variable structs) */
-
-/* forward declaration of variable actor structs */
-static Tester _LS_sys1_tester;
-static Fork _LS_sys1_fork;
-static Redirect _LS_sys1_redirect1;
-static Redirect _LS_sys1_redirect2;
-static Redirect _LS_sys1_redirect3;
-static Redirect _LS_sys1_redirect4;
-static Redirect _LS_sys1_redirect5;
-static Redirect _LS_sys1_redirect6;
-static Redirect _LS_sys1_redirect7;
-static Redirect _LS_sys1_redirect8;
-static Redirect _LS_sys1_redirect9;
-static Redirect _LS_sys1_redirect10;
-static Join _LS_sys1_join;
-static Supervisor _LS_sys1_supervisor;
-
-/* forward declaration of variable port structs */
-
-
-/* instance _LS_sys1_tester */
-static const Tester_const _LS_sys1_tester_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread2, 115, 1} /* Port outport */,
- {0, &msgService_PhysicalThread2, 157, 2} /* Port inport */
-
- /* data receive ports */
-};
-static Tester _LS_sys1_tester = {
- &_LS_sys1_tester_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_fork */
-static const etReplSubPort _LS_sys1_fork_repl_sub_ports[10] = {
- /* Replicated Sub Ports: {varData, msgService, peerAddress, localId, index} */
- {0,&msgService_PhysicalThread2, 117, 1, 0}, /* Repl Sub Port broadcast idx +0*/
- {0,&msgService_PhysicalThread2, 120, 1, 1}, /* Repl Sub Port broadcast idx +1*/
- {0,&msgService_PhysicalThread1, 123, 1, 2}, /* Repl Sub Port broadcast idx +2*/
- {0,&msgService_PhysicalThread1, 126, 1, 3}, /* Repl Sub Port broadcast idx +3*/
- {0,&msgService_PhysicalThread1, 129, 1, 4}, /* Repl Sub Port broadcast idx +4*/
- {0,&msgService_PhysicalThread1, 132, 1, 5}, /* Repl Sub Port broadcast idx +5*/
- {0,&msgService_PhysicalThread1, 135, 1, 6}, /* Repl Sub Port broadcast idx +6*/
- {0,&msgService_PhysicalThread1, 138, 1, 7}, /* Repl Sub Port broadcast idx +7*/
- {0,&msgService_PhysicalThread1, 141, 1, 8}, /* Repl Sub Port broadcast idx +8*/
- {0,&msgService_PhysicalThread1, 144, 1, 9} /* Repl Sub Port broadcast idx +9*/
-};
-static const Fork_const _LS_sys1_fork_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread1, 102, 2} /* Port inport */,
- {10, _LS_sys1_fork_repl_sub_ports+0}
-
- /* data receive ports */
-};
-static Fork _LS_sys1_fork = {
- &_LS_sys1_fork_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_redirect1 */
-static const Redirect_const _LS_sys1_redirect1_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread2, 105, 1} /* Port inport */,
- {0, &msgService_PhysicalThread2, 147, 2} /* Port outport */
-
- /* data receive ports */
-};
-static Redirect _LS_sys1_redirect1 = {
- &_LS_sys1_redirect1_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_redirect2 */
-static const Redirect_const _LS_sys1_redirect2_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread2, 106, 1} /* Port inport */,
- {0, &msgService_PhysicalThread2, 148, 2} /* Port outport */
-
- /* data receive ports */
-};
-static Redirect _LS_sys1_redirect2 = {
- &_LS_sys1_redirect2_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_redirect3 */
-static const Redirect_const _LS_sys1_redirect3_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread2, 107, 1} /* Port inport */,
- {0, &msgService_PhysicalThread2, 149, 2} /* Port outport */
-
- /* data receive ports */
-};
-static Redirect _LS_sys1_redirect3 = {
- &_LS_sys1_redirect3_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_redirect4 */
-static const Redirect_const _LS_sys1_redirect4_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread2, 108, 1} /* Port inport */,
- {0, &msgService_PhysicalThread2, 150, 2} /* Port outport */
-
- /* data receive ports */
-};
-static Redirect _LS_sys1_redirect4 = {
- &_LS_sys1_redirect4_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_redirect5 */
-static const Redirect_const _LS_sys1_redirect5_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread2, 109, 1} /* Port inport */,
- {0, &msgService_PhysicalThread2, 151, 2} /* Port outport */
-
- /* data receive ports */
-};
-static Redirect _LS_sys1_redirect5 = {
- &_LS_sys1_redirect5_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_redirect6 */
-static const Redirect_const _LS_sys1_redirect6_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread2, 110, 1} /* Port inport */,
- {0, &msgService_PhysicalThread2, 152, 2} /* Port outport */
-
- /* data receive ports */
-};
-static Redirect _LS_sys1_redirect6 = {
- &_LS_sys1_redirect6_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_redirect7 */
-static const Redirect_const _LS_sys1_redirect7_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread2, 111, 1} /* Port inport */,
- {0, &msgService_PhysicalThread2, 153, 2} /* Port outport */
-
- /* data receive ports */
-};
-static Redirect _LS_sys1_redirect7 = {
- &_LS_sys1_redirect7_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_redirect8 */
-static const Redirect_const _LS_sys1_redirect8_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread2, 112, 1} /* Port inport */,
- {0, &msgService_PhysicalThread2, 154, 2} /* Port outport */
-
- /* data receive ports */
-};
-static Redirect _LS_sys1_redirect8 = {
- &_LS_sys1_redirect8_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_redirect9 */
-static const Redirect_const _LS_sys1_redirect9_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread2, 113, 1} /* Port inport */,
- {0, &msgService_PhysicalThread2, 155, 2} /* Port outport */
-
- /* data receive ports */
-};
-static Redirect _LS_sys1_redirect9 = {
- &_LS_sys1_redirect9_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_redirect10 */
-static const Redirect_const _LS_sys1_redirect10_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread2, 114, 1} /* Port inport */,
- {0, &msgService_PhysicalThread2, 156, 2} /* Port outport */
-
- /* data receive ports */
-};
-static Redirect _LS_sys1_redirect10 = {
- &_LS_sys1_redirect10_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_join */
-static const etReplSubPort _LS_sys1_join_repl_sub_ports[10] = {
- /* Replicated Sub Ports: {varData, msgService, peerAddress, localId, index} */
- {0,&msgService_PhysicalThread2, 118, 1, 0}, /* Repl Sub Port inport idx +0*/
- {0,&msgService_PhysicalThread2, 121, 1, 1}, /* Repl Sub Port inport idx +1*/
- {0,&msgService_PhysicalThread1, 124, 1, 2}, /* Repl Sub Port inport idx +2*/
- {0,&msgService_PhysicalThread1, 127, 1, 3}, /* Repl Sub Port inport idx +3*/
- {0,&msgService_PhysicalThread1, 130, 1, 4}, /* Repl Sub Port inport idx +4*/
- {0,&msgService_PhysicalThread1, 133, 1, 5}, /* Repl Sub Port inport idx +5*/
- {0,&msgService_PhysicalThread1, 136, 1, 6}, /* Repl Sub Port inport idx +6*/
- {0,&msgService_PhysicalThread1, 139, 1, 7}, /* Repl Sub Port inport idx +7*/
- {0,&msgService_PhysicalThread1, 142, 1, 8}, /* Repl Sub Port inport idx +8*/
- {0,&msgService_PhysicalThread1, 145, 1, 9} /* Repl Sub Port inport idx +9*/
-};
-static const Join_const _LS_sys1_join_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread1, 103, 2} /* Port outport */,
- {0, &msgService_PhysicalThread3, 160, 3} /* Port security */,
- {10, _LS_sys1_join_repl_sub_ports+0}
-
- /* data receive ports */
-};
-static Join _LS_sys1_join = {
- &_LS_sys1_join_const,
-
- /* data send ports */
-
- /* attributes */
- 0 /* counter */
-
- /* state and history are initialized in init fuction */
-};
-
-/* instance _LS_sys1_supervisor */
-static const Supervisor_const _LS_sys1_supervisor_const = {
- /* Ports: {varData, msgService, peerAddress, localId} */
- {0, &msgService_PhysicalThread2, 158, 1} /* Port application */
-
- /* data receive ports */
-};
-static Supervisor _LS_sys1_supervisor = {
- &_LS_sys1_supervisor_const,
-
- /* data send ports */
-
- /* attributes */
-
- /* state and history are initialized in init fuction */
-};
-
diff --git a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1_Runner.c b/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1_Runner.c deleted file mode 100644 index c321f758b..000000000 --- a/examples/org.eclipse.etrice.generator.c.reference/src-gen/MassiveMultiThreading/node1_sys1_Runner.c +++ /dev/null @@ -1,49 +0,0 @@ -/**
- * @author generated by eTrice
- *
- * this class contains the main function running Node node1 with SubSystem sys1
- * it instantiates Node node1 with SubSystem sys1 and starts and ends the lifecycle
- */
-
-
-#include "node1_sys1.h"
-
-#include "debugging/etLogger.h"
-#include "debugging/etMSCLogger.h"
-#include "platform/etPlatform.h"
-
-
-/**
- * main function
- * creates component and starts and stops the lifecycle
- */
-
-int main(void) {
- etUserEntry(); /* platform specific */
-
- etLogger_logInfo("*** T H E B E G I N ***");
- ET_MSC_LOGGER_OPEN("main");
-
- /* startup sequence of lifecycle */
- node1_sys1_init(); /* lifecycle init */
- node1_sys1_start(); /* lifecycle start */
-
- etUserPreRun(); /* platform specific */
-
- /* run Scheduler */
- node1_sys1_run();
-
- etUserPostRun(); /* platform specific */
-
- /* shutdown sequence of lifecycle */
- node1_sys1_stop(); /* lifecycle stop */
- node1_sys1_destroy(); /* lifecycle destroy */
-
- ET_MSC_LOGGER_CLOSE
- etLogger_logInfo("*** T H E E N D ***");
-
- etUserExit(); /* platform specific */
-
- return 0;
-}
-
|