Method wrap_up

Processor/ThreadQueues.cpp:142–162

}

void ThreadQueues::wrap_up(ThreadJob job)
{
#ifdef VERBOSE_QUEUES
    cerr << "Wrap up " << available.size() << " threads" << endl;
#endif
    for (int i : available)
    {
        auto result = at(i)->result();
        assert(result.output == job.output);
        assert(result.type == job.type);
    }
    available.clear();

    if (sync_point)
    {
        if (OnlineOptions::singleton.has_option("debug_sync"))
            cerr << "stopping sync" << endl;
        delete sync_point;
        sync_point = 0;
    }
}

TimerWithComm ThreadQueues::sum(const string& phase)
{