new_relic_agent

1.17.0-rc.2

1.40.3 1.40.2 1.40.1 1.40.0 1.39.0 1.38.0 1.37.0 1.36.0 1.35.0 1.34.0 1.33.0 1.32.0 1.31.1 1.31.0 1.30.0 1.29.0 1.28.0 1.27.8 1.27.7 1.27.6 1.27.5 1.27.4 1.27.3 1.27.2 1.27.1 1.27.0 1.26.0 1.25.3 1.25.2 1.25.1 1.25.0 1.24.5 1.24.4 1.24.3 1.24.2 1.24.1 1.24.0 1.24.0-rc.10 1.24.0-rc.9 1.24.0-rc.8 1.24.0-rc.7 1.23.6 1.23.5 1.23.4 1.23.3 1.23.2 1.23.1 1.23.0 1.23.0-rc.6 1.23.0-rc.5 1.23.0-rc.4 1.23.0-rc.3 1.23.0-rc.2 1.23.0-rc.1 1.22.6 1.22.5 1.22.4 1.22.3 1.22.2 1.22.1 1.22.0 1.21.2 1.21.1 1.21.0 1.21.0-rc.3 1.21.0-rc.1 1.20.0 1.20.0-rc.1 1.19.7 1.19.6 1.19.5 1.19.4 1.19.3 1.19.2 1.19.1 1.19.0 1.18.5 1.18.4 1.18.3 1.18.2 1.18.1 1.18.0 1.18.0-rc.5 1.18.0-rc.4 1.18.0-rc.2 1.18.0-rc.1 1.17.1 1.17.0 1.17.0-rc.4 1.17.0-rc.3 1.17.0-rc.2 1.17.0-rc.1 1.17.0-rc.0 1.16.7 1.16.6 1.16.5 1.16.4 1.16.3 1.16.2 1.16.1 1.16.0 1.16.0-rc.2 1.16.0-rc.1 1.16.0-rc.0 1.15.0 1.15.0-rc.3 1.15.0-rc.2 1.15.0-rc.1 1.14.0 1.13.1 1.13.0 1.12.0 1.11.0 1.10.2 1.10.1 1.10.0 1.9.12 1.9.11 1.9.10 1.9.9 1.9.8 1.9.7 1.9.6 1.9.5 1.9.4 1.9.3 1.9.2 1.9.1 1.9.0 1.8.0 1.7.0 1.6.2 1.6.1 1.6.0 1.5.0 1.4.0 1.3.2 1.3.1 1.3.0 1.2.1 1.2.0 1.1.0 1.0.5 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0

New Relic's Open-Source Elixir Agent

HexDocs

Current section

Files

Jump to

Readme 148 Versions 5 Dependencies 8 Dependants Files Activity

new_relic_agent lib new_relic transaction monitor.ex

Raw

lib/new_relic/transaction/monitor.ex

defmodule NewRelic.Transaction.Monitor do
  use GenServer
  alias NewRelic.Transaction
  alias NewRelic.DistributedTrace

  # This GenServer watches transaction processes for
  #  - :trace messages
  #  - :DOWN messages
  #
  # :trace messages signal that a transaction process has
  # spwaned another process. We want to track that process
  # so we can track attributes on the original transaction
  #
  # :DOWN signals that the transaction process is complete, so
  # we tell the reporter to purge its data

  @moduledoc false

  def start_link do
    GenServer.start_link(__MODULE__, :ok, name: __MODULE__)
  end

  def init(:ok) do
    NewRelic.sample_process()
    enable_trace_patterns()
    {:ok, %{pids: %{}, tasks: %{}}}
  end

  # API

  def add(pid), do: GenServer.call(__MODULE__, {:add, pid})

  # Server

  def handle_call({:add, pid}, _from, %{pids: pids} = state) do
    pids =
      pids
      |> Map.has_key?(pid)
      |> setup_monitor(pids, pid)

    {:reply, :ok, %{state | pids: pids}}
  end

  # Trace messages

  def handle_info({:trace_ts, source, :spawn, pid, _mfa, timestamp}, state) do
    Transaction.Reporter.track_spawn(source, pid, NewRelic.Util.time_to_ms(timestamp))
    {:noreply, state}
  end

  def handle_info({:trace_ts, pid, :exit, _reason, timestamp}, state) do
    Transaction.Reporter.track_exit(pid, NewRelic.Util.time_to_ms(timestamp))
    {:noreply, state}
  end

  def handle_info(
        {:trace_ts, owner, :call, {Task.Supervisor, :async_nolink, [_, _, args]}, _},
        state
      ) do
    state =
      if {:new_relic, :no_track} in args do
        %{state | tasks: Map.put(state.tasks, owner, :no_track)}
      else
        state
      end

    {:noreply, state}
  end

  def handle_info(
        {:trace_ts, source, :return_from, {Task.Supervisor, :async_nolink, _arity},
         %Task{pid: pid, owner: owner}, timestamp},
        state
      ) do
    if state.tasks[owner] == :no_track do
      :no_track
    else
      enable_trace_flags(pid)
      Transaction.Reporter.track_spawn(source, pid, NewRelic.Util.time_to_ms(timestamp))
    end

    {:noreply, %{state | tasks: Map.delete(state.tasks, owner)}}
  end

  def handle_info(
        {:trace_ts, source, :return_from, {:poolboy, :checkout, _}, pid, timestamp},
        state
      ) do
    Transaction.Reporter.track_spawn(source, pid, NewRelic.Util.time_to_ms(timestamp))
    {:noreply, state}
  end

  def handle_info(
        {:trace_ts, _pid, :call,
         {Ecto.Repo.Supervisor, :start_link, [_repo, otp_app, _adapter, _opts]}, _timestamp},
        state
      ) do
    NewRelic.Telemetry.Ecto.Supervisor.start_child(otp_app)
    {:noreply, state}
  end

  def handle_info({:DOWN, _ref, :process, pid, _reason}, state) do
    Transaction.Reporter.ensure_purge(pid)
    Transaction.Reporter.complete(pid)
    DistributedTrace.Tracker.cleanup(pid)
    {:noreply, %{state | pids: Map.delete(state.pids, pid)}}
  end

  def handle_info(_msg, state) do
    # Ignore other :trace messages
    {:noreply, state}
  end

  # Helpers

  defp setup_monitor(false, pids, pid) do
    Process.monitor(pid)
    enable_trace_flags(pid)
    Map.put(pids, pid, true)
  end

  defp setup_monitor(true, pids, _) do
    pids
  end

  def enable_trace_flags(pid) do
    # Trace process events to notice when a process is spawned
    # Trace function calls so we can install specific trace_patterns
    #   http://erlang.org/doc/man/erlang.html#trace-3
    :erlang.trace(pid, true, [:procs, :call, :set_on_spawn, :timestamp])
  rescue
    # Process is already dead
    ArgumentError ->
      nil
  end

  def enable_trace_patterns do
    # Use function tracers to notice when Async work has been kicked off
    #   http://erlang.org/doc/man/erlang.html#trace_3_trace_messages_return_from
    #   http://erlang.org/doc/apps/erts/match_spec.html
    trace_task_async_nolink()
    trace_poolboy_checkout()
    trace_ecto_repo_discovery()
  end

  defp trace_task_async_nolink do
    :erlang.trace_pattern({Task.Supervisor, :async_nolink, :_}, [{:_, [], [{:return_trace}]}], [])
  end

  defp trace_poolboy_checkout do
    :erlang.trace_pattern({:poolboy, :checkout, :_}, [{:_, [], [{:return_trace}]}], [])
  end

  defp trace_ecto_repo_discovery() do
    Code.ensure_loaded?(Ecto.Repo.Supervisor) &&
      :erlang.trace_pattern({Ecto.Repo.Supervisor, :start_link, :_}, true, [:meta])
  end
end

Operator	Description	Example
name:	Match package name. Supports * wildcards and repo/package form	name:phx* or name:hexpm/phoenix
description:	Full-text search of package descriptions	description:auth
depends:	Packages depending on a given package. Supports repo:package form	depends:ecto or depends:hexpm:ecto
build_tool:	Filter by build tool	build_tool:mix
updated_after:	Packages updated after an ISO8601 datetime	updated_after:2025-01-01T00:00:00Z
extra:	Match custom metadata (key,value). Nested keys are separated by commas	extra:license,MIT