X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=blobdiff_plain;f=lustre%2Finclude%2Flu_target.h;h=307fff8810b502440e66a47e323b3d0706c83948;hp=4464c740b6d7e1bb72cac23c538e7724154f7374;hb=e9389613eb29297f7b5a6b6cd896bafc7a5551f8;hpb=70d70c4f541c84adc88c372d670cd3a7fa8bc91f

diff --git a/lustre/include/lu_target.h b/lustre/include/lu_target.h
index 4464c74..307fff8 100644
--- a/lustre/include/lu_target.h
+++ b/lustre/include/lu_target.h
@@ -116,9 +116,42 @@ struct target_distribute_txn_data {
 	void			*tdtd_show_retrievers_cbdata;
 };
 
+struct tg_grants_data {
+	/* grants: all values in bytes */
+	/* grant lock to protect all grant counters */
+	spinlock_t		 tgd_grant_lock;
+	/* total amount of dirty data reported by clients in incoming obdo */
+	u64			 tgd_tot_dirty;
+	/* sum of filesystem space granted to clients for async writes */
+	u64			 tgd_tot_granted;
+	/* grant used by I/Os in progress (between prepare and commit) */
+	u64			 tgd_tot_pending;
+	/* number of clients using grants */
+	int			 tgd_tot_granted_clients;
+	/* shall we grant space to clients not
+	 * supporting OBD_CONNECT_GRANT_PARAM? */
+	int			 tgd_grant_compat_disable;
+	/* protect all statfs-related counters */
+	spinlock_t		 tgd_osfs_lock;
+	__u64			 tgd_osfs_age;
+	int			 tgd_blockbits;
+	/* counters used during statfs update, protected by ofd_osfs_lock.
+	 * record when some statfs refresh are in progress */
+	int			 tgd_statfs_inflight;
+	/* writes between prep & commit which might be accounted twice in
+	 * ofd_osfs.os_bavail */
+	u64			 tgd_osfs_unstable;
+	/* track writes completed while statfs refresh is underway.
+	 * tracking is only effective when ofd_statfs_inflight > 1 */
+	u64			 tgd_osfs_inflight;
+	/* statfs optimization: we cache a bit  */
+	struct obd_statfs	 tgd_osfs;
+};
+
 struct lu_target {
 	struct obd_device	*lut_obd;
 	struct dt_device	*lut_bottom;
+	struct dt_device_param	 lut_dt_conf;
 
 	struct target_distribute_txn_data *lut_tdtd;
 	struct ptlrpc_thread	lut_tdtd_commit_thread;
@@ -165,6 +198,9 @@ struct lu_target {
 	/** cross MDT locks which should trigger Sync-on-Lock-Cancel */
 	spinlock_t		 lut_slc_locks_guard;
 	struct list_head	 lut_slc_locks;
+
+	/* target grants fields */
+	struct tg_grants_data	 lut_tgd;
 };
 
 /* number of slots in reply bitmap */
@@ -459,6 +495,35 @@ int tgt_add_reply_data(const struct lu_env *env, struct lu_target *tgt,
 struct tg_reply_data *tgt_lookup_reply_by_xid(struct tg_export_data *ted,
 					       __u64 xid);
 
+/* target/tgt_grant.c */
+static inline int exp_grant_param_supp(struct obd_export *exp)
+{
+	return !!(exp_connect_flags(exp) & OBD_CONNECT_GRANT_PARAM);
+}
+
+/* Blocksize used for client not supporting OBD_CONNECT_GRANT_PARAM.
+ * That's 4KB=2^12 which is the biggest block size known to work whatever
+ * the client's page size is. */
+#define COMPAT_BSIZE_SHIFT 12
+
+void tgt_grant_sanity_check(struct obd_device *obd, const char *func);
+void tgt_grant_connect(const struct lu_env *env, struct obd_export *exp,
+		       struct obd_connect_data *data, bool new_conn);
+void tgt_grant_discard(struct obd_export *exp);
+void tgt_grant_prepare_read(const struct lu_env *env, struct obd_export *exp,
+			    struct obdo *oa);
+void tgt_grant_prepare_write(const struct lu_env *env, struct obd_export *exp,
+			     struct obdo *oa, struct niobuf_remote *rnb,
+			     int niocount);
+void tgt_grant_commit(struct obd_export *exp, unsigned long grant_used, int rc);
+int tgt_grant_commit_cb_add(struct thandle *th, struct obd_export *exp,
+			    unsigned long grant);
+long tgt_grant_create(const struct lu_env *env, struct obd_export *exp,
+		      int *nr);
+int tgt_statfs_internal(const struct lu_env *env, struct lu_target *lut,
+			struct obd_statfs *osfs, __u64 max_age,
+			int *from_cache);
+
 /* target/update_trans.c */
 int distribute_txn_init(const struct lu_env *env,
 			struct lu_target *lut,