]> git.ipfire.org Git - thirdparty/pdns.git/commitdiff
Various UeberBackend cleanups
authorFred Morcos <fred.morcos@open-xchange.com>
Sun, 29 Oct 2023 14:09:36 +0000 (15:09 +0100)
committerFred Morcos <fred.morcos@open-xchange.com>
Sun, 29 Oct 2023 14:09:36 +0000 (15:09 +0100)
pdns/ueberbackend.cc
pdns/ueberbackend.hh

index 7bcb49bd09fcf8c1ceba2b774ffbef228c360978..6543968631ae7dc310805f11342e9118f0da2d75 100644 (file)
@@ -284,9 +284,9 @@ void UeberBackend::updateZoneCache()
   vector<std::tuple<DNSName, int>> zone_indices;
   g_zoneCache.setReplacePending();
 
-  for (vector<DNSBackend*>::iterator i = backends.begin(); i != backends.end(); ++i) {
+  for (auto& backend : backends) {
     vector<DomainInfo> zones;
-    (*i)->getAllDomains(&zones, false, true);
+    backend->getAllDomains(&zones, false, true);
     for (auto& di : zones) {
       zone_indices.emplace_back(std::move(di.zone), (int)di.id); // this cast should not be necessary
     }
@@ -296,11 +296,12 @@ void UeberBackend::updateZoneCache()
 
 void UeberBackend::rediscover(string* status)
 {
-  for (vector<DNSBackend*>::iterator i = backends.begin(); i != backends.end(); ++i) {
+  for (auto i = backends.begin(); i != backends.end(); ++i) {
     string tmpstr;
     (*i)->rediscover(&tmpstr);
-    if (status)
+    if (status != nullptr) {
       *status += tmpstr + (i != backends.begin() ? "\n" : "");
+    }
   }
 
   updateZoneCache();
@@ -387,10 +388,10 @@ bool UeberBackend::getAuth(const DNSName& target, const QType& qtype, SOAData* s
     d_question.zoneId = zoneId;
 
     // Check cache
-    if (cachedOk && (d_cache_ttl || d_negcache_ttl)) {
+    if (cachedOk && (d_cache_ttl != 0 || d_negcache_ttl != 0)) {
       cstat = cacheHas(d_question, d_answers);
 
-      if (cstat == 1 && !d_answers.empty() && d_cache_ttl) {
+      if (cstat == 1 && !d_answers.empty() && d_cache_ttl != 0) {
         DLOG(g_log << Logger::Error << "has pos cache entry: " << shorter << endl);
         fillSOAData(d_answers[0], *sd);
 
@@ -403,7 +404,7 @@ bool UeberBackend::getAuth(const DNSName& target, const QType& qtype, SOAData* s
         sd->qname = shorter;
         goto found;
       }
-      else if (cstat == 0 && d_negcache_ttl) {
+      else if (cstat == 0 && d_negcache_ttl != 0) {
         DLOG(g_log << Logger::Error << "has neg cache entry: " << shorter << endl);
         continue;
       }
@@ -411,8 +412,8 @@ bool UeberBackend::getAuth(const DNSName& target, const QType& qtype, SOAData* s
 
     // Check backends
     {
-      vector<DNSBackend*>::const_iterator i = backends.begin();
-      vector<pair<size_t, SOAData>>::iterator j = bestmatch.begin();
+      auto i = backends.begin();
+      auto j = bestmatch.begin();
       for (; i != backends.end() && j != bestmatch.end(); ++i, ++j) {
 
         DLOG(g_log << Logger::Error << "backend: " << i - backends.begin() << ", qname: " << shorter << endl);
@@ -454,7 +455,8 @@ bool UeberBackend::getAuth(const DNSName& target, const QType& qtype, SOAData* s
         }
         continue;
       }
-      else if (d_cache_ttl) {
+
+      if (d_cache_ttl != 0) {
         DLOG(g_log << Logger::Error << "add pos cache entry: " << sd->qname << endl);
         d_question.qtype = QType::SOA;
         d_question.qname = sd->qname;
@@ -806,18 +808,22 @@ bool UeberBackend::deleteTSIGKey(const DNSName& name)
 bool UeberBackend::searchRecords(const string& pattern, int maxResults, vector<DNSResourceRecord>& result)
 {
   bool rc = false;
-  for (vector<DNSBackend*>::iterator i = backends.begin(); result.size() < static_cast<vector<DNSResourceRecord>::size_type>(maxResults) && i != backends.end(); ++i)
-    if ((*i)->searchRecords(pattern, maxResults - result.size(), result))
+  for (auto i = backends.begin(); result.size() < static_cast<vector<DNSResourceRecord>::size_type>(maxResults) && i != backends.end(); ++i) {
+    if ((*i)->searchRecords(pattern, maxResults - result.size(), result)) {
       rc = true;
+    }
+  }
   return rc;
 }
 
 bool UeberBackend::searchComments(const string& pattern, int maxResults, vector<Comment>& result)
 {
   bool rc = false;
-  for (vector<DNSBackend*>::iterator i = backends.begin(); result.size() < static_cast<vector<Comment>::size_type>(maxResults) && i != backends.end(); ++i)
-    if ((*i)->searchComments(pattern, maxResults - result.size(), result))
+  for (auto i = backends.begin(); result.size() < static_cast<vector<Comment>::size_type>(maxResults) && i != backends.end(); ++i) {
+    if ((*i)->searchComments(pattern, maxResults - result.size(), result)) {
       rc = true;
+    }
+  }
   return rc;
 }
 
@@ -852,8 +858,9 @@ bool UeberBackend::handle::get(DNSZoneRecord& r)
       d_hinterBackend->lookup(qtype, qname, zoneId, pkt_p);
       ++(*s_backendQueries);
     }
-    else
+    else {
       break;
+    }
 
     DLOG(g_log << "Now asking backend #" << i << endl);
   }
index 04785d1adbb945b7f7d07d2c32e51beafdb1676d..ff15a5b74d99673bbc7f08b1ec04903bde977624 100644 (file)
@@ -95,7 +95,7 @@ public:
     static AtomicCounter instances;
   };
 
-  void lookup(const QType&, const DNSName& qdomain, int zoneId, DNSPacket* pkt_p = nullptr);
+  void lookup(const QType& qtype, const DNSName& qname, int zoneId, DNSPacket* pkt_p = nullptr);
 
   /** Determines if we are authoritative for a zone, and at what level */
   bool getAuth(const DNSName& target, const QType& qtype, SOAData* sd, bool cachedOk = true);
@@ -106,8 +106,8 @@ public:
 
   void getUnfreshSlaveInfos(vector<DomainInfo>* domains);
   void getUpdatedMasters(vector<DomainInfo>& domains, std::unordered_set<DNSName>& catalogs, CatalogHashMap& catalogHashes);
-  bool createDomain(const DNSName& domain, const DomainInfo::DomainKind kind, const vector<ComboAddress>& masters, const string& account);
   bool getDomainInfo(const DNSName& domain, DomainInfo& domainInfo, bool getSerial = true);
+  bool createDomain(const DNSName& domain, DomainInfo::DomainKind kind, const vector<ComboAddress>& masters, const string& account);
 
   bool doesDNSSEC();
   bool addDomainKey(const DNSName& name, const DNSBackend::KeyData& key, int64_t& id);