class Sentry::SessionFlusher

def add_session(session)
  return if @exited
  return unless @release
  begin
    ensure_thread
  rescue ThreadError
    log_debug("Session flusher thread creation failed")
    @exited = true
    return
  end
  return unless Session::AGGREGATE_STATUSES.include?(session.status)
  @pending_aggregates[session.aggregation_key] ||= init_aggregates(session.aggregation_key)
  @pending_aggregates[session.aggregation_key][session.status] += 1
end