fix shadow build

pull/13/head
Jeff Becker 6 years ago
parent 98b3bd6354
commit 6a828ea985
No known key found for this signature in database
GPG Key ID: F357B3B42F6F9B05

@ -409,7 +409,7 @@ link_directories(contrib/msc/lib)
endif() endif()
if(SHADOW) if(SHADOW)
add_shadow_plugin(shadow-plugin-${SHARED_LIB} ${EXE_SRC} ${LIB_SRC}) add_shadow_plugin(shadow-plugin-${SHARED_LIB} ${EXE_SRC} ${LIB_SRC} ${LIB_PLATFORM_SRC} ${CPP_BACKPORT_SRC})
target_link_libraries(shadow-plugin-${SHARED_LIB} ${LIBS}) target_link_libraries(shadow-plugin-${SHARED_LIB} ${LIBS})
install(TARGETS shadow-plugin-${SHARED_LIB} DESTINATION plugins) install(TARGETS shadow-plugin-${SHARED_LIB} DESTINATION plugins)
else() else()

@ -56,9 +56,14 @@ def makeBase(settings, name, id):
def makeClient(settings, name, id): def makeClient(settings, name, id):
peer = makeBase(settings, name, id) peer = makeBase(settings, name, id)
nodeconf(peer['config'], getSetting(settings, 'baseDir', 'tmp'), name) basedir = getSetting(settings, 'baseDir', 'tmp')
nodeconf(peer['config'], basedir, name)
fname = os.path.join(basedir, "test-service.ini")
peer['config']['services'] = { peer['config']['services'] = {
'test-service': fname
} }
with open(fname, 'w') as f:
f.write("[test-service]")
return peer return peer
@ -81,7 +86,8 @@ def genconf(settings, outf):
kill = etree.SubElement(root, 'kill') kill = etree.SubElement(root, 'kill')
kill.attrib['time'] = getSetting(settings, 'runFor', '600') kill.attrib['time'] = getSetting(settings, 'runFor', '600')
baseDir = getSetting(settings, 'baseDir', 'tmp') baseDir = getSetting(settings, 'baseDir',
os.path.join('/tmp', 'lokinet-shadow'))
if not os.path.exists(baseDir): if not os.path.exists(baseDir):
os.mkdir(baseDir) os.mkdir(baseDir)
@ -125,6 +131,7 @@ def genconf(settings, outf):
if __name__ == '__main__': if __name__ == '__main__':
settings = { settings = {
'baseDir': os.path.join("/tmp", "lokinet-shadow"),
'topology': os.path.join(shadowRoot, 'share', 'topology.graphml.xml'), 'topology': os.path.join(shadowRoot, 'share', 'topology.graphml.xml'),
'runFor': '{}'.format(60 * 10 * 10) 'runFor': '{}'.format(60 * 10 * 10)
} }

@ -32,8 +32,15 @@ namespace llarp
/// a condition variable that does nothing /// a condition variable that does nothing
struct NullCondition struct NullCondition
{ {
template < typename Lock_t >
void void
wait(NullLock& l) wait(Lock_t& l)
{
}
template < typename Lock_t, typename Pred >
void
wait(Lock_t& l, Pred p)
{ {
} }

@ -92,7 +92,7 @@ namespace llarp
Key_t peer; Key_t peer;
if(dht.nodes->FindClosest(K, peer)) if(dht.nodes->FindClosest(K, peer))
dht.LookupRouter(K, dht.OurKey(), txid, peer, job); dht.LookupRouter(K, dht.OurKey(), txid, peer, job);
return false; return true;
} }
FindRouterMessage::~FindRouterMessage() FindRouterMessage::~FindRouterMessage()

@ -326,11 +326,10 @@ llarp_link_session::EnterState(State st)
void void
llarp_link_session::on_intro(const void *buf, size_t sz) llarp_link_session::on_intro(const void *buf, size_t sz)
{ {
llarp::LogDebug("session onintro");
if(sz >= sizeof(workbuf)) if(sz >= sizeof(workbuf))
{ {
// too big? // too big?
llarp::LogError("intro too big"); llarp::LogError("intro too big from ", addr);
delete this; delete this;
return; return;
} }

@ -150,7 +150,10 @@ namespace llarp
while(itr != m_PendingRouters.end()) while(itr != m_PendingRouters.end())
{ {
if(itr->second.IsExpired(now)) if(itr->second.IsExpired(now))
{
llarp::LogInfo("lookup for ", itr->first, " timed out");
itr = m_PendingRouters.erase(itr); itr = m_PendingRouters.erase(itr);
}
else else
++itr; ++itr;
} }
@ -603,6 +606,8 @@ namespace llarp
void void
Endpoint::EnsureRouterIsKnown(const RouterID& router) Endpoint::EnsureRouterIsKnown(const RouterID& router)
{ {
if(router.IsZero())
return;
if(!llarp_nodedb_get_rc(m_Router->nodedb, router)) if(!llarp_nodedb_get_rc(m_Router->nodedb, router))
{ {
if(m_PendingRouters.find(router) == m_PendingRouters.end()) if(m_PendingRouters.find(router) == m_PendingRouters.end())

Loading…
Cancel
Save