summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <michael@clojurewerkz.org>2017-03-01 19:31:26 +0300
committerMichael Klishin <michael@clojurewerkz.org>2017-03-01 19:31:26 +0300
commitc40f527f4a73e17e2cb2563515845737dbca21b5 (patch)
tree801049bb9f38a175d82c1d8bb624f9e6a212f3b0
parente88fac2aebcb9f3eb55f5b23439d4dd69c09c7a4 (diff)
parent831300674837068af16f4e28e93108256b8fbe53 (diff)
downloadrabbitmq-server-git-c40f527f4a73e17e2cb2563515845737dbca21b5.tar.gz
Merge branch 'stable'
-rw-r--r--src/rabbit_queue_index.erl26
1 files changed, 22 insertions, 4 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl
index 793eb3e514..e101e4aef4 100644
--- a/src/rabbit_queue_index.erl
+++ b/src/rabbit_queue_index.erl
@@ -180,10 +180,28 @@
%%----------------------------------------------------------------------------
--record(qistate, {dir, segments, journal_handle, dirty_count,
- max_journal_entries, on_sync, on_sync_msg,
- unconfirmed, unconfirmed_msg,
- pre_publish_cache, delivered_cache}).
+-record(qistate, {
+ %% queue directory where segment and journal files are stored
+ dir,
+ %% map of #segment records
+ segments,
+ %% journal file handle obtained from/used by file_handle_cache
+ journal_handle,
+ %% how many not yet flushed entries are there
+ dirty_count,
+ %% this many not yet flushed journal entries will force a flush
+ max_journal_entries,
+ %% callback function invoked when a message is "handled"
+ %% by the index and potentially can be confirmed to the publisher
+ on_sync,
+ on_sync_msg,
+ %% set of IDs of unconfirmed [to publishers] messages
+ unconfirmed,
+ unconfirmed_msg,
+ %% optimisation
+ pre_publish_cache,
+ %% optimisation
+ delivered_cache}).
-record(segment, {num, path, journal_entries,
entries_to_segment, unacked}).