Whamcloud - gitweb
LU-3285 mdc: add IO methods to the MDC 15/28015/19
authorMikhal Pershin <mike.pershin@intel.com>
Tue, 8 Dec 2015 06:45:03 +0000 (09:45 +0300)
committerMike Pershin <mike.pershin@intel.com>
Tue, 17 Oct 2017 19:08:38 +0000 (19:08 +0000)
Add CL IO methods specific for MDC. Update and export
related OSC functions to be used from MDC.

Signed-off-by: Mikhal Pershin <mike.pershin@intel.com>
Change-Id: I0397b7f754c778c2af6479e1cde7437d4f86cac9
Reviewed-on: https://review.whamcloud.com/28015
Reviewed-by: Jinshan Xiong <jinshan.xiong@intel.com>
Tested-by: Jenkins
Reviewed-by: Bobi Jam <bobijam@hotmail.com>
Tested-by: Maloo <hpdd-maloo@intel.com>
lustre/include/lustre_osc.h
lustre/mdc/mdc_dev.c
lustre/osc/osc_cache.c
lustre/osc/osc_dev.c
lustre/osc/osc_internal.h
lustre/osc/osc_io.c
lustre/osc/osc_page.c
lustre/osc/osc_request.c

index 07b512f..d2563bb 100644 (file)
@@ -457,16 +457,17 @@ extern struct lu_context_key osc_session_key;
 
 #define OSC_FLAGS (ASYNC_URGENT|ASYNC_READY)
 
 
 #define OSC_FLAGS (ASYNC_URGENT|ASYNC_READY)
 
+/* osc_page.c */
 int osc_page_init(const struct lu_env *env, struct cl_object *obj,
                  struct cl_page *page, pgoff_t ind);
 void osc_index2policy(union ldlm_policy_data *policy, const struct cl_object *obj,
                      pgoff_t start, pgoff_t end);
 int osc_page_init(const struct lu_env *env, struct cl_object *obj,
                  struct cl_page *page, pgoff_t ind);
 void osc_index2policy(union ldlm_policy_data *policy, const struct cl_object *obj,
                      pgoff_t start, pgoff_t end);
-int  osc_lvb_print(const struct lu_env *env, void *cookie,
-                  lu_printer_t p, const struct ost_lvb *lvb);
-
 void osc_lru_add_batch(struct client_obd *cli, struct list_head *list);
 void osc_page_submit(const struct lu_env *env, struct osc_page *opg,
                     enum cl_req_type crt, int brw_flags);
 void osc_lru_add_batch(struct client_obd *cli, struct list_head *list);
 void osc_page_submit(const struct lu_env *env, struct osc_page *opg,
                     enum cl_req_type crt, int brw_flags);
+int lru_queue_work(const struct lu_env *env, void *data);
+
+/* osc_cache.c */
 int osc_cancel_async_page(const struct lu_env *env, struct osc_page *ops);
 int osc_set_async_flags(struct osc_object *obj, struct osc_page *opg,
                        u32 async_flags);
 int osc_cancel_async_page(const struct lu_env *env, struct osc_page *ops);
 int osc_set_async_flags(struct osc_object *obj, struct osc_page *opg,
                        u32 async_flags);
@@ -489,7 +490,6 @@ int osc_cache_writeback_range(const struct lu_env *env, struct osc_object *obj,
                              pgoff_t start, pgoff_t end, int hp, int discard);
 int osc_cache_wait_range(const struct lu_env *env, struct osc_object *obj,
                         pgoff_t start, pgoff_t end);
                              pgoff_t start, pgoff_t end, int hp, int discard);
 int osc_cache_wait_range(const struct lu_env *env, struct osc_object *obj,
                         pgoff_t start, pgoff_t end);
-
 int osc_io_unplug0(const struct lu_env *env, struct client_obd *cli,
                   struct osc_object *osc, int async);
 
 int osc_io_unplug0(const struct lu_env *env, struct client_obd *cli,
                   struct osc_object *osc, int async);
 
@@ -547,6 +547,37 @@ int osc_set_info_async(const struct lu_env *env, struct obd_export *exp,
 int osc_ldlm_resource_invalidate(struct cfs_hash *hs, struct cfs_hash_bd *bd,
                                 struct hlist_node *hnode, void *arg);
 
 int osc_ldlm_resource_invalidate(struct cfs_hash *hs, struct cfs_hash_bd *bd,
                                 struct hlist_node *hnode, void *arg);
 
+int osc_punch_send(struct obd_export *exp, struct obdo *oa,
+                  obd_enqueue_update_f upcall, void *cookie);
+
+/* osc_io.c */
+int osc_io_submit(const struct lu_env *env, const struct cl_io_slice *ios,
+                 enum cl_req_type crt, struct cl_2queue *queue);
+int osc_io_commit_async(const struct lu_env *env,
+                       const struct cl_io_slice *ios,
+                       struct cl_page_list *qin, int from, int to,
+                       cl_commit_cbt cb);
+int osc_io_iter_init(const struct lu_env *env, const struct cl_io_slice *ios);
+void osc_io_iter_fini(const struct lu_env *env,
+                     const struct cl_io_slice *ios);
+int osc_io_write_iter_init(const struct lu_env *env,
+                          const struct cl_io_slice *ios);
+void osc_io_write_iter_fini(const struct lu_env *env,
+                           const struct cl_io_slice *ios);
+int osc_io_fault_start(const struct lu_env *env, const struct cl_io_slice *ios);
+void osc_io_setattr_end(const struct lu_env *env,
+                       const struct cl_io_slice *slice);
+int osc_io_read_start(const struct lu_env *env,
+                     const struct cl_io_slice *slice);
+int osc_io_write_start(const struct lu_env *env,
+                      const struct cl_io_slice *slice);
+void osc_io_end(const struct lu_env *env, const struct cl_io_slice *slice);
+
+int osc_io_fsync_start(const struct lu_env *env,
+                      const struct cl_io_slice *slice);
+void osc_io_fsync_end(const struct lu_env *env,
+                     const struct cl_io_slice *slice);
+
 /*****************************************************************************
  *
  * Accessors and type conversions.
 /*****************************************************************************
  *
  * Accessors and type conversions.
index 99218c6..f3e4a81 100644 (file)
 
 #include "mdc_internal.h"
 
 
 #include "mdc_internal.h"
 
-int mdc_page_init(const struct lu_env *env, struct cl_object *obj,
-                 struct cl_page *page, pgoff_t index)
-{
-       return -ENOTSUPP;
-}
-
 int mdc_lock_init(const struct lu_env *env,
                  struct cl_object *obj, struct cl_lock *lock,
                  const struct cl_io *unused)
 {
 int mdc_lock_init(const struct lu_env *env,
                  struct cl_object *obj, struct cl_lock *lock,
                  const struct cl_io *unused)
 {
-       return -ENOTSUPP;
+       return 0;
+}
+
+/**
+ * IO operations.
+ *
+ * An implementation of cl_io_operations specific methods for MDC layer.
+ *
+ */
+static int mdc_async_upcall(void *a, int rc)
+{
+       struct osc_async_cbargs *args = a;
+
+       args->opc_rc = rc;
+       complete(&args->opc_sync);
+       return 0;
+}
+
+static int mdc_io_setattr_start(const struct lu_env *env,
+                               const struct cl_io_slice *slice)
+{
+       struct cl_io *io = slice->cis_io;
+       struct osc_io *oio = cl2osc_io(env, slice);
+       struct cl_object *obj = slice->cis_obj;
+       struct lov_oinfo *loi = cl2osc(obj)->oo_oinfo;
+       struct cl_attr *attr = &osc_env_info(env)->oti_attr;
+       struct obdo *oa = &oio->oi_oa;
+       struct osc_async_cbargs *cbargs = &oio->oi_cbarg;
+       __u64 size = io->u.ci_setattr.sa_attr.lvb_size;
+       unsigned int ia_valid = io->u.ci_setattr.sa_valid;
+       int rc;
+
+       /* silently ignore non-truncate setattr for Data-on-MDT object */
+       if (cl_io_is_trunc(io)) {
+               /* truncate cache dirty pages first */
+               rc = osc_cache_truncate_start(env, cl2osc(obj), size,
+                                             &oio->oi_trunc);
+               if (rc < 0)
+                       return rc;
+       }
+
+       if (oio->oi_lockless == 0) {
+               cl_object_attr_lock(obj);
+               rc = cl_object_attr_get(env, obj, attr);
+               if (rc == 0) {
+                       struct ost_lvb *lvb = &io->u.ci_setattr.sa_attr;
+                       unsigned int cl_valid = 0;
+
+                       if (ia_valid & ATTR_SIZE) {
+                               attr->cat_size = attr->cat_kms = size;
+                               cl_valid = (CAT_SIZE | CAT_KMS);
+                       }
+                       if (ia_valid & ATTR_MTIME_SET) {
+                               attr->cat_mtime = lvb->lvb_mtime;
+                               cl_valid |= CAT_MTIME;
+                       }
+                       if (ia_valid & ATTR_ATIME_SET) {
+                               attr->cat_atime = lvb->lvb_atime;
+                               cl_valid |= CAT_ATIME;
+                       }
+                       if (ia_valid & ATTR_CTIME_SET) {
+                               attr->cat_ctime = lvb->lvb_ctime;
+                               cl_valid |= CAT_CTIME;
+                       }
+                       rc = cl_object_attr_update(env, obj, attr, cl_valid);
+               }
+               cl_object_attr_unlock(obj);
+               if (rc < 0)
+                       return rc;
+       }
+
+       if (!(ia_valid & ATTR_SIZE))
+               return 0;
+
+       memset(oa, 0, sizeof(*oa));
+       oa->o_oi = loi->loi_oi;
+       oa->o_mtime = attr->cat_mtime;
+       oa->o_atime = attr->cat_atime;
+       oa->o_ctime = attr->cat_ctime;
+
+       oa->o_size = size;
+       oa->o_blocks = OBD_OBJECT_EOF;
+       oa->o_valid = OBD_MD_FLID | OBD_MD_FLGROUP | OBD_MD_FLATIME |
+                     OBD_MD_FLCTIME | OBD_MD_FLMTIME | OBD_MD_FLSIZE |
+                     OBD_MD_FLBLOCKS;
+       if (oio->oi_lockless) {
+               oa->o_flags = OBD_FL_SRVLOCK;
+               oa->o_valid |= OBD_MD_FLFLAGS;
+       }
+
+       init_completion(&cbargs->opc_sync);
+
+       rc = osc_punch_send(osc_export(cl2osc(obj)), oa,
+                           mdc_async_upcall, cbargs);
+       cbargs->opc_rpc_sent = rc == 0;
+       return rc;
 }
 
 }
 
-int mdc_io_init(const struct lu_env *env,
-               struct cl_object *obj, struct cl_io *io)
+static struct cl_io_operations mdc_io_ops = {
+       .op = {
+               [CIT_READ] = {
+                       .cio_iter_init = osc_io_iter_init,
+                       .cio_iter_fini = osc_io_iter_fini,
+                       .cio_start     = osc_io_read_start,
+               },
+               [CIT_WRITE] = {
+                       .cio_iter_init = osc_io_write_iter_init,
+                       .cio_iter_fini = osc_io_write_iter_fini,
+                       .cio_start     = osc_io_write_start,
+                       .cio_end       = osc_io_end,
+               },
+               [CIT_SETATTR] = {
+                       .cio_iter_init = osc_io_iter_init,
+                       .cio_iter_fini = osc_io_iter_fini,
+                       .cio_start     = mdc_io_setattr_start,
+                       .cio_end       = osc_io_setattr_end,
+               },
+               /* no support for data version so far */
+               [CIT_DATA_VERSION] = {
+                       .cio_start = NULL,
+                       .cio_end   = NULL,
+               },
+               [CIT_FAULT] = {
+                       .cio_iter_init = osc_io_iter_init,
+                       .cio_iter_fini = osc_io_iter_fini,
+                       .cio_start     = osc_io_fault_start,
+                       .cio_end       = osc_io_end,
+               },
+               [CIT_FSYNC] = {
+                       .cio_start = osc_io_fsync_start,
+                       .cio_end   = osc_io_fsync_end,
+               },
+       },
+       .cio_submit       = osc_io_submit,
+       .cio_commit_async = osc_io_commit_async,
+};
+
+int mdc_io_init(const struct lu_env *env, struct cl_object *obj,
+               struct cl_io *io)
 {
 {
-       return -ENOTSUPP;
+       struct osc_io *oio = osc_env_io(env);
+
+       CL_IO_SLICE_CLEAN(oio, oi_cl);
+       cl_io_slice_add(io, &oio->oi_cl, obj, &mdc_io_ops);
+       return 0;
 }
 
 /**
 }
 
 /**
@@ -77,7 +209,7 @@ static void mdc_req_attr_set(const struct lu_env *env, struct cl_object *obj,
 }
 
 static const struct cl_object_operations mdc_ops = {
 }
 
 static const struct cl_object_operations mdc_ops = {
-       .coo_page_init = mdc_page_init,
+       .coo_page_init = osc_page_init,
        .coo_lock_init = mdc_lock_init,
        .coo_io_init = mdc_io_init,
        .coo_attr_get = osc_attr_get,
        .coo_lock_init = mdc_lock_init,
        .coo_io_init = mdc_io_init,
        .coo_attr_get = osc_attr_get,
index 2231bff..2752009 100644 (file)
@@ -2366,6 +2366,7 @@ int osc_prep_async_page(struct osc_object *osc, struct osc_page *ops,
               oap, page, oap->oap_obj_off);
        RETURN(0);
 }
               oap, page, oap->oap_obj_off);
        RETURN(0);
 }
+EXPORT_SYMBOL(osc_prep_async_page);
 
 int osc_queue_async_io(const struct lu_env *env, struct cl_io *io,
                       struct osc_page *ops)
 
 int osc_queue_async_io(const struct lu_env *env, struct cl_io *io,
                       struct osc_page *ops)
@@ -2908,6 +2909,7 @@ again:
        }
        RETURN(result);
 }
        }
        RETURN(result);
 }
+EXPORT_SYMBOL(osc_cache_truncate_start);
 
 /**
  * Called after osc_io_setattr_end to add oio->oi_trunc back to cache.
 
 /**
  * Called after osc_io_setattr_end to add oio->oi_trunc back to cache.
@@ -2994,6 +2996,7 @@ again:
        OSC_IO_DEBUG(obj, "sync file range.\n");
        RETURN(result);
 }
        OSC_IO_DEBUG(obj, "sync file range.\n");
        RETURN(result);
 }
+EXPORT_SYMBOL(osc_cache_wait_range);
 
 /**
  * Called to write out a range of osc object.
 
 /**
  * Called to write out a range of osc object.
@@ -3110,6 +3113,7 @@ int osc_cache_writeback_range(const struct lu_env *env, struct osc_object *obj,
        OSC_IO_DEBUG(obj, "pageout [%lu, %lu], %d.\n", start, end, result);
        RETURN(result);
 }
        OSC_IO_DEBUG(obj, "pageout [%lu, %lu], %d.\n", start, end, result);
        RETURN(result);
 }
+EXPORT_SYMBOL(osc_cache_writeback_range);
 
 /**
  * Returns a list of pages by a given [start, end] of \a obj.
 
 /**
  * Returns a list of pages by a given [start, end] of \a obj.
index b11eb19..2e639be 100644 (file)
@@ -125,6 +125,7 @@ struct lu_context_key osc_key = {
         .lct_init = osc_key_init,
         .lct_fini = osc_key_fini
 };
         .lct_init = osc_key_init,
         .lct_fini = osc_key_fini
 };
+EXPORT_SYMBOL(osc_key);
 
 static void *osc_session_init(const struct lu_context *ctx,
                              struct lu_context_key *key)
 
 static void *osc_session_init(const struct lu_context *ctx,
                              struct lu_context_key *key)
@@ -149,6 +150,7 @@ struct lu_context_key osc_session_key = {
         .lct_init = osc_session_init,
         .lct_fini = osc_session_fini
 };
         .lct_init = osc_session_init,
         .lct_fini = osc_session_fini
 };
+EXPORT_SYMBOL(osc_session_key);
 
 /* type constructor/destructor: osc_type_{init,fini,start,stop}(). */
 LU_TYPE_INIT_FINI(osc, &osc_key, &osc_session_key);
 
 /* type constructor/destructor: osc_type_{init,fini,start,stop}(). */
 LU_TYPE_INIT_FINI(osc, &osc_key, &osc_session_key);
index 7534443..7a86744 100644 (file)
@@ -67,9 +67,6 @@ int osc_match_base(struct obd_export *exp, struct ldlm_res_id *res_id,
 int osc_setattr_async(struct obd_export *exp, struct obdo *oa,
                      obd_enqueue_update_f upcall, void *cookie,
                      struct ptlrpc_request_set *rqset);
 int osc_setattr_async(struct obd_export *exp, struct obdo *oa,
                      obd_enqueue_update_f upcall, void *cookie,
                      struct ptlrpc_request_set *rqset);
-int osc_punch_base(struct obd_export *exp, struct obdo *oa,
-                   obd_enqueue_update_f upcall, void *cookie,
-                   struct ptlrpc_request_set *rqset);
 int osc_sync_base(struct osc_object *obj, struct obdo *oa,
                  obd_enqueue_update_f upcall, void *cookie,
                  struct ptlrpc_request_set *rqset);
 int osc_sync_base(struct osc_object *obj, struct obdo *oa,
                  obd_enqueue_update_f upcall, void *cookie,
                  struct ptlrpc_request_set *rqset);
@@ -183,4 +180,14 @@ extern unsigned long osc_cache_shrink_count(struct shrinker *sk,
 extern unsigned long osc_cache_shrink_scan(struct shrinker *sk,
                                           struct shrink_control *sc);
 
 extern unsigned long osc_cache_shrink_scan(struct shrinker *sk,
                                           struct shrink_control *sc);
 
+static inline void osc_set_io_portal(struct ptlrpc_request *req)
+{
+       struct obd_import *imp = req->rq_import;
+
+       /* Distinguish OSC from MDC here to use OST or MDS portal */
+       if (OCD_HAS_FLAG(&imp->imp_connect_data, IBITS))
+               req->rq_request_portal = MDS_IO_PORTAL;
+       else
+               req->rq_request_portal = OST_IO_PORTAL;
+}
 #endif /* OSC_INTERNAL_H */
 #endif /* OSC_INTERNAL_H */
index 65c511c..6e25563 100644 (file)
@@ -104,9 +104,8 @@ static int osc_io_read_ahead(const struct lu_env *env,
  * or, if page is already submitted, changes osc flags through
  * osc_set_async_flags().
  */
  * or, if page is already submitted, changes osc flags through
  * osc_set_async_flags().
  */
-static int osc_io_submit(const struct lu_env *env,
-                         const struct cl_io_slice *ios,
-                        enum cl_req_type crt, struct cl_2queue *queue)
+int osc_io_submit(const struct lu_env *env, const struct cl_io_slice *ios,
+                 enum cl_req_type crt, struct cl_2queue *queue)
 {
        struct cl_page    *page;
        struct cl_page    *tmp;
 {
        struct cl_page    *page;
        struct cl_page    *tmp;
@@ -211,6 +210,7 @@ static int osc_io_submit(const struct lu_env *env,
        CDEBUG(D_INFO, "%d/%d %d\n", qin->pl_nr, qout->pl_nr, result);
        return qout->pl_nr > 0 ? 0 : result;
 }
        CDEBUG(D_INFO, "%d/%d %d\n", qin->pl_nr, qout->pl_nr, result);
        return qout->pl_nr > 0 ? 0 : result;
 }
+EXPORT_SYMBOL(osc_io_submit);
 
 /**
  * This is called when a page is accessed within file in a way that creates
 
 /**
  * This is called when a page is accessed within file in a way that creates
@@ -256,10 +256,10 @@ static void osc_page_touch_at(const struct lu_env *env,
        cl_object_attr_unlock(obj);
 }
 
        cl_object_attr_unlock(obj);
 }
 
-static int osc_io_commit_async(const struct lu_env *env,
-                               const struct cl_io_slice *ios,
-                               struct cl_page_list *qin, int from, int to,
-                               cl_commit_cbt cb)
+int osc_io_commit_async(const struct lu_env *env,
+                       const struct cl_io_slice *ios,
+                       struct cl_page_list *qin, int from, int to,
+                       cl_commit_cbt cb)
 {
        struct cl_io    *io = ios->cis_io;
        struct osc_io   *oio = cl2osc_io(env, ios);
 {
        struct cl_io    *io = ios->cis_io;
        struct osc_io   *oio = cl2osc_io(env, ios);
@@ -328,9 +328,9 @@ static int osc_io_commit_async(const struct lu_env *env,
        CDEBUG(D_INFO, "%d %d\n", qin->pl_nr, result);
        RETURN(result);
 }
        CDEBUG(D_INFO, "%d %d\n", qin->pl_nr, result);
        RETURN(result);
 }
+EXPORT_SYMBOL(osc_io_commit_async);
 
 
-static int osc_io_iter_init(const struct lu_env *env,
-                           const struct cl_io_slice *ios)
+int osc_io_iter_init(const struct lu_env *env, const struct cl_io_slice *ios)
 {
        struct osc_object *osc = cl2osc(ios->cis_obj);
        struct obd_import *imp = osc_cli(osc)->cl_import;
 {
        struct osc_object *osc = cl2osc(ios->cis_obj);
        struct obd_import *imp = osc_cli(osc)->cl_import;
@@ -348,9 +348,10 @@ static int osc_io_iter_init(const struct lu_env *env,
 
        return rc;
 }
 
        return rc;
 }
+EXPORT_SYMBOL(osc_io_iter_init);
 
 
-static int osc_io_write_iter_init(const struct lu_env *env,
-                                 const struct cl_io_slice *ios)
+int osc_io_write_iter_init(const struct lu_env *env,
+                          const struct cl_io_slice *ios)
 {
        struct cl_io *io = ios->cis_io;
        struct osc_io *oio = osc_env_io(env);
 {
        struct cl_io *io = ios->cis_io;
        struct osc_io *oio = osc_env_io(env);
@@ -369,9 +370,10 @@ static int osc_io_write_iter_init(const struct lu_env *env,
 
        RETURN(osc_io_iter_init(env, ios));
 }
 
        RETURN(osc_io_iter_init(env, ios));
 }
+EXPORT_SYMBOL(osc_io_write_iter_init);
 
 
-static void osc_io_iter_fini(const struct lu_env *env,
-                            const struct cl_io_slice *ios)
+void osc_io_iter_fini(const struct lu_env *env,
+                     const struct cl_io_slice *ios)
 {
        struct osc_io *oio = osc_env_io(env);
 
 {
        struct osc_io *oio = osc_env_io(env);
 
@@ -384,9 +386,10 @@ static void osc_io_iter_fini(const struct lu_env *env,
                        wake_up_all(&osc->oo_io_waitq);
        }
 }
                        wake_up_all(&osc->oo_io_waitq);
        }
 }
+EXPORT_SYMBOL(osc_io_iter_fini);
 
 
-static void osc_io_write_iter_fini(const struct lu_env *env,
-                                  const struct cl_io_slice *ios)
+void osc_io_write_iter_fini(const struct lu_env *env,
+                           const struct cl_io_slice *ios)
 {
        struct osc_io *oio = osc_env_io(env);
        struct osc_object *osc = cl2osc(ios->cis_obj);
 {
        struct osc_io *oio = osc_env_io(env);
        struct osc_object *osc = cl2osc(ios->cis_obj);
@@ -399,9 +402,9 @@ static void osc_io_write_iter_fini(const struct lu_env *env,
 
        osc_io_iter_fini(env, ios);
 }
 
        osc_io_iter_fini(env, ios);
 }
+EXPORT_SYMBOL(osc_io_write_iter_fini);
 
 
-static int osc_io_fault_start(const struct lu_env *env,
-                             const struct cl_io_slice *ios)
+int osc_io_fault_start(const struct lu_env *env, const struct cl_io_slice *ios)
 {
        struct cl_io       *io;
        struct cl_fault_io *fio;
 {
        struct cl_io       *io;
        struct cl_fault_io *fio;
@@ -421,6 +424,8 @@ static int osc_io_fault_start(const struct lu_env *env,
                                  fio->ft_index, fio->ft_nob);
        RETURN(0);
 }
                                  fio->ft_index, fio->ft_nob);
        RETURN(0);
 }
+EXPORT_SYMBOL(osc_io_fault_start);
+
 
 static int osc_async_upcall(void *a, int rc)
 {
 
 static int osc_async_upcall(void *a, int rc)
 {
@@ -562,9 +567,8 @@ static int osc_io_setattr_start(const struct lu_env *env,
                init_completion(&cbargs->opc_sync);
 
                if (ia_valid & ATTR_SIZE)
                init_completion(&cbargs->opc_sync);
 
                if (ia_valid & ATTR_SIZE)
-                       result = osc_punch_base(osc_export(cl2osc(obj)),
-                                               oa, osc_async_upcall,
-                                               cbargs, PTLRPCD_SET);
+                       result = osc_punch_send(osc_export(cl2osc(obj)),
+                                               oa, osc_async_upcall, cbargs);
                else
                        result = osc_setattr_async(osc_export(cl2osc(obj)),
                                                   oa, osc_async_upcall,
                else
                        result = osc_setattr_async(osc_export(cl2osc(obj)),
                                                   oa, osc_async_upcall,
@@ -576,8 +580,8 @@ static int osc_io_setattr_start(const struct lu_env *env,
        RETURN(result);
 }
 
        RETURN(result);
 }
 
-static void osc_io_setattr_end(const struct lu_env *env,
-                               const struct cl_io_slice *slice)
+void osc_io_setattr_end(const struct lu_env *env,
+                       const struct cl_io_slice *slice)
 {
        struct cl_io     *io  = slice->cis_io;
        struct osc_io    *oio = cl2osc_io(env, slice);
 {
        struct cl_io     *io  = slice->cis_io;
        struct osc_io    *oio = cl2osc_io(env, slice);
@@ -607,6 +611,7 @@ static void osc_io_setattr_end(const struct lu_env *env,
                oio->oi_trunc = NULL;
        }
 }
                oio->oi_trunc = NULL;
        }
 }
+EXPORT_SYMBOL(osc_io_setattr_end);
 
 struct osc_data_version_args {
        struct osc_io *dva_oio;
 
 struct osc_data_version_args {
        struct osc_io *dva_oio;
@@ -713,8 +718,8 @@ static void osc_io_data_version_end(const struct lu_env *env,
        EXIT;
 }
 
        EXIT;
 }
 
-static int osc_io_read_start(const struct lu_env *env,
-                             const struct cl_io_slice *slice)
+int osc_io_read_start(const struct lu_env *env,
+                     const struct cl_io_slice *slice)
 {
        struct cl_object *obj  = slice->cis_obj;
        struct cl_attr   *attr = &osc_env_info(env)->oti_attr;
 {
        struct cl_object *obj  = slice->cis_obj;
        struct cl_attr   *attr = &osc_env_info(env)->oti_attr;
@@ -730,9 +735,10 @@ static int osc_io_read_start(const struct lu_env *env,
 
        RETURN(rc);
 }
 
        RETURN(rc);
 }
+EXPORT_SYMBOL(osc_io_read_start);
 
 
-static int osc_io_write_start(const struct lu_env *env,
-                              const struct cl_io_slice *slice)
+int osc_io_write_start(const struct lu_env *env,
+                      const struct cl_io_slice *slice)
 {
        struct cl_object *obj   = slice->cis_obj;
        struct cl_attr   *attr  = &osc_env_info(env)->oti_attr;
 {
        struct cl_object *obj   = slice->cis_obj;
        struct cl_attr   *attr  = &osc_env_info(env)->oti_attr;
@@ -747,6 +753,7 @@ static int osc_io_write_start(const struct lu_env *env,
 
        RETURN(rc);
 }
 
        RETURN(rc);
 }
+EXPORT_SYMBOL(osc_io_write_start);
 
 static int osc_fsync_ost(const struct lu_env *env, struct osc_object *obj,
                         struct cl_fsync_io *fio)
 
 static int osc_fsync_ost(const struct lu_env *env, struct osc_object *obj,
                         struct cl_fsync_io *fio)
@@ -775,8 +782,8 @@ static int osc_fsync_ost(const struct lu_env *env, struct osc_object *obj,
        RETURN(rc);
 }
 
        RETURN(rc);
 }
 
-static int osc_io_fsync_start(const struct lu_env *env,
-                             const struct cl_io_slice *slice)
+int osc_io_fsync_start(const struct lu_env *env,
+                      const struct cl_io_slice *slice)
 {
        struct cl_io       *io  = slice->cis_io;
        struct cl_fsync_io *fio = &io->u.ci_fsync;
 {
        struct cl_io       *io  = slice->cis_io;
        struct cl_fsync_io *fio = &io->u.ci_fsync;
@@ -814,9 +821,10 @@ static int osc_io_fsync_start(const struct lu_env *env,
 
        RETURN(result);
 }
 
        RETURN(result);
 }
+EXPORT_SYMBOL(osc_io_fsync_start);
 
 
-static void osc_io_fsync_end(const struct lu_env *env,
-                            const struct cl_io_slice *slice)
+void osc_io_fsync_end(const struct lu_env *env,
+                     const struct cl_io_slice *slice)
 {
        struct cl_fsync_io *fio = &slice->cis_io->u.ci_fsync;
        struct cl_object   *obj = slice->cis_obj;
 {
        struct cl_fsync_io *fio = &slice->cis_io->u.ci_fsync;
        struct cl_object   *obj = slice->cis_obj;
@@ -836,6 +844,7 @@ static void osc_io_fsync_end(const struct lu_env *env,
        }
        slice->cis_io->ci_result = result;
 }
        }
        slice->cis_io->ci_result = result;
 }
+EXPORT_SYMBOL(osc_io_fsync_end);
 
 static int osc_io_ladvise_start(const struct lu_env *env,
                                const struct cl_io_slice *slice)
 
 static int osc_io_ladvise_start(const struct lu_env *env,
                                const struct cl_io_slice *slice)
@@ -907,8 +916,7 @@ static void osc_io_ladvise_end(const struct lu_env *env,
        slice->cis_io->ci_result = result;
 }
 
        slice->cis_io->ci_result = result;
 }
 
-static void osc_io_end(const struct lu_env *env,
-                      const struct cl_io_slice *slice)
+void osc_io_end(const struct lu_env *env, const struct cl_io_slice *slice)
 {
        struct osc_io *oio = cl2osc_io(env, slice);
 
 {
        struct osc_io *oio = cl2osc_io(env, slice);
 
@@ -917,6 +925,7 @@ static void osc_io_end(const struct lu_env *env,
                oio->oi_active = NULL;
        }
 }
                oio->oi_active = NULL;
        }
 }
+EXPORT_SYMBOL(osc_io_end);
 
 static const struct cl_io_operations osc_io_ops = {
        .op = {
 
 static const struct cl_io_operations osc_io_ops = {
        .op = {
index c0aa4be..d53725c 100644 (file)
@@ -301,6 +301,7 @@ int osc_page_init(const struct lu_env *env, struct cl_object *obj,
 
        return result;
 }
 
        return result;
 }
+EXPORT_SYMBOL(osc_page_init);
 
 /**
  * Helper function called by osc_io_submit() for every page in an immediate
 
 /**
  * Helper function called by osc_io_submit() for every page in an immediate
@@ -776,6 +777,7 @@ static int osc_lru_alloc(const struct lu_env *env, struct client_obd *cli,
        struct l_wait_info lwi = LWI_INTR(LWI_ON_SIGNAL_NOOP, NULL);
        struct osc_io *oio = osc_env_io(env);
        int rc = 0;
        struct l_wait_info lwi = LWI_INTR(LWI_ON_SIGNAL_NOOP, NULL);
        struct osc_io *oio = osc_env_io(env);
        int rc = 0;
+
        ENTRY;
 
        if (cli->cl_cache == NULL) /* shall not be in LRU */
        ENTRY;
 
        if (cli->cl_cache == NULL) /* shall not be in LRU */
index d16a7af..85df555 100644 (file)
@@ -408,31 +408,34 @@ out:
        RETURN(rc);
 }
 
        RETURN(rc);
 }
 
-int osc_punch_base(struct obd_export *exp, struct obdo *oa,
-                   obd_enqueue_update_f upcall, void *cookie,
-                   struct ptlrpc_request_set *rqset)
+int osc_punch_send(struct obd_export *exp, struct obdo *oa,
+                  obd_enqueue_update_f upcall, void *cookie)
 {
 {
-        struct ptlrpc_request   *req;
-        struct osc_setattr_args *sa;
-        struct ost_body         *body;
-        int                      rc;
-        ENTRY;
+       struct ptlrpc_request *req;
+       struct osc_setattr_args *sa;
+       struct obd_import *imp = class_exp2cliimp(exp);
+       struct ost_body *body;
+       int rc;
 
 
-        req = ptlrpc_request_alloc(class_exp2cliimp(exp), &RQF_OST_PUNCH);
-        if (req == NULL)
-                RETURN(-ENOMEM);
+       ENTRY;
 
 
-        rc = ptlrpc_request_pack(req, LUSTRE_OST_VERSION, OST_PUNCH);
-        if (rc) {
-                ptlrpc_request_free(req);
-                RETURN(rc);
-        }
-        req->rq_request_portal = OST_IO_PORTAL; /* bug 7198 */
-        ptlrpc_at_set_req_timeout(req);
+       req = ptlrpc_request_alloc(imp, &RQF_OST_PUNCH);
+       if (req == NULL)
+               RETURN(-ENOMEM);
+
+       rc = ptlrpc_request_pack(req, LUSTRE_OST_VERSION, OST_PUNCH);
+       if (rc < 0) {
+               ptlrpc_request_free(req);
+               RETURN(rc);
+       }
+
+       osc_set_io_portal(req);
+
+       ptlrpc_at_set_req_timeout(req);
 
        body = req_capsule_client_get(&req->rq_pill, &RMF_OST_BODY);
 
        body = req_capsule_client_get(&req->rq_pill, &RMF_OST_BODY);
-       LASSERT(body);
-       lustre_set_wire_obdo(&req->rq_import->imp_connect_data, &body->oa, oa);
+
+       lustre_set_wire_obdo(&imp->imp_connect_data, &body->oa, oa);
 
        ptlrpc_request_set_replen(req);
 
 
        ptlrpc_request_set_replen(req);
 
@@ -442,13 +445,12 @@ int osc_punch_base(struct obd_export *exp, struct obdo *oa,
        sa->sa_oa = oa;
        sa->sa_upcall = upcall;
        sa->sa_cookie = cookie;
        sa->sa_oa = oa;
        sa->sa_upcall = upcall;
        sa->sa_cookie = cookie;
-       if (rqset == PTLRPCD_SET)
-               ptlrpcd_add_req(req);
-       else
-               ptlrpc_set_add_req(rqset, req);
+
+       ptlrpcd_add_req(req);
 
        RETURN(0);
 }
 
        RETURN(0);
 }
+EXPORT_SYMBOL(osc_punch_send);
 
 static int osc_sync_interpret(const struct lu_env *env,
                               struct ptlrpc_request *req,
 
 static int osc_sync_interpret(const struct lu_env *env,
                               struct ptlrpc_request *req,
@@ -1154,8 +1156,9 @@ osc_brw_prep_request(int cmd, struct client_obd *cli, struct obdo *oa,
                 ptlrpc_request_free(req);
                 RETURN(rc);
         }
                 ptlrpc_request_free(req);
                 RETURN(rc);
         }
-        req->rq_request_portal = OST_IO_PORTAL; /* bug 7198 */
-        ptlrpc_at_set_req_timeout(req);
+       osc_set_io_portal(req);
+
+       ptlrpc_at_set_req_timeout(req);
        /* ask ptlrpc not to resend on EINPROGRESS since BRWs have their own
         * retry logic */
        req->rq_no_retry_einprogress = 1;
        /* ask ptlrpc not to resend on EINPROGRESS since BRWs have their own
         * retry logic */
        req->rq_no_retry_einprogress = 1;