Function GenerateSubtasks

library/cpp/par/distr_tree.cpp:279–298

    }

    void GenerateSubtasks(const TVector<ui16>& src, TVector<TVector<ui16>>* subTasks) {
        for (int i = 0; i < src.ysize(); ++i) {
            TVector<ui16>& dst = subTasks->emplace_back();
            if (src[i] == N_GROUP_START) {
                // embedded group
                int depth = 1;
                for (++i; i < src.ysize(); ++i) {
                    ui16 val = src[i];
                    if (val == N_GROUP_END) {
                        if (--depth == 0)
                            break;
                    } else if (val == N_GROUP_START)
                        ++depth;
                    dst.push_back(src[i]);
                }
                Y_ASSERT(depth == 0);
            } else
                dst.push_back(src[i]);
        }
    }

    int SelectRandomHost(const TVector<ui16>& execPlan) {
        size_t ptr = RandomNumber(execPlan.size());