X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Fosp%2Fosp_internal.h;h=0871d8da24fc8e7ceed6b675a8690210d8fd7293;hb=de73bdafb0e0ab187865dcdcc76c0f48e1b5239e;hp=2ba3de21054691ae27ac1afc01b7a66f9938d491;hpb=6c4c51e3079e6c257fbf86536e4739110c166e3b;p=fs%2Flustre-release.git diff --git a/lustre/osp/osp_internal.h b/lustre/osp/osp_internal.h index 2ba3de2..0871d8da 100644 --- a/lustre/osp/osp_internal.h +++ b/lustre/osp/osp_internal.h @@ -27,7 +27,7 @@ * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved. * Use is subject to license terms. * - * Copyright (c) 2012, Intel Corporation. + * Copyright (c) 2012, 2013, Intel Corporation. */ /* * This file is part of Lustre, http://www.lustre.org/ @@ -44,6 +44,7 @@ #include #include #include +#include #include /* @@ -64,10 +65,40 @@ struct osp_id_tracker { cfs_atomic_t otr_refcount; }; +struct osp_precreate { + /* + * Precreation pool + */ + spinlock_t osp_pre_lock; + + /* last fid to assign in creation */ + struct lu_fid osp_pre_used_fid; + /* last created id OST reported, next-created - available id's */ + struct lu_fid osp_pre_last_created_fid; + /* how many ids are reserved in declare, we shouldn't block in create */ + __u64 osp_pre_reserved; + /* consumers (who needs new ids) wait here */ + wait_queue_head_t osp_pre_user_waitq; + /* current precreation status: working, failed, stopping? */ + int osp_pre_status; + /* how many to precreate next time */ + int osp_pre_grow_count; + int osp_pre_min_grow_count; + int osp_pre_max_grow_count; + /* whether to grow precreation window next time or not */ + int osp_pre_grow_slow; + /* cleaning up orphans or recreating missing objects */ + int osp_pre_recovering; +}; + struct osp_device { struct dt_device opd_dt_dev; /* corresponded OST index */ int opd_index; + + /* corrsponded MDT index, which will be used when connecting to OST + * for validating the connection (see ofd_parse_connect_data) */ + int opd_group; /* device used to store persistent state (llogs, last ids) */ struct obd_export *opd_storage_exp; struct dt_device *opd_storage; @@ -93,40 +124,19 @@ struct osp_device { int opd_got_disconnected; int opd_imp_connected; int opd_imp_active; - int opd_imp_seen_connected:1, + unsigned int opd_imp_seen_connected:1, opd_connect_mdt:1; /* whether local recovery is completed: * reported via ->ldo_recovery_complete() */ int opd_recovery_completed; - /* - * Precreation pool - */ - spinlock_t opd_pre_lock; - - /* last fid to assign in creation */ - struct lu_fid opd_pre_used_fid; - /* last created id OST reported, next-created - available id's */ - struct lu_fid opd_pre_last_created_fid; - /* how many ids are reserved in declare, we shouldn't block in create */ - __u64 opd_pre_reserved; + /* precreate structure for OSP */ + struct osp_precreate *opd_pre; /* dedicate precreate thread */ struct ptlrpc_thread opd_pre_thread; /* thread waits for signals about pool going empty */ - cfs_waitq_t opd_pre_waitq; - /* consumers (who needs new ids) wait here */ - cfs_waitq_t opd_pre_user_waitq; - /* current precreation status: working, failed, stopping? */ - int opd_pre_status; - /* how many to precreate next time */ - int opd_pre_grow_count; - int opd_pre_min_grow_count; - int opd_pre_max_grow_count; - /* whether to grow precreation window next time or not */ - int opd_pre_grow_slow; - /* cleaning up orphans or recreating missing objects */ - int opd_pre_recovering; + wait_queue_head_t opd_pre_waitq; /* * OST synchronization @@ -140,7 +150,7 @@ struct osp_device { int opd_syn_prev_done; /* found records */ struct ptlrpc_thread opd_syn_thread; - cfs_waitq_t opd_syn_waitq; + wait_queue_head_t opd_syn_waitq; /* list of remotely committed rpc */ cfs_list_t opd_syn_committed_there; /* number of changes being under sync */ @@ -168,7 +178,7 @@ struct osp_device { */ struct obd_statfs opd_statfs; cfs_time_t opd_statfs_fresh_till; - cfs_timer_t opd_statfs_timer; + struct timer_list opd_statfs_timer; int opd_statfs_update_in_progress; /* how often to update statfs data */ int opd_statfs_maxage; @@ -176,18 +186,36 @@ struct osp_device { cfs_proc_dir_entry_t *opd_symlink; }; -extern cfs_mem_cache_t *osp_object_kmem; +#define opd_pre_lock opd_pre->osp_pre_lock +#define opd_pre_used_fid opd_pre->osp_pre_used_fid +#define opd_pre_last_created_fid opd_pre->osp_pre_last_created_fid +#define opd_pre_reserved opd_pre->osp_pre_reserved +#define opd_pre_user_waitq opd_pre->osp_pre_user_waitq +#define opd_pre_status opd_pre->osp_pre_status +#define opd_pre_grow_count opd_pre->osp_pre_grow_count +#define opd_pre_min_grow_count opd_pre->osp_pre_min_grow_count +#define opd_pre_max_grow_count opd_pre->osp_pre_max_grow_count +#define opd_pre_grow_slow opd_pre->osp_pre_grow_slow +#define opd_pre_recovering opd_pre->osp_pre_recovering + +extern struct kmem_cache *osp_object_kmem; /* this is a top object */ struct osp_object { - struct lu_object_header opo_header; - struct dt_object opo_obj; - int opo_reserved:1, - opo_new:1; + struct lu_object_header opo_header; + struct dt_object opo_obj; + unsigned int opo_reserved:1, + opo_new:1, + opo_empty:1; + + /* read/write lock for md osp object */ + struct rw_semaphore opo_sem; + const struct lu_env *opo_owner; }; extern struct lu_object_operations osp_lu_obj_ops; extern const struct dt_device_operations osp_dt_ops; +extern struct dt_object_operations osp_md_obj_ops; struct osp_thread_info { struct lu_buf osi_lb; @@ -207,6 +235,8 @@ struct osp_thread_info { struct llog_cookie osi_cookie; struct llog_catid osi_cid; struct lu_seq_range osi_seq; + struct ldlm_res_id osi_resid; + struct obdo osi_obdo; }; static inline void osp_objid_buf_prep(struct lu_buf *buf, loff_t *off, @@ -312,6 +342,11 @@ static inline struct dt_object *osp_object_child(struct osp_object *o) struct dt_object, do_lu); } +static inline struct seq_server_site *osp_seq_site(struct osp_device *osp) +{ + return osp->opd_dt_dev.dd_lu_dev.ld_site->ld_seq_site; +} + #define osp_init_rpc_lock(lck) mdc_init_rpc_lock(lck) #define osp_get_rpc_lock(lck, it) mdc_get_rpc_lock(lck, it) #define osp_put_rpc_lock(lck, it) mdc_put_rpc_lock(lck, it) @@ -335,6 +370,38 @@ static inline void osp_update_last_fid(struct osp_device *d, struct lu_fid *fid) } } +static int osp_fid_end_seq(const struct lu_env *env, struct lu_fid *fid) +{ + if (fid_is_idif(fid)) { + struct osp_thread_info *info = osp_env_info(env); + struct ost_id *oi = &info->osi_oi; + + fid_to_ostid(fid, oi); + return ostid_id(oi) == IDIF_MAX_OID; + } else { + return fid_oid(fid) == LUSTRE_DATA_SEQ_MAX_WIDTH; + } +} + +static inline int osp_precreate_end_seq_nolock(const struct lu_env *env, + struct osp_device *osp) +{ + struct lu_fid *fid = &osp->opd_pre_last_created_fid; + + return osp_fid_end_seq(env, fid); +} + +static inline int osp_precreate_end_seq(const struct lu_env *env, + struct osp_device *osp) +{ + int rc; + + spin_lock(&osp->opd_pre_lock); + rc = osp_precreate_end_seq_nolock(env, osp); + spin_unlock(&osp->opd_pre_lock); + return rc; +} + static inline int osp_is_fid_client(struct osp_device *osp) { struct obd_import *imp = osp->opd_obd->u.cli.cl_import; @@ -346,6 +413,10 @@ static inline int osp_is_fid_client(struct osp_device *osp) void osp_update_last_id(struct osp_device *d, obd_id objid); extern struct llog_operations osp_mds_ost_orig_logops; +/* osp_md_object.c */ +int osp_trans_start(const struct lu_env *env, struct dt_device *dt, + struct thandle *th); +int osp_trans_stop(const struct lu_env *env, struct thandle *th); /* osp_precreate.c */ int osp_init_precreate(struct osp_device *d); int osp_precreate_reserve(const struct lu_env *env, struct osp_device *d); @@ -359,6 +430,7 @@ void osp_statfs_need_now(struct osp_device *d); int osp_reset_last_used(const struct lu_env *env, struct osp_device *osp); int osp_write_last_oid_seq_files(struct lu_env *env, struct osp_device *osp, struct lu_fid *fid, int sync); +int osp_init_pre_fid(struct osp_device *osp); /* lproc_osp.c */ void lprocfs_osp_init_vars(struct lprocfs_static_vars *lvars); @@ -374,10 +446,9 @@ int osp_sync_init(const struct lu_env *env, struct osp_device *d); int osp_sync_fini(struct osp_device *d); void __osp_sync_check_for_work(struct osp_device *d); -/* osp_ost.c */ -int osp_init_for_ost(const struct lu_env *env, struct osp_device *m, - struct lu_device_type *ldt, struct lustre_cfg *cfg); -int osp_disconnect(struct osp_device *d); -int osp_fini_for_ost(struct osp_device *osp); +/* 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; #endif