| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | issue confirms when needed (and only then) | Matthias Radestock | 2011-10-11 | 1 | -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' handler | Matthias Radestock | 2011-10-10 | 1 | -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. | ||||
| * | cosmetic | Matthias Radestock | 2011-10-10 | 1 | -2/+2 |
| | | |||||
| * | there's more than one call site for remove_message... | Matthias Radestock | 2011-10-10 | 1 | -41/+41 |
| | | | | | ...and only one of them must pay attention to flying_ets | ||||
| * | be more careful about deleting cur_file_cache_ets entries | Matthias Radestock | 2011-10-10 | 1 | -6/+17 |
| | | |||||
| * | I'm pretty sure this is correct | Matthias Radestock | 2011-10-09 | 1 | -31/+47 |
| | | |||||
| * | slightly more obvious flying_writes accounting | Matthias Radestock | 2011-10-06 | 1 | -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 bug24308 | Matthias Radestock | 2011-10-06 | 1 | -73/+116 |
| |\ | |||||
| | * | Whoops, forgot that bit. | Matthew Sackman | 2011-08-19 | 1 | -0/+4 |
| | | | |||||
| | * | Fixed again. | Matthew Sackman | 2011-08-19 | 1 | -73/+112 |
| | | | |||||
| * | | Merged bug24459 into default | Emile Joubert | 2011-10-05 | 1 | -30/+34 |
| |\ \ | |||||
| | * \ | merge default into bug24459 | Matthias Radestock | 2011-10-01 | 1 | -30/+34 |
| | |\ \ | |||||
| | | * | | 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. | ||||
| * | | | | Merged bug24462 into default | Emile Joubert | 2011-10-04 | 1 | -1/+1 |
| |\ \ \ \ | |||||
| | * | | | | Don't blow up when nodes policy is used. | Simon MacMullen | 2011-10-03 | 1 | -1/+1 |
| | | | | | | |||||
| * | | | | | merge bug24323 into default | Matthias Radestock | 2011-10-03 | 69 | -1225/+1797 |
| |\ \ \ \ \ | |/ / / / | |||||
| | * | | | | optimise resource lookup | Matthias Radestock | 2011-10-03 | 2 | -8/+10 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This is worth ~2% in "MCM -a" when running with two Erlang schedulers, and drops rabbit_misc:dirty_read/1 from #21 to #49 in the fprof analysis of the publisher channel. | ||||
| | * | | | | improve performance by bypassing mnesia for queue lookup | Matthias Radestock | 2011-10-03 | 1 | -11/+10 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This is worth ~2% on "MCM -a" when running with two Erlang schedulers, and drops rabbit_router:lookup_qpids/1 from #21 to #42 in the fprof analysis of the channel process. | ||||
| | * | | | | optimise interaction of limiter with single queues | Matthias Radestock | 2011-10-01 | 1 | -0/+1 |
| | | | | | | | | | | | | | | | | | | | | | which is a common case | ||||
| | * | | | | switch vq pending_ack from dict to gb_trees | Matthias Radestock | 2011-10-01 | 1 | -14/+13 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The latter are generally more efficient and this gains us 1-2% when running "MCM" with two Erlang schedulers and drops vq:{record,remove}_pending_ack from 25/28th to 32/39th place in the fprof profile of the queue process | ||||
| | * | | | | optimise vq:drain_confirmed for the common case | Matthias Radestock | 2011-10-01 | 1 | -1/+5 |
| | |/ / / | | | | | | | | | | | | | | | | | | | | | | | | | This gets called on the processing of every event/msg by the queue process and making this change improves throughout of "MCM -a" by ~1% when running with two Erlang schedulers and bumps vq:drain_confirmed from #20 to #36 in an fprof profile of the queue process. | ||||
| | * | | | yes, this really does gain ~1% with MCM with two erlang schedulers | Matthias Radestock | 2011-10-01 | 1 | -3/+9 |
| | |/ / | |||||
| | * | | 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 | ||||
