mirror of
https://github.com/Xahau/xahaud.git
synced 2026-07-26 08:30:12 +00:00
Remove using namespace declarations at namespace scope in headers
This commit is contained in:
@@ -411,6 +411,7 @@ RCLConsensus::Adaptor::doAccept(
|
||||
if (consensusCloseTime == NetClock::time_point{})
|
||||
{
|
||||
// We agreed to disagree on the close time
|
||||
using namespace std::chrono_literals;
|
||||
consensusCloseTime = prevLedger.closeTime() + 1s;
|
||||
closeTimeCorrect = false;
|
||||
}
|
||||
@@ -668,6 +669,7 @@ RCLConsensus::Adaptor::buildLCL(
|
||||
}();
|
||||
|
||||
// Update fee computations based on accepted txs
|
||||
using namespace std::chrono_literals;
|
||||
app_.getTxQ().processClosedLedger(app_, *buildLCL, roundTime > 5s);
|
||||
|
||||
// And stash the ledger in the ledger master
|
||||
@@ -685,6 +687,7 @@ RCLConsensus::Adaptor::validate(RCLCxLedger const& ledger,
|
||||
RCLTxSet const& txns,
|
||||
bool proposing)
|
||||
{
|
||||
using namespace std::chrono_literals;
|
||||
auto validationTime = app_.timeKeeper().closeTime();
|
||||
if (validationTime <= lastValidationTime_)
|
||||
validationTime = lastValidationTime_ + 1s;
|
||||
|
||||
@@ -44,7 +44,7 @@ LedgerHistory::LedgerHistory (
|
||||
, mismatch_counter_ (collector->make_counter ("ledger.history", "mismatch"))
|
||||
, m_ledgers_by_hash ("LedgerCache", CACHED_LEDGER_NUM, CachedLedgerAge,
|
||||
stopwatch(), app_.journal("TaggedCache"))
|
||||
, m_consensus_validated ("ConsensusValidated", 64, 5min,
|
||||
, m_consensus_validated ("ConsensusValidated", 64, std::chrono::minutes {5},
|
||||
stopwatch(), app_.journal("TaggedCache"))
|
||||
, j_ (app.journal ("LedgerHistory"))
|
||||
{
|
||||
|
||||
@@ -28,7 +28,7 @@ namespace ripple {
|
||||
|
||||
TransactionMaster::TransactionMaster (Application& app)
|
||||
: mApp (app)
|
||||
, mCache ("TransactionCache", 65536, 30min, stopwatch(),
|
||||
, mCache ("TransactionCache", 65536, std::chrono::minutes {30}, stopwatch(),
|
||||
mApp.journal("TaggedCache"))
|
||||
{
|
||||
}
|
||||
|
||||
@@ -112,8 +112,8 @@ public:
|
||||
AppFamily (Application& app, NodeStore::Database& db,
|
||||
CollectorManager& collectorManager)
|
||||
: app_ (app)
|
||||
, treecache_ ("TreeNodeCache", 65536, 1min, stopwatch(),
|
||||
app.journal("TaggedCache"))
|
||||
, treecache_ ("TreeNodeCache", 65536, std::chrono::minutes {1},
|
||||
stopwatch(), app.journal("TaggedCache"))
|
||||
, fullbelow_ ("full_below", stopwatch(),
|
||||
collectorManager.collector(),
|
||||
fullBelowTargetSize, fullBelowExpiration)
|
||||
@@ -417,8 +417,8 @@ public:
|
||||
|
||||
, accountIDCache_(128000)
|
||||
|
||||
, m_tempNodeCache ("NodeCache", 16384, 90s, stopwatch(),
|
||||
logs_->journal("TaggedCache"))
|
||||
, m_tempNodeCache ("NodeCache", 16384, std::chrono::seconds {90},
|
||||
stopwatch(), logs_->journal("TaggedCache"))
|
||||
|
||||
, m_collectorManager (CollectorManager::New (
|
||||
config_->section (SECTION_INSIGHT), logs_->journal("Collector")))
|
||||
@@ -471,8 +471,8 @@ public:
|
||||
gotTXSet (set, fromAcquire);
|
||||
}))
|
||||
|
||||
, m_acceptedLedgerCache ("AcceptedLedger", 4, 1min, stopwatch(),
|
||||
logs_->journal("TaggedCache"))
|
||||
, m_acceptedLedgerCache ("AcceptedLedger", 4, std::chrono::minutes {1},
|
||||
stopwatch(), logs_->journal("TaggedCache"))
|
||||
|
||||
, m_networkOPs (make_NetworkOPs (*this, stopwatch(),
|
||||
config_->standalone(), config_->NETWORK_QUORUM, config_->START_VALID,
|
||||
@@ -609,7 +609,7 @@ public:
|
||||
return nodeIdentity_;
|
||||
}
|
||||
|
||||
|
||||
|
||||
PublicKey const &
|
||||
getValidationPublicKey() const override
|
||||
{
|
||||
@@ -926,6 +926,7 @@ public:
|
||||
}
|
||||
// Make sure that any waitHandlers pending in our timers are done
|
||||
// before we declare ourselves stopped.
|
||||
using namespace std::chrono_literals;
|
||||
waitHandlerCounter_.join("Application", 1s, m_journal);
|
||||
|
||||
JLOG(m_journal.debug()) << "Flushing validations";
|
||||
|
||||
@@ -104,6 +104,7 @@ void LoadManager::run ()
|
||||
{
|
||||
beast::setCurrentThreadName ("LoadManager");
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
using clock_type = std::chrono::system_clock;
|
||||
|
||||
auto t = clock_type::now();
|
||||
|
||||
@@ -766,6 +766,7 @@ void NetworkOPsImp::processHeartbeatTimer ()
|
||||
|
||||
void NetworkOPsImp::processClusterTimer ()
|
||||
{
|
||||
using namespace std::chrono_literals;
|
||||
bool const update = app_.cluster().update(
|
||||
app_.nodeIdentity().first,
|
||||
"",
|
||||
@@ -1780,6 +1781,7 @@ void NetworkOPsImp::pubPeerStatus (
|
||||
|
||||
void NetworkOPsImp::setMode (OperatingMode om)
|
||||
{
|
||||
using namespace std::chrono_literals;
|
||||
if (om == omCONNECTED)
|
||||
{
|
||||
if (app_.getLedgerMaster ().getValidatedLedgerAge () < 1min)
|
||||
@@ -2314,6 +2316,7 @@ Json::Value NetworkOPsImp::getServerInfo (bool human, bool admin, bool counters)
|
||||
auto closeTime = app_.timeKeeper().closeTime();
|
||||
if (lCloseTime <= closeTime)
|
||||
{
|
||||
using namespace std::chrono_literals;
|
||||
auto age = closeTime - lCloseTime;
|
||||
if (age < 1000000s)
|
||||
l[jss::age] = Json::UInt (age.count());
|
||||
|
||||
@@ -855,6 +855,7 @@ Consensus<Adaptor>::simulate(
|
||||
NetClock::time_point const& now,
|
||||
boost::optional<std::chrono::milliseconds> consensusDelay)
|
||||
{
|
||||
using namespace std::chrono_literals;
|
||||
JLOG(j_.info()) << "Simulating consensus";
|
||||
now_ = now;
|
||||
closeLedger();
|
||||
|
||||
@@ -25,8 +25,6 @@
|
||||
|
||||
namespace ripple {
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
|
||||
/** Consensus algorithm parameters
|
||||
|
||||
Parameters which control the consensus algorithm. This are not
|
||||
@@ -45,7 +43,7 @@ struct ConsensusParms
|
||||
This is a safety to protect against very old validations and the time
|
||||
it takes to adjust the close time accuracy window.
|
||||
*/
|
||||
std::chrono::seconds validationVALID_WALL = 5min;
|
||||
std::chrono::seconds validationVALID_WALL = std::chrono::minutes {5};
|
||||
|
||||
/** Duration a validation remains current after first observed.
|
||||
|
||||
@@ -53,21 +51,21 @@ struct ConsensusParms
|
||||
first saw it. This provides faster recovery in very rare cases where the
|
||||
number of validations produced by the network is lower than normal
|
||||
*/
|
||||
std::chrono::seconds validationVALID_LOCAL = 3min;
|
||||
std::chrono::seconds validationVALID_LOCAL = std::chrono::minutes {3};
|
||||
|
||||
/** Duration pre-close in which validations are acceptable.
|
||||
|
||||
The number of seconds before a close time that we consider a validation
|
||||
acceptable. This protects against extreme clock errors
|
||||
*/
|
||||
std::chrono::seconds validationVALID_EARLY = 3min;
|
||||
std::chrono::seconds validationVALID_EARLY = std::chrono::minutes {3};
|
||||
|
||||
|
||||
//! How long we consider a proposal fresh
|
||||
std::chrono::seconds proposeFRESHNESS = 20s;
|
||||
std::chrono::seconds proposeFRESHNESS = std::chrono::seconds {20};
|
||||
|
||||
//! How often we force generating a new proposal to keep ours fresh
|
||||
std::chrono::seconds proposeINTERVAL = 12s;
|
||||
std::chrono::seconds proposeINTERVAL = std::chrono::seconds {12};
|
||||
|
||||
|
||||
//-------------------------------------------------------------------------
|
||||
@@ -78,16 +76,17 @@ struct ConsensusParms
|
||||
std::size_t minCONSENSUS_PCT = 80;
|
||||
|
||||
//! The duration a ledger may remain idle before closing
|
||||
std::chrono::milliseconds ledgerIDLE_INTERVAL = 15s;
|
||||
std::chrono::milliseconds ledgerIDLE_INTERVAL = std::chrono::seconds {15};
|
||||
|
||||
//! The number of seconds we wait minimum to ensure participation
|
||||
std::chrono::milliseconds ledgerMIN_CONSENSUS = 1950ms;
|
||||
std::chrono::milliseconds ledgerMIN_CONSENSUS =
|
||||
std::chrono::milliseconds {1950};
|
||||
|
||||
//! Minimum number of seconds to wait to ensure others have computed the LCL
|
||||
std::chrono::milliseconds ledgerMIN_CLOSE = 2s;
|
||||
std::chrono::milliseconds ledgerMIN_CLOSE = std::chrono::seconds {2};
|
||||
|
||||
//! How often we check state or change positions
|
||||
std::chrono::milliseconds ledgerGRANULARITY = 1s;
|
||||
std::chrono::milliseconds ledgerGRANULARITY = std::chrono::seconds {1};
|
||||
|
||||
/** The minimum amount of time to consider the previous round
|
||||
to have taken.
|
||||
@@ -99,7 +98,7 @@ struct ConsensusParms
|
||||
twice the interval between proposals (0.7s) divided by
|
||||
the interval between mid and late consensus ([85-50]/100).
|
||||
*/
|
||||
std::chrono::milliseconds avMIN_CONSENSUS_TIME = 5s;
|
||||
std::chrono::milliseconds avMIN_CONSENSUS_TIME = std::chrono::seconds {5};
|
||||
|
||||
//------------------------------------------------------------------------------
|
||||
// Avalanche tuning
|
||||
|
||||
@@ -27,15 +27,20 @@
|
||||
|
||||
namespace ripple {
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
|
||||
/** Possible ledger close time resolutions.
|
||||
|
||||
Values should not be duplicated.
|
||||
@see getNextLedgerTimeResolution
|
||||
*/
|
||||
std::chrono::seconds constexpr ledgerPossibleTimeResolutions[] =
|
||||
{10s, 20s, 30s, 60s, 90s, 120s};
|
||||
{
|
||||
std::chrono::seconds { 10},
|
||||
std::chrono::seconds { 20},
|
||||
std::chrono::seconds { 30},
|
||||
std::chrono::seconds { 60},
|
||||
std::chrono::seconds { 90},
|
||||
std::chrono::seconds {120}
|
||||
};
|
||||
|
||||
//! Initial resolution of ledger close time.
|
||||
auto constexpr ledgerDefaultTimeResolution = ledgerPossibleTimeResolutions[2];
|
||||
|
||||
@@ -38,8 +38,6 @@
|
||||
|
||||
namespace ripple {
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
|
||||
class Rules;
|
||||
|
||||
//------------------------------------------------------------------------------
|
||||
@@ -144,7 +142,7 @@ public:
|
||||
bool PEER_PRIVATE = false; // True to ask peers not to relay current IP.
|
||||
int PEERS_MAX = 0;
|
||||
|
||||
std::chrono::seconds WEBSOCKET_PING_FREQ = 5min;
|
||||
std::chrono::seconds WEBSOCKET_PING_FREQ = std::chrono::minutes {5};
|
||||
|
||||
// Path searching
|
||||
int PATH_SEARCH_OLD = 7;
|
||||
|
||||
@@ -229,6 +229,7 @@ Shard::validate(Application& app)
|
||||
|
||||
// Use a short age to keep memory consumption low
|
||||
auto const savedAge {pCache_->getTargetAge()};
|
||||
using namespace std::chrono_literals;
|
||||
pCache_->setTargetAge(1s);
|
||||
|
||||
// Validate every ledger stored in this shard
|
||||
|
||||
@@ -113,6 +113,7 @@ Json::Value doGetCounts (RPC::Context& context)
|
||||
|
||||
std::string uptime;
|
||||
auto s = UptimeClock::now();
|
||||
using namespace std::chrono_literals;
|
||||
textTime (uptime, s, "year", 365 * 24h);
|
||||
textTime (uptime, s, "day", 24h);
|
||||
textTime (uptime, s, "hour", 1h);
|
||||
|
||||
@@ -55,8 +55,7 @@ static int const defaultAutoFillFeeDivisor = 1;
|
||||
static int const maxPathfindsInProgress = 2;
|
||||
static int const maxPathfindJobCount = 50;
|
||||
static int const maxJobQueueClients = 500;
|
||||
using namespace std::chrono_literals;
|
||||
auto constexpr maxValidatedLedgerAge = 2min;
|
||||
auto constexpr maxValidatedLedgerAge = std::chrono::minutes {2};
|
||||
static int const maxRequestSize = 1000000;
|
||||
|
||||
/** Maximum number of pages in one response from a binary LedgerData request. */
|
||||
|
||||
@@ -335,6 +335,7 @@ class Check_test : public beast::unit_test::suite
|
||||
// expected interaction between these optional fields; other than
|
||||
// the expiration, they are just plopped into the ledger. So I'm
|
||||
// not looking at interactions.
|
||||
using namespace std::chrono_literals;
|
||||
std::size_t const aliceCount {checksOnAccount (env, alice).size()};
|
||||
std::size_t const bobCount {checksOnAccount (env, bob).size()};
|
||||
env (check::create (alice, bob, USD(50)), expiration (env.now() + 1s));
|
||||
@@ -540,6 +541,7 @@ class Check_test : public beast::unit_test::suite
|
||||
expiration (env.now()), ter (tecEXPIRED));
|
||||
env.close();
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
env (check::create (alice, bob, USD(50)), expiration (env.now() + 1s));
|
||||
env.close();
|
||||
|
||||
@@ -1341,6 +1343,7 @@ class Check_test : public beast::unit_test::suite
|
||||
env (check::create (alice, bob, XRP(10)));
|
||||
env.close();
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
uint256 const chkIdExp {getCheckIndex (alice, env.seq (alice))};
|
||||
env (check::create (alice, bob, XRP(10)), expiration (env.now() + 1s));
|
||||
env.close();
|
||||
@@ -1615,6 +1618,7 @@ class Check_test : public beast::unit_test::suite
|
||||
env.close();
|
||||
|
||||
// Three checks that expire in 10 minutes.
|
||||
using namespace std::chrono_literals;
|
||||
uint256 const chkIdNotExp1 {getCheckIndex (alice, env.seq (alice))};
|
||||
env (check::create (alice, bob, XRP(10)), expiration (env.now()+600s));
|
||||
env.close();
|
||||
|
||||
@@ -259,6 +259,7 @@ public:
|
||||
g.signal();
|
||||
});
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
BEAST_EXPECT(g.wait_for(5s));
|
||||
BEAST_EXPECT(! result.isMember(jss::error));
|
||||
return result;
|
||||
|
||||
@@ -101,6 +101,7 @@ class RCLValidations_test : public beast::unit_test::suite
|
||||
std::vector<std::shared_ptr<Ledger const>> altHistory(
|
||||
history.begin(), history.begin() + diverge);
|
||||
// advance clock to get new ledgers
|
||||
using namespace std::chrono_literals;
|
||||
env.timeKeeper().set(env.timeKeeper().now() + 1200s);
|
||||
prev = altHistory.back();
|
||||
bool forceHash = true;
|
||||
|
||||
@@ -277,6 +277,7 @@ class Ticket_test : public beast::unit_test::suite
|
||||
Env env {*this, supported_amendments().set(featureTickets)};
|
||||
|
||||
// create and verify
|
||||
using namespace std::chrono_literals;
|
||||
uint32_t expire =
|
||||
(env.timeKeeper ().closeTime () + 60s)
|
||||
.time_since_epoch ().count ();
|
||||
|
||||
@@ -265,6 +265,7 @@ class TrustAndBalance_test : public beast::unit_test::suite
|
||||
|
||||
env.close();
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
BEAST_EXPECT(wsc->findMsg(5s,
|
||||
[](auto const& jv)
|
||||
{
|
||||
@@ -470,6 +471,7 @@ class TrustAndBalance_test : public beast::unit_test::suite
|
||||
"00000000DEADBEEF");
|
||||
env.close();
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
BEAST_EXPECT(wsc->findMsg(2s,
|
||||
[](auto const& jv)
|
||||
{
|
||||
|
||||
@@ -145,6 +145,7 @@ class TxQ_test : public beast::unit_test::suite
|
||||
|
||||
// Close the ledger with a delay to force the TxQ stats
|
||||
// to stay at the default.
|
||||
using namespace std::chrono_literals;
|
||||
env.close(env.now() + 5s, 10000ms);
|
||||
checkMetrics(env, 0,
|
||||
2 * (ripple::detail::supportedAmendments().size() + 1),
|
||||
@@ -2463,6 +2464,7 @@ public:
|
||||
checkMetrics(env, 0, boost::none, 4, 3, 256);
|
||||
|
||||
// First transaction establishes the messaging
|
||||
using namespace std::chrono_literals;
|
||||
BEAST_EXPECT(wsc->findMsg(5s,
|
||||
[&](auto const& jv)
|
||||
{
|
||||
|
||||
@@ -409,6 +409,7 @@ private:
|
||||
manifest1, expiredblob, expiredSig, version));
|
||||
|
||||
// apply single list
|
||||
using namespace std::chrono_literals;
|
||||
NetClock::time_point const expiration =
|
||||
env.timeKeeper().now() + 3600s;
|
||||
auto const blob1 = makeList (
|
||||
@@ -764,6 +765,7 @@ private:
|
||||
// do not apply expired list
|
||||
auto const version = 1;
|
||||
auto const sequence = 1;
|
||||
using namespace std::chrono_literals;
|
||||
NetClock::time_point const expiration =
|
||||
env.timeKeeper().now() + 60s;
|
||||
auto const blob = makeList (
|
||||
@@ -929,6 +931,7 @@ private:
|
||||
|
||||
auto const version = 1;
|
||||
auto const sequence = 1;
|
||||
using namespace std::chrono_literals;
|
||||
NetClock::time_point const expiration =
|
||||
env.timeKeeper().now() + 3600s;
|
||||
auto const blob = makeList (
|
||||
@@ -1011,6 +1014,7 @@ private:
|
||||
NetClock::time_point expiration;
|
||||
};
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
auto addPublishedList = [this, &env, &trustedKeys, &validators]()
|
||||
{
|
||||
auto const publisherSecret = randomSecretKey();
|
||||
|
||||
@@ -174,6 +174,7 @@ private:
|
||||
|
||||
auto const sequence = 1;
|
||||
auto const version = 1;
|
||||
using namespace std::chrono_literals;
|
||||
NetClock::time_point const expiration =
|
||||
env.timeKeeper().now() + 3600s;
|
||||
|
||||
|
||||
@@ -393,8 +393,6 @@ struct Peer
|
||||
Ledger const*
|
||||
acquireLedger(Ledger::ID const& ledgerID)
|
||||
{
|
||||
using namespace std::chrono;
|
||||
|
||||
auto it = ledgers.find(ledgerID);
|
||||
if (it != ledgers.end())
|
||||
return &(it->second);
|
||||
@@ -411,7 +409,7 @@ struct Peer
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
SimDuration minDuration{10s};
|
||||
for (auto const& link : net.links(this))
|
||||
{
|
||||
@@ -457,6 +455,7 @@ struct Peer
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
SimDuration minDuration{10s};
|
||||
for (auto const& link : net.links(this))
|
||||
{
|
||||
|
||||
@@ -101,6 +101,7 @@ LedgerOracle::accept(
|
||||
NetClock::duration closeTimeResolution,
|
||||
NetClock::time_point const& consensusCloseTime)
|
||||
{
|
||||
using namespace std::chrono_literals;
|
||||
Ledger::Instance next(*parent.instance_);
|
||||
next.txs.insert(txs.begin(), txs.end());
|
||||
next.seq = parent.seq() + Ledger::Seq{1};
|
||||
|
||||
@@ -45,12 +45,12 @@ class HeartbeatTimer
|
||||
|
||||
public:
|
||||
HeartbeatTimer(
|
||||
Scheduler& sched,
|
||||
SimDuration interval = std::chrono::seconds(60s),
|
||||
std::ostream& out = std::cerr)
|
||||
: scheduler_{sched}, interval_{interval}, out_{out},
|
||||
startRealTime_{RealClock::now()},
|
||||
startSimTime_{sched.now()}
|
||||
Scheduler& sched,
|
||||
SimDuration interval = std::chrono::seconds {60},
|
||||
std::ostream& out = std::cerr)
|
||||
: scheduler_{sched}, interval_{interval}, out_{out},
|
||||
startRealTime_{RealClock::now()},
|
||||
startSimTime_{sched.now()}
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
@@ -130,6 +130,7 @@ Env::close(NetClock::time_point closeTime,
|
||||
boost::optional<std::chrono::milliseconds> consensusDelay)
|
||||
{
|
||||
// Round up to next distinguishable value
|
||||
using namespace std::chrono_literals;
|
||||
closeTime += closed()->info().closeTimeResolution - 1s;
|
||||
timeKeeper().set(closeTime);
|
||||
// Go through the rpc interface unless we need to simulate
|
||||
|
||||
@@ -1013,6 +1013,7 @@ public:
|
||||
BEAST_EXPECT(jrOffer[jss::owner_funds] == "100");
|
||||
BEAST_EXPECT(jrOffer[jss::quality] == "400000000");
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
BEAST_EXPECT(wsc->findMsg(5s,
|
||||
[&](auto const& jv)
|
||||
{
|
||||
@@ -1156,6 +1157,7 @@ public:
|
||||
env(offer(charlie, USD(1000), XRP(1000)));
|
||||
env.close();
|
||||
env.require(offers(alice, 0), offers(bob, 0), offers(charlie, 0));
|
||||
using namespace std::chrono_literals;
|
||||
BEAST_EXPECT(offerOnlyOnceInStream(wsc, 1s, XRP(1000), USD(1000)));
|
||||
|
||||
// RPC unsubscribe
|
||||
@@ -1238,6 +1240,7 @@ public:
|
||||
// Charlies places an on offer for EUR -> USD that should auto-bridge
|
||||
env(offer(charlie, USD(1), EUR(1)));
|
||||
env.close();
|
||||
using namespace std::chrono_literals;
|
||||
BEAST_EXPECT(offerOnlyOnceInStream(wsc, 1s, EUR(1), USD(1)));
|
||||
|
||||
// RPC unsubscribe
|
||||
|
||||
@@ -666,6 +666,7 @@ class LedgerRPC_test : public beast::unit_test::suite
|
||||
return jv;
|
||||
};
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
env (escrowCreate (alice, alice, XRP(333), env.now() + 2s));
|
||||
env.close();
|
||||
|
||||
|
||||
@@ -52,6 +52,7 @@ class Peers_test : public beast::unit_test::suite
|
||||
|
||||
std::string name = "Node " + std::to_string(i);
|
||||
|
||||
using namespace std::chrono_literals;
|
||||
env.app().cluster().update(
|
||||
kp.first,
|
||||
name,
|
||||
|
||||
@@ -360,6 +360,7 @@ public:
|
||||
env.close();
|
||||
|
||||
// Check stream update
|
||||
using namespace std::chrono_literals;
|
||||
BEAST_EXPECT(wsc->findMsg(5s,
|
||||
[&](auto const& jv)
|
||||
{
|
||||
|
||||
@@ -269,6 +269,7 @@ public:
|
||||
//----------------------------------------------------------------------
|
||||
// Publisher list site available
|
||||
{
|
||||
using namespace std::chrono_literals;
|
||||
NetClock::time_point const expiration{3600s};
|
||||
|
||||
// Manage single thread io_service for server
|
||||
|
||||
Reference in New Issue
Block a user