diff options
| author | kjnilsson <knilsson@pivotal.io> | 2020-03-31 13:33:23 +0100 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2020-03-31 13:33:23 +0100 |
| commit | 6081958a0f6e589963d2fa7d617f39c1354c9e58 (patch) | |
| tree | 73880005774a44b429bc90a1b5ecd37f3585acbf /src | |
| parent | 3da9ace1c8599d2bd4aacebcee757aa787ebf716 (diff) | |
| download | rabbitmq-server-git-6081958a0f6e589963d2fa7d617f39c1354c9e58.tar.gz | |
Move rabbit_channel config value to config record
writer_gc_threshold is a static value and shoudl be in the static config
record not in the main channel record that should only hold mutable data
fields.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 5aa39c9792..bc32359769 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -122,7 +122,9 @@ %% Message content size limit max_message_size, consumer_timeout, - authz_context + authz_context, + %% defines how ofter gc will be executed + writer_gc_threshold }). -record(ch, {cfg :: #conf{}, @@ -169,9 +171,7 @@ delivery_flow, interceptor_state, queue_states, - tick_timer, - %% defines how ofter gc will be executed - writer_gc_threshold + tick_timer }). -define(QUEUE, lqueue). @@ -527,7 +527,8 @@ init([Channel, ReaderPid, WriterPid, ConnPid, ConnName, Protocol, User, VHost, consumer_prefetch = Prefetch, max_message_size = MaxMessageSize, consumer_timeout = ConsumerTimeout, - authz_context = OptionalVariables + authz_context = OptionalVariables, + writer_gc_threshold = GCThreshold }, limiter = Limiter, tx = none, @@ -546,8 +547,7 @@ init([Channel, ReaderPid, WriterPid, ConnPid, ConnName, Protocol, User, VHost, reply_consumer = none, delivery_flow = Flow, interceptor_state = undefined, - queue_states = #{}, - writer_gc_threshold = GCThreshold + queue_states = #{} }, State1 = State#ch{ interceptor_state = rabbit_channel_interceptor:init(State)}, @@ -1309,12 +1309,12 @@ handle_method(#'basic.publish'{exchange = ExchangeNameBin, user = #user{username = Username} = User, trace_state = TraceState, max_message_size = MaxMessageSize, - authz_context = AuthzContext + authz_context = AuthzContext, + writer_gc_threshold = GCThreshold }, tx = Tx, confirm_enabled = ConfirmEnabled, - delivery_flow = Flow, - writer_gc_threshold = GCThreshold + delivery_flow = Flow }) -> check_msg_size(Content, MaxMessageSize, GCThreshold), ExchangeName = rabbit_misc:r(VHostPath, exchange, ExchangeNameBin), @@ -2693,9 +2693,9 @@ handle_deliver(ConsumerTag, AckRequired, #basic_message{exchange_name = ExchangeName, routing_keys = [RoutingKey | _CcRoutes], content = Content}}, - State = #ch{cfg = #conf{writer_pid = WriterPid}, - next_tag = DeliveryTag, - writer_gc_threshold = GCThreshold}) -> + State = #ch{cfg = #conf{writer_pid = WriterPid, + writer_gc_threshold = GCThreshold}, + next_tag = DeliveryTag}) -> Deliver = #'basic.deliver'{consumer_tag = ConsumerTag, delivery_tag = DeliveryTag, redelivered = Redelivered, |