GOTO(out, rc = 1);
}
- if (!list_empty(&sbi->ll_commitcbd_not_committed))
- GOTO(out, rc = 1);
-
out:
spin_unlock(&sbi->ll_commitcbd_lock);
RETURN(rc);
/* And now, loop forever on requests */
while (1) {
- wait_event_interruptible
- (sbi->ll_commitcbd_waitq,
- ll_commitcbd_check_event(sbi));
+ wait_event(sbi->ll_commitcbd_waitq,
+ ll_commitcbd_check_event(sbi));
spin_lock(&sbi->ll_commitcbd_lock);
if (sbi->ll_commitcbd_flags & LL_COMMITCBD_STOPPING) {
spin_unlock(&sbi->ll_commitcbd_lock);
- CERROR("lustre_hamgr quitting\n");
+ CERROR("lustre_commitd quitting\n");
EXIT;
break;
}
RETURN(0);
}
+
+
int ll_commitcbd_setup(struct ll_sb_info *sbi)
{
int rc;
sbi->ll_commitcbd_flags = LL_COMMITCBD_STOPPING;
wake_up(&sbi->ll_commitcbd_waitq);
- wait_event_interruptible
- (sbi->ll_commitcbd_ctl_waitq,
- sbi->ll_commitcbd_flags & LL_COMMITCBD_STOPPED);
+ wait_event(sbi->ll_commitcbd_ctl_waitq,
+ sbi->ll_commitcbd_flags & LL_COMMITCBD_STOPPED);
RETURN(0);
}