summaryrefslogtreecommitdiff
path: root/ctdb/server/ctdb_recovery_helper.c
diff options
context:
space:
mode:
authorAmitay Isaacs <amitay@gmail.com>2017-03-02 16:38:58 +1100
committerMartin Schwenke <martins@samba.org>2017-06-29 10:34:27 +0200
commitb8a0420d10021c5521335f81effaeb28f43fd307 (patch)
treeee62e77071d6a8b33ba9cb8e59a78da52fccb359 /ctdb/server/ctdb_recovery_helper.c
parent99113c4c88c8e3f54d14600a30064948359a97db (diff)
downloadsamba-b8a0420d10021c5521335f81effaeb28f43fd307.tar.gz
ctdb-daemon: Add implementation for CTDB_CONTROL_DB_ATTACH_REPLICATED control
Signed-off-by: Amitay Isaacs <amitay@gmail.com> Reviewed-by: Martin Schwenke <martin@meltin.net>
Diffstat (limited to 'ctdb/server/ctdb_recovery_helper.c')
-rw-r--r--ctdb/server/ctdb_recovery_helper.c6
1 files changed, 4 insertions, 2 deletions
diff --git a/ctdb/server/ctdb_recovery_helper.c b/ctdb/server/ctdb_recovery_helper.c
index 943222a86e8..9f7fc07d3c4 100644
--- a/ctdb/server/ctdb_recovery_helper.c
+++ b/ctdb/server/ctdb_recovery_helper.c
@@ -1664,7 +1664,8 @@ static void recover_db_transaction_started(struct tevent_req *subreq)
return;
}
- if (state->db_flags & CTDB_DB_FLAGS_PERSISTENT) {
+ if ((state->db_flags & CTDB_DB_FLAGS_PERSISTENT) ||
+ (state->db_flags & CTDB_DB_FLAGS_REPLICATED)) {
subreq = collect_highseqnum_db_send(
state, state->ev, state->client,
state->pnn_list, state->count, state->caps,
@@ -1693,7 +1694,8 @@ static void recover_db_collect_done(struct tevent_req *subreq)
int ret;
bool status;
- if (state->db_flags & CTDB_DB_FLAGS_PERSISTENT) {
+ if ((state->db_flags & CTDB_DB_FLAGS_PERSISTENT) ||
+ (state->db_flags & CTDB_DB_FLAGS_REPLICATED)) {
status = collect_highseqnum_db_recv(subreq, &ret);
} else {
status = collect_all_db_recv(subreq, &ret);