LU-3606 fallocate: Implement fallocate preallocate operation

[fs/lustre-release.git] / lustre / ofd / ofd_objects.c

diff --git a/lustre/ofd/ofd_objects.c b/lustre/ofd/ofd_objects.c
index 6d55a99..bb92058 100644 (file)
--- a/lustre/ofd/ofd_objects.c
+++ b/lustre/ofd/ofd_objects.c
@@ -742,6 +742,91 @@ out:
 }
 
 /**
+ * Fallocate(Preallocate) space for OFD object.
+ *
+ * This function allocates space for the object from the \a start
+ * offset to the \a end offset.
+ *
+ * \param[in] env      execution environment
+ * \param[in] fo       OFD object
+ * \param[in] start    start offset to allocate from
+ * \param[in] end      end of allocate
+ * \param[in] mode     fallocate mode
+ * \param[in] la       object attributes
+ * \param[in] ff       filter_fid structure
+ *
+ * \retval             0 if successful
+ * \retval             negative value on error
+ */
+int ofd_object_fallocate(const struct lu_env *env, struct ofd_object *fo,
+                       __u64 start, __u64 end, int mode, struct lu_attr *la,
+                       struct obdo *oa)
+{
+       struct ofd_thread_info *info = ofd_info(env);
+       struct ofd_device *ofd = ofd_obj2dev(fo);
+       struct dt_object *dob = ofd_object_child(fo);
+       struct thandle *th;
+       struct filter_fid *ff = &info->fti_mds_fid;
+       bool ff_needed = false;
+       int rc;
+
+       ENTRY;
+
+       ofd_write_lock(env, fo);
+       if (!ofd_object_exists(fo))
+               GOTO(unlock, rc = -ENOENT);
+
+       /* VBR: version recovery check */
+       rc = ofd_version_get_check(info, fo);
+       if (rc != 0)
+               GOTO(unlock, rc);
+
+       if (ff != NULL) {
+               rc = ofd_object_ff_load(env, fo);
+               if (rc == -ENODATA)
+                       ff_needed = true;
+               else if (rc < 0)
+                       GOTO(unlock, rc);
+       }
+
+       th = ofd_trans_create(env, ofd);
+       if (IS_ERR(th))
+               GOTO(unlock, rc = PTR_ERR(th));
+
+       rc = dt_declare_attr_set(env, dob, la, th);
+       if (rc)
+               GOTO(stop, rc);
+
+       rc = dt_declare_falloc(env, dob, th);
+       if (rc)
+               GOTO(stop, rc);
+
+       rc = ofd_trans_start(env, ofd, fo, th);
+       if (rc)
+               GOTO(stop, rc);
+
+       rc = dt_falloc(env, dob, start, end, mode, th);
+       if (rc)
+               GOTO(stop, rc);
+
+       rc = dt_attr_set(env, dob, la, th);
+       if (rc)
+               GOTO(stop, rc);
+
+       if (ff_needed) {
+               rc = dt_xattr_set(env, ofd_object_child(fo), &info->fti_buf,
+                                 XATTR_NAME_FID, 0, th);
+               if (!rc)
+                       filter_fid_le_to_cpu(&fo->ofo_ff, ff, sizeof(*ff));
+       }
+stop:
+       ofd_trans_stop(env, ofd, th, rc);
+unlock:
+       ofd_write_unlock(env, fo);
+       RETURN(rc);
+}
+
+/**
  * Truncate/punch OFD object.
  *
  * This function frees all of the allocated object's space from the \a start