mirror of https://github.com/oxen-io/lokinet
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
62 lines
1.6 KiB
C++
62 lines
1.6 KiB
C++
#include <service/tag_lookup_job.hpp>
|
|
|
|
#include <dht/messages/findintro.hpp>
|
|
#include <routing/dht_message.hpp>
|
|
#include <service/endpoint.hpp>
|
|
|
|
namespace llarp
|
|
{
|
|
namespace service
|
|
{
|
|
bool
|
|
CachedTagResult::HandleResponse(const std::set< IntroSet >& introsets)
|
|
{
|
|
auto now = m_parent->Now();
|
|
|
|
for(const auto& introset : introsets)
|
|
if(result.insert(introset).second)
|
|
lastModified = now;
|
|
LogInfo("Tag result for ", tag.ToString(), " got ", introsets.size(),
|
|
" results from lookup, have ", result.size(),
|
|
" cached last modified at ", lastModified, " is ",
|
|
now - lastModified, "ms old");
|
|
return true;
|
|
}
|
|
|
|
void
|
|
CachedTagResult::Expire(llarp_time_t now)
|
|
{
|
|
auto itr = result.begin();
|
|
while(itr != result.end())
|
|
{
|
|
if(itr->HasExpiredIntros(now))
|
|
{
|
|
LogInfo("Removing expired tag Entry ", itr->A.Name());
|
|
itr = result.erase(itr);
|
|
lastModified = now;
|
|
}
|
|
else
|
|
{
|
|
++itr;
|
|
}
|
|
}
|
|
}
|
|
|
|
std::shared_ptr< routing::IMessage >
|
|
CachedTagResult::BuildRequestMessage(uint64_t txid)
|
|
{
|
|
auto msg = std::make_shared< routing::DHTMessage >();
|
|
msg->M.emplace_back(std::make_unique< dht::FindIntroMessage >(tag, txid));
|
|
lastRequest = m_parent->Now();
|
|
return msg;
|
|
}
|
|
|
|
TagLookupJob::TagLookupJob(Endpoint* parent, CachedTagResult* result)
|
|
: IServiceLookup(parent, parent->GenTXID(), "taglookup")
|
|
, m_result(result)
|
|
{
|
|
}
|
|
} // namespace service
|
|
|
|
} // namespace llarp
|