diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-10-26 16:05:17 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-10-26 16:05:17 +0000 |
| commit | a2191649b05773c76661ffe41a7d85e4e1c9b4e3 (patch) | |
| tree | 7ad36ae5134c0c10486b76a5f25a9d0206e1e97c /src | |
| parent | 896dee8c4acffe20e2e3c4dda3358678ca02e5ac (diff) | |
| download | rabbitmq-server-git-a2191649b05773c76661ffe41a7d85e4e1c9b4e3.tar.gz | |
correction of ordering of exports, specs and functions. And correction of specs. All just for qi though
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 39116b0dd2..dd62a7ed8f 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -32,9 +32,10 @@ -module(rabbit_queue_index). -export([init/1, terminate/1, terminate_and_erase/1, write_published/4, - write_delivered/2, write_acks/2, can_flush_journal/1, flush_journal/1, sync_seq_ids/3, - read_segment_entries/2, next_segment_boundary/1, segment_size/0, - find_lowest_seq_id_seg_and_next_seq_id/1, start_msg_store/1]). + write_delivered/2, write_acks/2, sync_seq_ids/3, can_flush_journal/1, + flush_journal/1, read_segment_entries/2, next_segment_boundary/1, + segment_size/0, find_lowest_seq_id_seg_and_next_seq_id/1, + start_msg_store/1]). %%---------------------------------------------------------------------------- %% The queue disk index @@ -136,11 +137,11 @@ -> qistate()). -spec(write_delivered/2 :: (seq_id(), qistate()) -> qistate()). -spec(write_acks/2 :: ([seq_id()], qistate()) -> qistate()). --spec(flush_journal/1 :: (qistate()) -> qistate()). +-spec(sync_seq_ids/3 :: ([seq_id()], boolean(), qistate()) -> qistate()). -spec(can_flush_journal/1 :: (qistate()) -> boolean()). +-spec(flush_journal/1 :: (qistate()) -> qistate()). -spec(read_segment_entries/2 :: (seq_id(), qistate()) -> - {( [{msg_id(), seq_id(), boolean(), boolean()}] - | 'not_found'), qistate()}). + {[{msg_id(), seq_id(), boolean(), boolean()}], qistate()}). -spec(next_segment_boundary/1 :: (seq_id()) -> seq_id()). -spec(segment_size/0 :: () -> non_neg_integer()). -spec(find_lowest_seq_id_seg_and_next_seq_id/1 :: (qistate()) -> |