[jboss-cvs] JBossCache/src/org/jboss/cache ...

Brian Stansberry brian.stansberry at jboss.com
Thu Mar 22 16:09:46 EDT 2007


  User: bstansberry
  Date: 07/03/22 16:09:46

  Modified:    src/org/jboss/cache  Tag: Branch_JBossCache_1_4_0
                        ReplicationQueue.java
  Log:
  [JBCACHE-1012] Don't issue a replication call if there's nothing in the queue
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.10.2.1  +10 -7     JBossCache/src/org/jboss/cache/ReplicationQueue.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: ReplicationQueue.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/ReplicationQueue.java,v
  retrieving revision 1.10
  retrieving revision 1.10.2.1
  diff -u -b -r1.10 -r1.10.2.1
  --- ReplicationQueue.java	26 May 2006 12:58:57 -0000	1.10
  +++ ReplicationQueue.java	22 Mar 2007 20:09:46 -0000	1.10.2.1
  @@ -22,7 +22,7 @@
    * Periodically (or when certain size is exceeded) takes elements and replicates them.
    *
    * @author <a href="mailto:bela at jboss.org">Bela Ban</a> May 24, 2003
  - * @version $Revision: 1.10 $
  + * @version $Revision: 1.10.2.1 $
    */
   public class ReplicationQueue {
   
  @@ -144,6 +144,8 @@
            elements.clear();
         }
   
  +      if (l.size() > 0)
  +      {
         try {
            // send to all live nodes in the cluster
            cache.callRemoteMethods(null, MethodDeclarations.replicateAllMethod, new Object[]{l}, false, true, 5000);
  @@ -152,6 +154,7 @@
            log.error("failed replicating " + l.size() + " elements in replication queue", t);
         }
      }
  +   }
   
      class MyTask extends TimerTask {
         public void run() {
  
  
  



More information about the jboss-cvs-commits mailing list