Module: ScoutRails::Agent::Reporting

Included in:
ScoutRails::Agent
Defined in:
lib/scout_rails/agent/reporting.rb

Instance Method Summary collapse

Instance Method Details

#add_metric_ids(metrics) ⇒ Object

Before reporting, lookup metric_id for each MetricMeta. This speeds up reporting on the server-side.



46
47
48
49
50
51
52
 
# File 'lib/scout_rails/agent/reporting.rb', line 46

def add_metric_ids(metrics)
  metrics.each do |meta,stats|
    if metric_id = metric_lookup[meta]
      meta.metric_id = metric_id
    end
  end
end

#checkin_uri ⇒ Object 



54
55
56
 
# File 'lib/scout_rails/agent/reporting.rb', line 54

def checkin_uri
  URI.parse("http://#{config.settings['host']}/app/#{config.settings['key']}/checkin.scout?name=#{CGI.escape(config.settings['name'])}")
end

#http(url) ⇒ Object

Take care of the http proxy, if specified in config. Given a blank string, the proxy_uri URI instance’s host/port/user/pass will be nil. Net::HTTP::Proxy returns a regular Net::HTTP class if the first argument (host) is nil.



91
92
93
94
 
# File 'lib/scout_rails/agent/reporting.rb', line 91

def http(url)
  proxy_uri = URI.parse(config.settings['proxy'].to_s)
  Net::HTTP::Proxy(proxy_uri.host,proxy_uri.port,proxy_uri.user,proxy_uri.password).new(url.host, url.port)
end

#post(url, body, headers = Hash.new) ⇒ Object 



58
59
60
61
62
63
64
65
66
67
68
 
# File 'lib/scout_rails/agent/reporting.rb', line 58

def post(url, body, headers = Hash.new)
  response = nil
  request(url) do |connection|
    post = Net::HTTP::Post.new( url.path +
                                (url.query ? ('?' + url.query) : ''),
                                HTTP_HEADERS.merge(headers) )
    post.body = body
    response=connection.request(post)
  end
  response
end

#process_metrics ⇒ Object

Called in the worker thread. Merges in-memory metrics w/those on disk and reports metrics to the server.



7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/scout_rails/agent/reporting.rb', line 7

def process_metrics
  logger.debug "Processing metrics"
  run_samplers
  metrics = layaway.deposit_and_deliver
  if metrics.any?
    add_metric_ids(metrics)  
    logger.warn "Some data may be lost - metric size is at limit" if metrics.size == ScoutRails::Store::MAX_SIZE
    # for debugging, count the total number of requests    
    controller_count = 0
    metrics.each do |meta,stats|
      if meta.metric_name =~ /\AController/
        controller_count += stats.call_count
      end
    end        
    logger.debug "#{config.settings['name']} Delivering metrics for #{controller_count} requests."        
    response =  post( checkin_uri,
                       Marshal.dump(:metrics => metrics, :sample => store.sample),
                       "Content-Type"     => "application/json" )
    if response and response.is_a?(Net::HTTPSuccess)
      directives = Marshal.load(response.body)
      self.metric_lookup.merge!(directives[:metric_lookup])
      if directives[:reset]
        logger.info "Resetting metric_lookup."
        self.metric_lookup = Hash.new
      end
      store.transaction_sample_lock.synchronize do
        store.sample = nil
      end
      logger.debug "Metric Cache Size: #{metric_lookup.size}"
    end
  end
rescue
  logger.info "Error on checkin to #{checkin_uri.to_s}"
  logger.info $!.message
  logger.debug $!.backtrace
end

#request(url, &connector) ⇒ Object 



70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
 
# File 'lib/scout_rails/agent/reporting.rb', line 70

def request(url, &connector)
  response           = nil
  response           = http(url).start(&connector)
  logger.debug "got response: #{response.inspect}"
  case response
  when Net::HTTPSuccess, Net::HTTPNotModified
    logger.debug "/checkin OK"
  when Net::HTTPBadRequest
    logger.warn "/checkin FAILED: The Account Key [#{config.settings['key']}] is invalid."
  else
    logger.debug "/checkin FAILED: #{response.inspect}"
  end
rescue Exception
  logger.debug "Exception sending request to server: #{$!.message}"
ensure
  response
end