org.jgroups.protocols
Class FLOWCONTROL

java.lang.Object
  org.jgroups.stack.Protocol
      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