- return Matchers.argThat(new ArgumentMatcher<EntityOwnershipChange>() {
- @Override
- public boolean matches(Object argument) {
- EntityOwnershipChange change = (EntityOwnershipChange) argument;
- return expEntity.equals(change.getEntity()) && expWasOwner == change.wasOwner() &&
- expIsOwner == change.isOwner() && expHasOwner == change.hasOwner();
+ return ownershipChange(expEntity, expWasOwner, expIsOwner, expHasOwner, false);
+ }
+
+ static DOMEntityOwnershipChange ownershipChange(final DOMEntity expEntity, final boolean expWasOwner,
+ final boolean expIsOwner, final boolean expHasOwner, final boolean expInJeopardy) {
+ return argThat(change -> expEntity.equals(change.getEntity()) && expWasOwner == change.getState().wasOwner()
+ && expIsOwner == change.getState().isOwner() && expHasOwner == change.getState().hasOwner()
+ && expInJeopardy == change.inJeopardy());
+ }
+
+ static DOMEntityOwnershipChange ownershipChange(final DOMEntity expEntity) {
+ return argThat(change -> expEntity.equals(change.getEntity()));
+ }
+
+ @SuppressWarnings("checkstyle:IllegalCatch")
+ static void verifyNoOwnerSet(final TestActorRef<? extends EntityOwnershipShard> shard, final String entityType,
+ final YangInstanceIdentifier entityId) {
+ YangInstanceIdentifier entityPath = entityPath(entityType, entityId).node(ENTITY_OWNER_QNAME);
+ try {
+ NormalizedNode<?, ?> node = AbstractShardTest.readStore(shard, entityPath);
+ if (node != null) {
+ Assert.fail("Owner " + node.getValue() + " was set for " + entityPath);