uint32_t db_id);
int ctdb_reply_control_set_db_readonly(struct ctdb_reply_control *reply);
-void ctdb_req_control_check_srvids(struct ctdb_req_control *request,
- struct ctdb_uint64_array *u64_array);
-int ctdb_reply_control_check_srvids(struct ctdb_reply_control *reply,
- TALLOC_CTX *mem_ctx,
- struct ctdb_uint8_array **u8_array);
-
void ctdb_req_control_traverse_start_ext(struct ctdb_req_control *request,
struct ctdb_traverse_start_ext *traverse);
int ctdb_reply_control_traverse_start_ext(struct ctdb_reply_control *reply);
/* CTDB_CONTROL_CHECK_SRVIDS */
-void ctdb_req_control_check_srvids(struct ctdb_req_control *request,
- struct ctdb_uint64_array *u64_array)
-{
- request->opcode = CTDB_CONTROL_CHECK_SRVIDS;
- request->pad = 0;
- request->srvid = 0;
- request->client_id = 0;
- request->flags = 0;
-
- request->rdata.opcode = CTDB_CONTROL_CHECK_SRVIDS;
- request->rdata.data.u64_array = u64_array;
-}
-
-int ctdb_reply_control_check_srvids(struct ctdb_reply_control *reply,
- TALLOC_CTX *mem_ctx,
- struct ctdb_uint8_array **u8_array)
-{
- if (reply->rdata.opcode != CTDB_CONTROL_CHECK_SRVIDS) {
- return EPROTO;
- }
-
- if (reply->status == 0) {
- *u8_array = talloc_steal(mem_ctx, reply->rdata.data.u8_array);
- }
- return reply->status;
-}
-
/* CTDB_CONTROL_TRAVERSE_START_EXT */
void ctdb_req_control_traverse_start_ext(struct ctdb_req_control *request,
break;
case CTDB_CONTROL_CHECK_SRVIDS:
- len = ctdb_uint64_array_len(cd->data.u64_array);
break;
case CTDB_CONTROL_TRAVERSE_START_EXT:
break;
case CTDB_CONTROL_CHECK_SRVIDS:
- ctdb_uint64_array_push(cd->data.u64_array, buf);
break;
case CTDB_CONTROL_TRAVERSE_START_EXT:
break;
case CTDB_CONTROL_CHECK_SRVIDS:
- ret = ctdb_uint64_array_pull(buf, buflen, mem_ctx,
- &cd->data.u64_array);
break;
case CTDB_CONTROL_TRAVERSE_START_EXT:
break;
case CTDB_CONTROL_CHECK_SRVIDS:
- len = ctdb_uint8_array_len(cd->data.u8_array);
break;
case CTDB_CONTROL_TRAVERSE_START_EXT:
break;
case CTDB_CONTROL_CHECK_SRVIDS:
- ctdb_uint8_array_push(cd->data.u8_array, buf);
break;
case CTDB_CONTROL_GET_DB_STATISTICS:
break;
case CTDB_CONTROL_CHECK_SRVIDS:
- ret = ctdb_uint8_array_pull(buf, buflen, mem_ctx,
- &cd->data.u8_array);
break;
case CTDB_CONTROL_GET_DB_STATISTICS:
break;
case CTDB_CONTROL_CHECK_SRVIDS:
- cd->data.u64_array = talloc(mem_ctx, struct ctdb_uint64_array);
- assert(cd->data.u64_array != NULL);
- fill_ctdb_uint64_array(mem_ctx, cd->data.u64_array);
break;
case CTDB_CONTROL_TRAVERSE_START_EXT:
break;
case CTDB_CONTROL_CHECK_SRVIDS:
- verify_ctdb_uint64_array(cd->data.u64_array,
- cd2->data.u64_array);
break;
case CTDB_CONTROL_TRAVERSE_START_EXT:
break;
case CTDB_CONTROL_CHECK_SRVIDS:
- cd->data.u8_array = talloc(mem_ctx, struct ctdb_uint8_array);
- assert(cd->data.u8_array != NULL);
- fill_ctdb_uint8_array(mem_ctx, cd->data.u8_array);
break;
case CTDB_CONTROL_TRAVERSE_START_EXT:
break;
case CTDB_CONTROL_CHECK_SRVIDS:
- verify_ctdb_uint8_array(cd->data.u8_array, cd2->data.u8_array);
break;
case CTDB_CONTROL_TRAVERSE_START_EXT: