opendaylight/md-sal/statistics-manager/src/test/java/test/mock/PortStatisticsTest.java

   1 package test.mock;
   2
   3 import static org.junit.Assert.assertEquals;
   4 import static org.junit.Assert.assertTrue;
   5
   6 import java.util.concurrent.ExecutionException;
   7
   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;
  23
  24 import test.mock.util.StatisticsManagerTest;
  25
  26 import com.google.common.base.Optional;
  27
  28 public class PortStatisticsTest extends StatisticsManagerTest {
  29     private final Object waitObject = new Object();
  30
  31 //    @Test(timeout = 23000)
  32     public void getPortStatisticsTest() throws ExecutionException, InterruptedException, ReadFailedException {
  33         final StatisticsManagerActivator activator = new StatisticsManagerActivator();
  34         activator.onSessionInitiated(providerContext);
  35
  36         addFlowCapableNodeWithFeatures(s1Key, false, FlowFeatureCapabilityPortStats.class);
  37
  38         final InstanceIdentifier<NodeConnector> nodeConnectorII = InstanceIdentifier.create(Nodes.class)
  39                 .child(Node.class, s1Key).child(NodeConnector.class, new NodeConnectorKey(getNodeConnectorId()));
  40
  41
  42         getDataBroker().registerDataChangeListener(LogicalDatastoreType.OPERATIONAL,
  43                 nodeConnectorII.augmentation(FlowCapableNodeConnectorStatisticsData.class),
  44                                                 new ChangeListener(), AsyncDataBroker.DataChangeScope.BASE);
  45
  46         synchronized (waitObject) {
  47             waitObject.wait();
  48         }
  49
  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()
  57                         .getReceiveDrops());
  58         assertEquals(BIG_INTEGER_TEST_VALUE,
  59                 flowCapableNodeConnectorStatisticsDataOptional.get().getFlowCapableNodeConnectorStatistics()
  60                         .getCollisionCount());
  61     }
  62
  63     private class ChangeListener implements DataChangeListener {
  64
  65         @Override
  66         public void onDataChanged(final AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) {
  67             synchronized (waitObject) {
  68                 waitObject.notify();
  69             }
  70         }
  71     }
  72 }
  73