community/pdns-recursor: upgrade to 4.1.4

3 files changed, 32 insertions, 2190 deletions

diff --git a/community/pdns-recursor/APKBUILD b/community/pdns-recursor/APKBUILD
index 0cb751a520..0872cc1a0c 100644
--- a/community/pdns-recursor/APKBUILD
+++ b/community/pdns-recursor/APKBUILD
@@ -1,21 +1,21 @@
 # Contributor: Olivier Mauras <olivier@mauras.ch>
 pkgname=pdns-recursor
-pkgver=4.1.3
-pkgrel=2
+pkgver=4.1.4
+pkgrel=0
 pkgdesc="PowerDNS Recursive Server"
 url="https://www.powerdns.com/"
+# s390x: missing boost-context
 arch="all !s390x"
 license="GPL-2.0-or-later"
 depends=""
 depends_dev=""
-makedepends="$depends_dev boost-dev file libressl-dev libsodium-dev lua-dev net-snmp-dev protobuf-dev"
+makedepends="$depends_dev boost-dev libressl-dev libsodium-dev lua-dev net-snmp-dev protobuf-dev"
 install="$pkgname.pre-install"
 subpackages="$pkgname-doc $pkgname-openrc"
 pkgusers="recursor"
 pkggroups="recursor"
 source="https://downloads.powerdns.com/releases/$pkgname-$pkgver.tar.bz2
 	libressl-2.7.patch
-	boost-1.67.patch
 	pdns-recursor.initd
 	recursor.conf
 	"
@@ -62,8 +62,7 @@ package() {
 		"$pkgdir"/etc/pdns/recursor.conf
 }
 
-sha512sums="5ea7e027131143b3ca45ca4a97316f52207a55cf5498a136e44cf5ee78bee00efecf3cd7c9c46261002cbd6e4ea0cd2af62c456b71fd2366729242950b7c060d  pdns-recursor-4.1.3.tar.bz2
-2846854b74bcc1149e18aa5ff17d1c0548790a5eaf87a7194b89a1063c6783708bfa109e8edf9c2b430fbd90445bee7f80137601babab8766be106bcad700cf3  libressl-2.7.patch
-ab36fd2b004f923a073e0acf4e2c70c082020b6eebaf024fabd41ab7552e3d1ef4d8eb6fdd3325ec6f92c64807a60e270956e4f871e474afd7bdc12a247a35c3  boost-1.67.patch
+sha512sums="1904685dfdcd69d4b85c4c70559d51cc8ef288551ffd8f93a96108c3aca4e46ec3950f93840e4bd39da00c63129033b5a541beb68d1e924d477b5b0abbf1d00c  pdns-recursor-4.1.4.tar.bz2
+d45111007decca36f9380e7c7b6b7fe3699b59eead3b42263378a7202158b7fd4e50846ef3f59cc309859a08699abcaa8629c06f3a78fecd2ee71a6e05c49531  libressl-2.7.patch
 f23cb30d943e0b0aea09371dc57aa43e55b8f91062a3caa3fac17e3565a8e36dfd304f45eba588f625ca2337cd2ade450ea5ae1776872c006204cdaf912f6651  pdns-recursor.initd
 954df537693a202fc195e751011bbfaa605b3f3df42ac386fa82eb809b73c2b987f5e418b5c96bb3b0669497426ce0daa39a719844701e06990b82843a4cf0d4  recursor.conf"
diff --git a/community/pdns-recursor/boost-1.67.patch b/community/pdns-recursor/boost-1.67.patch
deleted file mode 100644
index 3ad1e35f8d..0000000000
--- a/community/pdns-recursor/boost-1.67.patch
+++ /dev/null
@@ -1,2175 +0,0 @@
-diff --git a/arguments.cc b/arguments.cc
-index 935c9ea..5e62d41 100644
---- a/arguments.cc
-+++ b/arguments.cc
-@@ -443,7 +443,7 @@ bool ArgvMap::file(const char *fname, bool lax, bool included)
-     set("include-dir","Directory to include configuration files from");
- 
-   if(!parseFile(fname, "", lax)) {
--    L << Logger::Warning << "Unable to open " << fname << std::endl;
-+    g_log << Logger::Warning << "Unable to open " << fname << std::endl;
-     return false;
-   }
- 
-@@ -453,7 +453,7 @@ bool ArgvMap::file(const char *fname, bool lax, bool included)
-     gatherIncludes(extraConfigs); 
-     for(const std::string& fn :  extraConfigs) {
-       if (!file(fn.c_str(), lax, true)) {
--        L << Logger::Error << fn << " could not be parsed" << std::endl;
-+        g_log << Logger::Error << fn << " could not be parsed" << std::endl;
-         throw ArgException(fn + " could not be parsed");
-       }
-     }
-@@ -471,18 +471,18 @@ void ArgvMap::gatherIncludes(std::vector<std::string> &extraConfigs) {
- 
-     // stat
-     if (stat(params["include-dir"].c_str(), &st)) {
--       L << Logger::Error << params["include-dir"] << " does not exist!" << std::endl;
-+       g_log << Logger::Error << params["include-dir"] << " does not exist!" << std::endl;
-        throw ArgException(params["include-dir"] + " does not exist!");
-     }
- 
-     // wonder if it's accessible directory
-     if (!S_ISDIR(st.st_mode)) {
--       L << Logger::Error << params["include-dir"] << " is not a directory" << std::endl;
-+       g_log << Logger::Error << params["include-dir"] << " is not a directory" << std::endl;
-        throw ArgException(params["include-dir"] + " is not a directory");
-     }
- 
-     if (!(dir = opendir(params["include-dir"].c_str()))) {
--       L << Logger::Error << params["include-dir"] << " is not accessible" << std::endl;
-+       g_log << Logger::Error << params["include-dir"] << " is not accessible" << std::endl;
-        throw ArgException(params["include-dir"] + " is not accessible");
-     }
- 
-@@ -494,7 +494,7 @@ void ArgvMap::gatherIncludes(std::vector<std::string> &extraConfigs) {
-         namebuf << params["include-dir"].c_str() << "/" << ent->d_name; // FIXME: Use some path separator
-         // ensure it's readable file
-         if (stat(namebuf.str().c_str(), &st) || !S_ISREG(st.st_mode)) {
--          L << Logger::Error << namebuf.str() << " is not a file" << std::endl;
-+          g_log << Logger::Error << namebuf.str() << " is not a file" << std::endl;
-           closedir(dir);
-           throw ArgException(namebuf.str() + " does not exist!");
-         }
-diff --git a/dns.hh b/dns.hh
-index 88a658c..bce6202 100644
---- a/dns.hh
-+++ b/dns.hh
-@@ -225,7 +225,7 @@ inline uint16_t * getFlagsFromDNSHeader(struct dnsheader * dh)
- #define FLAGS_CD_OFFSET (12)
- #endif
- 
--#define L theL()
-+#define g_log theL()
- extern time_t s_starttime;
- 
- uint32_t hashQuestion(const char* packet, uint16_t len, uint32_t init);
-diff --git a/gss_context.cc b/gss_context.cc
-index 55c54be..8ef1061 100644
---- a/gss_context.cc
-+++ b/gss_context.cc
-@@ -456,17 +456,17 @@ bool gss_add_signature(const DNSName& context, const std::string& message, std::
-   string tmp_mac;
-   GssContext gssctx(context);
-   if (!gssctx.valid()) {
--    L<<Logger::Error<<"GSS context '"<<context<<"' is not valid"<<endl;
-+    g_log<<Logger::Error<<"GSS context '"<<context<<"' is not valid"<<endl;
-     for(const string& error :  gssctx.getErrorStrings()) {
--       L<<Logger::Error<<"GSS error: "<<error<<endl;;
-+       g_log<<Logger::Error<<"GSS error: "<<error<<endl;;
-     }
-     return false;
-   }
- 
-   if (!gssctx.sign(message, tmp_mac)) {
--    L<<Logger::Error<<"Could not sign message using GSS context '"<<context<<"'"<<endl;
-+    g_log<<Logger::Error<<"Could not sign message using GSS context '"<<context<<"'"<<endl;
-     for(const string& error :  gssctx.getErrorStrings()) {
--       L<<Logger::Error<<"GSS error: "<<error<<endl;;
-+       g_log<<Logger::Error<<"GSS error: "<<error<<endl;;
-     }
-     return false;
-   }
-@@ -477,17 +477,17 @@ bool gss_add_signature(const DNSName& context, const std::string& message, std::
- bool gss_verify_signature(const DNSName& context, const std::string& message, const std::string& mac) {
-   GssContext gssctx(context);
-   if (!gssctx.valid()) {
--    L<<Logger::Error<<"GSS context '"<<context<<"' is not valid"<<endl;
-+    g_log<<Logger::Error<<"GSS context '"<<context<<"' is not valid"<<endl;
-     for(const string& error :  gssctx.getErrorStrings()) {
--       L<<Logger::Error<<"GSS error: "<<error<<endl;;
-+       g_log<<Logger::Error<<"GSS error: "<<error<<endl;;
-     }
-     return false;
-   }
- 
-   if (!gssctx.verify(message, mac)) {
--    L<<Logger::Error<<"Could not verify message using GSS context '"<<context<<"'"<<endl;
-+    g_log<<Logger::Error<<"Could not verify message using GSS context '"<<context<<"'"<<endl;
-     for(const string& error :  gssctx.getErrorStrings()) {
--       L<<Logger::Error<<"GSS error: "<<error<<endl;;
-+       g_log<<Logger::Error<<"GSS error: "<<error<<endl;;
-     }
-     return false;
-   }
-diff --git a/logger.hh b/logger.hh
-index 989c921..7d955ea 100644
---- a/logger.hh
-+++ b/logger.hh
-@@ -70,9 +70,9 @@ public:
-   void resetFlags(){flags=0;open();} //!< zero the flags
-   /** Use this to stream to your log, like this:
-       \code
--      L<<"This is an informational message"<<endl; // logged at default loglevel (Info)
--      L<<Logger::Warning<<"Out of diskspace"<<endl; // Logged as a warning 
--      L<<"This is an informational message"<<endl; // logged AGAIN at default loglevel (Info)
-+      g_log<<"This is an informational message"<<endl; // logged at default loglevel (Info)
-+      g_log<<Logger::Warning<<"Out of diskspace"<<endl; // Logged as a warning 
-+      g_log<<"This is an informational message"<<endl; // logged AGAIN at default loglevel (Info)
-       \endcode
-   */
-   Logger& operator<<(const char *s);
-diff --git a/lua-recursor4.hh b/lua-recursor4.hh
-index d36fd7c..4c12022 100644
---- a/lua-recursor4.hh
-+++ b/lua-recursor4.hh
-@@ -43,9 +43,9 @@ unsigned int getRecursorThreadId();
- class LuaContext;
- 
- #if defined(HAVE_LUA)
--#undef L
-+#undef g_log
- #include "ext/luawrapper/include/LuaContext.hpp"
--#define L theL()
-+#define g_log theL()
- #endif
- 
- // pdns_ffi_param_t is a lightuserdata
-diff --git a/lwres.cc b/lwres.cc
-index 270f52c..30f0650 100644
---- a/lwres.cc
-+++ b/lwres.cc
-@@ -236,7 +236,7 @@ int asyncresolve(const ComboAddress& ip, const DNSName& domain, int type, bool d
- 
-     if(domain != mdp.d_qname) { 
-       if(!mdp.d_qname.empty() && domain.toString().find((char)0) == string::npos /* ugly */) {// embedded nulls are too noisy, plus empty domains are too
--        L<<Logger::Notice<<"Packet purporting to come from remote server "<<ip.toString()<<" contained wrong answer: '" << domain << "' != '" << mdp.d_qname << "'" << endl;
-+        g_log<<Logger::Notice<<"Packet purporting to come from remote server "<<ip.toString()<<" contained wrong answer: '" << domain << "' != '" << mdp.d_qname << "'" << endl;
-       }
-       // unexpected count has already been done @ pdns_recursor.cc
-       goto out;
-@@ -276,7 +276,7 @@ int asyncresolve(const ComboAddress& ip, const DNSName& domain, int type, bool d
-   }
-   catch(std::exception &mde) {
-     if(::arg().mustDo("log-common-errors"))
--      L<<Logger::Notice<<"Unable to parse packet from remote server "<<ip.toString()<<": "<<mde.what()<<endl;
-+      g_log<<Logger::Notice<<"Unable to parse packet from remote server "<<ip.toString()<<": "<<mde.what()<<endl;
-     lwr->d_rcode = RCode::FormErr;
-     g_stats.serverParseError++;
- #ifdef HAVE_PROTOBUF
-@@ -287,7 +287,7 @@ int asyncresolve(const ComboAddress& ip, const DNSName& domain, int type, bool d
-     return 1; // success - oddly enough
-   }
-   catch(...) {
--    L<<Logger::Notice<<"Unknown error parsing packet from remote server"<<endl;
-+    g_log<<Logger::Notice<<"Unknown error parsing packet from remote server"<<endl;
-   }
-   
-   g_stats.serverParseError++; 
-diff --git a/pdns_recursor.cc b/pdns_recursor.cc
-index 6175af2..32c0814 100644
---- a/pdns_recursor.cc
-+++ b/pdns_recursor.cc
-@@ -375,12 +375,12 @@ static void setSocketBuffer(int fd, int optname, uint32_t size)
-   socklen_t len=sizeof(psize);
- 
-   if(!getsockopt(fd, SOL_SOCKET, optname, (char*)&psize, &len) && psize > size) {
--    L<<Logger::Error<<"Not decreasing socket buffer size from "<<psize<<" to "<<size<<endl;
-+    g_log<<Logger::Error<<"Not decreasing socket buffer size from "<<psize<<" to "<<size<<endl;
-     return;
-   }
- 
-   if (setsockopt(fd, SOL_SOCKET, optname, (char*)&size, sizeof(size)) < 0 )
--    L<<Logger::Error<<"Unable to raise socket buffer size to "<<size<<": "<<strerror(errno)<<endl;
-+    g_log<<Logger::Error<<"Unable to raise socket buffer size to "<<size<<": "<<strerror(errno)<<endl;
- }
- 
- 
-@@ -423,7 +423,7 @@ public:
-         closesocket(*fd);
-       }
-       catch(const PDNSException& e) {
--        L<<Logger::Error<<"Error closing UDP socket after connect() failed: "<<e.reason<<endl;
-+        g_log<<Logger::Error<<"Error closing UDP socket after connect() failed: "<<e.reason<<endl;
-       }
- 
-       if(err==ENETUNREACH) // Seth "My Interfaces Are Like A Yo Yo" Arnold special
-@@ -461,7 +461,7 @@ public:
-       closesocket(*i);
-     }
-     catch(const PDNSException& e) {
--      L<<Logger::Error<<"Error closing returned UDP socket: "<<e.reason<<endl;
-+      g_log<<Logger::Error<<"Error closing returned UDP socket: "<<e.reason<<endl;
-     }
- 
-     d_socks.erase(i++);
-@@ -577,7 +577,7 @@ int arecvfrom(char *data, size_t len, int flags, const ComboAddress& fromaddr, s
-     *d_len=packet.size();
-     memcpy(data,packet.c_str(),min(len,*d_len));
-     if(*nearMissLimit && pident.nearMisses > *nearMissLimit) {
--      L<<Logger::Error<<"Too many ("<<pident.nearMisses<<" > "<<*nearMissLimit<<") bogus answers for '"<<domain<<"' from "<<fromaddr.toString()<<", assuming spoof attempt."<<endl;
-+      g_log<<Logger::Error<<"Too many ("<<pident.nearMisses<<" > "<<*nearMissLimit<<") bogus answers for '"<<domain<<"' from "<<fromaddr.toString()<<", assuming spoof attempt."<<endl;
-       g_stats.spoofCount++;
-       return -1;
-     }
-@@ -597,7 +597,7 @@ static void writePid(void)
-   if(of)
-     of<< Utility::getpid() <<endl;
-   else
--    L<<Logger::Error<<"Writing pid for "<<Utility::getpid()<<" to "<<s_pidfname<<" failed: "<<strerror(errno)<<endl;
-+    g_log<<Logger::Error<<"Writing pid for "<<Utility::getpid()<<" to "<<s_pidfname<<" failed: "<<strerror(errno)<<endl;
- }
- 
- TCPConnection::TCPConnection(int fd, const ComboAddress& addr) : d_remote(addr), d_fd(fd)
-@@ -610,10 +610,10 @@ TCPConnection::~TCPConnection()
- {
-   try {
-     if(closesocket(d_fd) < 0)
--      L<<Logger::Error<<"Error closing socket for TCPConnection"<<endl;
-+      g_log<<Logger::Error<<"Error closing socket for TCPConnection"<<endl;
-   }
-   catch(const PDNSException& e) {
--    L<<Logger::Error<<"Error closing TCPConnection socket: "<<e.reason<<endl;
-+    g_log<<Logger::Error<<"Error closing TCPConnection socket: "<<e.reason<<endl;
-   }
- 
-   if(t_tcpClientCounts->count(d_remote) && !(*t_tcpClientCounts)[d_remote]--)
-@@ -866,12 +866,12 @@ static void startDoResolve(void *p)
- 
- 
-     if(!g_quiet || tracedQuery) {
--      L<<Logger::Warning<<t_id<<" ["<<MT->getTid()<<"/"<<MT->numProcesses()<<"] " << (dc->d_tcp ? "TCP " : "") << "question for '"<<dc->d_mdp.d_qname<<"|"
-+      g_log<<Logger::Warning<<t_id<<" ["<<MT->getTid()<<"/"<<MT->numProcesses()<<"] " << (dc->d_tcp ? "TCP " : "") << "question for '"<<dc->d_mdp.d_qname<<"|"
-        <<DNSRecordContent::NumberToType(dc->d_mdp.d_qtype)<<"' from "<<dc->getRemote();
-       if(!dc->d_ednssubnet.source.empty()) {
--        L<<" (ecs "<<dc->d_ednssubnet.source.toString()<<")";
-+        g_log<<" (ecs "<<dc->d_ednssubnet.source.toString()<<")";
-       }
--      L<<endl;
-+      g_log<<endl;
-     }
- 
-     sr.setId(MT->getTid());
-@@ -934,7 +934,7 @@ static void startDoResolve(void *p)
-       }
-       catch(ImmediateServFailException &e) {
-         if(g_logCommonErrors)
--          L<<Logger::Notice<<"Sending SERVFAIL to "<<dc->getRemote()<<" during resolve of '"<<dc->d_mdp.d_qname<<"' because: "<<e.reason<<endl;
-+          g_log<<Logger::Notice<<"Sending SERVFAIL to "<<dc->getRemote()<<" during resolve of '"<<dc->d_mdp.d_qname<<"' because: "<<e.reason<<endl;
-         res = RCode::ServFail;
-       }
- 
-@@ -1056,7 +1056,7 @@ static void startDoResolve(void *p)
-         boost::split(lines, trace, boost::is_any_of("\n"));
-         for(const string& line : lines) {
-           if(!line.empty())
--            L<<Logger::Warning<< line << endl;
-+            g_log<<Logger::Warning<< line << endl;
-         }
-       }
-     }
-@@ -1073,14 +1073,14 @@ static void startDoResolve(void *p)
-       if(!shouldNotValidate && sr.isDNSSECValidationRequested()) {
-         try {
-           if(sr.doLog()) {
--            L<<Logger::Warning<<"Starting validation of answer to "<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<" for "<<dc->d_remote.toStringWithPort()<<endl;
-+            g_log<<Logger::Warning<<"Starting validation of answer to "<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<" for "<<dc->d_remote.toStringWithPort()<<endl;
-           }
- 
-           auto state = sr.getValidationState();
- 
-           if(state == Secure) {
-             if(sr.doLog()) {
--              L<<Logger::Warning<<"Answer to "<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<" for "<<dc->d_remote.toStringWithPort()<<" validates correctly"<<endl;
-+              g_log<<Logger::Warning<<"Answer to "<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<" for "<<dc->d_remote.toStringWithPort()<<" validates correctly"<<endl;
-             }
-             
-             // Is the query source interested in the value of the ad-bit?
-@@ -1089,34 +1089,34 @@ static void startDoResolve(void *p)
-           }
-           else if(state == Insecure) {
-             if(sr.doLog()) {
--              L<<Logger::Warning<<"Answer to "<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<" for "<<dc->d_remote.toStringWithPort()<<" validates as Insecure"<<endl;
-+              g_log<<Logger::Warning<<"Answer to "<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<" for "<<dc->d_remote.toStringWithPort()<<" validates as Insecure"<<endl;
-             }
-             
-             pw.getHeader()->ad=0;
-           }
-           else if(state == Bogus) {
-             if(g_dnssecLogBogus || sr.doLog() || g_dnssecmode == DNSSECMode::ValidateForLog) {
--              L<<Logger::Warning<<"Answer to "<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<" for "<<dc->d_remote.toStringWithPort()<<" validates as Bogus"<<endl;
-+              g_log<<Logger::Warning<<"Answer to "<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<" for "<<dc->d_remote.toStringWithPort()<<" validates as Bogus"<<endl;
-             }
-             
-             // Does the query or validation mode sending out a SERVFAIL on validation errors?
-             if(!pw.getHeader()->cd && (g_dnssecmode == DNSSECMode::ValidateAll || dc->d_mdp.d_header.ad || DNSSECOK)) {
-               if(sr.doLog()) {
--                L<<Logger::Warning<<"Sending out SERVFAIL for "<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<" because recursor or query demands it for Bogus results"<<endl;
-+                g_log<<Logger::Warning<<"Sending out SERVFAIL for "<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<" because recursor or query demands it for Bogus results"<<endl;
-               }
-               
-               pw.getHeader()->rcode=RCode::ServFail;
-               goto sendit;
-             } else {
-               if(sr.doLog()) {
--                L<<Logger::Warning<<"Not sending out SERVFAIL for "<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<" Bogus validation since neither config nor query demands this"<<endl;
-+                g_log<<Logger::Warning<<"Not sending out SERVFAIL for "<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<" Bogus validation since neither config nor query demands this"<<endl;
-               }
-             }
-           }
-         }
-         catch(ImmediateServFailException &e) {
-           if(g_logCommonErrors)
--            L<<Logger::Notice<<"Sending SERVFAIL to "<<dc->getRemote()<<" during validation of '"<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<"' because: "<<e.reason<<endl;
-+            g_log<<Logger::Notice<<"Sending SERVFAIL to "<<dc->getRemote()<<" during validation of '"<<dc->d_mdp.d_qname<<"|"<<QType(dc->d_mdp.d_qtype).getName()<<"' because: "<<e.reason<<endl;
-           pw.getHeader()->rcode=RCode::ServFail;
-           goto sendit;
-         }
-@@ -1203,7 +1203,7 @@ static void startDoResolve(void *p)
- 	addCMsgSrcAddr(&msgh, cbuf, &dc->d_local, 0);
-       }
-       if(sendmsg(dc->d_socket, &msgh, 0) < 0 && g_logCommonErrors) 
--        L<<Logger::Warning<<"Sending UDP reply to client "<<dc->d_remote.toStringWithPort()<<" failed with: "<<strerror(errno)<<endl;
-+        g_log<<Logger::Warning<<"Sending UDP reply to client "<<dc->d_remote.toStringWithPort()<<" failed with: "<<strerror(errno)<<endl;
- 
-       if(!SyncRes::s_nopacketcache && !variableAnswer && !sr.wasVariable() ) {
-         t_packetCache->insertResponsePacket(dc->d_tag, dc->d_qhash, dc->d_mdp.d_qname, dc->d_mdp.d_qtype, dc->d_mdp.d_qclass,
-@@ -1229,11 +1229,11 @@ static void startDoResolve(void *p)
-       bool hadError=true;
- 
-       if(wret == 0)
--        L<<Logger::Error<<"EOF writing TCP answer to "<<dc->getRemote()<<endl;
-+        g_log<<Logger::Error<<"EOF writing TCP answer to "<<dc->getRemote()<<endl;
-       else if(wret < 0 )
--        L<<Logger::Error<<"Error writing TCP answer to "<<dc->getRemote()<<": "<< strerror(errno) <<endl;
-+        g_log<<Logger::Error<<"Error writing TCP answer to "<<dc->getRemote()<<": "<< strerror(errno) <<endl;
-       else if((unsigned int)wret != 2 + packet.size())
--        L<<Logger::Error<<"Oops, partial answer sent to "<<dc->getRemote()<<" for "<<dc->d_mdp.d_qname<<" (size="<< (2 + packet.size()) <<", sent "<<wret<<")"<<endl;
-+        g_log<<Logger::Error<<"Oops, partial answer sent to "<<dc->getRemote()<<" for "<<dc->d_mdp.d_qname<<" (size="<< (2 + packet.size()) <<", sent "<<wret<<")"<<endl;
-       else
-         hadError=false;
- 
-@@ -1258,16 +1258,16 @@ static void startDoResolve(void *p)
-     }
-     float spent=makeFloat(sr.getNow()-dc->d_now);
-     if(!g_quiet) {
--      L<<Logger::Error<<t_id<<" ["<<MT->getTid()<<"/"<<MT->numProcesses()<<"] answer to "<<(dc->d_mdp.d_header.rd?"":"non-rd ")<<"question '"<<dc->d_mdp.d_qname<<"|"<<DNSRecordContent::NumberToType(dc->d_mdp.d_qtype);
--      L<<"': "<<ntohs(pw.getHeader()->ancount)<<" answers, "<<ntohs(pw.getHeader()->arcount)<<" additional, took "<<sr.d_outqueries<<" packets, "<<
-+      g_log<<Logger::Error<<t_id<<" ["<<MT->getTid()<<"/"<<MT->numProcesses()<<"] answer to "<<(dc->d_mdp.d_header.rd?"":"non-rd ")<<"question '"<<dc->d_mdp.d_qname<<"|"<<DNSRecordContent::NumberToType(dc->d_mdp.d_qtype);
-+      g_log<<"': "<<ntohs(pw.getHeader()->ancount)<<" answers, "<<ntohs(pw.getHeader()->arcount)<<" additional, took "<<sr.d_outqueries<<" packets, "<<
- 	sr.d_totUsec/1000.0<<" netw ms, "<< spent*1000.0<<" tot ms, "<<
- 	sr.d_throttledqueries<<" throttled, "<<sr.d_timeouts<<" timeouts, "<<sr.d_tcpoutqueries<<" tcp connections, rcode="<< res;
- 
-       if(!shouldNotValidate && sr.isDNSSECValidationRequested()) {
--	L<< ", dnssec="<<vStates[sr.getValidationState()];
-+	g_log<< ", dnssec="<<vStates[sr.getValidationState()];
-       }
- 	
--      L<<endl;
-+      g_log<<endl;
- 
-     }
- 
-@@ -1320,28 +1320,28 @@ static void startDoResolve(void *p)
-     dc=0;
-   }
-   catch(PDNSException &ae) {
--    L<<Logger::Error<<"startDoResolve problem "<<makeLoginfo(dc)<<": "<<ae.reason<<endl;
-+    g_log<<Logger::Error<<"startDoResolve problem "<<makeLoginfo(dc)<<": "<<ae.reason<<endl;
-     delete dc;
-   }
-   catch(MOADNSException& e) {
--    L<<Logger::Error<<"DNS parser error "<<makeLoginfo(dc) <<": "<<dc->d_mdp.d_qname<<", "<<e.what()<<endl;
-+    g_log<<Logger::Error<<"DNS parser error "<<makeLoginfo(dc) <<": "<<dc->d_mdp.d_qname<<", "<<e.what()<<endl;
-     delete dc;
-   }
-   catch(std::exception& e) {
--    L<<Logger::Error<<"STL error "<< makeLoginfo(dc)<<": "<<e.what();
-+    g_log<<Logger::Error<<"STL error "<< makeLoginfo(dc)<<": "<<e.what();
- 
-     // Luawrapper nests the exception from Lua, so we unnest it here
-     try {
-         std::rethrow_if_nested(e);
-     } catch(const std::exception& ne) {
--        L<<". Extra info: "<<ne.what();
-+        g_log<<". Extra info: "<<ne.what();
-     } catch(...) {}
- 
--    L<<endl;
-+    g_log<<endl;
-     delete dc;
-   }
-   catch(...) {
--    L<<Logger::Error<<"Any other exception in a resolver context "<< makeLoginfo(dc) <<endl;
-+    g_log<<Logger::Error<<"Any other exception in a resolver context "<< makeLoginfo(dc) <<endl;
-   }
- 
-   g_stats.maxMThreadStackUsage = max(MT->getMaxStackUsage(), g_stats.maxMThreadStackUsage);
-@@ -1449,7 +1449,7 @@ static void handleRunningTCPQuestion(int fd, FDMultiplexer::funcparam_t& var)
-     }
-     if(!bytes || bytes < 0) {
-       if(g_logCommonErrors)
--        L<<Logger::Error<<"TCP client "<< conn->d_remote.toString() <<" disconnected after first byte"<<endl;
-+        g_log<<Logger::Error<<"TCP client "<< conn->d_remote.toString() <<" disconnected after first byte"<<endl;
-       t_fdm->removeReadFD(fd);
-       return;
-     }
-@@ -1457,7 +1457,7 @@ static void handleRunningTCPQuestion(int fd, FDMultiplexer::funcparam_t& var)
-   else if(conn->state==TCPConnection::GETQUESTION) {
-     ssize_t bytes=recv(conn->getFD(), conn->data + conn->bytesread, conn->qlen - conn->bytesread, 0);
-     if(!bytes || bytes < 0 || bytes > std::numeric_limits<std::uint16_t>::max()) {
--      L<<Logger::Error<<"TCP client "<< conn->d_remote.toString() <<" disconnected while reading question body"<<endl;
-+      g_log<<Logger::Error<<"TCP client "<< conn->d_remote.toString() <<" disconnected while reading question body"<<endl;
-       t_fdm->removeReadFD(fd);
-       return;
-     }
-@@ -1472,7 +1472,7 @@ static void handleRunningTCPQuestion(int fd, FDMultiplexer::funcparam_t& var)
-       catch(MOADNSException &mde) {
-         g_stats.clientParseError++;
-         if(g_logCommonErrors)
--          L<<Logger::Error<<"Unable to parse packet from TCP client "<< conn->d_remote.toString() <<endl;
-+          g_log<<Logger::Error<<"Unable to parse packet from TCP client "<< conn->d_remote.toString() <<endl;
-         return;
-       }
-       dc->d_tcpConnection = conn; // carry the torch
-@@ -1516,14 +1516,14 @@ static void handleRunningTCPQuestion(int fd, FDMultiplexer::funcparam_t& var)
-             }
-             catch(const std::exception& e)  {
-               if(g_logCommonErrors)
--                L<<Logger::Warning<<"Error parsing a query packet qname='"<<qname<<"' for tag determination, setting tag=0: "<<e.what()<<endl;
-+                g_log<<Logger::Warning<<"Error parsing a query packet qname='"<<qname<<"' for tag determination, setting tag=0: "<<e.what()<<endl;
-             }
-           }
-         }
-         catch(const std::exception& e)
-         {
-           if(g_logCommonErrors)
--            L<<Logger::Warning<<"Error parsing a query packet for tag determination, setting tag=0: "<<e.what()<<endl;
-+            g_log<<Logger::Warning<<"Error parsing a query packet for tag determination, setting tag=0: "<<e.what()<<endl;
-         }
-       }
- #ifdef HAVE_PROTOBUF
-@@ -1543,20 +1543,20 @@ static void handleRunningTCPQuestion(int fd, FDMultiplexer::funcparam_t& var)
-         }
-         catch(std::exception& e) {
-           if(g_logCommonErrors)
--            L<<Logger::Warning<<"Error parsing a TCP query packet for edns subnet: "<<e.what()<<endl;
-+            g_log<<Logger::Warning<<"Error parsing a TCP query packet for edns subnet: "<<e.what()<<endl;
-         }
-       }
- #endif
-       if(dc->d_mdp.d_header.qr) {
-         delete dc;
-         g_stats.ignoredCount++;
--        L<<Logger::Error<<"Ignoring answer from TCP client "<< conn->d_remote.toString() <<" on server socket!"<<endl;
-+        g_log<<Logger::Error<<"Ignoring answer from TCP client "<< conn->d_remote.toString() <<" on server socket!"<<endl;
-         return;
-       }
-       if(dc->d_mdp.d_header.opcode) {
-         delete dc;
-         g_stats.ignoredCount++;
--        L<<Logger::Error<<"Ignoring non-query opcode from TCP client "<< conn->d_remote.toString() <<" on server socket!"<<endl;
-+        g_log<<Logger::Error<<"Ignoring non-query opcode from TCP client "<< conn->d_remote.toString() <<" on server socket!"<<endl;
-         return;
-       }
-       else {
-@@ -1582,7 +1582,7 @@ static void handleNewTCPQuestion(int fd, FDMultiplexer::funcparam_t& )
-         closesocket(newsock);
-       }
-       catch(const PDNSException& e) {
--        L<<Logger::Error<<"Error closing TCP socket after an over capacity drop: "<<e.reason<<endl;
-+        g_log<<Logger::Error<<"Error closing TCP socket after an over capacity drop: "<<e.reason<<endl;
-       }
-       return;
-     }
-@@ -1591,14 +1591,14 @@ static void handleNewTCPQuestion(int fd, FDMultiplexer::funcparam_t& )
-       t_remotes->push_back(addr);
-     if(t_allowFrom && !t_allowFrom->match(&addr)) {
-       if(!g_quiet)
--        L<<Logger::Error<<"["<<MT->getTid()<<"] dropping TCP query from "<<addr.toString()<<", address not matched by allow-from"<<endl;
-+        g_log<<Logger::Error<<"["<<MT->getTid()<<"] dropping TCP query from "<<addr.toString()<<", address not matched by allow-from"<<endl;
- 
-       g_stats.unauthorizedTCP++;
-       try {
-         closesocket(newsock);
-       }
-       catch(const PDNSException& e) {
--        L<<Logger::Error<<"Error closing TCP socket after an ACL drop: "<<e.reason<<endl;
-+        g_log<<Logger::Error<<"Error closing TCP socket after an ACL drop: "<<e.reason<<endl;
-       }
-       return;
-     }
-@@ -1608,7 +1608,7 @@ static void handleNewTCPQuestion(int fd, FDMultiplexer::funcparam_t& )
-         closesocket(newsock); // don't call TCPConnection::closeAndCleanup here - did not enter it in the counts yet!
-       }
-       catch(const PDNSException& e) {
--        L<<Logger::Error<<"Error closing TCP socket after an overflow drop: "<<e.reason<<endl;
-+        g_log<<Logger::Error<<"Error closing TCP socket after an overflow drop: "<<e.reason<<endl;
-       }
-       return;
-     }
-@@ -1700,14 +1700,14 @@ static string* doProcessUDPQuestion(const std::string& question, const ComboAddr
-           }
-           catch(const std::exception& e)  {
-             if(g_logCommonErrors)
--              L<<Logger::Warning<<"Error parsing a query packet qname='"<<qname<<"' for tag determination, setting tag=0: "<<e.what()<<endl;
-+              g_log<<Logger::Warning<<"Error parsing a query packet qname='"<<qname<<"' for tag determination, setting tag=0: "<<e.what()<<endl;
-           }
-         }
-       }
-       catch(const std::exception& e)
-       {
-         if(g_logCommonErrors)
--          L<<Logger::Warning<<"Error parsing a query packet for tag determination, setting tag=0: "<<e.what()<<endl;
-+          g_log<<Logger::Warning<<"Error parsing a query packet for tag determination, setting tag=0: "<<e.what()<<endl;
-       }
-     }
- 
-@@ -1745,7 +1745,7 @@ static string* doProcessUDPQuestion(const std::string& question, const ComboAddr
-       }
- #endif /* HAVE_PROTOBUF */
-       if(!g_quiet)
--        L<<Logger::Notice<<t_id<< " question answered from packet cache tag="<<ctag<<" from "<<fromaddr.toString()<<endl;
-+        g_log<<Logger::Notice<<t_id<< " question answered from packet cache tag="<<ctag<<" from "<<fromaddr.toString()<<endl;
- 
-       g_stats.packetCacheHits++;
-       SyncRes::s_queries++;
-@@ -1760,7 +1760,7 @@ static string* doProcessUDPQuestion(const std::string& question, const ComboAddr
- 	addCMsgSrcAddr(&msgh, cbuf, &destaddr, 0);
-       }
-       if(sendmsg(fd, &msgh, 0) < 0 && g_logCommonErrors)
--        L<<Logger::Warning<<"Sending UDP reply to client "<<fromaddr.toStringWithPort()<<" failed with: "<<strerror(errno)<<endl;
-+        g_log<<Logger::Warning<<"Sending UDP reply to client "<<fromaddr.toStringWithPort()<<" failed with: "<<strerror(errno)<<endl;
- 
-       if(response.length() >= sizeof(struct dnsheader)) {
-         struct dnsheader tmpdh;
-@@ -1773,14 +1773,14 @@ static string* doProcessUDPQuestion(const std::string& question, const ComboAddr
-     }
-   }
-   catch(std::exception& e) {
--    L<<Logger::Error<<"Error processing or aging answer packet: "<<e.what()<<endl;
-+    g_log<<Logger::Error<<"Error processing or aging answer packet: "<<e.what()<<endl;
-     return 0;
-   }
- 
-   if(t_pdl) {
-     if(t_pdl->ipfilter(fromaddr, destaddr, *dh)) {
-       if(!g_quiet)
--	L<<Logger::Notice<<t_id<<" ["<<MT->getTid()<<"/"<<MT->numProcesses()<<"] DROPPED question from "<<fromaddr.toStringWithPort()<<" based on policy"<<endl;
-+	g_log<<Logger::Notice<<t_id<<" ["<<MT->getTid()<<"/"<<MT->numProcesses()<<"] DROPPED question from "<<fromaddr.toStringWithPort()<<" based on policy"<<endl;
-       g_stats.policyDrops++;
-       return 0;
-     }
-@@ -1788,7 +1788,7 @@ static string* doProcessUDPQuestion(const std::string& question, const ComboAddr
- 
-   if(MT->numProcesses() > g_maxMThreads) {
-     if(!g_quiet)
--      L<<Logger::Notice<<t_id<<" ["<<MT->getTid()<<"/"<<MT->numProcesses()<<"] DROPPED question from "<<fromaddr.toStringWithPort()<<", over capacity"<<endl;
-+      g_log<<Logger::Notice<<t_id<<" ["<<MT->getTid()<<"/"<<MT->numProcesses()<<"] DROPPED question from "<<fromaddr.toStringWithPort()<<", over capacity"<<endl;
- 
-     g_stats.overCapacityDrops++;
-     return 0;
-@@ -1845,7 +1845,7 @@ static void handleNewUDPQuestion(int fd, FDMultiplexer::funcparam_t& var)
- 
-     if(t_allowFrom && !t_allowFrom->match(&fromaddr)) {
-       if(!g_quiet)
--        L<<Logger::Error<<"["<<MT->getTid()<<"] dropping UDP query from "<<fromaddr.toString()<<", address not matched by allow-from"<<endl;
-+        g_log<<Logger::Error<<"["<<MT->getTid()<<"] dropping UDP query from "<<fromaddr.toString()<<", address not matched by allow-from"<<endl;
- 
-       g_stats.unauthorizedUDP++;
-       return;
-@@ -1853,7 +1853,7 @@ static void handleNewUDPQuestion(int fd, FDMultiplexer::funcparam_t& var)
-     BOOST_STATIC_ASSERT(offsetof(sockaddr_in, sin_port) == offsetof(sockaddr_in6, sin6_port));
-     if(!fromaddr.sin4.sin_port) { // also works for IPv6
-      if(!g_quiet)
--        L<<Logger::Error<<"["<<MT->getTid()<<"] dropping UDP query from "<<fromaddr.toStringWithPort()<<", can't deal with port 0"<<endl;
-+        g_log<<Logger::Error<<"["<<MT->getTid()<<"] dropping UDP query from "<<fromaddr.toStringWithPort()<<", can't deal with port 0"<<endl;
- 
-       g_stats.clientParseError++; // not quite the best place to put it, but needs to go somewhere
-       return;
-@@ -1864,12 +1864,12 @@ static void handleNewUDPQuestion(int fd, FDMultiplexer::funcparam_t& var)
-       if(dh->qr) {
-         g_stats.ignoredCount++;
-         if(g_logCommonErrors)
--          L<<Logger::Error<<"Ignoring answer from "<<fromaddr.toString()<<" on server socket!"<<endl;
-+          g_log<<Logger::Error<<"Ignoring answer from "<<fromaddr.toString()<<" on server socket!"<<endl;
-       }
-       else if(dh->opcode) {
-         g_stats.ignoredCount++;
-         if(g_logCommonErrors)
--          L<<Logger::Error<<"Ignoring non-query opcode "<<dh->opcode<<" from "<<fromaddr.toString()<<" on server socket!"<<endl;
-+          g_log<<Logger::Error<<"Ignoring non-query opcode "<<dh->opcode<<" from "<<fromaddr.toString()<<" on server socket!"<<endl;
-       }
-       else {
-         string question(data, (size_t)len);
-@@ -1902,12 +1902,12 @@ static void handleNewUDPQuestion(int fd, FDMultiplexer::funcparam_t& var)
-     catch(MOADNSException& mde) {
-       g_stats.clientParseError++;
-       if(g_logCommonErrors)
--        L<<Logger::Error<<"Unable to parse packet from remote UDP client "<<fromaddr.toString() <<": "<<mde.what()<<endl;
-+        g_log<<Logger::Error<<"Unable to parse packet from remote UDP client "<<fromaddr.toString() <<": "<<mde.what()<<endl;
-     }
-     catch(std::runtime_error& e) {
-       g_stats.clientParseError++;
-       if(g_logCommonErrors)
--        L<<Logger::Error<<"Unable to parse packet from remote UDP client "<<fromaddr.toString() <<": "<<e.what()<<endl;
-+        g_log<<Logger::Error<<"Unable to parse packet from remote UDP client "<<fromaddr.toString() <<": "<<e.what()<<endl;
-     }
-   }
-   else {
-@@ -1951,17 +1951,17 @@ static void makeTCPServerSockets(unsigned int threadId)
- 
-     int tmp=1;
-     if(setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &tmp, sizeof tmp)<0) {
--      L<<Logger::Error<<"Setsockopt failed for TCP listening socket"<<endl;
-+      g_log<<Logger::Error<<"Setsockopt failed for TCP listening socket"<<endl;
-       exit(1);
-     }
-     if(sin.sin6.sin6_family == AF_INET6 && setsockopt(fd, IPPROTO_IPV6, IPV6_V6ONLY, &tmp, sizeof(tmp)) < 0) {
--      L<<Logger::Error<<"Failed to set IPv6 socket to IPv6 only, continuing anyhow: "<<strerror(errno)<<endl;
-+      g_log<<Logger::Error<<"Failed to set IPv6 socket to IPv6 only, continuing anyhow: "<<strerror(errno)<<endl;
-     }
- 
- #ifdef TCP_DEFER_ACCEPT
-     if(setsockopt(fd, SOL_TCP, TCP_DEFER_ACCEPT, &tmp, sizeof tmp) >= 0) {
-       if(i==locals.begin())
--        L<<Logger::Error<<"Enabled TCP data-ready filter for (slight) DoS protection"<<endl;
-+        g_log<<Logger::Error<<"Enabled TCP data-ready filter for (slight) DoS protection"<<endl;
-     }
- #endif
- 
-@@ -1979,10 +1979,10 @@ static void makeTCPServerSockets(unsigned int threadId)
- #ifdef TCP_FASTOPEN
-       int fastOpenQueueSize = ::arg().asNum("tcp-fast-open");
-       if (setsockopt(fd, IPPROTO_TCP, TCP_FASTOPEN, &fastOpenQueueSize, sizeof fastOpenQueueSize) < 0) {
--        L<<Logger::Error<<"Failed to enable TCP Fast Open for listening socket: "<<strerror(errno)<<endl;
-+        g_log<<Logger::Error<<"Failed to enable TCP Fast Open for listening socket: "<<strerror(errno)<<endl;
-       }
- #else
--      L<<Logger::Warning<<"TCP Fast Open configured but not supported for listening socket"<<endl;
-+      g_log<<Logger::Warning<<"TCP Fast Open configured but not supported for listening socket"<<endl;
- #endif
-     }
- 
-@@ -1999,9 +1999,9 @@ static void makeTCPServerSockets(unsigned int threadId)
-     // we don't need to update g_listenSocketsAddresses since it doesn't work for TCP/IP:
-     //  - fd is not that which we know here, but returned from accept()
-     if(sin.sin4.sin_family == AF_INET)
--      L<<Logger::Error<<"Listening for TCP queries on "<< sin.toString() <<":"<<st.port<<endl;
-+      g_log<<Logger::Error<<"Listening for TCP queries on "<< sin.toString() <<":"<<st.port<<endl;
-     else
--      L<<Logger::Error<<"Listening for TCP queries on ["<< sin.toString() <<"]:"<<st.port<<endl;
-+      g_log<<Logger::Error<<"Listening for TCP queries on ["<< sin.toString() <<"]:"<<st.port<<endl;
-   }
- }
- 
-@@ -2034,7 +2034,7 @@ static void makeUDPServerSockets(unsigned int threadId)
-       throw PDNSException("Making a UDP server socket for resolver: "+netstringerror());
-     }
-     if (!setSocketTimestamps(fd))
--      L<<Logger::Warning<<"Unable to enable timestamp reporting for socket"<<endl;
-+      g_log<<Logger::Warning<<"Unable to enable timestamp reporting for socket"<<endl;
- 
-     if(IsAnyAddress(sin)) {
-       if(sin.sin4.sin_family == AF_INET)
-@@ -2046,7 +2046,7 @@ static void makeUDPServerSockets(unsigned int threadId)
-           g_fromtosockets.insert(fd);
- #endif
-       if(sin.sin6.sin6_family == AF_INET6 && setsockopt(fd, IPPROTO_IPV6, IPV6_V6ONLY, &one, sizeof(one)) < 0) {
--	L<<Logger::Error<<"Failed to set IPv6 socket to IPv6 only, continuing anyhow: "<<strerror(errno)<<endl;
-+	g_log<<Logger::Error<<"Failed to set IPv6 socket to IPv6 only, continuing anyhow: "<<strerror(errno)<<endl;
-       }
-     }
-     if( ::arg().mustDo("non-local-bind") )
-@@ -2073,9 +2073,9 @@ static void makeUDPServerSockets(unsigned int threadId)
-     deferredAdds[threadId].push_back(make_pair(fd, handleNewUDPQuestion));
-     g_listenSocketsAddresses[fd]=sin;  // this is written to only from the startup thread, not from the workers
-     if(sin.sin4.sin_family == AF_INET)
--      L<<Logger::Error<<"Listening for UDP queries on "<< sin.toString() <<":"<<st.port<<endl;
-+      g_log<<Logger::Error<<"Listening for UDP queries on "<< sin.toString() <<":"<<st.port<<endl;
-     else
--      L<<Logger::Error<<"Listening for UDP queries on ["<< sin.toString() <<"]:"<<st.port<<endl;
-+      g_log<<Logger::Error<<"Listening for UDP queries on ["<< sin.toString() <<"]:"<<st.port<<endl;
-   }
- }
- 
-@@ -2088,7 +2088,7 @@ static void daemonize(void)
- 
-   int i=open("/dev/null",O_RDWR); /* open stdin */
-   if(i < 0)
--    L<<Logger::Critical<<"Unable to open /dev/null: "<<stringerror()<<endl;
-+    g_log<<Logger::Critical<<"Unable to open /dev/null: "<<stringerror()<<endl;
-   else {
-     dup2(i,0); /* stdin */
-     dup2(i,1); /* stderr */
-@@ -2118,35 +2118,35 @@ static void doStats(void)
-   uint64_t cacheMisses = broadcastAccFunction<uint64_t>(pleaseGetCacheMisses);
- 
-   if(g_stats.qcounter && (cacheHits + cacheMisses) && SyncRes::s_queries && SyncRes::s_outqueries) {
--    L<<Logger::Notice<<"stats: "<<g_stats.qcounter<<" questions, "<<
-+    g_log<<Logger::Notice<<"stats: "<<g_stats.qcounter<<" questions, "<<
-       broadcastAccFunction<uint64_t>(pleaseGetCacheSize)<< " cache entries, "<<
-       broadcastAccFunction<uint64_t>(pleaseGetNegCacheSize)<<" negative entries, "<<
-       (int)((cacheHits*100.0)/(cacheHits+cacheMisses))<<"% cache hits"<<endl;
- 
--    L<<Logger::Notice<<"stats: throttle map: "
-+    g_log<<Logger::Notice<<"stats: throttle map: "
-       << broadcastAccFunction<uint64_t>(pleaseGetThrottleSize) <<", ns speeds: "
-       << broadcastAccFunction<uint64_t>(pleaseGetNsSpeedsSize)<<endl;
--    L<<Logger::Notice<<"stats: outpacket/query ratio "<<(int)(SyncRes::s_outqueries*100.0/SyncRes::s_queries)<<"%";
--    L<<Logger::Notice<<", "<<(int)(SyncRes::s_throttledqueries*100.0/(SyncRes::s_outqueries+SyncRes::s_throttledqueries))<<"% throttled, "
-+    g_log<<Logger::Notice<<"stats: outpacket/query ratio "<<(int)(SyncRes::s_outqueries*100.0/SyncRes::s_queries)<<"%";
-+    g_log<<Logger::Notice<<", "<<(int)(SyncRes::s_throttledqueries*100.0/(SyncRes::s_outqueries+SyncRes::s_throttledqueries))<<"% throttled, "
-      <<SyncRes::s_nodelegated<<" no-delegation drops"<<endl;
--    L<<Logger::Notice<<"stats: "<<SyncRes::s_tcpoutqueries<<" outgoing tcp connections, "<<
-+    g_log<<Logger::Notice<<"stats: "<<SyncRes::s_tcpoutqueries<<" outgoing tcp connections, "<<
-       broadcastAccFunction<uint64_t>(pleaseGetConcurrentQueries)<<" queries running, "<<SyncRes::s_outgoingtimeouts<<" outgoing timeouts"<<endl;
- 
--    //L<<Logger::Notice<<"stats: "<<g_stats.ednsPingMatches<<" ping matches, "<<g_stats.ednsPingMismatches<<" mismatches, "<<
-+    //g_log<<Logger::Notice<<"stats: "<<g_stats.ednsPingMatches<<" ping matches, "<<g_stats.ednsPingMismatches<<" mismatches, "<<
-       //g_stats.noPingOutQueries<<" outqueries w/o ping, "<< g_stats.noEdnsOutQueries<<" w/o EDNS"<<endl;
- 
--    L<<Logger::Notice<<"stats: " <<  broadcastAccFunction<uint64_t>(pleaseGetPacketCacheSize) <<
-+    g_log<<Logger::Notice<<"stats: " <<  broadcastAccFunction<uint64_t>(pleaseGetPacketCacheSize) <<
-     " packet cache entries, "<<(int)(100.0*broadcastAccFunction<uint64_t>(pleaseGetPacketCacheHits)/SyncRes::s_queries) << "% packet cache hits"<<endl;
- 
-     time_t now = time(0);
-     if(lastOutputTime && lastQueryCount && now != lastOutputTime) {
--      L<<Logger::Notice<<"stats: "<< (SyncRes::s_queries - lastQueryCount) / (now - lastOutputTime) <<" qps (average over "<< (now - lastOutputTime) << " seconds)"<<endl;
-+      g_log<<Logger::Notice<<"stats: "<< (SyncRes::s_queries - lastQueryCount) / (now - lastOutputTime) <<" qps (average over "<< (now - lastOutputTime) << " seconds)"<<endl;
-     }
-     lastOutputTime = now;
-     lastQueryCount = SyncRes::s_queries;
-   }
-   else if(statsWanted)
--    L<<Logger::Notice<<"stats: no stats yet!"<<endl;
-+    g_log<<Logger::Notice<<"stats: no stats yet!"<<endl;
- 
-   statsWanted=false;
- }
-@@ -2193,19 +2193,19 @@ static void houseKeeping(void *)
- 	}
- 	catch(std::exception& e)
-         {
--          L<<Logger::Error<<"Exception while performing security poll: "<<e.what()<<endl;
-+          g_log<<Logger::Error<<"Exception while performing security poll: "<<e.what()<<endl;
-         }
-         catch(PDNSException& e)
-         {
--          L<<Logger::Error<<"Exception while performing security poll: "<<e.reason<<endl;
-+          g_log<<Logger::Error<<"Exception while performing security poll: "<<e.reason<<endl;
-         }
-         catch(ImmediateServFailException &e)
-         {
--          L<<Logger::Error<<"Exception while performing security poll: "<<e.reason<<endl;
-+          g_log<<Logger::Error<<"Exception while performing security poll: "<<e.reason<<endl;
-         }
-         catch(...)
-         {
--          L<<Logger::Error<<"Exception while performing security poll"<<endl;
-+          g_log<<Logger::Error<<"Exception while performing security poll"<<endl;
-         }
- 
-       }
-@@ -2215,7 +2215,7 @@ static void houseKeeping(void *)
-   catch(PDNSException& ae)
-     {
-       s_running=false;
--      L<<Logger::Error<<"Fatal error in housekeeping thread: "<<ae.reason<<endl;
-+      g_log<<Logger::Error<<"Fatal error in housekeeping thread: "<<ae.reason<<endl;
-       throw;
-     }
- }
-@@ -2260,7 +2260,7 @@ void broadcastFunction(const pipefunc_t& func)
-   /* This function might be called by the worker with t_id 0 during startup
-      for the initialization of ACLs and domain maps */
-   if (t_id != s_handlerThreadID && t_id != s_distributorThreadID) {
--    L<<Logger::Error<<"broadcastFunction() has been called by a worker ("<<t_id<<")"<<endl;
-+    g_log<<Logger::Error<<"broadcastFunction() has been called by a worker ("<<t_id<<")"<<endl;
-     exit(1);
-   }
- 
-@@ -2301,7 +2301,7 @@ void broadcastFunction(const pipefunc_t& func)
- void distributeAsyncFunction(const string& packet, const pipefunc_t& func)
- {
-   if (t_id != s_distributorThreadID) {
--    L<<Logger::Error<<"distributeAsyncFunction() has been called by a worker ("<<t_id<<")"<<endl;
-+    g_log<<Logger::Error<<"distributeAsyncFunction() has been called by a worker ("<<t_id<<")"<<endl;
-     exit(1);
-   }
- 
-@@ -2309,7 +2309,7 @@ void distributeAsyncFunction(const string& packet, const pipefunc_t& func)
-   unsigned int target = 1 + (hash % (g_pipes.size()-1));
- 
-   if(target == static_cast<unsigned int>(s_distributorThreadID)) {
--    L<<Logger::Error<<"distributeAsyncFunction() tried to assign a query to the distributor"<<endl;
-+    g_log<<Logger::Error<<"distributeAsyncFunction() tried to assign a query to the distributor"<<endl;
-     exit(1);
-   }
- 
-@@ -2350,11 +2350,11 @@ static void handlePipeRequest(int fd, FDMultiplexer::funcparam_t& var)
-   }
-   catch(std::exception& e) {
-     if(g_logCommonErrors)
--      L<<Logger::Error<<"PIPE function we executed created exception: "<<e.what()<<endl; // but what if they wanted an answer.. we send 0
-+      g_log<<Logger::Error<<"PIPE function we executed created exception: "<<e.what()<<endl; // but what if they wanted an answer.. we send 0
-   }
-   catch(PDNSException& e) {
-     if(g_logCommonErrors)
--      L<<Logger::Error<<"PIPE function we executed created PDNS exception: "<<e.reason<<endl; // but what if they wanted an answer.. we send 0
-+      g_log<<Logger::Error<<"PIPE function we executed created PDNS exception: "<<e.reason<<endl; // but what if they wanted an answer.. we send 0
-   }
-   if(tmsg->wantAnswer) {
-     if(write(g_pipes[t_id].writeFromThread, &resp, sizeof(resp)) != sizeof(resp)) {
-@@ -2396,7 +2396,7 @@ vector<pair<DNSName, uint16_t> >& operator+=(vector<pair<DNSName, uint16_t> >&a,
- template<class T> T broadcastAccFunction(const boost::function<T*()>& func)
- {
-   if (t_id != s_handlerThreadID) {
--    L<<Logger::Error<<"broadcastFunction has been called by a worker ("<<t_id<<")"<<endl;
-+    g_log<<Logger::Error<<"broadcastFunction has been called by a worker ("<<t_id<<")"<<endl;
-     exit(1);
-   }
- 
-@@ -2450,10 +2450,10 @@ static void handleRCC(int fd, FDMultiplexer::funcparam_t& var)
-     command();
-   }
-   catch(std::exception& e) {
--    L<<Logger::Error<<"Error dealing with control socket request: "<<e.what()<<endl;
-+    g_log<<Logger::Error<<"Error dealing with control socket request: "<<e.what()<<endl;
-   }
-   catch(PDNSException& ae) {
--    L<<Logger::Error<<"Error dealing with control socket request: "<<ae.reason<<endl;
-+    g_log<<Logger::Error<<"Error dealing with control socket request: "<<ae.reason<<endl;
-   }
- }
- 
-@@ -2540,7 +2540,7 @@ static void handleUDPServerResponse(int fd, FDMultiplexer::funcparam_t& var)
-     else {
-       g_stats.serverParseError++;
-       if(g_logCommonErrors)
--        L<<Logger::Error<<"Unable to parse packet from remote UDP server "<< fromaddr.toString() <<
-+        g_log<<Logger::Error<<"Unable to parse packet from remote UDP server "<< fromaddr.toString() <<
-           ": packet smaller than DNS header"<<endl;
-     }
- 
-@@ -2564,7 +2564,7 @@ static void handleUDPServerResponse(int fd, FDMultiplexer::funcparam_t& var)
-   pident.fd=fd;
- 
-   if(!dh.qr && g_logCommonErrors) {
--    L<<Logger::Notice<<"Not taking data from question on outgoing socket from "<< fromaddr.toStringWithPort()  <<endl;
-+    g_log<<Logger::Notice<<"Not taking data from question on outgoing socket from "<< fromaddr.toStringWithPort()  <<endl;
-   }
- 
-   if(!dh.qdcount || // UPC, Nominum, very old BIND on FormErr, NSD
-@@ -2579,7 +2579,7 @@ static void handleUDPServerResponse(int fd, FDMultiplexer::funcparam_t& var)
-     }
-     catch(std::exception& e) {
-       g_stats.serverParseError++; // won't be fed to lwres.cc, so we have to increment
--      L<<Logger::Warning<<"Error in packet from remote nameserver "<< fromaddr.toStringWithPort() << ": "<<e.what() << endl;
-+      g_log<<Logger::Warning<<"Error in packet from remote nameserver "<< fromaddr.toStringWithPort() << ": "<<e.what() << endl;
-       return;
-     }
-   }
-@@ -2612,7 +2612,7 @@ retryWithName:
-     }
-     g_stats.unexpectedCount++; // if we made it here, it really is an unexpected answer
-     if(g_logCommonErrors) {
--      L<<Logger::Warning<<"Discarding unexpected packet from "<<fromaddr.toStringWithPort()<<": "<< (pident.domain.empty() ? "<empty>" : pident.domain.toString())<<", "<<pident.type<<", "<<MT->d_waiters.size()<<" waiters"<<endl;
-+      g_log<<Logger::Warning<<"Discarding unexpected packet from "<<fromaddr.toStringWithPort()<<": "<< (pident.domain.empty() ? "<empty>" : pident.domain.toString())<<", "<<pident.type<<", "<<MT->d_waiters.size()<<" waiters"<<endl;
-     }
-   }
-   else if(fd >= 0) {
-@@ -2629,13 +2629,13 @@ FDMultiplexer* getMultiplexer()
-       return ret;
-     }
-     catch(FDMultiplexerException &fe) {
--      L<<Logger::Error<<"Non-fatal error initializing possible multiplexer ("<<fe.what()<<"), falling back"<<endl;
-+      g_log<<Logger::Error<<"Non-fatal error initializing possible multiplexer ("<<fe.what()<<"), falling back"<<endl;
-     }
-     catch(...) {
--      L<<Logger::Error<<"Non-fatal error initializing possible multiplexer"<<endl;
-+      g_log<<Logger::Error<<"Non-fatal error initializing possible multiplexer"<<endl;
-     }
-   }
--  L<<Logger::Error<<"No working multiplexer found!"<<endl;
-+  g_log<<Logger::Error<<"No working multiplexer found!"<<endl;
-   exit(1);
- }
- 
-@@ -2646,7 +2646,7 @@ static string* doReloadLuaScript()
-   try {
-     if(fname.empty()) {
-       t_pdl.reset();
--      L<<Logger::Error<<t_id<<" Unloaded current lua script"<<endl;
-+      g_log<<Logger::Error<<t_id<<" Unloaded current lua script"<<endl;
-       return new string("unloaded\n");
-     }
-     else {
-@@ -2654,11 +2654,11 @@ static string* doReloadLuaScript()
-     }
-   }
-   catch(std::exception& e) {
--    L<<Logger::Error<<t_id<<" Retaining current script, error from '"<<fname<<"': "<< e.what() <<endl;
-+    g_log<<Logger::Error<<t_id<<" Retaining current script, error from '"<<fname<<"': "<< e.what() <<endl;
-     return new string("retaining current script, error from '"+fname+"': "+e.what()+"\n");
-   }
- 
--  L<<Logger::Warning<<t_id<<" (Re)loaded lua script from '"<<fname<<"'"<<endl;
-+  g_log<<Logger::Warning<<t_id<<" (Re)loaded lua script from '"<<fname<<"'"<<endl;
-   return new string("(re)loaded '"+fname+"'\n");
- }
- 
-@@ -2699,7 +2699,7 @@ static void checkLinuxIPv6Limits()
-   if(readFileIfThere("/proc/sys/net/ipv6/route/max_size", &line)) {
-     int lim=std::stoi(line);
-     if(lim < 16384) {
--      L<<Logger::Error<<"If using IPv6, please raise sysctl net.ipv6.route.max_size, currently set to "<<lim<<" which is < 16384"<<endl;
-+      g_log<<Logger::Error<<"If using IPv6, please raise sysctl net.ipv6.route.max_size, currently set to "<<lim<<" which is < 16384"<<endl;
-     }
-   }
- #endif
-@@ -2713,11 +2713,11 @@ static void checkOrFixFDS()
-     unsigned int hardlimit= getFilenumLimit(true);
-     if(hardlimit >= wantFDs) {
-       setFilenumLimit(wantFDs);
--      L<<Logger::Warning<<"Raised soft limit on number of filedescriptors to "<<wantFDs<<" to match max-mthreads and threads settings"<<endl;
-+      g_log<<Logger::Warning<<"Raised soft limit on number of filedescriptors to "<<wantFDs<<" to match max-mthreads and threads settings"<<endl;
-     }
-     else {
-       int newval = (hardlimit - 25) / g_numWorkerThreads;
--      L<<Logger::Warning<<"Insufficient number of filedescriptors available for max-mthreads*threads setting! ("<<hardlimit<<" < "<<wantFDs<<"), reducing max-mthreads to "<<newval<<endl;
-+      g_log<<Logger::Warning<<"Insufficient number of filedescriptors available for max-mthreads*threads setting! ("<<hardlimit<<" < "<<wantFDs<<"), reducing max-mthreads to "<<newval<<endl;
-       g_maxMThreads = newval;
-       setFilenumLimit(hardlimit);
-     }
-@@ -2788,24 +2788,24 @@ void parseACLs()
- 
-       allowFrom->addMask(line);
-     }
--    L<<Logger::Warning<<"Done parsing " << allowFrom->size() <<" allow-from ranges from file '"<<::arg()["allow-from-file"]<<"' - overriding 'allow-from' setting"<<endl;
-+    g_log<<Logger::Warning<<"Done parsing " << allowFrom->size() <<" allow-from ranges from file '"<<::arg()["allow-from-file"]<<"' - overriding 'allow-from' setting"<<endl;
-   }
-   else if(!::arg()["allow-from"].empty()) {
-     vector<string> ips;
-     stringtok(ips, ::arg()["allow-from"], ", ");
- 
--    L<<Logger::Warning<<"Only allowing queries from: ";
-+    g_log<<Logger::Warning<<"Only allowing queries from: ";
-     for(vector<string>::const_iterator i = ips.begin(); i!= ips.end(); ++i) {
-       allowFrom->addMask(*i);
-       if(i!=ips.begin())
--        L<<Logger::Warning<<", ";
--      L<<Logger::Warning<<*i;
-+        g_log<<Logger::Warning<<", ";
-+      g_log<<Logger::Warning<<*i;
-     }
--    L<<Logger::Warning<<endl;
-+    g_log<<Logger::Warning<<endl;
-   }
-   else {
-     if(::arg()["local-address"]!="127.0.0.1" && ::arg().asNum("local-port")==53)
--      L<<Logger::Error<<"WARNING: Allowing queries from all IP addresses - this can be a security risk!"<<endl;
-+      g_log<<Logger::Error<<"WARNING: Allowing queries from all IP addresses - this can be a security risk!"<<endl;
-     allowFrom = nullptr;
-   }
- 
-@@ -2833,7 +2833,7 @@ static std::map<unsigned int, std::set<int> > parseCPUMap()
-   const std::string value = ::arg()["cpu-map"];
- 
-   if (!value.empty() && !isSettingThreadCPUAffinitySupported()) {
--    L<<Logger::Warning<<"CPU mapping requested but not supported, skipping"<<endl;
-+    g_log<<Logger::Warning<<"CPU mapping requested but not supported, skipping"<<endl;
-     return result;
-   }
- 
-@@ -2862,7 +2862,7 @@ static std::map<unsigned int, std::set<int> > parseCPUMap()
-       }
-     }
-     catch(const std::exception& e) {
--      L<<Logger::Error<<"Error parsing cpu-map entry '"<<part<<"': "<<e.what()<<endl;
-+      g_log<<Logger::Error<<"Error parsing cpu-map entry '"<<part<<"': "<<e.what()<<endl;
-     }
-   }
- 
-@@ -2875,34 +2875,34 @@ static void setCPUMap(const std::map<unsigned int, std::set<int> >& cpusMap, uns
-   if (cpuMapping != cpusMap.cend()) {
-     int rc = mapThreadToCPUList(tid, cpuMapping->second);
-     if (rc == 0) {
--      L<<Logger::Info<<"CPU affinity for worker "<<n<<" has been set to CPU map:";
-+      g_log<<Logger::Info<<"CPU affinity for worker "<<n<<" has been set to CPU map:";
-       for (const auto cpu : cpuMapping->second) {
--        L<<Logger::Info<<" "<<cpu;
-+        g_log<<Logger::Info<<" "<<cpu;
-       }
--      L<<Logger::Info<<endl;
-+      g_log<<Logger::Info<<endl;
-     }
-     else {
--      L<<Logger::Warning<<"Error setting CPU affinity for worker "<<n<<" to CPU map:";
-+      g_log<<Logger::Warning<<"Error setting CPU affinity for worker "<<n<<" to CPU map:";
-       for (const auto cpu : cpuMapping->second) {
--        L<<Logger::Info<<" "<<cpu;
-+        g_log<<Logger::Info<<" "<<cpu;
-       }
--      L<<Logger::Info<<strerror(rc)<<endl;
-+      g_log<<Logger::Info<<strerror(rc)<<endl;
-     }
-   }
- }
- 
- static int serviceMain(int argc, char*argv[])
- {
--  L.setName(s_programname);
--  L.disableSyslog(::arg().mustDo("disable-syslog"));
--  L.setTimestamps(::arg().mustDo("log-timestamp"));
-+  g_log.setName(s_programname);
-+  g_log.disableSyslog(::arg().mustDo("disable-syslog"));
-+  g_log.setTimestamps(::arg().mustDo("log-timestamp"));
- 
-   if(!::arg()["logging-facility"].empty()) {
-     int val=logFacilityToLOG(::arg().asNum("logging-facility") );
-     if(val >= 0)
-       theL().setFacility(val);
-     else
--      L<<Logger::Error<<"Unknown logging facility "<<::arg().asNum("logging-facility") <<endl;
-+      g_log<<Logger::Error<<"Unknown logging facility "<<::arg().asNum("logging-facility") <<endl;
-   }
- 
-   showProductVersion();
-@@ -2915,7 +2915,7 @@ static int serviceMain(int argc, char*argv[])
-     vector<string> addrs;
-     if(!::arg()["query-local-address6"].empty()) {
-       SyncRes::s_doIPv6=true;
--      L<<Logger::Warning<<"Enabling IPv6 transport for outgoing queries"<<endl;
-+      g_log<<Logger::Warning<<"Enabling IPv6 transport for outgoing queries"<<endl;
- 
-       stringtok(addrs, ::arg()["query-local-address6"], ", ;");
-       for(const string& addr : addrs) {
-@@ -2923,7 +2923,7 @@ static int serviceMain(int argc, char*argv[])
-       }
-     }
-     else {
--      L<<Logger::Warning<<"NOT using IPv6 for outgoing queries - set 'query-local-address6=::' to enable"<<endl;
-+      g_log<<Logger::Warning<<"NOT using IPv6 for outgoing queries - set 'query-local-address6=::' to enable"<<endl;
-     }
-     addrs.clear();
-     stringtok(addrs, ::arg()["query-local-address"], ", ;");
-@@ -2932,7 +2932,7 @@ static int serviceMain(int argc, char*argv[])
-     }
-   }
-   catch(std::exception& e) {
--    L<<Logger::Error<<"Assigning local query addresses: "<<e.what();
-+    g_log<<Logger::Error<<"Assigning local query addresses: "<<e.what();
-     exit(99);
-   }
- 
-@@ -2948,7 +2948,7 @@ static int serviceMain(int argc, char*argv[])
-   else if(::arg()["dnssec"]=="log-fail")
-     g_dnssecmode=DNSSECMode::ValidateForLog;
-   else {
--    L<<Logger::Error<<"Unknown DNSSEC mode "<<::arg()["dnssec"]<<endl;
-+    g_log<<Logger::Error<<"Unknown DNSSEC mode "<<::arg()["dnssec"]<<endl;
-     exit(1);
-   }
- 
-@@ -2962,7 +2962,7 @@ static int serviceMain(int argc, char*argv[])
-     loadRecursorLuaConfig(::arg()["lua-config-file"], ::arg().mustDo("daemon"));
-   }
-   catch (PDNSException &e) {
--    L<<Logger::Error<<"Cannot load Lua configuration: "<<e.reason<<endl;
-+    g_log<<Logger::Error<<"Cannot load Lua configuration: "<<e.reason<<endl;
-     exit(1);
-   }
- 
-@@ -2975,21 +2975,21 @@ static int serviceMain(int argc, char*argv[])
-     ips.push_back("0.0.0.0");
-     ips.push_back("::");
- 
--    L<<Logger::Warning<<"Will not send queries to: ";
-+    g_log<<Logger::Warning<<"Will not send queries to: ";
-     for(vector<string>::const_iterator i = ips.begin(); i!= ips.end(); ++i) {
-       SyncRes::addDontQuery(*i);
-       if(i!=ips.begin())
--        L<<Logger::Warning<<", ";
--      L<<Logger::Warning<<*i;
-+        g_log<<Logger::Warning<<", ";
-+      g_log<<Logger::Warning<<*i;
-     }
--    L<<Logger::Warning<<endl;
-+    g_log<<Logger::Warning<<endl;
-   }
- 
-   g_quiet=::arg().mustDo("quiet");
- 
-   g_weDistributeQueries = ::arg().mustDo("pdns-distributes-queries");
-   if(g_weDistributeQueries) {
--      L<<Logger::Warning<<"PowerDNS Recursor itself will distribute queries over threads"<<endl;
-+      g_log<<Logger::Warning<<"PowerDNS Recursor itself will distribute queries over threads"<<endl;
-   }
- 
-   setupDelegationOnly();
-@@ -3074,7 +3074,7 @@ static int serviceMain(int argc, char*argv[])
- 
-   g_numWorkerThreads = ::arg().asNum("threads");
-   if (g_numWorkerThreads < 1) {
--    L<<Logger::Warning<<"Asked to run with 0 threads, raising to 1 instead"<<endl;
-+    g_log<<Logger::Warning<<"Asked to run with 0 threads, raising to 1 instead"<<endl;
-     g_numWorkerThreads = 1;
-   }
- 
-@@ -3112,8 +3112,8 @@ static int serviceMain(int argc, char*argv[])
-   }
- 
-   if(::arg().mustDo("daemon")) {
--    L<<Logger::Warning<<"Calling daemonize, going to background"<<endl;
--    L.toConsole(Logger::Critical);
-+    g_log<<Logger::Warning<<"Calling daemonize, going to background"<<endl;
-+    g_log.toConsole(Logger::Critical);
-     daemonize();
-     loadRecursorLuaConfig(::arg()["lua-config-file"], false);
-   }
-@@ -3125,7 +3125,7 @@ static int serviceMain(int argc, char*argv[])
- 
- #ifdef HAVE_LIBSODIUM
-   if (sodium_init() == -1) {
--    L<<Logger::Error<<"Unable to initialize sodium crypto library"<<endl;
-+    g_log<<Logger::Error<<"Unable to initialize sodium crypto library"<<endl;
-     exit(99);
-   }
- #endif
-@@ -3147,16 +3147,16 @@ static int serviceMain(int argc, char*argv[])
-      char *ns;
-      ns = getenv("NOTIFY_SOCKET");
-      if (ns != nullptr) {
--       L<<Logger::Error<<"Unable to chroot when running from systemd. Please disable chroot= or set the 'Type' for this service to 'simple'"<<endl;
-+       g_log<<Logger::Error<<"Unable to chroot when running from systemd. Please disable chroot= or set the 'Type' for this service to 'simple'"<<endl;
-        exit(1);
-      }
- #endif
-     if (chroot(::arg()["chroot"].c_str())<0 || chdir("/") < 0) {
--      L<<Logger::Error<<"Unable to chroot to '"+::arg()["chroot"]+"': "<<strerror (errno)<<", exiting"<<endl;
-+      g_log<<Logger::Error<<"Unable to chroot to '"+::arg()["chroot"]+"': "<<strerror (errno)<<", exiting"<<endl;
-       exit(1);
-     }
-     else
--      L<<Logger::Error<<"Chrooted to '"<<::arg()["chroot"]<<"'"<<endl;
-+      g_log<<Logger::Error<<"Chrooted to '"<<::arg()["chroot"]<<"'"<<endl;
-   }
- 
-   s_pidfname=::arg()["socket-dir"]+"/"+s_programname+".pid";
-@@ -3186,7 +3186,7 @@ static int serviceMain(int argc, char*argv[])
- 
-   std::vector<std::thread> workers(g_numThreads);
-   if(g_numThreads == 1) {
--    L<<Logger::Warning<<"Operating unthreaded"<<endl;
-+    g_log<<Logger::Warning<<"Operating unthreaded"<<endl;
- #ifdef HAVE_SYSTEMD
-     sd_notify(0, "READY=1");
- #endif
-@@ -3194,7 +3194,7 @@ static int serviceMain(int argc, char*argv[])
-     recursorThread(0, true);
-   }
-   else {
--    L<<Logger::Warning<<"Launching "<< g_numThreads <<" threads"<<endl;
-+    g_log<<Logger::Warning<<"Launching "<< g_numThreads <<" threads"<<endl;
-     for(unsigned int n=0; n < g_numThreads; ++n) {
-       workers[n] = std::thread(recursorThread, n, true);
- 
-@@ -3224,16 +3224,16 @@ try
- #ifdef HAVE_PROTOBUF
-   t_uuidGenerator = std::unique_ptr<boost::uuids::random_generator>(new boost::uuids::random_generator());
- #endif
--  L<<Logger::Warning<<"Done priming cache with root hints"<<endl;
-+  g_log<<Logger::Warning<<"Done priming cache with root hints"<<endl;
- 
-   try {
-     if(!::arg()["lua-dns-script"].empty()) {
-       t_pdl = std::make_shared<RecursorLua4>(::arg()["lua-dns-script"]);
--      L<<Logger::Warning<<"Loaded 'lua' script from '"<<::arg()["lua-dns-script"]<<"'"<<endl;
-+      g_log<<Logger::Warning<<"Loaded 'lua' script from '"<<::arg()["lua-dns-script"]<<"'"<<endl;
-     }
-   }
-   catch(std::exception &e) {
--    L<<Logger::Error<<"Failed to load 'lua' script from '"<<::arg()["lua-dns-script"]<<"': "<<e.what()<<endl;
-+    g_log<<Logger::Error<<"Failed to load 'lua' script from '"<<::arg()["lua-dns-script"]<<"': "<<e.what()<<endl;
-     _exit(99);
-   }
- 
-@@ -3263,16 +3263,16 @@ try
- 
-   if(!worker) {
-     if(::arg().mustDo("webserver")) {
--      L<<Logger::Warning << "Enabling web server" << endl;
-+      g_log<<Logger::Warning << "Enabling web server" << endl;
-       try {
-         new RecursorWebServer(t_fdm);
-       }
-       catch(PDNSException &e) {
--        L<<Logger::Error<<"Exception: "<<e.reason<<endl;
-+        g_log<<Logger::Error<<"Exception: "<<e.reason<<endl;
-         exit(99);
-       }
-     }
--    L<<Logger::Error<<"Enabled '"<< t_fdm->getName() << "' multiplexer"<<endl;
-+    g_log<<Logger::Error<<"Enabled '"<< t_fdm->getName() << "' multiplexer"<<endl;
-   }
-   else {
-     t_fdm->addReadFD(g_pipes[t_id].readToThread, handlePipeRequest);
-@@ -3320,7 +3320,7 @@ try
-       for(expired_t::iterator i=expired.begin() ; i != expired.end(); ++i) {
-         shared_ptr<TCPConnection> conn=any_cast<shared_ptr<TCPConnection> >(i->second);
-         if(g_logCommonErrors)
--          L<<Logger::Warning<<"Timeout from remote TCP client "<< conn->d_remote.toString() <<endl;
-+          g_log<<Logger::Warning<<"Timeout from remote TCP client "<< conn->d_remote.toString() <<endl;
-         t_fdm->removeReadFD(i->first);
-       }
-     }
-@@ -3363,15 +3363,15 @@ try
-   }
- }
- catch(PDNSException &ae) {
--  L<<Logger::Error<<"Exception: "<<ae.reason<<endl;
-+  g_log<<Logger::Error<<"Exception: "<<ae.reason<<endl;
-   return 0;
- }
- catch(std::exception &e) {
--   L<<Logger::Error<<"STL Exception: "<<e.what()<<endl;
-+   g_log<<Logger::Error<<"STL Exception: "<<e.what()<<endl;
-    return 0;
- }
- catch(...) {
--   L<<Logger::Error<<"any other exception in main: "<<endl;
-+   g_log<<Logger::Error<<"any other exception in main: "<<endl;
-    return 0;
- }
- 
-@@ -3505,7 +3505,7 @@ int main(int argc, char **argv)
-     ::arg().setCmd("help","Provide a helpful message");
-     ::arg().setCmd("version","Print version string");
-     ::arg().setCmd("config","Output blank configuration");
--    L.toConsole(Logger::Info);
-+    g_log.toConsole(Logger::Info);
-     ::arg().laxParse(argc,argv); // do a lax parse
- 
-     string configname=::arg()["config-dir"]+"/recursor.conf";
-@@ -3521,12 +3521,12 @@ int main(int argc, char **argv)
-     }
- 
-     if(!::arg().file(configname.c_str()))
--      L<<Logger::Warning<<"Unable to parse configuration file '"<<configname<<"'"<<endl;
-+      g_log<<Logger::Warning<<"Unable to parse configuration file '"<<configname<<"'"<<endl;
- 
-     ::arg().parse(argc,argv);
- 
-     if( !::arg()["chroot"].empty() && !::arg()["api-config-dir"].empty() && !::arg().mustDo("api-readonly") )  {
--      L<<Logger::Error<<"Using chroot and a writable API is not possible"<<endl;
-+      g_log<<Logger::Error<<"Using chroot and a writable API is not possible"<<endl;
-       exit(EXIT_FAILURE);
-     }
- 
-@@ -3560,21 +3560,21 @@ int main(int argc, char **argv)
-     if(!g_quiet && logUrgency < Logger::Info) { // Logger::Info=6, Logger::Debug=7
-       logUrgency = Logger::Info;                // if you do --quiet=no, you need Info to also see the query log
-     }
--    L.setLoglevel(logUrgency);
--    L.toConsole(logUrgency);
-+    g_log.setLoglevel(logUrgency);
-+    g_log.toConsole(logUrgency);
- 
-     serviceMain(argc, argv);
-   }
-   catch(PDNSException &ae) {
--    L<<Logger::Error<<"Exception: "<<ae.reason<<endl;
-+    g_log<<Logger::Error<<"Exception: "<<ae.reason<<endl;
-     ret=EXIT_FAILURE;
-   }
-   catch(std::exception &e) {
--    L<<Logger::Error<<"STL Exception: "<<e.what()<<endl;
-+    g_log<<Logger::Error<<"STL Exception: "<<e.what()<<endl;
-     ret=EXIT_FAILURE;
-   }
-   catch(...) {
--    L<<Logger::Error<<"any other exception in main: "<<endl;
-+    g_log<<Logger::Error<<"any other exception in main: "<<endl;
-     ret=EXIT_FAILURE;
-   }
- 
-diff --git a/randomhelper.cc b/randomhelper.cc
-index 8d8b2db..97f0911 100644
---- a/randomhelper.cc
-+++ b/randomhelper.cc
-@@ -11,11 +11,11 @@
- 
- void seedRandom(const string& source)
- {
--  L<<Logger::Warning<<"Reading random entropy from '"<<source<<"'"<<endl;
-+  g_log<<Logger::Warning<<"Reading random entropy from '"<<source<<"'"<<endl;
- 
-   int fd=open(source.c_str(), O_RDONLY);
-   if(fd < 0) {
--    L<<Logger::Error<<"Unable to open source of random '"<<source<<"': "<<stringerror()<<endl;
-+    g_log<<Logger::Error<<"Unable to open source of random '"<<source<<"': "<<stringerror()<<endl;
-     exit(EXIT_FAILURE);
-   }
-   char seed[16];
-@@ -24,12 +24,12 @@ void seedRandom(const string& source)
-   while(pos!=sizeof(seed)) {
-     ret = read(fd, seed+pos, sizeof(seed)-pos);
-     if(ret < 0) { 
--      L<<Logger::Error<<"Unable to read random seed from "<<source<<": "<<stringerror()<<endl;
-+      g_log<<Logger::Error<<"Unable to read random seed from "<<source<<": "<<stringerror()<<endl;
-       close(fd);
-       exit(EXIT_FAILURE);
-     }
-     if(!ret) {
--      L<<Logger::Error<<"Unable to read random seed from "<<source<<": end of file"<<endl;
-+      g_log<<Logger::Error<<"Unable to read random seed from "<<source<<": end of file"<<endl;
-       close(fd);
-       exit(EXIT_FAILURE);
-     }
-diff --git a/rec-carbon.cc b/rec-carbon.cc
-index f8098ed..797d92b 100644
---- a/rec-carbon.cc
-+++ b/rec-carbon.cc
-@@ -60,20 +60,20 @@ try
- 
-     int ret=asendtcp(msg, &s);     // this will actually do the right thing waiting on the connect
-     if(ret < 0)
--      L<<Logger::Warning<<"Error writing carbon data to "<<remote.toStringWithPort()<<": "<<strerror(errno)<<endl;
-+      g_log<<Logger::Warning<<"Error writing carbon data to "<<remote.toStringWithPort()<<": "<<strerror(errno)<<endl;
-     if(ret==0)
--      L<<Logger::Warning<<"Timeout connecting/writing carbon data to "<<remote.toStringWithPort()<<endl;
-+      g_log<<Logger::Warning<<"Timeout connecting/writing carbon data to "<<remote.toStringWithPort()<<endl;
-   }
-  }
- catch(PDNSException& e)
- {
--  L<<Logger::Error<<"Error in carbon thread: "<<e.reason<<endl;
-+  g_log<<Logger::Error<<"Error in carbon thread: "<<e.reason<<endl;
- }
- catch(std::exception& e)
- {
--  L<<Logger::Error<<"Error in carbon thread: "<<e.what()<<endl;
-+  g_log<<Logger::Error<<"Error in carbon thread: "<<e.what()<<endl;
- }
- catch(...)
- {
--  L<<Logger::Error<<"Unknown error in carbon thread"<<endl;
-+  g_log<<Logger::Error<<"Unknown error in carbon thread"<<endl;
- }
-diff --git a/rec-lua-conf.cc b/rec-lua-conf.cc
-index e68836f..a3be927 100644
---- a/rec-lua-conf.cc
-+++ b/rec-lua-conf.cc
-@@ -327,11 +327,11 @@ void loadRecursorLuaConfig(const std::string& fname, bool checkOnly)
-           t.detach();
-         }
-         catch(const std::exception& e) {
--          L<<Logger::Error<<"Problem starting RPZIXFRTracker thread: "<<e.what()<<endl;
-+          g_log<<Logger::Error<<"Problem starting RPZIXFRTracker thread: "<<e.what()<<endl;
-           exit(1);  // FIXME proper exit code?
-         }
-         catch(const PDNSException& e) {
--          L<<Logger::Error<<"Problem starting RPZIXFRTracker thread: "<<e.reason<<endl;
-+          g_log<<Logger::Error<<"Problem starting RPZIXFRTracker thread: "<<e.reason<<endl;
-           exit(1);  // FIXME proper exit code?
-         }
-       }
-diff --git a/rec-snmp.cc b/rec-snmp.cc
-index 4669755..f240550 100644
---- a/rec-snmp.cc
-+++ b/rec-snmp.cc
-@@ -145,12 +145,12 @@ static int handleCounter64Stats(netsnmp_mib_handler* handler,
- static void registerCounter64Stat(const char* name, const oid statOID[], size_t statOIDLength)
- {
-   if (statOIDLength != OID_LENGTH(questionsOID)) {
--    L<<Logger::Error<<"Invalid OID for SNMP Counter64 statistic "<<std::string(name)<<endl;
-+    g_log<<Logger::Error<<"Invalid OID for SNMP Counter64 statistic "<<std::string(name)<<endl;
-     return;
-   }
- 
-   if (s_statsMap.find(statOID[statOIDLength - 1]) != s_statsMap.end()) {
--    L<<Logger::Error<<"OID for SNMP Counter64 statistic "<<std::string(name)<<" has already been registered"<<endl;
-+    g_log<<Logger::Error<<"OID for SNMP Counter64 statistic "<<std::string(name)<<" has already been registered"<<endl;
-     return;
-   }
- 
-diff --git a/rec_channel_rec.cc b/rec_channel_rec.cc
-index 17dddd0..9b9beeb 100644
---- a/rec_channel_rec.cc
-+++ b/rec_channel_rec.cc
-@@ -384,7 +384,7 @@ string doSetDnssecLogBogus(T begin, T end)
- 
-   if (pdns_iequals(*begin, "on") || pdns_iequals(*begin, "yes")) {
-     if (!g_dnssecLogBogus) {
--      L<<Logger::Warning<<"Enabling DNSSEC Bogus logging, requested via control channel"<<endl;
-+      g_log<<Logger::Warning<<"Enabling DNSSEC Bogus logging, requested via control channel"<<endl;
-       g_dnssecLogBogus = true;
-       return "DNSSEC Bogus logging enabled\n";
-     }
-@@ -393,7 +393,7 @@ string doSetDnssecLogBogus(T begin, T end)
- 
-   if (pdns_iequals(*begin, "off") || pdns_iequals(*begin, "no")) {
-     if (g_dnssecLogBogus) {
--      L<<Logger::Warning<<"Disabling DNSSEC Bogus logging, requested via control channel"<<endl;
-+      g_log<<Logger::Warning<<"Disabling DNSSEC Bogus logging, requested via control channel"<<endl;
-       g_dnssecLogBogus = false;
-       return "DNSSEC Bogus logging disabled\n";
-     }
-@@ -431,7 +431,7 @@ string doAddNTA(T begin, T end)
-     if (begin != end)
-       why += " ";
-   }
--  L<<Logger::Warning<<"Adding Negative Trust Anchor for "<<who<<" with reason '"<<why<<"', requested via control channel"<<endl;
-+  g_log<<Logger::Warning<<"Adding Negative Trust Anchor for "<<who<<" with reason '"<<why<<"', requested via control channel"<<endl;
-   g_luaconfs.modify([who, why](LuaConfigItems& lci) {
-       lci.negAnchors[who] = why;
-       });
-@@ -449,7 +449,7 @@ string doClearNTA(T begin, T end)
-     return "No Negative Trust Anchor specified, doing nothing.\n";
- 
-   if (begin + 1 == end && *begin == "*"){
--    L<<Logger::Warning<<"Clearing all Negative Trust Anchors, requested via control channel"<<endl;
-+    g_log<<Logger::Warning<<"Clearing all Negative Trust Anchors, requested via control channel"<<endl;
-     g_luaconfs.modify([](LuaConfigItems& lci) {
-         lci.negAnchors.clear();
-       });
-@@ -477,7 +477,7 @@ string doClearNTA(T begin, T end)
-   string removed("");
-   bool first(true);
-   for (auto const &entry : toRemove) {
--    L<<Logger::Warning<<"Clearing Negative Trust Anchor for "<<entry<<", requested via control channel"<<endl;
-+    g_log<<Logger::Warning<<"Clearing Negative Trust Anchor for "<<entry<<", requested via control channel"<<endl;
-     g_luaconfs.modify([entry](LuaConfigItems& lci) {
-         lci.negAnchors.erase(entry);
-       });
-@@ -531,17 +531,17 @@ string doAddTA(T begin, T end)
-   }
- 
-   try {
--    L<<Logger::Warning<<"Adding Trust Anchor for "<<who<<" with data '"<<what<<"', requested via control channel";
-+    g_log<<Logger::Warning<<"Adding Trust Anchor for "<<who<<" with data '"<<what<<"', requested via control channel";
-     g_luaconfs.modify([who, what](LuaConfigItems& lci) {
-       auto ds = unique_ptr<DSRecordContent>(dynamic_cast<DSRecordContent*>(DSRecordContent::make(what)));
-       lci.dsAnchors[who].insert(*ds);
-       });
-     broadcastAccFunction<uint64_t>(boost::bind(pleaseWipePacketCache, who, true));
--    L<<Logger::Warning<<endl;
-+    g_log<<Logger::Warning<<endl;
-     return "Added Trust Anchor for " + who.toStringRootDot() + " with data " + what + "\n";
-   }
-   catch(std::exception &e) {
--    L<<Logger::Warning<<", failed: "<<e.what()<<endl;
-+    g_log<<Logger::Warning<<", failed: "<<e.what()<<endl;
-     return "Unable to add Trust Anchor for " + who.toStringRootDot() + ": " + e.what() + "\n";
-   }
- }
-@@ -576,7 +576,7 @@ string doClearTA(T begin, T end)
-   string removed("");
-   bool first(true);
-   for (auto const &entry : toRemove) {
--    L<<Logger::Warning<<"Removing Trust Anchor for "<<entry<<", requested via control channel"<<endl;
-+    g_log<<Logger::Warning<<"Removing Trust Anchor for "<<entry<<", requested via control channel"<<endl;
-     g_luaconfs.modify([entry](LuaConfigItems& lci) {
-         lci.dsAnchors.erase(entry);
-       });
-@@ -984,7 +984,7 @@ void registerAllStats()
- 
- static void doExitGeneric(bool nicely)
- {
--  L<<Logger::Error<<"Exiting on user request"<<endl;
-+  g_log<<Logger::Error<<"Exiting on user request"<<endl;
-   extern RecursorControlChannel s_rcc;
-   s_rcc.~RecursorControlChannel(); 
- 
-@@ -1305,7 +1305,7 @@ string RecursorControlParser::getAnswer(const string& question, RecursorControlP
- 
-     try {
-       loadRecursorLuaConfig(::arg()["lua-config-file"], false);
--      L<<Logger::Warning<<"Reloaded Lua configuration file '"<<::arg()["lua-config-file"]<<"', requested via control channel"<<endl;
-+      g_log<<Logger::Warning<<"Reloaded Lua configuration file '"<<::arg()["lua-config-file"]<<"', requested via control channel"<<endl;
-       return "Reloaded Lua configuration file '"+::arg()["lua-config-file"]+"'\n";
-     }
-     catch(std::exception& e) {
-@@ -1330,7 +1330,7 @@ string RecursorControlParser::getAnswer(const string& question, RecursorControlP
- 
-   if(cmd=="reload-acls") {
-     if(!::arg()["chroot"].empty()) {
--      L<<Logger::Error<<"Unable to reload ACL when chroot()'ed, requested via control channel"<<endl;
-+      g_log<<Logger::Error<<"Unable to reload ACL when chroot()'ed, requested via control channel"<<endl;
-       return "Unable to reload ACL when chroot()'ed, please restart\n";
-     }
- 
-@@ -1339,12 +1339,12 @@ string RecursorControlParser::getAnswer(const string& question, RecursorControlP
-     } 
-     catch(std::exception& e) 
-     {
--      L<<Logger::Error<<"Reloading ACLs failed (Exception: "<<e.what()<<")"<<endl;
-+      g_log<<Logger::Error<<"Reloading ACLs failed (Exception: "<<e.what()<<")"<<endl;
-       return e.what() + string("\n");
-     }
-     catch(PDNSException& ae)
-     {
--      L<<Logger::Error<<"Reloading ACLs failed (PDNSException: "<<ae.reason<<")"<<endl;
-+      g_log<<Logger::Error<<"Reloading ACLs failed (PDNSException: "<<ae.reason<<")"<<endl;
-       return ae.reason + string("\n");
-     }
-     return "ok\n";
-@@ -1383,7 +1383,7 @@ string RecursorControlParser::getAnswer(const string& question, RecursorControlP
- 
-   if(cmd=="reload-zones") {
-     if(!::arg()["chroot"].empty()) {
--      L<<Logger::Error<<"Unable to reload zones and forwards when chroot()'ed, requested via control channel"<<endl;
-+      g_log<<Logger::Error<<"Unable to reload zones and forwards when chroot()'ed, requested via control channel"<<endl;
-       return "Unable to reload zones and forwards when chroot()'ed, please restart\n";
-     }
-     return reloadAuthAndForwards();
-diff --git a/recursor_cache.hh b/recursor_cache.hh
-index 2e40d4b..bd6f35c 100644
---- a/recursor_cache.hh
-+++ b/recursor_cache.hh
-@@ -30,7 +30,7 @@
- #include <iostream>
- #include "dnsrecords.hh"
- #include <boost/utility.hpp>
--#undef L
-+#undef g_log
- #include <boost/multi_index_container.hpp>
- #include <boost/multi_index/ordered_index.hpp>
- #include <boost/multi_index/hashed_index.hpp>
-@@ -42,7 +42,7 @@
- #include "validate.hh"
- #undef max
- 
--#define L theL()
-+#define g_log theL()
- #include "namespaces.hh"
- using namespace ::boost::multi_index;
- 
-diff --git a/reczones.cc b/reczones.cc
-index 7adb343..2021ce8 100644
---- a/reczones.cc
-+++ b/reczones.cc
-@@ -119,10 +119,10 @@ static void makeNameToIPZone(std::shared_ptr<SyncRes::domainmap_t> newMap, const
-   ad.d_records.insert(dr);
-   
-   if(newMap->count(dr.d_name)) {  
--    L<<Logger::Warning<<"Hosts file will not overwrite zone '"<<dr.d_name<<"' already loaded"<<endl;
-+    g_log<<Logger::Warning<<"Hosts file will not overwrite zone '"<<dr.d_name<<"' already loaded"<<endl;
-   }
-   else {
--    L<<Logger::Warning<<"Inserting forward zone '"<<dr.d_name<<"' based on hosts file"<<endl;
-+    g_log<<Logger::Warning<<"Inserting forward zone '"<<dr.d_name<<"' based on hosts file"<<endl;
-     ad.d_name=dr.d_name;
-     (*newMap)[ad.d_name]=ad;
-   }
-@@ -165,11 +165,11 @@ static void makeIPToNamesZone(std::shared_ptr<SyncRes::domainmap_t> newMap, cons
-     }
- 
-   if(newMap->count(dr.d_name)) {  
--    L<<Logger::Warning<<"Will not overwrite zone '"<<dr.d_name<<"' already loaded"<<endl;
-+    g_log<<Logger::Warning<<"Will not overwrite zone '"<<dr.d_name<<"' already loaded"<<endl;
-   }
-   else {
-     if(ipparts.size()==4)
--      L<<Logger::Warning<<"Inserting reverse zone '"<<dr.d_name<<"' based on hosts file"<<endl;
-+      g_log<<Logger::Warning<<"Inserting reverse zone '"<<dr.d_name<<"' based on hosts file"<<endl;
-     ad.d_name = dr.d_name;
-     (*newMap)[ad.d_name]=ad;
-   }
-@@ -215,15 +215,15 @@ void convertServersForAD(const std::string& input, SyncRes::AuthDomain& ad, cons
- 
-   for(vector<string>::const_iterator iter = servers.begin(); iter != servers.end(); ++iter) {
-     if(verbose && iter != servers.begin()) 
--      L<<", ";
-+      g_log<<", ";
- 
-     ComboAddress addr=parseIPAndPort(*iter, 53);
-     if(verbose)
--      L<<addr.toStringWithPort();
-+      g_log<<addr.toStringWithPort();
-     ad.d_servers.push_back(addr);
-   }
-   if(verbose)
--    L<<endl;
-+    g_log<<endl;
- }
- 
- void* pleaseWipeNegCache()
-@@ -243,7 +243,7 @@ string reloadAuthAndForwards()
-   std::shared_ptr<SyncRes::domainmap_t> original=SyncRes::getDomainMap();
-   
-   try {
--    L<<Logger::Warning<<"Reloading zones, purging data from cache"<<endl;
-+    g_log<<Logger::Warning<<"Reloading zones, purging data from cache"<<endl;
- 
-     if (original) {
-       for(const auto& i : *original) {
-@@ -302,13 +302,13 @@ string reloadAuthAndForwards()
-     return "ok\n";
-   }
-   catch(std::exception& e) {
--    L<<Logger::Error<<"Encountered error reloading zones, keeping original data: "<<e.what()<<endl;
-+    g_log<<Logger::Error<<"Encountered error reloading zones, keeping original data: "<<e.what()<<endl;
-   }
-   catch(PDNSException& ae) {
--    L<<Logger::Error<<"Encountered error reloading zones, keeping original data: "<<ae.reason<<endl;
-+    g_log<<Logger::Error<<"Encountered error reloading zones, keeping original data: "<<ae.reason<<endl;
-   }
-   catch(...) {
--    L<<Logger::Error<<"Encountered unknown error reloading zones, keeping original data"<<endl;
-+    g_log<<Logger::Error<<"Encountered unknown error reloading zones, keeping original data"<<endl;
-   }
-   return "reloading failed, see log\n";
- }
-@@ -336,7 +336,7 @@ std::shared_ptr<SyncRes::domainmap_t> parseAuthAndForwards()
-       // headers.first=toCanonic("", headers.first);
-       if(n==0) {
-         ad.d_rdForward = false;
--        L<<Logger::Error<<"Parsing authoritative data for zone '"<<headers.first<<"' from file '"<<headers.second<<"'"<<endl;
-+        g_log<<Logger::Error<<"Parsing authoritative data for zone '"<<headers.first<<"' from file '"<<headers.second<<"'"<<endl;
-         ZoneParserTNG zpt(headers.second, DNSName(headers.first));
-         DNSResourceRecord rr;
- 	DNSRecord dr;
-@@ -356,13 +356,13 @@ std::shared_ptr<SyncRes::domainmap_t> parseAuthAndForwards()
-         }
-       }
-       else {
--        L<<Logger::Error<<"Redirecting queries for zone '"<<headers.first<<"' ";
-+        g_log<<Logger::Error<<"Redirecting queries for zone '"<<headers.first<<"' ";
-         if(n == 2) {
--          L<<"with recursion ";
-+          g_log<<"with recursion ";
-           ad.d_rdForward = true;
-         }
-         else ad.d_rdForward = false;
--        L<<"to: ";
-+        g_log<<"to: ";
-         
-         convertServersForAD(headers.second, ad, ";");
-         if(n == 2) {
-@@ -376,7 +376,7 @@ std::shared_ptr<SyncRes::domainmap_t> parseAuthAndForwards()
-   }
-   
-   if(!::arg()["forward-zones-file"].empty()) {
--    L<<Logger::Warning<<"Reading zone forwarding information from '"<<::arg()["forward-zones-file"]<<"'"<<endl;
-+    g_log<<Logger::Warning<<"Reading zone forwarding information from '"<<::arg()["forward-zones-file"]<<"'"<<endl;
-     SyncRes::AuthDomain ad;
-     FILE *rfp=fopen(::arg()["forward-zones-file"].c_str(), "r");
- 
-@@ -421,7 +421,7 @@ std::shared_ptr<SyncRes::domainmap_t> parseAuthAndForwards()
-       ad.d_name = DNSName(domain);
-       (*newMap)[ad.d_name]=ad;
-     }
--    L<<Logger::Warning<<"Done parsing " << newMap->size() - before<<" forwarding instructions from file '"<<::arg()["forward-zones-file"]<<"'"<<endl;
-+    g_log<<Logger::Warning<<"Done parsing " << newMap->size() - before<<" forwarding instructions from file '"<<::arg()["forward-zones-file"]<<"'"<<endl;
-   }
- 
-   if(::arg().mustDo("export-etc-hosts")) {
-@@ -430,7 +430,7 @@ std::shared_ptr<SyncRes::domainmap_t> parseAuthAndForwards()
-     
-     ifstream ifs(fname.c_str());
-     if(!ifs) {
--      L<<Logger::Warning<<"Could not open /etc/hosts for reading"<<endl;
-+      g_log<<Logger::Warning<<"Could not open /etc/hosts for reading"<<endl;
-     }
-     else {
-       string searchSuffix = ::arg()["export-etc-hosts-search-suffix"];
-@@ -462,7 +462,7 @@ std::shared_ptr<SyncRes::domainmap_t> parseAuthAndForwards()
-     }
-   }
-   if(::arg().mustDo("serve-rfc1918")) {
--    L<<Logger::Warning<<"Inserting rfc 1918 private space zones"<<endl;
-+    g_log<<Logger::Warning<<"Inserting rfc 1918 private space zones"<<endl;
-     parts.clear();
-     parts.push_back("127");
-     makeIPToNamesZone(newMap, parts);
-diff --git a/remote_logger.cc b/remote_logger.cc
-index 07ab13e..ce0eeb3 100644
---- a/remote_logger.cc
-+++ b/remote_logger.cc
-@@ -21,7 +21,7 @@ bool RemoteLogger::reconnect()
-   }
-   catch(const std::exception& e) {
- #ifdef WE_ARE_RECURSOR
--    L<<Logger::Warning<<"Error connecting to remote logger "<<d_remote.toStringWithPort()<<": "<<e.what()<<std::endl;
-+    g_log<<Logger::Warning<<"Error connecting to remote logger "<<d_remote.toStringWithPort()<<": "<<e.what()<<std::endl;
- #else
-     warnlog("Error connecting to remote logger %s: %s", d_remote.toStringWithPort(), e.what());
- #endif
-@@ -54,7 +54,7 @@ void RemoteLogger::worker()
-     }
-     catch(const std::runtime_error& e) {
- #ifdef WE_ARE_RECURSOR
--      L<<Logger::Info<<"Error sending data to remote logger "<<d_remote.toStringWithPort()<<": "<< e.what()<<endl;
-+      g_log<<Logger::Info<<"Error sending data to remote logger "<<d_remote.toStringWithPort()<<": "<< e.what()<<endl;
- #else
-       vinfolog("Error sending data to remote logger (%s): %s", d_remote.toStringWithPort(), e.what());
- #endif
-diff --git a/rpzloader.cc b/rpzloader.cc
-index 815fb84..c36dbee 100644
---- a/rpzloader.cc
-+++ b/rpzloader.cc
-@@ -110,7 +110,7 @@ void RPZRecordToPolicy(const DNSRecord& dr, std::shared_ptr<DNSFilterEngine::Zon
-     else if(!crcTarget.empty() && !crcTarget.isRoot() && crcTarget.getRawLabel(crcTarget.countLabels() - 1).compare(0, rpzPrefix.length(), rpzPrefix) == 0) {
-       /* this is very likely an higher format number or a configuration error,
-          let's just ignore it. */
--      L<<Logger::Info<<"Discarding unsupported RPZ entry "<<crcTarget.toString()<<" for "<<dr.d_name<<endl;
-+      g_log<<Logger::Info<<"Discarding unsupported RPZ entry "<<crcTarget.toString()<<" for "<<dr.d_name<<endl;
-       return;
-     }
-     else {
-@@ -177,9 +177,9 @@ void RPZRecordToPolicy(const DNSRecord& dr, std::shared_ptr<DNSFilterEngine::Zon
- 
- shared_ptr<SOARecordContent> loadRPZFromServer(const ComboAddress& master, const DNSName& zoneName, std::shared_ptr<DNSFilterEngine::Zone> zone, boost::optional<DNSFilterEngine::Policy> defpol, uint32_t maxTTL, const TSIGTriplet& tt, size_t maxReceivedBytes, const ComboAddress& localAddress, uint16_t axfrTimeout)
- {
--  L<<Logger::Warning<<"Loading RPZ zone '"<<zoneName<<"' from "<<master.toStringWithPort()<<endl;
-+  g_log<<Logger::Warning<<"Loading RPZ zone '"<<zoneName<<"' from "<<master.toStringWithPort()<<endl;
-   if(!tt.name.empty())
--    L<<Logger::Warning<<"With TSIG key '"<<tt.name<<"' of algorithm '"<<tt.algo<<"'"<<endl;
-+    g_log<<Logger::Warning<<"With TSIG key '"<<tt.name<<"' of algorithm '"<<tt.algo<<"'"<<endl;
- 
-   ComboAddress local(localAddress);
-   if (local == ComboAddress())
-@@ -213,11 +213,11 @@ shared_ptr<SOARecordContent> loadRPZFromServer(const ComboAddress& master, const
-       throw PDNSException("Total AXFR time exceeded!");
-     }
-     if(last != time(0)) {
--      L<<Logger::Info<<"Loaded & indexed "<<nrecords<<" policy records so far"<<endl;
-+      g_log<<Logger::Info<<"Loaded & indexed "<<nrecords<<" policy records so far"<<endl;
-       last=time(0);
-     }
-   }
--  L<<Logger::Info<<"Done: "<<nrecords<<" policy records active, SOA: "<<sr->getZoneRepresentation()<<endl;
-+  g_log<<Logger::Info<<"Done: "<<nrecords<<" policy records active, SOA: "<<sr->getZoneRepresentation()<<endl;
-   return sr;
- }
- 
-@@ -289,7 +289,7 @@ void RPZIXFRTracker(const ComboAddress& master, boost::optional<DNSFilterEngine:
-   /* we can _never_ modify this zone directly, we need to do a full copy then replace the existing zone */
-   std::shared_ptr<DNSFilterEngine::Zone> oldZone = luaconfsLocal->dfe.getZone(zoneIdx);
-   if (!oldZone) {
--    L<<Logger::Error<<"Unable to retrieve RPZ zone with index "<<zoneIdx<<" from the configuration, exiting"<<endl;
-+    g_log<<Logger::Error<<"Unable to retrieve RPZ zone with index "<<zoneIdx<<" from the configuration, exiting"<<endl;
-     return;
-   }
-   uint32_t refresh = oldZone->getRefresh();
-@@ -337,7 +337,7 @@ void RPZIXFRTracker(const ComboAddress& master, boost::optional<DNSFilterEngine:
- 
-     sleep(refresh);
- 
--    L<<Logger::Info<<"Getting IXFR deltas for "<<zoneName<<" from "<<master.toStringWithPort()<<", our serial: "<<getRR<SOARecordContent>(dr)->d_st.serial<<endl;
-+    g_log<<Logger::Info<<"Getting IXFR deltas for "<<zoneName<<" from "<<master.toStringWithPort()<<", our serial: "<<getRR<SOARecordContent>(dr)->d_st.serial<<endl;
-     vector<pair<vector<DNSRecord>, vector<DNSRecord> > > deltas;
- 
-     ComboAddress local(localAddress);
-@@ -347,13 +347,13 @@ void RPZIXFRTracker(const ComboAddress& master, boost::optional<DNSFilterEngine:
-     try {
-       deltas = getIXFRDeltas(master, zoneName, dr, tt, &local, maxReceivedBytes);
-     } catch(std::runtime_error& e ){
--      L<<Logger::Warning<<e.what()<<endl;
-+      g_log<<Logger::Warning<<e.what()<<endl;
-       incRPZFailedTransfers(polName);
-       continue;
-     }
-     if(deltas.empty())
-       continue;
--    L<<Logger::Info<<"Processing "<<deltas.size()<<" delta"<<addS(deltas)<<" for RPZ "<<zoneName<<endl;
-+    g_log<<Logger::Info<<"Processing "<<deltas.size()<<" delta"<<addS(deltas)<<" for RPZ "<<zoneName<<endl;
- 
-     oldZone = luaconfsLocal->dfe.getZone(zoneIdx);
-     /* we need to make a _full copy_ of the zone we are going to work on */
-@@ -365,7 +365,7 @@ void RPZIXFRTracker(const ComboAddress& master, boost::optional<DNSFilterEngine:
-       const auto& remove = delta.first;
-       const auto& add = delta.second;
-       if(remove.empty()) {
--        L<<Logger::Warning<<"IXFR update is a whole new zone"<<endl;
-+        g_log<<Logger::Warning<<"IXFR update is a whole new zone"<<endl;
-         newZone->clear();
-         fullUpdate = true;
-       }
-@@ -378,11 +378,11 @@ void RPZIXFRTracker(const ComboAddress& master, boost::optional<DNSFilterEngine:
- 	    //	    cout<<"Got good removal of SOA serial "<<oldsr->d_st.serial<<endl;
- 	  }
- 	  else
--	    L<<Logger::Error<<"GOT WRONG SOA SERIAL REMOVAL, SHOULD TRIGGER WHOLE RELOAD"<<endl;
-+	    g_log<<Logger::Error<<"GOT WRONG SOA SERIAL REMOVAL, SHOULD TRIGGER WHOLE RELOAD"<<endl;
- 	}
- 	else {
-           totremove++;
--	  L<<(g_logRPZChanges ? Logger::Info : Logger::Debug)<<"Had removal of "<<rr.d_name<<" from RPZ zone "<<zoneName<<endl;
-+	  g_log<<(g_logRPZChanges ? Logger::Info : Logger::Debug)<<"Had removal of "<<rr.d_name<<" from RPZ zone "<<zoneName<<endl;
- 	  RPZRecordToPolicy(rr, newZone, false, defpol, maxTTL);
- 	}
-       }
-@@ -392,19 +392,19 @@ void RPZIXFRTracker(const ComboAddress& master, boost::optional<DNSFilterEngine:
-           continue;
- 	if(rr.d_type == QType::SOA) {
- 	  auto newsr = getRR<SOARecordContent>(rr);
--	  //	  L<<Logger::Info<<"New SOA serial for "<<zoneName<<": "<<newsr->d_st.serial<<endl;
-+	  //	  g_log<<Logger::Info<<"New SOA serial for "<<zoneName<<": "<<newsr->d_st.serial<<endl;
- 	  if (newsr) {
- 	    sr = newsr;
- 	  }
- 	}
- 	else {
-           totadd++;
--	  L<<(g_logRPZChanges ? Logger::Info : Logger::Debug)<<"Had addition of "<<rr.d_name<<" to RPZ zone "<<zoneName<<endl;
-+	  g_log<<(g_logRPZChanges ? Logger::Info : Logger::Debug)<<"Had addition of "<<rr.d_name<<" to RPZ zone "<<zoneName<<endl;
- 	  RPZRecordToPolicy(rr, newZone, true, defpol, maxTTL);
- 	}
-       }
-     }
--    L<<Logger::Info<<"Had "<<totremove<<" RPZ removal"<<addS(totremove)<<", "<<totadd<<" addition"<<addS(totadd)<<" for "<<zoneName<<" New serial: "<<sr->d_st.serial<<endl;
-+    g_log<<Logger::Info<<"Had "<<totremove<<" RPZ removal"<<addS(totremove)<<", "<<totadd<<" addition"<<addS(totadd)<<" for "<<zoneName<<" New serial: "<<sr->d_st.serial<<endl;
-     newZone->setSerial(sr->d_st.serial);
-     setRPZZoneNewState(polName, sr->d_st.serial, newZone->size(), fullUpdate);
- 
-diff --git a/secpoll-recursor.cc b/secpoll-recursor.cc
-index 3248b84..d88a7eb 100644
---- a/secpoll-recursor.cc
-+++ b/secpoll-recursor.cc
-@@ -55,7 +55,7 @@ void doSecPoll(time_t* last_secpoll)
-   }
- 
-   if(state == Bogus) {
--    L<<Logger::Error<<"Could not retrieve security status update for '" +pkgv+ "' on '"<<query<<"', DNSSEC validation result was Bogus!"<<endl;
-+    g_log<<Logger::Error<<"Could not retrieve security status update for '" +pkgv+ "' on '"<<query<<"', DNSSEC validation result was Bogus!"<<endl;
-     if(g_security_status == 1) // If we were OK, go to unknown
-       g_security_status = 0;
-     return;
-@@ -79,18 +79,18 @@ void doSecPoll(time_t* last_secpoll)
-   }
-   else {
-     if(pkgv.find("0.0.") != 0)
--      L<<Logger::Warning<<"Could not retrieve security status update for '" +pkgv+ "' on '"<<query<<"', RCODE = "<< RCode::to_s(res)<<endl;
-+      g_log<<Logger::Warning<<"Could not retrieve security status update for '" +pkgv+ "' on '"<<query<<"', RCODE = "<< RCode::to_s(res)<<endl;
-     else
--      L<<Logger::Warning<<"Ignoring response for security status update, this is a non-release version."<<endl;
-+      g_log<<Logger::Warning<<"Ignoring response for security status update, this is a non-release version."<<endl;
- 
-     if(g_security_status == 1) // it was ok, now it is unknown
-       g_security_status = 0;
-   }
- 
-   if(g_security_status == 2) {
--    L<<Logger::Error<<"PowerDNS Security Update Recommended: "<<g_security_message<<endl;
-+    g_log<<Logger::Error<<"PowerDNS Security Update Recommended: "<<g_security_message<<endl;
-   }
-   else if(g_security_status == 3) {
--    L<<Logger::Error<<"PowerDNS Security Update Mandatory: "<<g_security_message<<endl;
-+    g_log<<Logger::Error<<"PowerDNS Security Update Mandatory: "<<g_security_message<<endl;
-   }
- }
-diff --git a/syncres.cc b/syncres.cc
-index 4449534..eabc9d9 100644
---- a/syncres.cc
-+++ b/syncres.cc
-@@ -76,7 +76,7 @@ bool SyncRes::s_nopacketcache;
- bool SyncRes::s_rootNXTrust;
- bool SyncRes::s_noEDNS;
- 
--#define LOG(x) if(d_lm == Log) { L <<Logger::Warning << x; } else if(d_lm == Store) { d_trace << x; }
-+#define LOG(x) if(d_lm == Log) { g_log <<Logger::Warning << x; } else if(d_lm == Store) { d_trace << x; }
- 
- static void accountAuthLatency(int usec, int family)
- {
-@@ -2859,23 +2859,23 @@ int SyncRes::getRootNS(struct timeval now, asyncresolve_t asyncCallback) {
-     return res;
-   }
-   catch(const PDNSException& e) {
--    L<<Logger::Error<<"Failed to update . records, got an exception: "<<e.reason<<endl;
-+    g_log<<Logger::Error<<"Failed to update . records, got an exception: "<<e.reason<<endl;
-   }
-   catch(const ImmediateServFailException& e) {
--    L<<Logger::Error<<"Failed to update . records, got an exception: "<<e.reason<<endl;
-+    g_log<<Logger::Error<<"Failed to update . records, got an exception: "<<e.reason<<endl;
-   }
-   catch(const std::exception& e) {
--    L<<Logger::Error<<"Failed to update . records, got an exception: "<<e.what()<<endl;
-+    g_log<<Logger::Error<<"Failed to update . records, got an exception: "<<e.what()<<endl;
-   }
-   catch(...) {
--    L<<Logger::Error<<"Failed to update . records, got an exception"<<endl;
-+    g_log<<Logger::Error<<"Failed to update . records, got an exception"<<endl;
-   }
- 
-   if(!res) {
--    L<<Logger::Notice<<"Refreshed . records"<<endl;
-+    g_log<<Logger::Notice<<"Refreshed . records"<<endl;
-   }
-   else
--    L<<Logger::Error<<"Failed to update . records, RCODE="<<res<<endl;
-+    g_log<<Logger::Error<<"Failed to update . records, RCODE="<<res<<endl;
- 
-   return res;
- }
-diff --git a/test-syncres_cc.cc b/test-syncres_cc.cc
-index d02c613..01be477 100644
---- a/test-syncres_cc.cc
-+++ b/test-syncres_cc.cc
-@@ -101,16 +101,16 @@ LuaConfigItems::LuaConfigItems()
- 
- static void init(bool debug=false)
- {
--  L.setName("test");
--  L.disableSyslog(true);
-+  g_log.setName("test");
-+  g_log.disableSyslog(true);
- 
-   if (debug) {
--    L.setLoglevel((Logger::Urgency)(6)); // info and up
--    L.toConsole(Logger::Info);
-+    g_log.setLoglevel((Logger::Urgency)(6)); // info and up
-+    g_log.toConsole(Logger::Info);
-   }
-   else {
--    L.setLoglevel(Logger::None);
--    L.toConsole(Logger::Error);
-+    g_log.setLoglevel(Logger::None);
-+    g_log.toConsole(Logger::Error);
-   }
- 
-   seedRandom("/dev/urandom");
-diff --git a/validate-recursor.cc b/validate-recursor.cc
-index a870c2e..4a31698 100644
---- a/validate-recursor.cc
-+++ b/validate-recursor.cc
-@@ -13,7 +13,7 @@ bool checkDNSSECDisabled() {
- bool warnIfDNSSECDisabled(const string& msg) {
-   if(g_dnssecmode == DNSSECMode::Off) {
-     if (!msg.empty())
--      L<<Logger::Warning<<msg<<endl;
-+      g_log<<Logger::Warning<<msg<<endl;
-     return true;
-   }
-   return false;
-diff --git a/validate.cc b/validate.cc
-index 00afcd7..ca429de 100644
---- a/validate.cc
-+++ b/validate.cc
-@@ -8,7 +8,7 @@
- bool g_dnssecLOG{false};
- uint16_t g_maxNSEC3Iterations{0};
- 
--#define LOG(x) if(g_dnssecLOG) { L <<Logger::Warning << x; }
-+#define LOG(x) if(g_dnssecLOG) { g_log <<Logger::Warning << x; }
- void dotEdge(DNSName zone, string type1, DNSName name1, string tag1, string type2, DNSName name2, string tag2, string color="");
- void dotNode(string type, DNSName name, string tag, string content);
- string dotName(string type, DNSName name, string tag);
-diff --git a/webserver.cc b/webserver.cc
-index f1a95f4..af0a17e 100644
---- a/webserver.cc
-+++ b/webserver.cc
-@@ -39,12 +39,12 @@ json11::Json HttpRequest::json()
- {
-   string err;
-   if(this->body.empty()) {
--    L<<Logger::Debug<<"HTTP: JSON document expected in request body, but body was empty" << endl;
-+    g_log<<Logger::Debug<<"HTTP: JSON document expected in request body, but body was empty" << endl;
-     throw HttpBadRequestException();
-   }
-   json11::Json doc = json11::Json::parse(this->body, err);
-   if (doc.is_null()) {
--    L<<Logger::Debug<<"HTTP: parsing of JSON document failed:" << err << endl;
-+    g_log<<Logger::Debug<<"HTTP: parsing of JSON document failed:" << err << endl;
-     throw HttpBadRequestException();
-   }
-   return doc;
-@@ -132,13 +132,13 @@ static void apiWrapper(WebServer::HandlerFunction handler, HttpRequest* req, Htt
-   resp->headers["access-control-allow-origin"] = "*";
- 
-   if (api_key.empty()) {
--    L<<Logger::Error<<"HTTP API Request \"" << req->url.path << "\": Authentication failed, API Key missing in config" << endl;
-+    g_log<<Logger::Error<<"HTTP API Request \"" << req->url.path << "\": Authentication failed, API Key missing in config" << endl;
-     throw HttpUnauthorizedException("X-API-Key");
-   }
-   bool auth_ok = req->compareHeader("x-api-key", api_key) || req->getvars["api-key"]==api_key;
-   
-   if (!auth_ok) {
--    L<<Logger::Error<<"HTTP Request \"" << req->url.path << "\": Authentication by API Key failed" << endl;
-+    g_log<<Logger::Error<<"HTTP Request \"" << req->url.path << "\": Authentication by API Key failed" << endl;
-     throw HttpUnauthorizedException("X-API-Key");
-   }
- 
-@@ -181,7 +181,7 @@ static void webWrapper(WebServer::HandlerFunction handler, HttpRequest* req, Htt
-   if (!web_password.empty()) {
-     bool auth_ok = req->compareAuthorization(web_password);
-     if (!auth_ok) {
--      L<<Logger::Debug<<"HTTP Request \"" << req->url.path << "\": Web Authentication failed" << endl;
-+      g_log<<Logger::Debug<<"HTTP Request \"" << req->url.path << "\": Web Authentication failed" << endl;
-       throw HttpUnauthorizedException("Basic");
-     }
-   }
-@@ -206,11 +206,11 @@ void WebServer::handleRequest(HttpRequest& req, HttpResponse& resp) const
- 
-   try {
-     if (!req.complete) {
--      L<<Logger::Debug<<"HTTP: Incomplete request" << endl;
-+      g_log<<Logger::Debug<<"HTTP: Incomplete request" << endl;
-       throw HttpBadRequestException();
-     }
- 
--    L<<Logger::Debug<<"HTTP: Handling request \"" << req.url.path << "\"" << endl;
-+    g_log<<Logger::Debug<<"HTTP: Handling request \"" << req.url.path << "\"" << endl;
- 
-     YaHTTP::strstr_map_t::iterator header;
- 
-@@ -225,33 +225,33 @@ void WebServer::handleRequest(HttpRequest& req, HttpResponse& resp) const
- 
-     YaHTTP::THandlerFunction handler;
-     if (!YaHTTP::Router::Route(&req, handler)) {
--      L<<Logger::Debug<<"HTTP: No route found for \"" << req.url.path << "\"" << endl;
-+      g_log<<Logger::Debug<<"HTTP: No route found for \"" << req.url.path << "\"" << endl;
-       throw HttpNotFoundException();
-     }
- 
-     try {
-       handler(&req, &resp);
--      L<<Logger::Debug<<"HTTP: Result for \"" << req.url.path << "\": " << resp.status << ", body length: " << resp.body.size() << endl;
-+      g_log<<Logger::Debug<<"HTTP: Result for \"" << req.url.path << "\": " << resp.status << ", body length: " << resp.body.size() << endl;
-     }
-     catch(HttpException&) {
-       throw;
-     }
-     catch(PDNSException &e) {
--      L<<Logger::Error<<"HTTP ISE for \""<< req.url.path << "\": Exception: " << e.reason << endl;
-+      g_log<<Logger::Error<<"HTTP ISE for \""<< req.url.path << "\": Exception: " << e.reason << endl;
-       throw HttpInternalServerErrorException();
-     }
-     catch(std::exception &e) {
--      L<<Logger::Error<<"HTTP ISE for \""<< req.url.path << "\": STL Exception: " << e.what() << endl;
-+      g_log<<Logger::Error<<"HTTP ISE for \""<< req.url.path << "\": STL Exception: " << e.what() << endl;
-       throw HttpInternalServerErrorException();
-     }
-     catch(...) {
--      L<<Logger::Error<<"HTTP ISE for \""<< req.url.path << "\": Unknown Exception" << endl;
-+      g_log<<Logger::Error<<"HTTP ISE for \""<< req.url.path << "\": Unknown Exception" << endl;
-       throw HttpInternalServerErrorException();
-     }
-   }
-   catch(HttpException &e) {
-     resp = e.response();
--    L<<Logger::Debug<<"HTTP: Error result for \"" << req.url.path << "\": " << resp.status << endl;
-+    g_log<<Logger::Debug<<"HTTP: Error result for \"" << req.url.path << "\": " << resp.status << endl;
-     string what = YaHTTP::Utility::status2text(resp.status);
-     if(req.accept_html) {
-       resp.headers["Content-Type"] = "text/html; charset=utf-8";
-@@ -311,14 +311,14 @@ try {
-   client->writenWithTimeout(reply.c_str(), reply.size(), timeout);
- }
- catch(PDNSException &e) {
--  L<<Logger::Error<<"HTTP Exception: "<<e.reason<<endl;
-+  g_log<<Logger::Error<<"HTTP Exception: "<<e.reason<<endl;
- }
- catch(std::exception &e) {
-   if(strstr(e.what(), "timeout")==0)
--    L<<Logger::Error<<"HTTP STL Exception: "<<e.what()<<endl;
-+    g_log<<Logger::Error<<"HTTP STL Exception: "<<e.what()<<endl;
- }
- catch(...) {
--  L<<Logger::Error<<"HTTP: Unknown exception"<<endl;
-+  g_log<<Logger::Error<<"HTTP: Unknown exception"<<endl;
- }
- 
- WebServer::WebServer(const string &listenaddress, int port) : d_server(nullptr)
-@@ -331,10 +331,10 @@ void WebServer::bind()
- {
-   try {
-     d_server = createServer();
--    L<<Logger::Warning<<"Listening for HTTP requests on "<<d_server->d_local.toStringWithPort()<<endl;
-+    g_log<<Logger::Warning<<"Listening for HTTP requests on "<<d_server->d_local.toStringWithPort()<<endl;
-   }
-   catch(NetworkError &e) {
--    L<<Logger::Error<<"Listening on HTTP socket failed: "<<e.what()<<endl;
-+    g_log<<Logger::Error<<"Listening on HTTP socket failed: "<<e.what()<<endl;
-     d_server = nullptr;
-   }
- }
-@@ -359,28 +359,28 @@ void WebServer::go()
-         } else {
-           ComboAddress remote;
-           if (client->getRemote(remote))
--            L<<Logger::Error<<"Webserver closing socket: remote ("<< remote.toString() <<") does not match 'webserver-allow-from'"<<endl;
-+            g_log<<Logger::Error<<"Webserver closing socket: remote ("<< remote.toString() <<") does not match 'webserver-allow-from'"<<endl;
-         }
-       }
-       catch(PDNSException &e) {
--        L<<Logger::Error<<"PDNSException while accepting a connection in main webserver thread: "<<e.reason<<endl;
-+        g_log<<Logger::Error<<"PDNSException while accepting a connection in main webserver thread: "<<e.reason<<endl;
-       }
-       catch(std::exception &e) {
--        L<<Logger::Error<<"STL Exception while accepting a connection in main webserver thread: "<<e.what()<<endl;
-+        g_log<<Logger::Error<<"STL Exception while accepting a connection in main webserver thread: "<<e.what()<<endl;
-       }
-       catch(...) {
--        L<<Logger::Error<<"Unknown exception while accepting a connection in main webserver thread"<<endl;
-+        g_log<<Logger::Error<<"Unknown exception while accepting a connection in main webserver thread"<<endl;
-       }
-     }
-   }
-   catch(PDNSException &e) {
--    L<<Logger::Error<<"PDNSException in main webserver thread: "<<e.reason<<endl;
-+    g_log<<Logger::Error<<"PDNSException in main webserver thread: "<<e.reason<<endl;
-   }
-   catch(std::exception &e) {
--    L<<Logger::Error<<"STL Exception in main webserver thread: "<<e.what()<<endl;
-+    g_log<<Logger::Error<<"STL Exception in main webserver thread: "<<e.what()<<endl;
-   }
-   catch(...) {
--    L<<Logger::Error<<"Unknown exception in main webserver thread"<<endl;
-+    g_log<<Logger::Error<<"Unknown exception in main webserver thread"<<endl;
-   }
-   _exit(1);
- }
-diff --git a/ws-recursor.cc b/ws-recursor.cc
-index dbe1c07..9860d7b 100644
---- a/ws-recursor.cc
-+++ b/ws-recursor.cc
-@@ -585,11 +585,11 @@ void AsyncServerNewConnectionMT(void *p) {
-     }
-   } catch (NetworkError &e) {
-     // we're running in a shared process/thread, so can't just terminate/abort.
--    L<<Logger::Warning<<"Network error in web thread: "<<e.what()<<endl;
-+    g_log<<Logger::Warning<<"Network error in web thread: "<<e.what()<<endl;
-     return;
-   }
-   catch (...) {
--    L<<Logger::Warning<<"Unknown error in web thread"<<endl;
-+    g_log<<Logger::Warning<<"Unknown error in web thread"<<endl;
- 
-     return;
-   }
-@@ -639,18 +639,18 @@ try {
- 
-   // now send the reply
-   if (asendtcp(data, client.get()) == -1 || data.empty()) {
--    L<<Logger::Error<<"Failed sending reply to HTTP client"<<endl;
-+    g_log<<Logger::Error<<"Failed sending reply to HTTP client"<<endl;
-   }
- }
- catch(PDNSException &e) {
--  L<<Logger::Error<<"HTTP Exception: "<<e.reason<<endl;
-+  g_log<<Logger::Error<<"HTTP Exception: "<<e.reason<<endl;
- }
- catch(std::exception &e) {
-   if(strstr(e.what(), "timeout")==0)
--    L<<Logger::Error<<"HTTP STL Exception: "<<e.what()<<endl;
-+    g_log<<Logger::Error<<"HTTP STL Exception: "<<e.what()<<endl;
- }
- catch(...) {
--  L<<Logger::Error<<"HTTP: Unknown exception"<<endl;
-+  g_log<<Logger::Error<<"HTTP: Unknown exception"<<endl;
- }
- 
- void AsyncWebServer::go() {
diff --git a/community/pdns-recursor/libressl-2.7.patch b/community/pdns-recursor/libressl-2.7.patch
index f21249e103..7456cdce62 100644
--- a/community/pdns-recursor/libressl-2.7.patch
+++ b/community/pdns-recursor/libressl-2.7.patch
@@ -1,13 +1,31 @@
+From 1648b8ff39c705fdee526cd73bf2652982b80087 Mon Sep 17 00:00:00 2001
+From: Remi Gacogne <remi.gacogne@powerdns.com>
+Date: Sat, 8 Sep 2018 17:15:14 +0200
+Subject: [PATCH] Fix compilation with LibreSSL 2.7.0+
+
+---
+ pdns/opensslsigners.cc | 4 ++++
+ 1 file changed, 4 insertions(+)
+
 diff --git a/pdns/opensslsigners.cc b/pdns/opensslsigners.cc
-index 8e3bb54..459939a 100644
+index 6a2e856940..d0a65e6489 100644
 --- a/opensslsigners.cc
 +++ b/opensslsigners.cc
-@@ -33,7 +33,7 @@
- #include "opensslsigners.hh"
- #include "dnssecinfra.hh"
+@@ -77,6 +77,8 @@ void openssl_thread_cleanup()
+   OPENSSL_free(openssllocks);
+ }
  
--#if (OPENSSL_VERSION_NUMBER < 0x1010000fL || defined LIBRESSL_VERSION_NUMBER)
-+#if (OPENSSL_VERSION_NUMBER < 0x1010000fL)
- /* OpenSSL < 1.1.0 needs support for threading/locking in the calling application. */
- static pthread_mutex_t *openssllocks;
++#if !defined(LIBRESSL_VERSION_NUMBER) || LIBRESSL_VERSION_NUMBER < 0x2070000fL
++/* those symbols are defined in LibreSSL 2.7.0+ */
+ /* compat helpers. These DO NOT do any of the checking that the libssl 1.1 functions do. */
+ static inline void RSA_get0_key(const RSA* rsakey, const BIGNUM** n, const BIGNUM** e, const BIGNUM** d) {
+   *n = rsakey->n;
+@@ -144,6 +146,8 @@ static inline int ECDSA_SIG_set0(ECDSA_SIG* signature, BIGNUM* pr, BIGNUM* ps) {
+ }
+ #endif /* HAVE_LIBCRYPTO_ECDSA */
  
++#endif /* !defined(LIBRESSL_VERSION_NUMBER) || LIBRESSL_VERSION_NUMBER < 0x2070000fL */
++
+ #else
+ void openssl_thread_setup() {}
+ void openssl_thread_cleanup() {}