New development version.

[jaceP2P.git] / src / jaceP2P / JaceSpawnerServer.java

diff --git a/src/jaceP2P/JaceSpawnerServer.java b/src/jaceP2P/JaceSpawnerServer.java
index 502c059..e210d88 100644 (file)
--- a/src/jaceP2P/JaceSpawnerServer.java
+++ b/src/jaceP2P/JaceSpawnerServer.java
@@ -23,7 +23,6 @@ public class JaceSpawnerServer extends UnicastRemoteObject implements
        @SuppressWarnings("unchecked")
        public void startProcess(Vector spawnersList) throws RemoteException {
                JaceSpawner.Instance().startProcess(spawnersList);
-
        }
 
        public Register getRegister(int rank) throws RemoteException {
@@ -63,7 +62,7 @@ public class JaceSpawnerServer extends UnicastRemoteObject implements
                        res = RunningApplication.Instance().getChrono().getValue();
                        // System.out.println("temps chrono : " + res + " ms\n");
                } else {
-                       System.out.println("pas d'appli de ce nom sur ce spawner");
+                       System.err.println("No application of name "+appliName+" on this Spawner !");
                }
                return res;
        }
@@ -88,7 +87,7 @@ public class JaceSpawnerServer extends UnicastRemoteObject implements
 
        public void signalDeadNode(JaceInterface host, int rankOfDead)
                        throws RemoteException {
-               System.out.println("signalDeadNode of rank " + rankOfDead);
+               System.out.println("SignalDeadNode of rank " + rankOfDead);
                JaceSpawner.Instance().signalDeadNode(host, rankOfDead);
        }
 
@@ -128,20 +127,31 @@ public class JaceSpawnerServer extends UnicastRemoteObject implements
                else
                        System.out.println("Node " + oldNode.getName() + " of rank " + rank
                                        + " hasn't been removed");
-               Register.Instance().addNode(node);
+               
+               if( node != null )
+               {
+                       Register.Instance().addNode(node);
 
-               TaskId myTaskId = Register.Instance().getListeOfTasks()
+                       TaskId myTaskId = Register.Instance().getListeOfTasks()
                                .getTaskIdOfHostStub(oldNode.getStub());
 
-               myTaskId.setHostIP(node.getIP());
+                       myTaskId.setHostIP(node.getIP());
 
-               myTaskId.setHostName(node.getName());
-               myTaskId.setHostStub(node.getStub());
-               // Register.Instance().setVersion(Register.Instance().getVersion()+1);
-               RunningApplication.Instance().incrementNumberOfDisconnections();
-               System.out.println("replacing node: " + oldNode.getName() + " with: "
+                       myTaskId.setHostName(node.getName());
+                       myTaskId.setHostStub(node.getStub());
+                       // Register.Instance().setVersion(Register.Instance().getVersion()+1);
+                       RunningApplication.Instance().incrementNumberOfDisconnections();
+                       System.out.println("Replacing node: " + oldNode.getName() + " with: "
                                + node.getName());
-               // Register.Instance().getListeOfTasks().viewAll();
+                       // Register.Instance().getListeOfTasks().viewAll();
+               } else {
+                       System.err.println( "ReplaceDaemon: The new node is null!" ) ;
+               }
        }
 
+//     @Override
+//     public void setIdAlgo( String _s ) throws RemoteException 
+//     {
+//             JaceSpawner.Instance().setIdAlgo( _s ) ;
+//     }
 }