lib/joboe_metal.rb in oboe-2.6.6.1 vs lib/joboe_metal.rb in oboe-2.6.7.1

@@ -13,34 +13,10 @@
   include_package 'com.tracelytics.joboe.Event'
   import 'com.tracelytics.joboe.Event'
 
   class Context
     class << self
-      attr_accessor :layer_op
-      
-      def log(layer, label, options = {}, with_backtrace = false)
-        evt = Oboe::Context.createEvent()
-        evt.addInfo("Layer", layer.to_s)
-        evt.addInfo("Label", label.to_s)
-
-        options.each_pair do |k, v|
-          evt.addInfo(k.to_s, v.to_s)
-        end
-
-        evt.addInfo("Backtrace", Oboe::API.backtrace) if with_backtrace
-
-        Oboe.reporter.sendReport(evt)
-      end
-       
-      def tracing_layer_op?(operation)
-        if operation.is_a?(Array)
-          return operation.include?(@layer_op)
-        else
-          return @layer_op == operation
-        end
-      end
-      
       def toString
         md = getMetadata.toString
       end
 
       def clear
@@ -50,34 +26,34 @@
       def get
         getMetadata
       end
     end
   end
-  
+
   class Event
     def self.metadataString(evt)
       evt.getMetadata.toHexString
     end
   end
 
   def UdpReporter
     Java::ComTracelyticsJoboe
   end
-  
+
   module Metadata
     Java::ComTracelyticsJoboeMetaData
   end
-  
+
   module Reporter
     ##
     # Initialize the Oboe Context, reporter and report the initialization
     #
     def self.start
       begin
         return unless Oboe.loaded
 
-        Oboe_metal::Context.init() 
+        Oboe_metal::Context.init()
 
         if ENV['RACK_ENV'] == "test"
           Oboe.reporter = Oboe::FileReporter.new("/tmp/trace_output.bson")
         else
           Oboe.reporter = Oboe::UdpReporter.new(Oboe::Config[:reporter_host])
@@ -86,39 +62,41 @@
         # Only report __Init from here if we are not instrumenting a framework.
         # Otherwise, frameworks will handle reporting __Init after full initialization
         unless defined?(::Rails) or defined?(::Sinatra) or defined?(::Padrino) or defined?(::Grape)
           Oboe::API.report_init
         end
-      
+
       rescue Exception => e
         $stderr.puts e.message
         raise
       end
     end
-    
+
     def self.sendReport(evt)
       evt.report
     end
   end
 end
 
-module Oboe 
+module Oboe
   extend OboeBase
   include Oboe_metal
-  
+
   class << self
     def sample?(opts = {})
+      return false unless Oboe.always?
+
       # Assure defaults since SWIG enforces Strings
       opts[:layer]      ||= ''
       opts[:xtrace]     ||= ''
       opts['X-TV-Meta']   ||= ''
       Java::ComTracelyticsJoboeSettingsReader.shouldTraceRequest(opts[:layer], opts[:xtrace], opts['X-TV-Meta'])
     end
-    
+
     def set_tracing_mode(mode)
       # FIXME: TBD
     end
-    
+
     def set_sample_rate(rate)
       # FIXME: TBD
     end
   end
 end