From: Tschaen, Brendan Date: Thu, 14 Mar 2019 21:03:27 +0000 (-0400) Subject: Shutdown hook logic X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=refs%2Fchanges%2F07%2F82307%2F1;p=music%2Fmdbc.git Shutdown hook logic Release connections and partitions owned by this server instance Change-Id: I293705b0d212fcba7e6f80678dee70130a8abe25 Issue-ID: MUSIC-361 Signed-off-by: Tschaen, Brendan --- diff --git a/mdbc-server/src/main/java/org/onap/music/mdbc/MdbcServer.java b/mdbc-server/src/main/java/org/onap/music/mdbc/MdbcServer.java index 08f6e1e..1712c30 100755 --- a/mdbc-server/src/main/java/org/onap/music/mdbc/MdbcServer.java +++ b/mdbc-server/src/main/java/org/onap/music/mdbc/MdbcServer.java @@ -103,6 +103,7 @@ public class MdbcServer { public void stop() { if (null != server) { + meta.getStateManager().releaseAllPartitions(); server.stop(); server = null; } diff --git a/mdbc-server/src/main/java/org/onap/music/mdbc/StateManager.java b/mdbc-server/src/main/java/org/onap/music/mdbc/StateManager.java index 8e7976f..430e783 100644 --- a/mdbc-server/src/main/java/org/onap/music/mdbc/StateManager.java +++ b/mdbc-server/src/main/java/org/onap/music/mdbc/StateManager.java @@ -344,4 +344,13 @@ public class StateManager { public OwnershipAndCheckpoint getOwnAndCheck() { return ownAndCheck; } + + /** + * Close all connections for this server, relinquishing any locks/partitions owned by this server + */ + public void releaseAllPartitions() { + for(String connection: this.connectionRanges.keySet()) { + closeConnection(connection); + } + } }