sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2024-12-23 17:34:34 +03:00
Code

ctdb-tests: Implement GET_RUNSTATE control in fake_ctdbd

Browse Source 
Signed-off-by: Amitay Isaacs <amitay@gmail.com>
Reviewed-by: Martin Schwenke <martin@meltin.net>
This commit is contained in:
Amitay Isaacs 2016-07-07 15:54:27 +10:00 committed by Amitay Isaacs
parent cf5d70c3ca
commit eb2544e406
1 changed files with 24 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
ctdb/tests/src/fake_ctdbd.c
View File

@ -96,6 +96,7 @@ struct ctdbd_context {
struct timeval recovery_end_time; struct timeval recovery_end_time;
bool takeover_disabled; bool takeover_disabled;
enum debug_level log_level; enum debug_level log_level;
enum ctdb_runstate runstate;
}; };
/* /*
@ -604,6 +605,7 @@ static struct ctdbd_context *ctdbd_setup(TALLOC_CTX *mem_ctx)
ctdb->recovery_end_time = tevent_timeval_current(); ctdb->recovery_end_time = tevent_timeval_current();
ctdb->log_level = DEBUG_ERR; ctdb->log_level = DEBUG_ERR;
ctdb->runstate = CTDB_RUNSTATE_RUNNING;
return ctdb; return ctdb;
@ -1505,6 +1507,24 @@ fail:
client_send_control(req, header, &reply); client_send_control(req, header, &reply);
} }
static void control_get_runstate(TALLOC_CTX *mem_ctx,
struct tevent_req *req,
struct ctdb_req_header *header,
struct ctdb_req_control *request)
{
struct client_state *state = tevent_req_data(
req, struct client_state);
struct ctdbd_context *ctdb = state->ctdb;
struct ctdb_reply_control reply;
reply.rdata.opcode = request->opcode;
reply.rdata.data.runstate = ctdb->runstate;
reply.status = 0;
reply.errmsg = NULL;
client_send_control(req, header, &reply);
}
static void control_get_nodes_file(TALLOC_CTX *mem_ctx, static void control_get_nodes_file(TALLOC_CTX *mem_ctx,
struct tevent_req *req, struct tevent_req *req,
struct ctdb_req_header *header, struct ctdb_req_header *header,
@ -1934,6 +1954,10 @@ static void client_process_control(struct tevent_req *req,
control_get_ifaces(mem_ctx, req, &header, &request); control_get_ifaces(mem_ctx, req, &header, &request);
break; break;
case CTDB_CONTROL_GET_RUNSTATE:
control_get_runstate(mem_ctx, req, &header, &request);
break;
case CTDB_CONTROL_GET_NODES_FILE: case CTDB_CONTROL_GET_NODES_FILE:
control_get_nodes_file(mem_ctx, req, &header, &request); control_get_nodes_file(mem_ctx, req, &header, &request);
break; break;