diff options
| author | Amitay Isaacs <amitay@gmail.com> | 2017-07-05 17:51:03 +1000 |
|---|---|---|
| committer | Martin Schwenke <martins@samba.org> | 2017-08-30 14:59:23 +0200 |
| commit | e893b46e5e4147f5eb4df1eaf8537ccc81bfeb6e (patch) | |
| tree | 14e872707f16dda8236576853b55413d4aa800bf /ctdb/protocol/protocol_control.c | |
| parent | 4d70b972f2be599bcb9e8f70234b9768ac317a7c (diff) | |
| download | samba-e893b46e5e4147f5eb4df1eaf8537ccc81bfeb6e.tar.gz | |
ctdb-protocol: Fix marshalling for ctdb_transdb
Signed-off-by: Amitay Isaacs <amitay@gmail.com>
Reviewed-by: Martin Schwenke <martin@meltin.net>
Diffstat (limited to 'ctdb/protocol/protocol_control.c')
| -rw-r--r-- | ctdb/protocol/protocol_control.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/ctdb/protocol/protocol_control.c b/ctdb/protocol/protocol_control.c index 360665caf11..71892aa1249 100644 --- a/ctdb/protocol/protocol_control.c +++ b/ctdb/protocol/protocol_control.c @@ -555,7 +555,7 @@ static void ctdb_req_control_data_push(struct ctdb_req_control_data *cd, break; case CTDB_CONTROL_WIPE_DATABASE: - ctdb_transdb_push(cd->data.transdb, buf); + ctdb_transdb_push(cd->data.transdb, buf, &np); break; case CTDB_CONTROL_TRY_DELETE_RECORDS: @@ -686,11 +686,11 @@ static void ctdb_req_control_data_push(struct ctdb_req_control_data *cd, break; case CTDB_CONTROL_DB_TRANSACTION_START: - ctdb_transdb_push(cd->data.transdb, buf); + ctdb_transdb_push(cd->data.transdb, buf, &np); break; case CTDB_CONTROL_DB_TRANSACTION_COMMIT: - ctdb_transdb_push(cd->data.transdb, buf); + ctdb_transdb_push(cd->data.transdb, buf, &np); break; case CTDB_CONTROL_DB_TRANSACTION_CANCEL: @@ -858,7 +858,7 @@ static int ctdb_req_control_data_pull(uint8_t *buf, size_t buflen, case CTDB_CONTROL_WIPE_DATABASE: ret = ctdb_transdb_pull(buf, buflen, mem_ctx, - &cd->data.transdb); + &cd->data.transdb, &np); break; case CTDB_CONTROL_TRY_DELETE_RECORDS: @@ -1009,12 +1009,12 @@ static int ctdb_req_control_data_pull(uint8_t *buf, size_t buflen, case CTDB_CONTROL_DB_TRANSACTION_START: ret = ctdb_transdb_pull(buf, buflen, mem_ctx, - &cd->data.transdb); + &cd->data.transdb, &np); break; case CTDB_CONTROL_DB_TRANSACTION_COMMIT: ret = ctdb_transdb_pull(buf, buflen, mem_ctx, - &cd->data.transdb); + &cd->data.transdb, &np); break; case CTDB_CONTROL_DB_TRANSACTION_CANCEL: |