mirror of
https://github.com/Xahau/xahaud.git
synced 2026-06-03 08:46:36 +00:00
clang-format fixes
This commit is contained in:
@@ -48,8 +48,8 @@ public:
|
||||
pthread_rwlock_destroy(&rwlock_);
|
||||
}
|
||||
|
||||
reader_preferring_shared_mutex(
|
||||
reader_preferring_shared_mutex const&) = delete;
|
||||
reader_preferring_shared_mutex(reader_preferring_shared_mutex const&) =
|
||||
delete;
|
||||
reader_preferring_shared_mutex&
|
||||
operator=(reader_preferring_shared_mutex const&) = delete;
|
||||
|
||||
|
||||
@@ -963,17 +963,15 @@ NetworkOPsImp::processHeartbeatTimer()
|
||||
setMode(OperatingMode::DISCONNECTED);
|
||||
std::stringstream ss;
|
||||
ss << "Node count (" << numPeers << ") has fallen "
|
||||
<< "below required minimum (" << minPeerCount_
|
||||
<< ").";
|
||||
<< "below required minimum (" << minPeerCount_ << ").";
|
||||
JLOG(m_journal.warn()) << ss.str();
|
||||
CLOG(clog.ss())
|
||||
<< "set mode to DISCONNECTED: " << ss.str();
|
||||
CLOG(clog.ss()) << "set mode to DISCONNECTED: " << ss.str();
|
||||
}
|
||||
else
|
||||
{
|
||||
CLOG(clog.ss())
|
||||
<< "already DISCONNECTED. too few peers ("
|
||||
<< numPeers << "), need at least " << minPeerCount_;
|
||||
<< "already DISCONNECTED. too few peers (" << numPeers
|
||||
<< "), need at least " << minPeerCount_;
|
||||
}
|
||||
|
||||
// MasterMutex lock need not be held to call
|
||||
|
||||
@@ -123,8 +123,9 @@ SHAMapStoreImp::SHAMapStoreImp(
|
||||
// value never triggers the "online_delete must be at least …" throw.
|
||||
if (isMemoryBackend_ && deleteInterval_ == 0)
|
||||
{
|
||||
auto const minInterval =
|
||||
config.standalone() ? minimumDeletionIntervalSA_ : minimumDeletionInterval_;
|
||||
auto const minInterval = config.standalone()
|
||||
? minimumDeletionIntervalSA_
|
||||
: minimumDeletionInterval_;
|
||||
deleteInterval_ = std::max(config.LEDGER_HISTORY, minInterval);
|
||||
}
|
||||
|
||||
@@ -345,7 +346,8 @@ SHAMapStoreImp::run()
|
||||
// After rotate(), newBackend (archive copy) becomes the new
|
||||
// writable, old writable becomes new archive, and old archive
|
||||
// is destroyed.
|
||||
JLOG(journal_.debug()) << "RWDB: creating pre-populated backend for rotation";
|
||||
JLOG(journal_.debug())
|
||||
<< "RWDB: creating pre-populated backend for rotation";
|
||||
auto newBackend = makeBackendRotating();
|
||||
dbRotating_->copyArchiveTo(*newBackend);
|
||||
if (healthWait() == stopping)
|
||||
|
||||
@@ -3,8 +3,8 @@
|
||||
#include <xrpld/nodestore/detail/DecodedBlob.h>
|
||||
#include <xrpld/nodestore/detail/EncodedBlob.h>
|
||||
#include <xrpld/nodestore/detail/codec.h>
|
||||
#include <xrpl/basics/contract.h>
|
||||
#include <xrpl/basics/ReaderPreferringSharedMutex.h>
|
||||
#include <xrpl/basics/contract.h>
|
||||
#include <boost/beast/core/string.hpp>
|
||||
#include <boost/core/ignore_unused.hpp>
|
||||
#include <boost/unordered/concurrent_flat_map.hpp>
|
||||
|
||||
@@ -55,7 +55,8 @@ DatabaseRotatingImp::copyArchiveTo(Backend& dest)
|
||||
return archiveBackend_;
|
||||
}();
|
||||
|
||||
archive->for_each([&](std::shared_ptr<NodeObject> obj) { dest.store(obj); });
|
||||
archive->for_each(
|
||||
[&](std::shared_ptr<NodeObject> obj) { dest.store(obj); });
|
||||
}
|
||||
|
||||
void
|
||||
|
||||
Reference in New Issue
Block a user