summaryrefslogtreecommitdiffstats
path: root/sdnr/wt/netconfnode-state-service
diff options
context:
space:
mode:
authorherbert <herbert.eiselt@highstreet-technologies.com>2020-05-18 16:07:04 +0200
committerHerbert Eiselt <herbert.eiselt@highstreet-technologies.com>2020-05-18 14:15:01 +0000
commit2c6b92b339477b134b9d4d5825431e00572887a3 (patch)
tree7dd4ee38670c342ebb88d4754f32a283f5811687 /sdnr/wt/netconfnode-state-service
parent133677a0626ad01db8c8c949bce862dad04e35b8 (diff)
Fix Cluster AkaTimeoutException
Issue-ID: SDNC-1191 Signed-off-by: herbert <herbert.eiselt@highstreet-technologies.com> Change-Id: I7a85d66778f6b278d960257d4d8664ec8605253e
Diffstat (limited to 'sdnr/wt/netconfnode-state-service')
-rw-r--r--sdnr/wt/netconfnode-state-service/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/netconfnodestateservice/impl/GenericTransactionUtils.java15
1 files changed, 10 insertions, 5 deletions
diff --git a/sdnr/wt/netconfnode-state-service/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/netconfnodestateservice/impl/GenericTransactionUtils.java b/sdnr/wt/netconfnode-state-service/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/netconfnodestateservice/impl/GenericTransactionUtils.java
index 93f230a23..6a811ea59 100644
--- a/sdnr/wt/netconfnode-state-service/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/netconfnodestateservice/impl/GenericTransactionUtils.java
+++ b/sdnr/wt/netconfnode-state-service/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/netconfnodestateservice/impl/GenericTransactionUtils.java
@@ -92,7 +92,7 @@ public final class GenericTransactionUtils implements TransactionUtils {
int retry = 0;
int retryDelayMilliseconds = 2000;
- int maxRetries = 5; // 0 no Retry
+ int maxRetries = 0; // 0 no Retry
do {
if (retry > 0) {
@@ -107,8 +107,8 @@ public final class GenericTransactionUtils implements TransactionUtils {
LOG.debug("Sending message with retry {} ", retry);
statusIndicator.set("Create Read Transaction");
-
- try (ReadTransaction readTransaction = dataBroker.newReadOnlyTransaction();) {
+ ReadTransaction readTransaction = dataBroker.newReadOnlyTransaction();
+ try {
@NonNull FluentFuture<Optional<T>> od = readTransaction.read(dataStoreType, iid);
statusIndicator.set("Read done");
if (od != null) {
@@ -119,19 +119,24 @@ public final class GenericTransactionUtils implements TransactionUtils {
data = optionalData.orElse(null);
statusIndicator.set("Read transaction done");
noErrorIndication.set(true);
+ } else {
+ statusIndicator.set("optional Data is null");
}
+ } else {
+ statusIndicator.set("od feature is null");
}
-
- readTransaction.close();
} catch (CancellationException | ExecutionException | InterruptedException | NoSuchElementException e) {
statusIndicator.set(StackTrace.toString(e));
if (e instanceof InterruptedException) {
Thread.currentThread().interrupt();
}
+ LOG.debug("Exception during read", e);
}
} while (noErrorIndication.get() == false && retry++ < maxRetries);
+ LOG.debug("stage 2 noErrorIndication {} status text {}", noErrorIndication.get(), statusIndicator.get());
+
return data;
}