@Test public void test_EndpointsDelete_NoNE() throws Exception { writeBaseAddrEndpoint(); InstanceIdentifier<Endpoints> iid = InstanceIdentifier.builder(Endpoints.class) .build(); WriteTransaction wtx = dataBroker.newWriteOnlyTransaction(); wtx.delete(LogicalDatastoreType.OPERATIONAL, iid); wtx.submit().get(); List<AddressEndpoint> l3Endpoint = neProvider.getEndpoints(); assertEquals(0, l3Endpoint.size()); verifyEmptyLocations(); }
@VisibleForTesting synchronized List<AddressEndpoint> getEndpoints() { return endpoints; }
NeLocationProvider implements ClusteredDataTreeChangeListener<NetworkElements>, AutoCloseable { @VisibleForTesting synchronized List<AddressEndpoint> getEndpoints() { return endpoints; } }
NeLocationProvider implements ClusteredDataTreeChangeListener<NetworkElements>, AutoCloseable { @VisibleForTesting synchronized List<AddressEndpoint> getEndpoints() { return endpoints; } NeLocationProvider(DataBroker dataBroker); }
NeLocationProvider implements ClusteredDataTreeChangeListener<NetworkElements>, AutoCloseable { @VisibleForTesting synchronized List<AddressEndpoint> getEndpoints() { return endpoints; } NeLocationProvider(DataBroker dataBroker); @Override void close(); synchronized void onEndpointsChange(Collection<DataTreeModification<AddressEndpoint>> changes); @Override synchronized void onDataTreeChanged(Collection<DataTreeModification<NetworkElements>> changes); }
NeLocationProvider implements ClusteredDataTreeChangeListener<NetworkElements>, AutoCloseable { @VisibleForTesting synchronized List<AddressEndpoint> getEndpoints() { return endpoints; } NeLocationProvider(DataBroker dataBroker); @Override void close(); synchronized void onEndpointsChange(Collection<DataTreeModification<AddressEndpoint>> changes); @Override synchronized void onDataTreeChanged(Collection<DataTreeModification<NetworkElements>> changes); static final String NE_LOCATION_PROVIDER_NAME; }