incubator-sling-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jus...@apache.org
Subject svn commit: r1591638 - /sling/trunk/bundles/extensions/models/impl/src/main/java/org/apache/sling/models/impl/ModelAdapterFactory.java
Date Thu, 01 May 2014 12:48:32 GMT
Author: justin
Date: Thu May  1 12:48:32 2014
New Revision: 1591638

URL: http://svn.apache.org/r1591638
Log:
SLING-3536 - on each interval for callback disposal, continue to poll until all queue is exhausted.

Modified:
    sling/trunk/bundles/extensions/models/impl/src/main/java/org/apache/sling/models/impl/ModelAdapterFactory.java

Modified: sling/trunk/bundles/extensions/models/impl/src/main/java/org/apache/sling/models/impl/ModelAdapterFactory.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/models/impl/src/main/java/org/apache/sling/models/impl/ModelAdapterFactory.java?rev=1591638&r1=1591637&r2=1591638&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/models/impl/src/main/java/org/apache/sling/models/impl/ModelAdapterFactory.java
(original)
+++ sling/trunk/bundles/extensions/models/impl/src/main/java/org/apache/sling/models/impl/ModelAdapterFactory.java
Thu May  1 12:48:32 2014
@@ -133,10 +133,11 @@ public class ModelAdapterFactory impleme
     @Override
     public void run() {
         java.lang.ref.Reference<? extends Object> ref = queue.poll();
-        if (ref != null) {
-            log.debug("calling disposal for " + ref.toString());
+        while (ref != null) {
+            log.debug("calling disposal for {}.", ref.toString());
             DisposalCallbackRegistryImpl registry = disposalCallbacks.remove(ref);
             registry.onDisposed();
+            ref = queue.poll();
         }
     }
 



Mime
View raw message