/* callback is register once per diskfs -- that's the whole point */
struct dt_txn_callback otr_tx_cb;
/* single node can run many clusters */
- cfs_list_t otr_wakeup_list;
- cfs_list_t otr_list;
+ struct list_head otr_wakeup_list;
+ struct list_head otr_list;
/* underlying shared device */
struct dt_device *otr_dev;
/* how many users of this tracker */
struct ptlrpc_thread opd_syn_thread;
wait_queue_head_t opd_syn_waitq;
/* list of remotely committed rpc */
- cfs_list_t opd_syn_committed_there;
+ struct list_head opd_syn_committed_there;
/* number of changes being under sync */
int opd_syn_sync_in_progress;
/* number of RPCs in flight - flow control */
/* last processed (taken from llog) id */
unsigned long opd_syn_last_processed_id;
struct osp_id_tracker *opd_syn_tracker;
- cfs_list_t opd_syn_ontrack;
+ 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
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,
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 */
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;