int lockfile_fd;
int sock;
- struct tevent_fd *read_fde;
struct messaging_dgm_in_msg *in_msgs;
void (*recv_cb)(struct tevent_context *ev,
return ret;
}
- ctx->read_fde = tevent_add_fd(ctx->ev, ctx, ctx->sock, TEVENT_FD_READ,
- messaging_dgm_read_handler, ctx);
- if (ctx->read_fde == NULL) {
- goto fail_nomem;
- }
-
talloc_set_destructor(ctx, messaging_dgm_context_destructor);
ctx->have_dgm_context = &have_dgm_context;
TALLOC_FREE(c->in_msgs);
}
- TALLOC_FREE(c->read_fde);
close(c->sock);
if (getpid() == c->pid) {
return NULL;
}
- result->tevent_handle = messaging_dgm_register_tevent_context(
- result, ev);
- if (result->tevent_handle == NULL) {
- TALLOC_FREE(result);
- *err = ENOMEM;
- return NULL;
- }
+ }
+
+ result->tevent_handle = messaging_dgm_register_tevent_context(
+ result, ev);
+ if (result->tevent_handle == NULL) {
+ TALLOC_FREE(result);
+ *err = ENOMEM;
+ return NULL;
}
DBG_DEBUG("unique = %"PRIu64"\n", *unique);