Trigger CI

Author: mkuratczyk

deps/amqp10_client/src/amqp10_client_frame_reader.erl

@@ -158,7 +158,7 @@ handle_event(info, {TcpError, _Sock, Reason}, StateName, State)
 handle_event(info, {TcpClosed, _}, StateName, State)
   when TcpClosed == tcp_closed orelse TcpClosed == ssl_closed ->
     ?LOG_INFO("AMQP 1.0 connection socket was closed, connection state: '~ts'",
-                [StateName]),
+              [StateName]),
     {stop, normal, socket_closed(State)};
 handle_event(info, {gun_down, WsPid, _Proto, Reason, _Streams}, StateName,
              #state{socket = {ws, WsPid, _StreamRef}} = State) ->

deps/amqp_client/src/amqp_channel.erl

@@ -516,7 +516,7 @@ handle_info({bump_credit, Msg}, State) ->
 %% @private
 handle_info(timed_out_flushing_channel, State) ->
     ?LOG_WARNING("Channel (~tp) closing: timed out flushing while "
-              "connection closing", [self()]),
+                 "connection closing", [self()]),
     {stop, timed_out_flushing_channel, State};
 %% @private
 handle_info({'DOWN', _, process, ReturnHandler, shutdown},
@@ -525,7 +525,7 @@ handle_info({'DOWN', _, process, ReturnHandler, shutdown},
 handle_info({'DOWN', _, process, ReturnHandler, Reason},
             State = #state{return_handler = {ReturnHandler, _Ref}}) ->
     ?LOG_WARNING("Channel (~tp): Unregistering return handler ~tp because it died. "
-              "Reason: ~tp", [self(), ReturnHandler, Reason]),
+                 "Reason: ~tp", [self(), ReturnHandler, Reason]),
     {noreply, State#state{return_handler = none}};
 %% @private
 handle_info({'DOWN', _, process, ConfirmHandler, shutdown},
@@ -534,7 +534,7 @@ handle_info({'DOWN', _, process, ConfirmHandler, shutdown},
 handle_info({'DOWN', _, process, ConfirmHandler, Reason},
             State = #state{confirm_handler = {ConfirmHandler, _Ref}}) ->
     ?LOG_WARNING("Channel (~tp): Unregistering confirm handler ~tp because it died. "
-              "Reason: ~tp", [self(), ConfirmHandler, Reason]),
+                 "Reason: ~tp", [self(), ConfirmHandler, Reason]),
     {noreply, State#state{confirm_handler = none}};
 %% @private
 handle_info({'DOWN', _, process, FlowHandler, shutdown},
@@ -543,7 +543,7 @@ handle_info({'DOWN', _, process, FlowHandler, shutdown},
 handle_info({'DOWN', _, process, FlowHandler, Reason},
             State = #state{flow_handler = {FlowHandler, _Ref}}) ->
     ?LOG_WARNING("Channel (~tp): Unregistering flow handler ~tp because it died. "
-              "Reason: ~tp", [self(), FlowHandler, Reason]),
+                 "Reason: ~tp", [self(), FlowHandler, Reason]),
     {noreply, State#state{flow_handler = none}};
 handle_info({'DOWN', _, process, QPid, _Reason}, State) ->
     rabbit_amqqueue_common:notify_sent_queue_down(QPid),
@@ -593,13 +593,13 @@ handle_method_to_server(Method, AmqpMsg, From, Sender, Flow,
                                    From, Sender, Flow, State1)};
         {ok, none, BlockReply} ->
             ?LOG_WARNING("Channel (~tp): discarding method ~tp in cast.~n"
-                      "Reason: ~tp", [self(), Method, BlockReply]),
+                         "Reason: ~tp", [self(), Method, BlockReply]),
             {noreply, State};
         {ok, _, BlockReply} ->
             {reply, BlockReply, State};
         {{_, InvalidMethodMessage}, none, _} ->
             ?LOG_WARNING("Channel (~tp): ignoring cast of ~tp method. " ++
-                      InvalidMethodMessage ++ "", [self(), Method]),
+                         InvalidMethodMessage ++ "", [self(), Method]),
             {noreply, State};
         {{InvalidMethodReply, _}, _, _} ->
             {reply, {error, InvalidMethodReply}, State}
@@ -796,7 +796,7 @@ handle_method_from_server1(#'basic.ack'{} = BasicAck, none,
 handle_method_from_server1(#'basic.nack'{} = BasicNack, none,
                            #state{confirm_handler = none} = State) ->
     ?LOG_WARNING("Channel (~tp): received ~tp but there is no "
-              "confirm handler registered", [self(), BasicNack]),
+                 "confirm handler registered", [self(), BasicNack]),
     {noreply, update_confirm_set(BasicNack, State)};
 handle_method_from_server1(#'basic.nack'{} = BasicNack, none,
                            #state{confirm_handler = {CH, _Ref}} = State) ->
@@ -932,7 +932,7 @@ server_misbehaved(#amqp_error{} = AmqpError, State = #state{number = Number}) ->
             handle_shutdown({server_misbehaved, AmqpError}, State);
         {_, Close} ->
             ?LOG_WARNING("Channel (~tp) flushing and closing due to soft "
-                      "error caused by the server ~tp", [self(), AmqpError]),
+                         "error caused by the server ~tp", [self(), AmqpError]),
             Self = self(),
             spawn(fun () -> call(Self, Close) end),
             {noreply, State}

deps/amqp_client/src/amqp_connection.erl

@@ -429,7 +429,7 @@ maybe_update_call_timeout(BaseTimeout, CallTimeout)
 maybe_update_call_timeout(BaseTimeout, CallTimeout) ->
     EffectiveSafeCallTimeout = amqp_util:safe_call_timeout(BaseTimeout),
     ?LOG_WARNING("AMQP 0-9-1 client call timeout was ~tp ms, is updated to a safe effective "
-              "value of ~tp ms", [CallTimeout, EffectiveSafeCallTimeout]),
+                 "value of ~tp ms", [CallTimeout, EffectiveSafeCallTimeout]),
     amqp_util:update_call_timeout(EffectiveSafeCallTimeout),
     ok.
 

deps/amqp_client/src/amqp_gen_connection.erl

@@ -207,12 +207,12 @@ handle_cast({register_blocked_handler, HandlerPid}, State) ->
 handle_info({'DOWN', _, process, BlockHandler, Reason},
             State = #state{block_handler = {BlockHandler, _Ref}}) ->
     ?LOG_WARNING("Connection (~tp): Unregistering connection.{blocked,unblocked} handler ~tp because it died. "
-              "Reason: ~tp", [self(), BlockHandler, Reason]),
+                 "Reason: ~tp", [self(), BlockHandler, Reason]),
     {noreply, State#state{block_handler = none}};
 handle_info({'EXIT', BlockHandler, Reason},
             State = #state{block_handler = {BlockHandler, Ref}}) ->
     ?LOG_WARNING("Connection (~tp): Unregistering connection.{blocked,unblocked} handler ~tp because it died. "
-              "Reason: ~tp", [self(), BlockHandler, Reason]),
+                 "Reason: ~tp", [self(), BlockHandler, Reason]),
     erlang:demonitor(Ref, [flush]),
     {noreply, State#state{block_handler = none}};
 %% propagate the exit to the module that will stop with a sensible reason logged
@@ -318,7 +318,7 @@ internal_error(Pid, Reason, State) ->
 
 server_initiated_close(Close, State) ->
     ?LOG_WARNING("Connection (~tp) closing: received hard error ~tp "
-              "from server", [self(), Close]),
+                 "from server", [self(), Close]),
     set_closing_state(abrupt, #closing{reason = server_initiated_close,
                                        close = Close}, State).
 

deps/amqp_client/src/amqp_ssl.erl

@@ -53,7 +53,7 @@ maybe_add_verify1(Options) ->
             Options;
         _ ->
             ?LOG_WARNING("Connection (~tp): certificate chain verification is not enabled for this TLS connection. "
-                    "Please see https://rabbitmq.com/ssl.html for more information.", [self()]),
+                         "Please see https://rabbitmq.com/ssl.html for more information.", [self()]),
             Options
     end.
 

deps/rabbit/src/mirrored_supervisor.erl

@@ -288,15 +288,15 @@ handle_call({start_child, ChildSpec}, _From,
     Result = case maybe_start(Group, Overall, Delegate, ChildSpec) of
                  already_in_store ->
                      ?LOG_DEBUG("Mirrored supervisor: maybe_start for group ~tp,"
-                                      " overall ~p returned 'record already present'", [Group, Overall]),
+                                " overall ~p returned 'record already present'", [Group, Overall]),
                      {error, already_present};
                  {already_in_store, Pid} ->
                      ?LOG_DEBUG("Mirrored supervisor: maybe_start for group ~tp,"
-                                      " overall ~p returned 'already running: ~tp'", [Group, Overall, Pid]),
+                                " overall ~p returned 'already running: ~tp'", [Group, Overall, Pid]),
                      {error, {already_started, Pid}};
                  Else ->
                      ?LOG_DEBUG("Mirrored supervisor: maybe_start for group ~tp,"
-                                      " overall ~tp returned ~tp", [Group, Overall, Else]),
+                                " overall ~tp returned ~tp", [Group, Overall, Else]),
                      Else
              end,
     mirrored_supervisor_locks:unlock(LockId),
@@ -384,16 +384,16 @@ maybe_start(Group, Overall, Delegate, ChildSpec) ->
     try check_start(Group, Overall, Delegate, ChildSpec) of
         start      ->
             ?LOG_DEBUG("Mirrored supervisor: check_start for group ~tp,"
-                             " overall ~tp returned 'do start'", [Group, Overall]),
+                       " overall ~tp returned 'do start'", [Group, Overall]),
             start(Delegate, ChildSpec);
         undefined  ->
             ?LOG_DEBUG("Mirrored supervisor: check_start for group ~tp,"
-                             " overall ~tp returned 'undefined'", [Group, Overall]),
+                       " overall ~tp returned 'undefined'", [Group, Overall]),
             already_in_store;
         Pid ->
             ?LOG_DEBUG("Mirrored supervisor: check_start for group ~tp,"
-                             " overall ~tp returned 'already running (~tp)'",
-                             [Group, Overall, Pid]),
+                       " overall ~tp returned 'already running (~tp)'",
+                       [Group, Overall, Pid]),
             {already_in_store, Pid}
     catch
         %% If we are torn down while in the transaction...
@@ -403,7 +403,7 @@ maybe_start(Group, Overall, Delegate, ChildSpec) ->
 check_start(Group, Overall, Delegate, ChildSpec) ->
     Id = id(ChildSpec),
     ?LOG_DEBUG("Mirrored supervisor: check_start for group ~tp, id: ~tp, "
-                     "overall: ~tp", [Group, Id, Overall]),
+               "overall: ~tp", [Group, Id, Overall]),
     case rabbit_db_msup:create_or_update(Group, Overall, Delegate, ChildSpec, Id) of
         Delegate0 when is_pid(Delegate0) ->
             child(Delegate0, Id);

deps/rabbit/src/rabbit.erl

@@ -358,8 +358,7 @@ run_prelaunch_second_phase() ->
     case IsInitialPass of
         true ->
             ?LOG_DEBUG(""),
-            ?LOG_DEBUG(
-              "== Prelaunch phase [2/2] (initial pass) ==");
+            ?LOG_DEBUG("== Prelaunch phase [2/2] (initial pass) ==");
         false ->
             ?LOG_DEBUG(""),
             ?LOG_DEBUG("== Prelaunch phase [2/2] =="),
@@ -522,10 +521,9 @@ stop_and_halt() ->
     try
         stop()
     catch Type:Reason ->
-        ?LOG_ERROR(
-          "Error trying to stop ~ts: ~tp:~tp",
-          [product_name(), Type, Reason],
-          #{domain => ?RMQLOG_DOMAIN_PRELAUNCH}),
+        ?LOG_ERROR("Error trying to stop ~ts: ~tp:~tp",
+                   [product_name(), Type, Reason],
+                   #{domain => ?RMQLOG_DOMAIN_PRELAUNCH}),
         error({Type, Reason})
     after
         %% Enclose all the logging in the try block.
@@ -896,9 +894,8 @@ environment(App) ->
 -spec rotate_logs() -> rabbit_types:ok_or_error(any()).
 
 rotate_logs() ->
-    ?LOG_ERROR(
-       "Forcing log rotation is currently unsupported",
-       #{domain => ?RMQLOG_DOMAIN_GLOBAL}),
+    ?LOG_ERROR("Forcing log rotation is currently unsupported",
+               #{domain => ?RMQLOG_DOMAIN_GLOBAL}),
     {error, unsupported}.
 
 %%--------------------------------------------------------------------
@@ -1179,7 +1176,7 @@ prevent_startup_if_node_was_reset() ->
                         true ->
                             ?LOG_ERROR("Node has already been initialized, but database appears empty. "
                                        "This could indicate data loss or a split-brain scenario.",
-                                      #{domain => ?RMQLOG_DOMAIN_GLOBAL}),
+                                       #{domain => ?RMQLOG_DOMAIN_GLOBAL}),
                             throw({error, cluster_already_initialized_but_tables_empty});
                         false ->
                             ?LOG_INFO("Node has already been initialized, proceeding with normal startup",
@@ -1189,7 +1186,7 @@ prevent_startup_if_node_was_reset() ->
                 false ->
                     %% First time starting, create the marker file
                     ?LOG_INFO("First node startup detected, creating initialization marker",
-                             #{domain => ?RMQLOG_DOMAIN_GLOBAL}),
+                              #{domain => ?RMQLOG_DOMAIN_GLOBAL}),
                     ok = filelib:ensure_dir(MarkerFile),
                     ok = file:write_file(MarkerFile, <<>>, [exclusive]), % Empty file.
                     ok
@@ -1689,7 +1686,7 @@ maybe_warn_low_fd_limit() ->
             ok;
         L ->
             ?LOG_WARNING("Available file handles: ~tp. "
-                "Please consider increasing system limits", [L])
+                         "Please consider increasing system limits", [L])
     end.
 
 %% Any configuration that

deps/rabbit/src/rabbit_access_control.erl

@@ -75,7 +75,7 @@ check_user_login(Username, AuthProps, Modules) ->
             Type:Error:Stacktrace ->
                 ?LOG_DEBUG("User '~ts' authentication failed with ~ts:~tp:~n~tp", [Username, Type, Error, Stacktrace]),
                 {refused, Username, "User '~ts' authentication failed with internal error. "
-                                    "Enable debug logs to see the real error.", [Username]}
+                           "Enable debug logs to see the real error.", [Username]}
 
         end.
 

deps/rabbit/src/rabbit_amqqueue.erl

@@ -535,11 +535,11 @@ maybe_migrate(ByNode, MaxQueuesDesired, [N | Nodes]) ->
             end;
         [{_, _, true} | _] = All when length(All) > MaxQueuesDesired ->
             ?LOG_WARNING("Node ~tp contains ~tp queues, but all have already migrated. "
-                               "Do nothing", [N, length(All)]),
+                         "Do nothing", [N, length(All)]),
             maybe_migrate(ByNode, MaxQueuesDesired, Nodes);
         All ->
             ?LOG_DEBUG("Node ~tp only contains ~tp queues, do nothing",
-                               [N, length(All)]),
+                       [N, length(All)]),
             maybe_migrate(ByNode, MaxQueuesDesired, Nodes)
     end.
 
@@ -1895,7 +1895,8 @@ internal_delete(Queue, ActingUser, Reason) ->
 %% TODO this is used by `rabbit_mnesia:remove_node_if_mnesia_running`
 %% Does it make any sense once mnesia is not used/removed?
 forget_all_durable(Node) ->
-    ?LOG_INFO("Will remove all classic queues from node ~ts. The node is likely being removed from the cluster.", [Node]),
+    ?LOG_INFO("Will remove all classic queues from node ~ts. The node is likely being removed from the cluster.",
+              [Node]),
     UpdateFun = fun(Q) ->
                         forget_node_for_queue(Q)
                 end,
@@ -1961,9 +1962,9 @@ on_node_down(Node) ->
             %% restarts - a time that the cluster is very likely to have a
             %% majority - to ensure these records are deleted.
             ?LOG_WARNING("transient queues for node '~ts' could not be "
-                               "deleted because of a timeout. These queues "
-                               "will be removed when node '~ts' restarts or "
-                               "is removed from the cluster.", [Node, Node]),
+                         "deleted because of a timeout. These queues "
+                         "will be removed when node '~ts' restarts or "
+                         "is removed from the cluster.", [Node, Node]),
             ok
     end.
 

deps/rabbit/src/rabbit_auth_backend_internal.erl

@@ -472,17 +472,17 @@ notify_user_tags_set(Username, ConvertedTags, ActingUser) ->
 
 set_permissions(Username, VirtualHost, ConfigurePerm, WritePerm, ReadPerm, ActingUser) ->
     ?LOG_DEBUG("Asked to set permissions for user "
-                     "'~ts' in virtual host '~ts' to '~ts', '~ts', '~ts'",
-                     [Username, VirtualHost, ConfigurePerm, WritePerm, ReadPerm]),
+               "'~ts' in virtual host '~ts' to '~ts', '~ts', '~ts'",
+               [Username, VirtualHost, ConfigurePerm, WritePerm, ReadPerm]),
     _ = lists:map(
       fun (RegexpBin) ->
               Regexp = binary_to_list(RegexpBin),
               case re:compile(Regexp) of
                   {ok, _}         -> ok;
                   {error, Reason} ->
                       ?LOG_WARNING("Failed to set permissions for user '~ts' in virtual host '~ts': "
-                                         "regular expression '~ts' is invalid",
-                                         [Username, VirtualHost, RegexpBin]),
+                                   "regular expression '~ts' is invalid",
+                                   [Username, VirtualHost, RegexpBin]),
                       throw({error, {invalid_regexp, Regexp, Reason}})
               end
       end, [ConfigurePerm, WritePerm, ReadPerm]),
@@ -497,8 +497,8 @@ set_permissions(Username, VirtualHost, ConfigurePerm, WritePerm, ReadPerm, Actin
                                             read       = ReadPerm}},
         R = rabbit_db_user:set_user_permissions(UserPermission),
         ?LOG_INFO("Successfully set permissions for user "
-                        "'~ts' in virtual host '~ts' to '~ts', '~ts', '~ts'",
-                        [Username, VirtualHost, ConfigurePerm, WritePerm, ReadPerm]),
+                  "'~ts' in virtual host '~ts' to '~ts', '~ts', '~ts'",
+                  [Username, VirtualHost, ConfigurePerm, WritePerm, ReadPerm]),
         rabbit_event:notify(permission_created, [{user,      Username},
                                                  {vhost,     VirtualHost},
                                                  {configure, ConfigurePerm},
@@ -579,8 +579,8 @@ set_permissions_globally(Username, ConfigurePerm, WritePerm, ReadPerm, ActingUse
 
 set_topic_permissions(Username, VirtualHost, Exchange, WritePerm, ReadPerm, ActingUser) ->
     ?LOG_DEBUG("Asked to set topic permissions on exchange '~ts' for "
-                     "user '~ts' in virtual host '~ts' to '~ts', '~ts'",
-                     [Exchange, Username, VirtualHost, WritePerm, ReadPerm]),
+               "user '~ts' in virtual host '~ts' to '~ts', '~ts'",
+               [Exchange, Username, VirtualHost, WritePerm, ReadPerm]),
     WritePermRegex = rabbit_data_coercion:to_binary(WritePerm),
     ReadPermRegex = rabbit_data_coercion:to_binary(ReadPerm),
     lists:foreach(
@@ -589,8 +589,8 @@ set_topic_permissions(Username, VirtualHost, Exchange, WritePerm, ReadPerm, Acti
                   {ok, _}         -> ok;
                   {error, Reason} ->
                       ?LOG_WARNING("Failed to set topic permissions on exchange '~ts' for user "
-                                         "'~ts' in virtual host '~ts': regular expression '~ts' is invalid",
-                                         [Exchange, Username, VirtualHost, RegexpBin]),
+                                   "'~ts' in virtual host '~ts': regular expression '~ts' is invalid",
+                                   [Exchange, Username, VirtualHost, RegexpBin]),
                       throw({error, {invalid_regexp, RegexpBin, Reason}})
               end
       end, [WritePerm, ReadPerm]),
@@ -609,8 +609,8 @@ set_topic_permissions(Username, VirtualHost, Exchange, WritePerm, ReadPerm, Acti
                             },
         R = rabbit_db_user:set_topic_permissions(TopicPermission),
         ?LOG_INFO("Successfully set topic permissions on exchange '~ts' for "
-                         "user '~ts' in virtual host '~ts' to '~ts', '~ts'",
-                         [Exchange, Username, VirtualHost, WritePerm, ReadPerm]),
+                  "user '~ts' in virtual host '~ts' to '~ts', '~ts'",
+                  [Exchange, Username, VirtualHost, WritePerm, ReadPerm]),
         rabbit_event:notify(topic_permission_created, [
             {user,      Username},
             {vhost,     VirtualHost},