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