*
* You should have received a copy of the GNU General Public License
* version 2 along with this program; If not, see
- * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
- *
- * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
- * CA 95054 USA or visit www.sun.com if you need additional information or
- * have any questions.
+ * http://www.gnu.org/licenses/gpl-2.0.html
*
* GPL HEADER END
*/
* Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
* Use is subject to license terms.
*
- * Copyright (c) 2012, 2015, Intel Corporation.
+ * Copyright (c) 2012, 2016, Intel Corporation.
*/
/*
* This file is part of Lustre, http://www.lustre.org/
*/
struct osp_id_tracker {
spinlock_t otr_lock;
- __u32 otr_next_id;
- __u32 otr_committed_id;
+ __u64 otr_next_id;
+ __u64 otr_committed_id;
/* callback is register once per diskfs -- that's the whole point */
struct dt_txn_callback otr_tx_cb;
/* single node can run many clusters */
int osp_pre_create_slow;
/* cleaning up orphans or recreating missing objects */
int osp_pre_recovering;
+ int osp_pre_delorphan_sent;
};
struct osp_update_request_sub {
int our_update_nr;
struct list_head our_cb_items;
+ struct list_head our_invalidate_cb_list;
/* points to thandle if this update request belongs to one */
struct osp_thandle *our_th;
__u64 our_version;
+ __u64 our_generation;
/* protect our_list and flag */
spinlock_t our_list_lock;
/* linked to the list(ou_list) in osp_updates */
struct list_head ou_list;
spinlock_t ou_lock;
wait_queue_head_t ou_waitq;
- /* wait for next updates */
+
+ /* The next rpc version which supposed to be sent in
+ * osp_send_update_thread().*/
__u64 ou_rpc_version;
+
+ /* The rpc version assigned to the osp thandle during (osp_md_write()),
+ * which will be sent by this order. Note: the osp_thandle has be sent
+ * by this order to make sure the remote update log will follow the
+ * llog format rule. XXX: these probably should be removed once we
+ * invent new llog format */
__u64 ou_version;
+
+ /* The generation of current osp update RPC, which is used to make sure
+ * those stale RPC(with older generation) will not be sent, otherwise it
+ * will cause update lllog corruption */
+ __u64 ou_generation;
};
struct osp_device {
/* unique generation, to recognize start of new records in the llog */
struct llog_gen opd_syn_generation;
/* number of changes to sync, used to wake up sync thread */
- unsigned long opd_syn_changes;
+ atomic_t opd_syn_changes;
/* processing of changes from previous mount is done? */
int opd_syn_prev_done;
/* found records */
/* number of changes being under sync */
int opd_syn_sync_in_progress;
/* number of RPCs in flight - flow control */
- int opd_syn_rpc_in_flight;
+ atomic_t opd_syn_rpc_in_flight;
int opd_syn_max_rpc_in_flight;
/* number of RPC in processing (including non-committed by OST) */
- int opd_syn_rpc_in_progress;
+ atomic_t opd_syn_rpc_in_progress;
int opd_syn_max_rpc_in_progress;
/* osd api's commit cb control structure */
struct dt_txn_callback opd_syn_txn_cb;
/* last used change number -- semantically similar to transno */
- unsigned long opd_syn_last_used_id;
+ __u64 opd_syn_last_used_id;
/* last committed change number -- semantically similar to
* last_committed */
- unsigned long opd_syn_last_committed_id;
+ __u64 opd_syn_last_committed_id;
/* last processed (taken from llog) id */
- unsigned long opd_syn_last_processed_id;
+ volatile __u64 opd_syn_last_processed_id;
struct osp_id_tracker *opd_syn_tracker;
struct list_head opd_syn_ontrack;
/* stop processing new requests until barrier=0 */
struct list_head opd_async_updates;
struct rw_semaphore opd_async_updates_rwsem;
atomic_t opd_async_updates_count;
+
+ /*
+ * Limit the object allocation using ENOSPC for opd_pre_status
+ */
+ int opd_reserved_mb_high;
+ int opd_reserved_mb_low;
};
#define opd_pre_lock opd_pre->osp_pre_lock
char oxe_buf[0];
};
-struct osp_object_attr {
- struct lu_attr ooa_attr;
- struct list_head ooa_xattr_list;
-};
-
/* this is a top object */
struct osp_object {
struct lu_object_header opo_header;
/* read/write lock for md osp object */
struct rw_semaphore opo_sem;
const struct lu_env *opo_owner;
- struct osp_object_attr *opo_ooa;
+ struct lu_attr opo_attr;
+ struct list_head opo_xattr_list;
+ struct list_head opo_invalidate_cb_list;
/* Protect opo_ooa. */
spinlock_t opo_lock;
};
}
struct osp_txn_info {
- __u32 oti_current_id;
+ __u64 oti_current_id;
};
extern struct lu_context_key osp_txn_key;
osp_update_interpreter_t interpreter);
struct osp_update_request *osp_update_request_create(struct dt_device *dt);
-void osp_update_request_destroy(struct osp_update_request *update);
+void osp_update_request_destroy(const struct lu_env *env,
+ struct osp_update_request *update);
int osp_send_update_thread(void *arg);
int osp_check_and_set_rpc_version(struct osp_thandle *oth,
struct osp_object *obj);
-void osp_thandle_destroy(struct osp_thandle *oth);
+void osp_thandle_destroy(const struct lu_env *env, struct osp_thandle *oth);
static inline void osp_thandle_get(struct osp_thandle *oth)
{
atomic_inc(&oth->ot_refcount);
}
-static inline void osp_thandle_put(struct osp_thandle *oth)
+static inline void osp_thandle_put(const struct lu_env *env,
+ struct osp_thandle *oth)
{
if (atomic_dec_and_test(&oth->ot_refcount))
- osp_thandle_destroy(oth);
+ osp_thandle_destroy(env, oth);
}
int osp_prep_update_req(const struct lu_env *env, struct obd_import *imp,
const char *name, struct thandle *th);
int osp_xattr_del(const struct lu_env *env, struct dt_object *dt,
const char *name, struct thandle *th);
+int osp_invalidate(const struct lu_env *env, struct dt_object *dt);
+void osp_obj_invalidate_cache(struct osp_object *obj);
int osp_trans_stop(const struct lu_env *env, struct dt_device *dt,
struct thandle *th);
int osp_it_key_rec(const struct lu_env *env, const struct dt_it *di,
void *key_rec);
int osp_it_next_page(const struct lu_env *env, struct dt_it *di);
-int osp_oac_init(struct osp_object *obj);
/* osp_md_object.c */
int osp_md_declare_object_create(const struct lu_env *env,
struct dt_object *dt,
extern struct obd_ops lwp_obd_device_ops;
extern struct lu_device_type lwp_device_type;
+static inline struct lu_device *osp2top(const struct osp_device *osp)
+{
+ return osp->opd_dt_dev.dd_lu_dev.ld_site->ls_top_dev;
+}
+
+static inline void osp_set_req_replay(const struct osp_device *osp,
+ struct ptlrpc_request *req)
+{
+ struct obd_device *obd = osp2top(osp)->ld_obd;
+
+ /* The RPC must be recovery related for the cases:
+ *
+ * 1. sent during recovery, or
+ * 2. sent before the recovery thread target_recovery_thread() start,
+ * such as triggered by lod_sub_recovery_thread(). */
+ if (obd->obd_recovering || (obd->obd_replayable && obd->obd_no_conn))
+ req->rq_allow_replay = 1;
+}
+
#endif
git://git.whamcloud.com / fs / lustre-release.git / blobdiff