LU-11071 build: add files to .gitignore

[fs/lustre-release.git] / lustre / utils / liblustreapi_chlg.c

diff --git a/lustre/utils/liblustreapi_chlg.c b/lustre/utils/liblustreapi_chlg.c
index d9c7af0..5735fc1 100644 (file)
--- a/lustre/utils/liblustreapi_chlg.c
+++ b/lustre/utils/liblustreapi_chlg.c
@@ -68,6 +68,8 @@ struct changelog_private {
        int                              clp_fd;
        /* Changelog delivery mode */
        enum changelog_send_flag         clp_send_flags;
+       /* Changelog extra flags */
+       enum changelog_send_extra_flag   clp_send_extra_flags;
        /* Available bytes in buffer */
        size_t                           clp_buf_len;
        /* Current position in buffer */
@@ -89,6 +91,7 @@ int llapi_changelog_start(void **priv, enum changelog_send_flag flags,
                          const char *device, long long startrec)
 {
        struct changelog_private *cp;
+       static bool warned_extra_flags;
        static bool warned_jobid;
        static bool warned_follow;
        char cdev_path[PATH_MAX];
@@ -128,6 +131,17 @@ int llapi_changelog_start(void **priv, enum changelog_send_flag flags,
 
        *priv = cp;
 
+       /* CHANGELOG_FLAG_EXTRA_FLAGS will eventually become mandatory.
+        * If it wasn't specified, display a warning here.
+        * Code elsewhere will remove the corresponding extension.
+        */
+       if (!(flags & CHANGELOG_FLAG_EXTRA_FLAGS) && !warned_extra_flags) {
+               llapi_err_noerrno(LLAPI_MSG_WARN,
+                     "warning: %s() called without CHANGELOG_FLAG_EXTRA_FLAGS",
+                     __func__);
+               warned_extra_flags = true;
+       }
+
        /* CHANGELOG_FLAG_JOBID will eventually become mandatory. Display a
         * warning if it's missing. */
        if (!(flags & CHANGELOG_FLAG_JOBID) && !warned_jobid) {
@@ -212,6 +226,7 @@ int llapi_changelog_recv(void *priv, struct changelog_rec **rech)
 {
        struct changelog_private *cp = priv;
        enum changelog_rec_flags rec_fmt = DEFAULT_RECORD_FMT;
+       enum changelog_rec_extra_flags rec_extra_fmt = CLFE_INVALID;
        struct changelog_rec *tmp;
        int rc = 0;
 
@@ -228,6 +243,18 @@ int llapi_changelog_recv(void *priv, struct changelog_rec **rech)
        if (cp->clp_send_flags & CHANGELOG_FLAG_JOBID)
                rec_fmt |= CLF_JOBID;
 
+       if (cp->clp_send_flags & CHANGELOG_FLAG_EXTRA_FLAGS) {
+               rec_fmt |= CLF_EXTRA_FLAGS;
+               if (cp->clp_send_extra_flags & CHANGELOG_EXTRA_FLAG_UIDGID)
+                       rec_extra_fmt |= CLFE_UIDGID;
+               if (cp->clp_send_extra_flags & CHANGELOG_EXTRA_FLAG_NID)
+                       rec_extra_fmt |= CLFE_NID;
+               if (cp->clp_send_extra_flags & CHANGELOG_EXTRA_FLAG_OMODE)
+                       rec_extra_fmt |= CLFE_OPEN;
+               if (cp->clp_send_extra_flags & CHANGELOG_EXTRA_FLAG_XATTR)
+                       rec_extra_fmt |= CLFE_XATTR;
+       }
+
        if (cp->clp_buf + cp->clp_buf_len <= cp->clp_buf_pos) {
                ssize_t refresh;
 
@@ -249,7 +276,7 @@ int llapi_changelog_recv(void *priv, struct changelog_rec **rech)
               changelog_rec_size(tmp) + tmp->cr_namelen);
 
        cp->clp_buf_pos += changelog_rec_size(tmp) + tmp->cr_namelen;
-       changelog_remap_rec(*rech, rec_fmt);
+       changelog_remap_rec(*rech, rec_fmt, rec_extra_fmt);
 
        return 0;
 
@@ -311,3 +338,36 @@ out_close:
        close(fd);
        return rc;
 }
+
+/**
+ * Set extra flags for reading changelogs
+ *
+ * @param priv         Opaque private control structure
+ * @param extra_flags  Read extra flags (e.g. CHANGELOG_EXTRA_FLAG_UIDGID)
+ *
+ * Just call this function right after llapi_changelog_start().
+ */
+int llapi_changelog_set_xflags(void *priv,
+                              enum changelog_send_extra_flag extra_flags)
+{
+       struct changelog_private *cp = priv;
+       static bool warned_uidgid;
+
+       if (!cp || cp->clp_magic != CHANGELOG_PRIV_MAGIC)
+               return -EINVAL;
+
+       cp->clp_send_extra_flags = extra_flags;
+
+       /* CHANGELOG_EXTRA_FLAG_UIDGID will eventually become mandatory.
+        * If it wasn't specified, display a warning here.
+        * Code elsewhere will remove the corresponding extension.
+        */
+       if (!(extra_flags & CHANGELOG_EXTRA_FLAG_UIDGID) && !warned_uidgid) {
+               llapi_err_noerrno(LLAPI_MSG_WARN,
+                    "warning: %s() called without CHANGELOG_EXTRA_FLAG_UIDGID",
+                    __func__);
+               warned_uidgid = true;
+       }
+
+       return 0;
+}