commit 7c4801d5172422896db801874637d902665dfd5c
author Éric Lemoine <elemoine@mirantis.com> Tue Nov 08 14:00:56 2016 +0000
committer Éric Lemoine <elemoine@mirantis.com> Wed Nov 09 13:26:09 2016 +0000
tree bbe29dba1475a7bd3d5dd41069b7d3b80bcd0e1b
parent fc2ae37b03d05424bf90e9505b0ec457ea340c73

Do not rely on pacemaker_local_resource_active

heka/files/lua/filters/gse_cluster_filter.lua

diff --git a/heka/files/lua/filters/gse_cluster_filter.lua b/heka/files/lua/filters/gse_cluster_filter.lua
index e8a83f5..5b6402c 100644
--- a/heka/files/lua/filters/gse_cluster_filter.lua
+++ b/heka/files/lua/filters/gse_cluster_filter.lua
@@ -27,7 +27,6 @@
 local dimensions_json = read_config('dimensions') or ''
 local activate_alerting = read_config('activate_alerting') or true
 
-local is_active = false
 local first_tick
 local last_tick = 0
 local last_index = nil
@@ -49,20 +48,6 @@
 end
 
 function process_message()
-    local name = read_message('Fields[name]')
-    local hostname = read_message('Fields[hostname]')
-    if name and name == 'pacemaker_local_resource_active' and read_message("Fields[resource]") == 'vip__management' then
-        -- Skip pacemaker_local_resource_active metrics that don't
-        -- concern the local node
-        if read_message('Hostname') == hostname then
-            if read_message('Fields[value]') == 1 then
-                is_active = true
-            else
-                is_active = false
-            end
-        end
-        return 0
-    end
 
     local member_id = afd.get_entity_name('member')
     if not member_id then
@@ -89,10 +74,7 @@
 end
 
 function timer_event(ns)
-    if not is_active then
-        -- not running as the aggregator
-        return
-    elseif not first_tick then
+    if not first_tick then
         first_tick = ns
         return
     elseif ns - first_tick <= warm_up_period then