@Test public void offsetGreaterThanEgress() throws InterruptedException { int offset = 200; int egress = 10; AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change = createSfcOfRendererConfig(offset, egress); this.sfcOfRendererDataListener.onDataChanged(change); Thread.sleep(100); verifySettersCalled(offset, egress); }
@Override public void onDataChanged(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) { for (Entry<InstanceIdentifier<?>, DataObject> entry : change.getCreatedData().entrySet()) { if (entry.getValue() instanceof SfcOfRendererConfig) { LOG.info("SfcOfRendererDataListener.onDataChanged create SFC OF Renderer config {}", ((SfcOfRendererConfig) entry.getValue())); processConfig((SfcOfRendererConfig) entry.getValue()); } } for (Entry<InstanceIdentifier<?>, DataObject> entry : change.getUpdatedData().entrySet()) { if (entry.getValue() instanceof SfcOfRendererConfig) { LOG.info("SfcOfRendererDataListener.onDataChanged update SFC OF Renderer config {}", ((SfcOfRendererConfig) entry.getValue())); processConfig((SfcOfRendererConfig) entry.getValue()); } } }
SfcOfRendererDataListener extends SfcOfAbstractDataListener { @Override public void onDataChanged(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) { for (Entry<InstanceIdentifier<?>, DataObject> entry : change.getCreatedData().entrySet()) { if (entry.getValue() instanceof SfcOfRendererConfig) { LOG.info("SfcOfRendererDataListener.onDataChanged create SFC OF Renderer config {}", ((SfcOfRendererConfig) entry.getValue())); processConfig((SfcOfRendererConfig) entry.getValue()); } } for (Entry<InstanceIdentifier<?>, DataObject> entry : change.getUpdatedData().entrySet()) { if (entry.getValue() instanceof SfcOfRendererConfig) { LOG.info("SfcOfRendererDataListener.onDataChanged update SFC OF Renderer config {}", ((SfcOfRendererConfig) entry.getValue())); processConfig((SfcOfRendererConfig) entry.getValue()); } } } }
SfcOfRendererDataListener extends SfcOfAbstractDataListener { @Override public void onDataChanged(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) { for (Entry<InstanceIdentifier<?>, DataObject> entry : change.getCreatedData().entrySet()) { if (entry.getValue() instanceof SfcOfRendererConfig) { LOG.info("SfcOfRendererDataListener.onDataChanged create SFC OF Renderer config {}", ((SfcOfRendererConfig) entry.getValue())); processConfig((SfcOfRendererConfig) entry.getValue()); } } for (Entry<InstanceIdentifier<?>, DataObject> entry : change.getUpdatedData().entrySet()) { if (entry.getValue() instanceof SfcOfRendererConfig) { LOG.info("SfcOfRendererDataListener.onDataChanged update SFC OF Renderer config {}", ((SfcOfRendererConfig) entry.getValue())); processConfig((SfcOfRendererConfig) entry.getValue()); } } } SfcOfRendererDataListener(
            DataBroker dataBroker,
            SfcOfFlowProgrammerInterface sfcOfFlowProgrammer,
            SfcSynchronizer sfcSynchronizer); }
SfcOfRendererDataListener extends SfcOfAbstractDataListener { @Override public void onDataChanged(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) { for (Entry<InstanceIdentifier<?>, DataObject> entry : change.getCreatedData().entrySet()) { if (entry.getValue() instanceof SfcOfRendererConfig) { LOG.info("SfcOfRendererDataListener.onDataChanged create SFC OF Renderer config {}", ((SfcOfRendererConfig) entry.getValue())); processConfig((SfcOfRendererConfig) entry.getValue()); } } for (Entry<InstanceIdentifier<?>, DataObject> entry : change.getUpdatedData().entrySet()) { if (entry.getValue() instanceof SfcOfRendererConfig) { LOG.info("SfcOfRendererDataListener.onDataChanged update SFC OF Renderer config {}", ((SfcOfRendererConfig) entry.getValue())); processConfig((SfcOfRendererConfig) entry.getValue()); } } } SfcOfRendererDataListener(
            DataBroker dataBroker,
            SfcOfFlowProgrammerInterface sfcOfFlowProgrammer,
            SfcSynchronizer sfcSynchronizer); @Override void onDataChanged(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change); TableId verifyMaxTableId(short tableOffset, short maxTable); }
SfcOfRendererDataListener extends SfcOfAbstractDataListener { @Override public void onDataChanged(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) { for (Entry<InstanceIdentifier<?>, DataObject> entry : change.getCreatedData().entrySet()) { if (entry.getValue() instanceof SfcOfRendererConfig) { LOG.info("SfcOfRendererDataListener.onDataChanged create SFC OF Renderer config {}", ((SfcOfRendererConfig) entry.getValue())); processConfig((SfcOfRendererConfig) entry.getValue()); } } for (Entry<InstanceIdentifier<?>, DataObject> entry : change.getUpdatedData().entrySet()) { if (entry.getValue() instanceof SfcOfRendererConfig) { LOG.info("SfcOfRendererDataListener.onDataChanged update SFC OF Renderer config {}", ((SfcOfRendererConfig) entry.getValue())); processConfig((SfcOfRendererConfig) entry.getValue()); } } } SfcOfRendererDataListener(
            DataBroker dataBroker,
            SfcOfFlowProgrammerInterface sfcOfFlowProgrammer,
            SfcSynchronizer sfcSynchronizer); @Override void onDataChanged(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change); TableId verifyMaxTableId(short tableOffset, short maxTable);  }