rate_control.cc

Go to the documentation of this file.

// Copyright (C) 2013-2019 Internet Systems Consortium, Inc. ("ISC")
//
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
 
#include <config.h>
 
#include <perfdhcp/rate_control.h>
 
#include <exceptions/exceptions.h>
 
 
namespace isc {
namespace perfdhcp {
 
using namespace boost::posix_time;
 
RateControl::RateControl()
    : rate_(0), total_pkts_sent_count_(0) {
}
 
RateControl::RateControl(const unsigned int rate)
    : rate_(rate), total_pkts_sent_count_(0) {
}
 
uint64_t
RateControl::getOutboundMessageCount(bool const waiting_to_exit /* = false */) {
    if (total_pkts_sent_count_ == 0) {
        start_time_ = currentTime();
        total_pkts_sent_count_ = 1;
        return 1;
    }
 
    // If rate is not limited, then each time send 1 packet.
    if (getRate() == 0) {
        return 1;
    }
 
    // If we've entered exit wait time's zone, stop sending.
    if (waiting_to_exit) {
        return 0;
    }
 
    // Estimate number of packets to sent. If we are behind of time we will
    // try to catch up to upkeep request rate by sending more packets in one cycle.
    auto now = currentTime();
    time_period period(start_time_, now);
    time_duration duration = period.length();
    uint64_t should_sent_pkts_count = static_cast<double>(getRate()) / static_cast<double>(time_duration::ticks_per_second()) * duration.ticks();
    if (should_sent_pkts_count <= total_pkts_sent_count_) {
        return 0;
    }
    auto pending_pkts_count = should_sent_pkts_count - total_pkts_sent_count_;
 
    // Reduce bursts to have more uniform traffic.
    if (pending_pkts_count > 3) {
        pending_pkts_count = 3;
    }
    total_pkts_sent_count_ += pending_pkts_count;
 
    return pending_pkts_count;
}
 
boost::posix_time::ptime
RateControl::currentTime() {
    return (microsec_clock::universal_time());
}
 
void
RateControl::setRate(const int rate) {
    if (rate < 0) {
        isc_throw(isc::BadValue, "invalid value of rate " << rate
                  << ", expected non-negative value");
    }
    rate_ = rate;
}
 
} // namespace perfdhcp
} // namespace isc