const char *mdtname, long long startrec);
int llapi_changelog_fini(void **priv);
int llapi_changelog_recv(void *priv, struct changelog_rec **rech);
+int llapi_changelog_in_buf(void *priv);
int llapi_changelog_free(struct changelog_rec **rech);
int llapi_changelog_get_fd(void *priv);
/* Allow records up to endrec to be destroyed; requires registered id. */
#define OBD_IOC_START_LFSCK _IOWR('f', 230, OBD_IOC_DATA_TYPE)
#define OBD_IOC_STOP_LFSCK _IOW('f', 231, OBD_IOC_DATA_TYPE)
#define OBD_IOC_QUERY_LFSCK _IOR('f', 232, struct obd_ioctl_data)
+#define OBD_IOC_CHLG_POLL _IOR('f', 233, long)
/* lustre/lustre_user.h 240-249 */
/* was LIBCFS_IOC_DEBUG_MASK _IOWR('f', 250, long) until 2.11 */
#include <linux/miscdevice.h>
#include <lustre_log.h>
+#include <uapi/linux/lustre/lustre_ioctl.h>
#include "mdc_internal.h"
__u64 crs_rec_count;
/* List of prefetched enqueued_record::enq_linkage_items */
struct list_head crs_rec_queue;
+ unsigned int crs_last_catidx;
+ unsigned int crs_last_idx;
+ bool crs_poll;
};
struct chlg_rec_entry {
rec = container_of(hdr, struct llog_changelog_rec, cr_hdr);
+ crs->crs_last_catidx = llh->lgh_hdr->llh_cat_idx;
+ crs->crs_last_idx = hdr->lrh_index;
+
if (rec->cr_hdr.lrh_type != CHANGELOG_REC) {
rc = -EINVAL;
CERROR("%s: not a changelog rec %x/%d in llog "DFID" rc = %d\n",
if (ctx == NULL)
GOTO(err_out, rc = -ENOENT);
+ crs->crs_last_catidx = -1;
+ crs->crs_last_idx = 0;
+
+again:
rc = llog_open(NULL, ctx, &llh, NULL, CHANGELOG_CATALOG,
LLOG_OPEN_EXISTS);
if (rc) {
GOTO(err_out, rc);
}
+
rc = llog_init_handle(NULL, llh,
LLOG_F_IS_CAT |
LLOG_F_EXT_JOBID |
GOTO(err_out, rc);
}
- rc = llog_cat_process(NULL, llh, chlg_read_cat_process_cb, crs, 0, 0);
+ rc = llog_cat_process(NULL, llh, chlg_read_cat_process_cb, crs,
+ crs->crs_last_catidx, crs->crs_last_idx);
if (rc < 0) {
CERROR("%s: fail to process llog: rc = %d\n", obd->obd_name, rc);
GOTO(err_out, rc);
}
+ if (!kthread_should_stop() && crs->crs_poll) {
+ llog_cat_close(NULL, llh);
+ schedule_timeout_interruptible(HZ);
+ goto again;
+ }
crs->crs_eof = true;
return mask;
}
+static long chlg_ioctl(struct file *file, unsigned int cmd, unsigned long arg)
+{
+ int rc;
+
+ struct chlg_reader_state *crs = file->private_data;
+ switch (cmd) {
+ case OBD_IOC_CHLG_POLL:
+ crs->crs_poll = !!arg;
+ rc = 0;
+ break;
+ default:
+ rc = -EINVAL;
+ break;
+ }
+ return rc;
+}
+
static const struct file_operations chlg_fops = {
.owner = THIS_MODULE,
.llseek = chlg_llseek,
.open = chlg_open,
.release = chlg_release,
.poll = chlg_poll,
+ .unlocked_ioctl = chlg_ioctl,
};
/**
#include <poll.h>
#include <sys/stat.h>
#include <sys/types.h>
+#include <sys/ioctl.h>
#include <lustre/lustreapi.h>
+#include <linux/lustre/lustre_ioctl.h>
static int chlg_dev_path(char *path, size_t path_len, const char *device)
struct changelog_private *cp;
static bool warned_extra_flags;
static bool warned_jobid;
- static bool warned_follow;
char cdev_path[PATH_MAX];
int rc;
warned_jobid = true;
}
- /* Behavior expected by CHANGELOG_FLAG_FOLLOW is not implemented, warn
- * the user and ignore it. */
- if (flags & CHANGELOG_FLAG_FOLLOW && !warned_follow) {
- llapi_err_noerrno(LLAPI_MSG_WARN, "warning: %s() called with "
- "CHANGELOG_FLAG_FOLLOW (ignored)", __func__);
- warned_follow = true;
+ if (flags & CHANGELOG_FLAG_FOLLOW) {
+ int rc;
+ rc = ioctl(cp->clp_fd, OBD_IOC_CHLG_POLL, 1);
+ if (rc < 0)
+ llapi_err_noerrno(LLAPI_MSG_ERROR, "can't enable "
+ "CHANGELOG_FLAG_FOLLOW");
}
return 0;
return 0;
}
+int llapi_changelog_in_buf(void *priv)
+{
+ struct changelog_private *cp = priv;
+ if (cp->clp_buf + cp->clp_buf_len > cp->clp_buf_pos)
+ return 1;
+ return 0;
+}
+
int llapi_changelog_clear(const char *mdtname, const char *idstr,
long long endrec)
{