Package org.jgroups.util

Class RpcStats

java.lang.Object

org.jgroups.util.RpcStats

public class RpcStats
extends Object

Keeps track of stats for sync and async unicasts and multicasts

Since:

3.6.8

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	RpcStats.Result
protected static class	RpcStats.RTTStat
static enum	RpcStats.Type

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicInteger	async_anycasts
protected final AtomicInteger	async_multicasts
protected final AtomicInteger	async_unicasts
protected Map<Address,RpcStats.RTTStat>	rtt_stats
protected Map<Address,RpcStats.Result>	stats
protected final AtomicInteger	sync_anycasts
protected final AtomicInteger	sync_multicasts
protected final AtomicInteger	sync_unicasts

Constructor Summary

Constructors

Constructor	Description
RpcStats(boolean extended_stats)

Method Summary

Modifier and Type	Method	Description
void	add(RpcStats.Type type, Address dest, boolean sync, long time)
void	addAnycast(boolean sync, long time, Collection<Address> dests)
void	addRTTStats(Address sender, RTTHeader hdr)
protected void	addToResults(Address dest, boolean sync, long time)
int	anycasts(boolean sync)
boolean	extendedStats()
RpcStats	extendedStats(boolean f)
int	multicasts(boolean sync)
String	printRTTStatsByDest()
String	printStatsByDest()
void	reset()
void	retainAll(Collection<Address> members)
String	toString()
int	unicasts(boolean sync)
protected void	update(RpcStats.Type type, boolean sync)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

sync_unicasts

protected final AtomicInteger sync_unicasts

async_unicasts

protected final AtomicInteger async_unicasts

sync_multicasts

protected final AtomicInteger sync_multicasts

async_multicasts

protected final AtomicInteger async_multicasts

sync_anycasts

protected final AtomicInteger sync_anycasts

async_anycasts

protected final AtomicInteger async_anycasts

stats

protected volatile Map<Address,RpcStats.Result> stats

rtt_stats

protected volatile Map<Address,RpcStats.RTTStat> rtt_stats

Constructor Details

RpcStats

public RpcStats(boolean extended_stats)

Method Details

unicasts

public int unicasts(boolean sync)

multicasts

public int multicasts(boolean sync)

anycasts

public int anycasts(boolean sync)

extendedStats

public boolean extendedStats()

extendedStats

public RpcStats extendedStats(boolean f)

reset

public void reset()

add

public void add(RpcStats.Type type,
 Address dest,
 boolean sync,
 long time)

addAnycast

public void addAnycast(boolean sync,
 long time,
 Collection<Address> dests)

addRTTStats

public void addRTTStats(Address sender,
 RTTHeader hdr)

retainAll

public void retainAll(Collection<Address> members)

printStatsByDest

public String printStatsByDest()

printRTTStatsByDest

public String printRTTStatsByDest()

toString

public String toString()

Overrides:

toString in class Object

update

protected void update(RpcStats.Type type,
 boolean sync)

addToResults

protected void addToResults(Address dest,
 boolean sync,
 long time)