X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=pcep%2Ftopology-provider%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fbgpcep%2Fpcep%2Ftopology%2Fprovider%2FStateful07TopologySessionListener.java;h=4cbe6830c140c0e439006b9024e865c9b3fec26f;hb=da432867d3ce41ceab426b1ef546d247a1222078;hp=7ce02e810086d07a2099c4b69557a7c837550bfa;hpb=48da049ff2ab821e23af2ad444b74ce7e9cb84be;p=bgpcep.git diff --git a/pcep/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/Stateful07TopologySessionListener.java b/pcep/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/Stateful07TopologySessionListener.java index 7ce02e8100..4cbe6830c1 100644 --- a/pcep/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/Stateful07TopologySessionListener.java +++ b/pcep/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/Stateful07TopologySessionListener.java @@ -205,8 +205,8 @@ class Stateful07TopologySessionListener extends AbstractTopologySessionListener< } private void markAllLspAsStale() { - for (final PlspId plspId : lsps.keySet()) { - staleLsps.add(plspId); + for (final PlspId plspId : this.lsps.keySet()) { + this.staleLsps.add(plspId); } } @@ -229,7 +229,7 @@ class Stateful07TopologySessionListener extends AbstractTopologySessionListener< if (!staleLsp.getPath().isEmpty()) { final Path1 path1 = staleLsp.getPath().get(0).getAugmentation(Path1.class); if (path1 != null) { - staleLsps.add(path1.getLsp().getPlspId()); + Stateful07TopologySessionListener.this.staleLsps.add(path1.getLsp().getPlspId()); } } updatePccState(PccSyncState.PcepTriggeredResync); @@ -735,7 +735,7 @@ class Stateful07TopologySessionListener extends AbstractTopologySessionListener< if (path1 != null) { final PlspId plspId = path1.getLsp().getPlspId(); if (!incrementalSynchro) { - staleLsps.add(plspId); + this.staleLsps.add(plspId); } lsps.put(plspId, lspName); } @@ -750,7 +750,7 @@ class Stateful07TopologySessionListener extends AbstractTopologySessionListener< * @param plspId */ private synchronized void unmarkStaleLsp(final PlspId plspId) { - staleLsps.remove(plspId); + this.staleLsps.remove(plspId); } /** @@ -758,9 +758,9 @@ class Stateful07TopologySessionListener extends AbstractTopologySessionListener< * @param ctx */ private synchronized void purgeStaleLsps(final MessageContext ctx) { - for (final PlspId plspId : staleLsps) { + for (final PlspId plspId : this.staleLsps) { removeLsp(ctx, plspId); } - staleLsps.clear(); + this.staleLsps.clear(); } }