]> git.ipfire.org Git - thirdparty/squid.git/blobdiff - src/ipc/Coordinator.cc
SourceFormat Enforcement
[thirdparty/squid.git] / src / ipc / Coordinator.cc
index 7bc106ffce2c26a4a6abcedbf88f5d840112ae34..e54b028cbf479aa2ef8bffb970d48922e85d3fb2 100644 (file)
@@ -5,8 +5,7 @@
  *
  */
 
-
-#include "config.h"
+#include "squid.h"
 #include "base/Subscription.h"
 #include "base/TextException.h"
 #include "CacheManager.h"
 #include "mgr/Inquirer.h"
 #include "mgr/Request.h"
 #include "mgr/Response.h"
+#include "protos.h"
 #if SQUID_SNMP
 #include "snmp/Inquirer.h"
 #include "snmp/Request.h"
 #include "snmp/Response.h"
 #endif
+#if HAVE_ERRNO_H
+#include <errno.h>
+#endif
 
 CBDATA_NAMESPACED_CLASS_INIT(Ipc, Coordinator);
 Ipc::Coordinator* Ipc::Coordinator::TheInstance = NULL;
 
-
 Ipc::Coordinator::Coordinator():
         Port(coordinatorAddr)
 {
@@ -124,7 +126,7 @@ void Ipc::Coordinator::receive(const TypedMsgHdr& message)
 #endif
 
     default:
-        debugs(54, 1, HERE << "Unhandled message type: " << message.type());
+        debugs(54, DBG_IMPORTANT, HERE << "Unhandled message type: " << message.type());
         break;
     }
 }
@@ -168,8 +170,7 @@ Ipc::Coordinator::handleCacheMgrRequest(const Mgr::Request& request)
         Mgr::Action::Pointer action =
             CacheManager::GetInstance()->createRequestedAction(request.params);
         AsyncJob::Start(new Mgr::Inquirer(action, request, strands_));
-    }
-    catch (const std::exception &ex) {
+    } catch (const std::exception &ex) {
         debugs(54, DBG_IMPORTANT, "BUG: cannot aggregate mgr:" <<
                request.params.actionName << ": " << ex.what());
         // TODO: Avoid half-baked Connections or teach them how to close.