import org.opendaylight.controller.cluster.raft.utils.DoNothingActor;
import org.opendaylight.controller.md.cluster.datastore.model.CarsModel;
import org.opendaylight.controller.md.cluster.datastore.model.TestModel;
import org.opendaylight.controller.cluster.raft.utils.DoNothingActor;
import org.opendaylight.controller.md.cluster.datastore.model.CarsModel;
import org.opendaylight.controller.md.cluster.datastore.model.TestModel;
import org.opendaylight.mdsal.common.api.ReadFailedException;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
import org.opendaylight.mdsal.common.api.ReadFailedException;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
public String findShard(final YangInstanceIdentifier path) {
return TestModel.JUNK_QNAME.getLocalName();
}
public String findShard(final YangInstanceIdentifier path) {
return TestModel.JUNK_QNAME.getLocalName();
}
}).put(
CarsModel.BASE_QNAME.getLocalName(), new ShardStrategy() {
@Override
public String findShard(final YangInstanceIdentifier path) {
return CarsModel.BASE_QNAME.getLocalName();
}
}).put(
CarsModel.BASE_QNAME.getLocalName(), new ShardStrategy() {
@Override
public String findShard(final YangInstanceIdentifier path) {
return CarsModel.BASE_QNAME.getLocalName();
}
doReturn(getSystem()).when(mockActorContext).getActorSystem();
doReturn(getSystem().dispatchers().defaultGlobalDispatcher()).when(mockActorContext).getClientDispatcher();
doReturn(MemberName.forName(memberName)).when(mockActorContext).getCurrentMemberName();
doReturn(getSystem()).when(mockActorContext).getActorSystem();
doReturn(getSystem().dispatchers().defaultGlobalDispatcher()).when(mockActorContext).getClientDispatcher();
doReturn(MemberName.forName(memberName)).when(mockActorContext).getCurrentMemberName();
doReturn(SCHEMA_CONTEXT).when(mockActorContext).getSchemaContext();
doReturn(new Timeout(operationTimeoutInSeconds, TimeUnit.SECONDS)).when(mockActorContext).getOperationTimeout();
doReturn(mockClusterWrapper).when(mockActorContext).getClusterWrapper();
doReturn(SCHEMA_CONTEXT).when(mockActorContext).getSchemaContext();
doReturn(new Timeout(operationTimeoutInSeconds, TimeUnit.SECONDS)).when(mockActorContext).getOperationTimeout();
doReturn(mockClusterWrapper).when(mockActorContext).getClusterWrapper();
final TransactionType type) {
class CreateTransactionArgumentMatcher implements ArgumentMatcher<CreateTransaction> {
@Override
final TransactionType type) {
class CreateTransactionArgumentMatcher implements ArgumentMatcher<CreateTransaction> {
@Override
return argument.getTransactionId().getHistoryId().getClientId().getFrontendId().getMemberName()
.getName().equals(expMemberName) && argument.getTransactionType() == type.ordinal();
}
return argument.getTransactionId().getHistoryId().getClientId().getFrontendId().getMemberName()
.getName().equals(expMemberName) && argument.getTransactionType() == type.ordinal();
}
protected DataExists eqDataExists() {
class DataExistsArgumentMatcher implements ArgumentMatcher<DataExists> {
@Override
protected DataExists eqDataExists() {
class DataExistsArgumentMatcher implements ArgumentMatcher<DataExists> {
@Override
protected ReadData eqReadData(final YangInstanceIdentifier path) {
class ReadDataArgumentMatcher implements ArgumentMatcher<ReadData> {
@Override
protected ReadData eqReadData(final YangInstanceIdentifier path) {
class ReadDataArgumentMatcher implements ArgumentMatcher<ReadData> {
@Override
- && CommitTransactionReply.isSerializedType(actual)) {
- found = true;
- } else if (expReply instanceof ActorSelection && Objects.equals(expReply, actual)) {
+ && CommitTransactionReply.isSerializedType(actual)
+ || expReply instanceof ActorSelection && Objects.equals(expReply, actual)) {