Browse Source

Chang log format.

Roberto Ostinelli 3 years ago
parent
commit
4d2e13731d
3 changed files with 15 additions and 15 deletions
  1. 6 6
      src/syn_gen_scope.erl
  2. 3 3
      src/syn_groups.erl
  3. 6 6
      src/syn_registry.erl

+ 6 - 6
src/syn_gen_scope.erl

@@ -205,7 +205,7 @@ handle_info({'3.0', discover, RemoteScopePid}, #state{
     nodes_map = NodesMap
 } = State) ->
     RemoteScopeNode = node(RemoteScopePid),
-    error_logger:info_msg("SYN[~s|~s] Received DISCOVER request from node '~s'",
+    error_logger:info_msg("SYN[~s<~s>] Received DISCOVER request from node '~s'",
         [Handler, Scope, RemoteScopeNode]
     ),
     %% send local data to remote
@@ -229,7 +229,7 @@ handle_info({'3.0', ack_sync, RemoteScopePid, Data}, #state{
     scope = Scope
 } = State) ->
     RemoteScopeNode = node(RemoteScopePid),
-    error_logger:info_msg("SYN[~s|~s] Received ACK SYNC (~w entries) from node '~s'",
+    error_logger:info_msg("SYN[~s<~s>] Received ACK SYNC (~w entries) from node '~s'",
         [Handler, Scope, length(Data), RemoteScopeNode]
     ),
     %% save remote data
@@ -259,7 +259,7 @@ handle_info({'DOWN', MRef, process, Pid, Reason}, #state{
     RemoteNode = node(Pid),
     case maps:take(RemoteNode, NodesMap) of
         {Pid, NodesMap1} ->
-            error_logger:info_msg("SYN[~s|~s] Scope Process is DOWN on node '~s': ~p",
+            error_logger:info_msg("SYN[~s<~s>] Scope Process is DOWN on node '~s': ~p",
                 [Handler, Scope, RemoteNode, Reason]
             ),
             Handler:purge_local_data_for_node(RemoteNode, State),
@@ -278,7 +278,7 @@ handle_info({nodeup, RemoteNode}, #state{
     handler = Handler,
     scope = Scope
 } = State) ->
-    error_logger:info_msg("SYN[~s|~s] Node '~s' has joined the cluster, sending discover message",
+    error_logger:info_msg("SYN[~s<~s>] Node '~s' has joined the cluster, sending discover message",
         [Handler, Scope, RemoteNode]
     ),
     send_to_node(RemoteNode, {'3.0', discover, self()}, State),
@@ -298,7 +298,7 @@ handle_continue(after_init, #state{
     handler = Handler,
     scope = Scope
 } = State) ->
-    error_logger:info_msg("SYN[~s|~s] Discovering the cluster", [Handler, Scope]),
+    error_logger:info_msg("SYN[~s<~s>] Discovering the cluster", [Handler, Scope]),
     broadcast_all_cluster({'3.0', discover, self()}, State),
     {noreply, State}.
 
@@ -307,7 +307,7 @@ handle_continue(after_init, #state{
 %% ----------------------------------------------------------------------------------------------------------
 -spec terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()), #state{}) -> any().
 terminate(Reason, #state{handler = Handler, scope = Scope}) ->
-    error_logger:info_msg("SYN[~s|~s] ~s terminating with reason: ~p", [Handler, Scope, Handler, Reason]).
+    error_logger:info_msg("SYN[~s<~s>] ~s terminating with reason: ~p", [Handler, Scope, Handler, Reason]).
 
 %% ----------------------------------------------------------------------------------------------------------
 %% Convert process state when code is changed.

+ 3 - 3
src/syn_groups.erl

@@ -304,7 +304,7 @@ handle_call({leave_on_owner, RequesterNode, GroupName, Pid}, _From, #state{
     end;
 
 handle_call(Request, From, #state{scope = Scope} = State) ->
-    error_logger:warning_msg("SYN[~s|~s] Received from ~p an unknown call message: ~p", [?MODULE, Scope, From, Request]),
+    error_logger:warning_msg("SYN[~s<~s>] Received from ~p an unknown call message: ~p", [?MODULE, Scope, From, Request]),
     {reply, undefined, State}.
 
 %% ----------------------------------------------------------------------------------------------------------
@@ -338,7 +338,7 @@ handle_info({'DOWN', _MRef, process, Pid, Reason}, #state{
     case find_groups_entries_by_pid(Pid, TableByPid) of
         [] ->
             error_logger:warning_msg(
-                "SYN[~s|~s] Received a DOWN message from an unknown process ~p with reason: ~p",
+                "SYN[~s<~s>] Received a DOWN message from an unknown process ~p with reason: ~p",
                 [?MODULE, Scope, Pid, Reason]
             );
 
@@ -356,7 +356,7 @@ handle_info({'DOWN', _MRef, process, Pid, Reason}, #state{
     {noreply, State};
 
 handle_info(Info, #state{scope = Scope} = State) ->
-    error_logger:warning_msg("SYN[~s|~s] Received an unknown info message: ~p", [?MODULE, Scope, Info]),
+    error_logger:warning_msg("SYN[~s<~s>] Received an unknown info message: ~p", [?MODULE, Scope, Info]),
     {noreply, State}.
 
 %% ----------------------------------------------------------------------------------------------------------

+ 6 - 6
src/syn_registry.erl

@@ -262,7 +262,7 @@ handle_call({unregister_on_owner, RequesterNode, Name, Pid}, _From, #state{
     end;
 
 handle_call(Request, From, #state{scope = Scope} = State) ->
-    error_logger:warning_msg("SYN[~s|~s] Received from ~p an unknown call message: ~p", [?MODULE, Scope, From, Request]),
+    error_logger:warning_msg("SYN[~s<~s>] Received from ~p an unknown call message: ~p", [?MODULE, Scope, From, Request]),
     {reply, undefined, State}.
 
 %% ----------------------------------------------------------------------------------------------------------
@@ -295,7 +295,7 @@ handle_info({'DOWN', _MRef, process, Pid, Reason}, #state{
     case find_registry_entries_by_pid(Pid, TableByPid) of
         [] ->
             error_logger:warning_msg(
-                "SYN[~s|~s] Received a DOWN message from an unknown process ~p with reason: ~p",
+                "SYN[~s<~s>] Received a DOWN message from an unknown process ~p with reason: ~p",
                 [?MODULE, Scope, Pid, Reason]
             );
 
@@ -313,7 +313,7 @@ handle_info({'DOWN', _MRef, process, Pid, Reason}, #state{
     {noreply, State};
 
 handle_info(Info, #state{scope = Scope} = State) ->
-    error_logger:warning_msg("SYN[~s|~s] Received an unknown info message: ~p", [?MODULE, Scope, Info]),
+    error_logger:warning_msg("SYN[~s<~s>] Received an unknown info message: ~p", [?MODULE, Scope, Info]),
     {noreply, State}.
 
 %% ----------------------------------------------------------------------------------------------------------
@@ -551,7 +551,7 @@ resolve_conflict(Scope, Name, {Pid, Meta, Time}, {TablePid, TableMeta, TableTime
     case PidToKeep of
         Pid ->
             %% -> we keep the remote pid
-            error_logger:info_msg("SYN[~s|~s] Registry CONFLICT for name ~p: ~p vs ~p -> keeping remote: ~p",
+            error_logger:info_msg("SYN[~s<~s>] Registry CONFLICT for name ~p: ~p vs ~p -> keeping remote: ~p",
                 [?MODULE, Scope, Name, Pid, TablePid, Pid]
             ),
             %% update locally, the incoming sync_register will update with the time coming from remote node
@@ -564,7 +564,7 @@ resolve_conflict(Scope, Name, {Pid, Meta, Time}, {TablePid, TableMeta, TableTime
 
         TablePid ->
             %% -> we keep the local pid
-            error_logger:info_msg("SYN[~s|~s] Registry CONFLICT for name ~p: ~p vs ~p -> keeping local: ~p",
+            error_logger:info_msg("SYN[~s<~s>] Registry CONFLICT for name ~p: ~p vs ~p -> keeping local: ~p",
                 [?MODULE, Scope, Name, Pid, TablePid, TablePid]
             ),
             %% overwrite with updated time
@@ -574,7 +574,7 @@ resolve_conflict(Scope, Name, {Pid, Meta, Time}, {TablePid, TableMeta, TableTime
             syn_gen_scope:broadcast({'3.0', sync_register, Name, TablePid, TableMeta, ResolveTime}, State);
 
         Invalid ->
-            error_logger:info_msg("SYN[~s|~s] Registry CONFLICT for name ~p: ~p vs ~p -> none chosen (got: ~p)",
+            error_logger:info_msg("SYN[~s<~s>] Registry CONFLICT for name ~p: ~p vs ~p -> none chosen (got: ~p)",
                 [?MODULE, Scope, Name, Pid, TablePid, Invalid]
             ),
             %% remove