diff options
author | Volker Lendecke <vl@samba.org> | 2020-04-07 16:44:58 +0200 |
---|---|---|
committer | Ralph Boehme <slow@samba.org> | 2020-04-28 09:08:39 +0000 |
commit | 6f56f45639e6404161da425bcd2654624907a439 (patch) | |
tree | 0fd50c078b26a283b2b82a2bbc2187537937f401 /ctdb/protocol | |
parent | 4f3db63d5e68382fff9196ce6cf9976501519fdc (diff) | |
download | samba-6f56f45639e6404161da425bcd2654624907a439.tar.gz |
ctdb-protocol: Add marshalling for struct ctdb_echo_data
Signed-off-by: Volker Lendecke <vl@samba.org>
Reviewed-by: Martin Schwenke <martin@meltin.net>
Diffstat (limited to 'ctdb/protocol')
-rw-r--r-- | ctdb/protocol/protocol_private.h | 10 | ||||
-rw-r--r-- | ctdb/protocol/protocol_types.c | 72 |
2 files changed, 82 insertions, 0 deletions
diff --git a/ctdb/protocol/protocol_private.h b/ctdb/protocol/protocol_private.h index b151e64ef09..cbbba394df7 100644 --- a/ctdb/protocol/protocol_private.h +++ b/ctdb/protocol/protocol_private.h @@ -93,6 +93,16 @@ int ctdb_db_vacuum_pull(uint8_t *buf, struct ctdb_db_vacuum **out, size_t *npull); +size_t ctdb_echo_data_len(struct ctdb_echo_data *in); +void ctdb_echo_data_push(struct ctdb_echo_data *in, + uint8_t *buf, + size_t *npush); +int ctdb_echo_data_pull(uint8_t *buf, + size_t buflen, + TALLOC_CTX *mem_ctx, + struct ctdb_echo_data **out, + size_t *npull); + size_t ctdb_traverse_start_len(struct ctdb_traverse_start *in); void ctdb_traverse_start_push(struct ctdb_traverse_start *in, uint8_t *buf, size_t *npush); diff --git a/ctdb/protocol/protocol_types.c b/ctdb/protocol/protocol_types.c index 29e02898346..0eb1923207e 100644 --- a/ctdb/protocol/protocol_types.c +++ b/ctdb/protocol/protocol_types.c @@ -1303,6 +1303,78 @@ fail: return ret; } +size_t ctdb_echo_data_len(struct ctdb_echo_data *in) +{ + /* + * No overflow check, none of the routines in this file do it + * and there's no way to report it anyway. + */ + return ctdb_uint32_len(&in->timeout) + ctdb_tdb_datan_len(&in->buf); +} + +void ctdb_echo_data_push(struct ctdb_echo_data *in, + uint8_t *buf, + size_t *npush) +{ + size_t offset = 0, np; + + /* + * No overflow check, none of the routines in this file do it + * and there's no way to report it anyway. + */ + + ctdb_uint32_push(&in->timeout, buf+offset, &np); + offset += np; + + ctdb_tdb_datan_push(&in->buf, buf+offset, &np); + offset += np; + + *npush = offset; +} + +int ctdb_echo_data_pull(uint8_t *buf, + size_t buflen, + TALLOC_CTX *mem_ctx, + struct ctdb_echo_data **out, + size_t *npull) +{ + struct ctdb_echo_data *val; + size_t offset = 0, np; + int ret; + + val = talloc(mem_ctx, struct ctdb_echo_data); + if (val == NULL) { + return ENOMEM; + } + + ret = ctdb_uint32_pull(buf+offset, + buflen-offset, + &val->timeout, + &np); + if (ret != 0) { + goto fail; + } + offset += np; + + ret = ctdb_tdb_datan_pull(buf+offset, + buflen-offset, + val, + &val->buf, + &np); + if (ret != 0) { + goto fail; + } + offset += np; + + *out = val; + *npull = offset; + return 0; + +fail: + talloc_free(val); + return ret; +} + size_t ctdb_ltdb_header_len(struct ctdb_ltdb_header *in) { return ctdb_uint64_len(&in->rsn) + |