diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2016-01-29 17:15:16 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2016-01-29 17:15:16 +0300 |
| commit | 76b134a746c0a8c9a31810cce9b76202ff269516 (patch) | |
| tree | 57541c73db0e6057ad6950e8fca863732b0ccc4b | |
| parent | 2fa870f863567135e4fc2e4e0ea41837da1964f2 (diff) | |
| parent | 4f7da6bef9f9b273c9749739275b1a12ab3be91c (diff) | |
| download | rabbitmq-server-git-76b134a746c0a8c9a31810cce9b76202ff269516.tar.gz | |
Merge branch 'stable'
| -rw-r--r-- | src/rabbit_channel_sup.erl | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/rabbit_channel_sup.erl b/src/rabbit_channel_sup.erl index 047fce853f..7aa369b6ca 100644 --- a/src/rabbit_channel_sup.erl +++ b/src/rabbit_channel_sup.erl @@ -53,6 +53,8 @@ -endif. +-define(FAIR_WAIT, 70000). + %%---------------------------------------------------------------------------- start_link({tcp, Sock, Channel, FrameMax, ReaderPid, ConnName, Protocol, User, @@ -69,7 +71,7 @@ start_link({tcp, Sock, Channel, FrameMax, ReaderPid, ConnName, Protocol, User, [Channel, ReaderPid, WriterPid, ReaderPid, ConnName, Protocol, User, VHost, Capabilities, Collector, LimiterPid]}, - intrinsic, ?MAX_WAIT, worker, [rabbit_channel]}), + intrinsic, ?FAIR_WAIT, worker, [rabbit_channel]}), {ok, AState} = rabbit_command_assembler:init(Protocol), {ok, SupPid, {ChannelPid, AState}}; start_link({direct, Channel, ClientChannelPid, ConnPid, ConnName, Protocol, @@ -84,7 +86,7 @@ start_link({direct, Channel, ClientChannelPid, ConnPid, ConnName, Protocol, [Channel, ClientChannelPid, ClientChannelPid, ConnPid, ConnName, Protocol, User, VHost, Capabilities, Collector, LimiterPid]}, - intrinsic, ?MAX_WAIT, worker, [rabbit_channel]}), + intrinsic, ?FAIR_WAIT, worker, [rabbit_channel]}), {ok, SupPid, {ChannelPid, none}}. %%---------------------------------------------------------------------------- @@ -95,8 +97,8 @@ init(Type) -> child_specs({tcp, Sock, Channel, FrameMax, ReaderPid, Protocol, Identity}) -> [{writer, {rabbit_writer, start_link, [Sock, Channel, FrameMax, Protocol, ReaderPid, Identity, true]}, - intrinsic, ?MAX_WAIT, worker, [rabbit_writer]} + intrinsic, ?FAIR_WAIT, worker, [rabbit_writer]} | child_specs({direct, Identity})]; child_specs({direct, Identity}) -> [{limiter, {rabbit_limiter, start_link, [Identity]}, - transient, ?MAX_WAIT, worker, [rabbit_limiter]}]. + transient, ?FAIR_WAIT, worker, [rabbit_limiter]}]. |