ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-12-06 17:27:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Improve charge handling in NoRippleCheckLimits test (RIPD-1641)

Browse Source
This commit is contained in:
Mike Ellery
2018-06-19 18:00:16 -07:00
committed by Nik Bougalis
parent d89ff1b63d
commit 49bcdda418
1 changed files with 27 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
src/test/rpc/NoRippleCheck_test.cpp
View File

@@ -254,27 +254,36 @@ class NoRippleCheckLimits_test : public beast::unit_test::suite
env (fset (alice, asfDefaultRipple));
env.close ();
auto checkBalance = [&env]()
{
// this is endpoint drop prevention. Non admin ports will drop
// requests if they are coming too fast, so we manipulate the
// resource manager here to reset the enpoint balance (for
// localhost) if we get too close to the drop limit. It would
// be better if we could add this functionality to Env somehow
// or otherwise disable endpoint charging for certain test
// cases.
using namespace ripple::Resource;
using namespace std::chrono;
using namespace beast::IP;
auto c = env.app ().getResourceManager ()
.newInboundEndpoint (
Endpoint::from_string (test::getEnvLocalhostAddr()));
// if we go above the warning threshold, reset
if (c.balance() > warningThreshold)
{
using clock_type = beast::abstract_clock <steady_clock>;
c.entry().local_balance =
DecayingSample <decayWindowSeconds, clock_type>
{steady_clock::now()};
}
};
for (auto i = 0; i < ripple::RPC::Tuning::noRippleCheck.rmax + 5; ++i)
{
if (! admin)
{
// endpoint drop prevention. Non admin ports will drop requests
// if they are coming too fast, so we manipulate the resource
// manager here to reset the enpoint balance (for localhost) if
// we get too close to the drop limit.
using namespace ripple::Resource;
using namespace std::chrono;
using namespace beast::IP;
auto c = env.app().getResourceManager()
.newInboundEndpoint (Endpoint::from_string (test::getEnvLocalhostAddr()));
if (dropThreshold - c.balance() <= 20)
{
using clock_type = beast::abstract_clock <steady_clock>;
c.entry().local_balance =
DecayingSample <decayWindowSeconds, clock_type>
{steady_clock::now()};
}
}
checkBalance();
auto& txq = env.app().getTxQ();
auto const gw = Account {"gw" + std::to_string(i)};