Contents

require 'thread'

module SystemMetrics
  class AsyncStore

    # An instrumenter that does not send notifications. This is used in the
    # AsyncStore so saving events does not send any notifications, not even
    # for logging.
    class VoidInstrumenter < ::ActiveSupport::Notifications::Instrumenter
      def instrument(name, payload={})
        yield(payload) if block_given?
      end
    end

    def initialize
      @queue = Queue.new
      @thread = Thread.new do
        set_void_instrumenter
        consume
      end
    end

    def save(events)
      @queue << events
    end

    protected
      def set_void_instrumenter
        Thread.current[:"instrumentation_#{notifier.object_id}"] = VoidInstrumenter.new(notifier)
      end

      def notifier
        ActiveSupport::Notifications.notifier
      end

      def consume
        while events = @queue.pop
          root_event = SystemMetrics::NestedEvent.arrange(events, :presort => false)
          root_model = create_metric(root_event)
          root_model.update_attributes(:request_id => root_model.id)
          save_tree(root_event.children, root_model.id, root_model.id)
        end
      end

      def save_tree(events, request_id, parent_id)
        events.each do |event|
          model = create_metric(event, :request_id => request_id, :parent_id => parent_id)
          save_tree(event.children, request_id, model.id)
        end
      end

      def create_metric(event, merge_params={})
        SystemMetrics::Metric.create(event.to_hash.merge(merge_params))
      end

  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
system-metrics-0.2.5	lib/system_metrics/async_store.rb
system-metrics-0.2.4	lib/system_metrics/async_store.rb
system-metrics-0.2.3	lib/system_metrics/async_store.rb
system-metrics-0.2.2	lib/system_metrics/async_store.rb