File 7802-Test-UDP-socket-options.patch of Package erlang

Overview Repositories Revisions Requests Users Attributes Meta

File 7802-Test-UDP-socket-options.patch of Package erlang

From 6c27bc5ffaed274245944e5174861876a3c9aaa8 Mon Sep 17 00:00:00 2001
From: Raimo Niskanen <raimo@erlang.org>
Date: Tue, 29 Aug 2023 12:33:16 +0200
Subject: [PATCH 2/4] Test UDP socket options

---
 lib/kernel/test/inet_sockopt_SUITE.erl | 81 +++++++++++++++++++++++++-
 1 file changed, 80 insertions(+), 1 deletion(-)

diff --git a/lib/kernel/test/inet_sockopt_SUITE.erl b/lib/kernel/test/inet_sockopt_SUITE.erl
index 402e7440aa..7c07636751 100644
--- a/lib/kernel/test/inet_sockopt_SUITE.erl
+++ b/lib/kernel/test/inet_sockopt_SUITE.erl
@@ -133,7 +133,9 @@ loop_all(Config) when is_list(Config) ->
 	lists:foldr(make_check_fun(accept),[],all_accept_options()),
     ConnectFailures =
 	lists:foldr(make_check_fun(connect),[],all_connect_options()),
-    case ListenFailures++AcceptFailures++ConnectFailures of
+    UdpFailures =
+	lists:foldr(make_check_fun(Config),[],all_udp_options()),
+    case ListenFailures++AcceptFailures++ConnectFailures++UdpFailures of
 	[] ->
 	    ok;
 	Failed ->
@@ -1141,6 +1143,54 @@ make_check_fun(Config, Type) ->
 	    NewAcc
     end.
 
+make_check_fun(_Config) ->
+    fun ({Name,V1,V2,Mand,Chang} = Spec, Acc) ->
+            try
+                {ok,S1} = gen_udp:open(0, [{Name,V1}]),
+                {ok,S2} = gen_udp:open(0, [{Name,V2}]),
+                try
+                    {ok,[{Name,R1}]} = inet:getopts(S1, [Name]),
+                    {ok,[{Name,R2}]} = inet:getopts(S2, [Name]),
+                    case R1 =/= R2 of
+                        true ->
+                            case Chang of
+                                true ->
+                                    ok = inet:setopts(S1, [{Name,V2}]),
+                                    {ok,[{Name,R3}]} =
+                                        inet:getopts(S1, [Name]),
+                                    if
+                                        R3 =/= R1, R3 =:= R2 ->
+                                            Acc;
+                                        true ->
+                                            case Mand of
+                                                true ->
+                                                    exit(
+                                                      {failed_sockopt,
+                                                       {change,Name}});
+                                                false ->
+                                                    [{change,Name}|Acc]
+                                            end
+                                    end;
+                                false ->
+                                    Acc
+                            end;
+                        false ->
+                            case Mand of
+                                true ->
+                                    exit({failed_sockopt, {udp,Name}});
+                                false ->
+                                    [{udp,Name}|Acc]
+                            end
+                    end
+                after
+                    gen_udp:close(S1),
+                    gen_udp:close(S2)
+                end
+            catch Class : Reason : Stacktrace ->
+                    erlang:raise(Class, {fail,Reason,Spec}, Stacktrace)
+            end
+    end.
+
 %% {OptionName,Value1,Value2,Mandatory,Changeable}
 all_listen_options() ->
     OsType = os:type(),
@@ -1211,6 +1261,35 @@ all_connect_options() ->
     ].
 
 
+all_udp_options() ->
+    OsType = os:type(),
+    OsVersion = os:version(),
+    [{tos,0,1,false,true},
+     {priority,0,1,false,true},
+     {reuseaddr,false,true,mandatory_reuseaddr(OsType,OsVersion),false},
+     {reuseport,false,true,mandatory_reuseport(OsType,OsVersion),false},
+     {reuseport_lb,false,true,mandatory_reuseport_lb(OsType,OsVersion),false},
+     {exclusiveaddruse,false,true,
+      mandatory_exclusiveaddruse(OsType,OsVersion),false},
+     {sndbuf,2048,4096,false,true},
+     {recbuf,2048,4096,false,true},
+     {header,2,4,true,true},
+     {active,false,true,true,false},
+     {buffer,1000,2000,true,true},
+     {mode,list,binary,true,true},
+     {deliver,term,port,true,true},
+     %% broadcast
+     %% dontroute
+     %% multicast_if
+     %% multicast_ttl
+     %% multicast_loop
+     %% add_membership
+     %% drop_membership
+     %% read_packets
+     {high_msgq_watermark,4096,8192,true,true},
+     {low_msgq_watermark,2048,4096,true,true}].
+
+
 %% Mandatory on a lot of system other than those listed below. Please add more...
 mandatory_reuseaddr({unix, linux}, _OsVersion) ->
     true;
-- 
2.35.3

Places

File 7802-Test-UDP-socket-options.patch of Package erlang

Places