sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-01-03 01:18:10 +03:00
Code

ctdb-recoverd: Process leader broadcasts

Browse Source 
Signed-off-by: Martin Schwenke <martin@meltin.net>
Reviewed-by: Amitay Isaacs <amitay@gmail.com>
This commit is contained in:
Martin Schwenke 2020-03-16 16:07:26 +11:00 committed by Martin Schwenke
parent 3d3767a259
commit 789a75abfa
1 changed files with 43 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
ctdb/server/ctdb_recoverd.c
View File

@ -38,6 +38,8 @@
#include "ctdb_private.h" #include "ctdb_private.h"
#include "ctdb_client.h" #include "ctdb_client.h"
#include "protocol/protocol_basic.h"
#include "common/system_socket.h" #include "common/system_socket.h"
#include "common/common.h" #include "common/common.h"
#include "common/logging.h" #include "common/logging.h"
@ -1845,6 +1847,42 @@ static void push_flags_handler(uint64_t srvid, TDB_DATA data,
talloc_free(tmp_ctx); talloc_free(tmp_ctx);
} }
static void leader_handler(uint64_t srvid, TDB_DATA data, void *private_data)
{
struct ctdb_recoverd *rec = talloc_get_type_abort(
private_data, struct ctdb_recoverd);
struct ctdb_context *ctdb = rec->ctdb;
uint32_t pnn;
size_t npull;
int ret;
ret = ctdb_uint32_pull(data.dptr, data.dsize, &pnn, &npull);
if (ret != 0) {
DBG_WARNING("Unable to parse leader broadcast, ret=%d\n", ret);
return;
}
if (pnn == rec->leader) {
return;
}
if (pnn == CTDB_UNKNOWN_PNN) {
return;
}
D_NOTICE("Received leader broadcast, leader=%"PRIu32"\n", pnn);
ret = ctdb_ctrl_setrecmaster(ctdb,
CONTROL_TIMEOUT(),
CTDB_CURRENT_NODE,
pnn);
if (ret != 0) {
DBG_WARNING("Failed to set leader\n");
return;
}
rec->leader = pnn;
}
struct verify_recmode_normal_data { struct verify_recmode_normal_data {
uint32_t count; uint32_t count;
@ -3012,6 +3050,11 @@ static void monitor_cluster(struct ctdb_context *ctdb)
CTDB_SRVID_DISABLE_RECOVERIES, CTDB_SRVID_DISABLE_RECOVERIES,
disable_recoveries_handler, rec); disable_recoveries_handler, rec);
ctdb_client_set_message_handler(ctdb,
CTDB_SRVID_LEADER,
leader_handler,
rec);
for (;;) { for (;;) {
TALLOC_CTX *mem_ctx = talloc_new(ctdb); TALLOC_CTX *mem_ctx = talloc_new(ctdb);
struct timeval start; struct timeval start;