cfs_spin_unlock(&lut->lut_translock);
CFS_INIT_LIST_HEAD(&client_list);
- cfs_spin_lock_bh(&obd->obd_processing_task_lock);
+ cfs_spin_lock(&obd->obd_recovery_task_lock);
cfs_list_splice_init(&obd->obd_final_req_queue, &client_list);
- cfs_spin_unlock_bh(&obd->obd_processing_task_lock);
+ cfs_spin_unlock(&obd->obd_recovery_task_lock);
/**
* go through list of exports participated in recovery and
obt_client_epoch_update(req->rq_export);
}
/** return list back at once */
- cfs_spin_lock_bh(&obd->obd_processing_task_lock);
+ cfs_spin_lock(&obd->obd_recovery_task_lock);
cfs_list_splice_init(&client_list, &obd->obd_final_req_queue);
- cfs_spin_unlock_bh(&obd->obd_processing_task_lock);
+ cfs_spin_unlock(&obd->obd_recovery_task_lock);
obt_server_data_update(lut, 1);
}
rc = lu_env_init(&env, LCT_DT_THREAD);
if (rc) {
- CERROR("Can't initialize environment rc=%i\n", rc);
+ CERROR("Can't initialize environment rc=%d\n", rc);
return;
}
* The recovery is not yet finished and final queue can still be updated
* with resend requests. Move final list to separate one for processing
*/
- cfs_spin_lock_bh(&lut->lut_obd->obd_processing_task_lock);
+ cfs_spin_lock(&lut->lut_obd->obd_recovery_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);
+ cfs_spin_unlock(&lut->lut_obd->obd_recovery_task_lock);
/**
* go through list of exports participated in recovery and
lut_client_epoch_update(&env, req->rq_export);
}
/** return list back at once */
- cfs_spin_lock_bh(&lut->lut_obd->obd_processing_task_lock);
+ cfs_spin_lock(&lut->lut_obd->obd_recovery_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);
+ cfs_spin_unlock(&lut->lut_obd->obd_recovery_task_lock);
/** update server epoch */
lut_server_data_update(&env, lut, 1);
lu_env_fini(&env);