import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
*/
public final class Ipv4ReachabilityTopologyBuilderModule extends org.opendaylight.controller.config.yang.bgp.topology.provider.AbstractIpv4ReachabilityTopologyBuilderModule
{
+ private static final Logger LOG = LoggerFactory.getLogger(Ipv4ReachabilityTopologyBuilderModule.class);
public Ipv4ReachabilityTopologyBuilderModule(final org.opendaylight.controller.config.api.ModuleIdentifier identifier, final org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
super(identifier, dependencyResolver);
final Ipv4ReachabilityTopologyBuilder b = new Ipv4ReachabilityTopologyBuilder(getDataProviderDependency(), getLocalRibDependency(), getTopologyId());
final InstanceIdentifier<Tables> i = b.tableInstanceIdentifier(Ipv4AddressFamily.class, UnicastSubsequentAddressFamily.class);
final ListenerRegistration<DataChangeListener> r = getDataProviderDependency().registerDataChangeListener(i, b);
+ LOG.debug("Registered listener {} on {} (topology {})", b, i, b.getInstanceIdentifier());
final class TopologyReferenceAutocloseable extends DefaultTopologyReference implements AutoCloseable {
public TopologyReferenceAutocloseable(final InstanceIdentifier<Topology> instanceIdentifier) {
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
*
*/
public final class Ipv6ReachabilityTopologyBuilderModule extends org.opendaylight.controller.config.yang.bgp.topology.provider.AbstractIpv6ReachabilityTopologyBuilderModule
{
+ private static final Logger LOG = LoggerFactory.getLogger(Ipv6ReachabilityTopologyBuilderModule.class);
public Ipv6ReachabilityTopologyBuilderModule(final org.opendaylight.controller.config.api.ModuleIdentifier identifier, final org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
super(identifier, dependencyResolver);
final Ipv6ReachabilityTopologyBuilder b = new Ipv6ReachabilityTopologyBuilder(getDataProviderDependency(), getLocalRibDependency(), getTopologyId());
final InstanceIdentifier<Tables> i = b.tableInstanceIdentifier(Ipv6AddressFamily.class, UnicastSubsequentAddressFamily.class);
final ListenerRegistration<DataChangeListener> r = getDataProviderDependency().registerDataChangeListener(i, b);
+ LOG.debug("Registered listener {} on {} (topology {})", b, i, b.getInstanceIdentifier());
final class TopologyReferenceAutocloseable extends DefaultTopologyReference implements AutoCloseable {
public TopologyReferenceAutocloseable(final InstanceIdentifier<Topology> instanceIdentifier) {
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
*/
public final class LinkstateTopologyBuilderModule extends org.opendaylight.controller.config.yang.bgp.topology.provider.AbstractLinkstateTopologyBuilderModule
{
+ private static final Logger LOG = LoggerFactory.getLogger(LinkstateTopologyBuilderModule.class);
public LinkstateTopologyBuilderModule(final org.opendaylight.controller.config.api.ModuleIdentifier identifier, final org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
super(identifier, dependencyResolver);
final LinkstateTopologyBuilder b = new LinkstateTopologyBuilder(getDataProviderDependency(), getLocalRibDependency(), getTopologyId());
final InstanceIdentifier<Tables> i = b.tableInstanceIdentifier(LinkstateAddressFamily.class, LinkstateSubsequentAddressFamily.class);
final ListenerRegistration<DataChangeListener> r = getDataProviderDependency().registerDataChangeListener(i, b);
+ LOG.debug("Registered listener {} on {} (topology {})", b, i, b.getInstanceIdentifier());
final class TopologyReferenceAutocloseable extends DefaultTopologyReference implements AutoCloseable {
public TopologyReferenceAutocloseable(final InstanceIdentifier<Topology> instanceIdentifier) {
@Override
public final void onLocRIBChange(final DataModification<InstanceIdentifier<?>, DataObject> trans,
final DataChangeEvent<InstanceIdentifier<?>, DataObject> event) {
+ LOG.debug("Received data change {} event with transaction {}", event, trans);
final Set<InstanceIdentifier<T>> ids = new HashSet<>();
for (final InstanceIdentifier<?> i : event.getRemovedOperationalData()) {
Futures.addCallback(JdkFutureAdapters.listenInPoolThread(trans.commit()), new FutureCallback<RpcResult<TransactionStatus>>() {
@Override
public void onSuccess(final RpcResult<TransactionStatus> result) {
- // Nothing to do
+ LOG.trace("Change committed successfully");
}
@Override
@Override
public final void close() throws InterruptedException, ExecutionException {
+ LOG.info("Shutting down builder for {}", getInstanceIdentifier());
final DataModificationTransaction trans = this.dataProvider.beginTransaction();
trans.removeOperationalData(getInstanceIdentifier());
trans.commit().get();
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev131125.loc.rib.tables.routes.linkstate.routes._case.linkstate.routes.LinkstateRoute;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev131125.loc.rib.tables.routes.linkstate.routes._case.linkstate.routes.linkstate.route.object.type.LinkCase;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev131125.loc.rib.tables.routes.linkstate.routes._case.linkstate.routes.linkstate.route.object.type.link._case.LinkDescriptors;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
final class UriBuilder {
+ private static final Logger LOG = LoggerFactory.getLogger(UriBuilder.class);
private final StringBuilder sb;
UriBuilder(final UriBuilder base, final String type) {
@Override
public final String toString() {
- return sb.toString();
+ final String ret = sb.toString();
+ LOG.trace("New URI {}", ret);
+ return ret;
}
}