final AbstractImmutableDataContainerNode<YangInstanceIdentifier.PathArgument> parentContainerNode =
(AbstractImmutableDataContainerNode) parentData;
- final Map<YangInstanceIdentifier, NormalizedNodeUpdate> updates =
+ final Map<YangInstanceIdentifier, NormalizedNodeUpdate> childUpdates =
parentContainerNode.getChildren().entrySet().stream()
.flatMap(entry -> registry.normalizedUpdates(modification.getId(), entry).stream())
.collect(Collectors.toMap(NormalizedNodeUpdate::getId, update -> update));
- return new ModificationDiff(updates);
+ return new ModificationDiff(childUpdates);
}
}
return EMPTY_DIFF;
protected ShutdownHandler create() {
final ShutdownHandler handler = new ShutdownHandlerImpl();
// Make sure ShutdownHandler is run on JVM shutdown
- Runtime.getRuntime().addShutdownHook(new Thread((handler::performShutdown)));
+ Runtime.getRuntime().addShutdownHook(new Thread(handler::performShutdown));
return handler;
}
}
import org.opendaylight.controller.config.yang.netconf.mdsal.notification.CapabilityChangeNotificationProducer;
import org.opendaylight.controller.config.yang.netconf.mdsal.notification.NotificationToMdsalWriter;
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.controller.md.sal.binding.api.DataTreeChangeListener;
import org.opendaylight.controller.sal.binding.api.BindingAwareBroker;
import org.opendaylight.netconf.mapping.api.NetconfOperationServiceFactory;
import org.opendaylight.netconf.mapping.api.NetconfOperationServiceFactoryListener;
writer.start();
LOG.trace("Initializing CapabilityChangeNotificationProducer");
- final DataTreeChangeListener<Capabilities> publisher =
- new CapabilityChangeNotificationProducer(notificationCollector, dataBroker);
+ new CapabilityChangeNotificationProducer(notificationCollector, dataBroker);
LOG.trace("Providing NetconfNotificationOperationServiceFactory");
NetconfNotificationOperationServiceFactory netconfNotificationOperationServiceFactory =
URL keystoreURL = getClass().getResource(cfg.restconfKeystore.get());
sslContextFactory.setKeyStorePath(keystoreURL.getPath());
sslContextFactory.setKeyStorePassword(cfg.keystorePassword.get());
- sslContextFactory.setKeyManagerPassword((cfg.keystoreManagerPassword.get()));
+ sslContextFactory.setKeyManagerPassword(cfg.keystoreManagerPassword.get());
URL truststoreURL = getClass().getResource(cfg.restconfTruststore.get());
sslContextFactory.setTrustStorePath(truststoreURL.getPath());
- sslContextFactory.setTrustStorePassword((cfg.truststorePassword.get()));
+ sslContextFactory.setTrustStorePassword(cfg.truststorePassword.get());
// TODO HONEYCOMB-167 make this more configurable
sslContextFactory.setExcludeCipherSuites("SSL_RSA_WITH_DES_CBC_SHA", "SSL_DHE_RSA_WITH_DES_CBC_SHA",
"SSL_DHE_DSS_WITH_DES_CBC_SHA", "SSL_RSA_EXPORT_WITH_RC4_40_MD5",
package io.fd.honeycomb.test.tools;
-import org.opendaylight.controller.md.sal.binding.impl.BindingToNormalizedNodeCodec;
-import org.opendaylight.yangtools.yang.binding.DataObject;
-import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
-import org.opendaylight.yangtools.yang.model.api.SchemaContext;
+import static com.google.common.base.Preconditions.checkState;
-import javax.annotation.Nonnull;
import java.util.LinkedList;
import java.util.List;
import java.util.stream.Collectors;
-
-import static com.google.common.base.Preconditions.checkState;
+import javax.annotation.Nonnull;
+import org.opendaylight.controller.md.sal.binding.impl.BindingToNormalizedNodeCodec;
+import org.opendaylight.yangtools.yang.binding.DataObject;
+import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
+import org.opendaylight.yangtools.yang.model.api.SchemaContext;
/**
* Process yang data from json to BA Objects
private YangDataProcessor pickProcessor(final YangInstanceIdentifier yangInstanceIdentifier) {
final List<YangDataProcessor> eligibleProcessors = processors.stream()
- .filter(processors -> processors.canProcess(yangInstanceIdentifier))
+ .filter(processor -> processor.canProcess(yangInstanceIdentifier))
.collect(Collectors.toList());
// canProcess should be exclusive for node type, but just in case
if (writersData.isEmpty()) {
// If there are no data for current writer, but it is a SubtreeWriter and there are updates to
// its children, still invoke it with its root data
- if (writer instanceof SubtreeWriter<?> && isAffected(((SubtreeWriter<?>) writer), updates)) {
+ if (writer instanceof SubtreeWriter<?> && isAffected((SubtreeWriter<?>) writer, updates)) {
// Provide parent data for SubtreeWriter for further processing
writersData = getParentDataObjectUpdate(ctx, updates, writer);
} else {