Make sure we send servfail on error

diff --git a/pdns/distributor.hh b/pdns/distributor.hh
index 6235ec0f681c485ca702b2e71cd97f721711ab1f..cf8e56d8bfb0bed273ffb98918de4e26b0a5c8bb 100644 (file)
--- a/pdns/distributor.hh
+++ b/pdns/distributor.hh
@@ -218,7 +218,7 @@ template<class Answer, class Question, class Backend>void *MultiThreadDistributo
         us->d_overloaded=false;
       }
       
-      Answer *a;      
+      Answer *a; 
 
 #ifndef SMTPREDIR
       if(queuetimeout && q->d_dt.udiff()>queuetimeout*1000) {
@@ -235,12 +235,18 @@ template<class Answer, class Question, class Backend>void *MultiThreadDistributo
       catch(const PDNSException &e) {
         L<<Logger::Error<<"Backend error: "<<e.reason<<endl;
         delete b;
-        return 0;
+        a=q->replyPacket();
+        a->setRcode(RCode::ServFail);
+        S.inc("servfail-packets");
+        S.ringAccount("servfail-queries",q->qdomain);
       }
       catch(...) {
         L<<Logger::Error<<Logger::NTLog<<"Caught unknown exception in Distributor thread "<<(unsigned long)pthread_self()<<endl;
         delete b;
-        return 0;
+        a=q->replyPacket();
+        a->setRcode(RCode::ServFail);
+        S.inc("servfail-packets");
+        S.ringAccount("servfail-queries",q->qdomain);
       }
 
       AnswerData<Answer> AD;
@@ -270,13 +276,19 @@ template<class Answer, class Question, class Backend>int SingleThreadDistributor
     L<<Logger::Error<<"Backend error: "<<e.reason<<endl;
     delete b;
     b=new Backend;
-    return 0;
+    a=q->replyPacket();
+    a->setRcode(RCode::ServFail);
+    S.inc("servfail-packets");
+    S.ringAccount("servfail-queries",q->qdomain);
   }
   catch(...) {
     L<<Logger::Error<<Logger::NTLog<<"Caught unknown exception in Distributor thread "<<(unsigned long)pthread_self()<<endl;
     delete b;
     b=new Backend;
-    return 0;
+    a=q->replyPacket();
+    a->setRcode(RCode::ServFail);
+    S.inc("servfail-packets");
+    S.ringAccount("servfail-queries",q->qdomain);
   }
   AnswerData<Answer> AD;
   AD.A=a;