aboutsummaryrefslogtreecommitdiff
path: root/src/simulator.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/simulator.cc')
-rw-r--r--src/simulator.cc135
1 files changed, 72 insertions, 63 deletions
diff --git a/src/simulator.cc b/src/simulator.cc
index b34a95b..87cbe84 100644
--- a/src/simulator.cc
+++ b/src/simulator.cc
@@ -92,6 +92,7 @@ static void obs_node(std::vector<std::string> args) {
u32 nDataRcv=0;
u32 nSendFail=0;
u32 nRcvFail=0;
+ u32 nSend=0;
while(i.ShouldContinue()){
XBT_INFO("%s is spleeping",selfName.c_str());
MODE_OFF();
@@ -100,73 +101,81 @@ static void obs_node(std::vector<std::string> args) {
XBT_INFO("%s wakes up",selfName.c_str());
// Doing wake up stuff
- try {
- if(isSender){ // If I am a sender
- Payload *p=new Payload();
- p->node=selfName;
- if(useHint&&i.HasNext()){
- p->containsHint=true;
- p->hint=i.GetNextTS();
- p->duration=i.GetNextDuration();
+ double uptime=i.GetDuration();
+ while(uptime>0.00001){ // Ensure not infinite loop even if it should not happend (we loose accuracy here but just in case)
+ try {
+ if(isSender){ // If I am a sender
+ Payload *p=new Payload();
+ p->node=selfName;
+ if(useHint&&i.HasNext()){
+ p->containsHint=true;
+ p->hint=i.GetNextTS();
+ p->duration=i.GetNextDuration();
+ }
+ if(i.extended){
+ // We use a trick here
+ // First we send an instantaneous message (size=0) with the usual timeout
+ // to check whether there is a receiver!
+ // If there is one, we are sure that a put in the "medium"+selfName
+ // will not lead to a deadlock (cf anchor:5623) and we are using a exclusive
+ // channel (to avoid other receivers to get the message)
+ m->put(p,0,uptime);
+ simgrid::s4u::Mailbox *m_ext= simgrid::s4u::Mailbox::by_name("medium"+selfName);
+ MODE_TX();
+ m_ext->put(p,data_size);
+ }
+ else{
+ MODE_TX();
+ m->put(p,data_size,uptime);
+ }
+ nSend++;
+ isSender=(nSend<(i.n_nodes-1));
+ isObserver=!isSender;
+ XBT_INFO("%s sent data successfully",selfName.c_str());
}
- if(i.extended){
- // We use a trick here
- // First we send an instantaneous message (size=0) with the usual timeout
- // to check whether there is a receiver!
- // If there is one, we are sure that a put in the "medium"+selfName
- // will not lead to a deadlock (cf anchor:5623) and we are using a exclusive
- // channel (to avoid other receivers to get the message)
- m->put(p,0,i.GetDuration());
- simgrid::s4u::Mailbox *m_ext= simgrid::s4u::Mailbox::by_name("medium"+selfName);
- MODE_TX();
- m_ext->put(p,data_size);
+ else if (!isObserver){
+ Payload* p;
+ if(i.extended){
+ // anchor:5623 We can see here that
+ // we first receive the instantaneous message
+ // and then we use a mailbox specific to the sender (to have an exclusive channel)
+ p=m->get<Payload>(uptime);
+ simgrid::s4u::Mailbox *m_ext_sender = simgrid::s4u::Mailbox::by_name("medium"+p->node);
+ MODE_RX();
+ p=m_ext_sender->get<Payload>();
+ }
+ else{
+ MODE_RX();
+ p=m->get<Payload>(uptime);
+ }
+ nDataRcv++; // New data received
+ if(p->containsHint){
+ XBT_INFO("%s received and hint of %f",selfName.c_str(),p->hint);
+ i.AddEvent(p->hint, p->duration); // Schedule a new wake up time
+ }
+ else{
+ XBT_INFO("%s received data successfully",selfName.c_str());
+ }
+ isObserver=true; // Now we received the data we switch to observer
}
- else{
- MODE_TX();
- m->put(p,data_size,i.GetDuration());
+ else {
+ XBT_INFO("%s is observing his environment...",selfName.c_str());
+ MODE_ON();
+ simgrid::s4u::this_actor::sleep_for(uptime);
}
- XBT_INFO("%s sent data successfully",selfName.c_str());
}
- else if (!isObserver){
- Payload* p;
- if(i.extended){
- // anchor:5623 We can see here that
- // we first receive the instantaneous message
- // and then we use a mailbox specific to the sender (to have an exclusive channel)
- p=m->get<Payload>(i.GetDuration());
- simgrid::s4u::Mailbox *m_ext_sender = simgrid::s4u::Mailbox::by_name("medium"+p->node);
- MODE_RX();
- p=m_ext_sender->get<Payload>();
- }
- else{
- MODE_RX();
- p=m->get<Payload>(i.GetDuration());
- }
- nDataRcv++; // New data received
- if(p->containsHint){
- XBT_INFO("%s received and hint of %f",selfName.c_str(),p->hint);
- i.AddEvent(p->hint, p->duration); // Schedule a new wake up time
- }
- else{
- XBT_INFO("%s received data successfully and switch to forwarding mode",selfName.c_str());
- }
- isObserver=true; // Now we received the data we switch to observer
+ catch (...)
+ {
+ if(isSender){
+ XBT_INFO("%s could not send any data",selfName.c_str());
+ nSendFail++;
+ }
+ else{
+ XBT_INFO("%s could not receive any data",selfName.c_str());
+ nRcvFail++;
+ }
}
- else {
- XBT_INFO("%s is observing his environment...",selfName.c_str());
- simgrid::s4u::this_actor::sleep_until(i.GetDuration());
- }
- }
- catch (...)
- {
- if(isSender){
- XBT_INFO("%s could not send any data",selfName.c_str());
- nSendFail++;
- }
- else{
- XBT_INFO("%s could not receive any data",selfName.c_str());
- nRcvFail++;
- }
+ uptime=(i.GetTS()+i.GetDuration())-simgrid::s4u::Engine::get_clock();
}
// Load next event
i.GotoNextEvent();
@@ -174,5 +183,5 @@ static void obs_node(std::vector<std::string> args) {
}
// Done
MODE_OFF()
- XBT_INFO("Observation node %s finished [LOG2PARSE](node:%s|nWakeUp:%d|nDataRcv:%d|nSendFail:%d|nRcvFail:%d|simkey:%s|seed:%d)",selfName.c_str(),selfName.c_str(),nWakeUp,nDataRcv,nSendFail,nRcvFail,i.simkey.c_str(),i.seed);
+ XBT_INFO("Observation node %s finished [LOG2PARSE](node:%s|nSend:%d|nWakeUp:%d|nDataRcv:%d|nSendFail:%d|nRcvFail:%d|simkey:%s|seed:%d)",selfName.c_str(),selfName.c_str(),nSend,nWakeUp,nDataRcv,nSendFail,nRcvFail,i.simkey.c_str(),i.seed);
} \ No newline at end of file
generated by cgit v1.2.3 (git 2.46.0) at 2026-04-16 00:49:19 +0000