@SuppressWarnings("unchecked")
public void startProcess(Vector spawnersList) throws RemoteException {
JaceSpawner.Instance().startProcess(spawnersList);
-
}
public Register getRegister(int rank) throws RemoteException {
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;
}
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);
}
myTaskId.setHostStub(node.getStub());
// Register.Instance().setVersion(Register.Instance().getVersion()+1);
RunningApplication.Instance().incrementNumberOfDisconnections();
- System.out.println("replacing node: " + oldNode.getName() + " with: "
+ System.out.println("Replacing node: " + oldNode.getName() + " with: "
+ node.getName());
// Register.Instance().getListeOfTasks().viewAll();
}
+// @Override
+// public void setIdAlgo( String _s ) throws RemoteException
+// {
+// JaceSpawner.Instance().setIdAlgo( _s ) ;
+// }
}