* Copyright (c) 2003, 2010, Oracle and/or its affiliates. All rights reserved.
* Use is subject to license terms.
*
- * Copyright (c) 2012, 2016, Intel Corporation.
+ * Copyright (c) 2012, 2017, Intel Corporation.
*/
/*
* This file is part of Lustre, http://www.lustre.org/
#define OFD_VALID_FLAGS (LA_TYPE | LA_MODE | LA_SIZE | LA_BLOCKS | \
LA_BLKSIZE | LA_ATIME | LA_MTIME | LA_CTIME)
-/* per-client-per-object persistent state (LRU) */
-struct ofd_mod_data {
- struct list_head fmd_list; /* linked to fed_mod_list */
- struct lu_fid fmd_fid; /* FID being written to */
- __u64 fmd_mactime_xid; /* xid highest {m,a,c}time setattr */
- cfs_time_t fmd_expire; /* time when the fmd should expire */
- int fmd_refcount; /* reference counter - list holds 1 */
-};
-
-#define OFD_FMD_MAX_NUM_DEFAULT 128
-#define OFD_FMD_MAX_AGE_DEFAULT msecs_to_jiffies((obd_timeout+10)*MSEC_PER_SEC)
-
#define OFD_SOFT_SYNC_LIMIT_DEFAULT 16
/* request stats */
spinlock_t os_last_oid_lock;
struct mutex os_create_lock;
atomic_t os_refc;
+ atomic_t os_precreate_in_progress;
struct dt_object *os_lastid_obj;
- unsigned long os_destroys_in_progress:1;
+ unsigned long os_destroys_in_progress:1,
+ os_last_id_synced:1;
};
struct ofd_device {
struct dt_device ofd_dt_dev;
struct dt_device *ofd_osd;
struct obd_export *ofd_osd_exp;
- struct dt_device_param ofd_dt_conf;
/* DLM name-space for meta-data locks maintained by this server */
struct ldlm_namespace *ofd_namespace;
int ofd_precreate_batch;
spinlock_t ofd_batch_lock;
- /* protect all statfs-related counters */
- spinlock_t ofd_osfs_lock;
- /* statfs optimization: we cache a bit */
- struct obd_statfs ofd_osfs;
- __u64 ofd_osfs_age;
- int ofd_blockbits;
- /* counters used during statfs update, protected by ofd_osfs_lock.
- * record when some statfs refresh are in progress */
- int ofd_statfs_inflight;
-
- /* writes between prep & commit which might be accounted twice in
- * ofd_osfs.os_bavail */
- u64 ofd_osfs_unstable;
-
- /* track writes completed while statfs refresh is underway.
- * tracking is only effective when ofd_statfs_inflight > 1 */
- u64 ofd_osfs_inflight;
-
- /* grants: all values in bytes */
- /* grant lock to protect all grant counters */
- spinlock_t ofd_grant_lock;
- /* total amount of dirty data reported by clients in incoming obdo */
- u64 ofd_tot_dirty;
- /* sum of filesystem space granted to clients for async writes */
- u64 ofd_tot_granted;
- /* grant used by I/Os in progress (between prepare and commit) */
- u64 ofd_tot_pending;
- /* number of clients using grants */
- int ofd_tot_granted_clients;
-
/* preferred BRW size, decided by storage type and capability */
__u32 ofd_brw_size;
/* checksum types supported on this node */
enum cksum_types ofd_cksum_types_supported;
- /* ofd mod data: ofd_device wide values */
- int ofd_fmd_max_num; /* per ofd ofd_mod_data */
- cfs_duration_t ofd_fmd_max_age; /* time to fmd expiry */
-
spinlock_t ofd_flags_lock;
unsigned long ofd_raid_degraded:1,
/* sync journal on writes */
- ofd_syncjournal:1,
- /* shall we grant space to clients not
- * supporting OBD_CONNECT_GRANT_PARAM? */
- ofd_grant_compat_disable:1,
+ ofd_sync_journal:1,
/* Protected by ofd_lastid_rwsem. */
ofd_lastid_rebuilding:1,
ofd_record_fid_accessed:1,
ofd_lfsck_verify_pfid:1,
- ofd_skip_lfsck:1;
+ ofd_skip_lfsck:1,
+ /* Whether to enforce T10PI checksum of RPC */
+ ofd_checksum_t10pi_enforce:1;
struct seq_server_site ofd_seq_site;
/* the limit of SOFT_SYNC RPCs that will trigger a soft sync */
unsigned int ofd_soft_sync_limit;
struct ptlrpc_thread ofd_inconsistency_thread;
struct list_head ofd_inconsistency_list;
spinlock_t ofd_inconsistency_lock;
+ /* Backwards compatibility */
+ struct attribute *ofd_read_cache_enable;
+ struct attribute *ofd_read_cache_max_filesize;
+ struct attribute *ofd_write_cache_enable;
};
static inline struct ofd_device *ofd_dev(struct lu_device *d)
struct lu_buf fti_buf;
loff_t fti_off;
- /* Space used by the I/O, used by grant code */
- unsigned long fti_used;
struct ost_lvb fti_lvb;
union {
struct lfsck_req_local fti_lrl;
/* ofd_obd.c */
extern struct obd_ops ofd_obd_ops;
-int ofd_statfs_internal(const struct lu_env *env, struct ofd_device *ofd,
- struct obd_statfs *osfs, __u64 max_age,
- int *from_cache);
int ofd_destroy_by_fid(const struct lu_env *env, struct ofd_device *ofd,
const struct lu_fid *fid, int orphan);
int ofd_statfs(const struct lu_env *env, struct obd_export *exp,
- struct obd_statfs *osfs, __u64 max_age, __u32 flags);
+ struct obd_statfs *osfs, time64_t max_age, __u32 flags);
int ofd_obd_disconnect(struct obd_export *exp);
/* ofd_fs.c */
int ofd_stop_inconsistency_verification_thread(struct ofd_device *ofd);
int ofd_verify_ff(const struct lu_env *env, struct ofd_object *fo,
struct obdo *oa);
+int ofd_verify_layout_version(const struct lu_env *env,
+ struct ofd_object *fo, const struct obdo *oa);
int ofd_preprw(const struct lu_env *env,int cmd, struct obd_export *exp,
struct obdo *oa, int objcount, struct obd_ioobj *obj,
struct niobuf_remote *rnb, int *nr_local,
void *cookie);
/* lproc_ofd.c */
+int ofd_tunables_init(struct ofd_device *ofd);
#ifdef CONFIG_PROC_FS
-extern struct lprocfs_vars lprocfs_ofd_obd_vars[];
void ofd_stats_counter_init(struct lprocfs_stats *stats);
#else
static inline void ofd_stats_counter_init(struct lprocfs_stats *stats) {}
struct ofd_device *ofd,
const struct lu_fid *fid);
int ofd_object_ff_load(const struct lu_env *env, struct ofd_object *fo);
+int ofd_object_ff_update(const struct lu_env *env, struct ofd_object *fo,
+ const struct obdo *oa, struct filter_fid *ff);
int ofd_precreate_objects(const struct lu_env *env, struct ofd_device *ofd,
u64 id, struct ofd_seq *oseq, int nr, int sync);
dt_object_put(env, &fo->ofo_obj);
}
int ofd_attr_set(const struct lu_env *env, struct ofd_object *fo,
- struct lu_attr *la, struct filter_fid *ff);
+ struct lu_attr *la, struct obdo *oa);
int ofd_object_punch(const struct lu_env *env, struct ofd_object *fo,
__u64 start, __u64 end, struct lu_attr *la,
- struct filter_fid *ff, struct obdo *oa);
-int ofd_object_destroy(const struct lu_env *, struct ofd_object *, int);
+ struct obdo *oa);
+int ofd_destroy(const struct lu_env *, struct ofd_object *, int);
int ofd_attr_get(const struct lu_env *env, struct ofd_object *fo,
struct lu_attr *la);
int ofd_attr_handle_id(const struct lu_env *env, struct ofd_object *fo,
return fo;
}
-/* ofd_grants.c */
-static inline int ofd_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
-
-static inline int ofd_grant_prohibit(struct obd_export *exp,
- struct ofd_device *ofd)
-{
- /* When ofd_grant_compat_disable is set, we don't grant any space to
- * clients not supporting OBD_CONNECT_GRANT_PARAM.
- * Otherwise, space granted to such a client is inflated since it
- * consumes PAGE_SIZE of grant space per block */
- return !!(ofd_obd(ofd)->obd_self_export != exp &&
- !ofd_grant_param_supp(exp) && ofd->ofd_grant_compat_disable);
-}
-
-void ofd_grant_sanity_check(struct obd_device *obd, const char *func);
-void ofd_grant_connect(const struct lu_env *env, struct obd_export *exp,
- struct obd_connect_data *data, bool new_conn);
-void ofd_grant_discard(struct obd_export *exp);
-void ofd_grant_prepare_read(const struct lu_env *env, struct obd_export *exp,
- struct obdo *oa);
-void ofd_grant_prepare_write(const struct lu_env *env, struct obd_export *exp,
- struct obdo *oa, struct niobuf_remote *rnb,
- int niocount);
-void ofd_grant_commit(struct obd_export *exp, unsigned long grant_used, int rc);
-int ofd_grant_commit_cb_add(struct thandle *th, struct obd_export *exp,
- unsigned long grant);
-long ofd_grant_create(const struct lu_env *env, struct obd_export *exp,
- int *nr);
-
-/* ofd_fmd.c */
-int ofd_fmd_init(void);
-void ofd_fmd_exit(void);
-struct ofd_mod_data *ofd_fmd_find(struct obd_export *exp,
- const struct lu_fid *fid);
-struct ofd_mod_data *ofd_fmd_get(struct obd_export *exp,
- const struct lu_fid *fid);
-void ofd_fmd_put(struct obd_export *exp, struct ofd_mod_data *fmd);
-void ofd_fmd_expire(struct obd_export *exp);
-void ofd_fmd_cleanup(struct obd_export *exp);
-#ifdef DO_FMD_DROP
-void ofd_fmd_drop(struct obd_export *exp, const struct lu_fid *fid);
-#else
-#define ofd_fmd_drop(exp, fid) do {} while (0)
-#endif
-
/* ofd_dev.c */
int ofd_fid_set_index(const struct lu_env *env, struct ofd_device *ofd,
int index);
extern struct ldlm_valblock_ops ofd_lvbo;
/* ofd_dlm.c */
-int ofd_intent_policy(struct ldlm_namespace *ns, struct ldlm_lock **lockp,
- void *req_cookie, enum ldlm_mode mode, __u64 flags,
- void *data);
+extern struct kmem_cache *ldlm_glimpse_work_kmem;
+
+int ofd_intent_policy(const struct lu_env *env, struct ldlm_namespace *ns,
+ struct ldlm_lock **lockp, void *req_cookie,
+ enum ldlm_mode mode, __u64 flags, void *data);
static inline struct ofd_thread_info *ofd_info(const struct lu_env *env)
{
* sync on lock cancel if it is not enabled already. */
static inline void ofd_slc_set(struct ofd_device *ofd)
{
- if (ofd->ofd_syncjournal == 1)
+ if (ofd->ofd_sync_journal == 1)
ofd->ofd_lut.lut_sync_lock_cancel = NEVER_SYNC_ON_CANCEL;
else if (ofd->ofd_lut.lut_sync_lock_cancel == NEVER_SYNC_ON_CANCEL)
ofd->ofd_lut.lut_sync_lock_cancel = ALWAYS_SYNC_ON_CANCEL;
}
-static inline void ofd_prepare_fidea(struct filter_fid *ff,
- const struct obdo *oa)
-{
- /* packing fid and converting it to LE for storing into EA.
- * Here ->o_stripe_idx should be filled by LOV and rest of
- * fields - by client. */
- ff->ff_parent.f_seq = cpu_to_le64(oa->o_parent_seq);
- ff->ff_parent.f_oid = cpu_to_le32(oa->o_parent_oid);
- /* XXX: we are ignoring o_parent_ver here, since this should
- * be the same for all objects in this fileset. */
- ff->ff_parent.f_ver = cpu_to_le32(oa->o_stripe_idx);
- if (oa->o_valid & OBD_MD_FLOSTLAYOUT)
- ost_layout_cpu_to_le(&ff->ff_layout, &oa->o_layout);
- else
- memset(&ff->ff_layout, 0, sizeof(ff->ff_layout));
-}
-
static inline int ofd_validate_seq(struct obd_export *exp, __u64 seq)
{
struct filter_export_data *fed = &exp->exp_filter_data;
return 0;
}
+
#endif /* _OFD_INTERNAL_H */
git://git.whamcloud.com / fs / lustre-release.git / blobdiff