fixed hang with consumer not signaling producer to quit

biobuilds · Nov 10, 2016 · 774095a · 774095a
1 parent 314daeb
commit 774095a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tools/bam-loader/loader-imp.c b/tools/bam-loader/loader-imp.c
@@ -1472,6 +1472,7 @@ static BAM_Alignment const *getNextRecord(BAM_File const *const bam, rc_t *const
                 (void)PLOGERR(klogWarn, (klogWarn, *rc, "KQueuePop Error", NULL));
         }
     }
+	KQueueSeal(bamq);
     {
         rc_t rc2 = 0;
         KThreadWait(bamread_thread, &rc2);
@@ -1480,7 +1481,6 @@ static BAM_Alignment const *getNextRecord(BAM_File const *const bam, rc_t *const
     }
     KThreadRelease(bamread_thread);
     bamread_thread = NULL;
-	KQueueSeal(bamq);
 	KQueueRelease(bamq);
     bamq = NULL;
     return NULL;