QPID-3603: Introduced RemoteBackup to track backup status.

The primary creates RemoteBackup object for each connected or expected
backup. On first being promoted, the new primary has a RemoteBackup
for each of the known backups at the time of the failure.

The RemoteBackup manages queue guards for its backup and
tracks it's readiness.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1349540 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 11 insertions, 6 deletions

diff --git a/cpp/src/qpid/ha/ReplicationTest.cpp b/cpp/src/qpid/ha/ReplicationTest.cpp
index 1db101dc94..613ac0a8c6 100644
--- a/cpp/src/qpid/ha/ReplicationTest.cpp
+++ b/cpp/src/qpid/ha/ReplicationTest.cpp
@@ -52,18 +52,23 @@ namespace {
 const std::string AUTO_DELETE_TIMEOUT("qpid.auto_delete_timeout");
 }
 
-bool ReplicationTest::isReplicated(const Variant::Map& args, bool autodelete, bool exclusive) {
+bool ReplicationTest::isReplicated(
+    ReplicateLevel level, const Variant::Map& args, bool autodelete, bool exclusive)
+{
     bool ignore = autodelete && exclusive && args.find(AUTO_DELETE_TIMEOUT) == args.end();
-    return replicateLevel(args) && !ignore;
+    return !ignore && replicateLevel(args) >= level;
 }
 
-bool ReplicationTest::isReplicated(const framing::FieldTable& args, bool autodelete, bool exclusive) {
+bool ReplicationTest::isReplicated(
+    ReplicateLevel level, const framing::FieldTable& args, bool autodelete, bool exclusive)
+{
     bool ignore = autodelete && exclusive && !args.isSet(AUTO_DELETE_TIMEOUT);
-    return replicateLevel(args) && !ignore;
+    return !ignore && replicateLevel(args) >= level;
 }
 
-bool ReplicationTest::isReplicated(const broker::Queue& q) {
-    return isReplicated(q.getSettings(), q.isAutoDelete(), q.hasExclusiveOwner());
+bool ReplicationTest::isReplicated(ReplicateLevel level, const broker::Queue& q)
+{
+    return isReplicated(level, q.getSettings(), q.isAutoDelete(), q.hasExclusiveOwner());
 }