X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Finclude%2Fobd_support.h;h=71c5046830d414ab51a85903cacc8697d815bb39;hb=1725069067fa1113812973be73df9960004506c8;hp=befcde88c8e8c236a0e674afed18fdace5ee3220;hpb=ca6dd9a48e7b3ebf5df8a78c8ed65f7676cebf4d;p=fs%2Flustre-release.git diff --git a/lustre/include/obd_support.h b/lustre/include/obd_support.h index befcde8..71c5046 100644 --- a/lustre/include/obd_support.h +++ b/lustre/include/obd_support.h @@ -27,6 +27,16 @@ #include #include +#if defined(__linux__) +#include +#elif defined(__APPLE__) +#include +#elif defined(__WINNT__) +#include +#else +#error Unsupported operating system. +#endif + /* global variables */ extern struct lprocfs_stats *obd_memory; enum { @@ -35,7 +45,13 @@ enum { OBD_STATS_NUM, }; -extern unsigned int obd_fail_loc; +enum { + OBD_FAIL_LOC_NOSET = 0, + OBD_FAIL_LOC_ORSET = 1, + OBD_FAIL_LOC_RESET = 2 +}; + +extern unsigned long obd_fail_loc; extern unsigned int obd_fail_val; extern unsigned int obd_debug_peer_on_timeout; extern unsigned int obd_dump_on_timeout; @@ -52,6 +68,12 @@ extern cfs_waitq_t obd_race_waitq; extern int obd_race_state; extern unsigned int obd_alloc_fail_rate; +int __obd_fail_check_set(__u32 id, __u32 value, int set); + +/* lvfs.c */ +int obd_alloc_fail(const void *ptr, const char *name, const char *type, + size_t size, const char *file, int line); + /* Timeout definitions */ #define LDLM_TIMEOUT_DEFAULT 20 #define OBD_TIMEOUT_DEFAULT 100 @@ -122,6 +144,8 @@ extern unsigned int obd_alloc_fail_rate; #define OBD_FAIL_MDS_LLOG_CREATE_FAILED 0x13c #define OBD_FAIL_MDS_OSC_PRECREATE 0x13d #define OBD_FAIL_MDS_LOV_SYNC_RACE 0x13e +#define OBD_FAIL_MDS_CLOSE_NET_REP 0x13f +#define OBD_FAIL_MDS_LLOG_SYNC_TIMEOUT 0x140 #define OBD_FAIL_OST 0x200 #define OBD_FAIL_OST_CONNECT_NET 0x201 @@ -156,6 +180,9 @@ extern unsigned int obd_alloc_fail_rate; #define OBD_FAIL_OST_SETATTR_CREDITS 0x21e #define OBD_FAIL_OST_HOLD_WRITE_RPC 0x21f #define OBD_FAIL_OST_BRW_WRITE_BULK2 0x220 +#define OBD_FAIL_OST_LLOG_RECOVERY_TIMEOUT 0x221 +#define OBD_FAIL_OST_CANCEL_COOKIE_TIMEOUT 0x222 +#define OBD_FAIL_OST_CONNECT_NET2 0x225 #define OBD_FAIL_LDLM 0x300 #define OBD_FAIL_LDLM_NAMESPACE_NEW 0x301 @@ -175,6 +202,11 @@ extern unsigned int obd_alloc_fail_rate; #define OBD_FAIL_LDLM_GLIMPSE 0x30f #define OBD_FAIL_LDLM_CANCEL_RACE 0x310 #define OBD_FAIL_LDLM_CANCEL_EVICT_RACE 0x311 +/* +#define OBD_FAIL_LDLM_PAUSE_CANCEL 0x312 +*/ +#define OBD_FAIL_LDLM_CLOSE_THREAD 0x313 +#define OBD_FAIL_LDLM_CANCEL_BL_CB_RACE 0x314 #define OBD_FAIL_OSC 0x400 #define OBD_FAIL_OSC_BRW_READ_BULK 0x401 @@ -187,6 +219,8 @@ extern unsigned int obd_alloc_fail_rate; #define OBD_FAIL_OSC_CHECKSUM_RECEIVE 0x408 #define OBD_FAIL_OSC_CHECKSUM_SEND 0x409 #define OBD_FAIL_OSC_BRW_PREP_REQ2 0x40a +#define OBD_FAIL_OSC_CONNECT_CKSUM 0x40b +#define OBD_FAIL_OSC_CKSUM_ADLER_ONLY 0x40c #define OBD_FAIL_PTLRPC 0x500 #define OBD_FAIL_PTLRPC_ACK 0x501 @@ -240,128 +274,109 @@ extern unsigned int obd_alloc_fail_rate; /* Failure injection control */ #define OBD_FAIL_MASK_SYS 0x0000FF00 #define OBD_FAIL_MASK_LOC (0x000000FF | OBD_FAIL_MASK_SYS) -#define OBD_FAIL_ONCE 0x80000000 -#define OBD_FAILED 0x40000000 + +#define OBD_FAILED_BIT 30 +/* OBD_FAILED is 0x40000000 */ +#define OBD_FAILED (1 << OBD_FAILED_BIT) + +#define OBD_FAIL_ONCE_BIT 31 +/* OBD_FAIL_ONCE is 0x80000000 */ +#define OBD_FAIL_ONCE (1 << OBD_FAIL_ONCE_BIT) /* The following flags aren't made to be combined */ -#define OBD_FAIL_SKIP 0x20000000 /* skip N then fail */ -#define OBD_FAIL_SOME 0x10000000 /* fail N times */ -#define OBD_FAIL_RAND 0x08000000 /* fail 1/N of the time */ +#define OBD_FAIL_SKIP 0x20000000 /* skip N times then fail */ +#define OBD_FAIL_SOME 0x10000000 /* only fail N times */ +#define OBD_FAIL_RAND 0x08000000 /* fail 1/N of the times */ #define OBD_FAIL_USR1 0x04000000 /* user flag */ -static inline int obd_fail_check(__u32 id) +#define OBD_FAIL_PRECHECK(id) (obd_fail_loc && \ + (obd_fail_loc & OBD_FAIL_MASK_LOC) == \ + ((id) & OBD_FAIL_MASK_LOC)) + +static inline int obd_fail_check_set(__u32 id, __u32 value, int set) { - static int count = 0; - if (likely((obd_fail_loc & OBD_FAIL_MASK_LOC) != - (id & OBD_FAIL_MASK_LOC))) - return 0; - - if ((obd_fail_loc & (OBD_FAILED | OBD_FAIL_ONCE)) == - (OBD_FAILED | OBD_FAIL_ONCE)) { - count = 0; /* paranoia */ - return 0; + int ret = 0; + if (unlikely(OBD_FAIL_PRECHECK(id) && + (ret = __obd_fail_check_set(id, value, set)))) { + CERROR("*** obd_fail_loc=%x ***\n", id); } + return ret; +} - if (obd_fail_loc & OBD_FAIL_RAND) { - unsigned int ll_rand(void); - if (obd_fail_val < 2) - return 0; - if (ll_rand() % obd_fail_val > 0) - return 0; - } +/* If id hit obd_fail_loc, return 1, otherwise return 0 */ +#define OBD_FAIL_CHECK(id) \ + obd_fail_check_set(id, 0, OBD_FAIL_LOC_NOSET) - if (obd_fail_loc & OBD_FAIL_SKIP) { - count++; - if (count < obd_fail_val) - return 0; - count = 0; - } +/* If id hit obd_fail_loc, obd_fail_loc |= value and return 1, + * otherwise return 0 */ +#define OBD_FAIL_CHECK_ORSET(id, value) \ + obd_fail_check_set(id, value, OBD_FAIL_LOC_ORSET) - /* Overridden by FAIL_ONCE */ - if (obd_fail_loc & OBD_FAIL_SOME) { - count++; - if (count >= obd_fail_val) { - count = 0; - /* Don't fail anymore */ - obd_fail_loc |= OBD_FAIL_ONCE; - } - } +/* If id hit obd_fail_loc, obd_fail_loc = value and return 1, + * otherwise return 0 */ +#define OBD_FAIL_CHECK_RESET(id, value) \ + obd_fail_check_set(id, value, OBD_FAIL_LOC_RESET) - obd_fail_loc |= OBD_FAILED; - /* Handle old checks that OR in this */ - if (id & OBD_FAIL_ONCE) - obd_fail_loc |= OBD_FAIL_ONCE; - return 1; +static inline int obd_fail_timeout_set(__u32 id, __u32 value, int secs, int set) +{ + int ret = 0; + if (unlikely(OBD_FAIL_PRECHECK(id) && + (ret = __obd_fail_check_set(id, value, set)))) { + CERROR("obd_fail_timeout id %x sleeping for %d secs\n", + id, secs); + set_current_state(TASK_UNINTERRUPTIBLE); + cfs_schedule_timeout(CFS_TASK_UNINT, cfs_time_seconds(secs)); + set_current_state(TASK_RUNNING); + CERROR("obd_fail_timeout id %x awake\n", id); + } + return ret; } -#define OBD_FAIL_CHECK(id) \ -({ \ - int _ret_ = 0; \ - if (unlikely(obd_fail_loc && (_ret_ = obd_fail_check(id)))) { \ - CERROR("*** obd_fail_loc=%x ***\n", id); \ - } \ - _ret_; \ -}) +/* If id hit obd_fail_loc, sleep secs */ +#define OBD_FAIL_TIMEOUT(id, secs) \ + obd_fail_timeout_set(id, 0, secs, OBD_FAIL_LOC_NOSET) -/* deprecated - just use OBD_FAIL_CHECK */ -#define OBD_FAIL_CHECK_ONCE OBD_FAIL_CHECK - -#define OBD_FAIL_RETURN(id, ret) \ -do { \ - if (unlikely(obd_fail_loc && obd_fail_check(id))) { \ - CERROR("*** obd_fail_return=%x rc=%d ***\n", id, ret); \ - RETURN(ret); \ - } \ -} while(0) - -#define OBD_FAIL_TIMEOUT(id, secs) \ -({ int _ret_ = 0; \ - if (unlikely(obd_fail_loc && (_ret_ = obd_fail_check(id)))) { \ - CERROR("obd_fail_timeout id %x sleeping for %d secs\n", \ - (id), (secs)); \ - set_current_state(TASK_UNINTERRUPTIBLE); \ - cfs_schedule_timeout(CFS_TASK_UNINT, \ - cfs_time_seconds(secs)); \ - set_current_state(TASK_RUNNING); \ - CERROR("obd_fail_timeout id %x awake\n", (id)); \ - } \ - _ret_; \ -}) - -#define OBD_FAIL_TIMEOUT_MS(id, ms) \ -({ int _ret_ = 0; \ - if (unlikely(obd_fail_loc && (_ret_ = obd_fail_check(id)))) { \ - CERROR("obd_fail_timeout id %x sleeping for %d ms\n", \ - (id), (ms)); \ - set_current_state(TASK_UNINTERRUPTIBLE); \ - cfs_schedule_timeout(CFS_TASK_UNINT, \ - cfs_time_seconds(ms)/1000); \ - set_current_state(TASK_RUNNING); \ - CERROR("obd_fail_timeout id %x awake\n", (id)); \ - } \ - _ret_; \ -}) +/* If id hit obd_fail_loc, obd_fail_loc |= value and sleep secs */ +#define OBD_FAIL_TIMEOUT_ORSET(id, value, secs) \ + obd_fail_timeout_set(id, value, secs, OBD_FAIL_LOC_ORSET) #ifdef __KERNEL__ +static inline void obd_fail_write(int id, struct super_block *sb) +{ + /* We set FAIL_ONCE because we never "un-fail" a device */ + if (OBD_FAIL_CHECK_ORSET(id & ~OBD_FAIL_ONCE, OBD_FAIL_ONCE)) { +#ifdef LIBCFS_DEBUG + BDEVNAME_DECLARE_STORAGE(tmp); + CERROR("obd_fail_loc=%x, fail write operation on %s\n", + id, ll_bdevname(sb, tmp)); +#endif + /* TODO-CMD: fix getting jdev */ + __lvfs_set_rdonly(lvfs_sbdev(sb), (lvfs_sbdev_type)0); + } +} +#define OBD_FAIL_WRITE(id, sb) obd_fail_write(id, sb) + /* The idea here is to synchronise two threads to force a race. The * first thread that calls this with a matching fail_loc is put to * sleep. The next thread that calls with the same fail_loc wakes up * the first and continues. */ -#define OBD_RACE(id) \ -do { \ - if (unlikely(obd_fail_loc && obd_fail_check(id))) { \ - obd_race_state = 0; \ - CERROR("obd_race id %x sleeping\n", (id)); \ - OBD_SLEEP_ON(obd_race_waitq, obd_race_state != 0); \ - CERROR("obd_fail_race id %x awake\n", (id)); \ - } else if ((obd_fail_loc & OBD_FAIL_MASK_LOC) == \ - ((id) & OBD_FAIL_MASK_LOC)) { \ - CERROR("obd_fail_race id %x waking\n", (id)); \ - obd_race_state = 1; \ - wake_up(&obd_race_waitq); \ - } \ -} while(0) +static inline void obd_race(__u32 id) +{ + if (OBD_FAIL_PRECHECK(id)) { + if (unlikely(__obd_fail_check_set(id, 0, OBD_FAIL_LOC_NOSET))) { + obd_race_state = 0; + CERROR("obd_race id %x sleeping\n", id); + OBD_SLEEP_ON(obd_race_waitq, obd_race_state != 0); + CERROR("obd_fail_race id %x awake\n", id); + } else { + CERROR("obd_fail_race id %x waking\n", id); + obd_race_state = 1; + wake_up(&obd_race_waitq); + } + } +} +#define OBD_RACE(id) obd_race(id) #else /* sigh. an expedient fix until OBD_RACE is fixed up */ #define OBD_RACE(foo) do {} while(0) @@ -371,7 +386,7 @@ do { \ extern atomic_t libcfs_kmemory; -#ifdef LPROCFS +#ifdef LPROCFS #define obd_memory_add(size) \ lprocfs_counter_add(obd_memory, OBD_MEMORY_STAT, (long)(size)) #define obd_memory_sub(size) \ @@ -413,7 +428,7 @@ static inline void obd_memory_sub(long size) obd_alloc -= size; } -static inline void obd_pages_add(int order) +static inline void obd_pages_add(int order) { obd_pages += 1<< order; if (obd_pages > obd_max_pages) @@ -710,7 +725,7 @@ do { \ cfs_mem_cache_free((slab), (ptr)); \ (ptr) = NULL; \ 0; \ -}) +}) #define OBD_SLAB_ALLOC(ptr, slab, type, size) \ do { \ LASSERT(!in_interrupt()); \ @@ -782,14 +797,4 @@ do { \ #define OBD_PAGE_FREE(ptr) OBD_PAGES_FREE(ptr, 0) -#if defined(__linux__) -#include -#elif defined(__APPLE__) -#include -#elif defined(__WINNT__) -#include -#else -#error Unsupported operating system. -#endif - #endif