| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | keep track of uncommitted acks in a list instead of a queue | Matthias Radestock | 2011-10-01 | 1 | -17/+15 |
| | | | | | This is simpler. | ||||
| * | collect acks in lists rather than queues | Matthias Radestock | 2011-10-01 | 1 | -20/+26 |
| | | | | | | ...which is slightly simpler and more efficient. This also allows us to optimise for the common case in fold_per_queue. | ||||
| * | speed up acks a bit | Matthias Radestock | 2011-10-01 | 1 | -10/+5 |
| | | | | | | gb_trees are generally faster than dicts. Worth 1-2% in "MCM" when running with two Erlang schedulers. | ||||
| * | refactor: extract gb_trees_fold/3 and gb_trees_foreach/2 | Matthias Radestock | 2011-10-01 | 3 | -11/+17 |
| | | |||||
| * | refactor: eliminate gratuitous differences in 'confirm' code | Matthias Radestock | 2011-10-01 | 2 | -17/+17 |
| | | |||||
| * | refactor: one gb_trees_cons is quite enough | Matthias Radestock | 2011-10-01 | 3 | -15/+11 |
| | | |||||
| * | a few minor tweaks, essentially cosmetic | Matthias Radestock | 2011-09-30 | 1 | -7/+7 |
| | | |||||
| * | avoid creation of intermediate binaries by using io_lists | Matthias Radestock | 2011-09-30 | 1 | -3/+2 |
| | | | | | This is worth 1-2% with "MCM -a" and two Erlang schedulers | ||||
| * | performance improving short cut | Matthias Radestock | 2011-09-30 | 1 | -0/+2 |
| | | | | | This gains 1-2% when running "MCM -a" with two Erlang schedulers | ||||
| * | cosmetic | Matthias Radestock | 2011-09-30 | 1 | -2/+1 |
| | | |||||
| * | merge bug23764 into default | Matthias Radestock | 2011-09-30 | 4 | -175/+340 |
| |\ | |||||
| | * | correct formatting | Matthias Radestock | 2011-09-30 | 1 | -13/+14 |
| | | | |||||
| | * | merge default into bug23764 | Matthias Radestock | 2011-09-30 | 3 | -69/+60 |
| | |\ | |/ |/| | |||||
| * | | reformatting | Matthias Radestock | 2011-09-30 | 1 | -57/+46 |
| | | | |||||
| * | | merge bug24298 into default | Matthias Radestock | 2011-09-29 | 65 | -963/+1450 |
| |\ \ | |||||
| | * | | Further oops, we now depend on everything being built before running ↵ | Simon MacMullen | 2011-09-28 | 1 | -1/+1 |
| | | | | | | | | | | | | | run-background-node, otherwise we have two make processes tryi9ng to compile at the same time and they tread on each other. | ||||
| | * | | Ooops | Simon MacMullen | 2011-09-28 | 1 | -1/+1 |
| | | | | |||||
| | * | | Merge bug24371 | Simon MacMullen | 2011-09-28 | 25 | -483/+631 |
| | |\ \ | |||||
| | * \ \ | merge default into bug24371 | Alexandru Scvortov | 2011-09-21 | 1 | -4/+11 |
| | |\ \ \ | |||||
| | | * | | | Ensure dir exists | Matthew Sackman | 2011-09-06 | 1 | -0/+1 |
| | | | | | | |||||
| | | * | | | Use ctl wait in makefile; use setsid and backgrounding borrowed from init | Matthew Sackman | 2011-08-22 | 2 | -5/+11 |
| | | | | | | |||||
| * | | | | | Minor refactor | Matthew Sackman | 2011-08-22 | 1 | -3/+3 |
| | | | | | | |||||
| * | | | | | More efficient use of harddiscs | Matthew Sackman | 2011-08-22 | 1 | -2/+1 |
| | | | | | | |||||
| * | | | | | Always call client_delete_and_terminate for the transient queue. We then ↵ | Matthew Sackman | 2011-08-22 | 1 | -10/+6 |
| | | | | | | | | | | | | | | | | | | | | | don't need to store the TRef and we should certainly never re-present it. | ||||
| | | | | * | Add brief note about requeue to VQ docs | Emile Joubert | 2011-09-30 | 1 | -0/+5 |
| | | | | | | |||||
| | | | | * | always record pending acks in #msg_status form | Matthias Radestock | 2011-09-30 | 1 | -53/+34 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | #msg_status { msg = undefined } replaces the previous 4-tuple. This simplifies the API and gets rid of the obscure, ad-hoc 4-tuple. | ||||
| | | | | * | cosmetic | Matthias Radestock | 2011-09-30 | 1 | -8/+8 |
| | | | | | | |||||
| | | | | * | refactor: extract removal from pending_ack | Matthias Radestock | 2011-09-29 | 1 | -29/+29 |
| | | | | | | | | | | | | | | | | | | | | | and in the process renamed remove_pending_ack to purge_pending_ack. | ||||
| | | | | * | inline ack/4 | Matthias Radestock | 2011-09-29 | 1 | -32/+25 |
| | | | | | | | | | | | | | | | | | | | | | since there is now just one call site left | ||||
| | | | | * | refactor: pull call to msg_from_pending_ack into queue_merge | Matthias Radestock | 2011-09-29 | 1 | -36/+32 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | thus avoiding duplication, making the alpha/beta fun tables non-parametric, and containing knowledge of seq ids in queue_merge. | ||||
| | | | | * | inlining and reshuffling | Matthias Radestock | 2011-09-29 | 1 | -50/+45 |
| | | | | | | |||||
| | | | | * | further abstraction of queue/bpqueue distinction | Matthias Radestock | 2011-09-29 | 1 | -5/+9 |
| | | | | | | |||||
| | | | | * | a whole bunch of refactoring and cosmetic changes | Matthias Radestock | 2011-09-29 | 1 | -101/+105 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - more sensible order of args to queue_merge and delta_merge: 1) things that get consumed, 2) things that get added to, 3) constants, 4) State - more sensible order of results of queue_merge and delta_merge: 1) things left over from (1) above, 2) things produced, 4) State - better var names - correct indentation - stick to <80 columns - some inlining | ||||
| | | | | * | Refactor, rename, comment | Emile Joubert | 2011-09-29 | 1 | -31/+21 |
| | | | | | | |||||
| | | | | * | Concession to Qpid tests is now redundant | Emile Joubert | 2011-09-29 | 1 | -5/+1 |
| | | | | | | |||||
| | | | | * | Speed up requeue test | Emile Joubert | 2011-09-29 | 1 | -22/+24 |
| | | | | | | |||||
| | | | | * | Move #msg_status{} back to rabbit_variable_queue | Emile Joubert | 2011-09-29 | 2 | -28/+11 |
| | | | | | | |||||
| | | | | * | Only ack messages when necessary | Emile Joubert | 2011-09-29 | 1 | -10/+11 |
| | | | | | | |||||
| | | | | * | lshift | Emile Joubert | 2011-09-28 | 1 | -5/+5 |
| | | | | | | |||||
| | | | | * | Better test coverage | Emile Joubert | 2011-09-28 | 1 | -4/+6 |
| | | | | | | |||||
| | | | | * | Refactor | Emile Joubert | 2011-09-27 | 2 | -79/+84 |
| | | | | | | | | | | | | | | | | | | | | | Making use of the symmetry between q3 and q4 | ||||
| | | | | * | Requeue faster | Emile Joubert | 2011-09-27 | 2 | -103/+143 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | by not adding messages one at a time Modify test to requeue multiple messages | ||||
| | | | | * | Merged default into bug23764 | Emile Joubert | 2011-09-26 | 82 | -1684/+3986 |
| | | | | |\ | | | | |/ | | | |/| | |||||
| | | | * | | Merge bug 24315 | Simon MacMullen | 2011-09-23 | 8 | -18/+34 |
| | | | |\ \ | |||||
| | | | | * | | extend comment | Alexandru Scvortov | 2011-09-23 | 1 | -0/+2 |
| | | | | | | | |||||
| | | | | * | | merge default into bug24315 | Alexandru Scvortov | 2011-09-23 | 8 | -18/+32 |
| | | | | |\ \ | | | |/ / / | |||||
| | | | | * | | refactor | Alexandru Scvortov | 2011-09-06 | 3 | -29/+17 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Two with_local_ios in rabbit_mnesia were unneeded. Huh. We only need to use with_local_io/1 when we use error_logger; the most common case is error_logger:info_msg/2, so we now have a helper function. | ||||
| | | | | * | | fix tests | Alexandru Scvortov | 2011-09-06 | 1 | -2/+2 |
| | | | | | | | |||||
| | | | | * | | log various ctl actions | Alexandru Scvortov | 2011-09-06 | 6 | -7/+33 |
| | | | | | | | |||||
| | | | * | | | merge bug24332 into default | Matthias Radestock | 2011-09-23 | 3 | -130/+111 |
| | | | |\ \ \ | |||||
