- private static void verifyGetOwnershipState(DistributedEntityOwnershipService service, Entity entity,
- boolean isOwner, boolean hasOwner) {
- Optional<EntityOwnershipState> state = service.getOwnershipState(entity);
- assertEquals("getOwnershipState present", true, state.isPresent());
- assertEquals("isOwner", isOwner, state.get().isOwner());
- assertEquals("hasOwner", hasOwner, state.get().hasOwner());
- }
-
- private void verifyEntityCandidate(ActorRef entityOwnershipShard, String entityType,
- YangInstanceIdentifier entityId, String candidateName) {
- verifyEntityCandidate(entityType, entityId, candidateName,
- new Function<YangInstanceIdentifier, NormalizedNode<?,?>>() {
- @Override
- public NormalizedNode<?, ?> apply(YangInstanceIdentifier path) {
- try {
- return dataStore.newReadOnlyTransaction().read(path).get(5, TimeUnit.SECONDS).get();
- } catch (Exception e) {
- return null;
- }
- }
- });
- }
-
- private static void verifyRegisterCandidateLocal(final TestShardBuilder shardBuilder, Entity entity) {
- RegisterCandidateLocal regCandidate = shardBuilder.waitForShardMessage();
- assertEquals("getEntity", entity, regCandidate.getEntity());
- }
+ @Test
+ public void testIsCandidateRegistered() throws CandidateAlreadyRegisteredException {
+ DistributedEntityOwnershipService service = DistributedEntityOwnershipService.start(dataStore.getActorContext(),
+ EntityOwnerSelectionStrategyConfig.newBuilder().build());