sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-02-02 09:47:23 +03:00
Code

s3:ctdbd_conn: split out ctdbd_control_get_nodemap()

Browse Source 
This will simplify future changes...

Signed-off-by: Stefan Metzmacher <metze@samba.org>
Reviewed-by: Günther Deschner <gd@samba.org>
This commit is contained in:
Stefan Metzmacher 2023-08-11 11:51:04 +02:00
parent ceda79b6cc
commit 3106709c89
1 changed files with 27 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
source3/lib/ctdbd_conn.c
View File

@ -296,30 +296,44 @@ static int get_cluster_vnn(struct ctdbd_connection *conn, uint32_t *vnn)
return ret;
}
static int ctdbd_control_get_nodemap(struct ctdbd_connection *conn,
TALLOC_CTX *mem_ctx,
struct ctdb_node_map_old **_nodemap)
{
int32_t cstatus=-1;
TDB_DATA outdata = {0};
int ret;
ret = ctdbd_control_local(conn, CTDB_CONTROL_GET_NODEMAP, 0, 0,
tdb_null, mem_ctx, &outdata, &cstatus);
if (ret != 0) {
DEBUG(1, ("ctdbd_control failed: %s\n", strerror(ret)));
return ret;
}
if ((cstatus != 0) || (outdata.dptr == NULL)) {
DEBUG(2, ("Received invalid ctdb data\n"));
return EINVAL;
}
*_nodemap = (struct ctdb_node_map_old *)outdata.dptr;
return 0;
}
/*
* Are we active (i.e. not banned or stopped?)
*/
static bool ctdbd_working(struct ctdbd_connection *conn, uint32_t vnn)
{
int32_t cstatus=-1;
TDB_DATA outdata = {0};
struct ctdb_node_map_old *m;
struct ctdb_node_map_old *m = NULL;
bool ok = false;
uint32_t i;
int ret;
ret = ctdbd_control_local(conn, CTDB_CONTROL_GET_NODEMAP, 0, 0,
tdb_null, talloc_tos(), &outdata, &cstatus);
ret = ctdbd_control_get_nodemap(conn, talloc_tos(), &m);
if (ret != 0) {
DEBUG(1, ("ctdbd_control failed: %s\n", strerror(ret)));
DEBUG(1, ("ctdbd_control_get_nodemap() failed: %s\n", strerror(ret)));
return false;
}
if ((cstatus != 0) || (outdata.dptr == NULL)) {
DEBUG(2, ("Received invalid ctdb data\n"));
goto fail;
}
m = (struct ctdb_node_map_old *)outdata.dptr;
for (i=0; i<m->num; i++) {
if (vnn == m->nodes[i].pnn) {
@ -341,7 +355,7 @@ static bool ctdbd_working(struct ctdbd_connection *conn, uint32_t vnn)
ok = true;
fail:
TALLOC_FREE(outdata.dptr);
TALLOC_FREE(m);
return ok;
}