summaryrefslogtreecommitdiff
path: root/src/rabbit_msg_store.erl
Commit message (Collapse)AuthorAgeFilesLines
* Update copyright 2012bug24606Emile Joubert2012-02-021-1/+1
|
* More credit for the queue -> msg_store case.Simon MacMullen2012-01-191-2/+2
|
* two flavours of 'write'Matthias Radestock2012-01-171-11/+19
| | | | | | | Just like in the other applications of credit_flow:send/ack, we need two flavours of the surrounding API function, i.e. 'write' and 'write_flow' in this case. That way existing call sites, such as in rabbit_test can remain undisturbed.
* more sensible arg orderMatthias Radestock2012-01-171-13/+13
| | | | and consistent var naming
* Don't pass the client pid in for write.Simon MacMullen2012-01-171-3/+5
|
* Flow control: vq -> msg_store.Simon MacMullen2012-01-171-17/+26
|
* more accurate description of flying_ets tablebug24308Matthias Radestock2011-10-171-1/+1
|
* explain why client_update_flying phase 3 will always succeedMatthias Radestock2011-10-171-0/+3
|
* refactor: revert change to var nameMatthias Radestock2011-10-171-2/+2
|
* refactor: rename update_flying/3 to client_update_flying/3Matthias Radestock2011-10-171-4/+4
|
* fix bugMatthias Radestock2011-10-171-1/+1
|
* Give up on attempting to improve clarity.Simon MacMullen2011-10-171-6/+6
|
* Rephrase to make Matthias happier...Simon MacMullen2011-10-171-7/+7
|
* I find this clearerSimon MacMullen2011-10-171-6/+6
|
* rename 'removed' confirmation event name to 'ignored'Matthias Radestock2011-10-151-3/+3
| | | | since that reflects its meaning better
* merge default into bug24308Matthias Radestock2011-10-151-13/+8
|\
| * a spot of inliningMatthias Radestock2011-10-151-14/+7
| |
| * only confirm messages on 'remove' that are pending confirmationMatthias Radestock2011-10-111-2/+3
| |
* | documentationMatthias Radestock2011-10-141-0/+39
| |
* | issue confirms when needed (and only then)Matthias Radestock2011-10-111-22/+33
| | | | | | | | | | | | This also fixes a bug that is present on 'default', namely that we used to always issue a confirm on 'remove' regardless of whether there was preceding 'write'.
* | refactoring: extract core of 'write' handlerMatthias Radestock2011-10-101-66/+62
| | | | | | | | | | | | similar to what we already did for 'remove' Also, don't add the 'dying client' marker message to the pending confirms. While that does no harm, it is clearly not right.
* | cosmeticMatthias Radestock2011-10-101-2/+2
| |
* | there's more than one call site for remove_message...Matthias Radestock2011-10-101-41/+41
| | | | | | | | ...and only one of them must pay attention to flying_ets
* | be more careful about deleting cur_file_cache_ets entriesMatthias Radestock2011-10-101-6/+17
| |
* | I'm pretty sure this is correctMatthias Radestock2011-10-091-31/+47
| |
* | slightly more obvious flying_writes accountingMatthias Radestock2011-10-061-14/+11
| | | | | | | | | | and move the cache cleanup from 'remove' to 'write', which is a more obvious place. Improve docs on that too.
* | merge default into bug24308Matthias Radestock2011-10-061-73/+116
|\ \ | |/ |/|
| * Whoops, forgot that bit.Matthew Sackman2011-08-191-0/+4
| |
| * Fixed again.Matthew Sackman2011-08-191-73/+112
| |
* | move file functions from misc to rabbit_fileAlexandru Scvortov2011-09-211-4/+4
| |
* | merge default into bug 23056bug23056Alexandru Scvortov2011-08-251-0/+2
|\ \ | |/ |/|
| * even more specsAlexandru Scvortov2011-08-051-0/+2
| | | | | | | | | | | | Specs in heartbeat, limiter, log, memory_monitor, vm_memory_monitor, mirror_queue_coordinator, mirror_queue_master, mirror_queue_misc, mirror_queue_slave, mnesia, msg_file, msg_store are up to date.
* | Merging default to bug24340Matthew Sackman2011-08-161-1/+2
|\ \
| * | Correct specMatthew Sackman2011-08-161-1/+2
| | |
* | | Merging default to bug24340Matthew Sackman2011-08-161-1/+1
|\ \ \ | |/ /
| * | Reforce msg_store sync interval to 25ms, which was the goal of bug 23765, ↵Matthew Sackman2011-08-161-1/+1
| |/ | | | | | | but was accidentally undone in changeset 8fd9704bd1dc.
* | Correct capture of msg-on-disk in tests as sync replacement; rip out ↵Matthew Sackman2011-08-161-48/+14
| | | | | | | | explicit synchronous msg_store:sync and other unneeded logic
* | If the client is dying, turn the sync into a noopMatthew Sackman2011-08-121-8/+16
|/
* just ignore the result to erlang:cancel_timerAlexandru Scvortov2011-08-021-1/+1
|
* some more refactoringAlexandru Scvortov2011-08-021-1/+1
|
* merge default into bug23504Alexandru Scvortov2011-08-021-315/+300
|\
| * employ more sophisticated message queue formattingMatthias Radestock2011-07-281-1/+4
| | | | | | | | ...in the channel, queue and msg_store
| * It is not an error if the file does not existMatthew Sackman2011-04-061-1/+4
| |
| * Slimmer gatherer terminationEmile Joubert2011-03-311-1/+1
| |
| * Merging bug24008 to defaultMatthew Sackman2011-03-311-110/+29
| |\
| | * Merge default into bug23968bug23968Matthew Sackman2011-03-281-22/+25
| | |\
| | * | Rip out dedup cacheMatthew Sackman2011-03-181-101/+28
| | | |
| | * | Rip out msg_store:releaseMatthew Sackman2011-03-181-10/+1
| | | |
| * | | Don't transform markers when upgrading messagesbug24008Emile Joubert2011-03-311-1/+4
| | |/ | |/|
| * | Enforce a bunch of returnsMatthew Sackman2011-03-221-22/+24
| |/