X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Fllite%2Fcommit_callback.c;h=fed2b3d6161d9246b9da277e92af127322ddda50;hb=2ad1df3c62663ce61e82856ebe4f576f751d617d;hp=17b25b84f7fcdfdf2d983577d36a52dd24f7eb33;hpb=76ffaefbe8efe0c294562b433ed070c094b75519;p=fs%2Flustre-release.git diff --git a/lustre/llite/commit_callback.c b/lustre/llite/commit_callback.c index 17b25b8..fed2b3d 100644 --- a/lustre/llite/commit_callback.c +++ b/lustre/llite/commit_callback.c @@ -44,9 +44,6 @@ static int ll_commitcbd_check_event(struct ll_sb_info *sbi) 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); @@ -83,10 +80,12 @@ static int ll_commitcbd_main(void *arg) 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"); @@ -100,6 +99,8 @@ static int ll_commitcbd_main(void *arg) RETURN(0); } + + int ll_commitcbd_setup(struct ll_sb_info *sbi) { int rc;