Отправка сообщения по таймеру
Я хочу реализовать схему сообщений на основе таймера в VEINs/OMNeT++. Вот сценарий: один узел отправляет сообщение многим узлам (скажем, 5 узлам). Каждый узел после получения сообщения устанавливает свой таймер для передачи сообщения другим узлам в сети в зависимости от его расстояния от узла-отправителя, так что самый дальний узел устанавливает самый короткий таймер. И когда узел получает сообщение от других узлов до истечения срока его таймера, он отменяет таймер. Но если таймер истекает и он не получил никакого сообщения от других узлов, он передает сообщение.
Я пробовал следовать объяснению в этой ссылке Как реализовать таймеры в Omnet++?
Я объявил сообщение таймера в функции initialize()
MyApp::Initialize(int stage)
{
RstValueEvt = new cMessage("reset value evt");
}
Затем функция onWSM для получения сообщения проверяет, получено ли сообщение снова, я проверяю событие таймера, если оно запланировано, я отменяю таймер, используя:
MyApp::onWSM(BaseFrame1609* frame)
infoMsg* wsm = check _and_cast<infoMsg>(frame)
if (wsm.getrecipient==myId)
{
if (RstValueEvt->isScheduled())
{ cancelEvent(RstValueEvt); }
else{scheduleAt(simTime()+timer, RstValueEvt);
//creating copy of the message that I need to rebroadcast
cMessage* copyMessage = (cMessage *)infoMsg.dup;
}
}
Моя проблема заключается в том, как заставить этот узел транслировать копию сообщения (infoMsg) всем узлам в сети по истечении времени таймера, то есть как обрабатывать это сообщение в handleselfmsg fcn и onWSM fcn?
Где вы планируете самосообщение?
Где вы добавили строчку: if (RstValueEvt->isScheduled()) { cancelEvent(RstValueEvt); }?
В функции onWSM после расчета таймера на основе расстояния я запланировал собственное сообщение, используя; scheduleAt(simTime()+таймер, RstValueEvt); @ЕжиД.
Я тоже добавил эту строку в функцию onWSM @JerzyD.
Не могли бы вы добавить вышеупомянутую информацию в свой вопрос? Благодаря этому мы будем лучше видеть ваш код.
Ответы 1
Я предлагаю следующий способ достижения цели:
объявите в своем классе сообщение для хранения полученного широковещательного сообщения, например.
cMessage * toBroadcastMsg;в конструкторе
toBroadcastMsg = nullptr;создать экземпляр самосообщения (таймер):
MyApp::initialize() { // ... RstValueEvt = new cMessage("reset value evt"); // ... }проверьте, истекает ли ваше самосообщение (таймер):
MyApp::handleSelfMsg(cMessage* msg) { // ... if (RstValueEvt == msg && toBroadcastMsg != nullptr) { // (2) send a message from toBroadcastMsg // ... toBroadcastMsg = nullptr; }запланировать таймер после получения широковещательного сообщения, а также сохранить дубликат полученного широковещательного сообщения:
MyApp::onWSM(BaseFrame1609_4* wsm) { if (wsm.getrecipient == myId) { if (RstValueEvt->isScheduled()) { cancelEvent(RstValueEvt); } else { scheduleAt(simTime() + timer, RstValueEvt); // (1) remember copy of the message for future use toBroadcastMsg = wsm->dup; } }
Не могли бы вы помочь с кодом для отправки ретрансляции по истечении таймера @Jerzy D.
Ваш вопрос не содержит никакой информации о типе сообщения, используемого для трансляции, а также о том, когда и как оно отправляется. Не могли бы вы предоставить код, который вы используете для отправки и получения первого широковещательного сообщения?
Я отредактировал свой вопрос, включив в него код сообщения, которое необходимо передать после получения в функции onWSM.
Я добавил переменную для хранения копии полученного сообщения в своем ответе. В (2) вы должны добавить команду для отправки широковещательного сообщения - вы не показали эту команду в своем коде, поэтому я не могу включить ее в свой ответ.
Большое спасибо @Jerzy D., мне удалось транслировать после ответа на ваш ответ, но теперь моя проблема заключается в том, что все узлы транслируются после окончания их таймера, похоже, что часть события отмены не работает или, может быть, транслируемые сообщения работают не достичь запланированных узлов до истечения таймера
Не могли бы вы отредактировать вопрос и предоставить минимальный воспроизводимый пример?