mirror of
https://github.com/falcosecurity/falco.git
synced 2025-09-29 06:07:25 +00:00
c6953e810b
sinsp_utils::get_current_time_ns() has the same purpose as get_epoch_ns(), and now that we're including the token bucket in falco_engine, it's easy to package the dependency. So use that function instead.
72 lines
1.4 KiB
C++
72 lines
1.4 KiB
C++
/*
|
|
Copyright (C) 2016 Draios inc.
|
|
|
|
This file is part of falco.
|
|
|
|
falco is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License version 2 as
|
|
published by the Free Software Foundation.
|
|
|
|
falco is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with falco. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#include <cstddef>
|
|
#include <sys/time.h>
|
|
|
|
#include "utils.h"
|
|
#include "token_bucket.h"
|
|
|
|
token_bucket::token_bucket()
|
|
{
|
|
init(1, 1);
|
|
}
|
|
|
|
token_bucket::~token_bucket()
|
|
{
|
|
}
|
|
|
|
void token_bucket::init(uint32_t rate, uint32_t max_tokens)
|
|
{
|
|
m_rate = rate;
|
|
m_max_tokens = max_tokens;
|
|
m_tokens = max_tokens;
|
|
m_last_seen = sinsp_utils::get_current_time_ns();
|
|
}
|
|
|
|
bool token_bucket::claim()
|
|
{
|
|
// Determine the number of tokens gained. Delta between
|
|
// last_seen and now, divided by the rate.
|
|
uint64_t now = sinsp_utils::get_current_time_ns();
|
|
uint64_t tokens_gained = (now - m_last_seen) / (m_rate * 1000000000);
|
|
m_last_seen = now;
|
|
|
|
m_tokens += tokens_gained;
|
|
|
|
//
|
|
// Cap at max_tokens
|
|
//
|
|
if(m_tokens > m_max_tokens)
|
|
{
|
|
m_tokens = m_max_tokens;
|
|
}
|
|
|
|
//
|
|
// If tokens is < 1, can't claim.
|
|
//
|
|
if(m_tokens < 1)
|
|
{
|
|
return false;
|
|
}
|
|
|
|
m_tokens--;
|
|
|
|
return true;
|
|
}
|