[esock|test] Add ttest case(s) (sso/cso/s,m,l) work for local (stream)

Add ttest test case(s) for Unix Domain (stream) socket:

    Server:       socket with active = once
    Client:       socket with active = once
    Message Size: small, medium and large

Also added server path cleanup when closing.

OTP-15822

2 files changed, 89 insertions, 1 deletions

diff --git a/erts/emulator/test/socket_SUITE.erl b/erts/emulator/test/socket_SUITE.erl
index 456e4fed56..7b3de1de9a 100644
--- a/erts/emulator/test/socket_SUITE.erl
+++ b/erts/emulator/test/socket_SUITE.erl
@@ -418,10 +418,13 @@
 
          ttest_ssocko_csocko_small_tcp4/1,
          ttest_ssocko_csocko_small_tcp6/1,
+         ttest_ssocko_csocko_small_tcpL/1,
          ttest_ssocko_csocko_medium_tcp4/1,
          ttest_ssocko_csocko_medium_tcp6/1,
+         ttest_ssocko_csocko_medium_tcpL/1,
          ttest_ssocko_csocko_large_tcp4/1,
          ttest_ssocko_csocko_large_tcp6/1,
+         ttest_ssocko_csocko_large_tcpL/1,
 
          ttest_ssocko_csockt_small_tcp4/1,
          ttest_ssocko_csockt_small_tcp6/1,
@@ -1346,12 +1349,15 @@ ttest_ssocko_csocko_cases() ->
     [
      ttest_ssocko_csocko_small_tcp4,
      ttest_ssocko_csocko_small_tcp6,
+     ttest_ssocko_csocko_small_tcpL,
 
      ttest_ssocko_csocko_medium_tcp4,
      ttest_ssocko_csocko_medium_tcp6,
+     ttest_ssocko_csocko_medium_tcpL,
 
      ttest_ssocko_csocko_large_tcp4,
-     ttest_ssocko_csocko_large_tcp6
+     ttest_ssocko_csocko_large_tcp6,
+     ttest_ssocko_csocko_large_tcpL
     ].
 
 %% Server: transport = socket(tcp), active = once
@@ -17612,6 +17618,30 @@ ttest_ssocko_csocko_small_tcp6(Config) when is_list(Config) ->
 %% ping-pong like test case.
 %% Server:       Transport = socket(tcp), Active = once
 %% Client:       Transport = socket(tcp), Active = once
+%% Message Size: small (=1)
+%% Domain:       local
+%% 
+
+ttest_ssocko_csocko_small_tcpL(suite) ->
+    [];
+ttest_ssocko_csocko_small_tcpL(doc) ->
+    [];
+ttest_ssocko_csocko_small_tcpL(Config) when is_list(Config) ->
+    Runtime = which_ttest_runtime(Config),
+    ttest_tcp(ttest_ssocko_csocko_small_tcpL,
+              Runtime,
+              local,
+              sock, once,
+              sock, once,
+              1, 200).
+
+
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+%% This test case uses the time test (ttest) utility to implement a 
+%% ping-pong like test case.
+%% Server:       Transport = socket(tcp), Active = once
+%% Client:       Transport = socket(tcp), Active = once
 %% Message Size: medium (=2)
 %% Domain:       inet
 %%
@@ -17660,6 +17690,30 @@ ttest_ssocko_csocko_medium_tcp6(Config) when is_list(Config) ->
 %% ping-pong like test case.
 %% Server:       Transport = socket(tcp), Active = once
 %% Client:       Transport = socket(tcp), Active = once
+%% Message Size: medium (=2)
+%% Domain:       local
+%% 
+
+ttest_ssocko_csocko_medium_tcpL(suite) ->
+    [];
+ttest_ssocko_csocko_medium_tcpL(doc) ->
+    [];
+ttest_ssocko_csocko_medium_tcpL(Config) when is_list(Config) ->
+    Runtime = which_ttest_runtime(Config),
+    ttest_tcp(ttest_ssocko_csocko_medium_tcpL,
+              Runtime,
+              local,
+              sock, once,
+              sock, once,
+              2, 20).
+
+
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+%% This test case uses the time test (ttest) utility to implement a 
+%% ping-pong like test case.
+%% Server:       Transport = socket(tcp), Active = once
+%% Client:       Transport = socket(tcp), Active = once
 %% Message Size: large (=3)
 %% Domain:       inet
 %%
@@ -17707,6 +17761,30 @@ ttest_ssocko_csocko_large_tcp6(Config) when is_list(Config) ->
 %% This test case uses the time test (ttest) utility to implement a 
 %% ping-pong like test case.
 %% Server:       Transport = socket(tcp), Active = once
+%% Client:       Transport = socket(tcp), Active = once
+%% Message Size: large (=3)
+%% Domain:       local
+%% 
+
+ttest_ssocko_csocko_large_tcpL(suite) ->
+    [];
+ttest_ssocko_csocko_large_tcpL(doc) ->
+    [];
+ttest_ssocko_csocko_large_tcpL(Config) when is_list(Config) ->
+    Runtime = which_ttest_runtime(Config),
+    ttest_tcp(ttest_ssocko_csocko_large_tcpL,
+              Runtime,
+              local,
+              sock, once,
+              sock, once,
+              3, 2).
+
+
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+%% This test case uses the time test (ttest) utility to implement a 
+%% ping-pong like test case.
+%% Server:       Transport = socket(tcp), Active = once
 %% Client:       Transport = socket(tcp), Active = true
 %% Message Size: small (=1)
 %% Domain:       inet
diff --git a/erts/emulator/test/socket_test_ttest_tcp_server.erl b/erts/emulator/test/socket_test_ttest_tcp_server.erl
index 974f964c36..acb940e9cd 100644
--- a/erts/emulator/test/socket_test_ttest_tcp_server.erl
+++ b/erts/emulator/test/socket_test_ttest_tcp_server.erl
@@ -149,6 +149,7 @@ server_init(Starter, Parent, Transport, Active) ->
 				  mod            => Mod,
                                   active         => Active,
                                   lsock          => LSock,
+                                  port_or_path   => PortOrPath,
                                   handlers       => [],
                                   stats_interval => StatsInterval,
 				  %% Accumulation
@@ -205,15 +206,22 @@ server_accept(#{mod      := Mod,
                 {error, CPReason} ->
 		    (catch Mod:close(Sock)),
 		    (catch Mod:close(LSock)),
+                    maybe_unlink(maps:get(port_or_path, State)),
                     exit({controlling_process, CPReason})
             end;
         {error, timeout} ->
             State;
         {error, AReason} ->
 	    (catch Mod:close(LSock)),
+            maybe_unlink(maps:get(port_or_path, State)),
             exit({accept, AReason})
     end.
 
+maybe_unlink(Path) when is_list(Path) ->
+    os:cmd("unlink " ++ Path);
+maybe_unlink(_) ->
+    ok.
+
 format_peername({Addr, Port}) ->
     case inet:gethostbyaddr(Addr) of
         {ok, #hostent{h_name = N}} ->
@@ -247,6 +255,8 @@ server_handle_message(#{parent := Parent, handlers := H} = State) ->
         {?MODULE, Ref, Parent, stop} ->
             reply(Parent, Ref, ok),
             lists:foreach(fun(P) -> handler_stop(P) end, H),
+            (catch socket:close(maps:get(lsock, State))),
+             maybe_unlink(maps:get(port_or_path, State)),
             exit(normal);
 
         {'DOWN', _MRef, process, Pid, Reason} ->