uint32_t ctdbd_vnn(const struct ctdbd_connection *conn);
int ctdbd_register_msg_ctx(struct ctdbd_connection *conn,
- struct messaging_context *msg_ctx);
+ struct messaging_context *msg_ctx,
+ struct tevent_context *ev);
struct messaging_context *ctdb_conn_msg_ctx(struct ctdbd_connection *conn);
int ctdbd_conn_get_fd(struct ctdbd_connection *conn);
*/
int ctdbd_register_msg_ctx(struct ctdbd_connection *conn,
- struct messaging_context *msg_ctx)
+ struct messaging_context *msg_ctx,
+ struct tevent_context *ev)
{
SMB_ASSERT(conn->msg_ctx == NULL);
SMB_ASSERT(conn->fde == NULL);
- if (!(conn->fde = tevent_add_fd(messaging_tevent_context(msg_ctx),
- conn,
- conn->fd,
- TEVENT_FD_READ,
- ctdbd_socket_handler,
- conn))) {
+ conn->fde = tevent_add_fd(ev, conn, conn->fd, TEVENT_FD_READ,
+ ctdbd_socket_handler, conn);
+ if (conn->fde == NULL) {
DEBUG(0, ("event_add_fd failed\n"));
return ENOMEM;
}
return map_nt_error_from_unix(ret);
}
- ret = ctdbd_register_msg_ctx(ctx->conn, msg_ctx);
+ ret = ctdbd_register_msg_ctx(ctx->conn, msg_ctx,
+ messaging_tevent_context(msg_ctx));
if (ret != 0) {
DEBUG(10, ("ctdbd_register_msg_ctx failed: %s\n",