From 477dbe49a9f29fc1510ad98ac534f1e8db2fe07c Mon Sep 17 00:00:00 2001
From: quemy <alexandre.quemy@gmail.com>
Date: Sat, 10 Nov 2012 19:22:59 +0100
Subject: [PATCH] Add integration method, observer pattern from policy to
 island

---
 smp/src/island.cpp         | 22 ++++++++++++++++++----
 smp/src/island.h           | 12 ++++++++----
 smp/src/migPolicy.h        | 36 ++++++++++++++++++++++++++++++++----
 smp/src/migPolicyElement.h |  5 +++++
 smp/test/t-smpIsland.cpp   |  5 ++++-
 5 files changed, 67 insertions(+), 13 deletions(-)

diff --git a/smp/src/island.cpp b/smp/src/island.cpp
index 39f864dd1..da6066117 100644
--- a/smp/src/island.cpp
+++ b/smp/src/island.cpp
@@ -37,7 +37,8 @@ paradiseo::smp::Island<EOAlgo,EOT>::Island(unsigned _popSize, eoInit<EOT>& _chro
     algo(EOAlgo<EOT>(wrap_pp<eoContinue<EOT>>(this->ck,args)...)),
     intPolicy(_intPolicy)
 {
-    static_assert(std::is_base_of<eoAlgo<EOT>,EOAlgo<EOT>>::value, "Algorithm must inherit from eoAlgo<EOT>");  
+    static_assert(std::is_base_of<eoAlgo<EOT>,EOAlgo<EOT>>::value, "Algorithm must inherit from eoAlgo<EOT>");
+    _migPolicy.addObserver(this);  
 }
 
 template<template <class> class EOAlgo, class EOT>
@@ -49,7 +50,7 @@ void paradiseo::smp::Island<EOAlgo,EOT>::operator()()
 template<template <class> class EOAlgo, class EOT>
 void paradiseo::smp::Island<EOAlgo,EOT>::update(eoPop<EOT>& _data)
 {
-    algo(pop);
+    listImigrants.push_back(&_data);
 }
 
 template<template <class> class EOAlgo, class EOT>
@@ -59,8 +60,21 @@ eoPop<EOT>& paradiseo::smp::Island<EOAlgo,EOT>::getPop()
 }
 
 template<template <class> class EOAlgo, class EOT>
-void paradiseo::smp::Island<EOAlgo,EOT>::send()
+void paradiseo::smp::Island<EOAlgo,EOT>::send(eoSelect<EOT>& _select)
 {
-    algo(pop);
+    std::cout << "Ile lance la migration" << std::endl;
+    eoPop<EOT> migPop;
+    _select(pop, migPop);
+    std::cout << "   La population migrante est :" << std::endl << migPop << std::endl;
 }
 
+template<template <class> class EOAlgo, class EOT>
+void paradiseo::smp::Island<EOAlgo,EOT>::receive(void)
+{
+    while (!listImigrants.empty())
+    {
+        intPolicy(pop, *(listImigrants.front()));
+        listImigrants.pop();
+    }
+
+}
diff --git a/smp/src/island.h b/smp/src/island.h
index ef522d238..a035905b0 100644
--- a/smp/src/island.h
+++ b/smp/src/island.h
@@ -35,6 +35,7 @@ Contact: paradiseo-help@lists.gforge.inria.fr
 #include <utility>
 
 #include <eo>
+#include <abstractIsland.h>
 #include <migPolicy.h>
 #include <PPExpander.h>
 #include <contWrapper.h>
@@ -46,7 +47,7 @@ namespace smp
 {
 
 template<template <class> class EOAlgo, class EOT>
-class Island : private ContWrapper<EOT>
+class Island : private ContWrapper<EOT>, public AIsland<EOT>
 {
 public:
     template<class... Args>
@@ -57,13 +58,16 @@ public:
     void update(eoPop<EOT>& _data);
     
     eoPop<EOT>& getPop();
-
+    
+    //friend void Policy<EOT>::notifyIsland(eoSelect<EOT>& _select) const;
+    
 protected:
-    void send();
+    void send(eoSelect<EOT>& _select);
+    void receive(void);
 
     eoPop<EOT> pop;
     EOAlgo<EOT> algo;
-    std::queue<std::pair<unsigned, eoPop<EOT>>> listImigrants;
+    std::queue<eoPop<EOT>*> listImigrants;
     eoReplacement<EOT>& intPolicy;
 };
 
diff --git a/smp/src/migPolicy.h b/smp/src/migPolicy.h
index f083fcd5f..6bd0dcea2 100644
--- a/smp/src/migPolicy.h
+++ b/smp/src/migPolicy.h
@@ -30,14 +30,20 @@ Contact: paradiseo-help@lists.gforge.inria.fr
 #ifndef MIG_POLICY_H_
 #define MIG_POLICY_H_
 
-#include <eo>
+#include <set>
 
+#include <eo>
 #include <migPolicyElement.h>
+#include <island.h>
+#include <abstractIsland.h>
 
 namespace paradiseo
 {
 namespace smp
 {
+// Forward declaration
+template <class EOT>
+class AIsland;
 
 template <class EOT>
 class Policy : public eoContinue<EOT>, public std::vector<PolicyElement<EOT>>
@@ -50,12 +56,34 @@ public:
         {
             std::cout << ".";
             if(!elem(_pop))
+            {
                 std::cout << "On lance l'emmigration" << std::endl;
-        } 
-       
-        
+                notifyIsland(elem.getSelect());
+            }
+        }     
         return true; // Always return true because it never stops the algorithm
     }
+    
+    void addObserver(AIsland<EOT>* _observer)
+    {
+        observers.insert(_observer);
+    }
+ 
+    void removeObserver(AIsland<EOT>* _observer)
+    {
+        observers.erase(_observer);
+    }
+   
+protected:
+
+    void notifyIsland(eoSelect<EOT>& _select) const
+    {
+        std::cout << "On notifie les iles" << std::endl;
+        for (AIsland<EOT>* it : observers)
+            it->send(_select);
+    }
+
+    std::set<AIsland<EOT>*> observers;
 };
 
 }
diff --git a/smp/src/migPolicyElement.h b/smp/src/migPolicyElement.h
index 6ddacbcb3..15f37aeb8 100644
--- a/smp/src/migPolicyElement.h
+++ b/smp/src/migPolicyElement.h
@@ -64,6 +64,11 @@ public :
         criteria.add(_criteria);
     }
     
+    eoSelect<EOT>& getSelect() 
+    {
+        return selection;
+    }
+    
 protected :
     eoSelect<EOT>& selection;
     eoContinue<EOT>& criteria;
diff --git a/smp/test/t-smpIsland.cpp b/smp/test/t-smpIsland.cpp
index cea4ac71f..f89820d0f 100644
--- a/smp/test/t-smpIsland.cpp
+++ b/smp/test/t-smpIsland.cpp
@@ -51,10 +51,13 @@ int main(void)
     {
         // Emigration policy
         eoPeriodicContinue<Indi> criteria(25); // We mig each gen
+        eoDetTournamentSelect<Indi> selectOne(2);
+        eoSelectNumber<Indi> who(selectOne, 5);
         Policy<Indi> pol;
-        pol.push_back(PolicyElement<Indi>(select, criteria));
+        pol.push_back(PolicyElement<Indi>(who, criteria));
         
         Island<eoEasyEA,Indi> test(param.popSize, chromInit, replace, pol, genCont, plainEval, select, transform, replace);
+        
         test();
         cout << test.getPop() << endl;
     }