BGPCEP-766: Reduce synchornization

under AbstractTopologySessionListener

Change-Id: I99efef02cef6f9af761c73d57bb4b37e50177830
Signed-off-by: Claudio D. Gasparini <claudio.gasparini@pantheon.tech>

diff --git a/pcep/topology/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/AbstractTopologySessionListener.java b/pcep/topology/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/AbstractTopologySessionListener.java
index cdb6212d461bc6ab8fd30d246d9e60752f315a7d..e4eea25bd3958d1817d644d71186b081c8eab771 100755 (executable)
--- a/pcep/topology/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/AbstractTopologySessionListener.java
+++ b/pcep/topology/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/AbstractTopologySessionListener.java
@@ -285,19 +285,16 @@ public abstract class AbstractTopologySessionListener<S, L> implements TopologyS
         Futures.addCallback(ctx.trans.submit(), new FutureCallback<Void>() {
             @Override
             public void onSuccess(final Void result) {
-                synchronized (AbstractTopologySessionListener.this) {
-                    LOG.trace("Internal state for session {} updated successfully", psession);
-                    ctx.notifyRequests();
-                }
+                LOG.trace("Internal state for session {} updated successfully", psession);
+                ctx.notifyRequests();
+
             }
 
             @Override
             public void onFailure(final Throwable throwable) {
-                synchronized (AbstractTopologySessionListener.this) {
-                    LOG.error("Failed to update internal state for session {}, closing it", psession, throwable);
-                    ctx.notifyRequests();
-                    psession.close(TerminationReason.UNKNOWN);
-                }
+                LOG.error("Failed to update internal state for session {}, closing it", psession, throwable);
+                ctx.notifyRequests();
+                psession.close(TerminationReason.UNKNOWN);
             }
         }, MoreExecutors.directExecutor());
     }