diff options
| author | Matthew Sackman <matthew@lshift.net> | 2010-01-08 16:58:54 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2010-01-08 16:58:54 +0000 |
| commit | 003bcc5a106b5de17318c8a475ce0c9837b8923e (patch) | |
| tree | 4b756ce9ab8bee750d7bcef8db0daa3d3a9830f6 /include | |
| parent | 3274299179812bfc5be48886ecee4d29d02d22c4 (diff) | |
| download | rabbitmq-server-git-003bcc5a106b5de17318c8a475ce0c9837b8923e.tar.gz | |
Msg_store now supports concurrent reads when it is safe, directly from the queue. This means that even if the msg_store process is flooded with writes or acks, it won't (necessarily) block queues. This is extremely useful and has substantial benefit when memory has been exhausted and the queue is operating off γ only (effectively, no message content held in ram).
Diffstat (limited to 'include')
| -rw-r--r-- | include/rabbit_msg_store.hrl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/include/rabbit_msg_store.hrl b/include/rabbit_msg_store.hrl index 0e9a0408cb..a094454a78 100644 --- a/include/rabbit_msg_store.hrl +++ b/include/rabbit_msg_store.hrl @@ -34,7 +34,7 @@ -record(file_summary, {file, valid_total_size, contiguous_top, left, right, file_size, - locked}). + locked, readers}). -define(BINARY_MODE, [raw, binary]). -define(READ_MODE, [read]). @@ -52,3 +52,4 @@ -define(FILE_SUMMARY_ETS_NAME, rabbit_msg_store_file_summary). -define(CACHE_ETS_NAME, rabbit_msg_store_cache). +-define(FILE_HANDLES_ETS_NAME, rabbit_msg_store_file_handles). |