diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2017-03-01 19:30:38 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2017-03-01 19:30:52 +0300 |
| commit | 831300674837068af16f4e28e93108256b8fbe53 (patch) | |
| tree | 284eae6d0a3400b672ca51d53fcb8904bed10936 | |
| parent | 682a13633dcc155f7e807e5985b01e56c527f7f9 (diff) | |
| download | rabbitmq-server-git-831300674837068af16f4e28e93108256b8fbe53.tar.gz | |
Doco
| -rw-r--r-- | src/rabbit_queue_index.erl | 26 |
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}). |
