--- a/src/DAF/AE/AEPing.cc
+++ b/src/DAF/AE/AEPing.cc
@@ -17,22 +17,21 @@
Define_Module(AEPing);
-//Consts
-const char* TIM_START = "StartCommunication";
-const char* TIM_STOP = "StopCommunication";
-const char* MSG_PING = "PING-";
-const char* PAR_START = "startAt";
-const char* PAR_STOP = "stopAt";
-const char* PAR_PING = "pingAt";
-const char* PAR_RATE = "rate";
-const char* PAR_SIZE = "size";
-const char* PAR_DSTAPNAME = "dstApName";
-const char* PAR_DSTAPINSTANCE = "dstApInstance";
-const char* PAR_DSTAENAME = "dstAeName";
-const char* PAR_DSTAEINSTANCE = "dstAeInstance";
-const char* VAL_MODULEPATH = "getFullPath()";
-
AEPing::AEPing() {
+ //Consts
+ TIM_START = "StartCommunication";
+ TIM_STOP = "StopCommunication";
+ MSG_PING = "PING-";
+ PAR_START = "startAt";
+ PAR_STOP = "stopAt";
+ PAR_PING = "pingAt";
+ PAR_RATE = "rate";
+ PAR_SIZE = "size";
+ PAR_DSTAPNAME = "dstApName";
+ PAR_DSTAPINSTANCE = "dstApInstance";
+ PAR_DSTAENAME = "dstAeName";
+ PAR_DSTAEINSTANCE = "dstAeInstance";
+ VAL_MODULEPATH = "getFullPath()";
}
AEPing::~AEPing() {
@@ -99,6 +98,7 @@
//Watchers
WATCH_LIST(flows);
+ WATCH(connectionState);
}
void AEPing::handleSelfMessage(cMessage *msg) {
@@ -132,7 +132,7 @@
obj.objectInstance = -1;
obj.objectVal = (cObject*)(&myPath);
ping->setObject(obj);
- ping->setSize(size);
+ ping->setByteLength(size);
//Send message
sendData(&flows.back(), ping);