diff options
author | Wiktor Garbarek <wiktor.garbarek@nokia.com> | 2018-07-09 15:18:19 +0200 |
---|---|---|
committer | Wiktor Garbarek <wiktor.garbarek@nokia.com> | 2018-07-09 15:18:19 +0200 |
commit | 29a772f710bd05bcf1a6a3da9af9b198bc003482 (patch) | |
tree | efc470c4106b84fb52b3d487c9e2c283038e32b1 /champ-lib/champ-titan | |
parent | bce8bc8383c3f19b64b360a941ec1b1503791c85 (diff) |
Fix handling of InterruptedException in AAI-Champ
Added thread interrupts
Change-Id: Ic5b7eef71354efd02736e88a1e6716aa84169898
Issue-ID: AAI-1367
Signed-off-by: Wiktor Garbarek <wiktor.garbarek@nokia.com>
Diffstat (limited to 'champ-lib/champ-titan')
-rw-r--r-- | champ-lib/champ-titan/src/main/java/org/onap/aai/champtitan/graph/impl/TitanChampGraphImpl.java | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/champ-lib/champ-titan/src/main/java/org/onap/aai/champtitan/graph/impl/TitanChampGraphImpl.java b/champ-lib/champ-titan/src/main/java/org/onap/aai/champtitan/graph/impl/TitanChampGraphImpl.java index f3d821c..209bf79 100644 --- a/champ-lib/champ-titan/src/main/java/org/onap/aai/champtitan/graph/impl/TitanChampGraphImpl.java +++ b/champ-lib/champ-titan/src/main/java/org/onap/aai/champtitan/graph/impl/TitanChampGraphImpl.java @@ -362,6 +362,7 @@ public final class TitanChampGraphImpl extends AbstractTinkerpopChampGraph { } } catch (InterruptedException e) { LOGGER.warn("Interrupted while waiting for object index creation status"); + Thread.currentThread().interrupt(); return; } @@ -373,6 +374,7 @@ public final class TitanChampGraphImpl extends AbstractTinkerpopChampGraph { updateIndexMgmt.commit(); } catch (InterruptedException e) { LOGGER.warn("Interrupted while reindexing for object index"); + Thread.currentThread().interrupt(); return; } catch (ExecutionException e) { LOGGER.warn("Exception occurred during reindexing procedure for creating object index " + indexName, e); @@ -385,6 +387,7 @@ public final class TitanChampGraphImpl extends AbstractTinkerpopChampGraph { .call(); } catch (InterruptedException e) { LOGGER.warn("Interrupted while waiting for index to transition to ENABLED state"); + Thread.currentThread().interrupt(); return; } } |