summaryrefslogtreecommitdiff
path: root/src/main/java
diff options
context:
space:
mode:
authorBrian S. O'Neill <bronee@gmail.com>2008-07-23 20:04:09 +0000
committerBrian S. O'Neill <bronee@gmail.com>2008-07-23 20:04:09 +0000
commitccb7ca2b0d7bde5a2577b373eb289887bb25c58a (patch)
tree42458650e9f56584c4ce9e3b5685d2dbf14e17d1 /src/main/java
parentd4828dc3206fd3592640af31fe878d42e2b9e574 (diff)
Repair unmatched replica without rolling back.
Diffstat (limited to 'src/main/java')
-rw-r--r--src/main/java/com/amazon/carbonado/repo/replicated/ReplicationTrigger.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/main/java/com/amazon/carbonado/repo/replicated/ReplicationTrigger.java b/src/main/java/com/amazon/carbonado/repo/replicated/ReplicationTrigger.java
index 8cf7007..0b9770f 100644
--- a/src/main/java/com/amazon/carbonado/repo/replicated/ReplicationTrigger.java
+++ b/src/main/java/com/amazon/carbonado/repo/replicated/ReplicationTrigger.java
@@ -152,7 +152,7 @@ class ReplicationTrigger<S extends Storable> extends Trigger<S> {
if (!master.tryUpdate()) {
// Master record does not exist. To ensure consistency,
// delete record from replica.
- tryDeleteReplica(replica);
+ repair(replica);
throw abortTry();
}
} else {
@@ -161,7 +161,7 @@ class ReplicationTrigger<S extends Storable> extends Trigger<S> {
} catch (PersistNoneException e) {
// Master record does not exist. To ensure consistency,
// delete record from replica.
- tryDeleteReplica(replica);
+ repair(replica);
throw e;
}
}