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 --interactive/-i option in message_ring

Browse Source 
BUG: https://bugzilla.samba.org/show_bug.cgi?id=12109

Pair-programmed-with: Amitay Isaacs <amitay@gmail.com>
Signed-off-by: Martin Schwenke <martin@meltin.net>
Reviewed-by: Amitay Isaacs <amitay@gmail.com>
This commit is contained in:
Martin Schwenke 2016-08-02 14:19:18 +10:00 committed by Martin Schwenke
parent b100d78597
commit fbb3ef46b9
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
ctdb/tests/src/message_ring.c
View File

@ -34,6 +34,7 @@ struct message_ring_state {
struct ctdb_client_context *client;
int num_nodes;
int timelimit;
int interactive;
int msg_count;
int msg_plus, msg_minus;
struct timeval start_time;
@ -50,7 +51,8 @@ static void message_ring_finish(struct tevent_req *subreq);
static struct tevent_req *message_ring_send(TALLOC_CTX *mem_ctx,
struct tevent_context *ev,
struct ctdb_client_context *client,
int num_nodes, int timelimit)
int num_nodes, int timelimit,
int interactive)
{
struct tevent_req *req, *subreq;
struct message_ring_state *state;
@ -64,6 +66,7 @@ static struct tevent_req *message_ring_send(TALLOC_CTX *mem_ctx,
state->client = client;
state->num_nodes = num_nodes;
state->timelimit = timelimit;
state->interactive = interactive;
subreq = ctdb_client_set_message_handler_send(
state, state->ev, state->client,
@ -162,12 +165,12 @@ static void message_ring_each_second(struct tevent_req *subreq)
}
pnn = ctdb_client_pnn(state->client);
if (pnn == 0) {
if (pnn == 0 && state->interactive == 1) {
double t;
t = timeval_elapsed(&state->start_time);
printf("Ring: %.2f msgs/sec (+ve=%d -ve=%d)\r",
state->msg_count / t,
printf("Ring[%u]: %.2f msgs/sec (+ve=%d -ve=%d)\n",
pnn, state->msg_count / t,
state->msg_plus, state->msg_minus);
fflush(stdout);
}
@ -342,7 +345,8 @@ int main(int argc, const char *argv[])
}
req = message_ring_send(mem_ctx, ev, client,
opts->num_nodes, opts->timelimit);
opts->num_nodes, opts->timelimit,
opts->interactive);
if (req == NULL) {
fprintf(stderr, "Memory allocation error\n");
exit(1);