*/
package org.opendaylight.mdsal.dom.spi.shard;
+import static java.util.Objects.requireNonNull;
+
import com.google.common.annotations.Beta;
-import com.google.common.base.Preconditions;
import com.google.common.base.Stopwatch;
import com.google.common.base.Verify;
import com.google.common.collect.ImmutableList;
Aggregated(final Collection<DataTreeCandidate> changes,
final Map<DOMDataTreeIdentifier, NormalizedNode<?, ?>> subtrees,
final Collection<DOMDataTreeListeningException> failures) {
- this.changes = Preconditions.checkNotNull(changes);
- this.subtrees = Preconditions.checkNotNull(subtrees);
- this.failures = Preconditions.checkNotNull(failures);
+ this.changes = requireNonNull(changes);
+ this.subtrees = requireNonNull(subtrees);
+ this.failures = requireNonNull(failures);
}
}
Changes(final Collection<DataTreeCandidate> changes,
final Map<DOMDataTreeIdentifier, NormalizedNode<?, ?>> subtrees) {
- this.changes = Preconditions.checkNotNull(changes);
- this.subtrees = Preconditions.checkNotNull(subtrees);
+ this.changes = requireNonNull(changes);
+ this.subtrees = requireNonNull(subtrees);
}
}
final Collection<DOMDataTreeListeningException> causes;
Failure(final Collection<DOMDataTreeListeningException> causes) {
- this.causes = Preconditions.checkNotNull(causes);
+ this.causes = requireNonNull(causes);
}
}
private Map<DOMDataTreeIdentifier, NormalizedNode<?, ?>> subtrees = ImmutableMap.of();
@Override
- protected void append(final State state) {
+ protected synchronized void append(final State state) {
if (state instanceof Changes) {
final Changes changesState = (Changes) state;
this.changes.addAll(changesState.changes);
Operational(final Collection<AbstractStateAggregator.StateBuilder<State>> builders,
final DOMDataTreeListener listener) {
super(builders);
- this.listener = Preconditions.checkNotNull(listener);
+ this.listener = requireNonNull(listener);
}
@Override
protected void notifyListener(final Iterator<State> iterator) {
if (failed) {
- iterator.forEachRemaining(state -> LOG.debug("Listener {} failed, ignoring state {}", state));
+ iterator.forEachRemaining(state -> LOG.debug("Listener {} failed, ignoring state {}", listener, state));
return;
}