oxen-io/lokinet
1
1
Fork 0
mirror of https://github.com/oxen-io/lokinet synced 2023-12-14 06:53:00 +01:00
Code Issues Projects Releases Wiki Activity

extract more status info for outbound context

Browse source
This commit is contained in:
Jeff Becker 2019-02-09 10:39:39 -05:00
parent 1a929f9383
commit 05cd1b7f8e
No known key found for this signature in database
GPG key ID: F357B3B42F6F9B05
2 changed files with 37 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
llarp/service/endpoint.cpp
View file

@ -1718,6 +1718,40 @@ namespace llarp
}
}
void
Endpoint::OutboundContext::ExtractStatus(util::StatusObject& obj) const
{
path::Builder::ExtractStatus(obj);
obj.PutString("currentConvoTag", currentConvoTag.ToHex());
util::StatusObject remoteIntroObj;
remoteIntro.ExtractStatus(remoteIntroObj);
obj.PutObject("remoteIntro", remoteIntroObj);
obj.PutInt("sessionCreatedAt", createdAt);
obj.PutInt("lastGoodSend", lastGoodSend);
obj.PutInt("seqno", sequenceNo);
obj.PutBool("markedBad", markedBad);
obj.PutInt("lastShift", lastShift);
obj.PutString("remoteIdentity", remoteIdent.Addr().ToString());
util::StatusObject remoteIntrosetObj;
currentIntroSet.ExtractStatus(remoteIntrosetObj);
obj.PutObject("currentRemoteIntroset", remoteIntrosetObj);
util::StatusObject nextIntroObj;
m_NextIntro.ExtractStatus(nextIntroObj);
obj.PutObject("nextIntro", nextIntroObj);
std::vector< util::StatusObject > badIntrosObj(m_BadIntros.size());
{
size_t idx = 0;
for(const auto& item : m_BadIntros)
{
auto& badIntroObj = badIntrosObj[idx++];
badIntroObj.PutInt("count", item.second);
util::StatusObject i;
item.first.ExtractStatus(i);
badIntroObj.PutObject("intro", i);
}
}
}
bool
Endpoint::OutboundContext::Tick(llarp_time_t now)
{

3
llarp/service/endpoint.hpp
View file

@ -267,6 +267,9 @@ namespace llarp
OutboundContext(const IntroSet& introSet, Endpoint* parent);
~OutboundContext();
void
ExtractStatus(util::StatusObject& obj) const override;
bool
Stop() override;