int rc;
ENTRY;
- cfs_mutex_lock(&seq->lcs_mutex);
+ mutex_lock(&seq->lcs_mutex);
#ifdef __KERNEL__
if (seq->lcs_srv) {
#ifdef __KERNEL__
}
#endif
- cfs_mutex_unlock(&seq->lcs_mutex);
+ mutex_unlock(&seq->lcs_mutex);
RETURN(rc);
}
if (seq->lcs_update) {
cfs_waitq_add(&seq->lcs_waitq, link);
cfs_set_current_state(CFS_TASK_UNINT);
- cfs_mutex_unlock(&seq->lcs_mutex);
+ mutex_unlock(&seq->lcs_mutex);
cfs_waitq_wait(link, CFS_TASK_UNINT);
- cfs_mutex_lock(&seq->lcs_mutex);
+ mutex_lock(&seq->lcs_mutex);
cfs_waitq_del(&seq->lcs_waitq, link);
cfs_set_current_state(CFS_TASK_RUNNING);
return -EAGAIN;
}
++seq->lcs_update;
- cfs_mutex_unlock(&seq->lcs_mutex);
+ mutex_unlock(&seq->lcs_mutex);
return 0;
}
static void seq_fid_alloc_fini(struct lu_client_seq *seq)
{
LASSERT(seq->lcs_update == 1);
- cfs_mutex_lock(&seq->lcs_mutex);
+ mutex_lock(&seq->lcs_mutex);
--seq->lcs_update;
cfs_waitq_signal(&seq->lcs_waitq);
}
int rc;
LASSERT(seqnr != NULL);
- cfs_mutex_lock(&seq->lcs_mutex);
+ mutex_lock(&seq->lcs_mutex);
cfs_waitlink_init(&link);
while (1) {
CERROR("%s: Can't allocate new sequence, "
"rc %d\n", seq->lcs_name, rc);
seq_fid_alloc_fini(seq);
- cfs_mutex_unlock(&seq->lcs_mutex);
+ mutex_unlock(&seq->lcs_mutex);
return rc;
}
* to setup FLD for it.
*/
seq_fid_alloc_fini(seq);
- cfs_mutex_unlock(&seq->lcs_mutex);
+ mutex_unlock(&seq->lcs_mutex);
return rc;
}
LASSERT(fid != NULL);
cfs_waitlink_init(&link);
- cfs_mutex_lock(&seq->lcs_mutex);
+ mutex_lock(&seq->lcs_mutex);
+
+ if (OBD_FAIL_CHECK(OBD_FAIL_SEQ_EXHAUST))
+ seq->lcs_fid.f_oid = seq->lcs_width;
while (1) {
seqno_t seqnr;
CERROR("%s: Can't allocate new sequence, "
"rc %d\n", seq->lcs_name, rc);
seq_fid_alloc_fini(seq);
- cfs_mutex_unlock(&seq->lcs_mutex);
+ mutex_unlock(&seq->lcs_mutex);
RETURN(rc);
}
}
*fid = seq->lcs_fid;
- cfs_mutex_unlock(&seq->lcs_mutex);
+ mutex_unlock(&seq->lcs_mutex);
CDEBUG(D_INFO, "%s: Allocated FID "DFID"\n", seq->lcs_name, PFID(fid));
RETURN(rc);
LASSERT(seq != NULL);
cfs_waitlink_init(&link);
- cfs_mutex_lock(&seq->lcs_mutex);
+ mutex_lock(&seq->lcs_mutex);
while (seq->lcs_update) {
cfs_waitq_add(&seq->lcs_waitq, &link);
cfs_set_current_state(CFS_TASK_UNINT);
- cfs_mutex_unlock(&seq->lcs_mutex);
+ mutex_unlock(&seq->lcs_mutex);
cfs_waitq_wait(&link, CFS_TASK_UNINT);
- cfs_mutex_lock(&seq->lcs_mutex);
+ mutex_lock(&seq->lcs_mutex);
cfs_waitq_del(&seq->lcs_waitq, &link);
cfs_set_current_state(CFS_TASK_RUNNING);
}
seq->lcs_space.lsr_index = -1;
range_init(&seq->lcs_space);
- cfs_mutex_unlock(&seq->lcs_mutex);
+ mutex_unlock(&seq->lcs_mutex);
}
EXPORT_SYMBOL(seq_client_flush);
seq->lcs_exp = exp;
seq->lcs_srv = srv;
seq->lcs_type = type;
- cfs_mutex_init(&seq->lcs_mutex);
+ mutex_init(&seq->lcs_mutex);
seq->lcs_width = LUSTRE_SEQ_MAX_WIDTH;
cfs_waitq_init(&seq->lcs_waitq);