import org.opendaylight.controller.cluster.databroker.actors.dds.ClientTransaction;
import org.opendaylight.controller.cluster.databroker.actors.dds.DataStoreClient;
import org.opendaylight.controller.cluster.datastore.utils.ClusterUtils;
-import org.opendaylight.mdsal.common.api.ReadFailedException;
import org.opendaylight.mdsal.dom.api.DOMDataTreeWriteCursor;
import org.opendaylight.mdsal.dom.spi.store.DOMStoreThreePhaseCommitCohort;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
* by {@link DistributedShardedDOMDataTree} for updating
* prefix-shard-configuration upon creating and de-spawning prefix-based shards.
*/
+@Deprecated(forRemoval = true)
class PrefixedShardConfigWriter {
private static final Logger LOG = LoggerFactory.getLogger(PrefixedShardConfigWriter.class);
boolean checkDefaultIsPresent() {
final NodeIdentifierWithPredicates pag =
- new NodeIdentifierWithPredicates(ClusterUtils.SHARD_LIST_QNAME, ClusterUtils.SHARD_PREFIX_QNAME,
- YangInstanceIdentifier.EMPTY);
+ NodeIdentifierWithPredicates.of(ClusterUtils.SHARD_LIST_QNAME, ClusterUtils.SHARD_PREFIX_QNAME,
+ YangInstanceIdentifier.empty());
final YangInstanceIdentifier defaultId = ClusterUtils.SHARD_LIST_PATH.node(pag);
final ClientSnapshot snapshot = history.takeSnapshot();
try {
- return snapshot.exists(defaultId).checkedGet();
- } catch (final ReadFailedException e) {
+ return snapshot.exists(defaultId).get();
+ } catch (InterruptedException | ExecutionException e) {
LOG.error("Presence check of default shard in configuration failed.", e);
return false;
} finally {
final MapEntryNode newEntry = ImmutableMapEntryNodeBuilder.create()
.withNodeIdentifier(
- new NodeIdentifierWithPredicates(ClusterUtils.SHARD_LIST_QNAME, ClusterUtils.SHARD_PREFIX_QNAME,
+ NodeIdentifierWithPredicates.of(ClusterUtils.SHARD_LIST_QNAME, ClusterUtils.SHARD_PREFIX_QNAME,
path))
.withChild(ImmutableLeafNodeBuilder.create()
.withNodeIdentifier(new NodeIdentifier(ClusterUtils.SHARD_PREFIX_QNAME))
ClusterUtils.SHARD_LIST_PATH.getPathArguments().forEach(cursor::enter);
cursor.delete(
- new NodeIdentifierWithPredicates(ClusterUtils.SHARD_LIST_QNAME, ClusterUtils.SHARD_PREFIX_QNAME, path));
+ NodeIdentifierWithPredicates.of(ClusterUtils.SHARD_LIST_QNAME, ClusterUtils.SHARD_PREFIX_QNAME, path));
cursor.close();
return tx.ready();