Merge branch '3.4'

Conflicts:
	build/build.xml

build/build.xml

@@ -26,18 +26,39 @@
 
     <!-- Smack Version -->
     <property name="version.major" value="3" />
-    <property name="version.minor" value="4" />
+    <property name="version.minor" value="5" />
-    <property name="version.revision" value="1" />
+    <property name="version.revision" value="0" />
     <property name="version.extra" value="SNAPSHOT" />
 
     <var name="mutable-version" value="${version.major}.${version.minor}.${version.revision}"/>
-    <var name="mutable-experimental-version" value="0.1"/>
+    <var name="mutable-experimental-version" value="0.2"/>
+
+    <available file=".git" type="dir" property="gitDir.present"/>
+
+    <!-- <target name="git.revision" description="Store git revision in ${repository.version}" if="gitDir.present"> -->
+    <if>
+        <isset property="gitDir.present"/>
+            <then>
+                <exec executable="git" outputproperty="git.revision" failifexecutionfails="false" errorproperty="">
+                    <arg value="log"/>
+                    <arg value="-n 1"/>
+                    <arg value="--pretty=format:%h"/>
+                </exec>
+            </then>
+        </if>
+        <condition property="repository.version" value="${git.revision}" else="">
+            <and>
+                <isset property="git.revision"/>
+                <length string="${git.revision}" trim="yes" length="0" when="greater"/>
+            </and>
+        </condition>
+    <!-- </target> -->
 
     <if>
         <length string="${version.extra}" when="greater" length="0"/>
         <then>
-        	<var name="mutable-version" value="${mutable-version}.${version.extra}"/>
+            <var name="mutable-version" value="${mutable-version}-${version.extra}"/>
-        	<var name="mutable-experimental-version" value="${mutable-experimental-version}.${version.extra}" />
+            <var name="mutable-experimental-version" value="${mutable-experimental-version}-${version.extra}" />
         </then>
     </if>
 
@@ -52,6 +73,14 @@
         </then>
     </if>
 
+    <if>
+        <length string="${repository.version}" when="greater" length="0"/>
+        <then>
+            <var name="mutable-version" value="${mutable-version}-${repository.version}"/>
+            <var name="mutable-experimental-version" value="${mutable-experimental-version}-${repository.version}" />
+        </then>
+    </if>
+
     <property name="version" value="${mutable-version}" />
     <property name="experimental.version" value="${mutable-experimental-version}" />
 
@@ -227,7 +256,6 @@
                 <attribute name="Bundle-Version" value="${version}" />
             </manifest>
         </jar>
-    	
         <property name="smackx.jar.name" value="${jar.dest.dir}/smackx-${version}.jar" />
         <jar destfile="${smackx.jar.name}"
             basedir="${compile.dir}"
@@ -376,8 +404,7 @@
             <doctitle><![CDATA[<font face="arial,helvetica">Smack ${version}</font>]]></doctitle>
             <header><![CDATA[<b>Smack</b>]]></header>
             <bottom><![CDATA[<i>Copyright &copy; 2003-2007 Jive Software. </i>]]></bottom>
-            <link href="http://java.sun.com/j2se/1.3/docs/api/" />
+            <link href="http://docs.oracle.com/javase/7/docs/api/" />
-            <link href="http://java.sun.com/j2ee/sdk_1.2.1/techdocs/api/" />
         </javadoc>
     </target>
 
@@ -515,13 +542,7 @@
 
     <!-- release -->
     <!-- ======================================================================================= -->
-    <target name="release" description="Builds a release" if="release.exists" depends="release-exists">
+    <target name="release" description="Builds a release" depends="jar,javadoc">
-        <antcall target="jar">
-            <param name="no.test" value="true" />
-        </antcall>
-        <antcall target="javadoc">
-            <param name="no.test" value="true" />
-        </antcall>
         <ant antfile="${basedir}/build/release.xml" />
     </target>
 
@@ -545,13 +566,6 @@
         </pmd>
     </target>
 
-    <!-- release-exists -->
-    <!-- ======================================================================================= -->
-    <target name="release-exists" >
-        <available file="${basedir}/build/release.xml" property="release.exists"/>
-    </target>
-
-
     <!-- clean -->
     <!-- ======================================================================================= -->
     <target name="clean" description="Deletes all generated content.">
@@ -568,3 +582,7 @@
     </target>
 
 </project>
+
+<!-- Local Variables: -->
+<!-- indent-tabs-mode: nil -->
+<!-- End: -->

build/eclipse/classpath

@@ -33,5 +33,6 @@
 	<classpathentry kind="lib" path="build/junit-4.10.jar"/>
 	<classpathentry kind="lib" path="build/merge/jzlib.jar"/>
 	<classpathentry kind="lib" path="build/merge/org.xbill.dns_2.1.4.jar"/>
+	<classpathentry kind="lib" path="build/resources"/>
 	<classpathentry kind="output" path="target/classes"/>
 </classpath>

build/eclipse/project

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <projectDescription>
-	<name>smack-3.4.x</name>
+	<name>Smack</name>
 	<comment></comment>
 	<projects>
 	</projects>

build/resources/releasedocs/changelog.html

@@ -141,6 +141,14 @@ hr {
 
 	<div id="pageBody">
 
+<h2>3.4.1 -- <span style="font-weight: normal;">Feb 9, 2014</span></h2>
+
+<h2>Bug</h2>
+<ul>
+<li>[<a href='http://issues.igniterealtime.org/browse/SMACK-540'>SMACK-540</a>] -         Memory leak in MultiUserChat
+</li>
+</ul>
+
 <h2>3.4.0 -- <span style="font-weight: normal;">Feb 2, 2014</span></h2>
 
 <h2>Bug Fixes</h2>

experimental/source/org/jivesoftware/smackx/carbons/CarbonManager.java

@@ -16,6 +16,7 @@
 
 package org.jivesoftware.smackx.carbons;
 
+import java.lang.ref.WeakReference;
 import java.util.Collections;
 import java.util.Map;
 import java.util.WeakHashMap;
@@ -51,18 +52,18 @@ public class CarbonManager {
     static {
         Connection.addConnectionCreationListener(new ConnectionCreationListener() {
             public void connectionCreated(Connection connection) {
-                new CarbonManager(connection);
+                getInstanceFor(connection);
             }
         });
     }
     
-    private Connection connection;
+    private WeakReference<Connection> weakRefConnection;
     private volatile boolean enabled_state = false;
 
     private CarbonManager(Connection connection) {
         ServiceDiscoveryManager sdm = ServiceDiscoveryManager.getInstanceFor(connection);
         sdm.addFeature(Carbon.NAMESPACE);
-        this.connection = connection;
+        weakRefConnection = new WeakReference<Connection>(connection);
         instances.put(connection, this);
     }
 
@@ -73,7 +74,7 @@ public class CarbonManager {
      *
      * @return a CarbonManager instance
      */
-    public static CarbonManager getInstanceFor(Connection connection) {
+    public static synchronized CarbonManager getInstanceFor(Connection connection) {
         CarbonManager carbonManager = instances.get(connection);
 
         if (carbonManager == null) {
@@ -99,6 +100,7 @@ public class CarbonManager {
      * @return true if supported
      */
     public boolean isSupportedByServer() {
+        Connection connection = weakRefConnection.get();
         try {
             DiscoverInfo result = ServiceDiscoveryManager
                 .getInstanceFor(connection).discoverInfo(connection.getServiceName());
@@ -118,6 +120,7 @@ public class CarbonManager {
      * @param new_state whether carbons should be enabled or disabled
      */
     public void sendCarbonsEnabled(final boolean new_state) {
+        final Connection connection = weakRefConnection.get();
         IQ setIQ = carbonsEnabledIQ(new_state);
 
         connection.addPacketListener(new PacketListener() {
@@ -148,6 +151,7 @@ public class CarbonManager {
         if (enabled_state == new_state)
             return true;
 
+        Connection connection = weakRefConnection.get();
         IQ setIQ = carbonsEnabledIQ(new_state);
 
         PacketCollector collector =

source/org/jivesoftware/smack/keepalive/KeepAliveManager.java

@@ -16,12 +16,12 @@
 
 package org.jivesoftware.smack.keepalive;
 
+import java.lang.ref.WeakReference;
 import java.util.Collections;
-import java.util.Date;
-import java.util.HashMap;
 import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
+import java.util.WeakHashMap;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.ScheduledThreadPoolExecutor;
@@ -52,7 +52,7 @@ import org.jivesoftware.smack.ping.packet.Ping;
  * @author Florian Schmaus
  */
 public class KeepAliveManager {
-    private static Map<Connection, KeepAliveManager> instances = new HashMap<Connection, KeepAliveManager>();
+    private static Map<Connection, KeepAliveManager> instances = Collections.synchronizedMap(new WeakHashMap<Connection, KeepAliveManager>());
     private static volatile ScheduledExecutorService periodicPingExecutorService;
     
     static {
@@ -65,7 +65,7 @@ public class KeepAliveManager {
         }
     }
 
-    private Connection connection;
+    private WeakReference<Connection> weakRefConnection;
     private long pingInterval = SmackConfiguration.getKeepAliveInterval();
     private Set<PingFailedListener> pingFailedListeners = Collections.synchronizedSet(new HashSet<PingFailedListener>());
     private volatile ScheduledFuture<?> periodicPingTask;
@@ -120,40 +120,21 @@ public class KeepAliveManager {
     }
     
     private KeepAliveManager(Connection connection) {
-        this.connection = connection;
+        weakRefConnection = new WeakReference<Connection>(connection);
-        init();
-        handleConnect();
-    }
 
-    /*
-     * Call after every connection to add the packet listener.
-     */
-    private void handleConnect() {
-        // Listen for all incoming packets and reset the scheduled ping whenever
-        // one arrives.
-        connection.addPacketListener(new PacketListener() {
-
-            @Override
-            public void processPacket(Packet packet) {
-                // reschedule the ping based on this last server contact
-                lastSuccessfulContact = System.currentTimeMillis();
-                schedulePingServerTask();
-            }
-        }, null);
-    }
-
-    private void init() {
         connection.addConnectionListener(new ConnectionListener() {
 
             @Override
             public void connectionClosed() {
                 stopPingServerTask();
+                Connection connection = weakRefConnection.get();
                 handleDisconnect(connection);
             }
 
             @Override
             public void connectionClosedOnError(Exception arg0) {
                 stopPingServerTask();
+                Connection connection = weakRefConnection.get();
                 handleDisconnect(connection);
             }
 
@@ -174,6 +155,25 @@ public class KeepAliveManager {
 
         instances.put(connection, this);
         schedulePingServerTask();
+        handleConnect();
+    }
+
+    /*
+     * Call after every connection to add the packet listener.
+     */
+    private void handleConnect() {
+        Connection connection = weakRefConnection.get();
+        // Listen for all incoming packets and reset the scheduled ping whenever
+        // one arrives.
+        connection.addPacketListener(new PacketListener() {
+
+            @Override
+            public void processPacket(Packet packet) {
+                // reschedule the ping based on this last server contact
+                lastSuccessfulContact = System.currentTimeMillis();
+                schedulePingServerTask();
+            }
+        }, null);
     }
 
     /**
@@ -276,6 +276,7 @@ public class KeepAliveManager {
                 public void run() {
                     Ping ping = new Ping();
                     PacketFilter responseFilter = new PacketIDFilter(ping.getPacketID());
+                    Connection connection = weakRefConnection.get();
                     final PacketCollector response = pingFailedListeners.isEmpty() ? null : connection.createPacketCollector(responseFilter);
                     connection.sendPacket(ping);
         

source/org/jivesoftware/smackx/MessageEventManager.java

@@ -20,7 +20,6 @@
 
 package org.jivesoftware.smackx;
 
-import java.lang.reflect.InvocationTargetException;
 import java.lang.reflect.Method;
 import java.util.ArrayList;
 import java.util.Iterator;

source/org/jivesoftware/smackx/muc/MultiUserChat.java

@@ -27,6 +27,7 @@ import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Collections;
 import java.util.Iterator;
+import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
 import java.util.WeakHashMap;
@@ -116,12 +117,16 @@ public class MultiUserChat {
                 // Chat protocol. This information will be used when another client tries to
                 // discover whether this client supports MUC or not.
                 ServiceDiscoveryManager.getInstanceFor(connection).addFeature(discoNamespace);
+
                 // Set the NodeInformationProvider that will provide information about the
                 // joined rooms whenever a disco request is received
+                final WeakReference<Connection> weakRefConnection = new WeakReference<Connection>(connection);
                 ServiceDiscoveryManager.getInstanceFor(connection).setNodeInformationProvider(
                     discoNode,
                     new NodeInformationProvider() {
                         public List<DiscoverItems.Item> getNodeItems() {
+                            Connection connection = weakRefConnection.get();
+                            if (connection == null) return new LinkedList<DiscoverItems.Item>();
                             List<DiscoverItems.Item> answer = new ArrayList<DiscoverItems.Item>();
                             Iterator<String> rooms=MultiUserChat.getJoinedRooms(connection);
                             while (rooms.hasNext()) {

source/org/jivesoftware/smackx/ping/PingManager.java

@@ -16,6 +16,7 @@
 
 package org.jivesoftware.smackx.ping;
 
+import java.lang.ref.WeakReference;
 import java.util.Collections;
 import java.util.Map;
 import java.util.WeakHashMap;
@@ -65,7 +66,7 @@ public class PingManager {
         });
     }
 
-    private Connection connection;
+    private WeakReference<Connection> weakRefConnection;
 
     /**
      * Retrieves a {@link PingManager} for the specified {@link Connection}, creating one if it doesn't already
@@ -84,8 +85,8 @@ public class PingManager {
         return pingManager;
     }
 
-    private PingManager(Connection con) {
+    private PingManager(Connection connection) {
-        this.connection = con;
+        weakRefConnection = new WeakReference<Connection>(connection);
         ServiceDiscoveryManager sdm = ServiceDiscoveryManager.getInstanceFor(connection);
         
         // The ServiceDiscoveryManager was not pre-initialized
@@ -101,6 +102,7 @@ public class PingManager {
              * Sends a Pong for every Ping
              */
             public void processPacket(Packet packet) {
+                Connection connection = weakRefConnection.get();
                 IQ pong = IQ.createResultIQ((Ping) packet);
                 connection.sendPacket(pong);
             }
@@ -121,7 +123,7 @@ public class PingManager {
      */
     public boolean ping(String jid, long pingTimeout) {
         Ping ping = new Ping(jid);
-        
+        Connection connection = weakRefConnection.get();
         try {
             SyncPacketSend.getReply(connection, ping);
         }
@@ -151,6 +153,7 @@ public class PingManager {
      * @throws XMPPException An XMPP related error occurred during the request 
      */
     public boolean isPingSupported(String jid) throws XMPPException {
+        Connection connection = weakRefConnection.get();
         DiscoverInfo result = ServiceDiscoveryManager.getInstanceFor(connection).discoverInfo(jid);
         return result.containsFeature(Ping.NAMESPACE);
     }
@@ -165,6 +168,7 @@ public class PingManager {
      * @return true if a reply was received from the server, false otherwise.
      */
     public boolean pingMyServer() {
+        Connection connection = weakRefConnection.get();
         return ping(connection.getServiceName());
     }
 }

source/org/jivesoftware/smackx/receipts/DeliveryReceiptManager.java

@@ -16,6 +16,7 @@
 
 package org.jivesoftware.smackx.receipts;
 
+import java.lang.ref.WeakReference;
 import java.util.Collections;
 import java.util.HashSet;
 import java.util.Map;
@@ -52,7 +53,7 @@ public class DeliveryReceiptManager implements PacketListener {
         });
     }
 
-    private Connection connection;
+    private WeakReference<Connection> weakRefConnection;
     private boolean auto_receipts_enabled = false;
     private Set<ReceiptReceivedListener> receiptReceivedListeners = Collections
             .synchronizedSet(new HashSet<ReceiptReceivedListener>());
@@ -60,7 +61,7 @@ public class DeliveryReceiptManager implements PacketListener {
     private DeliveryReceiptManager(Connection connection) {
         ServiceDiscoveryManager sdm = ServiceDiscoveryManager.getInstanceFor(connection);
         sdm.addFeature(DeliveryReceipt.NAMESPACE);
-        this.connection = connection;
+        weakRefConnection = new WeakReference<Connection>(connection);
         instances.put(connection, this);
 
         // register listener for delivery receipts and requests
@@ -91,6 +92,7 @@ public class DeliveryReceiptManager implements PacketListener {
      * @return true if supported
      */
     public boolean isSupported(String jid) {
+        Connection connection = weakRefConnection.get();
         try {
             DiscoverInfo result =
                 ServiceDiscoveryManager.getInstanceFor(connection).discoverInfo(jid);
@@ -119,6 +121,7 @@ public class DeliveryReceiptManager implements PacketListener {
             DeliveryReceiptRequest drr = (DeliveryReceiptRequest)packet.getExtension(
                     DeliveryReceiptRequest.ELEMENT, DeliveryReceipt.NAMESPACE);
             if (drr != null) {
+                Connection connection = weakRefConnection.get();
                 Message ack = new Message(packet.getFrom(), Message.Type.normal);
                 ack.addExtension(new DeliveryReceipt(packet.getPacketID()));
                 connection.sendPacket(ack);