LUSTRE_IMP_EVICTED = 10,
};
+struct ptlrpc_at_array {
+ struct list_head *paa_reqs_array; /* array to hold requests */
+ __u32 paa_size; /* the size of array */
+ __u32 paa_count; /* the total count of reqs */
+ time_t paa_deadline; /* the earliest deadline of reqs */
+ __u32 *paa_reqs_count; /* the count of reqs in each entry */
+};
+
static inline char * ptlrpc_import_state_name(enum lustre_imp_state state)
{
static char* import_state_names[] = {
cfs_waitq_t imp_recovery_waitq;
atomic_t imp_inflight;
+ atomic_t imp_unregistering;
atomic_t imp_replay_inflight;
atomic_t imp_inval_count;
enum lustre_imp_state imp_state;
imp_server_timeout:1, /* use 1/2 timeout on MDS' OSCs */
imp_initial_recov:1, /* retry the initial connection */
imp_initial_recov_bk:1, /* turn off init_recov after trying all failover nids */
+ imp_delayed_recovery:1, /* VBR: imp in delayed recovery */
+ imp_no_lock_replay:1, /* VBR: if gap was found then no lock replays */
+ imp_vbr_failed:1, /* recovery by versions was failed */
imp_force_verify:1, /* force an immidiate ping */
imp_pingable:1, /* pingable */
imp_resend_replay:1, /* resend for replay */
void *event_arg);
/* import.c */
+static inline unsigned int at_est2timeout(unsigned int val)
+{
+ /* add an arbitrary minimum: 125% +5 sec */
+ return (val + (val >> 2) + 5);
+}
+
+static inline unsigned int at_timeout2est(unsigned int val)
+{
+ /* restore estimate value from timeout: e=4/5(t-5) */
+ LASSERT(val);
+ return (max((val << 2) / 5, 5U) - 4);
+}
+
static inline void at_init(struct adaptive_timeout *at, int val, int flags) {
memset(at, 0, sizeof(*at));
at->at_current = val;