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);
/****************************************************************************
(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:
{
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);
}
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;