sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-02-02 09:47:23 +03:00
Code

ctdb-client: Add new API for ctdb_client_wait_timeout()

Browse Source 
This is similar to ctdb_client_wait() with additional timeout argument.

Signed-off-by: Amitay Isaacs <amitay@gmail.com>
Reviewed-by: Martin Schwenke <martin@meltin.net>
This commit is contained in:
Amitay Isaacs 2015-11-10 16:59:21 +11:00 committed by Martin Schwenke
parent d8c28fc972
commit 69113fa02e
2 changed files with 46 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
ctdb/client/client.h
View File

@ -45,6 +45,9 @@ uint32_t ctdb_client_pnn(struct ctdb_client_context *client);
void ctdb_client_wait(struct tevent_context *ev, bool *done);
int ctdb_client_wait_timeout(struct tevent_context *ev, bool *done,
struct timeval timeout);
struct tevent_req *ctdb_recovery_wait_send(TALLOC_CTX *mem_ctx,
struct tevent_context *ev,
struct ctdb_client_context *client);

43
ctdb/client/client_connect.c
View File

@ -239,6 +239,49 @@ void ctdb_client_wait(struct tevent_context *ev, bool *done)
}
}
static void ctdb_client_wait_timeout_handler(struct tevent_context *ev,
struct tevent_timer *te,
struct timeval t,
void *private_data)
{
bool *timed_out = (bool *)private_data;
*timed_out = true;
}
int ctdb_client_wait_timeout(struct tevent_context *ev, bool *done,
struct timeval timeout)
{
TALLOC_CTX *mem_ctx;
struct tevent_timer *timer;
bool timed_out = false;
mem_ctx = talloc_new(ev);
if (mem_ctx == NULL) {
return ENOMEM;
}
timer = tevent_add_timer(ev, mem_ctx, timeout,
ctdb_client_wait_timeout_handler,
&timed_out);
if (timer == NULL) {
talloc_free(mem_ctx);
return ENOMEM;
}
while (! (*done) && ! timed_out) {
tevent_loop_once(ev);
}
talloc_free(mem_ctx);
if (timed_out) {
return ETIME;
}
return 0;
}
struct ctdb_recovery_wait_state {
struct tevent_context *ev;
struct ctdb_client_context *client;