struct recdb_add_traverse_state {
struct recdb_context *recdb;
- int mypnn;
+ uint32_t mypnn;
};
static int recdb_add_traverse(uint32_t reqid, struct ctdb_ltdb_header *header,
bool persistent;
bool failed;
int fd;
- int max_size;
- int num_buffers;
+ size_t max_size;
+ unsigned int num_buffers;
};
static int recdb_file_traverse(struct tdb_context *tdb,
struct recdb_context *recdb;
uint32_t pnn;
uint64_t srvid;
- int num_records;
+ unsigned int num_records;
int result;
};
int fd;
int num_buffers;
int num_buffers_sent;
- int num_records;
+ unsigned int num_records;
};
static void push_database_new_started(struct tevent_req *subreq);
struct db_recovery_state {
struct tevent_context *ev;
struct ctdb_dbid_map *dbmap;
- int num_replies;
- int num_failed;
+ unsigned int num_replies;
+ unsigned int num_failed;
};
struct db_recovery_one_state {
{
struct tevent_req *req, *subreq;
struct db_recovery_state *state;
- int i;
+ unsigned int i;
req = tevent_req_create(mem_ctx, &state, struct db_recovery_state);
if (req == NULL) {
}
}
-static bool db_recovery_recv(struct tevent_req *req, int *count)
+static bool db_recovery_recv(struct tevent_req *req, unsigned int *count)
{
struct db_recovery_state *state = tevent_req_data(
req, struct db_recovery_state);
struct ctdb_client_context *client;
uint32_t generation;
uint32_t *pnn_list;
- int count;
+ unsigned int count;
uint32_t destnode;
struct ctdb_node_map *nodemap;
uint32_t *caps;
struct ctdb_reply_control **reply;
struct ctdb_req_control request;
int *err_list;
- int ret, i;
+ unsigned int i;
+ int ret;
bool status;
status = ctdb_client_control_multi_recv(subreq, &ret, state, &err_list,
struct ctdb_req_control request;
struct ctdb_vnn_map *vnnmap;
int *err_list;
- int ret, i;
- unsigned int count;
+ int ret;
+ unsigned int count, i;
bool status;
status = ctdb_client_control_multi_recv(subreq, &ret, NULL, &err_list,
req, struct recovery_state);
struct ctdb_req_control request;
bool status;
- int count;
+ unsigned int count;
status = db_recovery_recv(subreq, &count);
TALLOC_FREE(subreq);
if (! status) {
uint32_t max_pnn = CTDB_UNKNOWN_PNN, max_credits = 0;
- int i;
+ unsigned int i;
/* Bans are not enabled */
if (state->tun_list->enable_bans == 0) {