From 549a82df3ae250b7c5598a9451b7b9802073d6f9 Mon Sep 17 00:00:00 2001
From: Anders Svensson <anders@erlang.org>
Date: Tue, 29 Aug 2017 09:08:38 +0200
Subject: Exercise unordered delivery in traffic suite

By randomly setting the number of outbound streams on associations.
---
 lib/diameter/test/diameter_traffic_SUITE.erl | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

(limited to 'lib/diameter/test/diameter_traffic_SUITE.erl')

diff --git a/lib/diameter/test/diameter_traffic_SUITE.erl b/lib/diameter/test/diameter_traffic_SUITE.erl
index 1760d7c5dc..f058ed65b8 100644
--- a/lib/diameter/test/diameter_traffic_SUITE.erl
+++ b/lib/diameter/test/diameter_traffic_SUITE.erl
@@ -112,6 +112,8 @@
 %% diameter_{tcp,sctp} callbacks
 -export([message/3]).
 
+-include_lib("kernel/include/inet_sctp.hrl").
+
 -include("diameter.hrl").
 -include("diameter_gen_base_rfc3588.hrl").
 -include("diameter_gen_base_accounting.hrl").
@@ -486,7 +488,7 @@ add_transports(Config) ->
                          | server_apps()]
                         ++ [{spawn_opt, {erlang, spawn, []}} || CS]),
     Cs = [?util:connect(CN,
-                        [T, {sender, CS}],
+                        [T, {sender, CS} | client_opts(T)],
                         LRef,
                         [{id, Id}
                          | client_apps(R, [{'Origin-State-Id', origin(Id)}])])
@@ -496,6 +498,14 @@ add_transports(Config) ->
              Id <- [{D,E}]],
     ?util:write_priv(Config, "transport", [LRef | Cs]).
 
+client_opts(tcp) ->
+    [];
+client_opts(sctp) ->
+    [{sctp_initmsg, #sctp_initmsg{num_ostreams = N,
+                                  max_instreams = 5}}
+     || N <- [rand:uniform(8)],
+        N =< 6].
+
 server_apps() ->
     B = have_nas(),
     [{applications, [diameter_gen_base_rfc3588,
-- 
cgit v1.2.3