blob: 947c54c0e62d1b1d88d020a07c900489610f5c7c (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
/*
* ActorClassBase.h
*
* The base class for model actor classes.
*
* Created on: 29.08.2012
* Author: karlitsc
*/
#ifndef ACTORCLASSBASE_H_
#define ACTORCLASSBASE_H_
#include "common/modelbase/EventReceiver.h"
#include "common/messaging/IMessageReceiver.h"
#include "common/messaging/RTServices.h"
#include "common/messaging/RTSystemServicesProtocol.h"
namespace etRuntime {
class ActorClassBase: public EventReceiver, public IMessageReceiver {
public:
ActorClassBase(IRTObject* parent, std::string name, Address ownAddr, Address systemPortPeerAddr);
virtual ~ActorClassBase();
std::string toString();
std::string getClassName() const { return m_className; }
void setClassName(std::string className) { m_className = className; }
virtual Address getAddress() const {
// TODO: Actor should have its own address for services and debugging
return Address(0,0,0);
}
//--------------------- lifecycle functions
// automatically generated lifecycle functions
virtual void init() = 0;
virtual void start() = 0;
virtual void stop() = 0;
virtual void destroy() = 0;
virtual void executeInitTransition() = 0;
// not automatically generated lifecycle functions
// are called, but with empty implementation -> can be overridden by user
void initUser() { }
void startUser() { }
void stopUser() { }
void destroyUser() { }
virtual void receive(Message* msg) { }
int getState() const { return m_state; }
MessageService* getMsgsvc() const { return m_ownMsgsvc; }
protected:
static const int EVT_SHIFT = 1000; // TODOHRR: use 256 or shift operation later
static const int NO_STATE = 0;
static const int STATE_TOP = 1;
static const int NOT_CAUGHT = 0;
/**
* the current state
*/
int m_state;
int* history; //Todo pka: name is not prefixed by m_ because generic generator uses this member
RTSystemServicesProtocolPort* m_RTSystemPort;
virtual bool handleSystemEvent(InterfaceItemBase* ifitem, int evt, void* generic_data);
private:
std::string m_className;
Address m_ownAddr;
MessageService* m_ownMsgsvc;
};
} /* namespace etRuntime */
#endif /* ACTORCLASSBASE_H_ */
|
