if a task of writting N files is assigned to this thread, but the input file doesn't have so many reads to input write some empty files so it will not break following pipelines
| 149 | // if a task of writting N files is assigned to this thread, but the input file doesn't have so many reads to input |
| 150 | // write some empty files so it will not break following pipelines |
| 151 | void ThreadConfig::writeEmptyFilesForSplitting() { |
| 152 | while(mWorkingSplit + mOptions->thread < mOptions->split.number) { |
| 153 | mWorkingSplit += mOptions->thread; |
| 154 | initWriterForSplit(); |
| 155 | mCurrentSplitReads = 0; |
| 156 | } |
| 157 | } |
| 158 | |
| 159 | bool ThreadConfig::canBeStopped() { |
| 160 | return mCanBeStopped; |
nothing calls this directly
no outgoing calls
no test coverage detected