diff options
| author | Volker Lendecke <vl@samba.org> | 2016-09-23 19:28:10 -0700 |
|---|---|---|
| committer | Jeremy Allison <jra@samba.org> | 2016-10-05 00:06:22 +0200 |
| commit | 82dd3562a5edc43e81a2ac897a329d6b06b097ad (patch) | |
| tree | c24f214f6822d62045a0defde056f39617c29042 /source3/lib/messages.c | |
| parent | 85c41375fd10d07a5dd6f3b65def3930eb65baf5 (diff) | |
| download | samba-82dd3562a5edc43e81a2ac897a329d6b06b097ad.tar.gz | |
messaging: Pass "ev" to messaging_dispatch_rec
Signed-off-by: Volker Lendecke <vl@samba.org>
Reviewed-by: Jeremy Allison <jra@samba.org>
Diffstat (limited to 'source3/lib/messages.c')
| -rw-r--r-- | source3/lib/messages.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/source3/lib/messages.c b/source3/lib/messages.c index a3fa5c49dfe..8dd684fc667 100644 --- a/source3/lib/messages.c +++ b/source3/lib/messages.c @@ -86,6 +86,7 @@ struct messaging_context { static struct messaging_rec *messaging_rec_dup(TALLOC_CTX *mem_ctx, struct messaging_rec *rec); static void messaging_dispatch_rec(struct messaging_context *msg_ctx, + struct tevent_context *ev, struct messaging_rec *rec); /**************************************************************************** @@ -199,7 +200,7 @@ static void messaging_recv_cb(struct tevent_context *ev, (unsigned)rec.msg_type, rec.buf.length, num_fds, server_id_str_buf(rec.src, &idbuf)); - messaging_dispatch_rec(msg_ctx, &rec); + messaging_dispatch_rec(msg_ctx, ev, &rec); return; close_fail: @@ -529,7 +530,7 @@ static void messaging_post_handler(struct tevent_context *ev, { struct messaging_post_state *state = talloc_get_type_abort( private_data, struct messaging_post_state); - messaging_dispatch_rec(state->msg_ctx, state->rec); + messaging_dispatch_rec(state->msg_ctx, ev, state->rec); TALLOC_FREE(state); } @@ -963,6 +964,7 @@ static bool messaging_append_new_waiters(struct messaging_context *msg_ctx) Dispatch one messaging_rec */ static void messaging_dispatch_rec(struct messaging_context *msg_ctx, + struct tevent_context *ev, struct messaging_rec *rec) { struct messaging_callback *cb, *next; |