X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Finclude%2Fobd.h;h=47a6df7572bd51848ccad81af0f5a14dd67e176f;hb=840274b5c5e95e44a5ffedd08ebb4727bc39a845;hp=8e33ef0e4c8261b545a3d5047d3823080b1dd7af;hpb=3049ba6ba1241770adeeeffbdfb6fef82bbf0b92;p=fs%2Flustre-release.git

diff --git a/lustre/include/obd.h b/lustre/include/obd.h
index 8e33ef0..47a6df7 100644
--- a/lustre/include/obd.h
+++ b/lustre/include/obd.h
@@ -969,7 +969,14 @@ struct md_readdir_info {
 struct md_op_item;
 typedef int (*md_op_item_cb_t)(struct md_op_item *item, int rc);
 
+enum md_item_opcode {
+	MD_OP_NONE	= 0,
+	MD_OP_GETATTR	= 1,
+	MD_OP_MAX,
+};
+
 struct md_op_item {
+	enum md_item_opcode		 mop_opc;
 	struct md_op_data		 mop_data;
 	struct lookup_intent		 mop_it;
 	struct lustre_handle		 mop_lockh;
@@ -981,6 +988,69 @@ struct md_op_item {
 	struct work_struct		 mop_work;
 };
 
+enum lu_batch_flags {
+	BATCH_FL_NONE	= 0x0,
+	/* All requests in a batch are read-only. */
+	BATCH_FL_RDONLY	= 0x1,
+	/* Will create PTLRPC request set for the batch. */
+	BATCH_FL_RQSET	= 0x2,
+	/* Whether need sync commit. */
+	BATCH_FL_SYNC	= 0x4,
+};
+
+struct lu_batch {
+	struct ptlrpc_request_set	*lbt_rqset;
+	__s32				 lbt_result;
+	__u32				 lbt_flags;
+	/* Max batched SUB requests count in a batch. */
+	__u32				 lbt_max_count;
+};
+
+struct batch_update_head {
+	struct obd_export	*buh_exp;
+	struct lu_batch		*buh_batch;
+	int			 buh_flags;
+	__u32			 buh_count;
+	__u32			 buh_update_count;
+	__u32			 buh_buf_count;
+	__u32			 buh_reqsize;
+	__u32			 buh_repsize;
+	__u32			 buh_batchid;
+	struct list_head	 buh_buf_list;
+	struct list_head	 buh_cb_list;
+};
+
+struct object_update_callback;
+typedef int (*object_update_interpret_t)(struct ptlrpc_request *req,
+					 struct lustre_msg *repmsg,
+					 struct object_update_callback *ouc,
+					 int rc);
+
+struct object_update_callback {
+	struct list_head		 ouc_item;
+	object_update_interpret_t	 ouc_interpret;
+	struct batch_update_head	*ouc_head;
+	void				*ouc_data;
+};
+
+typedef int (*md_update_pack_t)(struct batch_update_head *head,
+				struct lustre_msg *reqmsg,
+				size_t *max_pack_size,
+				struct md_op_item *item);
+
+struct cli_batch {
+	struct lu_batch			  cbh_super;
+	struct batch_update_head	 *cbh_head;
+};
+
+struct lu_batch *cli_batch_create(struct obd_export *exp,
+				  enum lu_batch_flags flags, __u32 max_count);
+int cli_batch_stop(struct obd_export *exp, struct lu_batch *bh);
+int cli_batch_flush(struct obd_export *exp, struct lu_batch *bh, bool wait);
+int cli_batch_add(struct obd_export *exp, struct lu_batch *bh,
+		  struct md_op_item *item, md_update_pack_t packer,
+		  object_update_interpret_t interpreter);
+
 struct obd_ops {
 	struct module *o_owner;
 	int (*o_iocontrol)(unsigned int cmd, struct obd_export *exp, int len,
@@ -1229,6 +1299,14 @@ struct md_ops {
 			  const union lmv_mds_md *lmv, size_t lmv_size);
 	int (*m_rmfid)(struct obd_export *exp, struct fid_array *fa, int *rcs,
 		       struct ptlrpc_request_set *set);
+	struct lu_batch *(*m_batch_create)(struct obd_export *exp,
+					   enum lu_batch_flags flags,
+					   __u32 max_count);
+	int (*m_batch_stop)(struct obd_export *exp, struct lu_batch *bh);
+	int (*m_batch_flush)(struct obd_export *exp, struct lu_batch *bh,
+			     bool wait);
+	int (*m_batch_add)(struct obd_export *exp, struct lu_batch *bh,
+			   struct md_op_item *item);
 };
 
 static inline struct md_open_data *obd_mod_alloc(void)