Changeset 130 for trunk/LogicMail/src/org/logicprobe/LogicMail/util/Connection.java

Timestamp:

07/14/07 11:22:05 PM (18 months ago)

Author:

octorian

Message:

Implemented connection tracking and cleanup (#28)

Files:

• trunk/LogicMail/src/org/logicprobe/LogicMail/util/Connection.java (modified) (4 diffs)

trunk/LogicMail/src/org/logicprobe/LogicMail/util/Connection.java

@@ -63 +63 @@
 import java.io.InputStream;
 import java.io.OutputStream;
+import java.util.Vector;
 import javax.microedition.io.SocketConnection;
 import javax.microedition.io.StreamConnection;
@@ -114 +115 @@
      */
     private int count;
-    
-    /**
-     * Holds the position of the next byte to be read from the buffer.
-     */
-    //private int position;
+
+    /**
+     * Holds a list of open connections
+     */
+    private static Vector openConnections = new Vector();
     
     public Connection(String serverName, int serverPort, boolean useSSL, boolean deviceSide) {
@@ -136 +137 @@
     public void open() throws IOException {
         close();
+
+        synchronized(openConnections) {
+            if(!openConnections.contains(this)) {
+                openConnections.addElement(this);
+            }
+        }
+        
         String protocolStr = (useSSL ? "ssl" : "socket");
         // This param, which allows bypassing the MDS proxy, should probably
@@ -166 +174 @@
             socket.close();
             socket = null;
+        }
+
+        synchronized(openConnections) {
+            if(openConnections.contains(this)) {
+                openConnections.removeElement(this);
+            }
+        }
+    }
+    
+    /**
+     * Determine whether open connections exist
+     *
+     * @return True if there are open connections
+     */
+    public static boolean hasOpenConnections() {
+        boolean result;
+        synchronized(openConnections) {
+            result = !openConnections.isEmpty();
+        }
+        return result;
+    }
+    
+    /**
+     * Close all open connections
+     */
+    public static void closeAllConnections() {
+        synchronized(openConnections) {
+            int size = openConnections.size();
+            for(int i = 0; i < size; i++) {
+                try {
+                    ((Connection)openConnections.elementAt(i)).close();
+                } catch (IOException e) { }
+            }
+            openConnections.removeAllElements();
         }
     }