diff options
| author | Kyle Snavely <kjsnavely@gmail.com> | 2020-01-07 19:10:14 -0700 |
|---|---|---|
| committer | Adam Kocoloski <kocolosk@apache.org> | 2020-01-07 21:10:14 -0500 |
| commit | 08d6538a27a23d118579b438cc54daf86be3d5b4 (patch) | |
| tree | c350c3a0ade5bca2f5f6862c47e198dded9a078c | |
| parent | dbdf1953e98b662e8d1184d8e6c5758af4f5a7c7 (diff) | |
| download | couchdb-08d6538a27a23d118579b438cc54daf86be3d5b4.tar.gz | |
Make the rexi:stream2 interface unacked message limit configurable (#2360)
Also lower the default stream_limit to 5 based on the results of
performance testing.
Co-authored-by: Adam Kocoloski <kocolosk@apache.org>
Co-authored-by: Kyle Snavely <kjsnavely@gmail.com>
| -rw-r--r-- | rel/overlay/etc/default.ini | 1 | ||||
| -rw-r--r-- | src/rexi/src/rexi.erl | 5 |
2 files changed, 4 insertions, 2 deletions
diff --git a/rel/overlay/etc/default.ini b/rel/overlay/etc/default.ini index f5f057859..669977ee0 100644 --- a/rel/overlay/etc/default.ini +++ b/rel/overlay/etc/default.ini @@ -214,6 +214,7 @@ port = 6984 ; [rexi] ; buffer_count = 2000 ; server_per_node = true +; stream_limit = 5 ; [global_changes] ; max_event_delay = 25 diff --git a/src/rexi/src/rexi.erl b/src/rexi/src/rexi.erl index ead5bee0c..170503b7c 100644 --- a/src/rexi/src/rexi.erl +++ b/src/rexi/src/rexi.erl @@ -211,9 +211,10 @@ stream(Msg, Limit, Timeout) -> exit(timeout) end. -%% @equiv stream2(Msg, 10, 300000) +%% @equiv stream2(Msg, 5, 300000) stream2(Msg) -> - stream2(Msg, 10, 300000). + Limit = config:get_integer("rexi", "stream_limit", 5), + stream2(Msg, Limit). %% @equiv stream2(Msg, Limit, 300000) stream2(Msg, Limit) -> |