1 files changed, 111 insertions, 0 deletions
diff --git a/erts/emulator/test/socket_test_logger.erl b/erts/emulator/test/socket_test_logger.erl
new file mode 100644
index 0000000000..e42251158f
--- /dev/null
+++ b/erts/emulator/test/socket_test_logger.erl
@@ -0,0 +1,111 @@
+%%
+%% %CopyrightBegin%
+%%
+%% Copyright Ericsson AB 2018-2018. All Rights Reserved.
+%%
+%% Licensed under the Apache License, Version 2.0 (the "License");
+%% you may not use this file except in compliance with the License.
+%% You may obtain a copy of the License at
+%%
+%%     http://www.apache.org/licenses/LICENSE-2.0
+%%
+%% Unless required by applicable law or agreed to in writing, software
+%% distributed under the License is distributed on an "AS IS" BASIS,
+%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+%% See the License for the specific language governing permissions and
+%% limitations under the License.
+%%
+%% %CopyrightEnd%
+%%
+
+-module(socket_test_logger).
+
+-export([
+         start/0,
+         stop/0,
+         format/2
+        ]).
+
+
+-define(LIB,    socket_test_lib).
+-define(LOGGER, ?MODULE).
+
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+start() ->
+    case global:whereis_name(?LOGGER) of
+        Pid when is_pid(Pid) ->
+            ok;
+        undefined ->
+            Self = self(),
+            Pid = spawn_link(fun() -> init(Self) end),
+            yes = global:register_name(?LOGGER, Pid),
+            ok
+    end.
+
+
+stop() ->
+    case global:whereis_name(?LOGGER) of
+        undefined ->
+            ok;
+        Pid when is_pid(Pid) ->
+            global:unregister_name(?LOGGER),
+            Pid ! {?LOGGER, '$logger', stop},
+            ok
+    end.
+
+
+format(F, []) ->
+    do_format(F);
+format(F, A) ->
+    do_format(?LIB:f(F, A)).
+
+do_format(Msg) ->
+    case global:whereis_name(?LOGGER) of
+        undefined ->
+            ok;
+        Pid when is_pid(Pid) ->
+            Pid ! {?MODULE, '$logger', {msg, Msg}},
+            ok
+    end.
+
+init(Parent) ->
+    put(sname, "logger"),
+    print("[~s][logger] starting~n", [?LIB:formated_timestamp()]),
+    loop(#{parent => Parent}).
+
+loop(#{parent := Parent} = State) ->
+    receive
+        {'EXIT', Parent, _} ->
+            print("[~s][logger] parent exit~n", [?LIB:formated_timestamp()]),
+            exit(normal);
+
+        {?MODULE, '$logger', stop} ->
+            print("[~s][logger] stopping~n", [?LIB:formated_timestamp()]),
+            exit(normal);
+
+        {?MODULE, '$logger', {msg, Msg}} ->
+            print(Msg),
+            loop(State)
+    end.
+
+
+print(F, A) ->
+    print(?LIB:f(F, A)).
+
+print(Str) ->
+    try
+        begin
+            io:format(user, Str ++ "~n", []),
+            io:format(Str, [])
+        end
+    catch
+        _:_:_ ->
+            io:format(user,
+                      "~nFailed Format message:"
+                      "~n~p~n", [Str]),
+            io:format("~nFailed Format message:"
+                      "~n~p~n", [Str])
+    end.
+