Skip to content

Commit 779c9e4

Browse files
committed
formatting and ensure use sup specs in rabbit_types
1 parent 3bd51f7 commit 779c9e4

File tree

3 files changed

+8
-13
lines changed

3 files changed

+8
-13
lines changed

deps/rabbit/src/rabbit_amqqueue.erl

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2120,8 +2120,9 @@ kill_queue_hard(Node, QRes = #resource{kind = queue}, Reason) ->
21202120
case kill_queue(Node, QRes, Reason) of
21212121
crashed -> ok;
21222122
stopped -> ok;
2123-
NewPid when is_pid(NewPid) -> timer:sleep(?KILL_QUEUE_DELAY_INTERVAL),
2124-
kill_queue_hard(Node, QRes, Reason);
2123+
NewPid when is_pid(NewPid) ->
2124+
timer:sleep(?KILL_QUEUE_DELAY_INTERVAL),
2125+
kill_queue_hard(Node, QRes, Reason);
21252126
Error -> Error
21262127
end.
21272128

deps/rabbit_common/src/rabbit_misc.erl

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1450,18 +1450,10 @@ safe_ets_update_element(Tab, Key, ElementSpec, OnSuccess, OnFailure) ->
14501450
false
14511451
end.
14521452

1453-
%% not exported by supervisor
1454-
-type supervisor_child_id() :: term().
1455-
-type supervisor_sup_ref() :: (Name :: atom())
1456-
| {Name :: atom(), Node :: node()}
1457-
| {'global', Name :: atom()}
1458-
| {'via', Module :: module(), Name :: any()}
1459-
| pid().
1460-
14611453
%% this used to be in supervisor2
14621454
-spec find_child(Supervisor, Name) -> [pid()] when
1463-
Supervisor :: supervisor_sup_ref(),
1464-
Name :: supervisor_child_id().
1455+
Supervisor :: rabbit_types:sup_ref(),
1456+
Name :: rabbit_types:child_id().
14651457
find_child(Supervisor, Name) ->
14661458
[Pid || {Name1, Pid, _Type, _Modules} <- supervisor:which_children(Supervisor),
14671459
Name1 =:= Name].

deps/rabbit_common/src/rabbit_types.erl

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
authz_data/0, authz_context/0,
3232
permission_atom/0, rabbit_amqqueue_name/0, binding_key/0, channel_number/0,
3333
exchange_name/0, exchange_type/0, guid/0, routing_key/0,
34-
sup_ref/0, child/0]).
34+
sup_ref/0, child/0, child_id/0]).
3535

3636
-type(option(T) :: T | 'none' | 'undefined').
3737
%% Deprecated, 'maybe' is a keyword in modern Erlang
@@ -218,10 +218,12 @@
218218

219219
-type(permission_atom() :: 'configure' | 'write' | 'read').
220220

221+
%% not exported by OTP supervisor
221222
-type sup_ref() :: (Name :: atom())
222223
| {Name :: atom(), Node :: node()}
223224
| {'global', Name :: term()}
224225
| {'via', Module :: module(), Name :: any()}
225226
| pid().
226227

227228
-type child() :: 'undefined' | pid().
229+
-type child_id() :: term().

0 commit comments

Comments
 (0)