Contents

# Copyright (c) 2013 AppNeta, Inc.
# All rights reserved.

require 'net/http'

if Oboe::Config[:nethttp][:enabled]

  Net::HTTP.class_eval do
    def request_with_oboe(*args, &block)
      unless started? 
        return request_without_oboe(*args, &block) 
      end

      # Avoid cross host tracing for blacklisted domains
      blacklisted = Oboe::API.blacklisted?(addr_port)

      Oboe::API.trace('net-http') do
        opts = {}
        if args.length and args[0]
          req = args[0]

          opts['IsService'] = 1
          opts['RemoteProtocol'] = use_ssl? ? 'HTTPS' : 'HTTP'
          opts['RemoteHost'] = addr_port
          opts['ServiceArg'] = req.path
          opts['HTTPMethod'] = req.method
          opts['Blacklisted'] = true if blacklisted
          opts['Backtrace'] = Oboe::API.backtrace if Oboe::Config[:nethttp][:collect_backtraces]
        
          req['X-Trace'] = Oboe::Context.toString() unless blacklisted
        end

        resp = request_without_oboe(*args, &block)

        opts['HTTPStatus'] = resp.code
        Oboe::API.log('net-http', 'info', opts)

        unless blacklisted
          xtrace = resp.get_fields('X-Trace')
          if xtrace and xtrace.size and Oboe.tracing? 
            Oboe::Context.fromString(xtrace[0])
          end
        end
        next resp
      end
    end

    alias request_without_oboe request
    alias request request_with_oboe

    Oboe.logger.info "[oboe/loading] Instrumenting net/http" if Oboe::Config[:verbose]
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
oboe-2.3.3.7	lib/oboe/inst/http.rb
oboe-2.3.2	lib/oboe/inst/http.rb