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

  User: belaban 
  Date: 10/09/07 15:39:33

  Modified:    src/org/jgroups/util CreditMap.java
  Log:
  added replenishAll()
  
  Revision  Changes    Path
  1.6       +17 -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.5
  retrieving revision 1.6
  diff -u -r1.5 -r1.6
  --- CreditMap.java	7 Sep 2010 15:30:09 -0000	1.5
  +++ CreditMap.java	7 Sep 2010 15:39:33 -0000	1.6
  @@ -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.5 2010/09/07 15:30:09 belaban Exp $
  + * @version $Id: CreditMap.java,v 1.6 2010/09/07 15:39:33 belaban Exp $
    */
   public class CreditMap {
       protected final long              max_credits;
  @@ -152,6 +152,22 @@
           }
       }
   
  +
  +    public void replenishAll() {
  +        lock.lock();
  +        try {
  +            flushAccumulatedCredits();
  +            for(Map.Entry<Address,Long> entry: credits.entrySet())
  +                entry.setValue(max_credits);
  +            min_credits=computeLowestCredit();
  +            credits_available.signalAll();
  +        }
  +        finally {
  +            lock.unlock();
  +        }
  +    }
  +
  +
       public void clear() {
           lock.lock();
           try {
  
  
  

------------------------------------------------------------------------------
This SF.net Dev2Dev email is sponsored by:

Show off your parallel programming skills.
Enter the Intel(R) Threading Challenge 2010.
http://p.sf.net/sfu/intel-thread-sfd