summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMichael Klishin <michael@clojurewerkz.org>2017-03-01 19:30:38 +0300
committerMichael Klishin <michael@clojurewerkz.org>2017-03-01 19:30:52 +0300
commit831300674837068af16f4e28e93108256b8fbe53 (patch)
tree284eae6d0a3400b672ca51d53fcb8904bed10936 /src
parent682a13633dcc155f7e807e5985b01e56c527f7f9 (diff)
downloadrabbitmq-server-git-831300674837068af16f4e28e93108256b8fbe53.tar.gz
Doco
Diffstat (limited to 'src')
-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 6560d61625..bf9dcbebbe 100644
--- a/src/rabbit_queue_index.erl
+++ b/src/rabbit_queue_index.erl
@@ -176,10 +176,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}).