Entry.h

#ifndef XRPL_RESOURCE_ENTRY_H_INCLUDED
#define XRPL_RESOURCE_ENTRY_H_INCLUDED
 
#include <xrpl/basics/DecayingSample.h>
#include <xrpl/beast/clock/abstract_clock.h>
#include <xrpl/beast/core/List.h>
#include <xrpl/beast/utility/instrumentation.h>
#include <xrpl/resource/detail/Key.h>
#include <xrpl/resource/detail/Tuning.h>
 
namespace xrpl {
namespace Resource {
 
using clock_type = beast::abstract_clock<std::chrono::steady_clock>;
 
// An entry in the table
// VFALCO DEPRECATED using boost::intrusive list
struct Entry : public beast::List<Entry>::Node
{
    Entry() = delete;
 
    explicit Entry(clock_type::time_point const now)
        : refcount(0)
        , local_balance(now)
        , remote_balance(0)
        , lastWarningTime()
        , whenExpires()
    {
    }
 
    std::string
    to_string() const
    {
        return getFingerprint(key->address, publicKey);
    }
 
    bool
    isUnlimited() const
    {
        return key->kind == kindUnlimited;
    }
 
    // Balance including remote contributions
    int
    balance(clock_type::time_point const now)
    {
        return local_balance.value(now) + remote_balance;
    }
 
    // Add a charge and return normalized balance
    // including contributions from imports.
    int
    add(int charge, clock_type::time_point const now)
    {
        return local_balance.add(charge, now) + remote_balance;
    }
 
    // The public key of the peer
    std::optional<PublicKey> publicKey;
 
    // Back pointer to the map key (bit of a hack here)
    Key const* key;
 
    // Number of Consumer references
    int refcount;
 
    // Exponentially decaying balance of resource consumption
    DecayingSample<decayWindowSeconds, clock_type> local_balance;
 
    // Normalized balance contribution from imports
    int remote_balance;
 
    // Time of the last warning
    clock_type::time_point lastWarningTime;
 
    // For inactive entries, time after which this entry will be erased
    clock_type::time_point whenExpires;
};
 
inline std::ostream&
operator<<(std::ostream& os, Entry const& v)
{
    os << v.to_string();
    return os;
}
 
}  // namespace Resource
}  // namespace xrpl
 
#endif