// if no stub there is a problem
if (stub == null) {
- System.out.println("unable to SEND backup on task of rank " + rank);
+ System.err.println("Unable to send backup on task of rank " + rank);
} else {
// if there is a stub, send the stream to that node
try {
}
}
} catch (Exception e) {
- System.out.println("error in getBackupForNewNode :" + e);
+ System.err.println("Error in getBackupForNewNode :" + e);
e.printStackTrace(System.out);
}
}
jaceSize = Register.Instance().getNbOfTasks();
} catch (Exception e) {
try {
- System.out.println("setId is bad !! " + e + " "
+ System.err.println("SetId is bad !! " + e + " "
+ LocalHost.Instance().getName());
// jaceSize = Register.Instance().getListeOfTasks().getSize();
} catch (Exception e2) {
- System.out.println("not localised the spawner : " + e2);
+ System.err.println("Not localised the spawner : " + e2);
}
}
}
public void jaceFinalize() {
finalize = true;
- System.out.println("ready to Death Task:" + jaceMyId);
+ System.out.println("Ready to Death Task:" + jaceMyId);
try {
Register.Instance().getSpawnerStub().killApplication(
LocalHost.Instance().getStub());
} catch (Exception e) {
- System.out
- .println("pas reussit a joindre Spawner pr killApplication : "
+ System.err
+ .println("Cannot join the Spawner to kill application: "
+ e);
}
reinitializeVectors();
} catch (Exception e) {
- System.out.println("erreur ds jaceP2P_reinitConv():" + e);
+ System.err.println("Error in jaceP2P_reinitConv():" + e);
}
pseudoPerBeg = false;
pseudoPerEnd = false;
result = Register.Instance().getSpawnerStub().getChronoValue(
Register.Instance().getAppliName());
} catch (Exception e) {
- System.out
+ System.err
.println("JaceP2P_Error in Task.jaceP2P_getChronoValue() on SuperNode : "
+ e);
}
recev = Register.Instance().getListeOfTasks().getTaskIdOfRank(dest);
if (recev == null) {
- System.out.println("In jaceSend recv = null !");
+ System.err.println("In jaceSend recv = null !");
try {
JaceSession.Instance().getTaskThread().sleep(10);
JaceSession.Instance().getTaskThread().yield();
// TODO : virer ce else, mais chercher pkoi recev est null des fois
else {
if (recev.getRank() != dest) {
- System.out.println("Problem !! pas le meme dest que ds les param");
+ System.err.println("Problem !! pas le meme dest que ds les param");
}
// creer le Message
// SenderSocket.Instance().getBuffer().add(msg);
}
} catch (Exception e) {
- System.out.println("unable to send data message to " + dest
+ System.err.println("Unable to send data message to " + dest
+ ": " + e);
}
// System.out.println("TASK : g mis un msg qui doit etre envoye");
}
} catch (Exception e) {
if (Register.Instance().getListeOfTasks() == null)
- System.out.println("Liste des taches est nulle: " + e);
+ System.err.println("Tasks list is null: " + e);
}
}
}
} catch (Exception e) {
- System.out.println("error jaceReceive :" + e);
- System.out.println("sender=" + sender);
+ System.err.println("Error jaceReceive :" + e);
+ System.err.println("Sender=" + sender);
}
return (tmp.getData());
} else {
// + ") taille MsgQueue : " + MsgQueue.Instance().getSize());
} catch (Exception e) {
if (Register.Instance().getListeOfTasks() == null)
- System.out.println("Liste des taches est nulle: " + e);
+ System.err.println("Tasks list is null: " + e);
}
try {
JaceSession.Instance().getTaskThread().sleep(10);
.getTaskIdOfRank(saveTab[i]); // ///////////////////////////pb
stub = task.getHostStub();
} catch (Exception e) {
- System.out
- .println("pb in the broadcast, ligne d'assignation de task ds broadcats: "
+ System.err
+ .println("Problem in the broadcast, ligne d'assignation de task ds broadcats: "
+ e);
}
.getTaskIdOfRank(saveTab[i]); // ///////////////////////////pb
stub = task.getHostStub();
} catch (Exception e) {
- System.out
- .println("pb in the broadcast, ligne d'assignation de task ds broadcats: "
+ System.err
+ .println("Problem in the broadcast, ligne d'assignation de task ds broadcats: "
+ e);
}
fluxOut.writeObject(t);
fluxOut.close();
} catch (Exception e) {
- System.out
+ System.err
.println("JaceP2P_Error in Task.jaceP2P_ReinitConv() when converting Task in Stream : "
+ e);
}
fluxOut.writeObject(t);
fluxOut.close();
} catch (Exception e) {
- System.out
+ System.err
.println("JaceP2P_Error in Task.jaceP2P_ReinitConv() when converting Task in Stream : "
+ e);
}
sauv.lastSave = lastSave;
}
} catch (Exception e) {
- System.out.println("probleme ds rmi");
+ System.err.println("Problem with RMI !");
}
return sauv;
}
sauvConvg.initialized = true;
} catch (Exception e) {
- System.out.println("probleme ds rmi" + e);
+ System.err.println("Problem with RMI:" + e);
}
return sauvConvg;
.println("I got a null register from the spawner");
broadcastTasks(tag);
System.out
- .println("sleeping till acknowledge saved");
+ .println("Sleeping till acknowledge saved");
count = 0;
} catch (Exception e2) {
- System.out
- .println("unable to get register from spawner :"
+ System.err
+ .println("Unable to get register from spawner :"
+ e2);
e2.printStackTrace(System.out);
}
printResp();
printDep();
} catch (Exception e) {
- System.out.println("error printing status in Task :" + e);
+ System.err.println("Error printing status in Task :" + e);
}
Thread.yield();
if (action.equals("sendVerif") && state.equals("VERIF")
state = "VERIF";
broadcastTasks(3);
} catch (Exception e) {
- System.out
- .println("le message de verification n'est pas recu: "
+ System.err
+ .println("The verification message is not received: "
+ e);
Register.Instance().viewAll();
}
broadcastTasks(3);
}
} catch (Exception e) {
- System.out
- .println("unable to decrease the number of neighbors not converged on node :"
+ System.err
+ .println("Unable to decrease the number of neighbors not converged on node :"
+ recev.getHostName()
+ " count ="
+ count
count = 0;
} catch (Exception e2) {
- System.out
- .println("unable to contact the spawner :"
+ System.err
+ .println("Unable to contact the spawner: "
+ e2);
}
}
broadcastTasks(3);
} catch (Exception e) {
- System.out
- .println("le message de verification n'est pas recu:"
+ System.err
+ .println("The verification message is not received:"
+ e);
}
} else if (jaceMyId > neighId) {
state = "VERIF";
broadcastTasks(3);
} catch (Exception e) {
- System.out
- .println("le message de verification n'est pas recu:"
+ System.err
+ .println("The verification message is not received: "
+ e);
}
}
waitForAck(1);
}
} catch (Exception e) {
- System.out.println("erreur: " + e);
+ System.err.println("Error: " + e);
}
}
} else if (pseudoPerEnd == true) {
reinitializePPEr();
broadcastTasks(3);
} catch (Exception e) {
- System.out
- .println("unable to broadcast a negative verdict :"
+ System.err
+ .println("Unable to broadcast a negative verdict :"
+ e);
}
}
broadcastTasks(3);
} catch (Exception e) {
- System.out
- .println("response not received:" + e);
+ System.err
+ .println("Response not received:" + e);
Register.Instance().viewAll();
}
}
broadcastTasks(3);
} catch (Exception e) {
- System.out.println("response not received by "
+ System.err.println("Response not received by "
+ rank + ": " + e);
Register.Instance().viewAll();
}
spawnerStub.setOver(true);
// localStub.setState("FINISHED");
} catch (Exception e) {
- System.out.println("erreur erreur" + e);
+ System.err.println("Error" + e);
}
} else if (!respSent) {
int index = recievedAllRespMinusOne();
// System.out.println("send response to"+rank);
}
} catch (Exception e) {
- System.out.println("reponse non recue" + e);
+ System.err.println("Response not received" + e);
}
}
}
postReloading = false;
} catch (Exception e) {
- System.out.println(" Exception in Global Convergence :" + e);
+ System.err.println("Exception in Global Convergence :" + e);
e.printStackTrace(System.out);
Register.Instance().viewAll();
}
.getTaskIdOfRank(taskRankDest); // ///////////////////////////pb
stub = task.getHostStub();
} catch (Exception e) {
- System.out
- .println("problem in SaveTaskThread on assignation line in save : "
+ System.err
+ .println("Problem in SaveTaskThread on assignation line in save : "
+ e);
}
// System.out.println("ite " + jaceP2P_Iteration +
sent = true;
} catch (Exception e) {
- System.out
+ System.err
.println("JaceP2P_Error in Task.jaceP2P_Save() when saving stream: "
+ e);
j++;
// 5 - if stream not sent at all, do something (WHAT ???)
if (j > saveTab.length) {
- System.out
+ System.err
.println("No more alive neighbors for storing the Backup");
// TODO : what to do if no BackupNode has answered ???
}
}
} catch (Exception e) {
- System.out
- .println("node not reachable by JaceServer.saveTask() in BroadcastTaskThread :"
+ System.err
+ .println("Node not reachable by JaceServer.saveTask() in BroadcastTaskThread :"
+ e);
}
}
}
+
