sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2024-12-22 13:34:15 +03:00
Code

ctdb-vacuum: Replace VACUUM_FETCH message with control

Browse Source 
Signed-off-by: Amitay Isaacs <amitay@gmail.com>
Reviewed-by: Martin Schwenke <martin@meltin.net>
This commit is contained in:
Amitay Isaacs 2018-02-16 17:01:21 +11:00 committed by Amitay Isaacs
parent 86521837b6
commit 498932c0e8
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
ctdb/server/ctdb_vacuum.c
View File

@ -839,6 +839,7 @@ static void ctdb_process_vacuum_fetch_lists(struct ctdb_db_context *ctdb_db,
{
unsigned int i;
struct ctdb_context *ctdb = ctdb_db->ctdb;
int ret, res;
for (i = 0; i < ctdb->num_nodes; i++) {
TDB_DATA data;
@ -857,17 +858,16 @@ static void ctdb_process_vacuum_fetch_lists(struct ctdb_db_context *ctdb_db,
ctdb_db->db_name));
data = ctdb_marshall_finish(vfl);
if (ctdb_client_send_message(ctdb, ctdb->nodes[i]->pnn,
CTDB_SRVID_VACUUM_FETCH,
data) != 0)
{
DEBUG(DEBUG_ERR, (__location__ " Failed to send vacuum "
"fetch message to %u\n",
ret = ctdb_control(ctdb, ctdb->nodes[i]->pnn, 0,
CTDB_CONTROL_VACUUM_FETCH, 0,
data, NULL, NULL, &res, NULL, NULL);
if (ret != 0 || res != 0) {
DEBUG(DEBUG_ERR, ("Failed to send vacuum "
"fetch control to node %u\n",
ctdb->nodes[i]->pnn));
}
}
return;
}
/**
@ -1197,7 +1197,7 @@ fail:
* - The vacuum_fetch lists
* (one for each other lmaster node):
* The records in this list are sent for deletion to
* their lmaster in a bulk VACUUM_FETCH message.
* their lmaster in a bulk VACUUM_FETCH control.
*
* The lmaster then migrates all these records to itelf
* so that they can be vacuumed there.