static final QName ID_INTS =
QName.create("tag:opendaylight.org,2017:controller:yang:lowlevel:target", "2017-02-15", "id-ints");
- static final QName ID_INT =
+ public static final QName ID_INT =
QName.create("tag:opendaylight.org,2017:controller:yang:lowlevel:target", "2017-02-15", "id-int");
static final QName ID =
QName.create("tag:opendaylight.org,2017:controller:yang:lowlevel:target", "2017-02-15", "id");
cursor.close();
try {
- tx.submit().checkedGet();
- } catch (final TransactionCommitFailedException e) {
+ tx.submit().checkedGet(125, TimeUnit.SECONDS);
+ } catch (final TransactionCommitFailedException | TimeoutException e) {
LOG.warn("Unable to fill the initial item list.", e);
settableFuture.set(RpcResultBuilder.<ProduceTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", e).build());
+
+ try {
+ itemProducer.close();
+ } catch (final DOMDataTreeProducerException exception) {
+ LOG.warn("Failure while closing producer.", exception);
+ }
return false;
}
final ListenableFuture<List<Void>> allFutures = Futures.allAsList(futures);
try {
- allFutures.get(30, TimeUnit.SECONDS);
+ // Timeout from cds should be 2 minutes so leave some leeway.
+ allFutures.get(125, TimeUnit.SECONDS);
LOG.debug("All futures completed successfully.");