summaryrefslogtreecommitdiff
path: root/src/rabbit_queue_index.erl
diff options
context:
space:
mode:
authorRob Harrop <rharrop@vmware.com>2010-09-21 14:29:15 +0100
committerRob Harrop <rharrop@vmware.com>2010-09-21 14:29:15 +0100
commit7794fbfccc040408c522aa8123fe8b587556c733 (patch)
tree177360fdee6c3b7c2e03e3d1423889cf7b5ca17a /src/rabbit_queue_index.erl
parent0fd2b6857de945734d86312bbef0ed9a9af7f3db (diff)
downloadrabbitmq-server-7794fbfccc040408c522aa8123fe8b587556c733.tar.gz
cosmetic fixes - tabs to spaces
Diffstat (limited to 'src/rabbit_queue_index.erl')
-rw-r--r--src/rabbit_queue_index.erl10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl
index b5e92dca..ed04c1e1 100644
--- a/src/rabbit_queue_index.erl
+++ b/src/rabbit_queue_index.erl
@@ -204,14 +204,14 @@
-spec(terminate/2 :: ([any()], qistate()) -> qistate()).
-spec(delete_and_terminate/1 :: (qistate()) -> qistate()).
-spec(publish/5 :: (rabbit_guid:guid(), seq_id(), msg_properties(),
- boolean(), qistate()) -> qistate()).
+ boolean(), qistate()) -> qistate()).
-spec(deliver/2 :: ([seq_id()], qistate()) -> qistate()).
-spec(ack/2 :: ([seq_id()], qistate()) -> qistate()).
-spec(sync/2 :: ([seq_id()], qistate()) -> qistate()).
-spec(flush/1 :: (qistate()) -> qistate()).
-spec(read/3 :: (seq_id(), seq_id(), qistate()) ->
{[{rabbit_guid:guid(), seq_id(), msg_properties(),
- boolean(), boolean()}], qistate()}).
+ boolean(), boolean()}], qistate()}).
-spec(next_segment_boundary/1 :: (seq_id()) -> seq_id()).
-spec(bounds/1 :: (qistate()) ->
{non_neg_integer(), non_neg_integer(), qistate()}).
@@ -259,8 +259,8 @@ publish(Guid, SeqId, MsgProperties, IsPersistent, State)
true -> ?PUB_PERSIST_JPREFIX;
false -> ?PUB_TRANS_JPREFIX
end):?JPREFIX_BITS,
- SeqId:?SEQ_BITS>>,
- create_pub_record_body(Guid, MsgProperties)]),
+ SeqId:?SEQ_BITS>>,
+ create_pub_record_body(Guid, MsgProperties)]),
maybe_flush_journal(add_to_journal(SeqId, {Guid, MsgProperties, IsPersistent}, State1)).
deliver(SeqIds, State) ->
@@ -540,7 +540,7 @@ read_pub_record_body(Hdl) ->
X -> X
end,
{Guid, #msg_properties{expiry = Exp}}.
-
+
%%----------------------------------------------------------------------------
%% journal manipulation
%%----------------------------------------------------------------------------