org.jgroups.protocols.pbcast

Class PBCAST

Implemented Interfaces:
Runnable

public class PBCAST
extends Protocol
implements Runnable

Implementation of probabilistic broadcast. Sends group messages via unreliable multicast. Gossips regularly to a random subset of group members to retransmit missing messages. Gossiping is used both for bringing all members to the same state (having received the same messages) and to garbage-collect messages seen by all members (gc is piggybacked in gossip messages). See DESIGN for more details.
Author:
Bela Ban

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

Method Summary

void
down(Event evt)
String
getName()
Vector
providedUpServices()
void
run()
Gossip thread.
boolean
setProperties(Properties props)
Setup the Protocol instance acording to the configuration string
void
stop()
void
up(Event evt)

Methods inherited from class org.jgroups.stack.Protocol

destroy, down, downThreadEnabled, dumpStats, enableStats, getDownProtocol, getDownQueue, getName, 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, up, upThreadEnabled

Method Details

down

public void down(Event evt)
Overrides:
down in interface Protocol

getName

public String getName()
Overrides:
getName in interface Protocol

providedUpServices

public Vector providedUpServices()
Overrides:
providedUpServices in interface Protocol

run

public void run()
Gossip thread. Sends gossips containing a message digest every gossip_interval msecs

setProperties

public boolean setProperties(Properties props)
Setup the Protocol instance acording to the configuration string
Overrides:
setProperties in interface Protocol

stop

public void stop()
Overrides:
stop in interface Protocol

up

public void up(Event evt)
Overrides:
up in interface Protocol

Copyright B) 1998-2005 Bela Ban. All Rights Reserved.