diff options
Diffstat (limited to 'deps/rabbit/src/rabbit_connection_sup.erl')
-rw-r--r-- | deps/rabbit/src/rabbit_connection_sup.erl | 66 |
1 files changed, 66 insertions, 0 deletions
diff --git a/deps/rabbit/src/rabbit_connection_sup.erl b/deps/rabbit/src/rabbit_connection_sup.erl new file mode 100644 index 0000000000..c1d1bd0d77 --- /dev/null +++ b/deps/rabbit/src/rabbit_connection_sup.erl @@ -0,0 +1,66 @@ +%% This Source Code Form is subject to the terms of the Mozilla Public +%% License, v. 2.0. If a copy of the MPL was not distributed with this +%% file, You can obtain one at https://mozilla.org/MPL/2.0/. +%% +%% Copyright (c) 2007-2020 VMware, Inc. or its affiliates. All rights reserved. +%% + +-module(rabbit_connection_sup). + +%% Supervisor for a (network) AMQP 0-9-1 client connection. +%% +%% Supervises +%% +%% * rabbit_reader +%% * Auxiliary process supervisor +%% +%% See also rabbit_reader, rabbit_connection_helper_sup. + +-behaviour(supervisor2). +-behaviour(ranch_protocol). + +-export([start_link/4, reader/1]). + +-export([init/1]). + +-include("rabbit.hrl"). + +%%---------------------------------------------------------------------------- + +-spec start_link(any(), rabbit_net:socket(), module(), any()) -> + {'ok', pid(), pid()}. + +start_link(Ref, _Sock, _Transport, _Opts) -> + {ok, SupPid} = supervisor2:start_link(?MODULE, []), + %% We need to get channels in the hierarchy here so they get shut + %% down after the reader, so the reader gets a chance to terminate + %% them cleanly. But for 1.0 readers we can't start the real + %% ch_sup_sup (because we don't know if we will be 0-9-1 or 1.0) - + %% so we add another supervisor into the hierarchy. + %% + %% This supervisor also acts as an intermediary for heartbeaters and + %% the queue collector process, since these must not be siblings of the + %% reader due to the potential for deadlock if they are added/restarted + %% whilst the supervision tree is shutting down. + {ok, HelperSup} = + supervisor2:start_child( + SupPid, + {helper_sup, {rabbit_connection_helper_sup, start_link, []}, + intrinsic, infinity, supervisor, [rabbit_connection_helper_sup]}), + {ok, ReaderPid} = + supervisor2:start_child( + SupPid, + {reader, {rabbit_reader, start_link, [HelperSup, Ref]}, + intrinsic, ?WORKER_WAIT, worker, [rabbit_reader]}), + {ok, SupPid, ReaderPid}. + +-spec reader(pid()) -> pid(). + +reader(Pid) -> + hd(supervisor2:find_child(Pid, reader)). + +%%-------------------------------------------------------------------------- + +init([]) -> + ?LG_PROCESS_TYPE(connection_sup), + {ok, {{one_for_all, 0, 1}, []}}. |