struct ctdb_rec_buffer *recbuf);
int ctdb_reply_control_vacuum_fetch(struct ctdb_reply_control *reply);
+void ctdb_req_control_db_vacuum(struct ctdb_req_control *request,
+ struct ctdb_db_vacuum *db_vacuum);
+int ctdb_reply_control_db_vacuum(struct ctdb_reply_control *reply);
+
/* From protocol/protocol_debug.c */
void ctdb_packet_print(uint8_t *buf, size_t buflen, FILE *fp);
return reply->status;
}
+
+/* CTDB_CONTROL_DB_VACUUM */
+
+void ctdb_req_control_db_vacuum(struct ctdb_req_control *request,
+ struct ctdb_db_vacuum *db_vacuum)
+{
+ request->opcode = CTDB_CONTROL_DB_VACUUM;
+ request->pad = 0;
+ request->srvid = 0;
+ request->client_id = 0;
+ request->flags = 0;
+
+ request->rdata.opcode = CTDB_CONTROL_DB_VACUUM;
+ request->rdata.data.db_vacuum = db_vacuum;
+}
+
+int ctdb_reply_control_db_vacuum(struct ctdb_reply_control *reply)
+{
+ if (reply->rdata.opcode != CTDB_CONTROL_DB_VACUUM) {
+ return EPROTO;
+ }
+
+ return reply->status;
+}
case CTDB_CONTROL_VACUUM_FETCH:
len = ctdb_rec_buffer_len(cd->data.recbuf);
break;
+
+ case CTDB_CONTROL_DB_VACUUM:
+ len = ctdb_db_vacuum_len(cd->data.db_vacuum);
+ break;
}
return len;
case CTDB_CONTROL_VACUUM_FETCH:
ctdb_rec_buffer_push(cd->data.recbuf, buf, &np);
break;
+
+ case CTDB_CONTROL_DB_VACUUM:
+ ctdb_db_vacuum_push(cd->data.db_vacuum, buf, &np);
+ break;
}
*npush = np;
ret = ctdb_rec_buffer_pull(buf, buflen, mem_ctx,
&cd->data.recbuf, &np);
break;
+
+ case CTDB_CONTROL_DB_VACUUM:
+ ret = ctdb_db_vacuum_pull(buf,
+ buflen,
+ mem_ctx,
+ &cd->data.db_vacuum,
+ &np);
+ break;
}
if (ret != 0) {
case CTDB_CONTROL_VACUUM_FETCH:
break;
+
+ case CTDB_CONTROL_DB_VACUUM:
+ break;
}
return len;
case CTDB_CONTROL_VACUUM_FETCH:
break;
+
+ case CTDB_CONTROL_DB_VACUUM:
+ break;
}
*npush = np;
case CTDB_CONTROL_VACUUM_FETCH:
break;
+
+ case CTDB_CONTROL_DB_VACUUM:
+ break;
}
if (ret != 0) {
{ CTDB_CONTROL_TUNNEL_REGISTER, "TUNNEL_REGISTER" },
{ CTDB_CONTROL_TUNNEL_DEREGISTER, "TUNNEL_DEREGISTER" },
{ CTDB_CONTROL_VACUUM_FETCH, "VACUUM_FETCH" },
+ { CTDB_CONTROL_DB_VACUUM, "DB_VACUUM" },
{ MAP_END, "" },
};
. "${TEST_SCRIPTS_DIR}/unit.sh"
-last_control=154
+last_control=155
generate_control_output ()
{
assert(cd->data.recbuf != NULL);
fill_ctdb_rec_buffer(mem_ctx, cd->data.recbuf);
break;
+
+ case CTDB_CONTROL_DB_VACUUM:
+ cd->data.db_vacuum = talloc(mem_ctx, struct ctdb_db_vacuum);
+ assert(cd->data.db_vacuum != NULL);
+ fill_ctdb_db_vacuum(mem_ctx, cd->data.db_vacuum);
+ break;
}
}
case CTDB_CONTROL_VACUUM_FETCH:
verify_ctdb_rec_buffer(cd->data.recbuf, cd2->data.recbuf);
break;
+
+ case CTDB_CONTROL_DB_VACUUM:
+ verify_ctdb_db_vacuum(cd->data.db_vacuum, cd2->data.db_vacuum);
+ break;
}
}
case CTDB_CONTROL_VACUUM_FETCH:
break;
+ case CTDB_CONTROL_DB_VACUUM:
+ break;
}
}
case CTDB_CONTROL_VACUUM_FETCH:
break;
+
+ case CTDB_CONTROL_DB_VACUUM:
+ break;
}
}
PROTOCOL_CTDB4_TEST(struct ctdb_reply_dmaster, ctdb_reply_dmaster,
CTDB_REPLY_DMASTER);
-#define NUM_CONTROLS 155
+#define NUM_CONTROLS 156
PROTOCOL_CTDB2_TEST(struct ctdb_req_control_data, ctdb_req_control_data);
PROTOCOL_CTDB2_TEST(struct ctdb_reply_control_data, ctdb_reply_control_data);