GOTO(out, rc = 1);
}
- if (!list_empty(&sbi->ll_commitcbd_not_committed))
- GOTO(out, rc = 1);
-
out:
- spin_unlock(&mgr->mgr_lock);
+ spin_unlock(&sbi->ll_commitcbd_lock);
RETURN(rc);
}
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;
}
+ if (!list_empty(&sbi->ll_mds_client.cli_replied_head))
+ CERROR("** clean up committed reqs here **\n");
schedule_timeout(sbi->ll_commitcbd_timeout);
CERROR("commit callback daemon woken up - FIXME\n");
- spin_unlock(&mgr->mgr_lock);
+ spin_unlock(&sbi->ll_commitcbd_lock);
}
sbi->ll_commitcbd_thread = NULL;
RETURN(0);
}
+
+
int ll_commitcbd_setup(struct ll_sb_info *sbi)
{
int rc;