X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Ftarget%2Ftgt_internal.h;h=bc9cbbc3f49e9c6467a85251dbac9ae3d3feecc1;hb=8961816b87b626319f273874948b37edcba7a542;hp=02cc499c40295200ebc6bd3057486898273c1946;hpb=93a6346f8b73f68cb5bc02a3c826ac0e5b4c236e;p=fs%2Flustre-release.git

diff --git a/lustre/target/tgt_internal.h b/lustre/target/tgt_internal.h
index 02cc499..bc9cbbc 100644
--- a/lustre/target/tgt_internal.h
+++ b/lustre/target/tgt_internal.h
@@ -21,7 +21,7 @@
  * GPL HEADER END
  */
 /*
- * Copyright (c) 2012, Intel Corporation.
+ * Copyright (c) 2012, 2016, Intel Corporation.
  */
 /*
  * lustre/target/tgt_internal.h
@@ -43,8 +43,10 @@
 #include <lustre_req_layout.h>
 #include <lustre_sec.h>
 
-extern struct lu_context_key tgt_thread_key;
-
+extern int (*tgt_lfsck_in_notify)(const struct lu_env *env,
+				  struct dt_device *key,
+				  struct lfsck_request *lr,
+				  struct thandle *th);
 /**
  * Common data shared by tg-level handlers. This is allocated per-thread to
  * reduce stack consumption.
@@ -53,10 +55,43 @@ struct tgt_thread_info {
 	/* server and client data buffers */
 	struct lr_server_data	 tti_lsd;
 	struct lsd_client_data	 tti_lcd;
+	struct lsd_reply_data	 tti_lrd;
 	struct lu_buf		 tti_buf;
 	loff_t			 tti_off;
+
+	struct lu_attr		 tti_attr;
+	struct lu_fid		 tti_fid1;
+
+	/* transno storage during last_rcvd update */
+	__u64			 tti_transno;
+	__u32			 tti_has_trans:1,
+				 tti_mult_trans:1;
+
+	/* Updates data for OUT target */
+	struct thandle_exec_args tti_tea;
+	union {
+		struct {
+			/* for tgt_readpage()      */
+			struct lu_rdpg     tti_rdpg;
+			/* for tgt_sendpage()      */
+			struct l_wait_info tti_wait_info;
+		} rdpg;
+		struct {
+			struct dt_object_format	   tti_update_dof;
+			struct object_update_reply *tti_update_reply;
+			struct object_update	   *tti_update;
+			int			   tti_update_reply_index;
+			struct obdo		   tti_obdo;
+			struct dt_object	   *tti_dt_object;
+			struct l_wait_info tti_wait_info;
+		} update;
+	} tti_u;
+	struct lfsck_request tti_lr;
+	struct dt_insert_rec tti_rec;
 };
 
+extern struct lu_context_key tgt_thread_key;
+
 static inline struct tgt_thread_info *tgt_th_info(const struct lu_env *env)
 {
 	struct tgt_thread_info *tti;
@@ -80,4 +115,176 @@ static inline int req_xid_is_last(struct ptlrpc_request *req)
 		req->rq_xid == lcd->lcd_last_close_xid);
 }
 
+static inline char *dt_obd_name(struct dt_device *dt)
+{
+	return dt->dd_lu_dev.ld_obd->obd_name;
+}
+
+/* out_lib.c */
+int out_tx_create_exec(const struct lu_env *env, struct thandle *th,
+		       struct tx_arg *arg);
+struct tx_arg *tx_add_exec(struct thandle_exec_args *ta,
+			   tx_exec_func_t func, tx_exec_func_t undo,
+			   const char *file, int line);
+
+int out_create_add_exec(const struct lu_env *env, struct dt_object *obj,
+			struct lu_attr *attr, struct lu_fid *parent_fid,
+			struct dt_object_format *dof,
+			struct thandle_exec_args *ta, struct thandle *th,
+			struct object_update_reply *reply,
+			int index, const char *file, int line);
+
+int out_attr_set_add_exec(const struct lu_env *env, struct dt_object *dt_obj,
+			  const struct lu_attr *attr,
+			  struct thandle_exec_args *ta, struct thandle *th,
+			  struct object_update_reply *reply, int index,
+			  const char *file, int line);
+
+int out_write_add_exec(const struct lu_env *env, struct dt_object *dt_obj,
+		       const struct lu_buf *buf, loff_t pos,
+		       struct thandle_exec_args *ta, struct thandle *th,
+		       struct object_update_reply *reply, int index,
+		       const char *file, int line);
+
+int out_xattr_set_add_exec(const struct lu_env *env, struct dt_object *dt_obj,
+			   const struct lu_buf *buf, const char *name,
+			   int flags, struct thandle_exec_args *ta,
+			   struct thandle *th,
+			   struct object_update_reply *reply, int index,
+			   const char *file, int line);
+
+int out_xattr_del_add_exec(const struct lu_env *env, struct dt_object *dt_obj,
+			   const char *name, struct thandle_exec_args *ta,
+			   struct thandle *th,
+			   struct object_update_reply *reply, int index,
+			   const char *file, int line);
+
+int out_ref_add_add_exec(const struct lu_env *env, struct dt_object *dt_obj,
+			 struct thandle_exec_args *ta, struct thandle *th,
+			 struct object_update_reply *reply, int index,
+			 const char *file, int line);
+
+int out_ref_del_add_exec(const struct lu_env *env, struct dt_object *dt_obj,
+			 struct thandle_exec_args *ta, struct thandle *th,
+			 struct object_update_reply *reply, int index,
+			 const char *file, int line);
+
+int out_index_insert_add_exec(const struct lu_env *env,
+			      struct dt_object *dt_obj,
+			      const struct dt_rec *rec,
+			      const struct dt_key *key,
+			      struct thandle_exec_args *ta,
+			      struct thandle *th,
+			      struct object_update_reply *reply,
+			      int index, const char *file, int line);
+
+int out_index_delete_add_exec(const struct lu_env *env,
+			      struct dt_object *dt_obj,
+			      const struct dt_key *key,
+			      struct thandle_exec_args *ta,
+			      struct thandle *th,
+			      struct object_update_reply *reply,
+			      int index, const char *file, int line);
+
+int out_destroy_add_exec(const struct lu_env *env, struct dt_object *dt_obj,
+			 struct thandle_exec_args *ta, struct thandle *th,
+			 struct object_update_reply *reply,
+			 int index, const char *file, int line);
+
+/* Update handlers */
+int out_handle(struct tgt_session_info *tsi);
+
+#define out_tx_create(env, obj, attr, fid, dof, ta, th, reply, idx) \
+	out_create_add_exec(env, obj, attr, fid, dof, ta, th, reply, idx, \
+			    __FILE__, __LINE__)
+
+#define out_tx_attr_set(env, obj, attr, ta, th, reply, idx) \
+	out_attr_set_add_exec(env, obj, attr, ta, th, reply, idx, \
+			      __FILE__, __LINE__)
+
+#define out_tx_xattr_set(env, obj, buf, name, fl, ta, th, reply, idx)	\
+	out_xattr_set_add_exec(env, obj, buf, name, fl, ta, th, reply, idx, \
+			       __FILE__, __LINE__)
+
+#define out_tx_xattr_del(env, obj, name, ta, th, reply, idx)	\
+	out_xattr_del_add_exec(env, obj, name, ta, th, reply, idx,	\
+			       __FILE__, __LINE__)
+
+#define out_tx_ref_add(env, obj, ta, th, reply, idx) \
+	out_ref_add_add_exec(env, obj, ta, th, reply, idx,	\
+			     __FILE__, __LINE__)
+
+#define out_tx_ref_del(env, obj, ta, th, reply, idx) \
+	out_ref_del_add_exec(env, obj, ta, th, reply, idx,	\
+			     __FILE__, __LINE__)
+
+#define out_tx_index_insert(env, obj, rec, key, ta, th, reply, idx) \
+	out_index_insert_add_exec(env, obj, rec, key, ta, th, reply, idx, \
+				  __FILE__, __LINE__)
+
+#define out_tx_index_delete(env, obj, key, ta, th, reply, idx) \
+	out_index_delete_add_exec(env, obj, key, ta, th, reply, idx, \
+				  __FILE__, __LINE__)
+
+#define out_tx_destroy(env, obj, ta, th, reply, idx) \
+	out_destroy_add_exec(env, obj, ta, th, reply, idx,	\
+			     __FILE__, __LINE__)
+
+#define out_tx_write(env, obj, buf, pos, ta, th, reply, idx) \
+	out_write_add_exec(env, obj, buf, pos, ta, th, reply, idx,\
+			   __FILE__, __LINE__)
+
+const char *update_op_str(__u16 opcode);
+
+extern struct page *tgt_page_to_corrupt;
+
+int tgt_server_data_init(const struct lu_env *env, struct lu_target *tgt);
+int tgt_txn_start_cb(const struct lu_env *env, struct thandle *th,
+		     void *cookie);
+int tgt_txn_stop_cb(const struct lu_env *env, struct thandle *th,
+		    void *cookie);
+int tgt_handle_received_xid(struct obd_export *exp, __u64 rcvd_xid);
+int tgt_handle_tag(struct obd_export *exp, __u16 tag);
+
+void update_records_dump(const struct update_records *records,
+			 unsigned int mask, bool dump_updates);
+int check_and_prepare_update_record(const struct lu_env *env,
+				    struct thandle_update_records *tur);
+struct update_thread_info {
+	struct lu_attr			uti_attr;
+	struct lu_fid			uti_fid;
+	struct lu_buf			uti_buf;
+	struct thandle_update_records	uti_tur;
+	struct obdo			uti_obdo;
+	struct thandle_exec_args	uti_tea;
+	struct dt_insert_rec		uti_rec;
+	struct distribute_txn_replay_req *uti_dtrq;
+};
+
+extern struct lu_context_key update_thread_key;
+
+static inline struct update_thread_info *
+update_env_info(const struct lu_env *env)
+{
+	struct update_thread_info *uti;
+
+	uti = lu_context_key_get(&env->le_ctx, &update_thread_key);
+	LASSERT(uti != NULL);
+	return uti;
+}
+
+void update_info_init(void);
+void update_info_fini(void);
+struct sub_thandle *create_sub_thandle(struct top_multiple_thandle *tmt,
+				       struct dt_device *dt_dev);
+int sub_thandle_trans_create(const struct lu_env *env,
+			     struct top_thandle *top_th,
+			     struct sub_thandle *st);
+void distribute_txn_insert_by_batchid(struct top_multiple_thandle *new);
+int top_trans_create_tmt(const struct lu_env *env,
+			 struct top_thandle *top_th);
+
+void tgt_cancel_slc_locks(struct lu_target *tgt, __u64 transno);
+void barrier_init(void);
+void barrier_fini(void);
 #endif /* _TG_INTERNAL_H */