* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-
package org.opendaylight.openflowplugin.applications.lldpspeaker;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
-import static org.mockito.Mockito.verifyZeroInteractions;
+import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.when;
import static org.opendaylight.mdsal.binding.api.DataObjectModification.ModificationType.DELETE;
import static org.opendaylight.mdsal.binding.api.DataObjectModification.ModificationType.SUBTREE_MODIFIED;
import static org.opendaylight.mdsal.binding.api.DataObjectModification.ModificationType.WRITE;
-import java.util.ArrayList;
-import java.util.Collections;
import java.util.List;
import org.junit.Before;
import org.junit.Test;
import org.opendaylight.yangtools.yang.binding.DataObject;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-
/**
* Tests for {@link NodeConnectorInventoryEventTranslator}.
*/
/**
* Test that checks if {@link NodeConnectorEventsObserver#nodeConnectorAdded} is called
* for each FlowCapableNodeConnector item added in
- * {@link org.opendaylight.controller.md.sal.binding.api.DataTreeModification}.
+ * {@link org.opendaylight.mdsal.binding.api.DataTreeModification}.
*/
@Test
public void testNodeConnectorCreation() {
DataTreeModification dataTreeModification = setupDataTreeChange(WRITE, NODE_CONNECTOR_INSTANCE_IDENTIFIER,
FLOW_CAPABLE_NODE_CONNECTOR);
- translator.onDataTreeChanged(Collections.singleton(dataTreeModification));
+ translator.onDataTreeChanged(List.of(dataTreeModification));
verify(eventsObserver).nodeConnectorAdded(ID, FLOW_CAPABLE_NODE_CONNECTOR);
}
public void testNodeConnectorCreationLinkDown() {
FlowCapableNodeConnector fcnc = TestUtils.createFlowCapableNodeConnector(true, false).build();
DataTreeModification dataTreeModification = setupDataTreeChange(WRITE, ID, fcnc);
- translator.onDataTreeChanged(Collections.singleton(dataTreeModification));
- verifyZeroInteractions(eventsObserver);
+ translator.onDataTreeChanged(List.of(dataTreeModification));
+ verifyNoInteractions(eventsObserver);
}
/**
public void testNodeConnectorCreationAdminDown() {
FlowCapableNodeConnector fcnc = TestUtils.createFlowCapableNodeConnector(false, true).build();
DataTreeModification dataTreeModification = setupDataTreeChange(WRITE, ID, fcnc);
- translator.onDataTreeChanged(Collections.singleton(dataTreeModification));
- verifyZeroInteractions(eventsObserver);
+ translator.onDataTreeChanged(List.of(dataTreeModification));
+ verifyNoInteractions(eventsObserver);
}
/**
* Test that checks if {@link NodeConnectorEventsObserver#nodeConnectorRemoved} is called
* for each FlowCapableNodeConnector item that have link down state removed in
- * {@link org.opendaylight.controller.md.sal.binding.api.DataTreeModification}.
+ * {@link org.opendaylight.mdsal.binding.api.DataTreeModification}.
*/
@Test
public void testNodeConnectorUpdateToLinkDown() {
FlowCapableNodeConnector fcnc = TestUtils.createFlowCapableNodeConnector(true, false).build();
DataTreeModification dataTreeModification = setupDataTreeChange(SUBTREE_MODIFIED,
NODE_CONNECTOR_INSTANCE_IDENTIFIER, fcnc);
- translator.onDataTreeChanged(Collections.singleton(dataTreeModification));
+ translator.onDataTreeChanged(List.of(dataTreeModification));
verify(eventsObserver).nodeConnectorRemoved(ID);
}
/**
* Test that checks if {@link NodeConnectorEventsObserver#nodeConnectorRemoved} is called
* for each FlowCapableNodeConnector item with administrative down state removed in
- * {@link org.opendaylight.controller.md.sal.binding.api.DataTreeModification}.
+ * {@link org.opendaylight.mdsal.binding.api.DataTreeModification}.
*/
@Test
public void testNodeConnectorUpdateToAdminDown() {
FlowCapableNodeConnector fcnc = TestUtils.createFlowCapableNodeConnector(false, true).build();
DataTreeModification dataTreeModification = setupDataTreeChange(SUBTREE_MODIFIED,
NODE_CONNECTOR_INSTANCE_IDENTIFIER, fcnc);
- translator.onDataTreeChanged(Collections.singleton(dataTreeModification));
+ translator.onDataTreeChanged(List.of(dataTreeModification));
verify(eventsObserver).nodeConnectorRemoved(ID);
}
/**
* Test that checks if {@link NodeConnectorEventsObserver#nodeConnectorAdded} is called
* for each FlowCapableNodeConnector item with administrative up and link up state added in
- * {@link org.opendaylight.controller.md.sal.binding.api.DataTreeModification}.
+ * {@link org.opendaylight.md}.
*/
@Test
public void testNodeConnectorUpdateToUp() {
DataTreeModification dataTreeModification = setupDataTreeChange(SUBTREE_MODIFIED,
NODE_CONNECTOR_INSTANCE_IDENTIFIER,
FLOW_CAPABLE_NODE_CONNECTOR);
- translator.onDataTreeChanged(Collections.singleton(dataTreeModification));
+ translator.onDataTreeChanged(List.of(dataTreeModification));
verify(eventsObserver).nodeConnectorAdded(ID, FLOW_CAPABLE_NODE_CONNECTOR);
}
/**
* Test that checks if {@link NodeConnectorEventsObserver#nodeConnectorRemoved} is called
* for each FlowCapableNodeConnector path that
- * {@link org.opendaylight.controller.md.sal.binding.api.DataTreeModification} return.
+ * {@link org.opendaylight.mdsal.binding.api.DataTreeModification} return.
*/
@Test
public void testNodeConnectorRemoval() {
DataTreeModification dataTreeModification = setupDataTreeChange(DELETE, NODE_CONNECTOR_INSTANCE_IDENTIFIER,
null);
// Invoke NodeConnectorInventoryEventTranslator and check result
- translator.onDataTreeChanged(Collections.singleton(dataTreeModification));
+ translator.onDataTreeChanged(List.of(dataTreeModification));
verify(eventsObserver).nodeConnectorRemoved(ID);
}
// Create prerequisites
InstanceIdentifier<NodeConnector> id2 = TestUtils.createNodeConnectorId("openflow:1", "openflow:1:2");
InstanceIdentifier<FlowCapableNodeConnector> iiToConnector2 = id2.augmentation(FlowCapableNodeConnector.class);
- List<DataTreeModification> modifications = new ArrayList();
- modifications.add(setupDataTreeChange(WRITE, NODE_CONNECTOR_INSTANCE_IDENTIFIER, FLOW_CAPABLE_NODE_CONNECTOR));
- modifications.add(setupDataTreeChange(DELETE, iiToConnector2, null));
// Invoke onDataTreeChanged and check that both observers notified
- translator.onDataTreeChanged(modifications);
+ translator.onDataTreeChanged(List.of(
+ setupDataTreeChange(WRITE, NODE_CONNECTOR_INSTANCE_IDENTIFIER, FLOW_CAPABLE_NODE_CONNECTOR),
+ setupDataTreeChange(DELETE, iiToConnector2, null)));
verify(eventsObserver).nodeConnectorAdded(ID, FLOW_CAPABLE_NODE_CONNECTOR);
verify(eventsObserver).nodeConnectorRemoved(id2);
verify(eventsObserver2).nodeConnectorAdded(ID, FLOW_CAPABLE_NODE_CONNECTOR);
translator.close();
}
- private <T extends DataObject> DataTreeModification setupDataTreeChange(final ModificationType type,
- final InstanceIdentifier<T> ii,
- final FlowCapableNodeConnector connector) {
+ private static <T extends DataObject> DataTreeModification setupDataTreeChange(final ModificationType type,
+ final InstanceIdentifier<T> ii, final FlowCapableNodeConnector connector) {
final DataTreeModification dataTreeModification = mock(DataTreeModification.class);
when(dataTreeModification.getRootNode()).thenReturn(mock(DataObjectModification.class));
- DataTreeIdentifier<T> identifier = DataTreeIdentifier.create(LogicalDatastoreType.OPERATIONAL, ii);
- when(dataTreeModification.getRootNode().getModificationType()).thenReturn(type);
+ DataTreeIdentifier<T> identifier = DataTreeIdentifier.of(LogicalDatastoreType.OPERATIONAL, ii);
+ when(dataTreeModification.getRootNode().modificationType()).thenReturn(type);
when(dataTreeModification.getRootPath()).thenReturn(identifier);
- when(dataTreeModification.getRootNode().getDataAfter()).thenReturn(connector);
+ when(dataTreeModification.getRootNode().dataAfter()).thenReturn(connector);
return dataTreeModification;
-
}
}