-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
/**
* Convert capabilities of netconfnode into internal format. Boron and Carbon are providing
* different versions
import org.slf4j.LoggerFactory;
/**
- * Wrapper class for capabilites for Boron and later releases. Uses generics because yang model was
- * changed from Boron to later version. Interface class:
+ * Wrapper class for capabilites for Boron and later releases. Uses generics because yang model was changed from Boron
+ * to later version. Interface class:
* org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.available.capabilities.AvailableCapability
*/
public class Capabilities {
if (nnode != null) {
AvailableCapabilities availableCapabilites = nnode.getAvailableCapabilities();
if (availableCapabilites != null) {
- capabilities.constructor(availableCapabilites.getAvailableCapability());
+ capabilities.constructor(availableCapabilites.getAvailableCapability());
} else {
LOG.debug("empty capabilites");
}
if (nnode != null) {
UnavailableCapabilities availableCapabilites = nnode.getUnavailableCapabilities();
if (availableCapabilites != null) {
- capabilities.constructor(availableCapabilites.getUnavailableCapability());
+ capabilities.constructor(availableCapabilites.getUnavailableCapability());
} else {
LOG.debug("empty capabilites");
}
Method methodGetCapability;
for (Object capability : pcapabilities) {
- if (capability instanceof String) { // ODL Boron specific
+ if (capability instanceof String) { // ODL Boron specific
this.capabilities.add((String) capability);
} else { // Carbon specific part .. handled via generics
try {
/**
* Get Capabilites
+ *
* @return List<String> with capabilites
*/
public List<String> getCapabilities() {
/**
* Verify if the namespace is supported
+ *
* @param qCapability from model
* @return true if namespace is supported
*/
*
* @param qCapability capability from the model
* @return true if supporting the model AND revision<br>
- * false if revision not available or both not found.
+ * false if revision not available or both not found.
*/
public boolean isSupportingNamespaceAndRevision(QName qCapability) {
/**
* Provide revision as String from QName, considering older formats.
+ *
* @param qCapability that specifies the revision
* @return String with revisiondate or null
*/
/**
* Get revision of first entry of related capability
+ *
* @param qCapability that specifies the namespace
* @return String with date or
*/
public String getRevisionForNamespace(QName qCapability) {
String namespace = qCapability.getNamespace().toString();
- for (String capability : capabilities) {
+ for (String capability : capabilities) {
if (capability.contains(namespace)) {
return QName.create(capability).getRevision().get().toString();
}
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice;
import com.google.common.util.concurrent.ListenableFuture;
import org.opendaylight.yangtools.yang.common.RpcResult;
/**
- * Interface handling netconf connection.
+ * Interface handling netconf connection.
*/
public interface NetconfAccessor {
/**
* Register netconf notification listener for related mountpoint
*
- * @param <T> specific child class of NotificationListener
- * @param listener listener to be called
+ * @param <T> specific child class of NotificationListener
+ * @param listener listener to be called
* @return handler to manager registration
*/
<T extends NotificationListener> ListenerRegistration<NotificationListener> doRegisterNotificationListener(
/**
* Register notifications stream for the connection.
+ *
* @param streamName that should be "NETCONF" as default.
* @return progress indication
*/
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
/**
- * Indicate if device is connected or not.
- * A NetconfNode (Mountpoint) is providing the status.
- * If this is Master and connected, this function is calles.
+ * Indicate if device is connected or not. A NetconfNode (Mountpoint) is providing the status. If this is Master and
+ * connected, this function is calles.
*/
public interface NetconfNodeConnectListener extends EventListener, AutoCloseable {
/**
* Called if device state changes to "connected" for a netconf master node.
+ *
* @param acessor containing <br>
- * - nNodeId name of mount point<br>
- * - netconfNode with related information<br>
- * - mountPoint of the node<br>
- * -netconfNodeDataBroker to access connected netconf device
+ * - nNodeId name of mount point<br>
+ * - netconfNode with related information<br>
+ * - mountPoint of the node<br>
+ * -netconfNodeDataBroker to access connected netconf device
*/
- public void onEnterConnected(@NonNull NetconfAccessor acessor );
+ public void onEnterConnected(@NonNull NetconfAccessor acessor);
+
/**
- * Notify of device state change to "not connected" mount point supervision for
- * master mountpoint HINT: This callback could be called multiple times also the
- * onEnterConnected state was not called.
+ * Notify of device state change to "not connected" mount point supervision for master mountpoint HINT: This
+ * callback could be called multiple times also the onEnterConnected state was not called.
*
- * @param nNodeId name of mount point
+ * @param nNodeId name of mount point
* @param optionalNetconfNode with new status or if removed not present
*/
public void onLeaveConnected(@NonNull NodeId nNodeId, @NonNull Optional<NetconfNode> optionalNetconfNode);
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
/**
- * Indicate all state changes of NetconfNode (Mountpoint). Cleans up and
- * summarizes the
+ * Indicate all state changes of NetconfNode (Mountpoint). Cleans up and summarizes the
*/
public interface NetconfNodeStateListener extends EventListener {
- /**
- * New NetconfNode has been created
- * @param nNodeId of Node
- * @param netconfNode object
- */
-
- void onCreated(NodeId nNodeId, NetconfNode netconfNode);
-
- /**
- * New NetconfNode has been created
- * @param nNodeId of node
- * @param netconfNode object after change
- */
- void onStateChange(NodeId nNodeId, NetconfNode netconfNode);
-
- /**
- * NetconfNode has been removed
- * @param nNodeId of related node
- */
- void onRemoved(NodeId nNodeId);
+ /**
+ * New NetconfNode has been created
+ *
+ * @param nNodeId of Node
+ * @param netconfNode object
+ */
+
+ void onCreated(NodeId nNodeId, NetconfNode netconfNode);
+
+ /**
+ * New NetconfNode has been created
+ *
+ * @param nNodeId of node
+ * @param netconfNode object after change
+ */
+ void onStateChange(NodeId nNodeId, NetconfNode netconfNode);
+
+ /**
+ * NetconfNode has been removed
+ *
+ * @param nNodeId of related node
+ */
+ void onRemoved(NodeId nNodeId);
}
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice;
/**
* Register for indication that Master NetconNode is entering or leaving Connected state.
+ *
* @param netconfNodeConnectListener
* @return managing object for listener
*/
- @NonNull <L extends NetconfNodeConnectListener> ListenerRegistration<L> registerNetconfNodeConnectListener(@NonNull L netconfNodeConnectListener);
+ @NonNull
+ <L extends NetconfNodeConnectListener> ListenerRegistration<L> registerNetconfNodeConnectListener(
+ @NonNull L netconfNodeConnectListener);
/**
* Register for all NetconfNode specific state changes
+ *
* @param netconfNodeStateListener
* @return managing object for listener
*/
- @NonNull <L extends NetconfNodeStateListener> ListenerRegistration<L> registerNetconfNodeStateListener(@NonNull L netconfNodeStateListener);
+ @NonNull
+ <L extends NetconfNodeStateListener> ListenerRegistration<L> registerNetconfNodeStateListener(
+ @NonNull L netconfNodeStateListener);
/**
* Register for Ves/DmaaP provided messages
+ *
* @param netconfNodeStateListener
* @return managing object for listener
*/
- @NonNull <L extends VesNotificationListener> ListenerRegistration<L> registerVesNotifications(@NonNull L netconfNodeStateListener);
+ @NonNull
+ <L extends VesNotificationListener> ListenerRegistration<L> registerVesNotifications(
+ @NonNull L netconfNodeStateListener);
}
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice;
import java.util.concurrent.atomic.AtomicBoolean;
*/
public interface TransactionUtils {
- /**
- * Deliver the data back or null. Warning
- *
- * @param <T> SubType of the DataObject to be handled
- * @param dataBroker for accessing data
- * @param dataStoreType to address datastore
- * @param iid id to access data
- * @return null or object
- */
- @Nullable
- <T extends DataObject> T readData(DataBroker dataBroker, LogicalDatastoreType dataStoreType,
- InstanceIdentifier<T> iid);
+ /**
+ * Deliver the data back or null. Warning
+ *
+ * @param <T> SubType of the DataObject to be handled
+ * @param dataBroker for accessing data
+ * @param dataStoreType to address datastore
+ * @param iid id to access data
+ * @return null or object
+ */
+ @Nullable
+ <T extends DataObject> T readData(DataBroker dataBroker, LogicalDatastoreType dataStoreType,
+ InstanceIdentifier<T> iid);
- /**
- * Deliver the data back or null
- *
- * @param <T> SubType of the DataObject to be handled
- * @param dataBroker for accessing data
- * @param dataStoreType to address datastore
- * @param iid id to access data
- * @param noErrorIndication (Output) true if data could be read and are available and is not null
- * @param statusIndicator (Output) String with status indications during the read.
- * @return null or object
- */
- @Nullable
- <T extends DataObject> T readDataOptionalWithStatus(DataBroker dataBroker, LogicalDatastoreType dataStoreType,
- InstanceIdentifier<T> iid, AtomicBoolean noErrorIndication, AtomicReference<String> statusIndicator);
+ /**
+ * Deliver the data back or null
+ *
+ * @param <T> SubType of the DataObject to be handled
+ * @param dataBroker for accessing data
+ * @param dataStoreType to address datastore
+ * @param iid id to access data
+ * @param noErrorIndication (Output) true if data could be read and are available and is not null
+ * @param statusIndicator (Output) String with status indications during the read.
+ * @return null or object
+ */
+ @Nullable
+ <T extends DataObject> T readDataOptionalWithStatus(DataBroker dataBroker, LogicalDatastoreType dataStoreType,
+ InstanceIdentifier<T> iid, AtomicBoolean noErrorIndication, AtomicReference<String> statusIndicator);
-}
\ No newline at end of file
+}
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netconfnode.state.rev191011.FaultNotification;
/**
- * Indicate if device is connected or not.
- * A NetconfNode (Mountpoint) is providing the status.
- * If this is Master and connected, this function is calles.
+ * Indicate if device is connected or not. A NetconfNode (Mountpoint) is providing the status. If this is Master and
+ * connected, this function is calles.
*/
public interface VesNotificationListener extends EventListener, AutoCloseable {
/**
* Called in case of fault notification
+ *
* @param faultNotification to handle
*/
public void onNotification(FaultNotification faultNotification);
/**
* Called in case of attributeChange notification
+ *
* @param attributeChangeNotification to handle
*/
public void onNotification(AttributeChangeNotification attributeChangeNotification);
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.impl;
import com.google.common.base.Preconditions;
AtomicBoolean noErrorIndication = new AtomicBoolean();
AtomicReference<String> statusText = new AtomicReference<>();
- @Nullable T obj = readDataOptionalWithStatus(dataBroker, dataStoreType, iid, noErrorIndication, statusText);
+ @Nullable
+ T obj = readDataOptionalWithStatus(dataBroker, dataStoreType, iid, noErrorIndication, statusText);
if (!noErrorIndication.get()) {
LOG.warn("Read transaction for identifier " + iid + " failed with status " + statusText.get());
LogicalDatastoreType dataStoreType, InstanceIdentifier<T> iid, AtomicBoolean noErrorIndication,
AtomicReference<String> statusIndicator) {
- @Nullable T data = null;
+ @Nullable
+ T data = null;
noErrorIndication.set(false);
statusIndicator.set("Preconditions");
statusIndicator.set("Create Read Transaction");
ReadTransaction readTransaction = dataBroker.newReadOnlyTransaction();
try {
- @NonNull FluentFuture<Optional<T>> od = readTransaction.read(dataStoreType, iid);
+ @NonNull
+ FluentFuture<Optional<T>> od = readTransaction.read(dataStoreType, iid);
statusIndicator.set("Read done");
if (od != null) {
statusIndicator.set("Unwrap checkFuture done");
/**
* Contains all data to access and manage netconf device
- * @param nodeId of managed netconf node
+ *
+ * @param nodeId of managed netconf node
* @param netconfNode information
* @param dataBroker to access node
* @param mountpoint of netconfNode
}
/**
- * @param nodeId with uuid of managed netconf node
+ * @param nodeId with uuid of managed netconf node
* @param dataBroker to access node
*/
public NetconfAccessorImpl(String nodeId, NetconfNode netconfNode, DataBroker dataBroker, MountPoint mountpoint,
public DataBroker getDataBroker() {
return dataBroker;
}
+
@Override
public MountPoint getMountpoint() {
return mountpoint;
}
+
@Override
public TransactionUtils getTransactionUtils() {
return transactionUtils;
}
+
@Override
public NetconfNode getNetconfNode() {
return netconfNode;
}
+
@Override
public Capabilities getCapabilites() {
return capabilities;
}
@Override
- public @NonNull <T extends NotificationListener> ListenerRegistration<NotificationListener> doRegisterNotificationListener(@NonNull T listener) {
+ public @NonNull <T extends NotificationListener> ListenerRegistration<NotificationListener> doRegisterNotificationListener(
+ @NonNull T listener) {
log.info("Begin register listener for Mountpoint {}", mountpoint.getIdentifier().toString());
- final Optional<NotificationService> optionalNotificationService = mountpoint
- .getService(NotificationService.class);
+ final Optional<NotificationService> optionalNotificationService =
+ mountpoint.getService(NotificationService.class);
final NotificationService notificationService = optionalNotificationService.get();
- final ListenerRegistration<NotificationListener> ranListenerRegistration = notificationService
- .registerNotificationListener(listener);
+ final ListenerRegistration<NotificationListener> ranListenerRegistration =
+ notificationService.registerNotificationListener(listener);
log.info("End registration listener for Mountpoint {} Listener: {} Result: {}",
mountpoint.getIdentifier().toString(), optionalNotificationService, ranListenerRegistration);
return ranListenerRegistration;
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.impl;
import java.util.Collection;
this.listenerL1 = null;
this.listenerL2 = null;
- this.initializationSuccessful= false;
+ this.initializationSuccessful = false;
this.netconfNodeConnectListenerList = new CopyOnWriteArrayList<>();
this.netconfNodeStateListenerList = new CopyOnWriteArrayList<>();
this.vesNotificationListenerList = new CopyOnWriteArrayList<>();
public void setMountPointService(MountPointService mountPointService) {
this.mountPointService = mountPointService;
}
+
public void setClusterSingletonService(ClusterSingletonServiceProvider clusterSingletonService) {
this.clusterSingletonServiceProvider = clusterSingletonService;
}
+
public void setEntityDataProvider(IEntityDataProvider iEntityDataProvider) {
this.iEntityDataProvider = iEntityDataProvider;
}
this.clusterName = akkaConfig == null ? "" : akkaConfig.getClusterConfig().getClusterSeedNodeName("abc");
// Provide status information
- ClusterConfig cc = akkaConfig==null?null:akkaConfig.getClusterConfig();
- this.iEntityDataProvider.setStatus(StatusKey.CLUSTER_SIZE,cc==null?"1":String.format("%d",cc.getClusterSize()));
+ ClusterConfig cc = akkaConfig == null ? null : akkaConfig.getClusterConfig();
+ this.iEntityDataProvider.setStatus(StatusKey.CLUSTER_SIZE,
+ cc == null ? "1" : String.format("%d", cc.getClusterSize()));
// RPC Service for specific services
this.rpcApiService.setStatusCallback(this);
LOG.info("Session Initiated end. Initialization done {}", initializationSuccessful);
}
+
/** Blueprint destroy-method method */
public void destroy() {
close();
/**
* Getter
+ *
* @return NetconfnodeStateServiceRpcApiImpl
*/
public NetconfnodeStateServiceRpcApiImpl getNetconfnodeStateServiceRpcApiImpl() {
@Override
public <L extends NetconfNodeConnectListener> @NonNull ListenerRegistration<L> registerNetconfNodeConnectListener(
final @NonNull L netconfNodeConnectListener) {
- LOG.info("Register connect listener {}",netconfNodeConnectListener.getClass().getName());
+ LOG.info("Register connect listener {}", netconfNodeConnectListener.getClass().getName());
netconfNodeConnectListenerList.add(netconfNodeConnectListener);
return new ListenerRegistration<L>() {
@Override
public void close() {
- LOG.info("Remove connect listener {}",netconfNodeConnectListener);
+ LOG.info("Remove connect listener {}", netconfNodeConnectListener);
netconfNodeConnectListenerList.remove(netconfNodeConnectListener);
}
};
@Override
public <L extends NetconfNodeStateListener> @NonNull ListenerRegistration<L> registerNetconfNodeStateListener(
@NonNull L netconfNodeStateListener) {
- LOG.info("Register state listener {}",netconfNodeStateListener.getClass().getName());
+ LOG.info("Register state listener {}", netconfNodeStateListener.getClass().getName());
netconfNodeStateListenerList.add(netconfNodeStateListener);
return new ListenerRegistration<L>() {
@Override
public void close() {
- LOG.info("Remove state listener {}",netconfNodeStateListener);
+ LOG.info("Remove state listener {}", netconfNodeStateListener);
netconfNodeStateListenerList.remove(netconfNodeStateListener);
}
};
@Override
public <L extends VesNotificationListener> @NonNull ListenerRegistration<L> registerVesNotifications(
@NonNull L vesNotificationListener) {
- LOG.info("Register Ves notification listener {}",vesNotificationListener.getClass().getName());
+ LOG.info("Register Ves notification listener {}", vesNotificationListener.getClass().getName());
vesNotificationListenerList.add(vesNotificationListener);
return new ListenerRegistration<L>() {
@Override
public void close() {
- LOG.info("Remove Ves notification listener {}",vesNotificationListener);
+ LOG.info("Remove Ves notification listener {}", vesNotificationListener);
vesNotificationListenerList.remove(vesNotificationListener);
}
};
/**
* Indication if init() of this bundle successfully done.
+ *
* @return true if init() was successful. False if not done or not successful.
*/
public boolean isInitializationSuccessful() {
*/
/**
- * For each mounted device a mountpoint is created and this listener is called.
- * Mountpoint was created or existing. Managed device is now fully connected to node/mountpoint.
+ * For each mounted device a mountpoint is created and this listener is called. Mountpoint was created or existing.
+ * Managed device is now fully connected to node/mountpoint.
+ *
* @param nNodeId id of the mountpoint
* @param netconfNode mountpoint contents
*/
LOG.info("isNetconfNodeMaster indication {} for mountpoint {}", isNetconfNodeMaster, mountPointNodeName);
if (isNetconfNodeMaster) {
- InstanceIdentifier<Node> instanceIdentifier = NETCONF_TOPO_IID.child(Node.class,
- new NodeKey(new NodeId(mountPointNodeName)));
+ InstanceIdentifier<Node> instanceIdentifier =
+ NETCONF_TOPO_IID.child(Node.class, new NodeKey(new NodeId(mountPointNodeName)));
Optional<MountPoint> optionalMountPoint = null;
int timeout = 10000;
/**
* Leave the connected status to a non connected or removed status for master mountpoint
+ *
* @param action that occurred
* @param nNodeId id of the mountpoint
* @param netconfNode mountpoint contents or not available on remove
String mountPointNodeName = nNodeId.getValue();
LOG.info("netconfNode id {}", mountPointNodeName);
- InstanceIdentifier<Node> instanceIdentifier = NETCONF_TOPO_IID.child(Node.class,
- new NodeKey(new NodeId(mountPointNodeName)));
+ InstanceIdentifier<Node> instanceIdentifier =
+ NETCONF_TOPO_IID.child(Node.class, new NodeKey(new NodeId(mountPointNodeName)));
Optional<MountPoint> optionalMountPoint = mountPointService.getMountPoint(instanceIdentifier);
if (optionalMountPoint.isPresent()) {
Optional<DataBroker> optionalNetconfNodeDatabroker = optionalMountPoint.get().getService(DataBroker.class);
final DataObjectModification<Node> root = change.getRootNode();
//if (LOG.isTraceEnabled()) {
- LOG.info /*trace*/("Handle this modificationType:{} path:{} root:{}", root.getModificationType(),
- change.getRootPath(), root);
+ LOG.info /*trace*/("Handle this modificationType:{} path:{} root:{}", root.getModificationType(),
+ change.getRootPath(), root);
//}
// Catch potential nullpointer exceptions ..
try {
ModificationType modificationTyp = root.getModificationType();
- Node node = modificationTyp == ModificationType.DELETE ? root.getDataBefore()
- : root.getDataAfter();
+ Node node = modificationTyp == ModificationType.DELETE ? root.getDataBefore() : root.getDataAfter();
NodeId nodeId = node != null ? node.getNodeId() : null;
if (nodeId != null) {
if (nodeId.equals(CONTROLLER)) {
} else {
if (modificationTyp != null) {
switch (modificationTyp) {
- case SUBTREE_MODIFIED: // Create or modify sub level node
- case WRITE: // Create or modify top level node
- // Treat an overwrite as an update
- // leaveconnected state.before = connected; state.after != connected
- // enterConnected state.after == connected
- // => Here create or update by checking root.getDataBefore() != null
-
- boolean connectedBefore, connectedAfter, created=false;
- NetconfNode nNodeAfter = getNetconfNode(root.getDataAfter());
- connectedAfter = isConnected(nNodeAfter);
- if (root.getDataBefore() != null) {
- // It is an update
- NetconfNode nodeBefore = getNetconfNode(root.getDataBefore());
- connectedBefore = isConnected(nodeBefore);
- } else {
- // It is a create
- connectedBefore = false;
- created = true;
- }
-
- LOG.info(
- "L1 NETCONF Node change with id:{} ConnectedBefore:{} connectedAfter {}:cluster status:{} akkaIsCluster:{}",
- nodeId, connectedBefore, connectedAfter,
- getClusteredConnectionStatus(nNodeAfter), isCluster);
-
- if(created) {
- netconfNodeStateListenerList.forEach(item -> {
- try {
- item.onCreated(nodeId, nNodeAfter);
- } catch (Exception e) {
- LOG.info("Exception during onCreated listener call", e);
- }
- });
- }
- if (!connectedBefore && connectedAfter) {
- enterConnectedState(nodeId, nNodeAfter);
- } else {
- LOG.debug("State change {} {}", connectedBefore, connectedAfter);
- if (connectedBefore && !connectedAfter) {
- leaveConnectedState(nodeId, Optional.of(nNodeAfter));
+ case SUBTREE_MODIFIED: // Create or modify sub level node
+ case WRITE: // Create or modify top level node
+ // Treat an overwrite as an update
+ // leaveconnected state.before = connected; state.after != connected
+ // enterConnected state.after == connected
+ // => Here create or update by checking root.getDataBefore() != null
+
+ boolean connectedBefore, connectedAfter, created = false;
+ NetconfNode nNodeAfter = getNetconfNode(root.getDataAfter());
+ connectedAfter = isConnected(nNodeAfter);
+ if (root.getDataBefore() != null) {
+ // It is an update
+ NetconfNode nodeBefore = getNetconfNode(root.getDataBefore());
+ connectedBefore = isConnected(nodeBefore);
+ } else {
+ // It is a create
+ connectedBefore = false;
+ created = true;
+ }
+
+ LOG.info(
+ "L1 NETCONF Node change with id:{} ConnectedBefore:{} connectedAfter {}:cluster status:{} akkaIsCluster:{}",
+ nodeId, connectedBefore, connectedAfter,
+ getClusteredConnectionStatus(nNodeAfter), isCluster);
+
+ if (created) {
+ netconfNodeStateListenerList.forEach(item -> {
+ try {
+ item.onCreated(nodeId, nNodeAfter);
+ } catch (Exception e) {
+ LOG.info("Exception during onCreated listener call", e);
+ }
+ });
+ }
+ if (!connectedBefore && connectedAfter) {
+ enterConnectedState(nodeId, nNodeAfter);
+ } else {
+ LOG.debug("State change {} {}", connectedBefore, connectedAfter);
+ if (connectedBefore && !connectedAfter) {
+ leaveConnectedState(nodeId, Optional.of(nNodeAfter));
+ }
+ netconfNodeStateListenerList.forEach(item -> {
+ try {
+ item.onStateChange(nodeId, nNodeAfter);
+ } catch (Exception e) {
+ LOG.info("Exception during onStateChange listener call", e);
+ }
+ });
}
+ // doProcessing(update ? Action.UPDATE : Action.CREATE, nodeId, root);
+ break;
+ case DELETE:
+ // Node removed
+ // leaveconnected state.before = connected;
+ leaveConnectedState(nodeId, Optional.empty());
netconfNodeStateListenerList.forEach(item -> {
try {
- item.onStateChange(nodeId, nNodeAfter);
+ item.onRemoved(nodeId);
} catch (Exception e) {
- LOG.info("Exception during onStateChange listener call", e);
+ LOG.info("Exception during onRemoved listener call", e);
}
});
- }
- // doProcessing(update ? Action.UPDATE : Action.CREATE, nodeId, root);
- break;
- case DELETE:
- // Node removed
- // leaveconnected state.before = connected;
- leaveConnectedState(nodeId, Optional.empty());
- netconfNodeStateListenerList.forEach(item -> {
- try {
- item.onRemoved(nodeId);
- } catch (Exception e) {
- LOG.info("Exception during onRemoved listener call", e);
- }
- });
- // doProcessing(Action.REMOVE, nodeId, root);
- break;
+ // doProcessing(Action.REMOVE, nodeId, root);
+ break;
}
}
}
// ---- subclasses for listeners
/**
- * Clustered listener function to select the right node from
- * DataObjectModification. Called at all nodes.
+ * Clustered listener function to select the right node from DataObjectModification. Called at all nodes.
*/
private class L1 implements ClusteredDataTreeChangeListener<Node> {
@Override
public void onDataTreeChanged(@NonNull Collection<DataTreeModification<Node>> changes) {
LOG.info("L1 TreeChange enter changes:{}", changes.size());
- new Thread( () -> onDataTreeChangedHandler(changes)).start();
+ new Thread(() -> onDataTreeChangedHandler(changes)).start();
LOG.info("L1 TreeChange leave");
}
}
/* --- private helpers --- */
private static @Nullable NetconfNode getNetconfNode(Node node) {
- return node != null ? node.augmentation(NetconfNode.class) : null;
+ return node != null ? node.augmentation(NetconfNode.class) : null;
}
private static boolean isConnected(NetconfNode nNode) {
LOG.debug("check if me is responsible for node");
ClusteredConnectionStatus ccs = nNode.getClusteredConnectionStatus();
@SuppressWarnings("null")
- @NonNull String masterNodeName = ccs == null || ccs.getNetconfMasterNode() == null ? "null" : ccs.getNetconfMasterNode();
+ @NonNull
+ String masterNodeName =
+ ccs == null || ccs.getNetconfMasterNode() == null ? "null" : ccs.getNetconfMasterNode();
LOG.debug("sdnMasterNode=" + masterNodeName + " and sdnMyNode=" + this.clusterName);
if (!masterNodeName.equals(this.clusterName)) {
LOG.debug("netconf change but me is not master for this node");
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.impl.conf.odlAkka;
import java.io.File;
public boolean isSingleNode() {
return !this.isCluster();
}
- public static AkkaConfig parse(String content) throws Exception {
+
+ public static AkkaConfig parse(String content) throws Exception {
Config cfg = ConfigFactory.parseString(content);
AkkaConfig c = new AkkaConfig();
- c.cluserConfig=new ClusterConfig(cfg.getConfig("odl-cluster-data").getConfig("akka").getConfig("cluster"));
+ c.cluserConfig = new ClusterConfig(cfg.getConfig("odl-cluster-data").getConfig("akka").getConfig("cluster"));
return c;
}
}
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.impl.conf.odlAkka;
import java.util.ArrayList;
private final ClusterRoleInfoCollection roles;
private ClusterNodeInfo ismeInfo;
- public static ClusterConfig defaultSingleNodeConfig()
- {
- ClusterConfig cfg=new ClusterConfig();
- cfg.ismeInfo=ClusterNodeInfo.defaultSingleNodeInfo();
+ public static ClusterConfig defaultSingleNodeConfig() {
+ ClusterConfig cfg = new ClusterConfig();
+ cfg.ismeInfo = ClusterNodeInfo.defaultSingleNodeInfo();
cfg.seedNodes.add(cfg.ismeInfo);
cfg.roles.add(ClusterRoleInfo.defaultSingleNodeRole());
return cfg;
}
- public ClusterConfig()
- {
+
+ public ClusterConfig() {
this.seedNodes = new ArrayList<>();
this.roles = new ClusterRoleInfoCollection();
}
+
public ClusterConfig(Config o) throws Exception {
{
this.seedNodes = new ArrayList<>();
public String getHostName(String defaultValue) {
if (getRoleMemberIndex() > 0 && getRoleMemberIndex() <= seedNodes.size()) {
- return this.seedNodes.get(getRoleMemberIndex()-1).getRemoteAddress();
+ return this.seedNodes.get(getRoleMemberIndex() - 1).getRemoteAddress();
} else {
- LOG.warn("Seednode not available for roleMemberIndex {}. Using default {}",getRoleMember(), defaultValue);
+ LOG.warn("Seednode not available for roleMemberIndex {}. Using default {}", getRoleMember(), defaultValue);
return defaultValue;
}
}
public String getDBClusterName(String defaultValue) {
String r = null;
if (this.seedNodes != null && this.seedNodes.size() > 0) {
- r = String.format("cluster-%s.%d", this.seedNodes.get(0).getRemoteAddress(), this.seedNodes.get(0).getPort());
+ r = String.format("cluster-%s.%d", this.seedNodes.get(0).getRemoteAddress(),
+ this.seedNodes.get(0).getPort());
}
if (r == null || r.isEmpty()) {
r = defaultValue;
}
return r;
}
+
public String getClusterSeedNodeName() {
return this.getClusterSeedNodeName("");
}
+
public String getClusterSeedNodeName(String defaultValue) {
- int idx=this.getRoleMemberIndex()-1;
- String r=null;
- if(this.seedNodes!=null && idx>=0 && this.seedNodes.size()>0 && this.seedNodes.size()>idx)
- {
- r=this.seedNodes.get(idx).getSeedNodeName();
+ int idx = this.getRoleMemberIndex() - 1;
+ String r = null;
+ if (this.seedNodes != null && idx >= 0 && this.seedNodes.size() > 0 && this.seedNodes.size() > idx) {
+ r = this.seedNodes.get(idx).getSeedNodeName();
}
if (r == null || r.isEmpty()) {
r = defaultValue;
}
return r;
}
+
public int getRoleMemberIndex() {
- ClusterRoleInfo role=this.roles.get("member");
- return role!=null?role.getIndex():0;
+ ClusterRoleInfo role = this.roles.get("member");
+ return role != null ? role.getIndex() : 0;
}
+
public ClusterRoleInfo getRoleMember() {
return this.roles.get("member");
}
return "ClusterConfig [seedNodes=" + seedNodes + ", roles=" + roles + ", ismeInfo=" + ismeInfo + "]";
}
- public int getClusterSize() {
- return this.seedNodes == null ? 0 : this.seedNodes.size();
- }
+ public int getClusterSize() {
+ return this.seedNodes == null ? 0 : this.seedNodes.size();
+ }
}
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.impl.conf.odlAkka;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
-public class ClusterNodeInfo {
+public class ClusterNodeInfo {
private final String protocol;
private final String clusterName;
private final String remoteAdr;
private final String seedNodeName;
public static ClusterNodeInfo defaultSingleNodeInfo() {
- return new ClusterNodeInfo("akka.tcp","opendaylight-cluster-data","127.0.0.1",2550);
+ return new ClusterNodeInfo("akka.tcp", "opendaylight-cluster-data", "127.0.0.1", 2550);
}
public ClusterNodeInfo(String s) throws Exception {
}
public ClusterNodeInfo(String protocol, String clustername, String remoteadr, int port) {
- this.protocol=protocol;
- this.clusterName=clustername;
- this.remoteAdr=remoteadr;
- this.port=port;
- this.seedNodeName=this.protocol+"://"+this.clusterName+"@"+this.remoteAdr+":"+this.port;
+ this.protocol = protocol;
+ this.clusterName = clustername;
+ this.remoteAdr = remoteadr;
+ this.port = port;
+ this.seedNodeName = this.protocol + "://" + this.clusterName + "@" + this.remoteAdr + ":" + this.port;
}
public String getProtocol() {
public String getRemoteAddress() {
return remoteAdr;
}
+
public String getSeedNodeName() {
return seedNodeName;
}
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.impl.conf.odlGeo;
import java.util.regex.Matcher;
final Pattern pattern = Pattern.compile(regex);
final Matcher matcher = pattern.matcher(s);
if (!matcher.find()) {
- throw new Exception("unexpected role format:"+s);
+ throw new Exception("unexpected role format:" + s);
}
this.Role = matcher.group(1);
this.Index = Integer.parseInt(matcher.group(2));
}
private ClusterRoleInfo(String role, int idx) {
- this.Role=role;
- this.Index=idx;
+ this.Role = role;
+ this.Index = idx;
}
public static ClusterRoleInfo defaultSingleNodeRole() {
- return new ClusterRoleInfo("member",1);
+ return new ClusterRoleInfo("member", 1);
}
public String getRole() {
return Role;
}
+
public int getIndex() {
return Index;
}
}
return true;
}
+
@Override
public String toString() {
return "ClusterRoleInfo [Role=" + Role + ", Index=" + Index + "]";
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.impl.conf.odlGeo;
import java.util.ArrayList;
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.impl.conf.odlGeo;
import java.io.File;
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.impl.rpc;
import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.VesNotificationListener;
PushAttributeChangeNotificationInput input) {
RpcResultBuilder<PushAttributeChangeNotificationOutput> result;
try {
- AttributeChangeNotificationBuilder attributeChangeNotificationBuilder = new AttributeChangeNotificationBuilder();
+ AttributeChangeNotificationBuilder attributeChangeNotificationBuilder =
+ new AttributeChangeNotificationBuilder();
attributeChangeNotificationBuilder.fieldsFrom(input);
- vesNotificationListenerList.forEach(item -> item.onNotification(attributeChangeNotificationBuilder.build()));
+ vesNotificationListenerList
+ .forEach(item -> item.onNotification(attributeChangeNotificationBuilder.build()));
result = RpcResultBuilder.success();
} catch (Exception e) {
result = RpcResultBuilder.failed();
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.impl.rpc;
public interface RpcApigetStateCallback {
- GetStatusOutputBuilder getStatus(GetStatusInput input);
+ GetStatusOutputBuilder getStatus(GetStatusInput input);
}
-/*******************************************************************************
+/*
* ============LICENSE_START=======================================================
* ONAP : ccsdk feature sdnr wt
* ================================================================================
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test;
import static org.junit.Assert.fail;
String failMessage = "failed: " + e.getMessage();
System.out.println(failMessage);
fail(failMessage);
- }
+ }
}
@Test
System.out.println("testing clusternode config1");
System.out.println("===========================");
cfg = AkkaConfig.load(file.getAbsolutePath());
- System.out.println("succeeded: "+cfg.hashCode());
+ System.out.println("succeeded: " + cfg.hashCode());
System.out.println(cfg.toString());
System.out.println(String.format("found %d cluster nodes", cfg.getClusterConfig().getSeedNodes().size()));
for (ClusterNodeInfo n : cfg.getClusterConfig().getSeedNodes()) {
-/*******************************************************************************
+/*
* ============LICENSE_START=======================================================
* ONAP : ccsdk feature sdnr wt
* ================================================================================
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test;
import static org.junit.Assert.*;
-/*******************************************************************************
+/*
* ============LICENSE_START======================================================= ONAP : ccsdk
* feature sdnr wt ================================================================================
* Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. All rights reserved.
* is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
* or implied. See the License for the specific language governing permissions and limitations under
* the License. ============LICENSE_END=========================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test;
import static org.mockito.Mockito.mock;
System.out.println("Test2: Register state listener");
NetconfNodeStateListener nSL = mock(NetconfNodeStateListener.class);
- ListenerRegistration<NetconfNodeStateListener> res =
- netconfStateService.registerNetconfNodeStateListener(nSL);
+ ListenerRegistration<NetconfNodeStateListener> res = netconfStateService.registerNetconfNodeStateListener(nSL);
assertNotNull("Result should be null", res);
res.getInstance();
res.close();
NetconfNodeConnectListener nCL = mock(NetconfNodeConnectListener.class);
ListenerRegistration<NetconfNodeConnectListener> res =
- netconfStateService.registerNetconfNodeConnectListener(nCL);
+ netconfStateService.registerNetconfNodeConnectListener(nCL);
assertNotNull("Result should be null", res);
res.getInstance();
res.close();
//verify that it was called one time and nodeId is the expected
ArgumentCaptor<NetconfAccessor> varArgs = ArgumentCaptor.forClass(NetconfAccessor.class);
verify(nCL).onEnterConnected(varArgs.capture());
- System.out.println("Accessor "+varArgs.getValue().getNodeId());
+ System.out.println("Accessor " + varArgs.getValue().getNodeId());
assertEquals(nodeIdString, varArgs.getValue().getNodeId().getValue());
}
ListenableFuture<RpcResult<GetStatusOutput>> statusOutput = api.getStatus(statusInput.build());
RpcResult<GetStatusOutput> res = statusOutput.get();
GetStatusOutput output = res.getResult();
- System.out.println("Output "+output);
+ System.out.println("Output " + output);
}
FaultNotification fault = faultBuilder.build();
PushFaultNotificationInputBuilder statusInput = new PushFaultNotificationInputBuilder();
statusInput.fieldsFrom(fault);
- ListenableFuture<RpcResult<PushFaultNotificationOutput>> rpcOutput = api.pushFaultNotification(statusInput.build());
+ ListenableFuture<RpcResult<PushFaultNotificationOutput>> rpcOutput =
+ api.pushFaultNotification(statusInput.build());
RpcResult<PushFaultNotificationOutput> res = rpcOutput.get();
PushFaultNotificationOutput output = res.getResult();
//verify that it was called one time
- verify(vNL,times(1)).onNotification(fault);
+ verify(vNL, times(1)).onNotification(fault);
registration.close();
- System.out.println("Output "+output);
+ System.out.println("Output " + output);
}
@Test
AttributeChangeNotification change = changeBuilder.build();
PushAttributeChangeNotificationInputBuilder statusInput = new PushAttributeChangeNotificationInputBuilder();
statusInput.fieldsFrom(change);
- ListenableFuture<RpcResult<PushAttributeChangeNotificationOutput>> rpcOutput = api.pushAttributeChangeNotification(statusInput.build());
+ ListenableFuture<RpcResult<PushAttributeChangeNotificationOutput>> rpcOutput =
+ api.pushAttributeChangeNotification(statusInput.build());
RpcResult<PushAttributeChangeNotificationOutput> res = rpcOutput.get();
PushAttributeChangeNotificationOutput output = res.getResult();
//verify that it was called one time
- verify(vNL,times(1)).onNotification(change);
+ verify(vNL, times(1)).onNotification(change);
registration.close();
- System.out.println("Output "+output);
+ System.out.println("Output " + output);
}
-/*******************************************************************************
+/*
* ============LICENSE_START========================================================================
* ONAP : ccsdk feature sdnr wt
* =================================================================================================
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
* ============LICENSE_END==========================================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test.mock;
public class ClusterSingletonServiceProviderMock implements ClusterSingletonServiceProvider {
- @Override
- public void close() throws Exception {
+ @Override
+ public void close() throws Exception {
- }
+ }
- @Override
- public ClusterSingletonServiceRegistration registerClusterSingletonService(ClusterSingletonService service) {
- return null;
- }
+ @Override
+ public ClusterSingletonServiceRegistration registerClusterSingletonService(ClusterSingletonService service) {
+ return null;
+ }
}
-/*******************************************************************************
+/*
* ============LICENSE_START=======================================================
* ONAP : ccsdk feature sdnr wt
* ================================================================================
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test.mock;
import org.eclipse.jdt.annotation.NonNull;
-/*******************************************************************************
+/*
* ============LICENSE_START=======================================================
* ONAP : ccsdk feature sdnr wt
* ================================================================================
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test.mock;
import java.util.Collection;
@Override
public <T extends DataObject, L extends DataTreeChangeListener<T>> @NonNull ListenerRegistration<L> registerDataTreeChangeListener(
@NonNull DataTreeIdentifier<T> treeId, @NonNull L pListener) {
- System.out.println("Register "+pListener.getClass().getName());
+ System.out.println("Register " + pListener.getClass().getName());
if (pListener instanceof ClusteredDataTreeChangeListener) {
System.out.println("Clustered listener");
this.listenerClustered = (ClusteredDataTreeChangeListener<Node>) pListener;
}
@Override
- public void close() {
- }
+ public void close() {}
};
}
-/*******************************************************************************
+/*
* ============LICENSE_START=======================================================
* ONAP : ccsdk feature sdnr wt sdnr-wt-devicemanager-provider
* ================================================================================
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test.mock;
@Override
public <T extends BindingService> Optional<T> getService(Class<T> service) {
- System.out.println("Requested mountpoint service: "+service.getSimpleName()+" databrokerAbsent state: "+databrokerAbsent);
+ System.out.println("Requested mountpoint service: " + service.getSimpleName() + " databrokerAbsent state: "
+ + databrokerAbsent);
Optional<? extends BindingService> res;
if (service.isInstance(dataBroker)) {
System.out.println("Delivering databroker");
- res = databrokerAbsent ? Optional.empty() : Optional.of(dataBroker);
+ res = databrokerAbsent ? Optional.empty() : Optional.of(dataBroker);
} else if (service.isInstance(rpcConsumerRegistry)) {
System.out.println("Delivering RpcConsumerRegistryMock");
res = Optional.of(rpcConsumerRegistry);
return (Optional<T>) res;
}
- public void setDatabrokerAbsent( boolean state) {
+ public void setDatabrokerAbsent(boolean state) {
this.databrokerAbsent = state;
}
-/*******************************************************************************
+/*
* ============LICENSE_START=======================================================
* ONAP : ccsdk feature sdnr wt
* ================================================================================
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test.mock;
import java.util.Optional;
-/*******************************************************************************
+/*
* ============LICENSE_START=======================================================
* ONAP : ccsdk feature sdnr wt
* ================================================================================
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test.mock;
import com.google.common.util.concurrent.ListenableFuture;
return null;
}
- @Override
+ @Override
public ListenableFuture<?> offerNotification(Notification notification, int timeout, TimeUnit unit)
throws InterruptedException {
return null;
}
@Override
- public void putNotification(Notification notification) throws InterruptedException {
- }
+ public void putNotification(Notification notification) throws InterruptedException {}
}
-/*******************************************************************************
+/*
* ============LICENSE_START=======================================================
* ONAP : ccsdk feature sdnr wt sdnr-wt-devicemanager-provider
* ================================================================================
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test.mock;
-/*******************************************************************************
+/*
* ============LICENSE_START=======================================================
* ONAP : ccsdk feature sdnr wt
* ================================================================================
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
- ******************************************************************************/
+ */
package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.test.mock;
import java.util.Set;
Code Review / ccsdk / features.git / commitdiff