Kouhei Sutou
null+****@clear*****
Mon Dec 4 22:34:00 JST 2017
Kouhei Sutou 2017-12-04 22:34:00 +0900 (Mon, 04 Dec 2017) New Revision: 5391b3ca5b2a2cd0b9c462a9edea15b4d660d8c3 https://github.com/groonga/groonga-query-log/commit/5391b3ca5b2a2cd0b9c462a9edea15b4d660d8c3 Message: Unindent Modified files: lib/groonga-query-log/parser.rb Modified: lib/groonga-query-log/parser.rb (+101 -101) =================================================================== --- lib/groonga-query-log/parser.rb 2017-11-21 18:44:30 +0900 (fcb80a4) +++ lib/groonga-query-log/parser.rb 2017-12-04 22:34:00 +0900 (07b7af9) @@ -17,122 +17,122 @@ require "groonga-query-log/statistic" module GroongaQueryLog - class Parser - def initialize(options={}) - @options = options - @slow_operation_threshold = options[:slow_operation_threshold] - @slow_response_threshold = options[:slow_response_threshold] - @target_commands = options[:target_commands] - @target_tables = options[:target_tables] - @parsing_statistics = {} - end + class Parser + def initialize(options={}) + @options = options + @slow_operation_threshold = options[:slow_operation_threshold] + @slow_response_threshold = options[:slow_response_threshold] + @target_commands = options[:target_commands] + @target_tables = options[:target_tables] + @parsing_statistics = {} + end - PATTERN = - /\A(?<year>\d{4})-(?<month>\d\d)-(?<day>\d\d) - \ (?<hour>\d\d):(?<minute>\d\d):(?<second>\d\d)\.(?<microsecond>\d+) - \|(?<context_id>.+?) - \|(?<type>[>:<])/x + PATTERN = + /\A(?<year>\d{4})-(?<month>\d\d)-(?<day>\d\d) + \ (?<hour>\d\d):(?<minute>\d\d):(?<second>\d\d)\.(?<microsecond>\d+) + \|(?<context_id>.+?) + \|(?<type>[>:<])/x - # Parses query-log file as stream to - # {GroongaQueryLog::Analyzer::Statistic}s including some - # informations for each query. - # - # @param [IO] input IO for input query log file. - # @yield [statistics] if a block is specified, it is called - # every time a query is finished parsing. - # @yieldparam [GroongaQueryLog::Statistic] statistic - # statistics of each query in log files. - def parse(input, &block) - input.each_line do |line| - next unless line.valid_encoding? + # Parses query-log file as stream to + # {GroongaQueryLog::Analyzer::Statistic}s including some + # informations for each query. + # + # @param [IO] input IO for input query log file. + # @yield [statistics] if a block is specified, it is called + # every time a query is finished parsing. + # @yieldparam [GroongaQueryLog::Statistic] statistic + # statistics of each query in log files. + def parse(input, &block) + input.each_line do |line| + next unless line.valid_encoding? - match_data = PATTERN.match(line) - next if match_data.nil? + match_data = PATTERN.match(line) + next if match_data.nil? - year = match_data[:year].to_i - month = match_data[:month].to_i - day = match_data[:day].to_i - hour = match_data[:hour].to_i - minute = match_data[:minute].to_i - second = match_data[:second].to_i - microsecond = match_data[:microsecond].to_i - context_id = match_data[:context_id] - type = match_data[:type] - rest = match_data.post_match.strip - time_stamp = Time.local(year, - month, - day, - hour, - minute, - second, - microsecond) - parse_line(time_stamp, context_id, type, rest, &block) - end + year = match_data[:year].to_i + month = match_data[:month].to_i + day = match_data[:day].to_i + hour = match_data[:hour].to_i + minute = match_data[:minute].to_i + second = match_data[:second].to_i + microsecond = match_data[:microsecond].to_i + context_id = match_data[:context_id] + type = match_data[:type] + rest = match_data.post_match.strip + time_stamp = Time.local(year, + month, + day, + hour, + minute, + second, + microsecond) + parse_line(time_stamp, context_id, type, rest, &block) end + end - def parsing_statistics - @parsing_statistics.values - end + def parsing_statistics + @parsing_statistics.values + end - private - def parse_line(time_stamp, context_id, type, rest, &block) - case type - when ">" - return if rest.empty? - statistic = create_statistic(context_id) - statistic.start(time_stamp, rest) - @parsing_statistics[context_id] = statistic - when ":" - return unless /\A(\d+) (.+)\((\d+)\)(\[.+\])?/ =~ rest - elapsed = $1 - name = $2 - name += $4 if $4 - n_records = $3.to_i - statistic = @parsing_statistics[context_id] - return if statistic.nil? - statistic.add_operation(:name => name, - :elapsed => elapsed.to_i, - :n_records => n_records) - when "<" - return unless /\A(\d+) rc=(-?\d+)/ =~ rest - elapsed = $1 - return_code = $2 - statistic = @parsing_statistics.delete(context_id) - return if statistic.nil? - statistic.finish(elapsed.to_i, return_code.to_i) - return unless target_statistic?(statistic) - block.call(statistic) - end + private + def parse_line(time_stamp, context_id, type, rest, &block) + case type + when ">" + return if rest.empty? + statistic = create_statistic(context_id) + statistic.start(time_stamp, rest) + @parsing_statistics[context_id] = statistic + when ":" + return unless /\A(\d+) (.+)\((\d+)\)(\[.+\])?/ =~ rest + elapsed = $1 + name = $2 + name += $4 if $4 + n_records = $3.to_i + statistic = @parsing_statistics[context_id] + return if statistic.nil? + statistic.add_operation(:name => name, + :elapsed => elapsed.to_i, + :n_records => n_records) + when "<" + return unless /\A(\d+) rc=(-?\d+)/ =~ rest + elapsed = $1 + return_code = $2 + statistic = @parsing_statistics.delete(context_id) + return if statistic.nil? + statistic.finish(elapsed.to_i, return_code.to_i) + return unless target_statistic?(statistic) + block.call(statistic) end + end - def create_statistic(context_id) - statistic = Statistic.new(context_id) - if @slow_operation_threshold - statistic.slow_operation_threshold = @slow_operation_threshold - end - if @slow_response_threshold - statistic.slow_response_threshold = @slow_response_threshold - end - statistic + def create_statistic(context_id) + statistic = Statistic.new(context_id) + if @slow_operation_threshold + statistic.slow_operation_threshold = @slow_operation_threshold end + if @slow_response_threshold + statistic.slow_response_threshold = @slow_response_threshold + end + statistic + end - def target_statistic?(statistic) - if @target_commands - unless @target_commands.include?(statistic.command.name) - return false - end + def target_statistic?(statistic) + if @target_commands + unless @target_commands.include?(statistic.command.name) + return false end + end - if @target_tables - table = statistic.command["table"] - return false if table.nil? + if @target_tables + table = statistic.command["table"] + return false if table.nil? - unless @target_tables.include?(table) - return false - end + unless @target_tables.include?(table) + return false end - - true end + + true end + end end -------------- next part -------------- HTML����������������������������... URL: https://lists.osdn.me/mailman/archives/groonga-commit/attachments/20171204/bf27a8bd/attachment-0001.htm
