struct ctdb_client_context *client;
uint32_t *pnn_list;
int count;
+ uint32_t *caps;
uint32_t db_id;
struct recdb_context *recdb;
uint32_t max_pnn;
TALLOC_CTX *mem_ctx,
struct tevent_context *ev,
struct ctdb_client_context *client,
- uint32_t *pnn_list, int count,
+ uint32_t *pnn_list, int count, uint32_t *caps,
uint32_t db_id, struct recdb_context *recdb)
{
struct tevent_req *req, *subreq;
state->client = client;
state->pnn_list = pnn_list;
state->count = count;
+ state->caps = caps;
state->db_id = db_id;
state->recdb = recdb;
struct ctdb_client_context *client;
uint32_t *pnn_list;
int count;
+ uint32_t *caps;
uint32_t db_id;
struct recdb_context *recdb;
struct ctdb_pulldb pulldb;
TALLOC_CTX *mem_ctx,
struct tevent_context *ev,
struct ctdb_client_context *client,
- uint32_t *pnn_list, int count,
+ uint32_t *pnn_list, int count, uint32_t *caps,
uint32_t db_id, struct recdb_context *recdb)
{
struct tevent_req *req, *subreq;
struct ctdb_tunable_list *tun_list;
uint32_t *pnn_list;
int count;
+ uint32_t *caps;
uint32_t db_id;
bool persistent;
struct ctdb_client_context *client,
struct ctdb_tunable_list *tun_list,
uint32_t *pnn_list, int count,
+ uint32_t *caps,
uint32_t generation,
uint32_t db_id, bool persistent)
{
state->tun_list = tun_list;
state->pnn_list = pnn_list;
state->count = count;
+ state->caps = caps;
state->db_id = db_id;
state->persistent = persistent;
if (state->persistent && state->tun_list->recover_pdb_by_seqnum != 0) {
subreq = collect_highseqnum_db_send(
state, state->ev, state->client,
- state->pnn_list, state->count,
+ state->pnn_list, state->count, state->caps,
state->db_id, state->recdb);
} else {
subreq = collect_all_db_send(
state, state->ev, state->client,
- state->pnn_list, state->count,
+ state->pnn_list, state->count, state->caps,
state->db_id, state->recdb);
}
if (tevent_req_nomem(subreq, req)) {
struct ctdb_tunable_list *tun_list;
uint32_t *pnn_list;
int count;
+ uint32_t *caps;
uint32_t generation;
uint32_t db_id;
bool persistent;
struct ctdb_dbid_map *dbmap,
struct ctdb_tunable_list *tun_list,
uint32_t *pnn_list, int count,
+ uint32_t *caps,
uint32_t generation)
{
struct tevent_req *req, *subreq;
substate->tun_list = tun_list;
substate->pnn_list = pnn_list;
substate->count = count;
+ substate->caps = caps;
substate->generation = generation;
substate->db_id = dbmap->dbs[i].db_id;
substate->persistent = dbmap->dbs[i].flags &
CTDB_DB_FLAGS_PERSISTENT;
subreq = recover_db_send(state, ev, client, tun_list,
- pnn_list, count, generation,
- substate->db_id,
+ pnn_list, count, caps,
+ generation, substate->db_id,
substate->persistent);
if (tevent_req_nomem(subreq, req)) {
return tevent_req_post(req, ev);
subreq = recover_db_send(state, state->ev, substate->client,
substate->tun_list,
substate->pnn_list, substate->count,
+ substate->caps,
substate->generation, substate->db_id,
substate->persistent);
if (tevent_req_nomem(subreq, req)) {
subreq = db_recovery_send(state, state->ev, state->client,
state->dbmap, state->tun_list,
state->pnn_list, state->count,
- state->vnnmap->generation);
+ state->caps, state->vnnmap->generation);
if (tevent_req_nomem(subreq, req)) {
return;
}