diff options
| author | kjnilsson <knilsson@pivotal.io> | 2020-07-23 11:08:01 +0100 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2020-09-07 09:42:11 +0100 |
| commit | 46da15c35f485a4cf5298e7089211d173aaf1851 (patch) | |
| tree | b3cf23b3a354a5f2b03b441e9e7203a457b7ecca | |
| parent | 727a86ce6f94a27f1bd4d128a5512a90fc071a4c (diff) | |
| download | rabbitmq-server-git-46da15c35f485a4cf5298e7089211d173aaf1851.tar.gz | |
Add some unused fields to rabbit_fifo records
To allow for future extensions without necessitating a machine version
upgrade
| -rw-r--r-- | src/rabbit_fifo.hrl | 17 |
1 files changed, 11 insertions, 6 deletions
diff --git a/src/rabbit_fifo.hrl b/src/rabbit_fifo.hrl index dc01b6ec1c..f9b0d5e1c3 100644 --- a/src/rabbit_fifo.hrl +++ b/src/rabbit_fifo.hrl @@ -110,7 +110,9 @@ %% it is useful to have a record of when this was blocked %% so that we can retry sending the block effect if %% the publisher did not receive the initial one - blocked :: undefined | ra:index() + blocked :: undefined | ra:index(), + unused_1, + unused_2 }). -record(cfg, @@ -127,7 +129,9 @@ %% the maximum number of unsuccessful delivery attempts permitted delivery_limit :: option(non_neg_integer()), max_in_memory_length :: option(non_neg_integer()), - max_in_memory_bytes :: option(non_neg_integer()) + max_in_memory_bytes :: option(non_neg_integer()), + unused_1, + unused_2 }). -type prefix_msgs() :: {list(), list()} | @@ -138,10 +142,9 @@ {cfg :: #cfg{}, % unassigned messages messages = lqueue:new() :: lqueue:queue(), - % defines the next message in id to be added to the messages map + % defines the next message id next_msg_num = 1 :: msg_in_id(), - % list of returned msg_in_ids - when checking out it picks from - % this list first before taking low_msg_num + % queue of returned msg_in_ids - when checking out it picks from returns = lqueue:new() :: lqueue:lqueue(prefix_msg() | {msg_in_id(), indexed_msg()}), % a counter of enqueues - used to trigger shadow copy points @@ -180,7 +183,9 @@ %% used only when single active consumer is on waiting_consumers = [] :: [{consumer_id(), consumer()}], msg_bytes_in_memory = 0 :: non_neg_integer(), - msgs_ready_in_memory = 0 :: non_neg_integer() + msgs_ready_in_memory = 0 :: non_neg_integer(), + unused_1, + unused_2 }). -type config() :: #{name := atom(), |