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

Author:

Bela Ban

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 LongAdder	async_anycasts
protected final LongAdder	async_multicasts
protected final LongAdder	async_unicasts
protected static final Function<Address, RpcStats.RTTStat>	FUNC
protected static final Function<Address, RpcStats.Result>	FUNC2
protected Map<Address, RpcStats.RTTStat>	rtt_stats
protected Map<Address, RpcStats.Result>	stats
protected final LongAdder	sync_anycasts
protected final LongAdder	sync_multicasts
protected final LongAdder	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)
long	anycasts(boolean sync)
boolean	extendedStats()
RpcStats	extendedStats(boolean f)
long	multicasts(boolean sync)
String	printRTTStatsByDest()
String	printStatsByDest()
void	reset()
void	retainAll(Collection<Address> members)
String	toString()
long	unicasts(boolean sync)
protected void	update(RpcStats.Type type, boolean sync)

Methods inherited from class Object

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

Field Details

sync_unicasts

protected final LongAdder sync_unicasts

async_unicasts

protected final LongAdder async_unicasts

sync_multicasts

protected final LongAdder sync_multicasts

async_multicasts

protected final LongAdder async_multicasts

sync_anycasts

protected final LongAdder sync_anycasts

async_anycasts

protected final LongAdder async_anycasts

stats

protected volatile Map<Address, RpcStats.Result> stats

rtt_stats

protected volatile Map<Address, RpcStats.RTTStat> rtt_stats

FUNC

protected static final Function<Address, RpcStats.RTTStat> FUNC

FUNC2

protected static final Function<Address, RpcStats.Result> FUNC2

Constructor Details

RpcStats

public RpcStats(boolean extended_stats)

Method Details

unicasts

public long unicasts(boolean sync)

multicasts

public long multicasts(boolean sync)

anycasts

public long 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)