diff --git a/src/filtering-KMC/fastq_reader.cpp b/src/filtering-KMC/fastq_reader.cpp index e963ab2..075ad52 100644 --- a/src/filtering-KMC/fastq_reader.cpp +++ b/src/filtering-KMC/fastq_reader.cpp @@ -1140,8 +1140,9 @@ uint64 CFastqReaderDataSrc::read(uchar* buff, uint64 size, bool& last_in_file) { pmm_binary_file_reader->free(in_data); in_data = nullptr; - binary_pack_queue->pop(in_data, in_data_size, file_part, compression_type); - if (file_part == FilePart::End) + //may be false even if file_part != FilePart::End in stats mode + auto pop_res = binary_pack_queue->pop(in_data, in_data_size, file_part, compression_type); + if (!pop_res || file_part == FilePart::End) { in_progress = false; last_in_file = true;