diff options
Diffstat (limited to 'runtime/org.eclipse.etrice.runtime.cpp/src/common/modelbase/SubSystemClassBase.h')
-rw-r--r-- | runtime/org.eclipse.etrice.runtime.cpp/src/common/modelbase/SubSystemClassBase.h | 146 |
1 files changed, 73 insertions, 73 deletions
diff --git a/runtime/org.eclipse.etrice.runtime.cpp/src/common/modelbase/SubSystemClassBase.h b/runtime/org.eclipse.etrice.runtime.cpp/src/common/modelbase/SubSystemClassBase.h index 526cc93dd..ed5c8522b 100644 --- a/runtime/org.eclipse.etrice.runtime.cpp/src/common/modelbase/SubSystemClassBase.h +++ b/runtime/org.eclipse.etrice.runtime.cpp/src/common/modelbase/SubSystemClassBase.h @@ -1,73 +1,73 @@ -/*******************************************************************************
- * Copyright (c) 2012 Draeger Medical GmbH (http://www.draeger.com).
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * CONTRIBUTORS:
- * Peter Karlitschek (initial contribution)
- *
- *******************************************************************************/
-
-#ifndef SUBSYSTEMCLASSBASE_H_
-#define SUBSYSTEMCLASSBASE_H_
-
-#include "common/messaging/RTSystemServicesProtocol.h"
-#include "common/messaging/IRTObject.h"
-#include "common/debugging/MSCLogger.h"
-#include "common/modelbase/TestSemaphore.h"
-#include <string>
-#include <vector>
-#include <iostream>
-
-namespace etRuntime {
-
-class MessageService;
-class ActorClassBase;
-
-class SubSystemClassBase: public RTObject, public IEventReceiver {
-public:
- SubSystemClassBase(IRTObject* parent, std::string name);
- virtual ~SubSystemClassBase();
-
- void init();
- virtual void instantiateMessageServices() = 0;
- virtual void instantiateActors() = 0;
-
- void start(bool singlethreaded);
- void stop(bool singlethreaded);
- void runOnce();
-
- void destroy();
-
- MessageService* getMsgService(int idx) const;
-
- ActorClassBase* getInstance(unsigned int i);
- ActorClassBase* getInstance(std::string path);
-
- //---------------------------------------------
- // this is to run integration tests
- //---------------------------------------------
- // TODO synchronized
- void setTestSemaphore(TestSemaphore& sem);
- //TODO synchronized
- int getTestErrorCode() const;
- void testFinished(int errorCode);
-
-protected:
- RTSystemServicesProtocolConjPortRepl* m_RTSystemPort;
- //--------------------- interface item IDs
- static const int IFITEM_RTSystemPort = 0;
- std::vector<ActorClassBase*> m_instances;
-private:
- TestSemaphore* m_testSem;
- int m_testErrorCode;
-
- SubSystemClassBase();
- SubSystemClassBase(const SubSystemClassBase& right);
- SubSystemClassBase& operator=(const SubSystemClassBase& right);
-};
-
-} /* namespace etRuntime */
-#endif /* SUBSYSTEMCLASSBASE_H_ */
+/******************************************************************************* + * Copyright (c) 2012 Draeger Medical GmbH (http://www.draeger.com). + * All rights reserved. This program and the accompanying materials + * are made available under the terms of the Eclipse Public License v1.0 + * which accompanies this distribution, and is available at + * http://www.eclipse.org/legal/epl-v10.html + * + * CONTRIBUTORS: + * Peter Karlitschek (initial contribution) + * + *******************************************************************************/ + +#ifndef SUBSYSTEMCLASSBASE_H_ +#define SUBSYSTEMCLASSBASE_H_ + +#include "common/messaging/RTSystemServicesProtocol.h" +#include "common/messaging/IRTObject.h" +#include "common/debugging/MSCLogger.h" +#include "common/modelbase/TestSemaphore.h" +#include <string> +#include <vector> +#include <iostream> + +namespace etRuntime { + +class MessageService; +class ActorClassBase; + +class SubSystemClassBase: public RTObject, public IEventReceiver { +public: + SubSystemClassBase(IRTObject* parent, std::string name); + virtual ~SubSystemClassBase(); + + void init(); + virtual void instantiateMessageServices() = 0; + virtual void instantiateActors() = 0; + + void start(bool singlethreaded); + void stop(bool singlethreaded); + void runOnce(); + + void destroy(); + + MessageService* getMsgService(int idx) const; + + ActorClassBase* getInstance(unsigned int i); + ActorClassBase* getInstance(std::string path); + + //--------------------------------------------- + // this is to run integration tests + //--------------------------------------------- + // TODO synchronized + void setTestSemaphore(TestSemaphore& sem); + //TODO synchronized + int getTestErrorCode() const; + void testFinished(int errorCode); + +protected: + RTSystemServicesProtocolConjPortRepl* m_RTSystemPort; + //--------------------- interface item IDs + static const int IFITEM_RTSystemPort = 0; + std::vector<ActorClassBase*> m_instances; +private: + TestSemaphore* m_testSem; + int m_testErrorCode; + + SubSystemClassBase(); + SubSystemClassBase(const SubSystemClassBase& right); + SubSystemClassBase& operator=(const SubSystemClassBase& right); +}; + +} /* namespace etRuntime */ +#endif /* SUBSYSTEMCLASSBASE_H_ */ |