X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/jaceP2P.git/blobdiff_plain/90623bf0db7a268b9c697e64f1bb6be61545af31..e4891bd929a468ef21bd083d2c9bb3fb06254c91:/src/jaceP2P/Task.java

diff --git a/src/jaceP2P/Task.java b/src/jaceP2P/Task.java
index 7dfd861..ffad2e9 100644
--- a/src/jaceP2P/Task.java
+++ b/src/jaceP2P/Task.java
@@ -3,6 +3,7 @@ package jaceP2P;
 import java.io.ByteArrayOutputStream;
 import java.io.ObjectInputStream;
 import java.io.ObjectOutputStream;
+import java.rmi.ConnectException;
 import java.rmi.RemoteException;
 import java.util.Vector;
 
@@ -56,7 +57,8 @@ public class Task implements Runnable, Cloneable, java.io.Serializable {
 	public Task sauv;
 	public BackupConvg sauvConvg = new BackupConvg();
 	public boolean postReloading = false;
-	public Vector<?> reduceAll;
+	@SuppressWarnings("unchecked")
+	public Vector reduceAll;
 
 	int cpt = 0;
 	int count = 0;
@@ -319,9 +321,13 @@ public class Task implements Runnable, Cloneable, java.io.Serializable {
 						// else
 						// SenderSocket.Instance().getBuffer().add(msg);
 					}
+					
+				} catch( ConnectException ce ) {
+					recev.getHostStub().suicide2( "Not responding!" ) ;
 				} catch (Exception e) {
 					System.err.println("Unable to send data message to " + dest
 							+ ": " + e);
+//					recev.getHostStub().suicide2( "Not responding!" ) ;
 				}
 				// System.out.println("TASK : g mis un msg qui doit etre envoye");
 				// envoie toujours asynchrone !!!!!!!! : le Message partira
@@ -397,7 +403,7 @@ public class Task implements Runnable, Cloneable, java.io.Serializable {
 				// + ")   taille MsgQueue : " + MsgQueue.Instance().getSize());
 			} catch (Exception e) {
 				if (Register.Instance().getListeOfTasks() == null)
-					System.err.println("Tasks list is null: " + e);
+					System.err.println("Tasks list is null2: " + e);
 			}
 			try {
 				JaceSession.Instance().getTaskThread().sleep(10);