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

Add PropertyStream for server state introspection

Browse Source
This commit is contained in:
Vinnie Falco
2013-10-07 13:26:56 -07:00
parent 0b69378a03
commit fb6ecebbd1
17 changed files with 650 additions and 480 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/ripple/validators/impl/Manager.cpp
View File

@@ -139,6 +139,11 @@ public:
DeadlineTimer m_checkTimer;
ServiceQueue m_queue;
typedef ScopedWrapperContext <
RecursiveMutex, RecursiveMutex::ScopedLockType> Context;
Context m_context;
// True if we should call check on idle.
// This gets set to false once we make it through the whole list.
//
@@ -289,25 +294,28 @@ public:
// PropertyStream
//
void writeSources (PropertyStream stream)
void onWrite (PropertyStream::Map& map)
{
PropertyStream::ScopedArray sources ("sources", stream);
Context::Scope scope (m_context);
map ["trusted"] = uint32 (
m_logic.m_chosenList ?
m_logic.m_chosenList->size() : 0);
for (Logic::SourceTable::const_iterator iter (m_logic.m_sources.begin());
iter != m_logic.m_sources.end(); ++iter)
{
stream.append (iter->source->name().toStdString());
PropertyStream::Set items ("sources", map);
for (Logic::SourceTable::const_iterator iter (m_logic.m_sources.begin());
iter != m_logic.m_sources.end(); ++iter)
items.add (iter->source->name().toStdString());
}
}
void onWrite (PropertyStream stream)
{
// VFALCO NOTE this is not thread safe (yet)
stream ["trusted"] = uint32 (
m_logic.m_chosenList ? m_logic.m_chosenList->size() : 0);
writeSources (stream);
{
PropertyStream::Set items ("validators", map);
for (Logic::ValidatorTable::iterator iter (m_logic.m_validators.begin());
iter != m_logic.m_validators.end(); ++iter)
{
}
}
}
//--------------------------------------------------------------------------

1
src/ripple/validators/ripple_validators.cpp
View File

@@ -31,6 +31,7 @@
#include <set>
#include "beast/beast/threads/ScopedWrapperContext.h"
#include "beast/modules/beast_asio/beast_asio.h"
#include "beast/modules/beast_sqdb/beast_sqdb.h"