Class TrafficAccounting

java.lang.Object

ecmwf.ecpds.master.TrafficAccounting

public final class TrafficAccounting
extends Object

Absolute, per-source minute counters. Replaying a snapshot merges maxima, never adds the same bytes twice. Transfer threads only touch in-memory counters.

Field Summary

Fields

Modifier and Type	Field	Description
static final List<String>	TYPES

Constructor Summary

Constructors

Constructor	Description
TrafficAccounting()

Method Summary

Modifier and Type	Method	Description
void	add(String type, long count)
static Map<String,String>	changedBuckets(Map<String,String> current, Map<String,String> previous)
Map<String,String>	checkpoint(Path path)
String	getSourceId()
void	load(Path path)
void	merge(Map<String,String> snapshot)
Map<String,String>	snapshot()
Map<String,Long>	totals()

Methods inherited from class Object

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

Field Details

TYPES

public static final List<String> TYPES

Constructor Details

TrafficAccounting

public TrafficAccounting()

Method Details

getSourceId

public String getSourceId()

add

public void add(String type,
 long count)

snapshot

public Map<String,String> snapshot()

merge

public void merge(Map<String,String> snapshot)

totals

public Map<String,Long> totals()

load

public void load(Path path)
          throws IOException

Throws:

IOException

checkpoint

public Map<String,String> checkpoint(Path path)
                              throws IOException

Throws:

IOException

changedBuckets

public static Map<String,String> changedBuckets(Map<String,String> current,
 Map<String,String> previous)