diff options
Diffstat (limited to 'src/rabbit_queue_index.erl')
| -rw-r--r-- | src/rabbit_queue_index.erl | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 65118c1a..70121154 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -305,6 +305,7 @@ publish(MsgOrId, SeqId, MsgProps, IsPersistent, State#qistate{unconfirmed_msg = UCM1}; {false, _} -> State end), + file_handle_cache_stats:update(queue_index_journal_write), ok = file_handle_cache:append( JournalHdl, [<<(case IsPersistent of true -> ?PUB_PERSIST_JPREFIX; @@ -795,6 +796,7 @@ deliver_or_ack(_Kind, [], State) -> deliver_or_ack(Kind, SeqIds, State) -> JPrefix = case Kind of ack -> ?ACK_JPREFIX; del -> ?DEL_JPREFIX end, {JournalHdl, State1} = get_journal_handle(State), + file_handle_cache_stats:update(queue_index_journal_write), ok = file_handle_cache:append( JournalHdl, [<<JPrefix:?JPREFIX_BITS, SeqId:?SEQ_BITS>> || SeqId <- SeqIds]), @@ -894,6 +896,7 @@ write_entry_to_segment(RelSeq, {Pub, Del, Ack}, Hdl) -> no_pub -> ok; {MsgOrId, MsgProps, IsPersistent} -> + file_handle_cache_stats:update(queue_index_write), file_handle_cache:append( Hdl, [<<?PUB_PREFIX:?PUB_PREFIX_BITS, (bool_to_int(IsPersistent)):1, @@ -906,6 +909,7 @@ write_entry_to_segment(RelSeq, {Pub, Del, Ack}, Hdl) -> _ -> Binary = <<?REL_SEQ_ONLY_PREFIX:?REL_SEQ_ONLY_PREFIX_BITS, RelSeq:?REL_SEQ_BITS>>, + file_handle_cache_stats:update(queue_index_write), file_handle_cache:append( Hdl, case {Del, Ack} of {del, ack} -> [Binary, Binary]; @@ -952,6 +956,7 @@ load_segment(KeepAcked, #segment { path = Path }) -> end. load_segment_entries(Hdl, KeepAcked, Acc) -> + file_handle_cache_stats:update(queue_index_read), case file_handle_cache:read(Hdl, ?PUB_RECORD_PREFIX_BYTES) of {ok, <<?PUB_PREFIX:?PUB_PREFIX_BITS, IsPersistNum:1, RelSeq:?REL_SEQ_BITS>>} -> |