Handle more "normal" socket errors

Author: RaimoNiskanen

lib/ssl/test/inet_epmd_cryptcookie_inet_ktls.erl

@@ -179,7 +179,10 @@ stream_recv(InStream = [_ | Socket], Size) ->
             [Data | InStream];
         {error, timeout} ->
             [<<>> | InStream];
-        {error, closed} ->
+        {error, Reason}
+          when Reason =:= closed;
+               Reason =:= econnreset;
+               Reason =:= epipe ->
             [closed | InStream];
         {error, Reason} ->
             erlang:error({?MODULE, ?FUNCTION_NAME, Reason})
@@ -192,7 +195,10 @@ stream_send(OutStream = [_ | Socket], Data) ->
     case ?DRIVER:send(Socket, Data) of
         ok ->
             OutStream;
-        {error, closed} ->
+        {error, Reason}
+          when Reason =:= closed;
+               Reason =:= econnreset;
+               Reason =:= epipe ->
             [closed | OutStream];
         {error, Reason} ->
             erlang:error({?MODULE, ?FUNCTION_NAME, Reason, [OutStream, Data]})

lib/ssl/test/inet_epmd_cryptcookie_socket_ktls.erl

@@ -218,7 +218,8 @@ stream_recv(InStream = [_ | Socket], Size) ->
 stream_recv_error(InStream, Reason) ->
     if
         Reason =:= closed;
-        Reason =:= econnreset ->
+        Reason =:= econnreset;
+        Reason =:= epipe ->
             [closed | InStream];
         true ->
             erlang:error({?MODULE, ?FUNCTION_NAME, Reason})
@@ -233,7 +234,10 @@ stream_send(OutStream = [_ | Socket], Data) ->
     case socket:sendmsg(Socket, #{ iov => Data }) of
         ok ->
             OutStream;
-        {error, closed} ->
+        {error, Reason}
+          when Reason =:= closed;
+               Reason =:= econnreset;
+               Reason =:= epipe ->
             [closed | OutStream];
         {error, Reason} ->
             erlang:error({?MODULE, ?FUNCTION_NAME, Reason, [OutStream, Data]})

lib/ssl/test/inet_epmd_dist_cryptcookie_inet.erl

@@ -168,7 +168,10 @@ stream_recv(InStream = [_ | Socket], Size) ->
             [Data | InStream];
         {error, timeout} ->
             [<<>> | InStream];
-        {error, closed} ->
+        {error, Reason}
+          when Reason =:= closed;
+               Reason =:= econnreset;
+               Reason =:= epipe ->
             [closed | InStream];
         {error, Reason} ->
             erlang:error({?MODULE, ?FUNCTION_NAME, Reason})
@@ -181,7 +184,10 @@ stream_send(OutStream = [_ | Socket], Data) ->
     case ?DRIVER:send(Socket, Data) of
         ok ->
             OutStream;
-        {error, closed} ->
+        {error, Reason}
+          when Reason =:= closed;
+               Reason =:= econnreset;
+               Reason =:= epipe ->
             [closed | OutStream];
         {error, Reason} ->
             erlang:error({?MODULE, ?FUNCTION_NAME, Reason, [OutStream, Data]})

lib/ssl/test/inet_epmd_dist_cryptcookie_socket.erl

@@ -204,7 +204,8 @@ stream_recv(InStream = [_ | Socket], Size) ->
 stream_recv_error(InStream, Reason) ->
     if
         Reason =:= closed;
-        Reason =:= econnreset ->
+        Reason =:= econnreset;
+        Reason =:= epipe ->
             [closed | InStream];
         true ->
             erlang:error({?MODULE, ?FUNCTION_NAME, Reason})
@@ -219,7 +220,10 @@ stream_send(OutStream = [_ | Socket], Data) ->
     case socket:sendmsg(Socket, #{ iov => Data }) of
         ok ->
             OutStream;
-        {error, closed} ->
+        {error, Reason}
+          when Reason =:= closed;
+               Reason =:= econnreset;
+               Reason =:= epipe ->
             [closed | OutStream];
         {error, Reason} ->
             erlang:error({?MODULE, ?FUNCTION_NAME, Reason, [OutStream, Data]})