void/ZeroTierOne
2
0
Fork 0
mirror of https://github.com/zerotier/ZeroTierOne.git synced 2025-06-05 03:53:44 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

cleanup

Browse source
This commit is contained in:
Grant Limberg 2018-12-07 01:58:23 -08:00
parent 4a89729529
commit f6e9f0e2a2
1 changed files with 1 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
service/OneService.cpp
View file

@ -607,16 +607,13 @@ public:
_ports[1] = 0; _ports[1] = 0;
_ports[2] = 0; _ports[2] = 0;
_incomingPacketConcurrency = std::max((unsigned long)1,std::min((unsigned long)16,(unsigned long)std::thread::hardware_concurrency()));
char *envPool = std::getenv("INCOMING_PACKET_CONCURRENCY"); char *envPool = std::getenv("INCOMING_PACKET_CONCURRENCY");
if (envPool != NULL) { if (envPool != NULL) {
int tmp = atoi(envPool); int tmp = atoi(envPool);
if (tmp > 0) { if (tmp > 0) {
_incomingPacketConcurrency = tmp; _incomingPacketConcurrency = tmp;
} else {
_incomingPacketConcurrency = std::max((unsigned long)1,std::min((unsigned long)16,(unsigned long)std::thread::hardware_concurrency()));
} }
} else {
_incomingPacketConcurrency = std::max((unsigned long)1,std::min((unsigned long)16,(unsigned long)std::thread::hardware_concurrency()));
} }
for(long t=0;t<_incomingPacketConcurrency;++t) { for(long t=0;t<_incomingPacketConcurrency;++t) {
_incomingPacketThreads.push_back(std::thread([this]() { _incomingPacketThreads.push_back(std::thread([this]() {