org.opendaylight.mdsal.dom.spi.shard

Class AbstractStateAggregator<S extends AbstractStateAggregator.State>

java.lang.Object

org.opendaylight.mdsal.dom.spi.shard.AbstractStateAggregator<S>

Type Parameters:

S - State type

Direct Known Subclasses:

DOMDataTreeListenerAggregator

@Beta
public abstract class AbstractStateAggregator<S extends AbstractStateAggregator.State>
extends Object

Aggregator which combines state reported by potentially multiple threads into a single state report. State is received concurrently to reports and reporter threads are hijacked when there is state to be reported and no thread is reporting it.

Author:

Robert Varga

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractStateAggregator.Behavior<B extends AbstractStateAggregator.Behavior<B,S>,S extends AbstractStateAggregator.State>
protected static class	AbstractStateAggregator.Failed<S extends AbstractStateAggregator.State>
protected static class	AbstractStateAggregator.Operational<S extends AbstractStateAggregator.State>
protected static class	AbstractStateAggregator.Started<S extends AbstractStateAggregator.State>
static class	AbstractStateAggregator.State Marker interface for state as both reported up and down.
protected static class	AbstractStateAggregator.StateBuilder<S extends AbstractStateAggregator.State> State aggregator, which receives state chunks and creates an aggregated state object via the build method.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractStateAggregator(int sizeHint)

Method Summary

Modifier and Type	Method and Description
protected void	addBuilder(AbstractStateAggregator.StateBuilder<S> builder)
protected void	receiveState(AbstractStateAggregator.StateBuilder<S> builder, S state)
protected AbstractStateAggregator.Started<S>	start(Function<Collection<AbstractStateAggregator.StateBuilder<S>>,AbstractStateAggregator.Started<S>> function)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractStateAggregator

protected AbstractStateAggregator(int sizeHint)

Method Detail

addBuilder

protected final void addBuilder(AbstractStateAggregator.StateBuilder<S> builder)

start

protected final AbstractStateAggregator.Started<S> start(Function<Collection<AbstractStateAggregator.StateBuilder<S>>,AbstractStateAggregator.Started<S>> function)

receiveState

protected final void receiveState(AbstractStateAggregator.StateBuilder<S> builder,
                                  S state)