summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
561058b)
Change-Id: I2ef68b48de8da4cc7d82a91263976295458d011a
Signed-off-by: Tom Pantelis <tpanteli@brocade.com>
// Gracefully stop the leader via a Shutdown message.
// Gracefully stop the leader via a Shutdown message.
+ sendDatastoreContextUpdate(leaderDistributedDataStore, leaderDatastoreContextBuilder.
+ shardElectionTimeoutFactor(100));
+
FiniteDuration duration = FiniteDuration.create(5, TimeUnit.SECONDS);
Future<ActorRef> future = leaderDistributedDataStore.getActorContext().findLocalShardAsync("cars");
ActorRef leaderActor = Await.result(future, duration);
FiniteDuration duration = FiniteDuration.create(5, TimeUnit.SECONDS);
Future<ActorRef> future = leaderDistributedDataStore.getActorContext().findLocalShardAsync("cars");
ActorRef leaderActor = Await.result(future, duration);
@Override
public void onReceive(Object message) {
if(CanCommitTransaction.isSerializedType(message)) {
@Override
public void onReceive(Object message) {
if(CanCommitTransaction.isSerializedType(message)) {
+ canCommitCount.incrementAndGet();
onMessage("CanCommitTransaction", message, CanCommitTransaction.fromSerializable(message),
builder.expCanCommitType, builder.canCommitReply);
onMessage("CanCommitTransaction", message, CanCommitTransaction.fromSerializable(message),
builder.expCanCommitType, builder.canCommitReply);
- canCommitCount.incrementAndGet();
} else if(CommitTransaction.isSerializedType(message)) {
} else if(CommitTransaction.isSerializedType(message)) {
+ commitCount.incrementAndGet();
onMessage("CommitTransaction", message, CommitTransaction.fromSerializable(message),
builder.expCommitType, builder.commitReply);
onMessage("CommitTransaction", message, CommitTransaction.fromSerializable(message),
builder.expCommitType, builder.commitReply);
- commitCount.incrementAndGet();
} else if(AbortTransaction.isSerializedType(message)) {
} else if(AbortTransaction.isSerializedType(message)) {
+ abortCount.incrementAndGet();
onMessage("AbortTransaction", message, AbortTransaction.fromSerializable(message),
builder.expAbortType, builder.abortReply);
onMessage("AbortTransaction", message, AbortTransaction.fromSerializable(message),
builder.expAbortType, builder.abortReply);
- abortCount.incrementAndGet();
} else {
assertionError = new AssertionError("Unexpected message " + message);
}
} else {
assertionError = new AssertionError("Unexpected message " + message);
}