__u32 start_epoch;
struct obd_device_target *obt = &obd->u.obt;
struct ptlrpc_request *req;
- struct list_head client_list;
+ cfs_list_t client_list;
- spin_lock(&obt->obt_translock);
+ cfs_spin_lock(&obt->obt_translock);
start_epoch = lr_epoch(le64_to_cpu(obt->obt_last_transno)) + 1;
obt->obt_last_transno = cpu_to_le64((__u64)start_epoch <<
LR_EPOCH_BITS);
obt->obt_lsd->lsd_start_epoch = cpu_to_le32(start_epoch);
- spin_unlock(&obt->obt_translock);
+ cfs_spin_unlock(&obt->obt_translock);
CFS_INIT_LIST_HEAD(&client_list);
- spin_lock_bh(&obd->obd_processing_task_lock);
- list_splice_init(&obd->obd_final_req_queue, &client_list);
- spin_unlock_bh(&obd->obd_processing_task_lock);
+ cfs_spin_lock_bh(&obd->obd_processing_task_lock);
+ cfs_list_splice_init(&obd->obd_final_req_queue, &client_list);
+ cfs_spin_unlock_bh(&obd->obd_processing_task_lock);
/**
* go through list of exports participated in recovery and
* set new epoch for them
*/
- list_for_each_entry(req, &client_list, rq_list) {
+ cfs_list_for_each_entry(req, &client_list, rq_list) {
LASSERT(!req->rq_export->exp_delayed);
obt_client_epoch_update(req->rq_export);
}
/** return list back at once */
- spin_lock_bh(&obd->obd_processing_task_lock);
- list_splice_init(&client_list, &obd->obd_final_req_queue);
- spin_unlock_bh(&obd->obd_processing_task_lock);
+ cfs_spin_lock_bh(&obd->obd_processing_task_lock);
+ cfs_list_splice_init(&client_list, &obd->obd_final_req_queue);
+ cfs_spin_unlock_bh(&obd->obd_processing_task_lock);
obt_server_data_update(obd, 1);
}
lut->lut_lsd.lsd_uuid, lut->lut_mount_count,
lut->lut_last_transno);
- spin_lock(&lut->lut_translock);
+ cfs_spin_lock(&lut->lut_translock);
lut->lut_lsd.lsd_last_transno = lut->lut_last_transno;
- spin_unlock(&lut->lut_translock);
+ cfs_spin_unlock(&lut->lut_translock);
lsd_cpu_to_le(&lut->lut_lsd, &tmp_lsd);
if (lut->lut_last_rcvd != NULL)
struct lu_env env;
struct ptlrpc_request *req;
__u32 start_epoch;
- struct list_head client_list;
+ cfs_list_t client_list;
int rc;
if (lut->lut_obd->obd_stopping)
return;
}
- spin_lock(&lut->lut_translock);
+ cfs_spin_lock(&lut->lut_translock);
start_epoch = lr_epoch(lut->lut_last_transno) + 1;
lut->lut_last_transno = (__u64)start_epoch << LR_EPOCH_BITS;
lut->lut_lsd.lsd_start_epoch = start_epoch;
- spin_unlock(&lut->lut_translock);
+ cfs_spin_unlock(&lut->lut_translock);
CFS_INIT_LIST_HEAD(&client_list);
/**
* The recovery is not yet finished and final queue can still be updated
* with resend requests. Move final list to separate one for processing
*/
- spin_lock_bh(&lut->lut_obd->obd_processing_task_lock);
- list_splice_init(&lut->lut_obd->obd_final_req_queue, &client_list);
- spin_unlock_bh(&lut->lut_obd->obd_processing_task_lock);
+ cfs_spin_lock_bh(&lut->lut_obd->obd_processing_task_lock);
+ cfs_list_splice_init(&lut->lut_obd->obd_final_req_queue, &client_list);
+ cfs_spin_unlock_bh(&lut->lut_obd->obd_processing_task_lock);
/**
* go through list of exports participated in recovery and
* set new epoch for them
*/
- list_for_each_entry(req, &client_list, rq_list) {
+ cfs_list_for_each_entry(req, &client_list, rq_list) {
LASSERT(!req->rq_export->exp_delayed);
if (!req->rq_export->exp_vbr_failed)
lut_client_epoch_update(&env, lut, req->rq_export);
}
/** return list back at once */
- spin_lock_bh(&lut->lut_obd->obd_processing_task_lock);
- list_splice_init(&client_list, &lut->lut_obd->obd_final_req_queue);
- spin_unlock_bh(&lut->lut_obd->obd_processing_task_lock);
+ cfs_spin_lock_bh(&lut->lut_obd->obd_processing_task_lock);
+ cfs_list_splice_init(&client_list, &lut->lut_obd->obd_final_req_queue);
+ cfs_spin_unlock_bh(&lut->lut_obd->obd_processing_task_lock);
/** update server epoch */
lut_server_data_update(&env, lut, 1);
lu_env_fini(&env);
{
struct obd_export *exp = data;
LASSERT(exp->exp_obd == lut->lut_obd);
- spin_lock(&lut->lut_translock);
+ cfs_spin_lock(&lut->lut_translock);
if (transno > lut->lut_obd->obd_last_committed)
lut->lut_obd->obd_last_committed = transno;
LASSERT(exp);
if (transno > exp->exp_last_committed) {
exp->exp_last_committed = transno;
- spin_unlock(&lut->lut_translock);
+ cfs_spin_unlock(&lut->lut_translock);
ptlrpc_commit_replies(exp);
} else {
- spin_unlock(&lut->lut_translock);
+ cfs_spin_unlock(&lut->lut_translock);
}
class_export_cb_put(exp);
if (transno)
lut->lut_bottom = dt;
lut->lut_last_rcvd = NULL;
- spin_lock_init(&lut->lut_translock);
- spin_lock_init(&lut->lut_client_bitmap_lock);
- spin_lock_init(&lut->lut_trans_table_lock);
+ cfs_spin_lock_init(&lut->lut_translock);
+ cfs_spin_lock_init(&lut->lut_client_bitmap_lock);
+ cfs_spin_lock_init(&lut->lut_trans_table_lock);
/** obdfilter has no lu_device stack yet */
if (dt == NULL)