LASSERT(req->rq_next_phase != RQ_PHASE_UNDEFINED);
if (req->rq_req_deadline &&
- !OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_REQ_UNLINK))
+ !CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_REQ_UNLINK))
req->rq_req_deadline = 0;
if (req->rq_reply_deadline &&
- !OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_REPL_UNLINK))
+ !CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_REPL_UNLINK))
req->rq_reply_deadline = 0;
if (req->rq_bulk_deadline &&
- !OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_BULK_UNLINK))
+ !CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_BULK_UNLINK))
req->rq_bulk_deadline = 0;
/*
* Turn fail_loc off to prevent it from looping
* forever.
*/
- if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_REPL_UNLINK)) {
- OBD_FAIL_CHECK_ORSET(OBD_FAIL_PTLRPC_LONG_REPL_UNLINK,
- OBD_FAIL_ONCE);
+ if (CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_REPL_UNLINK)) {
+ CFS_FAIL_CHECK_ORSET(OBD_FAIL_PTLRPC_LONG_REPL_UNLINK,
+ CFS_FAIL_ONCE);
}
- if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_BULK_UNLINK)) {
- OBD_FAIL_CHECK_ORSET(OBD_FAIL_PTLRPC_LONG_BULK_UNLINK,
- OBD_FAIL_ONCE);
+ if (CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_BULK_UNLINK)) {
+ CFS_FAIL_CHECK_ORSET(OBD_FAIL_PTLRPC_LONG_BULK_UNLINK,
+ CFS_FAIL_ONCE);
}
/*
LASSERT(!in_interrupt());
/* Let's setup deadline for reply unlink. */
- if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_REPL_UNLINK) &&
+ if (CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_REPL_UNLINK) &&
async && request->rq_reply_deadline == 0 && cfs_fail_val == 0)
request->rq_reply_deadline = ktime_get_real_seconds() +
PTLRPC_REQ_LONG_UNLINK;
int rc;
ENTRY;
- //if (OBD_FAIL_CHECK_ORSET(OBD_FAIL_SVCGSS_ERR_NOTIFY, OBD_FAIL_ONCE))
- // RETURN(-EINVAL);
-
grctx->src_err_notify = 1;
grctx->src_reserve_len = 0;
if (!imp->imp_invalid || imp->imp_obd->obd_no_recov)
ptlrpc_deactivate_import(imp);
- if (OBD_FAIL_PRECHECK(OBD_FAIL_PTLRPC_CONNECT_RACE)) {
- OBD_RACE(OBD_FAIL_PTLRPC_CONNECT_RACE);
+ if (CFS_FAIL_PRECHECK(OBD_FAIL_PTLRPC_CONNECT_RACE)) {
+ CFS_RACE(OBD_FAIL_PTLRPC_CONNECT_RACE);
msleep(10 * MSEC_PER_SEC);
}
CFS_FAIL_TIMEOUT(OBD_FAIL_MGS_CONNECT_NET, 3 * cfs_fail_val / 2);
* out. Use obd_timeout if calculated value is smaller
* than it.
*/
- if (!OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_REPL_UNLINK)) {
+ if (!CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_REPL_UNLINK)) {
timeout = ptlrpc_inflight_timeout(imp);
timeout += div_u64(timeout, 3);
struct ptlrpc_request *req;
ENTRY;
- if (unlikely(OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_FINISH_REPLAY)))
+ if (unlikely(CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_FINISH_REPLAY)))
RETURN(0);
if (!atomic_add_unless(&imp->imp_replay_inflight, 1, 1))
req->rq_interpret_reply = ptlrpc_disconnect_idle_interpret;
- if (OBD_FAIL_PRECHECK(OBD_FAIL_PTLRPC_IDLE_RACE)) {
+ if (CFS_FAIL_PRECHECK(OBD_FAIL_PTLRPC_IDLE_RACE)) {
__u32 idx;
server_name2index(imp->imp_obd->obd_name, &idx, NULL);
if (idx == 0)
- OBD_RACE(OBD_FAIL_PTLRPC_IDLE_RACE);
+ CFS_RACE(OBD_FAIL_PTLRPC_IDLE_RACE);
}
spin_lock(&imp->imp_lock);
ctxt = llog_get_context(req->rq_export->exp_obd, body->lgd_ctxt_idx);
if (ctxt == NULL)
RETURN(-ENODEV);
- if (OBD_FAIL_PRECHECK(OBD_FAIL_MDS_LLOG_UMOUNT_RACE))
+ if (CFS_FAIL_PRECHECK(OBD_FAIL_MDS_LLOG_UMOUNT_RACE))
cfs_fail_val = 1;
rc = llog_open(req->rq_svc_thread->t_env, ctxt, &loghandle,
md.options |= LNET_MD_BULK_HANDLE;
}
- if (unlikely(ack == LNET_ACK_REQ &&
- OBD_FAIL_CHECK_ORSET(OBD_FAIL_PTLRPC_ACK, OBD_FAIL_ONCE))){
+ if (CFS_FAIL_CHECK_ORSET(OBD_FAIL_PTLRPC_ACK, CFS_FAIL_ONCE) &&
+ ack == LNET_ACK_REQ) {
/* don't ask for the ack to simulate failing client */
ack = LNET_NOACK_REQ;
}
struct lnet_md md;
ENTRY;
- if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_BULK_PUT_NET))
+ if (CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_BULK_PUT_NET))
RETURN(0);
/* NB no locking required until desc is on the network */
/* sanity.sh 224c: lets skip last md */
if (posted_md == desc->bd_md_max_brw - 1)
- OBD_FAIL_CHECK_RESET(OBD_FAIL_PTLRPC_CLIENT_BULK_CB3,
+ CFS_FAIL_CHECK_RESET(OBD_FAIL_PTLRPC_CLIENT_BULK_CB3,
CFS_FAIL_PTLRPC_OST_BULK_CB2);
/* Network is about to get at the memory */
struct lnet_md md;
ENTRY;
- if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_BULK_GET_NET))
- RETURN(0);
+ if (CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_BULK_GET_NET))
+ RETURN(0);
/* NB no locking required until desc is on the network */
LASSERT(desc->bd_nob > 0);
ptlrpc_fill_bulk_md(&md, desc, posted_md);
if (posted_md > 0 && posted_md + 1 == desc->bd_md_count &&
- OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_BULK_ATTACH)) {
+ CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_BULK_ATTACH)) {
rc = -ENOMEM;
} else {
me = LNetMEAttach(desc->bd_portal, &peer, mbits, 0,
desc->bd_registered = 0;
/* Let's setup deadline for reply unlink. */
- if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_BULK_UNLINK) &&
+ if (CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_LONG_BULK_UNLINK) &&
async && req->rq_bulk_deadline == 0 && cfs_fail_val == 0)
req->rq_bulk_deadline = ktime_get_real_seconds() +
PTLRPC_REQ_LONG_UNLINK;
LNetInvalidateMDHandle(&bulk_cookie);
- if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_DROP_RPC))
+ if (CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_DROP_RPC))
RETURN(0);
- if (unlikely(OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_DELAY_RECOV) &&
+ if (unlikely(CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_DELAY_RECOV) &&
lustre_msg_get_opc(request->rq_reqmsg) == MDS_CONNECT &&
strcmp(obd->obd_type->typ_name, LUSTRE_OSP_NAME) == 0)) {
RETURN(0);
peer = connection->c_peer;
if (request->rq_bulk &&
- OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_BULK_REPLY_ATTACH)) {
+ CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_BULK_REPLY_ATTACH)) {
reply_me = ERR_PTR(-ENOMEM);
} else {
reply_me = LNetMEAttach(request->rq_reply_portal,
lprocfs_counter_add(obd->obd_svc_stats, PTLRPC_REQACTIVE_CNTR,
atomic_read(&imp->imp_inflight));
- OBD_FAIL_TIMEOUT(OBD_FAIL_PTLRPC_DELAY_SEND, request->rq_timeout + 5);
+ CFS_FAIL_TIMEOUT(OBD_FAIL_PTLRPC_DELAY_SEND, request->rq_timeout + 5);
request->rq_sent_ns = ktime_get_real();
request->rq_sent = ktime_get_real_seconds();
ptlrpc_at_get_net_latency(request);
if (unlikely(opc == OBD_PING &&
- OBD_FAIL_TIMEOUT(OBD_FAIL_PTLRPC_DELAY_SEND_FAIL, cfs_fail_val)))
+ CFS_FAIL_TIMEOUT(OBD_FAIL_PTLRPC_DELAY_SEND_FAIL, cfs_fail_val)))
GOTO(skip_send, rc);
DEBUG_REQ(D_INFO, request, "send flags=%x",
CDEBUG(D_NET, "%s: registering portal %d\n", service->srv_name,
service->srv_req_portal);
- if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_RQBD))
+ if (CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_RQBD))
return -ENOMEM;
/* NB: CPT affinity service should use new LNet flag LNET_INS_LOCAL,
hash = iops->store(env, it);
ii->ii_hash_end = hash;
- if (OBD_FAIL_CHECK(OBD_FAIL_OBD_IDX_READ_BREAK)) {
+ if (CFS_FAIL_CHECK(OBD_FAIL_OBD_IDX_READ_BREAK)) {
if (lip->lip_nr != 0)
GOTO(out, rc = 0);
}
static inline int imp_is_deactive(struct obd_import *imp)
{
return imp->imp_deactive ||
- OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_IMP_DEACTIVE);
+ CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_IMP_DEACTIVE);
}
static inline time64_t ptlrpc_next_reconnect(struct obd_import *imp)
#include <lustre_lib.h>
#include <lustre_ha.h>
#include <obd_class.h> /* for obd_zombie */
-#include <obd_support.h> /* for OBD_FAIL_CHECK */
+#include <obd_support.h>
#include <cl_object.h> /* cl_env_{get,put}() */
#include <lprocfs_status.h>
}
spin_unlock(&imp->imp_lock);
- OBD_FAIL_TIMEOUT(OBD_FAIL_LDLM_ENQUEUE_OLD_EXPORT, 2);
+ CFS_FAIL_TIMEOUT(OBD_FAIL_LDLM_ENQUEUE_OLD_EXPORT, 2);
RETURN(0);
}
if (rc)
GOTO(out, rc);
- OBD_RACE(OBD_FAIL_PTLRPC_CONNECT_RACE);
+ CFS_RACE(OBD_FAIL_PTLRPC_CONNECT_RACE);
rc = ptlrpc_connect_import(imp);
if (rc)
* for sending we only compute the wrong checksum instead
* of corrupting the data so it is still correct on a redo
*/
- if (OBD_FAIL_CHECK(OBD_FAIL_OSC_CHECKSUM_SEND) &&
+ if (CFS_FAIL_CHECK(OBD_FAIL_OSC_CHECKSUM_SEND) &&
req->rq_flvr.u_bulk.hash.hash_alg != BULK_HASH_ALG_NULL)
token->pbt_hash[0] ^= 0x1;
}
CERROR("bulk read: server failed to compute checksum: %d\n",
rc);
} else {
- if (OBD_FAIL_CHECK(OBD_FAIL_OSC_CHECKSUM_RECEIVE))
+ if (CFS_FAIL_CHECK(OBD_FAIL_OSC_CHECKSUM_RECEIVE))
corrupt_bulk_data(desc);
}
ptlrpc_server_mark_in_progress_obsolete(req);
#endif
orig = ptlrpc_server_check_resend_in_progress(req);
- if (orig && OBD_FAIL_PRECHECK(OBD_FAIL_PTLRPC_RESEND_RACE)) {
+ if (orig && CFS_FAIL_PRECHECK(OBD_FAIL_PTLRPC_RESEND_RACE)) {
spin_unlock_bh(&exp->exp_rpc_lock);
- OBD_RACE(OBD_FAIL_PTLRPC_RESEND_RACE);
+ CFS_RACE(OBD_FAIL_PTLRPC_RESEND_RACE);
msleep(4 * MSEC_PER_SEC);
continue;
}
}
opc = lustre_msg_get_opc(req->rq_reqmsg);
- if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_DROP_REQ_OPC) &&
+ if (CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_DROP_REQ_OPC) &&
opc == cfs_fail_val) {
CERROR("drop incoming rpc opc %u, x%llu\n",
cfs_fail_val, req->rq_xid);
}
/* Skip early reply */
- if (OBD_FAIL_PRECHECK(OBD_FAIL_MDS_RESEND))
+ if (CFS_FAIL_PRECHECK(OBD_FAIL_MDS_RESEND))
req->rq_deadline += obd_timeout;
req->rq_svc_thread = thread;
}
- if (unlikely(OBD_FAIL_PRECHECK(OBD_FAIL_PTLRPC_ENQ_RESEND) &&
+ if (unlikely(CFS_FAIL_PRECHECK(OBD_FAIL_PTLRPC_ENQ_RESEND) &&
(opc == LDLM_ENQUEUE) &&
(lustre_msg_get_flags(req->rq_reqmsg) & MSG_RESENT)))
- OBD_FAIL_TIMEOUT(OBD_FAIL_PTLRPC_ENQ_RESEND, 6);
+ CFS_FAIL_TIMEOUT(OBD_FAIL_PTLRPC_ENQ_RESEND, 6);
ptlrpc_at_add_timed(req);
if (request == NULL)
RETURN(0);
- if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_HPREQ_NOTIMEOUT))
+ if (CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_HPREQ_NOTIMEOUT))
fail_opc = OBD_FAIL_PTLRPC_HPREQ_NOTIMEOUT;
- else if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_HPREQ_TIMEOUT))
+ else if (CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_HPREQ_TIMEOUT))
fail_opc = OBD_FAIL_PTLRPC_HPREQ_TIMEOUT;
if (unlikely(fail_opc)) {
if (request->rq_export && request->rq_ops)
- OBD_FAIL_TIMEOUT(fail_opc, 4);
+ CFS_FAIL_TIMEOUT(fail_opc, 4);
}
ptlrpc_rqphase_move(request, RQ_PHASE_INTERPRET);
- if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_DUMP_LOG))
+ if (CFS_FAIL_CHECK(OBD_FAIL_PTLRPC_DUMP_LOG))
libcfs_debug_dumplog();
work_start = ktime_get_real();
RETURN(-ESRCH);
if (!ptlrpc_threads_increasable(svcpt) ||
- (OBD_FAIL_CHECK(OBD_FAIL_TGT_TOOMANY_THREADS) &&
+ (CFS_FAIL_CHECK(OBD_FAIL_TGT_TOOMANY_THREADS) &&
svcpt->scp_nthrs_running == svc->srv_nthrs_cpt_init - 1))
RETURN(-EMFILE);