Method NextConsumerWeight

phxqueue/scheduler/schedulermgr.cpp:878–891

}

int SchedulerMgr::NextConsumerWeight(const shared_ptr<const config::TopicConfig> &topic_config,
                                     const int dynamic_load, const float mean_load,
                                     const int init_weight) {
    if (0 >= dynamic_load)
        return 0;

    int new_weight{static_cast<int>(init_weight * mean_load /
                                    static_cast<float>(dynamic_load))};
    if (init_weight * topic_config->GetProto().topic().scheduler_max_init_weight_percent() / 100 < new_weight) {
        new_weight = init_weight * topic_config->GetProto().topic().scheduler_max_init_weight_percent() / 100;
    }

    return new_weight;
}

void SchedulerMgr::IsForceMaster(bool &force, bool &master) {
    force = false;