CVS update: JGroups/src/org/jgroups/protocols FC.java

"Bela Ban" <[email protected]>
Newsgroups gmane.comp.java.javagroups.cvs
Message-ID <[email protected]>
  User: belaban 
  Date: 10/08/27 08:41:05

  Modified:    src/org/jgroups/protocols FC.java
  Log:
  ns
  
  Revision  Changes    Path
  1.123     +4 -5      JGroups/src/org/jgroups/protocols/FC.java
  
  Index: FC.java
  ===================================================================
  RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/protocols/FC.java,v
  retrieving revision 1.122
  retrieving revision 1.123
  diff -u -r1.122 -r1.123
  --- FC.java	24 Aug 2010 14:21:40 -0000	1.122
  +++ FC.java	27 Aug 2010 08:41:05 -0000	1.123
  @@ -34,7 +34,7 @@
    * <li>Receivers don't send the full credits (max_credits), but rather tha actual number of bytes received
    * <ol/>
    * @author Bela Ban
  - * @version $Id: FC.java,v 1.122 2010/08/24 14:21:40 belaban Exp $
  + * @version $Id: FC.java,v 1.123 2010/08/27 08:41:05 belaban Exp $
    */
   @MBean(description="Simple flow control protocol based on a credit system")
   public class FC extends Protocol {
  @@ -127,12 +127,11 @@
       private final Map<Address,Long> sent=new HashMap<Address, Long>(11);
   
       /**
  -     * Map<Address,Long>: keys are members, values are credits left (in bytes).
  +     * Keeps track of credits / member at the receiver's side. Keys are members, values are credits left (in bytes).
        * For each receive, the credits for the sender are decremented by the size of the received message.
  -     * When the credits are 0, we refill and send a CREDIT message to the sender. Sender blocks until CREDIT
  -     * is received after reaching <tt>min_credits</tt> credits.
  +     * When the credits fall below the threshold, we refill and send a REPLENISH message to the sender.
  +     * The sender blocks until REPLENISH message is received.
        */
  -    @GuardedBy("received_lock")
       private final ConcurrentMap<Address,Credit> received=new ConcurrentHashMap<Address,Credit>(11);
   
   
  
  
  

------------------------------------------------------------------------------
Sell apps to millions through the Intel(R) Atom(Tm) Developer Program
Be part of this innovative community and reach millions of netbook users 
worldwide. Take advantage of special opportunities to increase revenue and 
speed time-to-market. Join now, and jumpstart your future.
http://p.sf.net/sfu/intel-atom-d2d
lmpx.com only provides a reader for public news (NNTP) servers. It is not affiliated with the servers or forums shown here and is not responsible for the content of articles, which is written by their respective authors.