diff options
| author | Amitay Isaacs <amitay@gmail.com> | 2017-06-30 00:31:21 +1000 |
|---|---|---|
| committer | Martin Schwenke <martins@samba.org> | 2017-08-30 14:59:23 +0200 |
| commit | 7f34ad2a8270e86103a0ee73cee36852e38d8cc1 (patch) | |
| tree | 1ed069fe81ead56c6945133c2507477cf5b8ae36 /ctdb/protocol/protocol_control.c | |
| parent | 32539cd5cc5aba9ff01573cb9d1dc8e98827802e (diff) | |
| download | samba-7f34ad2a8270e86103a0ee73cee36852e38d8cc1.tar.gz | |
ctdb-protocol: Fix marshalling for ctdb_connection
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 | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/ctdb/protocol/protocol_control.c b/ctdb/protocol/protocol_control.c index 01238b36284..057dc25719a 100644 --- a/ctdb/protocol/protocol_control.c +++ b/ctdb/protocol/protocol_control.c @@ -511,15 +511,15 @@ static void ctdb_req_control_data_push(struct ctdb_req_control_data *cd, break; case CTDB_CONTROL_TCP_CLIENT: - ctdb_connection_push(cd->data.conn, buf); + ctdb_connection_push(cd->data.conn, buf, &np); break; case CTDB_CONTROL_TCP_ADD: - ctdb_connection_push(cd->data.conn, buf); + ctdb_connection_push(cd->data.conn, buf, &np); break; case CTDB_CONTROL_TCP_REMOVE: - ctdb_connection_push(cd->data.conn, buf); + ctdb_connection_push(cd->data.conn, buf, &np); break; case CTDB_CONTROL_SET_TUNABLE: @@ -637,7 +637,7 @@ static void ctdb_req_control_data_push(struct ctdb_req_control_data *cd, break; case CTDB_CONTROL_TCP_ADD_DELAYED_UPDATE: - ctdb_connection_push(cd->data.conn, buf); + ctdb_connection_push(cd->data.conn, buf, &np); break; case CTDB_CONTROL_SCHEDULE_FOR_DELETION: @@ -803,17 +803,17 @@ static int ctdb_req_control_data_pull(uint8_t *buf, size_t buflen, case CTDB_CONTROL_TCP_CLIENT: ret = ctdb_connection_pull(buf, buflen, mem_ctx, - &cd->data.conn); + &cd->data.conn, &np); break; case CTDB_CONTROL_TCP_ADD: ret = ctdb_connection_pull(buf, buflen, mem_ctx, - &cd->data.conn); + &cd->data.conn, &np); break; case CTDB_CONTROL_TCP_REMOVE: ret = ctdb_connection_pull(buf, buflen, mem_ctx, - &cd->data.conn); + &cd->data.conn, &np); break; case CTDB_CONTROL_SET_TUNABLE: @@ -955,7 +955,7 @@ static int ctdb_req_control_data_pull(uint8_t *buf, size_t buflen, case CTDB_CONTROL_TCP_ADD_DELAYED_UPDATE: ret = ctdb_connection_pull(buf, buflen, mem_ctx, - &cd->data.conn); + &cd->data.conn, &np); break; case CTDB_CONTROL_SCHEDULE_FOR_DELETION: |