2
0
mirror of https://github.com/munin-monitoring/contrib.git synced 2018-11-08 00:59:34 +01:00
contrib-munin/plugins/ejabberd/ejabberd_scanlog

165 lines
4.1 KiB
Ruby
Executable File

#!/usr/bin/env ruby
require 'yaml'
# ejabberd_scanlog revision 2 (Mar 2012)
#
# Scans ejabberd 2.1.x log for known error signatures and counts them
#
# Required privileges: read ejabberd log (user ejabberd or, in some cases, root)
#
# OS: Unix
#
# Configuration:
# env.log: ejabberd log file (defaults to /var...)
#
# Author: Artem Sheremet <dot.doom@gmail.com>
#
# Run with 'debug' argument to initiate full log rescan.
# This will also print out unparsed log entries to stderr.
# Cache file will be untouched.
#
LOG_FILE = ENV['log'] || '/var/log/ejabberd/ejabberd.log'
CACHE_FILE = '/tmp/ejabberd_scanlog_cache' # cache file position
DEFAULT_CACHE = { :start => 0 }
$debug_mode = ARGV.first == 'debug'
if $debug_mode
log_info = DEFAULT_CACHE
else
begin
log_info = YAML.load IO.read(CACHE_FILE)
rescue
log_info = DEFAULT_CACHE
end
if File.size(LOG_FILE) < log_info[:start]
# logrotate?
log_info = DEFAULT_CACHE
end
end
if ARGV.first == 'reset'
log_info = { :start => File.size(LOG_FILE)-1 }
puts 'Log reset'
end
new_data = ''
File.open(LOG_FILE, 'rb') do |flog|
flog.seek(log_info[:start])
new_data = flog.read
end
KNOWN_LOG_TYPES = [
# each element is an instance of Array. 1st item: error description, others: text to search log for
['EJAB-1482 Crash when waiting for item',
['wait_for_']],
['EJAB-1483 ODBC sup failure (wrong PID?)',
['ejabberd_odbc_sup']],
['EJAB-1483 ODBC sup wrong PID failure echo',
["mod_pubsub_odbc,'-unsubscribe"]],
['DNS failure',
['You should check your DNS configuration']],
['Database unavailable/too slow',
['Database was not available or too slow']],
['State machine terminated: timeout',
['State machine',
'terminating',
'Reason for',
'timeout']],
['The auth module returned an error',
['The authentication module',
'returned an error']],
['MySQL disconnected',
['mysql',
'Received unknown signal, exiting']],
['Connecting to MySQL: failed',
['mysql',
'Failed connecting to']],
['Timeout while running a hook',
['ejabberd_hooks',
'timeout']],
['SQL transaction restarts exceeded',
['SQL transaction restarts exceeded']],
['Unexpected info',
['nexpected info']],
['Other sql_cmd timeout',
['sql_cmd']],
['System limit hit: ports', # check with length(erlang:ports())., set in ejabberdctl config file
['system_limit',
'open_port']],
['Other system limit hit', # processes? check with erlang:system_info(process_count)., erlang:system_info(process_limit)., set in ejabberdctl cfg
['system_limit']],
['Generic server terminating',
['Generic server',
'terminating']],
['Mnesia table shrinked',
['shrinking table']],
['Admin access failed',
['Access of',
'failed with error']],
['MySQL sock timedout',
['mysql_',
': Socket',
'timedout']],
['Configuration error',
['{badrecord,config}']],
['Strange vCard error (vhost)',
['error found when trying to get the vCard']],
['Mnesia is overloaded',
['Mnesia is overloaded']],
['MySQL: init failed recv data',
['mysql_conn: init failed receiving data']],
['TCP Error',
['Failed TCP']]
]
def log_type(text)
KNOWN_LOG_TYPES.find_index { |entry|
entry[1].all? { |substr| text.include? substr }
}
end
new_data.split("\n=").each { |report|
next if report.empty?
report =~ /\A(\w+) REPORT==== (.*) ===\n(.*)\z/m
type, time, text = $1, $2, $3
next unless type and time and text
log_info[type] = (log_info[type] || 0) + 1
if sub_type = log_type(text)
log_info[sub_type] = (log_info[sub_type] || 0) + 1
elsif $debug_mode
warn "Unparsed log entry #{type}: #{text} at #{time}"
end
}
log_info[:start] += new_data.size
File.open(CACHE_FILE, 'w') { |f| f.write log_info.to_yaml } unless $debug_mode
if ARGV.first == 'config'
puts <<CONFIG
graph_title Ejabberd Log
graph_vlabel total
graph_category chat
graph_args -l 0
CONFIG
end
(KNOWN_LOG_TYPES + %w(ERROR WARNING INFO DEBUG)).each.with_index { |log_type, index|
label, index = if log_type.is_a? Array
[log_type.first, index]
else
[log_type, log_type]
end
if ARGV.first == 'config'
puts "T#{index}.label #{label}"
puts "T#{index}.draw LINE"
else
puts "T#{index}.value #{log_info[index] or 0}"
end
}