Archives/lokinet
2
0
Fork 0
mirror of https://github.com/oxen-io/lokinet.git synced 2024-11-03 23:15:52 +00:00
Code Issues Projects Releases Wiki Activity

actually start disk threadpool

Browse Source
This commit is contained in:
Jeff Becker 2018-11-20 12:08:02 -05:00
parent 1380014583
commit a3bb2c7d6a
No known key found for this signature in database
GPG Key ID: F357B3B42F6F9B05
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
llarp/router.cpp
View File

@ -669,15 +669,16 @@ llarp_router::async_verify_RC(const llarp::RouterContact &rc)
job->hook = &llarp_router::on_verify_client_rc; job->hook = &llarp_router::on_verify_client_rc;
if(rpcCaller && rc.IsPublicRouter()) if(rpcCaller && rc.IsPublicRouter())
{ {
rpcCaller->VerifyRouter(rc.pubkey, [job, ctx](llarp::PubKey, bool valid) { rpcCaller->VerifyRouter(rc.pubkey, [job](llarp::PubKey pk, bool valid) {
if(valid) if(valid)
{ {
llarp::LogDebug("lokid says ", pk, " is valid");
llarp_nodedb_async_verify(job); llarp_nodedb_async_verify(job);
} }
else else
{ {
delete job; llarp::LogDebug("lokid says ", pk, " is NOT valid");
delete ctx; job->hook(job);
} }
}); });
} }
@ -710,6 +711,7 @@ llarp_router::Run()
} }
llarp_threadpool_start(tp); llarp_threadpool_start(tp);
llarp_threadpool_start(disk);
routerProfiling.Load(routerProfilesFile.c_str()); routerProfiling.Load(routerProfilesFile.c_str());