diff options
| author | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2016-07-06 13:44:00 +0200 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2016-07-06 13:50:56 +0200 |
| commit | c72013ec63479cf643806e6af9dbae7237e841ef (patch) | |
| tree | ec3b3707c72949972073b5de1ae05f9e8246d1a5 | |
| parent | 02807ba720feb3482966c312f5dddf0c14ba1599 (diff) | |
| download | rabbitmq-server-git-c72013ec63479cf643806e6af9dbae7237e841ef.tar.gz | |
Only use new non-builtin types in master
We only support Erlang 18.3+. Therefore we can revert what was done in
b6a3aa477156036c129d04a82c90ad916bc3865e.
[#118562897]
| -rw-r--r-- | src/lqueue.erl | 4 | ||||
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_binding.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 6 | ||||
| -rw-r--r-- | src/rabbit_msg_store.erl | 4 | ||||
| -rw-r--r-- | src/rabbit_queue_index.erl | 12 | ||||
| -rw-r--r-- | src/rabbit_variable_queue.erl | 8 | ||||
| -rw-r--r-- | test/channel_operation_timeout_test_queue.erl | 8 |
8 files changed, 22 insertions, 24 deletions
diff --git a/src/lqueue.erl b/src/lqueue.erl index fc7157dff1..0652061075 100644 --- a/src/lqueue.erl +++ b/src/lqueue.erl @@ -27,9 +27,7 @@ -export_type([?MODULE/0]). --include_lib("rabbit_common/include/old_builtin_types.hrl"). - --opaque ?MODULE() :: {non_neg_integer(), ?QUEUE_TYPE()}. +-opaque ?MODULE() :: {non_neg_integer(), queue:queue()}. -type value() :: any(). -type result() :: 'empty' | {'value', value()}. diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 533b23f9ed..10fcfe7493 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -99,7 +99,7 @@ -spec info_keys() -> rabbit_types:info_keys(). -spec init_with_backing_queue_state (rabbit_types:amqqueue(), atom(), tuple(), any(), - [rabbit_types:delivery()], pmon:pmon(), ?DICT_TYPE()) -> + [rabbit_types:delivery()], pmon:pmon(), dict:dict()) -> #q{}. %%---------------------------------------------------------------------------- diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl index 51bc883976..7cebd194a6 100644 --- a/src/rabbit_binding.erl +++ b/src/rabbit_binding.erl @@ -52,7 +52,7 @@ %% TODO this should really be opaque but that seems to confuse 17.1's %% dialyzer into objecting to everything that uses it. --type deletions() :: ?DICT_TYPE(). +-type deletions() :: dict:dict(). -spec recover([rabbit_exchange:name()], [rabbit_amqqueue:name()]) -> 'ok'. diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index 8c1040f876..78d7341584 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -57,13 +57,13 @@ coordinator :: pid(), backing_queue :: atom(), backing_queue_state :: any(), - seen_status :: ?DICT_TYPE(), + seen_status :: dict:dict(), confirmed :: [rabbit_guid:guid()], - known_senders :: ?SET_TYPE() + known_senders :: sets:set() }. -spec promote_backing_queue_state (rabbit_amqqueue:name(), pid(), atom(), any(), pid(), [any()], - ?DICT_TYPE(), [pid()]) -> + dict:dict(), [pid()]) -> master_state(). -spec sender_death_fun() -> death_fun(). diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 22af95ced1..2a6e2cd103 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -149,7 +149,7 @@ -type client_msstate() :: #client_msstate { server :: server(), client_ref :: client_ref(), - file_handle_cache :: ?DICT_TYPE(), + file_handle_cache :: dict:dict(), index_state :: any(), index_module :: atom(), dir :: file:filename(), @@ -163,7 +163,7 @@ fun ((A) -> 'finished' | {rabbit_types:msg_id(), non_neg_integer(), A}). -type maybe_msg_id_fun() :: - 'undefined' | fun ((?GB_SET_TYPE(), 'written' | 'ignored') -> any()). + 'undefined' | fun ((gb_sets:set(), 'written' | 'ignored') -> any()). -type maybe_close_fds_fun() :: 'undefined' | fun (() -> 'ok'). -type deletion_thunk() :: fun (() -> boolean()). diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 6a14854882..8b96bbffbd 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -197,13 +197,13 @@ -type segment() :: ('undefined' | #segment { num :: non_neg_integer(), path :: file:filename(), - journal_entries :: ?ARRAY_TYPE(), - entries_to_segment :: ?ARRAY_TYPE(), + journal_entries :: array:array(), + entries_to_segment :: array:array(), unacked :: non_neg_integer() }). -type seq_id() :: integer(). --type seg_dict() :: {?DICT_TYPE(), [segment()]}. --type on_sync_fun() :: fun ((?GB_SET_TYPE()) -> ok). +-type seg_dict() :: {dict:dict(), [segment()]}. +-type on_sync_fun() :: fun ((gb_sets:set()) -> ok). -type qistate() :: #qistate { dir :: file:filename(), segments :: 'undefined' | seg_dict(), journal_handle :: hdl(), @@ -211,8 +211,8 @@ max_journal_entries :: non_neg_integer(), on_sync :: on_sync_fun(), on_sync_msg :: on_sync_fun(), - unconfirmed :: ?GB_SET_TYPE(), - unconfirmed_msg :: ?GB_SET_TYPE(), + unconfirmed :: gb_sets:set(), + unconfirmed_msg :: gb_sets:set(), pre_publish_cache :: list(), delivered_cache :: list() }. diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index b0010e6723..943e3019b3 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -392,10 +392,10 @@ out_counter :: non_neg_integer(), in_counter :: non_neg_integer(), rates :: rates(), - msgs_on_disk :: ?GB_SET_TYPE(), - msg_indices_on_disk :: ?GB_SET_TYPE(), - unconfirmed :: ?GB_SET_TYPE(), - confirmed :: ?GB_SET_TYPE(), + msgs_on_disk :: gb_sets:set(), + msg_indices_on_disk :: gb_sets:set(), + unconfirmed :: gb_sets:set(), + confirmed :: gb_sets:set(), ack_out_counter :: non_neg_integer(), ack_in_counter :: non_neg_integer(), disk_read_count :: non_neg_integer(), diff --git a/test/channel_operation_timeout_test_queue.erl b/test/channel_operation_timeout_test_queue.erl index 75c050d681..4407a24e7f 100644 --- a/test/channel_operation_timeout_test_queue.erl +++ b/test/channel_operation_timeout_test_queue.erl @@ -174,10 +174,10 @@ out_counter :: non_neg_integer(), in_counter :: non_neg_integer(), rates :: rates(), - msgs_on_disk :: ?GB_SET_TYPE(), - msg_indices_on_disk :: ?GB_SET_TYPE(), - unconfirmed :: ?GB_SET_TYPE(), - confirmed :: ?GB_SET_TYPE(), + msgs_on_disk :: gb_sets:set(), + msg_indices_on_disk :: gb_sets:set(), + unconfirmed :: gb_sets:set(), + confirmed :: gb_sets:set(), ack_out_counter :: non_neg_integer(), ack_in_counter :: non_neg_integer(), disk_read_count :: non_neg_integer(), |
