uint32_t ctdbd_vnn(const struct ctdbd_connection *conn);
int ctdbd_conn_get_fd(struct ctdbd_connection *conn);
-void ctdbd_socket_readable(struct ctdbd_connection *conn);
+void ctdbd_socket_readable(struct tevent_context *ev,
+ struct ctdbd_connection *conn);
int ctdbd_messaging_send_iov(struct ctdbd_connection *conn,
uint32_t dst_vnn, uint64_t dst_srvid,
return 0;
}
-void ctdbd_socket_readable(struct ctdbd_connection *conn)
+void ctdbd_socket_readable(struct tevent_context *ev,
+ struct ctdbd_connection *conn)
{
struct ctdb_req_header *hdr = NULL;
int ret;
cluster_fatal("ctdbd died\n");
}
- ret = ctdb_handle_message(NULL, conn, hdr);
+ ret = ctdb_handle_message(ev, conn, hdr);
TALLOC_FREE(hdr);
if ((flags & TEVENT_FD_READ) == 0) {
return;
}
- ctdbd_socket_readable(conn);
+ ctdbd_socket_readable(ev, conn);
}
static int messaging_ctdbd_init_internal(struct messaging_context *msg_ctx,