</dependency>
<dependency>
<groupId>org.powermock</groupId>
- <artifactId>powermock-api-mockito</artifactId>
- <version>1.6.4</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.javassist</groupId>
- <artifactId>javassist</artifactId>
- <version>3.21.0-GA</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-core</artifactId>
- <version>1.10.19</version>
+ <artifactId>powermock-api-mockito2</artifactId>
+ <version>2.0.0</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.powermock</groupId>
<artifactId>powermock-module-junit4</artifactId>
- <version>1.6.4</version>
+ <version>2.0.0</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.powermock</groupId>
<artifactId>powermock-api-support</artifactId>
- <version>1.6.4</version>
+ <version>2.0.0</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.powermock</groupId>
<artifactId>powermock-reflect</artifactId>
- <version>1.6.4</version>
+ <version>2.0.0</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.powermock</groupId>
<artifactId>powermock-core</artifactId>
- <version>1.6.4</version>
+ <version>2.0.0</version>
<scope>test</scope>
</dependency>
<dependency>
import static org.opendaylight.ovsdb.southbound.SouthboundUtil.schemaMismatchLog;
+import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
import com.google.common.net.InetAddresses;
}
}
- private void updateBridge(ReadWriteTransaction transaction,
+ @VisibleForTesting
+ void updateBridge(ReadWriteTransaction transaction,
Bridge bridge, InstanceIdentifier<Node> connectionIId) {
// Update the connection node to let it know it manages this bridge
Node connectionNode = buildConnectionNode(bridge);
deleteEntries(transaction, bridgeOtherConfigsToRemove(bridgeIid,bridge));
}
- private static <T extends DataObject> void deleteEntries(ReadWriteTransaction transaction,
+ @VisibleForTesting
+ <T extends DataObject> void deleteEntries(ReadWriteTransaction transaction,
List<InstanceIdentifier<T>> entryIids) {
- for (InstanceIdentifier<T> entryIid: entryIids) {
+ for (InstanceIdentifier<T> entryIid : entryIids) {
transaction.delete(LogicalDatastoreType.OPERATIONAL, entryIid);
}
}
*/
package org.opendaylight.ovsdb.southbound.transactions.md;
+import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Optional;
import java.util.HashMap;
import java.util.List;
public class OvsdbControllerUpdateCommand extends AbstractTransactionCommand {
private static final Logger LOG = LoggerFactory.getLogger(OvsdbControllerUpdateCommand.class);
- private Map<UUID, Controller> updatedControllerRows;
- private Map<UUID, Bridge> updatedBridgeRows;
+ private final Map<UUID, Controller> updatedControllerRows;
+ private final Map<UUID, Bridge> updatedBridgeRows;
public OvsdbControllerUpdateCommand(OvsdbConnectionInstance key,
TableUpdates updates, DatabaseSchema dbSchema) {
*
* @param transaction the {@link ReadWriteTransaction}
* @param newUpdatedControllerRows updated {@link Controller} rows
-
*/
- private void updateController(ReadWriteTransaction transaction,
+ @VisibleForTesting
+ void updateController(ReadWriteTransaction transaction,
Map<UUID, Controller> newUpdatedControllerRows) {
Map<InstanceIdentifier<Node>, Node> bridgeNodes = getBridgeNodes(transaction);
* @param bridgeName the name of the bridge
* @return the {@link InstanceIdentifier}
*/
- private InstanceIdentifier<ControllerEntry> getControllerEntryIid(
+ @VisibleForTesting
+ InstanceIdentifier<ControllerEntry> getControllerEntryIid(
ControllerEntry controllerEntry, String bridgeName) {
OvsdbConnectionInstance client = getOvsdbConnectionInstance();
import static org.opendaylight.ovsdb.southbound.SouthboundUtil.schemaMismatchLog;
+import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Optional;
import java.util.ArrayList;
import java.util.Collection;
}
}
- private void updateTerminationPoints(ReadWriteTransaction transaction, Node node) {
+ @VisibleForTesting
+ void updateTerminationPoints(ReadWriteTransaction transaction, Node node) {
for (Entry<UUID, Port> portUpdate : portUpdatedRows.entrySet()) {
String portName = null;
portName = portUpdate.getValue().getNameColumn().getData();
}
- private void buildTerminationPoint(ReadWriteTransaction transaction,
+ @VisibleForTesting
+ void buildTerminationPoint(ReadWriteTransaction transaction,
InstanceIdentifier<TerminationPoint> tpPath,
OvsdbTerminationPointAugmentationBuilder tpAugmentationBuilder,
Node node, Entry<UUID, Port> portUpdate) {
return Optional.absent();
}
- private void updateInterfaces(Interface interfaceUpdate,
+ @VisibleForTesting
+ void updateInterfaces(Interface interfaceUpdate,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
Column<GenericTableSchema, String> typeColumn = interfaceUpdate.getTypeColumn();
updateInterface(interfaceUpdate, type,ovsdbTerminationPointBuilder);
}
- private void updatePort(final ReadWriteTransaction transaction, final Node node,
+ @VisibleForTesting
+ void updatePort(final ReadWriteTransaction transaction, final Node node,
final InstanceIdentifier<TerminationPoint> tpPath, final Entry<UUID, Port> port,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
updatePortOtherConfig(port.getValue(), ovsdbTerminationPointBuilder);
}
- private void updateInterface(final Interface interf,
+ @VisibleForTesting
+ void updateInterface(final Interface interf,
final String type,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
updateInterfacePolicing(interf, ovsdbTerminationPointBuilder);
}
- private void updateVlan(final Port port,
+ @VisibleForTesting
+ void updateVlan(final Port port,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
Collection<Long> vlanId = port.getTagColumn().getData();
}
}
- private void updateVlanTrunks(final Port port,
+ @VisibleForTesting
+ void updateVlanTrunks(final Port port,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
Set<Long> portTrunks = port.getTrunksColumn().getData();
ovsdbTerminationPointBuilder.setTrunks(modelTrunks);
}
- private void updateVlanMode(final Port port,
+ @VisibleForTesting
+ void updateVlanMode(final Port port,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
Collection<String> vlanMode = port.getVlanModeColumn().getData();
}
}
- @SuppressWarnings("unchecked")
private void updateQos(final ReadWriteTransaction transaction, final Node node,
InstanceIdentifier<TerminationPoint> tpPath, final Entry<UUID, Port> port,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
}
}
- private void updateOfPort(final Interface interf,
+ @VisibleForTesting
+ void updateOfPort(final Interface interf,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
Set<Long> ofPorts = interf.getOpenFlowPortColumn().getData();
}
}
- private void updateOfPortRequest(final Interface interf,
+ @VisibleForTesting
+ void updateOfPortRequest(final Interface interf,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
Set<Long> ofPortRequests = null;
}
}
- private void updateInterfaceExternalIds(final Interface interf,
+ @VisibleForTesting
+ void updateInterfaceExternalIds(final Interface interf,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
Map<String, String> interfaceExternalIds =
}
}
- private void updatePortExternalIds(final Port port,
+ @VisibleForTesting
+ void updatePortExternalIds(final Port port,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
Map<String, String> portExternalIds = port.getExternalIdsColumn().getData();
}
}
- private void updateOptions(final Interface interf,
+ @VisibleForTesting
+ void updateOptions(final Interface interf,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
Map<String, String> optionsMap = interf.getOptionsColumn().getData();
}
}
- private void updatePortOtherConfig(final Port port,
+ @VisibleForTesting
+ void updatePortOtherConfig(final Port port,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
Map<String, String> portOtherConfigMap = port.getOtherConfigColumn().getData();
}
}
- private void updateInterfaceOtherConfig(final Interface interf,
+ @VisibleForTesting
+ void updateInterfaceOtherConfig(final Interface interf,
final OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder) {
Map<String, String> interfaceOtherConfigMap = interf.getOtherConfigColumn().getData();
}
@SuppressWarnings("unchecked")
- private InstanceIdentifier<TerminationPoint> getInstanceIdentifier(InstanceIdentifier<Node> bridgeIid,Port port) {
+ @VisibleForTesting
+ InstanceIdentifier<TerminationPoint> getInstanceIdentifier(InstanceIdentifier<Node> bridgeIid,Port port) {
if (port.getExternalIdsColumn() != null
&& port.getExternalIdsColumn().getData() != null
&& port.getExternalIdsColumn().getData().containsKey(SouthboundConstants.IID_EXTERNAL_ID_KEY)) {
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.anyString;
-import static org.mockito.Matchers.eq;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyString;
+import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
package org.opendaylight.ovsdb.southbound;
import static org.junit.Assert.assertEquals;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.anyInt;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyInt;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
package org.opendaylight.ovsdb.southbound;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.eq;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
package org.opendaylight.ovsdb.southbound.ovsdb.transact;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.eq;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.times;
verify(externalId).getExternalIdKey();
verify(otherConfig).getOtherConfigKey();
verify(ovs, times(2)).getExternalIdsColumn();
- verify(transaction, times(2)).add(any(Operation.class));
+ verify(transaction, times(2)).add(eq(null));
}
static Operations setOpField() throws Exception {
package org.opendaylight.ovsdb.southbound.ovsdb.transact;
import static org.junit.Assert.assertEquals;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.anyString;
-import static org.mockito.Matchers.eq;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyString;
+import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
package org.opendaylight.ovsdb.southbound.reconciliation.configuration;
import static org.junit.Assert.assertTrue;
-import static org.mockito.Matchers.any;
+import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.spy;
package org.opendaylight.ovsdb.southbound.transactions.md;
import static org.junit.Assert.assertEquals;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.anyString;
-import static org.mockito.Matchers.eq;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyString;
+import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
package org.opendaylight.ovsdb.southbound.transactions.md;
import static org.junit.Assert.assertEquals;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.anyString;
-import static org.mockito.Matchers.eq;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyString;
+import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.times;
MemberModifier.suppress(MemberMatcher.method(OvsdbBridgeUpdateCommand.class, "updateBridge",
ReadWriteTransaction.class, Bridge.class, InstanceIdentifier.class));
ovsdbBridgeUpdateCommand.execute(transaction);
- PowerMockito.verifyPrivate(ovsdbBridgeUpdateCommand).invoke("updateBridge", any(ReadWriteTransaction.class),
+ verify(ovsdbBridgeUpdateCommand).updateBridge(any(ReadWriteTransaction.class),
any(Bridge.class), any(InstanceIdentifier.class));
}
Bridge bridge = mock(Bridge.class);
InstanceIdentifier<Node> connectionIId = mock(InstanceIdentifier.class);
Whitebox.invokeMethod(ovsdbBridgeUpdateCommand, "updateBridge", transaction, bridge, connectionIId);
- PowerMockito.verifyPrivate(ovsdbBridgeUpdateCommand, times(3)).invoke("deleteEntries",
- any(ReadWriteTransaction.class), any(Bridge.class));
+ verify(ovsdbBridgeUpdateCommand, times(3)).deleteEntries(any(ReadWriteTransaction.class), eq(null));
}
@SuppressWarnings("unchecked")
List<InstanceIdentifier<DataObject>> entryIids = new ArrayList<>();
InstanceIdentifier<DataObject> iid = mock(InstanceIdentifier.class);
entryIids.add(iid);
- doNothing().when(transaction).delete(any(LogicalDatastoreType.class), (InstanceIdentifier<?>) any(List.class));
+ doNothing().when(transaction).delete(any(LogicalDatastoreType.class), any(InstanceIdentifier.class));
Whitebox.invokeMethod(ovsdbBridgeUpdateCommand, "deleteEntries", transaction, entryIids);
- verify(transaction).delete(any(LogicalDatastoreType.class), (InstanceIdentifier<?>) any(List.class));
+ verify(transaction).delete(any(LogicalDatastoreType.class), any(InstanceIdentifier.class));
}
@SuppressWarnings("unchecked")
verify(controllerEntry, times(2)).isIsConnected();
verify(ovsdbBridgeAugmentationBuilder).setBridgeOpenflowNodeRef(any(InstanceIdentifier.class));
}
-
- @SuppressWarnings("unchecked")
- @Test
- public void testGetInstanceIdentifier() throws Exception {
- PowerMockito.mockStatic(SouthboundMapper.class);
- when(ovsdbBridgeUpdateCommand.getOvsdbConnectionInstance()).thenReturn(mock(OvsdbConnectionInstance.class));
- InstanceIdentifier<Node> iid = mock(InstanceIdentifier.class);
- when(SouthboundMapper.createInstanceIdentifier(any(InstanceIdentifierCodec.class),
- any(OvsdbConnectionInstance.class), any(Bridge.class)))
- .thenReturn(iid);
-
- assertEquals(iid, Whitebox.invokeMethod(ovsdbBridgeUpdateCommand, "getInstanceIdentifier", mock(Bridge.class)));
- }
}
package org.opendaylight.ovsdb.southbound.transactions.md;
import static org.junit.Assert.assertEquals;
-import static org.mockito.Matchers.any;
+import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.doNothing;
+import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
// updatedBridgeRows null case
ReadWriteTransaction transaction = mock(ReadWriteTransaction.class);
ovsdbControllerUpdateCommand.execute(transaction);
- PowerMockito.verifyPrivate(ovsdbControllerUpdateCommand).invoke("updateController",
- any(ReadWriteTransaction.class), any(Map.class));
+ verify(ovsdbControllerUpdateCommand).updateController(any(ReadWriteTransaction.class), any(Map.class));
// updatedBridgeRows not null case
Map<UUID, Bridge> updatedBridgeRows = new HashMap<>();
// suppress call to getControllerEntryIid()
ReadWriteTransaction transaction = mock(ReadWriteTransaction.class);
Map<UUID, Controller> updatedControllerRows = new HashMap<>();
- MemberModifier.suppress(MemberMatcher.method(OvsdbControllerUpdateCommand.class, "getControllerEntryIid",
- ControllerEntry.class, String.class));
+ doReturn(mock(InstanceIdentifier.class)).when(ovsdbControllerUpdateCommand).getControllerEntryIid(
+ any(ControllerEntry.class), any(String.class));
doNothing().when(transaction).merge(any(LogicalDatastoreType.class), any(InstanceIdentifier.class),
any(ControllerEntry.class));
Whitebox.invokeMethod(ovsdbControllerUpdateCommand, "updateController", transaction, updatedControllerRows,
PowerMockito.whenNew(TopologyKey.class).withAnyArguments().thenReturn(mock(TopologyKey.class));
//PowerMockito.suppress(MemberMatcher.methodsDeclaredIn(InstanceIdentifier.class));
when(controllerEntry.key()).thenReturn(mock(ControllerEntryKey.class));
- assertEquals(KeyedInstanceIdentifier.class, (Whitebox
+ assertEquals(KeyedInstanceIdentifier.class, Whitebox
.invokeMethod(ovsdbControllerUpdateCommand, "getControllerEntryIid", controllerEntry, BRIDGE_NAME)
- .getClass()));
+ .getClass());
}
}
package org.opendaylight.ovsdb.southbound.transactions.md;
import static org.junit.Assert.assertEquals;
-import static org.mockito.Matchers.any;
+import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
package org.opendaylight.ovsdb.southbound.transactions.md;
import static org.junit.Assert.assertEquals;
-import static org.mockito.Matchers.any;
+import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
package org.opendaylight.ovsdb.southbound.transactions.md;
import static org.junit.Assert.assertEquals;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.eq;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doNothing;
+import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
public void testExecute() throws Exception {
when(ovsdbPortRemoveCommand.getUpdates()).thenReturn(mock(TableUpdates.class));
when(ovsdbPortRemoveCommand.getDbSchema()).thenReturn(mock(DatabaseSchema.class));
- PowerMockito.mockStatic(TyperUtils.class);
UUID uuid = mock(UUID.class);
Map<UUID, Port> portRemovedRows = new HashMap<>();
Port port = mock(Port.class);
portRemovedRows.put(uuid, port);
- when(TyperUtils.extractRowsRemoved(eq(Port.class), any(TableUpdates.class), any(DatabaseSchema.class)))
- .thenReturn(portRemovedRows);
+
+ PowerMockito.mockStatic(TyperUtils.class);
+ PowerMockito.doReturn(portRemovedRows).when(TyperUtils.class);
+ TyperUtils.extractRowsRemoved(eq(Port.class), any(TableUpdates.class), any(DatabaseSchema.class));
+
Map<UUID, Bridge> bridgeUpdatedRows = new HashMap<>();
Bridge updatedBridgeData = mock(Bridge.class);
bridgeUpdatedRows.put(uuid, updatedBridgeData);
- when(TyperUtils.extractRowsUpdated(eq(Bridge.class), any(TableUpdates.class), any(DatabaseSchema.class)))
- .thenReturn(bridgeUpdatedRows);
+ PowerMockito.doReturn(bridgeUpdatedRows).when(TyperUtils.class);
+ TyperUtils.extractRowsUpdated(eq(Bridge.class), any(TableUpdates.class), any(DatabaseSchema.class));
+
Map<UUID, Bridge> bridgeUpdatedOldRows = new HashMap<>();
Bridge oldBridgeData = mock(Bridge.class);
bridgeUpdatedOldRows.put(uuid, oldBridgeData);
- when(TyperUtils.extractRowsOld(eq(Bridge.class), any(TableUpdates.class), any(DatabaseSchema.class)))
- .thenReturn(bridgeUpdatedOldRows);
+ PowerMockito.doReturn(bridgeUpdatedOldRows).when(TyperUtils.class);
+ TyperUtils.extractRowsOld(eq(Bridge.class), any(TableUpdates.class), any(DatabaseSchema.class));
Column<GenericTableSchema, Set<UUID>> column = mock(Column.class);
when(oldBridgeData.getPortsColumn()).thenReturn(column);
when(uuidColumn.getData()).thenReturn(uuid);
when(port.getName()).thenReturn(PORT_NAME);
- PowerMockito.mockStatic(SouthboundMapper.class);
InstanceIdentifier<Node> nodeIID = mock(InstanceIdentifier.class);
- when(ovsdbPortRemoveCommand.getOvsdbConnectionInstance()).thenReturn(mock(OvsdbConnectionInstance.class));
- when(SouthboundMapper.createInstanceIdentifier(any(InstanceIdentifierCodec.class),
- any(OvsdbConnectionInstance.class), any(Bridge.class)))
- .thenReturn(nodeIID);
+ doReturn(mock(OvsdbConnectionInstance.class)).when(ovsdbPortRemoveCommand).getOvsdbConnectionInstance();
+
+ PowerMockito.mockStatic(SouthboundMapper.class);
+ PowerMockito.doReturn(nodeIID).when(SouthboundMapper.class);
+ SouthboundMapper.createInstanceIdentifier(eq(null),
+ any(OvsdbConnectionInstance.class), any(Bridge.class));
+
MemberModifier.suppress(MemberModifier.methodsDeclaredIn(InstanceIdentifier.class));
ReadWriteTransaction transaction = mock(ReadWriteTransaction.class);
doNothing().when(transaction).delete(any(LogicalDatastoreType.class), any(InstanceIdentifier.class));
ovsdbPortRemoveCommand.execute(transaction);
- verify(transaction).delete(any(LogicalDatastoreType.class), any(InstanceIdentifier.class));
+ verify(transaction).delete(any(LogicalDatastoreType.class), eq(null));
}
}
package org.opendaylight.ovsdb.southbound.transactions.md;
import static org.junit.Assert.assertEquals;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.anyString;
-import static org.mockito.Matchers.eq;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyString;
+import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.times;
import com.google.common.base.Optional;
import com.google.common.util.concurrent.CheckedFuture;
+import java.util.AbstractMap.SimpleEntry;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
Optional<Node> node = Optional.of(mock(Node.class));
PowerMockito.doReturn(node).when(ovsdbPortUpdateCommand, "readNode", any(ReadWriteTransaction.class),
any(InstanceIdentifier.class));
- PowerMockito.suppress(MemberMatcher.method(OvsdbPortUpdateCommand.class, "updateTerminationPoints",
- ReadWriteTransaction.class, Node.class));
+ doNothing().when(ovsdbPortUpdateCommand).updateTerminationPoints(any(ReadWriteTransaction.class),
+ any(Node.class));
ReadWriteTransaction transaction = mock(ReadWriteTransaction.class);
ovsdbPortUpdateCommand.execute(transaction);
verify(ovsdbConnectionInstance).getInstanceIdentifier();
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updateTerminationPoints",
- any(ReadWriteTransaction.class), any(Node.class));
+ verify(ovsdbPortUpdateCommand).updateTerminationPoints(any(ReadWriteTransaction.class), any(Node.class));
}
@Test
Node node = mock(Node.class);
Whitebox.invokeMethod(ovsdbPortUpdateCommand, "updateTerminationPoints", transaction, node);
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("getInstanceIdentifier",
- any(OvsdbTerminationPointAugmentationBuilder.class), any(Port.class));
+ verify(ovsdbPortUpdateCommand).getInstanceIdentifier(any(InstanceIdentifier.class),
+ any(Port.class));
verify(transaction, times(2)).merge(any(LogicalDatastoreType.class), any(InstanceIdentifier.class),
any(TerminationPoint.class));
}
when(tpAugmentationBuilder.setName(anyString())).thenReturn(tpAugmentationBuilder);
when(tpAugmentationBuilder.setPortUuid(any(Uuid.class))).thenReturn(tpAugmentationBuilder);
- MemberModifier.suppress(
- MemberMatcher.method(OvsdbPortUpdateCommand.class, "updatePort", ReadWriteTransaction.class, Node.class,
- InstanceIdentifier.class, Entry.class, OvsdbTerminationPointAugmentationBuilder.class));
+ doNothing().when(ovsdbPortUpdateCommand).updatePort(any(ReadWriteTransaction.class),
+ any(Node.class), any(InstanceIdentifier.class), any(Entry.class),
+ any(OvsdbTerminationPointAugmentationBuilder.class));
Node node = mock(Node.class);
ReadWriteTransaction transaction = mock(ReadWriteTransaction.class);
tpAugmentationBuilder, node, portEntry);
verify(tpAugmentationBuilder).setName(anyString());
verify(tpAugmentationBuilder).setPortUuid(any(Uuid.class));
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updatePort", any(ReadWriteTransaction.class),
+ verify(ovsdbPortUpdateCommand).updatePort(any(ReadWriteTransaction.class),
any(Node.class), any(InstanceIdentifier.class), any(Entry.class),
any(OvsdbTerminationPointAugmentationBuilder.class));
}
OvsdbTerminationPointAugmentationBuilder.class);
when(tpAugmentationBuilder.setName(anyString())).thenReturn(tpAugmentationBuilder);
when(tpAugmentationBuilder.setInterfaceUuid(any(Uuid.class))).thenReturn(tpAugmentationBuilder);
- MemberModifier.suppress(MemberMatcher.method(OvsdbPortUpdateCommand.class, "updateInterfaces", Interface.class,
- OvsdbTerminationPointAugmentationBuilder.class));
+
+ doNothing().when(ovsdbPortUpdateCommand).updateInterfaces(any(Interface.class),
+ any(OvsdbTerminationPointAugmentationBuilder.class));
Whitebox.invokeMethod(ovsdbPortUpdateCommand, "buildTerminationPoint", tpAugmentationBuilder, interfaceUpdate);
verify(tpAugmentationBuilder).setName(anyString());
verify(tpAugmentationBuilder).setInterfaceUuid(any(Uuid.class));
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updateInterfaces", any(Interface.class),
+ verify(ovsdbPortUpdateCommand).updateInterfaces(any(Interface.class),
any(OvsdbTerminationPointAugmentationBuilder.class));
}
assertEquals(node, Whitebox.invokeMethod(ovsdbPortUpdateCommand, "readNode", transaction, nodePath));
}
- @SuppressWarnings("unchecked")
- @Test
- public void testGetTerminationPointBridge() throws Exception {
- bridgeUpdatedRows = new HashMap<>();
- Bridge bridge = mock(Bridge.class);
- UUID bridgeUuid = mock(UUID.class);
- bridgeUpdatedRows.put(bridgeUuid, bridge);
- field(OvsdbPortUpdateCommand.class, "bridgeUpdatedRows").set(ovsdbPortUpdateCommand, bridgeUpdatedRows);
-
- Column<GenericTableSchema, Set<UUID>> column = mock(Column.class);
- when(bridge.getPortsColumn()).thenReturn(column);
- Set<UUID> set = new HashSet<>();
- UUID portUuid = mock(UUID.class);
- set.add(portUuid);
- when(column.getData()).thenReturn(set);
-
- PowerMockito.mockStatic(SouthboundMapper.class);
- when(ovsdbPortUpdateCommand.getOvsdbConnectionInstance()).thenReturn(mock(OvsdbConnectionInstance.class));
- InstanceIdentifier<Node> nodeIid = mock(InstanceIdentifier.class);
- PowerMockito.when(SouthboundMapper.createInstanceIdentifier(any(InstanceIdentifierCodec.class),
- any(OvsdbConnectionInstance.class), any(Bridge.class))).thenReturn(nodeIid);
-
- Optional<InstanceIdentifier<Node>> testResult = Optional.of(nodeIid);
- assertEquals(testResult, Whitebox.invokeMethod(ovsdbPortUpdateCommand, "getTerminationPointBridge", portUuid));
- }
-
@SuppressWarnings("unchecked")
@Test
public void testGetTerminationPointBridge1() throws Exception {
Column<GenericTableSchema, String> typeColumn = mock(Column.class);
when(interfaceUpdate.getTypeColumn()).thenReturn(typeColumn);
when(typeColumn.getData()).thenReturn(OVSDB_INTERFACE_TYPE);
- MemberModifier.suppress(MemberMatcher.method(OvsdbPortUpdateCommand.class, "updateInterface", Interface.class,
- String.class, OvsdbTerminationPointAugmentationBuilder.class));
+ doNothing().when(ovsdbPortUpdateCommand).updateInterface(any(Interface.class), anyString(),
+ any(OvsdbTerminationPointAugmentationBuilder.class));
OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder = mock(
OvsdbTerminationPointAugmentationBuilder.class);
Whitebox.invokeMethod(ovsdbPortUpdateCommand, "updateInterfaces", interfaceUpdate,
ovsdbTerminationPointBuilder);
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updateInterface", any(Interface.class), anyString(),
+ verify(ovsdbPortUpdateCommand).updateInterface(any(Interface.class), anyString(),
any(OvsdbTerminationPointAugmentationBuilder.class));
}
ovsdbTerminationPointBuilder);
verify(ovsdbTerminationPointBuilder).setInterfaceUuid(any(Uuid.class));
verify(ovsdbTerminationPointBuilder).setInterfaceType(any(Class.class));
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updateOfPort", any(Interface.class),
+ verify(ovsdbPortUpdateCommand).updateOfPort(any(Interface.class),
any(OvsdbTerminationPointAugmentationBuilder.class));
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updateOfPortRequest", any(Interface.class),
+ verify(ovsdbPortUpdateCommand).updateOfPortRequest(any(Interface.class),
any(OvsdbTerminationPointAugmentationBuilder.class));
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updateInterfaceExternalIds", any(Interface.class),
+ verify(ovsdbPortUpdateCommand).updateInterfaceExternalIds(any(Interface.class),
any(OvsdbTerminationPointAugmentationBuilder.class));
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updateOptions", any(Interface.class),
+ verify(ovsdbPortUpdateCommand).updateOptions(any(Interface.class),
any(OvsdbTerminationPointAugmentationBuilder.class));
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updateInterfaceOtherConfig", any(Interface.class),
+ verify(ovsdbPortUpdateCommand).updateInterfaceOtherConfig(any(Interface.class),
any(OvsdbTerminationPointAugmentationBuilder.class));
}
@SuppressWarnings("unchecked")
public void testUpdatePort() throws Exception {
suppress(method(OvsdbPortUpdateCommand.class, "updateVlan", Port.class,
- OvsdbTerminationPointAugmentationBuilder.class));
+ OvsdbTerminationPointAugmentationBuilder.class));
suppress(method(OvsdbPortUpdateCommand.class, "updateVlanTrunks", Port.class,
- OvsdbTerminationPointAugmentationBuilder.class));
+ OvsdbTerminationPointAugmentationBuilder.class));
suppress(method(OvsdbPortUpdateCommand.class, "updateVlanMode", Port.class,
- OvsdbTerminationPointAugmentationBuilder.class));
+ OvsdbTerminationPointAugmentationBuilder.class));
suppress(method(OvsdbPortUpdateCommand.class, "updatePortExternalIds", Port.class,
- OvsdbTerminationPointAugmentationBuilder.class));
+ OvsdbTerminationPointAugmentationBuilder.class));
suppress(method(OvsdbPortUpdateCommand.class, "updatePortOtherConfig", Port.class,
- OvsdbTerminationPointAugmentationBuilder.class));
+ OvsdbTerminationPointAugmentationBuilder.class));
+ suppress(method(OvsdbPortUpdateCommand.class, "updatePortOtherConfig", Port.class,
+ OvsdbTerminationPointAugmentationBuilder.class));
+ suppress(method(OvsdbPortUpdateCommand.class, "updateQos", ReadWriteTransaction.class, Node.class,
+ InstanceIdentifier.class, Entry.class, OvsdbTerminationPointAugmentationBuilder.class));
Node node = mock(Node.class);
- Entry<UUID, Port> port = mock(Entry.class);
+ Entry<UUID, Port> port = new SimpleEntry<>(mock(UUID.class), mock(Port.class));
OvsdbTerminationPointAugmentationBuilder ovsdbTerminationPointBuilder = mock(
OvsdbTerminationPointAugmentationBuilder.class);
ReadWriteTransaction transaction = mock(ReadWriteTransaction.class);
Whitebox.invokeMethod(ovsdbPortUpdateCommand, "updatePort", transaction, node, tpPath, port,
ovsdbTerminationPointBuilder);
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updateVlan", any(Port.class),
+ verify(ovsdbPortUpdateCommand).updateVlan(any(Port.class),
any(OvsdbTerminationPointAugmentationBuilder.class));
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updateVlanTrunks", any(Port.class),
+ verify(ovsdbPortUpdateCommand).updateVlanTrunks(any(Port.class),
any(OvsdbTerminationPointAugmentationBuilder.class));
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updateVlanMode", any(Port.class),
+ verify(ovsdbPortUpdateCommand).updateVlanMode(any(Port.class),
any(OvsdbTerminationPointAugmentationBuilder.class));
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updatePortExternalIds", any(Port.class),
+ verify(ovsdbPortUpdateCommand).updatePortExternalIds(any(Port.class),
any(OvsdbTerminationPointAugmentationBuilder.class));
- PowerMockito.verifyPrivate(ovsdbPortUpdateCommand).invoke("updatePortOtherConfig", any(Port.class),
+ verify(ovsdbPortUpdateCommand).updatePortOtherConfig(any(Port.class),
any(OvsdbTerminationPointAugmentationBuilder.class));
}