Package org.jgroups.util

Class RpcStats

java.lang.Object

org.jgroups.util.RpcStats

public class RpcStats
extends java.lang.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 class	RpcStats.Type

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.atomic.LongAdder	async_anycasts
protected java.util.concurrent.atomic.LongAdder	async_multicasts
protected java.util.concurrent.atomic.LongAdder	async_unicasts
protected static java.util.function.Function<Address,RpcStats.RTTStat>	FUNC
protected static java.util.function.Function<Address,RpcStats.Result>	FUNC2
protected java.util.Map<Address,RpcStats.RTTStat>	rtt_stats
protected java.util.Map<Address,RpcStats.Result>	stats
protected java.util.concurrent.atomic.LongAdder	sync_anycasts
protected java.util.concurrent.atomic.LongAdder	sync_multicasts
protected java.util.concurrent.atomic.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, java.util.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)
java.lang.String	printRTTStatsByDest()
java.lang.String	printStatsByDest()
void	reset()
void	retainAll(java.util.Collection<Address> members)
java.lang.String	toString()
long	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 Detail

sync_unicasts

protected final java.util.concurrent.atomic.LongAdder sync_unicasts

async_unicasts

protected final java.util.concurrent.atomic.LongAdder async_unicasts

sync_multicasts

protected final java.util.concurrent.atomic.LongAdder sync_multicasts

async_multicasts

protected final java.util.concurrent.atomic.LongAdder async_multicasts

sync_anycasts

protected final java.util.concurrent.atomic.LongAdder sync_anycasts

async_anycasts

protected final java.util.concurrent.atomic.LongAdder async_anycasts

stats

protected volatile java.util.Map<Address,RpcStats.Result> stats

rtt_stats

protected volatile java.util.Map<Address,RpcStats.RTTStat> rtt_stats

FUNC

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

FUNC2

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

Constructor Detail

RpcStats

public RpcStats(boolean extended_stats)

Method Detail

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,
                       java.util.Collection<Address> dests)

addRTTStats

public void addRTTStats(Address sender,
                        RTTHeader hdr)

retainAll

public void retainAll(java.util.Collection<Address> members)

printStatsByDest

public java.lang.String printStatsByDest()

printRTTStatsByDest

public java.lang.String printRTTStatsByDest()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

update

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

addToResults

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