diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2017-03-01 19:31:26 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2017-03-01 19:31:26 +0300 |
| commit | c40f527f4a73e17e2cb2563515845737dbca21b5 (patch) | |
| tree | 801049bb9f38a175d82c1d8bb624f9e6a212f3b0 | |
| parent | e88fac2aebcb9f3eb55f5b23439d4dd69c09c7a4 (diff) | |
| parent | 831300674837068af16f4e28e93108256b8fbe53 (diff) | |
| download | rabbitmq-server-git-c40f527f4a73e17e2cb2563515845737dbca21b5.tar.gz | |
Merge branch 'stable'
| -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 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}). |
