msgr: remove rank number from endpoint, since there's only one.

Remove Endpoint's wait() method as it's unused.

diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc
index 15f50054891f4bc43366ef74388d07dcc14a55fd..6fb4860f00b6e688485a41b322ba3060893ee78d 100644 (file)
--- a/src/msg/SimpleMessenger.cc
+++ b/src/msg/SimpleMessenger.cc
@@ -2230,7 +2230,7 @@ SimpleMessenger::Endpoint *SimpleMessenger::register_entity(entity_name_t name)
   }
 
   // create messenger
-  Endpoint *msgr = new Endpoint(this, name, 0);
+  Endpoint *msgr = new Endpoint(this, name);
 
   // now i know my type.
   if (my_type >= 0)

diff --git a/src/msg/SimpleMessenger.h b/src/msg/SimpleMessenger.h
index f874ea3b8a1c8b5598ebbd9b37d590a995376cdf..53c4cfe0470e3b69d98eef3a6361a133a06badd0 100644 (file)
--- a/src/msg/SimpleMessenger.h
+++ b/src/msg/SimpleMessenger.h
@@ -409,7 +409,7 @@ private:
     friend class SimpleMessenger;
 
   public:
-    Endpoint(SimpleMessenger *r, entity_name_t name, int rn) : 
+    Endpoint(SimpleMessenger *r, entity_name_t name) : 
       Messenger(name),
       rank(r),
       dispatch_thread(this) {
@@ -428,10 +428,6 @@ private:
     void ready();
     //bool is_stopped() { return stop; }
 
-    void wait() {
-      dispatch_thread.join();
-    }
-    
     int get_dispatch_queue_len() { return rank->dispatch_queue.get_queue_len(); }
 
     entity_addr_t get_myaddr();