diff options
| author | Michael Klishin <michael@novemberain.com> | 2017-06-18 12:01:12 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-06-18 12:01:12 +0300 |
| commit | 1c8798a9fb841ec67bbfecee2703d40db65e93cd (patch) | |
| tree | f40f485b9ecc6cd2b2529584a5c892c524aee4bc /src | |
| parent | 2c6edde9bfa44f55d1bda038b854194c9b552364 (diff) | |
| parent | 0e148dac5956c7123546da7aca460693aea2c30b (diff) | |
| download | rabbitmq-server-git-1c8798a9fb841ec67bbfecee2703d40db65e93cd.tar.gz | |
Merge pull request #1268 from rabbitmq/rabbitmq-server-1243
Make term_to_binary_compat generate binaries using minor_version 1.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 2 | ||||
| -rw-r--r-- | src/term_to_binary_compat.erl | 13 |
2 files changed, 4 insertions, 11 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 5d7ced615c..5a0f76a544 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -653,7 +653,7 @@ recover_message(false, _, no_del, RelSeq, {Segment, DirtyCount}) -> DirtyCount + 2}. queue_name_to_dir_name(Name = #resource { kind = queue }) -> - <<Num:128>> = erlang:md5(term_to_binary_compat:queue_name_to_binary(Name)), + <<Num:128>> = erlang:md5(term_to_binary_compat:term_to_binary_1(Name)), rabbit_misc:format("~.36B", [Num]). queues_dir() -> diff --git a/src/term_to_binary_compat.erl b/src/term_to_binary_compat.erl index a3e1045623..13396ddacb 100644 --- a/src/term_to_binary_compat.erl +++ b/src/term_to_binary_compat.erl @@ -18,15 +18,8 @@ -include("rabbit.hrl"). --export([queue_name_to_binary/1]). +-export([term_to_binary_1/1]). -queue_name_to_binary(#resource{kind = queue} = {resource, VHost, queue, Name}) -> - VHostBSize = byte_size(VHost), - NameBSize = byte_size(Name), - <<131, %% Binary format "version" - 104, 4, %% 4-element tuple - 100, 0, 8, "resource", %% `resource` atom - 109, VHostBSize:32, VHost/binary, %% Vhost binary - 100, 0, 5, "queue", %% `queue` atom - 109, NameBSize:32, Name/binary>>. %% Name binary +term_to_binary_1(Term) -> + term_to_binary(Term, [{minor_version, 1}]). |