]> granicus.if.org Git - icinga2/commitdiff
Eventqueue: Remove unused code 7088/head
authorMichael Friedrich <michael.friedrich@icinga.com>
Thu, 25 Apr 2019 14:21:07 +0000 (16:21 +0200)
committerMichael Friedrich <michael.friedrich@icinga.com>
Thu, 25 Apr 2019 14:21:07 +0000 (16:21 +0200)
lib/remote/eventqueue.cpp
lib/remote/eventqueue.hpp

index 178f095cc3dbe23cd4b8f5bd86a8c9e2da0d8082..2a7869d459d30176df8c38d09feec1df8d75d3bc 100644 (file)
@@ -90,25 +90,6 @@ void EventQueue::SetFilter(std::unique_ptr<Expression> filter)
        m_Filter.swap(filter);
 }
 
-Dictionary::Ptr EventQueue::WaitForEvent(void *client, double timeout)
-{
-       boost::mutex::scoped_lock lock(m_Mutex);
-
-       for (;;) {
-               auto it = m_Events.find(client);
-               ASSERT(it != m_Events.end());
-
-               if (!it->second.empty()) {
-                       Dictionary::Ptr result = *it->second.begin();
-                       it->second.pop_front();
-                       return result;
-               }
-
-               if (!m_CV.timed_wait(lock, boost::posix_time::milliseconds(long(timeout * 1000))))
-                       return nullptr;
-       }
-}
-
 std::vector<EventQueue::Ptr> EventQueue::GetQueuesForType(const String& type)
 {
        EventQueueRegistry::ItemMap queues = EventQueueRegistry::GetInstance()->GetItems();
index 29f9314f73088f36f87f6b2343b0b2039d74c165..ec389929a496f491d5b5b75abacc94b0d602d55a 100644 (file)
@@ -36,8 +36,6 @@ public:
        void SetTypes(const std::set<String>& types);
        void SetFilter(std::unique_ptr<Expression> filter);
 
-       Dictionary::Ptr WaitForEvent(void *client, double timeout = 5);
-
        static std::vector<EventQueue::Ptr> GetQueuesForType(const String& type);
        static void UnregisterIfUnused(const String& name, const EventQueue::Ptr& queue);