package io.fd.hc2vpp.acl.read;
import static io.fd.hc2vpp.acl.read.AbstractVppAclCustomizer.getAclCfgId;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Optional;
final int interfaceIndex = interfaceContext.getIndex(interfaceName, mappingContext);
final ModificationCache modificationCache = ctx.getModificationCache();
final Optional<MacipAclInterfaceGetReply> interfacesMacIpDumpReply =
- interfaceMacIpAclDumpManager.getDump(id, modificationCache, NO_PARAMS);
+ interfaceMacIpAclDumpManager.getDump(id, modificationCache);
if (interfacesMacIpDumpReply.isPresent() && interfaceIndex < interfacesMacIpDumpReply.get().count) {
final int aclIndex = interfacesMacIpDumpReply.get().acls[interfaceIndex];
package io.fd.hc2vpp.dhcp.read;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
-
import com.google.common.base.Optional;
import com.google.common.primitives.UnsignedInts;
import io.fd.hc2vpp.common.translate.util.ByteDataTranslator;
Collections.emptyList();
final Optional<DhcpProxyDetailsReplyDump> dump =
- dumpManager.getDump(id, context.getModificationCache(), NO_PARAMS);
+ dumpManager.getDump(id, context.getModificationCache());
if (!dump.isPresent() || dump.get().dhcpProxyDetails.isEmpty()) {
return Collections.emptyList();
@Override
public void readCurrentAttributes(@Nonnull final InstanceIdentifier<Relay> id, @Nonnull final RelayBuilder builder,
@Nonnull final ReadContext ctx) throws ReadFailedException {
- final Optional<DhcpProxyDetailsReplyDump> dump =
- dumpManager.getDump(id, ctx.getModificationCache(), NO_PARAMS);
+ final Optional<DhcpProxyDetailsReplyDump> dump = dumpManager.getDump(id, ctx.getModificationCache());
if (!dump.isPresent() || dump.get().dhcpProxyDetails.isEmpty()) {
return;
package io.fd.hc2vpp.l3.read.ipv6.nd;
import static com.google.common.base.Preconditions.checkNotNull;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Optional;
final int swIfIndex = interfaceContext.getIndex(interfaceName, context.getMappingContext());
LOG.debug("Reading NDProxies for interface {}(id={})", interfaceName, swIfIndex);
final Optional<Ip6NdProxyDetailsReplyDump> dump =
- dumpManager.getDump(id, context.getModificationCache(), NO_PARAMS);
+ dumpManager.getDump(id, context.getModificationCache());
if (!dump.isPresent() || dump.get().ip6NdProxyDetails.isEmpty()) {
return Collections.emptyList();
package io.fd.hc2vpp.lisp.gpe.translate.read;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
import static java.lang.String.format;
import com.google.common.base.Optional;
private Stream<Integer> activeVnis(final InstanceIdentifier<GpeEntry> id,
final ModificationCache cache) throws ReadFailedException {
- final int[] vnis = activeVnisDumpManager.getDump(id, cache, NO_PARAMS).or(() -> {
+ final int[] vnis = activeVnisDumpManager.getDump(id, cache).or(() -> {
final GpeFwdEntryVnisGetReply reply = new GpeFwdEntryVnisGetReply();
reply.vnis = new int[0];
return reply;
package io.fd.hc2vpp.lisp.gpe.translate.read;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
-
import com.google.common.primitives.UnsignedInts;
import io.fd.hc2vpp.common.translate.util.FutureJVppCustomizer;
import io.fd.hc2vpp.common.translate.util.JvppReplyConsumer;
private Stream<Integer> v4FibsStream(final InstanceIdentifier<NativeForwardPathsTable> id,
final ReadContext ctx) throws ReadFailedException {
- return dumpCacheManagerV4.getDump(id, ctx.getModificationCache(), NO_PARAMS).or(DEFAULT_REPLY_V4)
+ return dumpCacheManagerV4.getDump(id, ctx.getModificationCache()).or(DEFAULT_REPLY_V4)
.ipFibDetails.stream()
.map(ipFibDetails -> ipFibDetails.tableId);
}
private Stream<Integer> v6FibsStream(final InstanceIdentifier<NativeForwardPathsTable> id,
final ReadContext ctx) throws ReadFailedException {
- return dumpCacheManagerV6.getDump(id, ctx.getModificationCache(), NO_PARAMS).or(DEFAULT_REPLY_V6)
+ return dumpCacheManagerV6.getDump(id, ctx.getModificationCache()).or(DEFAULT_REPLY_V6)
.ip6FibDetails.stream()
.map(ip6FibDetails -> ip6FibDetails.tableId);
}
package io.fd.hc2vpp.lisp.gpe.translate.service;
import static com.google.common.base.Preconditions.checkState;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
import com.google.inject.Inject;
import io.fd.hc2vpp.common.translate.util.ByteDataTranslator;
public boolean isGpeEnabled(@Nonnull final ReadContext readContext) {
try {
return byteToBoolean(
- dumpCacheManager.getDump(GPE_FEATURE_STATE_ID, readContext.getModificationCache(), NO_PARAMS)
+ dumpCacheManager.getDump(GPE_FEATURE_STATE_ID, readContext.getModificationCache())
.or(DEFAULT_REPLY).gpeStatus);
} catch (ReadFailedException e) {
throw new IllegalStateException("Unable to read Gpe feature status", e);
package io.fd.hc2vpp.lisp.translate.read;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
-
import com.google.common.base.Optional;
import io.fd.hc2vpp.common.translate.util.ByteDataTranslator;
import io.fd.hc2vpp.common.translate.util.JvppReplyConsumer;
return;
}
- final Optional<OneGetMapRequestItrRlocsReply> reply =
- dumpCacheManager.getDump(id, ctx.getModificationCache(), NO_PARAMS);
+ final Optional<OneGetMapRequestItrRlocsReply> reply = dumpCacheManager.getDump(id, ctx.getModificationCache());
if (!reply.isPresent() || reply.get().locatorSetName == null) {
return;
}
package io.fd.hc2vpp.lisp.translate.read;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
-
import com.google.common.base.Optional;
import io.fd.hc2vpp.common.translate.util.ByteDataTranslator;
import io.fd.hc2vpp.common.translate.util.FutureJVppCustomizer;
*/
final Optional<OneLocatorSetDetailsReplyDump> dumpOptional;
try {
- dumpOptional = dumpManager.getDump(id, ctx.getModificationCache(), NO_PARAMS);
+ dumpOptional = dumpManager.getDump(id, ctx.getModificationCache());
} catch (ReadFailedException e) {
throw new IllegalStateException("Unable to initialize locator set context mapping", e);
}
package io.fd.hc2vpp.lisp.translate.read;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
-
import com.google.common.base.Optional;
import io.fd.hc2vpp.common.translate.util.ByteDataTranslator;
import io.fd.hc2vpp.lisp.translate.read.init.LispInitPathsMapper;
LOG.debug("Reading attributes for Locator Set {}", id);
final Optional<OneLocatorSetDetailsReplyDump> dumpOptional =
- dumpManager.getDump(id, ctx.getModificationCache(), NO_PARAMS);
+ dumpManager.getDump(id, ctx.getModificationCache());
if (!dumpOptional.isPresent() || dumpOptional.get().oneLocatorSetDetails.isEmpty()) {
return;
LOG.debug("Dumping Locator Set {}", id);
final Optional<OneLocatorSetDetailsReplyDump> dumpOptional =
- dumpManager.getDump(id, context.getModificationCache(), NO_PARAMS);
+ dumpManager.getDump(id, context.getModificationCache());
if (!dumpOptional.isPresent() || dumpOptional.get().oneLocatorSetDetails.isEmpty()) {
return Collections.emptyList();
package io.fd.hc2vpp.lisp.translate.read;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
-
import com.google.common.base.Optional;
import io.fd.hc2vpp.common.translate.util.AddressTranslator;
import io.fd.hc2vpp.common.translate.util.JvppReplyConsumer;
import io.fd.vpp.jvpp.core.dto.OneMapResolverDetailsReplyDump;
import io.fd.vpp.jvpp.core.dto.OneMapResolverDump;
import io.fd.vpp.jvpp.core.future.FutureJVppCore;
-import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;
import javax.annotation.Nonnull;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.lisp.rev170808.map.resolvers.grouping.MapResolvers;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.lisp.rev170808.map.resolvers.grouping.MapResolversBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.lisp.rev170808.map.resolvers.grouping.map.resolvers.MapResolver;
LOG.debug("Reading attributes...");
final Optional<OneMapResolverDetailsReplyDump> dumpOptional =
- dumpManager.getDump(id, ctx.getModificationCache(), NO_PARAMS);
+ dumpManager.getDump(id, ctx.getModificationCache());
if (!dumpOptional.isPresent() || dumpOptional.get().oneMapResolverDetails.isEmpty()) {
LOG.warn("No data dumped");
LOG.debug("Dumping MapResolver...");
final Optional<OneMapResolverDetailsReplyDump> dumpOptional =
- dumpManager.getDump(id, context.getModificationCache(), NO_PARAMS);
+ dumpManager.getDump(id, context.getModificationCache());
if (!dumpOptional.isPresent() || dumpOptional.get().oneMapResolverDetails.isEmpty()) {
return Collections.emptyList();
package io.fd.hc2vpp.lisp.translate.read;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
-
import com.google.common.base.Optional;
import io.fd.hc2vpp.common.translate.util.AddressTranslator;
import io.fd.hc2vpp.common.translate.util.JvppReplyConsumer;
}
final Optional<OneMapServerDetailsReplyDump> dump =
- dumpManager.getDump(instanceIdentifier, readContext.getModificationCache(), NO_PARAMS);
+ dumpManager.getDump(instanceIdentifier, readContext.getModificationCache());
if (dump.isPresent() && dump.get().oneMapServerDetails != null) {
return dump.get().oneMapServerDetails.stream()
return;
}
final Optional<OneMapServerDetailsReplyDump> dump =
- dumpManager.getDump(instanceIdentifier, readContext.getModificationCache(), NO_PARAMS);
+ dumpManager.getDump(instanceIdentifier, readContext.getModificationCache());
if (dump.isPresent() && dump.get().oneMapServerDetails != null) {
final IpAddress currentAddress = instanceIdentifier.firstKeyOf(MapServer.class).getIpAddress();
package io.fd.hc2vpp.lisp.translate.read;
import static com.google.common.base.Preconditions.checkState;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
import com.google.common.base.Optional;
import io.fd.hc2vpp.common.translate.util.JvppReplyConsumer;
LOG.trace("Reading all IDS...");
final Optional<OneEidTableVniDetailsReplyDump> optionalReply =
- dumpManager.getDump(id, context.getModificationCache(), NO_PARAMS);
+ dumpManager.getDump(id, context.getModificationCache());
if (!optionalReply.isPresent() || optionalReply.get().oneEidTableVniDetails.isEmpty()) {
return Collections.emptyList();
VniTableKey key = new VniTableKey(id.firstKeyOf(VniTable.class).getVirtualNetworkIdentifier());
final Optional<OneEidTableVniDetailsReplyDump> optionalReply =
- dumpManager.getDump(id, ctx.getModificationCache(), NO_PARAMS);
+ dumpManager.getDump(id, ctx.getModificationCache());
if (!optionalReply.isPresent() || optionalReply.get().oneEidTableVniDetails.isEmpty()) {
return;
package io.fd.hc2vpp.lisp.translate.service;
import static com.google.common.base.Preconditions.checkState;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
import com.google.inject.Inject;
import io.fd.hc2vpp.common.translate.util.ByteDataTranslator;
public boolean lispEnabled(@Nonnull final ReadContext ctx) {
// in this case it must be dumped
try {
- return byteToBoolean(dumpManager.getDump(IDENTIFIER, ctx.getModificationCache(), NO_PARAMS)
+ return byteToBoolean(dumpManager.getDump(IDENTIFIER, ctx.getModificationCache())
.or(DEFAULT_REPLY).featureStatus);
} catch (ReadFailedException e) {
throw new IllegalStateException("Unable to read Lisp Feature status", e);
final Long poolId = id.firstKeyOf(ExternalIpAddressPool.class).getPoolId();
final List<Nat44AddressDetails> nat44Details =
- nat44DumpMgr.getDump(id, ctx.getModificationCache(), null)
+ nat44DumpMgr.getDump(id, ctx.getModificationCache())
.or(new Nat44AddressDetailsReplyDump()).nat44AddressDetails;
final int nat44PoolCount = nat44Details.size();
readPoolIp(builder, detail.ipAddress);
setPoolType(builder, NatPoolType.Nat44);
} else {
- final List<Nat64PoolAddrDetails> nat64Details = nat64DumpMgr.getDump(id, ctx.getModificationCache(), null)
+ final List<Nat64PoolAddrDetails> nat64Details = nat64DumpMgr.getDump(id, ctx.getModificationCache())
.or(new Nat64PoolAddrDetailsReplyDump()).nat64PoolAddrDetails;
final int nat64PoolCount = nat64Details.size();
final int nat64PoolPosition = Math.toIntExact(poolId) - nat44PoolCount;
// That's why the write and read is not symmetrical in terms of data structure, instead,
// this customizer also returns every single address as a 32 prefix and assigns an artificial key to them
- long addressCount = nat44DumpMgr.getDump(id, ctx.getModificationCache(), null)
+ long addressCount = nat44DumpMgr.getDump(id, ctx.getModificationCache())
.or(new Nat44AddressDetailsReplyDump()).nat44AddressDetails.stream()
.count();
// The ietf-nat model groups address pools for Nat44 and Nat64 under the same list,
// but VPP uses different APIs, so we need an other dump:
- addressCount += nat64DumpMgr.getDump(id, ctx.getModificationCache(), null)
+ addressCount += nat64DumpMgr.getDump(id, ctx.getModificationCache())
.or(new Nat64PoolAddrDetailsReplyDump()).nat64PoolAddrDetails.stream()
.count();
final int idx = id.firstKeyOf(MappingEntry.class).getIndex().intValue();
final int natInstanceId = id.firstKeyOf(NatInstance.class).getId().intValue();
final List<Nat44StaticMappingDetails> nat44Details =
- nat44DumpManager.getDump(id, ctx.getModificationCache(), null)
+ nat44DumpManager.getDump(id, ctx.getModificationCache())
.or(new Nat44StaticMappingDetailsReplyDump()).nat44StaticMappingDetails;
final Optional<Nat44StaticMappingDetails> nat44StaticMappingDetails =
mappingEntryContext.findDetailsNat44(nat44Details, natInstanceId, idx, ctx.getMappingContext());
readNat44Entry(builder, idx, nat44StaticMappingDetails.get());
} else {
final List<Nat64BibDetails> nat64Details =
- nat64DumpManager.getDump(id, ctx.getModificationCache(), null)
+ nat64DumpManager.getDump(id, ctx.getModificationCache())
.or(new Nat64BibDetailsReplyDump()).nat64BibDetails;
final Optional<Nat64BibDetails> nat64StaticMappingDetails =
LOG.trace("Listing IDs for all mapping-entries within nat-instance(vrf):{}", natInstanceId);
final List<MappingEntryKey> entryKeys =
- nat44DumpManager.getDump(id, context.getModificationCache(), null)
+ nat44DumpManager.getDump(id, context.getModificationCache())
.or(new Nat44StaticMappingDetailsReplyDump()).nat44StaticMappingDetails.stream()
.filter(detail -> natInstanceId == detail.vrfId)
.map(detail -> mappingEntryContext
final List<MappingEntryKey> nat64Keys =
- nat64DumpManager.getDump(id, context.getModificationCache(), null)
+ nat64DumpManager.getDump(id, context.getModificationCache())
.or(new Nat64BibDetailsReplyDump()).nat64BibDetails.stream()
.filter(detail -> natInstanceId == detail.vrfId)
.map(detail -> mappingEntryContext
LOG.trace("Listing IDs for all nat64 prefixes within nat-instance(vrf): {}", natKey);
final Map<Long, Nat64PrefixDetails> prefixesByVrfId =
- dumpManager.getDump(id, context.getModificationCache(), null).get();
+ dumpManager.getDump(id, context.getModificationCache()).get();
final Nat64PrefixDetails nat64PrefixDetails = prefixesByVrfId.get(natKey.getId());
if (nat64PrefixDetails != null) {
// VPP supports only single nat64-prefix per VRF/nat-instance (we map nat-instances to VRFs)
return;
}
final Map<Long, Nat64PrefixDetails> prefixesByVrfId =
- dumpManager.getDump(id, context.getModificationCache(), null).get();
+ dumpManager.getDump(id, context.getModificationCache()).get();
final Nat64PrefixDetails prefixDetails = prefixesByVrfId.get(id.firstKeyOf(NatInstance.class).getId());
if (prefixDetails != null) {
builder.setNat64PrefixId(prefixId);
// Find the nat instance IDs (vrf-ids) by listing all static mappings and their VRF assignment
final List<NatInstanceKey> vrfIds = Stream.concat(
- nat44DumpManager.getDump(id, context.getModificationCache(), null)
+ nat44DumpManager.getDump(id, context.getModificationCache())
.or(new Nat44StaticMappingDetailsReplyDump()).nat44StaticMappingDetails.stream()
.map(detail -> detail.vrfId),
- nat64DumpManager.getDump(id, context.getModificationCache(), null)
+ nat64DumpManager.getDump(id, context.getModificationCache())
.or(new Nat64BibDetailsReplyDump()).nat64BibDetails.stream()
.map(detail -> detail.vrfId))
// V4 (nat44) and V6 (nat64) VRFs in VPP can have the same id. We store them under single nat instance,
private void readPreRoutingNat44(final InstanceIdentifier<C> id, final int index, final B builder,
final ReadContext ctx) throws ReadFailedException {
final Optional<Nat44InterfaceDetailsReplyDump> dump =
- preRoutingNat44DumpMgr.getDump(id, ctx.getModificationCache(), null);
+ preRoutingNat44DumpMgr.getDump(id, ctx.getModificationCache());
dump.or(new Nat44InterfaceDetailsReplyDump()).nat44InterfaceDetails.stream()
.filter(natIfcDetail -> natIfcDetail.swIfIndex == index)
private void readPreRoutingNat64(final InstanceIdentifier<C> id, final int index, final B builder,
final ReadContext ctx) throws ReadFailedException {
final Optional<Nat64InterfaceDetailsReplyDump> dump =
- preRoutingNat64DumpMgr.getDump(id, ctx.getModificationCache(), null);
+ preRoutingNat64DumpMgr.getDump(id, ctx.getModificationCache());
dump.or(new Nat64InterfaceDetailsReplyDump()).nat64InterfaceDetails.stream()
.filter(natIfcDetail -> natIfcDetail.swIfIndex == index)
private void readPostRoutingNat44(final InstanceIdentifier<C> id, final int index, final B builder,
final ReadContext ctx) throws ReadFailedException {
final Optional<Nat44InterfaceOutputFeatureDetailsReplyDump> dump =
- postRoutingNat44DumpMgr.getDump(id, ctx.getModificationCache(), null);
+ postRoutingNat44DumpMgr.getDump(id, ctx.getModificationCache());
dump.or(new Nat44InterfaceOutputFeatureDetailsReplyDump()).nat44InterfaceOutputFeatureDetails
.stream()
package io.fd.hc2vpp.routing.read;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
-
import com.google.common.base.Optional;
import io.fd.hc2vpp.common.translate.util.MultiNamingContext;
import io.fd.hc2vpp.common.translate.util.NamingContext;
@Nonnull final ReadContext readContext) throws ReadFailedException {
final Optional<IpFibDetailsReplyDump> ipv4RoutesDump =
- ipv4RoutesDumpManager.getDump(instanceIdentifier, readContext.getModificationCache(), NO_PARAMS);
+ ipv4RoutesDumpManager.getDump(instanceIdentifier, readContext.getModificationCache());
final String protocolName = instanceIdentifier.firstKeyOf(RoutingProtocol.class).getName();
final int protocolTableId = routingProtocolContext.getIndex(protocolName, readContext.getMappingContext());
final String protocolName = instanceIdentifier.firstKeyOf(RoutingProtocol.class).getName();
final int protocolTableId = routingProtocolContext.getIndex(protocolName, readContext.getMappingContext());
final Optional<IpFibDetailsReplyDump> ipv4RoutesDump =
- ipv4RoutesDumpManager.getDump(instanceIdentifier, readContext.getModificationCache(), NO_PARAMS);
+ ipv4RoutesDumpManager.getDump(instanceIdentifier, readContext.getModificationCache());
if (ipv4RoutesDump.isPresent() && !ipv4RoutesDump.get().ipFibDetails.isEmpty()) {
package io.fd.hc2vpp.routing.read;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
-
import com.google.common.base.Optional;
import io.fd.hc2vpp.common.translate.util.MultiNamingContext;
import io.fd.hc2vpp.common.translate.util.NamingContext;
@Nonnull final ReadContext readContext) throws ReadFailedException {
final Optional<Ip6FibDetailsReplyDump> ipv6RoutesDump =
- ipv6RoutesDumpManager.getDump(instanceIdentifier, readContext.getModificationCache(), NO_PARAMS);
+ ipv6RoutesDumpManager.getDump(instanceIdentifier, readContext.getModificationCache());
final String protocolName = instanceIdentifier.firstKeyOf(RoutingProtocol.class).getName();
final int protocolTableId = routingProtocolContext.getIndex(protocolName, readContext.getMappingContext());
final String protocolName = instanceIdentifier.firstKeyOf(RoutingProtocol.class).getName();
final int protocolTableId = routingProtocolContext.getIndex(protocolName, readContext.getMappingContext());
final Optional<Ip6FibDetailsReplyDump> ipv6RoutesDump =
- ipv6RoutesDumpManager.getDump(instanceIdentifier, readContext.getModificationCache(), NO_PARAMS);
+ ipv6RoutesDumpManager.getDump(instanceIdentifier, readContext.getModificationCache());
if (ipv6RoutesDump.isPresent() && !ipv6RoutesDump.get().ip6FibDetails.isEmpty()) {
package io.fd.hc2vpp.routing.read;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
-
import com.google.common.base.Optional;
import io.fd.hc2vpp.common.translate.util.NamingContext;
import io.fd.hc2vpp.routing.trait.RouteMapper;
private List<Integer> ipv4TableIds(final InstanceIdentifier<RoutingProtocol> instanceIdentifier,
final ModificationCache modificationCache) throws ReadFailedException {
final Optional<IpFibDetailsReplyDump>
- ipv4Routes = ipv4RoutesDumpManager.getDump(instanceIdentifier, modificationCache, NO_PARAMS);
+ ipv4Routes = ipv4RoutesDumpManager.getDump(instanceIdentifier, modificationCache);
if (ipv4Routes.isPresent()) {
return ipv4Routes.get().ipFibDetails.stream()
private List<Integer> ipv6TableIds(final InstanceIdentifier<RoutingProtocol> instanceIdentifier,
final ModificationCache modificationCache) throws ReadFailedException {
final Optional<Ip6FibDetailsReplyDump>
- ipv6Routes = ipv6RoutesDumpManager.getDump(instanceIdentifier, modificationCache, NO_PARAMS);
+ ipv6Routes = ipv6RoutesDumpManager.getDump(instanceIdentifier, modificationCache);
if (ipv6Routes.isPresent()) {
return ipv6Routes.get().ip6FibDetails.stream()
package io.fd.hc2vpp.v3po.interfacesstate;
import static com.google.common.base.Preconditions.checkState;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
import static java.util.Objects.requireNonNull;
import io.fd.hc2vpp.common.translate.util.NamingContext;
final SwInterfaceDetails iface = dumpManager.getInterfaceDetail(id, ctx, ifaceName);
LOG.debug("Interface details for interface: {}, details: {}", ifaceName, iface);
- final BridgeDomainDetailsReplyDump dumpReply = bdDumpManager.getDump(id, ctx.getModificationCache(), NO_PARAMS)
+ final BridgeDomainDetailsReplyDump dumpReply = bdDumpManager.getDump(id, ctx.getModificationCache())
.or(new BridgeDomainDetailsReplyDump());
for (final BridgeDomainDetails bd : dumpReply.bridgeDomainDetails) {
final Optional<BridgeDomainSwIf> bdIfAssignment = getBridgeDomainSwIf(ifaceId, bd);
package io.fd.hc2vpp.v3po.interfacesstate;
import static com.google.common.base.Preconditions.checkState;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
import static java.lang.String.format;
import io.fd.hc2vpp.common.translate.util.FutureJVppCustomizer;
}
LOG.debug("Reading attributes for tap interface: {}", key.getName());
- final SwInterfaceTapDetailsReplyDump reply = tapDumpManager.getDump(id, ctx.getModificationCache(), NO_PARAMS)
+ final SwInterfaceTapDetailsReplyDump reply = tapDumpManager.getDump(id, ctx.getModificationCache())
.or(new SwInterfaceTapDetailsReplyDump());
final Optional<SwInterfaceTapDetails> detail = reply.swInterfaceTapDetails.stream()
package io.fd.hc2vpp.v3po.interfacesstate;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
import static java.lang.String.format;
import io.fd.hc2vpp.common.translate.util.JvppReplyConsumer;
final SwInterfaceVhostUserDetailsReplyDump dump =
- vhostDumpManager.getDump(id, ctx.getModificationCache(), NO_PARAMS)
+ vhostDumpManager.getDump(id, ctx.getModificationCache())
.or(new SwInterfaceVhostUserDetailsReplyDump());
// Relying here that parent InterfaceCustomizer was invoked first to fill in the context with initial ifc mapping
package io.fd.hc2vpp.v3po.interfacesstate.cache;
import static io.fd.hc2vpp.common.translate.util.JvppReplyConsumer.INSTANCE;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
import static java.util.stream.Collectors.toMap;
import io.fd.hc2vpp.common.translate.util.ByteDataTranslator;
if (!cache.containsKey(BY_NAME_INDEX_KEY)) {
LOG.debug("Performing dump[{}]", identifier);
final SwInterfaceDetailsReplyDump dump =
- fullDumpManager.getDump(identifier, cache, NO_PARAMS)
+ fullDumpManager.getDump(identifier, cache)
.or(new SwInterfaceDetailsReplyDump());
// naming context initialization must be done here, as it is uses getName in next step, therefore it would
package io.fd.hc2vpp.policer.read;
-import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
-
import com.google.common.base.Optional;
import com.google.common.primitives.Longs;
import com.google.common.primitives.UnsignedInts;
@Override
public List<PolicerKey> getAllIds(@Nonnull final InstanceIdentifier<Policer> id,
@Nonnull final ReadContext ctx) throws ReadFailedException {
- final Optional<PolicerDetailsReplyDump> dump = dumpManager.getDump(id, ctx.getModificationCache(), NO_PARAMS);
+ final Optional<PolicerDetailsReplyDump> dump = dumpManager.getDump(id, ctx.getModificationCache());
if (!dump.isPresent() || dump.get().policerDetails.isEmpty()) {
return Collections.emptyList();
public void readCurrentAttributes(@Nonnull final InstanceIdentifier<Policer> id,
@Nonnull final PolicerBuilder builder,
@Nonnull final ReadContext ctx) throws ReadFailedException {
- final Optional<PolicerDetailsReplyDump> dump = dumpManager.getDump(id, ctx.getModificationCache(), NO_PARAMS);
+ final Optional<PolicerDetailsReplyDump> dump = dumpManager.getDump(id, ctx.getModificationCache());
if (!dump.isPresent() || dump.get().policerDetails.isEmpty()) {
return;