3 import static org.junit.Assert.assertEquals;
4 import static org.junit.Assert.assertTrue;
6 import java.util.concurrent.ExecutionException;
8 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
9 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
10 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker;
11 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
12 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
13 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
14 import org.opendaylight.controller.md.statistics.manager.StatisticsManagerActivator;
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowFeatureCapabilityPortStats;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorKey;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.FlowCapableNodeConnectorStatisticsData;
21 import org.opendaylight.yangtools.yang.binding.DataObject;
22 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
24 import test.mock.util.StatisticsManagerTest;
26 import com.google.common.base.Optional;
28 public class PortStatisticsTest extends StatisticsManagerTest {
29 private final Object waitObject = new Object();
31 // @Test(timeout = 23000)
32 public void getPortStatisticsTest() throws ExecutionException, InterruptedException, ReadFailedException {
33 final StatisticsManagerActivator activator = new StatisticsManagerActivator();
34 activator.onSessionInitiated(providerContext);
36 addFlowCapableNodeWithFeatures(s1Key, false, FlowFeatureCapabilityPortStats.class);
38 final InstanceIdentifier<NodeConnector> nodeConnectorII = InstanceIdentifier.create(Nodes.class)
39 .child(Node.class, s1Key).child(NodeConnector.class, new NodeConnectorKey(getNodeConnectorId()));
42 getDataBroker().registerDataChangeListener(LogicalDatastoreType.OPERATIONAL,
43 nodeConnectorII.augmentation(FlowCapableNodeConnectorStatisticsData.class),
44 new ChangeListener(), AsyncDataBroker.DataChangeScope.BASE);
46 synchronized (waitObject) {
50 final ReadOnlyTransaction readTx = getDataBroker().newReadOnlyTransaction();
51 final Optional<FlowCapableNodeConnectorStatisticsData> flowCapableNodeConnectorStatisticsDataOptional =
52 readTx.read(LogicalDatastoreType.OPERATIONAL,
53 nodeConnectorII.augmentation(FlowCapableNodeConnectorStatisticsData.class)).checkedGet();
54 assertTrue(flowCapableNodeConnectorStatisticsDataOptional.isPresent());
55 assertEquals(BIG_INTEGER_TEST_VALUE,
56 flowCapableNodeConnectorStatisticsDataOptional.get().getFlowCapableNodeConnectorStatistics()
58 assertEquals(BIG_INTEGER_TEST_VALUE,
59 flowCapableNodeConnectorStatisticsDataOptional.get().getFlowCapableNodeConnectorStatistics()
60 .getCollisionCount());
63 private class ChangeListener implements DataChangeListener {
66 public void onDataChanged(final AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) {
67 synchronized (waitObject) {