CVS update: JGroups/src/org/jgroups/stack NakReceiverWindow.java

"Bela Ban" <[email protected]> Fri, 17 Sep 2010 11:58:18 +0000
Newsgroups gmane.comp.java.javagroups.cvs
Message-ID <[email protected]>
  User: belaban 
  Date: 10/09/17 11:58:18

  Modified:    src/org/jgroups/stack NakReceiverWindow.java
  Log:
  use of Util.createConcurrentMap() instead of new ConcurrentHashMap()
  
  Revision  Changes    Path
  1.80      +6 -4      JGroups/src/org/jgroups/stack/NakReceiverWindow.java
  
  Index: NakReceiverWindow.java
  ===================================================================
  RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/stack/NakReceiverWindow.java,v
  retrieving revision 1.79
  retrieving revision 1.80
  diff -u -r1.79 -r1.80
  --- NakReceiverWindow.java	27 Aug 2010 09:25:44 -0000	1.79
  +++ NakReceiverWindow.java	17 Sep 2010 11:58:18 -0000	1.80
  @@ -9,11 +9,11 @@
   import org.jgroups.logging.Log;
   import org.jgroups.logging.LogFactory;
   import org.jgroups.util.TimeScheduler;
  +import org.jgroups.util.Util;
   
   import java.util.LinkedList;
   import java.util.List;
   import java.util.Map;
  -import java.util.concurrent.ConcurrentHashMap;
   import java.util.concurrent.ConcurrentMap;
   import java.util.concurrent.atomic.AtomicBoolean;
   import java.util.concurrent.locks.ReadWriteLock;
  @@ -48,7 +48,7 @@
    * 
    * @author Bela Ban May 27 1999, May 2004, Jan 2007
    * @author John Georgiadis May 8 2001
  - * @version $Id: NakReceiverWindow.java,v 1.79 2010/08/27 09:25:44 belaban Exp $
  + * @version $Id: NakReceiverWindow.java,v 1.80 2010/09/17 11:58:18 belaban Exp $
    */
   public class NakReceiverWindow {
   
  @@ -77,8 +77,10 @@
       private long highest_received=0;
   
   
  -    /** ConcurrentMap<Long,Message>. Maintains messages keyed by (sorted) sequence numbers */
  -    private final ConcurrentMap<Long,Message> xmit_table=new ConcurrentHashMap<Long,Message>();
  +    /**
  +     * ConcurrentMap<Long,Message>. Maintains messages keyed by (sorted) sequence numbers
  +     */
  +    private final ConcurrentMap<Long, Message> xmit_table=Util.createConcurrentMap();
   
       /**
        * Messages that have been received in order are sent up the stack (= delivered to the application). Delivered
  
  
  

------------------------------------------------------------------------------
Start uncovering the many advantages of virtual appliances
and start using them to simplify application deployment and
accelerate your shift to cloud computing.
http://p.sf.net/sfu/novell-sfdev2dev