{
struct ctdb_persistent_state *state = talloc_get_type(private_data,
struct ctdb_persistent_state);
- enum ctdb_trans2_commit_error etype;
if (ctdb->recovery_mode != CTDB_RECOVERY_NORMAL) {
DEBUG(DEBUG_INFO, ("ctdb_persistent_callback: ignoring reply "
return;
}
- if (state->num_failed == state->num_sent) {
- etype = CTDB_TRANS2_COMMIT_ALLFAIL;
- } else if (state->num_failed != 0) {
- etype = CTDB_TRANS2_COMMIT_SOMEFAIL;
- } else {
- etype = CTDB_TRANS2_COMMIT_SUCCESS;
- }
-
- ctdb_request_control_reply(state->ctdb, state->c, NULL, etype, state->errormsg);
+ ctdb_request_control_reply(state->ctdb, state->c, NULL, 0, state->errormsg);
talloc_free(state);
}
return;
}
- ctdb_request_control_reply(state->ctdb, state->c, NULL, CTDB_TRANS2_COMMIT_TIMEOUT,
+ ctdb_request_control_reply(state->ctdb, state->c, NULL, 1,
"timeout in ctdb_persistent_state");
talloc_free(state);
state = ctdb_db->persistent_state;
- ctdb_request_control_reply(ctdb, state->c, NULL,
- CTDB_TRANS2_COMMIT_SOMEFAIL,
+ ctdb_request_control_reply(ctdb, state->c, NULL, 2,
"trans3 commit ended by recovery");
/* The destructor sets ctdb_db->persistent_state to NULL. */
}
}
-/*
- store a set of persistent records - called from a ctdb client when it has updated
- some records in a persistent database. The client will have the record
- locked for the duration of this call. The client is the dmaster when
- this call is made
- */
-int32_t ctdb_control_trans2_commit(struct ctdb_context *ctdb,
- struct ctdb_req_control *c,
- TDB_DATA recdata, bool *async_reply)
-{
- struct ctdb_client *client = ctdb_reqid_find(ctdb, c->client_id, struct ctdb_client);
- struct ctdb_persistent_state *state;
- int i;
- struct ctdb_marshall_buffer *m = (struct ctdb_marshall_buffer *)recdata.dptr;
- struct ctdb_db_context *ctdb_db;
-
- ctdb_db = find_ctdb_db(ctdb, m->db_id);
- if (ctdb_db == NULL) {
- DEBUG(DEBUG_ERR,(__location__ " ctdb_control_trans2_commit: "
- "Unknown database db_id[0x%08x]\n", m->db_id));
- return -1;
- }
-
- if (client == NULL) {
- DEBUG(DEBUG_ERR,(__location__ " can not match persistent_store to a client. Returning error\n"));
- return -1;
- }
-
- if (ctdb_db->unhealthy_reason) {
- DEBUG(DEBUG_ERR,("db(%s) unhealty in ctdb_control_trans2_commit: %s\n",
- ctdb_db->db_name, ctdb_db->unhealthy_reason));
- return -1;
- }
-
- /* handling num_persistent_updates is a bit strange -
- there are 3 cases
- 1) very old clients, which never called CTDB_CONTROL_START_PERSISTENT_UPDATE
- They don't expect num_persistent_updates to be used at all
-
- 2) less old clients, which uses CTDB_CONTROL_START_PERSISTENT_UPDATE, and expected
- this commit to then decrement it
-
- 3) new clients which use TRANS2 commit functions, and
- expect this function to increment the counter, and
- then have it decremented in ctdb_control_trans2_error
- or ctdb_control_trans2_finished
- */
- switch (c->opcode) {
- case CTDB_CONTROL_PERSISTENT_STORE:
- if (ctdb_db->transaction_active) {
- DEBUG(DEBUG_ERR, (__location__ " trans2_commit: a "
- "transaction is active on database "
- "db_id[0x%08x] - refusing persistent "
- " store for client id[0x%08x]\n",
- ctdb_db->db_id, client->client_id));
- return -1;
- }
- if (client->num_persistent_updates > 0) {
- client->num_persistent_updates--;
- }
- break;
- case CTDB_CONTROL_TRANS2_COMMIT:
- if (ctdb_db->transaction_active) {
- DEBUG(DEBUG_ERR,(__location__ " trans2_commit: there is"
- " already a transaction commit "
- "active on db_id[0x%08x] - forbidding "
- "client_id[0x%08x] to commit\n",
- ctdb_db->db_id, client->client_id));
- return -1;
- }
- if (client->db_id != 0) {
- DEBUG(DEBUG_ERR,(__location__ " ERROR: trans2_commit: "
- "client-db_id[0x%08x] != 0 "
- "(client_id[0x%08x])\n",
- client->db_id, client->client_id));
- return -1;
- }
- client->num_persistent_updates++;
- ctdb_db->transaction_active = true;
- client->db_id = m->db_id;
- DEBUG(DEBUG_DEBUG, (__location__ " client id[0x%08x] started to"
- " commit transaction on db id[0x%08x]\n",
- client->client_id, client->db_id));
- break;
- case CTDB_CONTROL_TRANS2_COMMIT_RETRY:
- /* already updated from the first commit */
- if (client->db_id != m->db_id) {
- DEBUG(DEBUG_ERR,(__location__ " ERROR: trans2_commit "
- "retry: client-db_id[0x%08x] != "
- "db_id[0x%08x] (client_id[0x%08x])\n",
- client->db_id,
- m->db_id, client->client_id));
- return -1;
- }
- DEBUG(DEBUG_DEBUG, (__location__ " client id[0x%08x] started "
- "transaction commit retry on "
- "db_id[0x%08x]\n",
- client->client_id, client->db_id));
- break;
- }
-
- if (ctdb->recovery_mode != CTDB_RECOVERY_NORMAL) {
- DEBUG(DEBUG_INFO,("rejecting ctdb_control_trans2_commit when recovery active\n"));
- return -1;
- }
-
- state = talloc_zero(ctdb, struct ctdb_persistent_state);
- CTDB_NO_MEMORY(ctdb, state);
-
- state->ctdb = ctdb;
- state->c = c;
-
- for (i=0;i<ctdb->vnn_map->size;i++) {
- struct ctdb_node *node = ctdb->nodes[ctdb->vnn_map->map[i]];
- int ret;
-
- /* only send to active nodes */
- if (node->flags & NODE_FLAGS_INACTIVE) {
- continue;
- }
-
- /* don't send to ourselves */
- if (node->pnn == ctdb->pnn) {
- continue;
- }
-
- ret = ctdb_daemon_send_control(ctdb, node->pnn, 0, CTDB_CONTROL_UPDATE_RECORD,
- c->client_id, 0, recdata,
- ctdb_persistent_callback, state);
- if (ret == -1) {
- DEBUG(DEBUG_ERR,("Unable to send CTDB_CONTROL_UPDATE_RECORD to pnn %u\n", node->pnn));
- talloc_free(state);
- return -1;
- }
-
- state->num_pending++;
- state->num_sent++;
- }
-
- if (state->num_pending == 0) {
- talloc_free(state);
- return 0;
- }
-
- /* we need to wait for the replies */
- *async_reply = true;
-
- /* need to keep the control structure around */
- talloc_steal(state, c);
-
- /* but we won't wait forever */
- event_add_timed(ctdb->ev, state,
- timeval_current_ofs(ctdb->tunable.control_timeout, 0),
- ctdb_persistent_store_timeout, state);
-
- return 0;
-}
-
static int ctdb_persistent_state_destructor(struct ctdb_persistent_state *state)
{
if (state->client != NULL) {
}
-/*
- called when a client has finished a local commit in a transaction to
- a persistent database
- */
-int32_t ctdb_control_trans2_finished(struct ctdb_context *ctdb,
- struct ctdb_req_control *c)
-{
- struct ctdb_client *client = ctdb_reqid_find(ctdb, c->client_id, struct ctdb_client);
- struct ctdb_db_context *ctdb_db;
-
- ctdb_db = find_ctdb_db(ctdb, client->db_id);
- if (ctdb_db == NULL) {
- DEBUG(DEBUG_ERR,(__location__ " ctdb_control_trans2_finish "
- "Unknown database 0x%08x\n", client->db_id));
- return -1;
- }
- if (!ctdb_db->transaction_active) {
- DEBUG(DEBUG_ERR,(__location__ " ctdb_control_trans2_finish: "
- "Database 0x%08x has no transaction commit "
- "started\n", client->db_id));
- return -1;
- }
-
- ctdb_db->transaction_active = false;
- client->db_id = 0;
-
- if (client->num_persistent_updates == 0) {
- DEBUG(DEBUG_ERR, (__location__ " ERROR: num_persistent_updates == 0\n"));
- DEBUG(DEBUG_ERR,(__location__ " Forcing recovery\n"));
- client->ctdb->recovery_mode = CTDB_RECOVERY_ACTIVE;
- return -1;
- }
- client->num_persistent_updates--;
-
- DEBUG(DEBUG_DEBUG, (__location__ " client id[0x%08x] finished "
- "transaction commit db_id[0x%08x]\n",
- client->client_id, ctdb_db->db_id));
-
- return 0;
-}
-
-/*
- called when a client gets an error committing its database
- during a transaction commit
- */
-int32_t ctdb_control_trans2_error(struct ctdb_context *ctdb,
- struct ctdb_req_control *c)
-{
- struct ctdb_client *client = ctdb_reqid_find(ctdb, c->client_id, struct ctdb_client);
- struct ctdb_db_context *ctdb_db;
-
- ctdb_db = find_ctdb_db(ctdb, client->db_id);
- if (ctdb_db == NULL) {
- DEBUG(DEBUG_ERR,(__location__ " ctdb_control_trans2_error: "
- "Unknown database 0x%08x\n", client->db_id));
- return -1;
- }
- if (!ctdb_db->transaction_active) {
- DEBUG(DEBUG_ERR,(__location__ " ctdb_control_trans2_error: "
- "Database 0x%08x has no transaction commit "
- "started\n", client->db_id));
- return -1;
- }
-
- ctdb_db->transaction_active = false;
- client->db_id = 0;
-
- if (client->num_persistent_updates == 0) {
- DEBUG(DEBUG_ERR, (__location__ " ERROR: num_persistent_updates == 0\n"));
- } else {
- client->num_persistent_updates--;
- }
-
- DEBUG(DEBUG_ERR,(__location__ " An error occurred during transaction on"
- " db_id[0x%08x] - forcing recovery\n",
- ctdb_db->db_id));
- client->ctdb->recovery_mode = CTDB_RECOVERY_ACTIVE;
-
- return 0;
-}
-
-/**
- * Tell whether a transaction is active on this node on the give DB.
- */
-int32_t ctdb_control_trans2_active(struct ctdb_context *ctdb,
- struct ctdb_req_control *c,
- uint32_t db_id)
-{
- struct ctdb_db_context *ctdb_db;
- struct ctdb_client *client = ctdb_reqid_find(ctdb, c->client_id, struct ctdb_client);
-
- ctdb_db = find_ctdb_db(ctdb, db_id);
- if (!ctdb_db) {
- DEBUG(DEBUG_ERR,(__location__ " Unknown db 0x%08x\n", db_id));
- return -1;
- }
-
- if (client->db_id == db_id) {
- return 0;
- }
-
- if (ctdb_db->transaction_active) {
- return 1;
- } else {
- return 0;
- }
-}
-
/*
backwards compatibility:
return 0;
}
-
-/*
- backwards compatibility:
-
- single record varient of ctdb_control_trans2_commit for older clients
- */
-int32_t ctdb_control_persistent_store(struct ctdb_context *ctdb,
- struct ctdb_req_control *c,
- TDB_DATA recdata, bool *async_reply)
-{
- struct ctdb_marshall_buffer *m;
- struct ctdb_rec_data *rec = (struct ctdb_rec_data *)recdata.dptr;
- TDB_DATA key, data;
-
- if (recdata.dsize != offsetof(struct ctdb_rec_data, data) +
- rec->keylen + rec->datalen) {
- DEBUG(DEBUG_ERR, (__location__ " Bad data size in recdata\n"));
- return -1;
- }
-
- key.dptr = &rec->data[0];
- key.dsize = rec->keylen;
- data.dptr = &rec->data[rec->keylen];
- data.dsize = rec->datalen;
-
- m = ctdb_marshall_add(c, NULL, rec->reqid, rec->reqid, key, NULL, data);
- CTDB_NO_MEMORY(ctdb, m);
-
- return ctdb_control_trans2_commit(ctdb, c, ctdb_marshall_finish(m), async_reply);
-}
-
static int32_t ctdb_get_db_seqnum(struct ctdb_context *ctdb,
uint32_t db_id,
uint64_t *seqnum)
git.samba.org / kai / samba-autobuild / .git / commitdiff