CVS update: JGroups/src/org/jgroups/blocks RequestCorrelator.java

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

  Modified:    src/org/jgroups/blocks RequestCorrelator.java
  Log:
  use of Util.createConcurrentMap() instead of new ConcurrentHashMap()
  
  Revision  Changes    Path
  1.67      +8 -5      JGroups/src/org/jgroups/blocks/RequestCorrelator.java
  
  Index: RequestCorrelator.java
  ===================================================================
  RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/blocks/RequestCorrelator.java,v
  retrieving revision 1.66
  retrieving revision 1.67
  diff -u -r1.66 -r1.67
  --- RequestCorrelator.java	15 Jun 2010 06:44:39 -0000	1.66
  +++ RequestCorrelator.java	17 Sep 2010 12:02:12 -0000	1.67
  @@ -1,4 +1,4 @@
  -// $Id: RequestCorrelator.java,v 1.66 2010/06/15 06:44:39 belaban Exp $
  +// $Id: RequestCorrelator.java,v 1.67 2010/09/17 12:02:12 belaban Exp $
   
   package org.jgroups.blocks;
   
  @@ -11,9 +11,10 @@
   import org.jgroups.util.Buffer;
   import org.jgroups.util.Util;
   
  -import java.io.*;
  +import java.io.DataInputStream;
  +import java.io.DataOutputStream;
  +import java.io.IOException;
   import java.util.*;
  -import java.util.concurrent.ConcurrentHashMap;
   import java.util.concurrent.ConcurrentMap;
   
   
  @@ -39,8 +40,10 @@
       /** The protocol layer to use to pass up/down messages. Can be either a Protocol or a Transport */
       protected Object transport=null;
   
  -    /** The table of pending requests (keys=Long (request IDs), values=<tt>RequestEntry</tt>) */
  -    protected final ConcurrentMap<Long,RspCollector> requests=new ConcurrentHashMap<Long,RspCollector>();
  +    /**
  +     * The table of pending requests (keys=Long (request IDs), values=<tt>RequestEntry</tt>)
  +     */
  +    protected final ConcurrentMap<Long, RspCollector> requests=Util.createConcurrentMap();
   
   
       /** The handler for the incoming requests. It is called from inside the dispatcher thread */
  
  
  

------------------------------------------------------------------------------
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