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

Normalize files containing unit test code:

Browse Source 
Source files are split to place all unit test code into translation
units ending in .test.cpp with no other business logic in the same file,
and in directories named "test".

A new target is added to the SConstruct, invoked by:
    scons count
This prints the total number of source code lines occupied by unit tests,
in rippled specific code and excluding library subtrees.
This commit is contained in:
Vinnie Falco
2014-12-23 12:28:19 -08:00
parent 9eb7c8344f
commit 9a3214d46e
65 changed files with 2396 additions and 2788 deletions
Download Patch File Download Diff File Expand all files Collapse all files

257
src/ripple/resource/impl/Tests.cpp
View File

@@ -1,257 +0,0 @@
//------------------------------------------------------------------------------
/*
This file is part of rippled: https://github.com/ripple/rippled
Copyright (c) 2012, 2013 Ripple Labs Inc.
Permission to use, copy, modify, and/or distribute this software for any
purpose with or without fee is hereby granted, provided that the above
copyright notice and this permission notice appear in all copies.
THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
ANY SPECIAL , DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
*/
//==============================================================================
#include <beast/unit_test/suite.h>
#include <beast/chrono/chrono_io.h>
#include <beast/chrono/manual_clock.h>
#include <beast/module/core/maths/Random.h>
#include <boost/utility/base_from_member.hpp>
namespace ripple {
namespace Resource {
class Manager_test : public beast::unit_test::suite
{
public:
class TestLogic
: private boost::base_from_member <
beast::manual_clock <std::chrono::steady_clock>>
, public Logic
{
private:
typedef boost::base_from_member <
beast::manual_clock <std::chrono::steady_clock>> clock_type;
public:
explicit TestLogic (beast::Journal journal)
: Logic (beast::insight::NullCollector::New(), member, journal)
{
}
void advance ()
{
++member;
}
beast::manual_clock <std::chrono::steady_clock>& clock ()
{
return member;
}
};
//--------------------------------------------------------------------------
void createGossip (Gossip& gossip)
{
beast::Random r;
int const v (10 + r.nextInt (10));
int const n (10 + r.nextInt (10));
gossip.items.reserve (n);
for (int i = 0; i < n; ++i)
{
Gossip::Item item;
item.balance = 100 + r.nextInt (500);
item.address = beast::IP::Endpoint (
beast::IP::AddressV4 (207, 127, 82, v + i));
gossip.items.push_back (item);
}
}
//--------------------------------------------------------------------------
void testDrop (beast::Journal j)
{
testcase ("Warn/drop");
TestLogic logic (j);
Charge const fee (dropThreshold + 1);
beast::IP::Endpoint const addr (
beast::IP::Endpoint::from_string ("207.127.82.2"));
{
Consumer c (logic.newInboundEndpoint (addr));
// Create load until we get a warning
int n = 10000;
while (--n >= 0)
{
if (n == 0)
{
fail ("Loop count exceeded without warning");
return;
}
if (c.charge (fee) == warn)
{
pass ();
break;
}
++logic.clock ();
}
// Create load until we get dropped
while (--n >= 0)
{
if (n == 0)
{
fail ("Loop count exceeded without dropping");
return;
}
if (c.charge (fee) == drop)
{
// Disconnect abusive Consumer
expect (c.disconnect ());
break;
}
++logic.clock ();
}
}
// Make sure the consumer is on the blacklist for a while.
{
Consumer c (logic.newInboundEndpoint (addr));
logic.periodicActivity();
if (c.disposition () != drop)
{
fail ("Dropped consumer not put on blacklist");
return;
}
}
// Makes sure the Consumer is eventually removed from blacklist
bool readmitted = false;
{
// Give Consumer time to become readmitted. Should never
// exceed expiration time.
std::size_t n (secondsUntilExpiration + 1);
while (--n > 0)
{
++logic.clock ();
logic.periodicActivity();
Consumer c (logic.newInboundEndpoint (addr));
if (c.disposition () != drop)
{
readmitted = true;
break;
}
}
}
if (readmitted == false)
{
fail ("Dropped Consumer left on blacklist too long");
return;
}
pass();
}
void testImports (beast::Journal j)
{
testcase ("Imports");
TestLogic logic (j);
Gossip g[5];
for (int i = 0; i < 5; ++i)
createGossip (g[i]);
for (int i = 0; i < 5; ++i)
logic.importConsumers (std::to_string (i), g[i]);
pass();
}
void testImport (beast::Journal j)
{
testcase ("Import");
TestLogic logic (j);
Gossip g;
Gossip::Item item;
item.balance = 100;
item.address = beast::IP::Endpoint (
beast::IP::AddressV4 (207, 127, 82, 1));
g.items.push_back (item);
logic.importConsumers ("g", g);
pass();
}
void testCharges (beast::Journal j)
{
testcase ("Charge");
TestLogic logic (j);
{
beast::IP::Endpoint address (beast::IP::Endpoint::from_string ("207.127.82.1"));
Consumer c (logic.newInboundEndpoint (address));
Charge fee (1000);
j.info <<
"Charging " << c.to_string() << " " << fee << " per second";
c.charge (fee);
for (int i = 0; i < 128; ++i)
{
j.info <<
"Time= " << logic.clock().now().time_since_epoch() <<
", Balance = " << c.balance();
logic.advance();
}
}
{
beast::IP::Endpoint address (beast::IP::Endpoint::from_string ("207.127.82.2"));
Consumer c (logic.newInboundEndpoint (address));
Charge fee (1000);
j.info <<
"Charging " << c.to_string() << " " << fee << " per second";
for (int i = 0; i < 128; ++i)
{
c.charge (fee);
j.info <<
"Time= " << logic.clock().now().time_since_epoch() <<
", Balance = " << c.balance();
logic.advance();
}
}
pass();
}
void run()
{
beast::Journal j;
testDrop (j);
testCharges (j);
testImports (j);
testImport (j);
}
};
BEAST_DEFINE_TESTSUITE(Manager,resource,ripple);
}
}