INNER CODE UNIT · C++

worker_to_retrieve_from

fbreitwieser/krakenuniq · src/classify.cpp:421

    int worker_to_retrieve_from = -1;
    for (int worker_id = 0; worker_id < Num_threads; ++worker_id) {
      if (seq_idx == next_read_id[worker_id]) {
        worker_to_retrieve_from = worker_id;
        break;
      }
    }
    if (worker_to_retrieve_from == -1)
      break; // finished processing all files

    // retrieve from that worker and load next sequence name
    uint32_t taxa_size;
    fread(&taxa_size, sizeof(uint32_t), 1, worker_files[worker_to_retrieve_from]);
    taxa.resize(taxa_size);
    fread(&taxa[0], sizeof(uint32_t), taxa_size, worker_files[worker_to_retrieve_from]);

    if (!first_intermediate_output)
    {

View source record →