Packages

new_relic_agent

1.18.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 sampler top_process.ex
Raw

lib/new_relic/sampler/top_process.ex 

defmodule NewRelic.Sampler.TopProcess do

  use GenServer



  # Track and sample the top processes by:

  # * memory usage

  # * message queue length



  @moduledoc false



  alias NewRelic.Util.PriorityQueue, as: PQ



  def start_link do

    GenServer.start_link(__MODULE__, :ok, name: __MODULE__)

  end



  def init(:ok) do

    NewRelic.sample_process()



    if NewRelic.Config.enabled?(),

      do: Process.send_after(self(), :sample, NewRelic.Sampler.Reporter.random_offset())



    {:ok, :reset}

  end



  def handle_info(:sample, :reset) do

    top_procs = detect_top_processes()

    Process.send_after(self(), :report, NewRelic.Sampler.Reporter.sample_cycle())

    {:noreply, top_procs}

  end



  @kb 1024

  def handle_info(:report, top_procs) do

    Enum.each(top_procs, &report_sample/1)

    send(self(), :sample)

    {:noreply, :reset}

  end



  def detect_top_processes() do

    {mem_pq, msg_pq} =

      Process.list()

      |> Enum.reduce({PQ.new(), PQ.new()}, &measure_and_insert/2)



    (PQ.values(mem_pq) ++ PQ.values(msg_pq))

    |> Enum.uniq_by(&elem(&1, 0))

  end



  @size 5

  def measure_and_insert(pid, {mem_pq, msg_pq}) do

    case Process.info(pid, [:memory, :message_queue_len, :registered_name, :reductions]) do

      [memory: mem, message_queue_len: msg, registered_name: _, reductions: _] = info ->

        mem_pq = PQ.insert(mem_pq, @size, mem, {pid, info})

        msg_pq = if msg > 0, do: PQ.insert(msg_pq, @size, msg, {pid, info}), else: msg_pq

        {mem_pq, msg_pq}



      nil ->

        {mem_pq, msg_pq}

    end

  end



  def report_sample({pid, info}) do

    case Process.info(pid, :reductions) do

      {:reductions, current_reductions} ->

        NewRelic.report_sample(:ProcessSample, %{

          pid: inspect(pid),

          memory_kb: info[:memory] / @kb,

          message_queue_length: info[:message_queue_len],

          name: parse(:name, pid, info[:registered_name]),

          reductions: current_reductions - info[:reductions]

        })



      nil ->

        :ignore

    end

  end



  defp parse(:name, pid, []) do

    with {:dictionary, dictionary} <- Process.info(pid, :dictionary),

         {m, f, a} <- Keyword.get(dictionary, :"$initial_call") do

      "#{inspect(m)}.#{f}/#{a}"

    else

      _ -> inspect(pid)

    end

  end



  defp parse(:name, _pid, name), do: inspect(name)

end