org.jgroups.protocols
Class FLOWCONTROL

java.lang.Object
  extended by org.jgroups.stack.Protocol
      extended by org.jgroups.protocols.FLOWCONTROL

public class FLOWCONTROL
extends Protocol

Title: Flow control layer Description: This layer limits the number of sent messages without a receive of an own message to MAXSENTMSGS, just put this layer above GMS and you will get a more Copyright: Copyright (c) 2000 Company: Computer Network Laboratory

Version:
1.0
Author:
Gianluca Collot

Field Summary
 
Fields inherited from class org.jgroups.stack.Protocol
down_handler, down_prot, down_queue, down_thread, down_thread_prio, log, observer, props, stack, stats, trace, up_handler, up_prot, up_queue, up_thread, up_thread_prio, warn
 
Constructor Summary
FLOWCONTROL()
           
 
Method Summary
 void down(Event evt)
          Checs if it can send the message, else puts the message in the queue.
 java.lang.String getName()
           
 void up(Event evt)
          Checs if up messages are from myaddr and in the case sends down queued messages or decremnts sentMsgs if there are no queued messages
 
Methods inherited from class org.jgroups.stack.Protocol
destroy, downThreadEnabled, dumpStats, enableStats, getDownProtocol, getDownQueue, getProperties, getUpProtocol, getUpQueue, handleSpecialDownEvent, init, isTrace, isWarn, passDown, passUp, printStats, providedDownServices, providedUpServices, receiveDownEvent, receiveUpEvent, requiredDownServices, requiredUpServices, resetStats, setDownProtocol, setObserver, setProperties, setPropertiesInternal, setProtocolStack, setTrace, setUpProtocol, setWarn, start, startDownHandler, startUpHandler, statsEnabled, stop, stopInternal, upThreadEnabled
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

FLOWCONTROL

public FLOWCONTROL()
Method Detail

getName

public java.lang.String getName()
Specified by:
getName in class Protocol

up

public void up(Event evt)
Checs if up messages are from myaddr and in the case sends down queued messages or decremnts sentMsgs if there are no queued messages

Overrides:
up in class Protocol

down

public void down(Event evt)
Checs if it can send the message, else puts the message in the queue.

Overrides:
down in class Protocol


Copyright ? 1998-2005 Bela Ban. All Rights Reserved.