]> git.ipfire.org Git - thirdparty/squid.git/blobdiff - src/ipc/Coordinator.h
SourceFormat Enforcement
[thirdparty/squid.git] / src / ipc / Coordinator.h
index f2f4da03a4ab4d2d19fcbbd3190f4ca8f8fdeaa2..59fc24a7169007da3861a218d222f87b5669436c 100644 (file)
@@ -8,7 +8,6 @@
 #ifndef SQUID_IPC_COORDINATOR_H
 #define SQUID_IPC_COORDINATOR_H
 
-
 #include "Array.h"
 #include "ipc/Messages.h"
 #include "ipc/Port.h"
@@ -16,7 +15,9 @@
 #include "ipc/StrandCoords.h"
 #include "ipc/StrandSearch.h"
 #include "mgr/forward.h"
-
+#if SQUID_SNMP
+#include "snmp/forward.h"
+#endif
 #include <list>
 #include <map>
 
@@ -53,9 +54,12 @@ protected:
     void handleSharedListenRequest(const SharedListenRequest& request);
     void handleCacheMgrRequest(const Mgr::Request& request);
     void handleCacheMgrResponse(const Mgr::Response& response);
-
+#if SQUID_SNMP
+    void handleSnmpRequest(const Snmp::Request& request);
+    void handleSnmpResponse(const Snmp::Response& response);
+#endif
     /// calls comm_open_listener()
-    int openListenSocket(const SharedListenRequest& request, int &errNo);
+    Comm::ConnectionPointer openListenSocket(const SharedListenRequest& request, int &errNo);
 
 private:
     StrandCoords strands_; ///< registered processes and threads
@@ -63,7 +67,7 @@ private:
     typedef std::list<StrandSearchRequest> Searchers; ///< search requests
     Searchers searchers; ///< yet unanswered search requests in arrival order
 
-    typedef std::map<OpenListenerParams, int> Listeners; ///< params:fd map
+    typedef std::map<OpenListenerParams, Comm::ConnectionPointer> Listeners; ///< params:connection map
     Listeners listeners; ///< cached comm_open_listener() results
 
     static Coordinator* TheInstance; ///< the only class instance in existence
@@ -75,7 +79,6 @@ private:
     CBDATA_CLASS2(Coordinator);
 };
 
-
 } // namespace Ipc
 
 #endif /* SQUID_IPC_COORDINATOR_H */