Correction of some bugs and performance enhancement.

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

diff --git a/src/jaceP2P/MsgQueue.java b/src/jaceP2P/MsgQueue.java
index b726451..005089f 100644 (file)
--- a/src/jaceP2P/MsgQueue.java
+++ b/src/jaceP2P/MsgQueue.java
@@ -1,16 +1,17 @@
 package jaceP2P;
 
-import java.util.Vector;
+import java.util.ArrayList;
+
 
 public class MsgQueue {
 
        public static MsgQueue Instance;
        // attributes
-       private Vector<Message> liste;
+       private ArrayList<Message> liste;
 
        // constructors
        public MsgQueue() {
-               liste = new Vector<Message>();
+               liste = new ArrayList<Message>();
        }
 
        public synchronized static MsgQueue Instance() {
@@ -97,7 +98,7 @@ public class MsgQueue {
                // si existe deja 1 Message de meme tag ET meme envoyeur, on l'ecrase
                if (is != -1) {
                        // liste.remove(is);
-                       liste.setElementAt(msg, is);
+                       liste.set( is, msg ) ;
                }
 
                // si existe pas de Message de meme tag ET meme envoyeur, on l'ajoute
@@ -132,7 +133,7 @@ public class MsgQueue {
                                // tmp.getSender().getHostIP());
                                return tmp;
                        } else {
-                               // System.out.println("existe po :(((( "+tag+"---"+id);
+                               // System.out.println("existe pas :(((( "+tag+"---"+id);
                                return null;
                        }
                }
@@ -159,7 +160,7 @@ public class MsgQueue {
                }
        }
 
-       // les reception bloqunte
+       // les reception bloquantes
        /*
         * public synchronized Message getBl(int id) { int is = -1; //
         * System.out.println("Taille de la file: "+liste.size()); if