ctdb-protocol: Add marshalling for struct ctdb_db_vacuum

[amitay/samba.git] / ctdb / protocol / protocol_types.c

diff --git a/ctdb/protocol/protocol_types.c b/ctdb/protocol/protocol_types.c
index d9388b74b1ef542541ce853480bc04660be32342..fb288635234dc3584d4a340356b44f8958a1a67b 100644 (file)
--- a/ctdb/protocol/protocol_types.c
+++ b/ctdb/protocol/protocol_types.c
@@ -1240,6 +1240,69 @@ fail:
        return ret;
 }
 
+size_t ctdb_db_vacuum_len(struct ctdb_db_vacuum *in)
+{
+       return ctdb_uint32_len(&in->db_id) +
+               ctdb_bool_len(&in->full_vacuum_run);
+}
+
+void ctdb_db_vacuum_push(struct ctdb_db_vacuum *in,
+                        uint8_t *buf,
+                        size_t *npush)
+{
+       size_t offset = 0, np;
+
+       ctdb_uint32_push(&in->db_id, buf+offset, &np);
+       offset += np;
+
+       ctdb_bool_push(&in->full_vacuum_run, buf+offset, &np);
+       offset += np;
+
+       *npush = offset;
+}
+
+int ctdb_db_vacuum_pull(uint8_t *buf,
+                       size_t buflen,
+                       TALLOC_CTX *mem_ctx,
+                       struct ctdb_db_vacuum **out,
+                       size_t *npull)
+{
+       struct ctdb_db_vacuum *val;
+       size_t offset = 0, np;
+       int ret;
+
+       val = talloc(mem_ctx, struct ctdb_db_vacuum);
+       if (val == NULL) {
+               return ENOMEM;
+       }
+
+       ret = ctdb_uint32_pull(buf+offset,
+                              buflen-offset,
+                              &val->db_id,
+                              &np);
+       if (ret != 0) {
+               goto fail;;
+       }
+       offset += np;
+
+       ret = ctdb_bool_pull(buf+offset,
+                            buflen-offset,
+                            &val->full_vacuum_run,
+                            &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) +