lib/instana/tracing/processor.rb in instana-1.5.0 vs lib/instana/tracing/processor.rb in instana-1.5.1

- old
+ new

@@ -23,19 +23,19 @@ # Adds a trace to the queue to be processed and # sent to the host agent # # @param [Trace] the trace to be added to the queue def add(trace) - ::Instana.logger.trace("Queuing completed trace id: #{trace.id}") + ::Instana.logger.debug("Queuing completed trace id: #{trace.id}") @queue.push(trace) end # Adds a trace to the staging queue. # # @param [Trace] the trace to be added to the queue def stage(trace) - ::Instana.logger.trace("Staging incomplete trace id: #{trace.id}") + ::Instana.logger.debug("Staging incomplete trace id: #{trace.id}") @staging_queue.add(trace) end # This will run through the staged traces (if any) to find # completed or timed out incompleted traces. Completed traces will @@ -44,11 +44,11 @@ def process_staged @staging_lock.synchronize { if @staging_queue.size > 0 @staging_queue.delete_if do |t| if t.complete? - ::Instana.logger.trace("Moving staged complete trace to main queue: #{t.id}") + ::Instana.logger.debug("Moving staged complete trace to main queue: #{t.id}") add(t) true elsif t.discard? ::Instana.logger.debug("Discarding trace with uncompleted async spans over 5 mins old. id: #{t.id}") true @@ -158,10 +158,10 @@ break end end } unless candidate - ::Instana.logger.trace("Couldn't find staged trace with trace_id: #{trace_id}") + ::Instana.logger.debug("Couldn't find staged trace with trace_id: #{trace_id}") end candidate end # Get the number traces currently in the queue