|
|
@ -20,6 +20,7 @@
|
|
|
|
#include <util/buffer.hpp>
|
|
|
|
#include <util/buffer.hpp>
|
|
|
|
#include <util/meta/memfn.hpp>
|
|
|
|
#include <util/meta/memfn.hpp>
|
|
|
|
#include <hook/shell.hpp>
|
|
|
|
#include <hook/shell.hpp>
|
|
|
|
|
|
|
|
#include <link/link_manager.hpp>
|
|
|
|
|
|
|
|
|
|
|
|
#include <utility>
|
|
|
|
#include <utility>
|
|
|
|
|
|
|
|
|
|
|
@ -1107,7 +1108,6 @@ namespace llarp
|
|
|
|
{
|
|
|
|
{
|
|
|
|
epPump();
|
|
|
|
epPump();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
auto router = Router();
|
|
|
|
auto router = Router();
|
|
|
|
// TODO: locking on this container
|
|
|
|
// TODO: locking on this container
|
|
|
|
for(const auto& item : m_state->m_RemoteSessions)
|
|
|
|
for(const auto& item : m_state->m_RemoteSessions)
|
|
|
@ -1125,7 +1125,8 @@ namespace llarp
|
|
|
|
}
|
|
|
|
}
|
|
|
|
m_state->m_SendQueue.clear();
|
|
|
|
m_state->m_SendQueue.clear();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
router->PumpLL();
|
|
|
|
UpstreamFlush(router);
|
|
|
|
|
|
|
|
router->linkManager().PumpLinks();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
bool
|
|
|
|
bool
|
|
|
|