diff options
| -rw-r--r-- | ctdb/server/ctdb_recover.c | 7 | ||||
| -rw-r--r-- | ctdb/server/ctdb_vacuum.c | 9 |
2 files changed, 5 insertions, 11 deletions
diff --git a/ctdb/server/ctdb_recover.c b/ctdb/server/ctdb_recover.c index aa6abbeaaa..ecf3aba301 100644 --- a/ctdb/server/ctdb_recover.c +++ b/ctdb/server/ctdb_recover.c @@ -1092,8 +1092,7 @@ int32_t ctdb_control_try_delete_records(struct ctdb_context *ctdb, TDB_DATA inda } - outdata->dptr = (uint8_t *)records; - outdata->dsize = talloc_get_size(records); + *outdata = ctdb_marshall_finish(records); return 0; } @@ -1290,9 +1289,7 @@ int32_t ctdb_control_receive_records(struct ctdb_context *ctdb, rec = (struct ctdb_rec_data *)(rec->length + (uint8_t *)rec); } - - outdata->dptr = (uint8_t *)records; - outdata->dsize = talloc_get_size(records); + *outdata = ctdb_marshall_finish(records); return 0; } diff --git a/ctdb/server/ctdb_vacuum.c b/ctdb/server/ctdb_vacuum.c index fe59a83fcf..be3ee1e8b4 100644 --- a/ctdb/server/ctdb_vacuum.c +++ b/ctdb/server/ctdb_vacuum.c @@ -775,8 +775,7 @@ static void ctdb_process_vacuum_fetch_lists(struct ctdb_db_context *ctdb_db, vfl->count, ctdb->nodes[i]->pnn, ctdb_db->db_name)); - data.dsize = talloc_get_size(vfl); - data.dptr = (void *)vfl; + data = ctdb_marshall_finish(vfl); if (ctdb_client_send_message(ctdb, ctdb->nodes[i]->pnn, CTDB_SRVID_VACUUM_FETCH, data) != 0) @@ -901,8 +900,7 @@ static void ctdb_process_delete_list(struct ctdb_db_context *ctdb_db, "delete list for first marshalling.\n")); } - indata.dsize = talloc_get_size(recs->records); - indata.dptr = (void *)recs->records; + indata = ctdb_marshall_finish(recs->records); for (i = 0; i < num_active_nodes; i++) { struct ctdb_marshall_buffer *records; @@ -1009,8 +1007,7 @@ static void ctdb_process_delete_list(struct ctdb_db_context *ctdb_db, goto done; } - indata.dsize = talloc_get_size(recs->records); - indata.dptr = (void *)recs->records; + indata = ctdb_marshall_finish(recs->records); for (i = 0; i < num_active_nodes; i++) { struct ctdb_marshall_buffer *records; |