Packages

roger

1.4.2
3.2.1 3.2.0 3.1.1 3.1.0 3.0.3 3.0.2 3.0.1 3.0.0 2.4.2 2.4.1 2.4.0 2.3.0 2.2.2 2.2.1 2.2.0 2.1.1 retired 2.1.0 2.0.1 2.0.0 2.0.0-pre.2 2.0.0-pre.1 1.4.2 1.4.1 1.4.0 1.3.2 1.3.1 1.3.0 1.2.1 1.2.0 1.1.0 1.0.0

RabbitMQ-backed background job processing system

HexDocs

Current section

Files

Jump to
Readme
31 Versions
5 Dependencies
1 Dependant
Files
Activity
roger lib roger gproc.ex
Raw

lib/roger/gproc.ex 

defmodule Roger.GProc do

  @moduledoc false



  @scope :l



  def name(proc), do: {:n, @scope, proc}



  def reg(proc), do: :gproc.reg(name(proc))



  def unreg(proc), do: :gproc.unreg(name(proc))



  def regp(proc), do: :gproc.reg(prop(proc))



  def regp(proc, value), do: :gproc.reg(prop(proc), value)



  def unregp(proc), do: :gproc.unreg(prop(proc))



  def prop(proc), do: {:p, @scope, proc}



  def whereis(proc) do

    map_nil(:gproc.whereis_name(name(proc)))

  end



  def is_alive(proc), do: is_pid(whereis(proc)) and Process.alive?(whereis(proc))



  def via(proc), do: {:via, :gproc, name(proc)}



  defp map_nil(:undefined), do: nil

  defp map_nil(value), do: value



  @doc """

  Return list of {pid, value} pairs for the given selector.

  """

  def find_properties(selector) do

    for [_, pid, value] <- :gproc.select([{{ {:p, @scope, selector}, :_, :_}, [], [:'$$']}]), do: {pid, value}

  end



  @doc """

  Return list of {pid, value} pairs for the given selector.

  """

  def find_names(selector) do

    for [{:n, @scope, value}, _, _] <- :gproc.select([{{ {:n, @scope, selector}, :_, :_}, [], [:'$$']}]), do: value

  end

end