- public void mergeData(YangInstanceIdentifier path, NormalizedNode<?, ?> data) {
- LOG.debug("Tx {} mergeData called path = {}", getIdentifier(), path);
- operationLimiter.release();
+ public <T> void executeRead(final AbstractRead<T> readCmd, final SettableFuture<T> proxyFuture,
+ final Boolean havePermit) {
+ LOG.debug("Tx {} executeRead {} called path = {}", getIdentifier(), readCmd.getClass().getSimpleName(),
+ readCmd.getPath());
+
+ final Throwable t;
+ if (failure instanceof NoShardLeaderException) {
+ t = new DataStoreUnavailableException(failure.getMessage(), failure);
+ } else {
+ t = failure;
+ }
+ proxyFuture.setException(new ReadFailedException("Error executeRead " + readCmd.getClass().getSimpleName()
+ + " for path " + readCmd.getPath(), t));