Packages

plug

1.20.2
1.20.3 1.20.2 1.20.1 retired 1.20.0 retired 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.17.4 1.17.3 1.17.2 1.17.1 1.17.0 1.16.6 1.16.5 1.16.4 1.16.3 1.16.2 1.16.1 1.16.0 1.15.6 1.15.5 1.15.4 1.15.3 1.15.2 1.15.1 1.15.0 1.14.2 1.14.1 1.14.0 1.13.6 1.13.5 1.13.4 1.13.3 1.13.2 1.13.1 retired 1.13.0 retired 1.12.1 1.12.0 1.11.1 1.11.0 1.10.4 1.10.3 1.10.2 1.10.1 1.10.0 1.9.0 1.8.3 1.8.2 1.8.1 1.8.0 1.7.2 1.7.1 1.7.0 1.6.4 1.6.3 1.6.2 1.6.1 1.6.0 1.5.1 1.5.0 1.5.0-rc.2 1.5.0-rc.1 1.5.0-rc.0 1.4.5 1.4.4 1.4.3 1.4.2 1.4.1 1.4.0 1.4.0-rc.0 1.3.6 1.3.5 1.3.4 1.3.3 1.3.2 1.3.1 1.3.0 1.2.6 1.2.5 1.2.4 1.2.3 1.2.2 1.2.1 1.2.0 1.2.0-rc.0 1.1.9 1.1.8 1.1.7 1.1.6 1.1.5 1.1.4 1.1.3 1.1.2 1.1.1 1.1.0 1.0.6 1.0.5 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 0.14.0 0.13.1 0.13.0 0.12.2 0.12.1 0.12.0 0.11.3 0.11.2 0.11.1 0.11.0 0.10.0 0.9.0 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.0 0.6.0 0.5.3 0.5.2 0.5.1 0.5.0 0.4.4 0.4.3 0.4.2 0.4.1

Compose web applications with functions

Security advisory: This version has known vulnerabilities. View advisories
HexDocs

Current section

Files

Jump to
Readme
138 Versions
3 Dependencies
Dependants
7 Advisories
Files
Activity
plug lib plug upload supervisor.ex
Raw

lib/plug/upload/supervisor.ex 

defmodule Plug.Upload.Supervisor do

  @moduledoc false

  use Supervisor



  @temp_env_vars ~w(PLUG_TMPDIR TMPDIR TMP TEMP)s

  @dir_table Plug.Upload.Dir

  @path_table Plug.Upload.Path

  @otp_vsn System.otp_release() |> String.to_integer()

  @write_mode if @otp_vsn >= 25, do: :auto, else: true

  @ets_opts [:public, :named_table, read_concurrency: true, write_concurrency: @write_mode]



  def start_link(args) do

    Supervisor.start_link(__MODULE__, args, name: __MODULE__)

  end



  @impl true

  def init(_args) do

    # Initialize the upload system

    tmp = Enum.find_value(@temp_env_vars, "/tmp", &System.get_env/1) |> Path.expand()

    cwd = Path.join(File.cwd!(), "tmp")

    # Add a tiny random component to avoid clashes between nodes

    suffix = :crypto.strong_rand_bytes(3) |> Base.url_encode64()

    :persistent_term.put(Plug.Upload, {[tmp, cwd], suffix})

    :ets.new(@dir_table, [:set | @ets_opts])

    :ets.new(@path_table, [:duplicate_bag | @ets_opts])



    children = [

      Plug.Upload.Terminator,

      {PartitionSupervisor, child_spec: Plug.Upload, name: Plug.Upload}

    ]



    Supervisor.init(children, strategy: :one_for_one)

  end

end