debugging

Author: henricasanova

include/wrench/simgrid_S4U_util/S4U_Daemon.h

@@ -52,7 +52,7 @@ namespace wrench {
          *        which then causes memory errors when freeing communications
          *        these actors were involved in
          */
-        static std::set<std::shared_ptr<S4U_Daemon>> running_actors;
+//        static std::set<std::shared_ptr<S4U_Daemon>> running_actors;
 
 
         /** @brief The name of the daemon */

src/wrench/simgrid_S4U_util/S4U_Daemon.cpp

@@ -30,7 +30,7 @@ std::unordered_map<std::string, unsigned long> num_actors;
 namespace wrench {
 
     std::unordered_map<aid_t, S4U_CommPort *> S4U_Daemon::map_actor_to_recv_commport;
-    std::set<std::shared_ptr<S4U_Daemon>> S4U_Daemon::running_actors;
+//    std::set<std::shared_ptr<S4U_Daemon>> S4U_Daemon::running_actors;
 
     int S4U_Daemon::num_non_daemonized_actors_running = 0;
 
@@ -82,6 +82,8 @@ namespace wrench {
         this->has_returned_from_main = false;
 
         //        std::cerr << "IN DAEMON CONSTRUCTOR: " << this->process_name << "\n";
+        this->commport = S4U_CommPort::getTemporaryCommPort();
+        this->recv_commport = S4U_CommPort::getTemporaryCommPort();
     }
 
     S4U_Daemon::~S4U_Daemon() {
@@ -259,15 +261,15 @@ namespace wrench {
  * @brief Method that run's the user-defined main method (that's called by the S4U actor class)
  */
     void S4U_Daemon::runMainMethod() {
-        this->commport = S4U_CommPort::getTemporaryCommPort();
-        this->recv_commport = S4U_CommPort::getTemporaryCommPort();
+//        this->commport = S4U_CommPort::getTemporaryCommPort();
+//        this->recv_commport = S4U_CommPort::getTemporaryCommPort();
         // Set the commport receiver
         // Causes Mailbox::put() to no longer implement a rendez-vous communication.
         this->commport->s4u_mb->set_receiver(this->s4u_actor);
         //        this->recv_commport->set_receiver(this->s4u_actor);
 
         S4U_Daemon::map_actor_to_recv_commport[simgrid::s4u::this_actor::get_pid()] = this->recv_commport;
-        S4U_Daemon::running_actors.insert(this->getSharedPtr<S4U_Daemon>());
+//        S4U_Daemon::running_actors.insert(this->getSharedPtr<S4U_Daemon>());
 
         this->num_starts++;
         // Compute zero flop so that nothing happens
@@ -283,7 +285,7 @@ namespace wrench {
         S4U_CommPort::retireTemporaryCommPort(this->commport);
         this->recv_commport->s4u_mb->set_receiver(nullptr);
         S4U_CommPort::retireTemporaryCommPort(this->recv_commport);
-        S4U_Daemon::running_actors.erase(this->getSharedPtr<S4U_Daemon>());
+//        S4U_Daemon::running_actors.erase(this->getSharedPtr<S4U_Daemon>());
     }