From: Remi Gacogne Date: Thu, 3 Oct 2019 13:41:07 +0000 (+0200) Subject: dnsdist: Fix shadowed variables X-Git-Tag: dnsdist-1.4.0-rc4~44^2~2 X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=dd026b9cab67a776083465c124ae5cd03f8e0c15;p=pdns dnsdist: Fix shadowed variables --- diff --git a/pdns/dnsdist.hh b/pdns/dnsdist.hh index e654b9e15..81b32c378 100644 --- a/pdns/dnsdist.hh +++ b/pdns/dnsdist.hh @@ -113,8 +113,8 @@ struct DNSQuestion struct DNSResponse : DNSQuestion { - DNSResponse(const DNSName* name, uint16_t type, uint16_t class_, unsigned int consumed, const ComboAddress* lc, const ComboAddress* rem, struct dnsheader* header, size_t bufferSize, uint16_t responseLen, bool isTcp, const struct timespec* queryTime_): - DNSQuestion(name, type, class_, consumed, lc, rem, header, bufferSize, responseLen, isTcp, queryTime_) { } + DNSResponse(const DNSName* name, uint16_t type, uint16_t class_, unsigned int consumed_, const ComboAddress* lc, const ComboAddress* rem, struct dnsheader* header, size_t bufferSize, uint16_t responseLen, bool isTcp, const struct timespec* queryTime_): + DNSQuestion(name, type, class_, consumed_, lc, rem, header, bufferSize, responseLen, isTcp, queryTime_) { } DNSResponse(const DNSResponse&) = delete; DNSResponse& operator=(const DNSResponse&) = delete; DNSResponse(DNSResponse&&) = default; @@ -749,9 +749,9 @@ struct ClientState } #endif /* HAVE_EBPF */ - void updateTCPMetrics(size_t queries, uint64_t durationMs) + void updateTCPMetrics(size_t nbQueries, uint64_t durationMs) { - tcpAvgQueriesPerConnection = (99.0 * tcpAvgQueriesPerConnection / 100.0) + (queries / 100.0); + tcpAvgQueriesPerConnection = (99.0 * tcpAvgQueriesPerConnection / 100.0) + (nbQueries / 100.0); tcpAvgConnectionDuration = (99.0 * tcpAvgConnectionDuration / 100.0) + (durationMs / 100.0); } }; @@ -943,9 +943,9 @@ struct DownstreamState void setId(const boost::uuids::uuid& newId); void setWeight(int newWeight); - void updateTCPMetrics(size_t queries, uint64_t durationMs) + void updateTCPMetrics(size_t nbQueries, uint64_t durationMs) { - tcpAvgQueriesPerConnection = (99.0 * tcpAvgQueriesPerConnection / 100.0) + (queries / 100.0); + tcpAvgQueriesPerConnection = (99.0 * tcpAvgQueriesPerConnection / 100.0) + (nbQueries / 100.0); tcpAvgConnectionDuration = (99.0 * tcpAvgConnectionDuration / 100.0) + (durationMs / 100.0); } }; diff --git a/pdns/test-dnsdistpacketcache_cc.cc b/pdns/test-dnsdistpacketcache_cc.cc index 38d35dfdf..e2786e378 100644 --- a/pdns/test-dnsdistpacketcache_cc.cc +++ b/pdns/test-dnsdistpacketcache_cc.cc @@ -295,7 +295,7 @@ BOOST_AUTO_TEST_CASE(test_PacketCacheNXDomainTTL) { } } -static DNSDistPacketCache PC(500000); +static DNSDistPacketCache g_PC(500000); static void *threadMangler(void* off) { @@ -328,9 +328,9 @@ static void *threadMangler(void* off) boost::optional subnet; auto dh = reinterpret_cast(query.data()); DNSQuestion dq(&a, QType::A, QClass::IN, 0, &remote, &remote, dh, query.size(), query.size(), false, &queryTime); - PC.get(dq, a.wirelength(), 0, responseBuf, &responseBufSize, &key, subnet, dnssecOK); + g_PC.get(dq, a.wirelength(), 0, responseBuf, &responseBufSize, &key, subnet, dnssecOK); - PC.insert(key, subnet, *(getFlagsFromDNSHeader(dh)), dnssecOK, a, QType::A, QClass::IN, (const char*) response.data(), responseLen, false, 0, boost::none); + g_PC.insert(key, subnet, *(getFlagsFromDNSHeader(dh)), dnssecOK, a, QType::A, QClass::IN, (const char*) response.data(), responseLen, false, 0, boost::none); } } catch(PDNSException& e) { @@ -363,7 +363,7 @@ static void *threadReader(void* off) uint32_t key = 0; boost::optional subnet; DNSQuestion dq(&a, QType::A, QClass::IN, 0, &remote, &remote, (struct dnsheader*) query.data(), query.size(), query.size(), false, &queryTime); - bool found = PC.get(dq, a.wirelength(), 0, responseBuf, &responseBufSize, &key, subnet, dnssecOK); + bool found = g_PC.get(dq, a.wirelength(), 0, responseBuf, &responseBufSize, &key, subnet, dnssecOK); if (!found) { g_missing++; } @@ -385,15 +385,15 @@ BOOST_AUTO_TEST_CASE(test_PacketCacheThreaded) { for(int i=0; i < 4 ; ++i) pthread_join(tid[i], &res); - BOOST_CHECK_EQUAL(PC.getSize() + PC.getDeferredInserts() + PC.getInsertCollisions(), 400000); - BOOST_CHECK_SMALL(1.0*PC.getInsertCollisions(), 10000.0); + BOOST_CHECK_EQUAL(g_PC.getSize() + g_PC.getDeferredInserts() + g_PC.getInsertCollisions(), 400000); + BOOST_CHECK_SMALL(1.0*g_PC.getInsertCollisions(), 10000.0); for(int i=0; i < 4; ++i) pthread_create(&tid[i], 0, threadReader, (void*)(i*1000000UL)); for(int i=0; i < 4 ; ++i) pthread_join(tid[i], &res); - BOOST_CHECK((PC.getDeferredInserts() + PC.getDeferredLookups() + PC.getInsertCollisions()) >= g_missing); + BOOST_CHECK((g_PC.getDeferredInserts() + g_PC.getDeferredLookups() + g_PC.getInsertCollisions()) >= g_missing); } catch(PDNSException& e) { cerr<<"Had error: "<