Remove deadlock scenario in ListenersBroker

[netconf.git] / restconf / restconf-nb-rfc8040 / src / main / java / org / opendaylight / restconf / nb / rfc8040 / streams / listeners / ListenersBroker.java

diff --git a/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/streams/listeners/ListenersBroker.java b/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/streams/listeners/ListenersBroker.java
index 85a6569100d8951315e62820b37fac13bce126f5..d751207d5190c45aeff2e00ae7541b526d5c2ee3 100644 (file)
--- a/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/streams/listeners/ListenersBroker.java
+++ b/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/streams/listeners/ListenersBroker.java
@@ -271,7 +271,6 @@ public final class ListenersBroker {
      */
     @SuppressWarnings("checkstyle:IllegalCatch")
     private void removeAndCloseDataChangeListenerTemplate(final ListenerAdapter listener) {
-        final long stamp = dataChangeListenersLock.writeLock();
         try {
             requireNonNull(listener).close();
             if (dataChangeListeners.inverse().remove(listener) == null) {
@@ -282,8 +281,6 @@ public final class ListenersBroker {
             throw new IllegalStateException(String.format(
                     "Data-change listener %s cannot be closed.",
                     listener), exception);
-        } finally {
-            dataChangeListenersLock.unlockWrite(stamp);
         }
     }