* network failure. Do not send any reply in case any of NET related
* fail_id has occured.
*/
- if (OBD_FAIL_CHECK_ORSET(h->th_fail_id, OBD_FAIL_ONCE))
+ if (CFS_FAIL_CHECK_ORSET(h->th_fail_id, CFS_FAIL_ONCE))
RETURN(0);
if (unlikely(lustre_msg_get_opc(req->rq_reqmsg) == MDS_REINT &&
- OBD_FAIL_CHECK(OBD_FAIL_MDS_REINT_MULTI_NET)))
+ CFS_FAIL_CHECK(OBD_FAIL_MDS_REINT_MULTI_NET)))
RETURN(0);
/* drop OUT_UPDATE rpc */
if (unlikely(lustre_msg_get_opc(req->rq_reqmsg) == OUT_UPDATE &&
- OBD_FAIL_CHECK(OBD_FAIL_OUT_UPDATE_DROP)))
+ CFS_FAIL_CHECK(OBD_FAIL_OUT_UPDATE_DROP)))
RETURN(0);
rc = tgt_request_preprocess(tsi, h, req);
goto err_unsupported;
}
- if (OBD_FAIL_CHECK(OBD_FAIL_OST_OPCODE) && opc == cfs_fail_val)
+ if (CFS_FAIL_CHECK(OBD_FAIL_OST_OPCODE) && opc == cfs_fail_val)
goto err_unsupported;
RETURN(h);
bool is_connect = false;
ENTRY;
- if (unlikely(OBD_FAIL_CHECK(OBD_FAIL_TGT_RECOVERY_REQ_RACE))) {
+ if (unlikely(CFS_FAIL_CHECK(OBD_FAIL_TGT_RECOVERY_REQ_RACE))) {
if (cfs_fail_val == 0 &&
lustre_msg_get_opc(msg) != OBD_PING &&
lustre_msg_get_flags(msg) & MSG_REQ_REPLAY_DONE) {
}
/* recovery-small test 18c asks to drop connect reply */
if (unlikely(opc == OST_CONNECT &&
- OBD_FAIL_CHECK(OBD_FAIL_OST_CONNECT_NET2)))
+ CFS_FAIL_CHECK(OBD_FAIL_OST_CONNECT_NET2)))
GOTO(out, rc = 0);
}
ENTRY;
- OBD_FAIL_TIMEOUT(OBD_FAIL_OST_DISCONNECT_DELAY, cfs_fail_val);
+ CFS_FAIL_TIMEOUT(OBD_FAIL_OST_DISCONNECT_DELAY, cfs_fail_val);
rc = target_handle_disconnect(tgt_ses_req(tsi));
if (rc)
/* corrupt the data before we compute the checksum, to
* simulate a client->OST data error */
if (i == 0 && opc == OST_WRITE &&
- OBD_FAIL_CHECK(OBD_FAIL_OST_CHECKSUM_RECEIVE)) {
+ CFS_FAIL_CHECK(OBD_FAIL_OST_CHECKSUM_RECEIVE)) {
int off = local_nb[i].lnb_page_offset & ~PAGE_MASK;
int len = local_nb[i].lnb_len;
struct page *np = tgt_page_to_corrupt;
/* corrupt the data after we compute the checksum, to
* simulate an OST->client data error */
if (i == 0 && opc == OST_READ &&
- OBD_FAIL_CHECK(OBD_FAIL_OST_CHECKSUM_SEND)) {
+ CFS_FAIL_CHECK(OBD_FAIL_OST_CHECKSUM_SEND)) {
int off = local_nb[i].lnb_page_offset & ~PAGE_MASK;
int len = local_nb[i].lnb_len;
struct page *np = tgt_page_to_corrupt;
/* corrupt the data before we compute the checksum, to
* simulate a client->OST data error */
if (i == 0 && opc == OST_WRITE &&
- OBD_FAIL_CHECK(OBD_FAIL_OST_CHECKSUM_RECEIVE)) {
+ CFS_FAIL_CHECK(OBD_FAIL_OST_CHECKSUM_RECEIVE)) {
struct page *np = tgt_page_to_corrupt;
if (np) {
/* corrupt the data after we compute the checksum, to
* simulate an OST->client data error */
if (unlikely(i == 0 && opc == OST_READ &&
- OBD_FAIL_CHECK(OBD_FAIL_OST_CHECKSUM_SEND))) {
+ CFS_FAIL_CHECK(OBD_FAIL_OST_CHECKSUM_SEND))) {
struct page *np = tgt_page_to_corrupt;
if (np) {
req->rq_bulk_read = 1;
- if (OBD_FAIL_CHECK(OBD_FAIL_OST_BRW_READ_BULK)) {
+ if (CFS_FAIL_CHECK(OBD_FAIL_OST_BRW_READ_BULK)) {
/* optionally use cfs_fail_val - 1 to select a specific OST on
* this server to fail requests.
*/
}
}
- OBD_FAIL_TIMEOUT(OBD_FAIL_OST_BRW_PAUSE_BULK, cfs_fail_val > 0 ?
+ CFS_FAIL_TIMEOUT(OBD_FAIL_OST_BRW_PAUSE_BULK, cfs_fail_val > 0 ?
cfs_fail_val : (obd_timeout + 1) / 4);
/* Check if there is eviction in progress, and if so, wait for it to
* client was willing to wait, drop it. b=11330
*/
if (ktime_get_real_seconds() > req->rq_deadline ||
- OBD_FAIL_CHECK(OBD_FAIL_OST_DROP_REQ)) {
+ CFS_FAIL_CHECK(OBD_FAIL_OST_DROP_REQ)) {
no_reply = 1;
CERROR("Dropping timed-out read from %s because locking object " DOSTID " took %lld seconds (limit was %lld).\n",
libcfs_idstr(&req->rq_peer), POSTID(&ioo->ioo_oid),
target_send_reply(req, 0, 0);
CDEBUG(D_INFO, "reorder BULK\n");
- OBD_FAIL_TIMEOUT(OBD_FAIL_PTLRPC_CLIENT_BULK_CB2,
+ CFS_FAIL_TIMEOUT(OBD_FAIL_PTLRPC_CLIENT_BULK_CB2,
cfs_fail_val ? : 3);
target_bulk_io(exp, desc);
RETURN(err_serious(-EPROTO));
}
- if (OBD_FAIL_CHECK(OBD_FAIL_OST_ENOSPC))
+ if (CFS_FAIL_CHECK(OBD_FAIL_OST_ENOSPC))
RETURN(err_serious(-ENOSPC));
- if (OBD_FAIL_TIMEOUT(OBD_FAIL_OST_EROFS, 1))
+ if (CFS_FAIL_TIMEOUT(OBD_FAIL_OST_EROFS, 1))
RETURN(err_serious(-EROFS));
req->rq_bulk_write = 1;
- if (OBD_FAIL_CHECK(OBD_FAIL_OST_BRW_WRITE_BULK))
+ if (CFS_FAIL_CHECK(OBD_FAIL_OST_BRW_WRITE_BULK))
rc = -EIO;
- if (OBD_FAIL_CHECK(OBD_FAIL_OST_BRW_WRITE_BULK2))
+ if (CFS_FAIL_CHECK(OBD_FAIL_OST_BRW_WRITE_BULK2))
rc = -EFAULT;
if (rc < 0) {
/* optionally use cfs_fail_val - 1 to select a specific OST on
* client was willing to wait, drop it. b=11330
*/
if (ktime_get_real_seconds() > req->rq_deadline ||
- OBD_FAIL_CHECK(OBD_FAIL_OST_DROP_REQ)) {
+ CFS_FAIL_CHECK(OBD_FAIL_OST_DROP_REQ)) {
no_reply = true;
CERROR("%s: Dropping timed-out write from %s because locking object " DOSTID " took %lld seconds (limit was %lld).\n",
tgt_name(tsi->tsi_tgt), libcfs_idstr(&req->rq_peer),
}
}
- OBD_FAIL_TIMEOUT(OBD_FAIL_OST_BRW_PAUSE_BULK2, cfs_fail_val);
+ CFS_FAIL_TIMEOUT(OBD_FAIL_OST_BRW_PAUSE_BULK2, cfs_fail_val);
out_commitrw:
/* calculate the expected actual write bytes (nob) for OFD stats.
OBD_FREE(lmi, sizeof(*lmi));
mutex_unlock(&lustre_mount_info_lock);
- OBD_RACE(OBD_FAIL_MDS_LLOG_UMOUNT_RACE);
+ CFS_RACE(OBD_FAIL_MDS_LLOG_UMOUNT_RACE);
RETURN(0);
}
}
lsi->lsi_server_started = 1;
mutex_unlock(&server_start_lock);
- if (OBD_FAIL_PRECHECK(OBD_FAIL_OBD_STOP_MDS_RACE) &&
+ if (CFS_FAIL_PRECHECK(OBD_FAIL_OBD_STOP_MDS_RACE) &&
IS_MDT(lsi)) {
- OBD_RACE(OBD_FAIL_OBD_STOP_MDS_RACE);
+ CFS_RACE(OBD_FAIL_OBD_STOP_MDS_RACE);
msleep(2 * MSEC_PER_SEC);
}
*/
obd->obd_force = 1;
class_manual_cleanup(obd);
- if (OBD_FAIL_PRECHECK(OBD_FAIL_OBD_STOP_MDS_RACE)) {
+ if (CFS_FAIL_PRECHECK(OBD_FAIL_OBD_STOP_MDS_RACE)) {
int idx;
server_name2index(lsi->lsi_svname, &idx, NULL);
/* sleeping for MDT0001 */
if (idx == 1)
- OBD_RACE(OBD_FAIL_OBD_STOP_MDS_RACE);
+ CFS_RACE(OBD_FAIL_OBD_STOP_MDS_RACE);
}
} else {
CERROR("no obd %s\n", lsi->lsi_svname);
ENTRY;
/* to simulate target mount race */
- OBD_RACE(OBD_FAIL_TGT_MOUNT_RACE);
+ CFS_RACE(OBD_FAIL_TGT_MOUNT_RACE);
rc = lsi_prepare(lsi);
if (rc < 0) {