return ret;
}
};
- private final int maximumCachedObjects;
public SimpleBGPExtensionProviderContext() {
this(DEFAULT_MAXIMUM_CACHED_OBJECTS);
}
public SimpleBGPExtensionProviderContext(final int maximumCachedObjects) {
- this.maximumCachedObjects = maximumCachedObjects;
-
final Cache<Object, Object> cache = CacheBuilder.newBuilder().maximumSize(maximumCachedObjects).build();
this.cacheRef = new AtomicReference<>(cache);
}
import com.google.common.primitives.UnsignedInteger;
import java.util.ArrayList;
import java.util.List;
-import java.util.Map;
import java.util.Optional;
import javax.annotation.concurrent.NotThreadSafe;
import org.opendaylight.controller.md.sal.dom.api.DOMDataWriteTransaction;
import org.opendaylight.protocol.bgp.mode.spi.AbstractRouteEntry;
import org.opendaylight.protocol.bgp.rib.spi.ExportPolicyPeerTracker;
import org.opendaylight.protocol.bgp.rib.spi.PeerExportGroup;
-import org.opendaylight.protocol.bgp.rib.spi.PeerExportGroup.PeerExporTuple;
import org.opendaylight.protocol.bgp.rib.spi.RIBSupport;
import org.opendaylight.protocol.bgp.rib.spi.RouterIds;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.PeerId;
throw new UnsupportedOperationException();
}
- public static TopologyReferenceSingletonService createBackwardsCssInstance(final TopologyTypes topologyTypes, final TopologyId topologyId, final DataBroker dataBroker, final BundleContext bundleContext,
+ public static TopologyReferenceSingletonService createBackwardsCssInstance(final TopologyTypes topologyTypes, final TopologyId topologyId, final BundleContext bundleContext,
final KeyedInstanceIdentifier<Rib, RibKey> ribIId) {
//map configuration to topology
final Topology topology = createConfiguration(topologyTypes, topologyId, ribIId.getKey().getId());
@Override
public java.lang.AutoCloseable createInstance() {
- return BackwardsCssTopologyProvider.createBackwardsCssInstance(Ipv4ReachabilityTopologyBuilder.IPV4_TOPOLOGY_TYPE, getTopologyId(), getDataProviderDependency(), this.bundleContext,
+ return BackwardsCssTopologyProvider.createBackwardsCssInstance(Ipv4ReachabilityTopologyBuilder.IPV4_TOPOLOGY_TYPE, getTopologyId(), this.bundleContext,
getLocalRibDependency().getInstanceIdentifier());
}
public void setBundleContext(final BundleContext bundleContext) {
@Override
public AutoCloseable createInstance() {
- return BackwardsCssTopologyProvider.createBackwardsCssInstance(Ipv6ReachabilityTopologyBuilder.IPV6_TOPOLOGY_TYPE, getTopologyId(), getDataProviderDependency(), this.bundleContext,
+ return BackwardsCssTopologyProvider.createBackwardsCssInstance(Ipv6ReachabilityTopologyBuilder.IPV6_TOPOLOGY_TYPE, getTopologyId(), this.bundleContext,
getLocalRibDependency().getInstanceIdentifier());
}
@Override
public java.lang.AutoCloseable createInstance() {
- return BackwardsCssTopologyProvider.createBackwardsCssInstance(LinkstateTopologyBuilder.LINKSTATE_TOPOLOGY_TYPE, getTopologyId(), getDataProviderDependency(), this.bundleContext,
+ return BackwardsCssTopologyProvider.createBackwardsCssInstance(LinkstateTopologyBuilder.LINKSTATE_TOPOLOGY_TYPE, getTopologyId(), this.bundleContext,
getLocalRibDependency().getInstanceIdentifier());
}
public void setBundleContext(final BundleContext bundleContext) {
flags.set(IGNORED, ignore);
flags.set(PROCESSED, processingRule);
final byte flagB = flags.toByte();
- final int typeByte = objectType << FLAGS_SIZE | flagB;
+ final int typeByte = objectType << FLAGS_SIZE | (flagB & 0xff);
out.writeByte(typeByte);
out.writeShort(body.writerIndex() + HEADER_SIZE);
out.writeBytes(body);
import com.google.common.util.concurrent.ListenableFuture;
import java.util.Collection;
import java.util.HashMap;
-import java.util.Iterator;
import java.util.Map;
import javax.annotation.concurrent.ThreadSafe;
import org.opendaylight.controller.md.sal.binding.api.BindingTransactionChain;