public void startProcess(Vector<Object> spawnersList) {
this.spawnersList = spawnersList;
+
int is = spawnersList.indexOf((Object) Register.Instance()
.getSpawnerStub());
+
if (is != -1) {
int nextNeighbour;
if (is == spawnersList.size() - 1)
if( node != null )
{
found = true ;
+ } else {
+ Thread.sleep( 1000 ) ;
+ System.out.println("Pas de bon retour !");
}
} catch (Exception e) {
// trouver un autre superNode et lui demander le noeud a lui
.updateHeart(spawnerStub);
} catch (Exception e) {
System.err
- .println("unable to change the server of the heartbeatThread for the previous node of rank "
+ .println("Unable to change the server of the heartbeatThread for the previous node of rank "
+ previous + ". error:" + e);
}
}
centralServer = (JaceSuperNodeInterface) Naming.lookup("rmi://"
+ superNode_IP + ":" + superNode_port
+ "/JaceSuperNode");
- System.out.println("succesfully located " + superNode_IP);
+ System.out.println("Succesfully located " + superNode_IP);
// add stub and IP in LocalHost to store it until super node
// death
spawnersList = new Vector<Object>();
for (int i = 0; i < nbExtraSpawners && i < registerSpawner.getSize(); i++) {
- spawnersList.add(registerSpawner.getNodeAt(i
- * nbOfDaemonsPerSpawner));
- registerSpawner.removeNode(registerSpawner.getNodeAt(i
- * nbOfDaemonsPerSpawner));
+ spawnersList.add(registerSpawner.getNodeAt(0));
+// * nbOfDaemonsPerSpawner));
+ registerSpawner.removeNodeOfName(registerSpawner.getNodeAt(0).getName());
+// * nbOfDaemonsPerSpawner));
}
registerSpawner.setNbOfTasks(nbTasks);
+ ez);
}
}
- System.exit(0);
+ System.exit(1);
}
}
}
* System.out.println("waiting till transform of spawner "+i+
* " is finished"); Thread.sleep(20); }catch(Exception e1){}
*/
-
// System.out.println("start process on spawner of rank "+i);
- JaceSpawnerInterface spawnerStub = (JaceSpawnerInterface) spawnersList
- .elementAt(i);
+ JaceSpawnerInterface spawnerStub = (JaceSpawnerInterface) spawnersList.get(i);
spawnerStub.startProcess(spawnersList);
} catch (Exception e) {
e.printStackTrace(System.out);
// in order to start each task on the Daemons
spawnersList.add(Register.Instance().getSpawnerStub());
- System.out.println(" rank=spawnersList.size()=" + spawnersList.size());
+ System.out.println(" rank="+rank+" spawnersList.size()=" + spawnersList.size());
rank = spawnersList.size() - 1;
+
broadcastRegister(1);
+
for (int j = 0; j < spawnersList.size(); j++) {
System.out.println("waiting till transform of spawner " + j
+ " is finished");
Thread.sleep(20);
} catch (Exception e) {
}
- System.out
- .println("End Transformation of all spawners. Beginning the computing processes");
}
+
+ System.out.println("End Transformation of all spawners. Beginning the computing processes");
+
for (i = 0; i < spawnersList.size(); i++) {
// while(!(spawnersList.elementAt(i) instanceof
JaceInterface nodeStub = null;
TaskId myTask = null;
- System.out.println("appli launched, starting the chrono");
+ System.out.println("Application launched, starting the chronometer");
RunningApplication.Instance().getChrono().start();
RunningApplication.Instance().setName(appliName);
while (broadcasting == true)
Thread.sleep(5);
broadcasting = true;
- Register.Instance().setSpawnerStub(
- Register.Instance().getSpawnerStub());
+// Register.Instance().setSpawnerStub(
+// Register.Instance().getSpawnerStub());
int x = reg.getListeOfTasks().getSize() / nbOfDaemonsPerSpawner;
int s;
if (rank == x)