diff options
Diffstat (limited to 'examples/org.eclipse.etrice.tutorials.java/src-gen/SendingData/PingPongProtocol.java')
| -rw-r--r-- | examples/org.eclipse.etrice.tutorials.java/src-gen/SendingData/PingPongProtocol.java | 207 |
1 files changed, 0 insertions, 207 deletions
diff --git a/examples/org.eclipse.etrice.tutorials.java/src-gen/SendingData/PingPongProtocol.java b/examples/org.eclipse.etrice.tutorials.java/src-gen/SendingData/PingPongProtocol.java deleted file mode 100644 index e5d4e3d77..000000000 --- a/examples/org.eclipse.etrice.tutorials.java/src-gen/SendingData/PingPongProtocol.java +++ /dev/null @@ -1,207 +0,0 @@ -package SendingData;
-
-import org.eclipse.etrice.runtime.java.messaging.Message;
-import org.eclipse.etrice.runtime.java.modelbase.EventMessage;
-import org.eclipse.etrice.runtime.java.modelbase.EventWithDataMessage;
-import org.eclipse.etrice.runtime.java.modelbase.IEventReceiver;
-import org.eclipse.etrice.runtime.java.modelbase.InterfaceItemBase;
-import org.eclipse.etrice.runtime.java.modelbase.PortBase;
-import org.eclipse.etrice.runtime.java.modelbase.ReplicatedPortBase;
-import org.eclipse.etrice.runtime.java.debugging.DebuggingService;
-import static org.eclipse.etrice.runtime.java.etunit.EtUnit.*;
-
-
-
-public class PingPongProtocol {
- // message IDs
- public static final int MSG_MIN = 0;
- public static final int OUT_pong = 1;
- public static final int OUT_pongSimple = 2;
- public static final int IN_ping = 3;
- public static final int IN_pingSimple = 4;
- public static final int MSG_MAX = 5;
-
-
- private static String messageStrings[] = {"MIN", "pong","pongSimple", "ping","pingSimple","MAX"};
-
- public String getMessageString(int msg_id) {
- if (msg_id<MSG_MIN || msg_id>MSG_MAX+1){
- // id out of range
- return "Message ID out of range";
- }
- else{
- return messageStrings[msg_id];
- }
- }
-
-
- // port class
- static public class PingPongProtocolPort extends PortBase {
- // constructors
- public PingPongProtocolPort(IEventReceiver actor, String name, int localId) {
- this(actor, name, localId, 0);
- }
- public PingPongProtocolPort(IEventReceiver actor, String name, int localId, int idx) {
- super(actor, name, localId, idx);
- DebuggingService.getInstance().addPortInstance(this);
- }
-
- @Override
- public void receive(Message m) {
- if (!(m instanceof EventMessage))
- return;
- EventMessage msg = (EventMessage) m;
- if (0 < msg.getEvtId() && msg.getEvtId() < MSG_MAX) {
- if (messageStrings[msg.getEvtId()] != "timerTick"){
- DebuggingService.getInstance().addMessageAsyncIn(getPeerAddress(), getAddress(), messageStrings[msg.getEvtId()]);
- }
- if (msg instanceof EventWithDataMessage)
- getActor().receiveEvent(this, msg.getEvtId(), ((EventWithDataMessage)msg).getData());
- else
- getActor().receiveEvent(this, msg.getEvtId(), null);
- }
- }
-
-
- // sent messages
- public void pong(DemoData data) {
- if (messageStrings[ OUT_pong] != "timerTick") {
- DebuggingService.getInstance().addMessageAsyncOut(getAddress(), getPeerAddress(), messageStrings[OUT_pong]);
- }
- if (getPeerAddress()!=null)
- getPeerMsgReceiver().receive(new EventWithDataMessage(getPeerAddress(), OUT_pong, data.deepCopy()));
- }
- public void pong(int int32Val, byte[] int8Array, double float64Val, String stringVal) {
- pong(new DemoData(int32Val, int8Array, float64Val, stringVal));
- }
- public void pongSimple(int data) {
- if (messageStrings[ OUT_pongSimple] != "timerTick") {
- DebuggingService.getInstance().addMessageAsyncOut(getAddress(), getPeerAddress(), messageStrings[OUT_pongSimple]);
- }
- if (getPeerAddress()!=null)
- getPeerMsgReceiver().receive(new EventWithDataMessage(getPeerAddress(), OUT_pongSimple, data));
- }
- }
-
- // replicated port class
- static public class PingPongProtocolReplPort extends ReplicatedPortBase {
-
- public PingPongProtocolReplPort(IEventReceiver actor, String name, int localId) {
- super(actor, name, localId);
- }
-
- public int getReplication() {
- return getNInterfaceItems();
- }
-
- public int getIndexOf(InterfaceItemBase ifitem){
- return ifitem.getIdx();
- }
-
- public PingPongProtocolPort get(int idx) {
- return (PingPongProtocolPort) getInterfaceItem(idx);
- }
-
- protected InterfaceItemBase createInterfaceItem(IEventReceiver rcv, String name, int lid, int idx) {
- return new PingPongProtocolPort(rcv, name, lid, idx);
- }
-
- // outgoing messages
- public void pong(DemoData data){
- for (int i=0; i<getReplication(); ++i) {
- get(i).pong( data);
- }
- }
- public void pongSimple(int data){
- for (int i=0; i<getReplication(); ++i) {
- get(i).pongSimple( data);
- }
- }
- }
-
-
- // port class
- static public class PingPongProtocolConjPort extends PortBase {
- // constructors
- public PingPongProtocolConjPort(IEventReceiver actor, String name, int localId) {
- this(actor, name, localId, 0);
- }
- public PingPongProtocolConjPort(IEventReceiver actor, String name, int localId, int idx) {
- super(actor, name, localId, idx);
- DebuggingService.getInstance().addPortInstance(this);
- }
-
- @Override
- public void receive(Message m) {
- if (!(m instanceof EventMessage))
- return;
- EventMessage msg = (EventMessage) m;
- if (0 < msg.getEvtId() && msg.getEvtId() < MSG_MAX) {
- if (messageStrings[msg.getEvtId()] != "timerTick"){
- DebuggingService.getInstance().addMessageAsyncIn(getPeerAddress(), getAddress(), messageStrings[msg.getEvtId()]);
- }
- if (msg instanceof EventWithDataMessage)
- getActor().receiveEvent(this, msg.getEvtId(), ((EventWithDataMessage)msg).getData());
- else
- getActor().receiveEvent(this, msg.getEvtId(), null);
- }
- }
-
-
- // sent messages
- public void ping(DemoData data) {
- if (messageStrings[ IN_ping] != "timerTick") {
- DebuggingService.getInstance().addMessageAsyncOut(getAddress(), getPeerAddress(), messageStrings[IN_ping]);
- }
- if (getPeerAddress()!=null)
- getPeerMsgReceiver().receive(new EventWithDataMessage(getPeerAddress(), IN_ping, data.deepCopy()));
- }
- public void ping(int int32Val, byte[] int8Array, double float64Val, String stringVal) {
- ping(new DemoData(int32Val, int8Array, float64Val, stringVal));
- }
- public void pingSimple(int data) {
- if (messageStrings[ IN_pingSimple] != "timerTick") {
- DebuggingService.getInstance().addMessageAsyncOut(getAddress(), getPeerAddress(), messageStrings[IN_pingSimple]);
- }
- if (getPeerAddress()!=null)
- getPeerMsgReceiver().receive(new EventWithDataMessage(getPeerAddress(), IN_pingSimple, data));
- }
- }
-
- // replicated port class
- static public class PingPongProtocolConjReplPort extends ReplicatedPortBase {
-
- public PingPongProtocolConjReplPort(IEventReceiver actor, String name, int localId) {
- super(actor, name, localId);
- }
-
- public int getReplication() {
- return getNInterfaceItems();
- }
-
- public int getIndexOf(InterfaceItemBase ifitem){
- return ifitem.getIdx();
- }
-
- public PingPongProtocolConjPort get(int idx) {
- return (PingPongProtocolConjPort) getInterfaceItem(idx);
- }
-
- protected InterfaceItemBase createInterfaceItem(IEventReceiver rcv, String name, int lid, int idx) {
- return new PingPongProtocolConjPort(rcv, name, lid, idx);
- }
-
- // incoming messages
- public void ping(DemoData data){
- for (int i=0; i<getReplication(); ++i) {
- get(i).ping( data);
- }
- }
- public void pingSimple(int data){
- for (int i=0; i<getReplication(); ++i) {
- get(i).pingSimple( data);
- }
- }
- }
-
-}
|