Contents

require 'date'
require 'protobuf/common/logger'

module Protobuf
  module Rpc
    class Stat
      attr_accessor :type, :start_time, :end_time, :request_size, :response_size, :client, :server, :service, :method
      
      TYPES = [:SERVER, :CLIENT]
      
      def initialize type=:SERVER, do_start=true
        @type = type
        start if do_start
      end
      
      def client= peer
        @client = {:port => peer[0], :ip => peer[1]}
      end
      
      def client
        @client ? '%s:%d' % [@client[:ip], @client[:port]] : nil
      end
      
      def server= peer
        @server = {:port => peer[0], :ip => peer[1]}
      end
      
      def server
        @server ? '%s:%d' % [@server[:ip], @server[:port]] : nil
      end
      
      def sizes
        '%dB/%dB' % [@request_size || 0, @response_size || 0]
      end
      
      def start
        @start_time ||= Time.now
      end
      
      def end
        start if !@start_time
        @end_time ||= Time.now
      end
      
      def rpc
        service && method ? '%s#%s' % [service, method] : nil
      end
      
      def elapsed_time
        (start_time && end_time ? '%ss' % (end_time - start_time).round(4) : nil)
      end
      
      def log_stats
        Protobuf::Logger.info(self.to_s)
      end
      
      def to_s
        [
          @type == :SERVER ? "[SRV-#{self.class}]" : "[CLT-#{self.class}]",
          rpc,
          elapsed_time,
          sizes,
          @type == :SERVER ? server : client
        ].delete_if{|v| v.nil? }.join(' - ')
      end
      
    end
  end
end

Version data entries

13 entries across 13 versions & 1 rubygems

Version	Path
protobuf-2.0.0.rc3	lib/protobuf/rpc/stat.rb
protobuf-2.0.0.rc2	lib/protobuf/rpc/stat.rb
protobuf-2.0.0.rc1	lib/protobuf/rpc/stat.rb
protobuf-1.4.2	lib/protobuf/rpc/stat.rb
protobuf-1.4.1	lib/protobuf/rpc/stat.rb
protobuf-1.4.0	lib/protobuf/rpc/stat.rb
protobuf-1.3.0	lib/protobuf/rpc/stat.rb
protobuf-1.1.3	lib/protobuf/rpc/stat.rb
protobuf-1.1.2	lib/protobuf/rpc/stat.rb
protobuf-1.1.1	lib/protobuf/rpc/stat.rb
protobuf-1.1.0.beta2	lib/protobuf/rpc/stat.rb
protobuf-1.1.0.beta1	lib/protobuf/rpc/stat.rb
protobuf-1.1.0.beta0	lib/protobuf/rpc/stat.rb