diff options
author | Jan Srnicek <jsrnicek@cisco.com> | 2017-04-24 09:39:59 +0200 |
---|---|---|
committer | Marek Gradzki <mgradzki@cisco.com> | 2017-04-24 08:07:47 +0000 |
commit | 470588683af86c9ab73538ced85e1d88f55e3b70 (patch) | |
tree | 127211cd95071b425ec5e4836cccf7f45e70fe6c /lisp/lisp2vpp/src/main/java/io/fd/hc2vpp/lisp/translate/read/MapServerCustomizer.java | |
parent | e4139584aaf94df71a4ddb5e5a0dded1a80c249d (diff) |
HC2VPP-124 - Post lisp apis to one***
All apis starting with prefix lisp*** will be abandoned, so refactoring
to one*** variants
Change-Id: I603b3ce54ef1f8b6cefaaccedb87ccbf3ea38dd0
Signed-off-by: Jan Srnicek <jsrnicek@cisco.com>
Diffstat (limited to 'lisp/lisp2vpp/src/main/java/io/fd/hc2vpp/lisp/translate/read/MapServerCustomizer.java')
-rw-r--r-- | lisp/lisp2vpp/src/main/java/io/fd/hc2vpp/lisp/translate/read/MapServerCustomizer.java | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/lisp/lisp2vpp/src/main/java/io/fd/hc2vpp/lisp/translate/read/MapServerCustomizer.java b/lisp/lisp2vpp/src/main/java/io/fd/hc2vpp/lisp/translate/read/MapServerCustomizer.java index bd4c0ba5d..26e193a98 100644 --- a/lisp/lisp2vpp/src/main/java/io/fd/hc2vpp/lisp/translate/read/MapServerCustomizer.java +++ b/lisp/lisp2vpp/src/main/java/io/fd/hc2vpp/lisp/translate/read/MapServerCustomizer.java @@ -30,9 +30,9 @@ import io.fd.honeycomb.translate.spi.read.InitializingListReaderCustomizer; import io.fd.honeycomb.translate.util.RWUtils; import io.fd.honeycomb.translate.util.read.cache.DumpCacheManager; import io.fd.honeycomb.translate.util.read.cache.DumpCacheManager.DumpCacheManagerBuilder; -import io.fd.vpp.jvpp.core.dto.LispMapServerDetails; -import io.fd.vpp.jvpp.core.dto.LispMapServerDetailsReplyDump; -import io.fd.vpp.jvpp.core.dto.LispMapServerDump; +import io.fd.vpp.jvpp.core.dto.OneMapServerDetails; +import io.fd.vpp.jvpp.core.dto.OneMapServerDetailsReplyDump; +import io.fd.vpp.jvpp.core.dto.OneMapServerDump; import io.fd.vpp.jvpp.core.future.FutureJVppCore; import java.util.Arrays; import java.util.Collections; @@ -59,16 +59,16 @@ public class MapServerCustomizer extends CheckedLispCustomizer private static final Logger LOG = LoggerFactory.getLogger(MapServerCustomizer.class); - private final DumpCacheManager<LispMapServerDetailsReplyDump, Void> dumpManager; + private final DumpCacheManager<OneMapServerDetailsReplyDump, Void> dumpManager; public MapServerCustomizer(@Nonnull final FutureJVppCore futureJVppCore, @Nonnull final LispStateCheckService lispStateCheckService) { super(futureJVppCore, lispStateCheckService); - dumpManager = new DumpCacheManagerBuilder<LispMapServerDetailsReplyDump, Void>() - .acceptOnly(LispMapServerDetailsReplyDump.class) + dumpManager = new DumpCacheManagerBuilder<OneMapServerDetailsReplyDump, Void>() + .acceptOnly(OneMapServerDetailsReplyDump.class) .withExecutor((instanceIdentifier, aVoid) -> getReplyForRead(getFutureJVpp() - .lispMapServerDump(new LispMapServerDump()).toCompletableFuture(), instanceIdentifier)) + .oneMapServerDump(new OneMapServerDump()).toCompletableFuture(), instanceIdentifier)) .build(); } @@ -94,11 +94,11 @@ public class MapServerCustomizer extends CheckedLispCustomizer return Collections.emptyList(); } - final Optional<LispMapServerDetailsReplyDump> dump = + final Optional<OneMapServerDetailsReplyDump> dump = dumpManager.getDump(instanceIdentifier, readContext.getModificationCache(), NO_PARAMS); - if (dump.isPresent() && dump.get().lispMapServerDetails != null) { - return dump.get().lispMapServerDetails.stream() + if (dump.isPresent() && dump.get().oneMapServerDetails != null) { + return dump.get().oneMapServerDetails.stream() .map(detail -> arrayToIpAddress(byteToBoolean(detail.isIpv6), detail.ipAddress)) .map(MapServerKey::new) .collect(Collectors.toList()); @@ -126,13 +126,13 @@ public class MapServerCustomizer extends CheckedLispCustomizer LOG.info("Lisp feature must be enabled first"); return; } - final Optional<LispMapServerDetailsReplyDump> dump = + final Optional<OneMapServerDetailsReplyDump> dump = dumpManager.getDump(instanceIdentifier, readContext.getModificationCache(), NO_PARAMS); - if (dump.isPresent() && dump.get().lispMapServerDetails != null) { + if (dump.isPresent() && dump.get().oneMapServerDetails != null) { final IpAddress currentAddress = instanceIdentifier.firstKeyOf(MapServer.class).getIpAddress(); - final LispMapServerDetails currentDetail = dump.get().lispMapServerDetails.stream() + final OneMapServerDetails currentDetail = dump.get().oneMapServerDetails.stream() .filter(detail -> Arrays.equals(currentAddress.getValue(), arrayToIpAddress(byteToBoolean(detail.isIpv6), detail.ipAddress).getValue())) .collect(RWUtils.singleItemCollector()); |