CVS update: JGroups/src/org/jgroups/util CreditMap.java

  User: belaban 
  Date: 10/09/10 10:53:32

  Modified:    src/org/jgroups/util CreditMap.java
  Log:
  ns
  
  Revision  Changes    Path
  1.10      +19 -1     JGroups/src/org/jgroups/util/CreditMap.java
  
  Index: CreditMap.java
  ===================================================================
  RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/util/CreditMap.java,v
  retrieving revision 1.9
  retrieving revision 1.10
  diff -u -r1.9 -r1.10
  --- CreditMap.java	9 Sep 2010 11:34:45 -0000	1.9
  +++ CreditMap.java	10 Sep 2010 10:53:32 -0000	1.10
  @@ -12,7 +12,7 @@
   /**
    * Maintains credits for senders, when credits fall below 0, a sender blocks until new credits have been received.
    * @author Bela Ban
  - * @version $Id: CreditMap.java,v 1.9 2010/09/09 11:34:45 belaban Exp $
  + * @version $Id: CreditMap.java,v 1.10 2010/09/10 10:53:32 belaban Exp $
    */
   public class CreditMap {
       protected final long              max_credits;
  @@ -116,6 +116,24 @@
               lock.unlock();
           }
       }
  +
  +
  +    public List<Tuple<Address,Long>> getMembersWithCreditsLessThan(long min_credits) {
  +        List<Tuple<Address,Long>> retval=new LinkedList<Tuple<Address,Long>>();
  +
  +        lock.lock();
  +        try {
  +            flushAccumulatedCredits();
  +            for(Map.Entry<Address,Long> entry: credits.entrySet()) {
  +                if(entry.getValue().longValue() <= min_credits )
  +                    retval.add(new Tuple<Address,Long>(entry.getKey(), entry.getValue()));
  +            }
  +            return retval;
  +        }
  +        finally {
  +            lock.unlock();
  +        }
  +    }
       
   
       /**
  
  
  

------------------------------------------------------------------------------
Automate Storage Tiering Simply
Optimize IT performance and efficiency through flexible, powerful, 
automated storage tiering capabilities. View this brief to learn how
you can reduce costs and improve performance. 
http://p.sf.net/sfu/dell-sfdev2dev