2 * Copyright (c) 2015 Inocybe Technologies and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.ovsdb.southbound.ovsdb.transact;
11 import static org.junit.Assert.assertEquals;
12 import static org.mockito.Matchers.any;
13 import static org.mockito.Mockito.doNothing;
14 import static org.mockito.Mockito.mock;
15 import static org.mockito.Mockito.verify;
17 import java.util.ArrayList;
18 import java.util.List;
20 import org.junit.Before;
21 import org.junit.Test;
22 import org.junit.runner.RunWith;
23 import org.mockito.Mock;
24 import org.mockito.Mockito;
25 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
26 import org.opendaylight.ovsdb.lib.operations.TransactionBuilder;
27 import org.opendaylight.yangtools.yang.binding.DataObject;
28 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
29 import org.powermock.api.mockito.PowerMockito;
30 import org.powermock.api.support.membermodification.MemberModifier;
31 import org.powermock.core.classloader.annotations.PrepareForTest;
32 import org.powermock.modules.junit4.PowerMockRunner;
33 import org.powermock.reflect.Whitebox;
36 @RunWith(PowerMockRunner.class)
37 public class TransactCommandAggregatorTest {
38 private static final int NUMBER_OF_COMMANDS = 11;
39 private List<TransactCommand> commands = new ArrayList<TransactCommand>();
40 private TransactCommandAggregator transactCommandAggregator;
41 @Mock private AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes;
42 @Mock private BridgeOperationalState operationalState;
45 public void setUp() throws Exception {
46 transactCommandAggregator = PowerMockito.mock(TransactCommandAggregator.class, Mockito.CALLS_REAL_METHODS);
49 commands.add(mock(BridgeUpdateCommand.class));
50 commands.add(mock(OpenVSwitchBridgeAddCommand.class));
51 commands.add(mock(ControllerUpdateCommand.class));
52 commands.add(mock(ControllerRemovedCommand.class));
53 commands.add(mock(ProtocolUpdateCommand.class));
54 commands.add(mock(ProtocolRemovedCommand.class));
55 commands.add(mock(BridgeRemovedCommand.class));
56 commands.add(mock(TerminationPointCreateCommand.class));
57 commands.add(mock(TerminationPointDeleteCommand.class));
58 commands.add(mock(OvsdbNodeUpdateCommand.class));
59 commands.add(mock(TerminationPointUpdateCommand.class));
60 MemberModifier.field(TransactCommandAggregator.class, "commands").set(transactCommandAggregator, commands);
64 public void testOvsdbOperationalCommandAggregator() throws Exception {
65 TransactCommandAggregator transactCommandAggregator1 = new TransactCommandAggregator(operationalState, changes);
66 List<TransactCommand> testCommands = Whitebox.getInternalState(transactCommandAggregator1, "commands");
67 assertEquals(NUMBER_OF_COMMANDS, testCommands.size());
71 public void testExecute() {
72 TransactionBuilder transaction = mock(TransactionBuilder.class);
73 for (TransactCommand command: commands) {
74 doNothing().when(command).execute(any(TransactionBuilder.class));
76 transactCommandAggregator.execute(transaction);
77 for (TransactCommand command: commands) {
78 verify(command).execute(any(TransactionBuilder.class));