LU-4976 osp: add comments for osp_trans.c functions

[fs/lustre-release.git] / lustre / osp / osp_internal.h

diff --git a/lustre/osp/osp_internal.h b/lustre/osp/osp_internal.h
index 3a5d0a6..6f12c20 100644 (file)
--- a/lustre/osp/osp_internal.h
+++ b/lustre/osp/osp_internal.h
@@ -174,6 +174,9 @@ struct osp_device {
        unsigned long                    opd_syn_last_processed_id;
        struct osp_id_tracker           *opd_syn_tracker;
        struct list_head                 opd_syn_ontrack;
+       /* stop processing new requests until barrier=0 */
+       atomic_t                         opd_syn_barrier;
+       wait_queue_head_t                opd_syn_barrier_waitq;
 
        /*
         * statfs related fields: OSP maintains it on its own
@@ -491,27 +494,24 @@ static inline int osp_is_fid_client(struct osp_device *osp)
        return imp->imp_connect_data.ocd_connect_flags & OBD_CONNECT_FID;
 }
 
-typedef int (*osp_async_update_interpterer_t)(const struct lu_env *env,
-                                             struct object_update_reply *reply,
-                                             struct ptlrpc_request *req,
-                                             struct osp_object *obj,
-                                             void *data, int index, int rc);
+typedef int (*osp_async_request_interpreter_t)(const struct lu_env *env,
+                                              struct object_update_reply *rep,
+                                              struct ptlrpc_request *req,
+                                              struct osp_object *obj,
+                                              void *data, int index, int rc);
 
 /* osp_dev.c */
 void osp_update_last_id(struct osp_device *d, obd_id objid);
 extern struct llog_operations osp_mds_ost_orig_logops;
 
 /* osp_trans.c */
-struct dt_update_request *
-osp_find_or_create_async_update_request(struct osp_device *osp);
-int osp_insert_async_update(const struct lu_env *env,
-                           struct dt_update_request *update, int op,
-                           struct osp_object *obj, int count,
-                           int *lens, const char **bufs, void *data,
-                           osp_async_update_interpterer_t interpterer);
-int osp_unplug_async_update(const struct lu_env *env,
-                           struct osp_device *osp,
-                           struct dt_update_request *update);
+int osp_insert_async_request(const struct lu_env *env,
+                            int op, struct osp_object *obj, int count,
+                            int *lens, const char **bufs, void *data,
+                            osp_async_request_interpreter_t interpterer);
+int osp_unplug_async_request(const struct lu_env *env,
+                            struct osp_device *osp,
+                            struct dt_update_request *update);
 struct thandle *osp_trans_create(const struct lu_env *env,
                                 struct dt_device *d);
 int osp_trans_start(const struct lu_env *env, struct dt_device *dt,
@@ -586,7 +586,6 @@ int osp_write_last_oid_seq_files(struct lu_env *env, struct osp_device *osp,
 int osp_init_pre_fid(struct osp_device *osp);
 
 /* lproc_osp.c */
-void lprocfs_osp_init_vars(struct lprocfs_static_vars *lvars);
 void osp_lprocfs_init(struct osp_device *osp);
 
 /* osp_sync.c */
@@ -600,7 +599,6 @@ int osp_sync_fini(struct osp_device *d);
 void __osp_sync_check_for_work(struct osp_device *d);
 
 /* lwp_dev.c */
-void lprocfs_lwp_init_vars(struct lprocfs_static_vars *lvars);
 extern struct obd_ops lwp_obd_device_ops;
 extern struct lu_device_type lwp_device_type;