Skip to content

Commit

Permalink
Update main_muse.cpp
Browse files Browse the repository at this point in the history
  • Loading branch information
jiyunmaths committed Nov 3, 2023
1 parent 1f99084 commit 9707298
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/main_muse.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -61,18 +61,18 @@ void processReadFun(PBReader* reader, std::atomic<bool>& gatherDone, PileUpLockF
node Node = {read, bam_calend(read)};
region = iter.push(Node);
if (region){
while(writeQ.push(region) == false);
while(processQSize.load() > PILEUP_SIZE);
assert(processQ.push(region));
++processQSize;
while(writeQ.push(region) == false);
}
}

while(region = iter.pop()){
while(writeQ.push(region) == false);
while(processQSize.load() > PILEUP_SIZE);
assert(processQ.push(region));
++processQSize;
while(writeQ.push(region) == false);
}
gatherDone.store(true);

Expand Down

0 comments on commit 9707298

Please sign in to comment.