Merge branch 'anders/diameter/sctp/OTP-17366' into maint-23

* anders/diameter/sctp/OTP-17366:
  Fix appup blunder
  Add appup
  Suppress dialyzer warnings in code
  Fix association id of unordered send setopts in diameter_sctp
  Fix ignored unordered option on client diameter_sctp transport

Author: Erlang/OTP

lib/diameter/src/Makefile

@@ -231,16 +231,13 @@ $(PLT):
 dialyze: opt $(PLT)
 	dialyzer --plt $(PLT) \
 	         --verbose \
-	         -Wno_improper_lists \
 	         $(EBIN)/diameter_gen_base_rfc3588.$(EMULATOR) \
 	         $(patsubst %, $(EBIN)/%.$(EMULATOR), \
 	                $(notdir $(DICT_YRL) \
 	                         $(RT_MODULES) \
 	                         $(CT_MODULES) \
+	                         $(DICT_MODULES) \
 	                         $(INFO_MODULES)))
-# Omit all but the common dictionary module since these
-# (diameter_gen_relay in particular) generate warnings depending on how
-# much of the included diameter_gen.hrl they use.
 
 # ----------------------------------------------------
 # Release targets

lib/diameter/src/base/diameter_traffic.erl

@@ -26,6 +26,8 @@
 
 -module(diameter_traffic).
 
+-dialyzer(no_improper_lists).
+
 %% towards diameter
 -export([send_request/4]).
 

lib/diameter/src/compiler/diameter_codegen.erl

@@ -1,7 +1,7 @@
 %%
 %% %CopyrightBegin%
 %%
-%% Copyright Ericsson AB 2010-2017. All Rights Reserved.
+%% Copyright Ericsson AB 2010-2020. 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.
@@ -143,7 +143,8 @@ gen(erl, ParseD, Mod) ->
 erl_forms(Mod, ParseD) ->
     Forms = [[{?attribute, module, Mod},
               {?attribute, compile, {parse_transform, diameter_exprecs}},
-              {?attribute, compile, nowarn_unused_function}],
+              {?attribute, compile, nowarn_unused_function},
+              {?attribute, dialyzer, no_return}],
              make_hrl_forms(ParseD),
              [{?attribute, export, [{name, 0},
                                     {id, 0},

lib/diameter/src/diameter.appup.src

@@ -2,7 +2,7 @@
 %%
 %% %CopyrightBegin%
 %%
-%% Copyright Ericsson AB 2010-2020. All Rights Reserved.
+%% Copyright Ericsson AB 2010-2021. 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.
@@ -70,8 +70,11 @@
                {update, diameter_peer_fsm},
                {update, diameter_service},
                {load_module, diameter_traffic},
-               {update, diameter_tcp}]},
- {"2.2.2",    [{load_module, diameter}]}           %% 22.2.8
+               {update, diameter_tcp},
+               {update, diameter_sctp}]},
+ {"2.2.2",    [{load_module, diameter},            %% 22.2.8
+               {update, diameter_sctp}]},
+ {"2.2.3",    [{update, diameter_sctp}]}           %% 22.3
  ],
  [
   {"0.9",     [{restart_application, diameter}]},
@@ -123,7 +126,10 @@
                {update, diameter_peer_fsm},
                {update, diameter_service},
                {load_module, diameter_traffic},
-               {update, diameter_tcp}]},
-  {"2.2.2",   [{load_module, diameter}]}
+               {update, diameter_tcp},
+               {update, diameter_sctp}]},
+  {"2.2.2",   [{load_module, diameter},
+               {update, diameter_sctp}]},
+  {"2.2.3",   [{update, diameter_sctp}]}
  ]
 }.

lib/diameter/src/transport/diameter_sctp.erl

@@ -1,7 +1,7 @@
 %%
 %% %CopyrightBegin%
 %%
-%% Copyright Ericsson AB 2010-2017. All Rights Reserved.
+%% Copyright Ericsson AB 2010-2021. 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.
@@ -283,7 +283,7 @@ i({connect, Pid, Opts, Addrs, Ref}) ->
                mode = {connect, connect(Sock, RAs, RP, [])},
                socket = Sock,
                message_cb = CB,
-               unordered = proplists:get_value(ordered, OwnOpts, false),
+               unordered = proplists:get_value(unordered, OwnOpts, false),
                packet = proplists:get_value(packet, OwnOpts, true),
                send = proplists:get_value(sender, OwnOpts, false)};
 
@@ -813,23 +813,25 @@ recv(#transport{rotate = B} = S)
 recv(#transport{rotate = 0,
                 streams = {_,OS},
                 socket = Sock,
+                assoc_id = Id,
                 unordered = B}
      = S) ->
-    ok = unordered(Sock, OS, B),
+    ok = unordered(Sock, Id, OS, B),
     S#transport{rotate = 1 < OS};
 
 recv(#transport{rotate = N} = S) ->
     S#transport{rotate = N-1}.
 
-%% unordered/3
+%% unordered/4
 
-unordered(Sock, OS, B)
+unordered(Sock, Id, OS, B)
   when B;
        is_integer(B), OS =< B ->
     inet:setopts(Sock, [{sctp_default_send_param,
-                         #sctp_sndrcvinfo{flags = [unordered]}}]);
+                         #sctp_sndrcvinfo{flags = [unordered],
+                                          assoc_id = Id}}]);
 
-unordered(_, OS, B)
+unordered(_, _, OS, B)
   when not B;
        is_integer(B), B < OS ->
     ok.

lib/diameter/src/transport/diameter_tcp.erl

@@ -20,6 +20,8 @@
 
 -module(diameter_tcp).
 
+-dialyzer(no_improper_lists).
+
 -behaviour(gen_server).
 
 %% interface

lib/diameter/test/diameter_traffic_SUITE.erl

@@ -1,7 +1,7 @@
 %%
 %% %CopyrightBegin%
 %%
-%% Copyright Ericsson AB 2010-2020. All Rights Reserved.
+%% Copyright Ericsson AB 2010-2021. 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.
@@ -279,19 +279,19 @@ all() ->
 
 %% Redefine this to run one or more groups for debugging purposes.
 -define(GROUPS, []).
-%-define(GROUPS, [[tcp,rfc6733,record,map,false,false,false,false]]).
+%-define(GROUPS, [[sctp,rfc6733,record,map,false,false,true,false]]).
 
 %% Issues with gen_sctp sporadically cause huge numbers of failed
 %% testcases when running testcases in parallel.
 groups() ->
-    Names = names(),
+    Names = names([] == ?GROUPS orelse ?GROUPS),
     [{P, [P], Ts} || Ts <- [tc()], P <- [shuffle, parallel]]
         ++
         [{?util:name(N), [], [{group, if T == sctp; S -> shuffle;
                                          true         -> parallel end}]}
          || [T,_,_,_,S|_] = N <- Names]
         ++
-        [{T, [], [{group, ?util:name(N)} || N <- names(Names, ?GROUPS),
+        [{T, [], [{group, ?util:name(N)} || N <- Names,
                                             T == hd(N)]}
          || T <- ?TRANSPORTS]
         ++
@@ -308,13 +308,13 @@ names() ->
                              CS <- ?SENDERS,
                              ?SKIP =< rand:uniform()].
 
-names(Names, []) ->
+names(true) ->
+    names(names());
+
+names(Names) ->
     [N || N <- Names,
           [CS,SS|_] <- [lists:reverse(N)],
-          SS orelse CS];  %% avoid deadlock
-
-names(_, Names) ->
-    Names.
+          SS orelse CS].  %% avoid deadlock
 
 %% --------------------