From ce3ce6cd49e14f640a1cabfef9cf21a239dd961d Mon Sep 17 00:00:00 2001 From: Attila Molnar Date: Mon, 3 Nov 2014 15:43:49 +0100 Subject: m_flashpolicyd, m_httpd Store sockets in a intrusive list --- src/modules/m_flashpolicyd.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'src/modules/m_flashpolicyd.cpp') diff --git a/src/modules/m_flashpolicyd.cpp b/src/modules/m_flashpolicyd.cpp index 6466a9fb2..8f847e111 100644 --- a/src/modules/m_flashpolicyd.cpp +++ b/src/modules/m_flashpolicyd.cpp @@ -23,12 +23,12 @@ class FlashPDSocket; namespace { - std::set sockets; + insp::intrusive_list sockets; std::string policy_reply; const std::string expected_request("\0", 23); } -class FlashPDSocket : public BufferedSocket, public Timer +class FlashPDSocket : public BufferedSocket, public Timer, public insp::intrusive_list_node { /** True if this object is in the cull list */ @@ -90,7 +90,7 @@ class ModuleFlashPD : public Module if (policy_reply.empty()) return MOD_RES_DENY; - sockets.insert(new FlashPDSocket(nfd, timeout)); + sockets.push_front(new FlashPDSocket(nfd, timeout)); return MOD_RES_ALLOW; } @@ -148,7 +148,7 @@ class ModuleFlashPD : public Module CullResult cull() { - for (std::set::const_iterator i = sockets.begin(); i != sockets.end(); ++i) + for (insp::intrusive_list::const_iterator i = sockets.begin(); i != sockets.end(); ++i) { FlashPDSocket* sock = *i; sock->AddToCull(); -- cgit v1.3.1-10-gc9f91