ExternalVendorCode/ZeroTierOne
1
0
Fork 0
mirror of https://github.com/zerotier/ZeroTierOne.git synced 2025-01-30 16:13:55 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

revert queue... not quite what we need

Browse Source
This commit is contained in:
Adam Ierymenko 2020-11-13 21:01:55 -05:00
parent bb62279a20
commit 57516cfbe6
1 changed files with 2 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
service/OneService.cpp
View File

@ -529,7 +529,6 @@ public:
ZT_VirtualNetworkConfig config; // memcpy() of raw config from core
std::vector<InetAddress> managedIps;
std::map< InetAddress, SharedPtr<ManagedRoute> > managedRoutes;
std::list< InetAddress > routeSyncQueue;
NetworkSettings settings;
};
std::map<uint64_t,NetworkState> _nets;
@ -918,21 +917,6 @@ public:
OSUtils::cleanDirectory((_homePath + ZT_PATH_SEPARATOR_S "peers.d").c_str(),now - 2592000000LL); // delete older than 30 days
}
// Check to see if we have to sync any managed routes, and if so do it every 100ms to
// avoid route dependency problems.
{
Mutex::Lock nl(_nets_m);
for(std::map<uint64_t,NetworkState>::iterator n(_nets.begin());n!=_nets.end();++n) {
if (!n->second.routeSyncQueue.empty()) {
std::map< InetAddress, SharedPtr<ManagedRoute> >::const_iterator mr(n->second.managedRoutes.find(n->second.routeSyncQueue.front()));
if (mr != n->second.managedRoutes.end())
mr->second->sync();
n->second.routeSyncQueue.pop_front();
dl = now + 100;
}
}
}
const unsigned long delay = (dl > now) ? (unsigned long)(dl - now) : 500;
clockShouldBe = now + (int64_t)delay;
_phy.poll(delay);
@ -2018,11 +2002,11 @@ public:
// that do not yet have routes in the system.
for(std::map< InetAddress, SharedPtr<ManagedRoute> >::iterator r(n.managedRoutes.begin());r!=n.managedRoutes.end();++r) {
if (!r->second->via())
n.routeSyncQueue.push_back(r->first);
n->second->sync();
}
for(std::map< InetAddress, SharedPtr<ManagedRoute> >::iterator r(n.managedRoutes.begin());r!=n.managedRoutes.end();++r) {
if (r->second->via())
n.routeSyncQueue.push_back(r->first);
n->second->sync();
}
}