Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | correct formattingbug23764 | 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 bug24371bug24371 | 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 refactorbug24298 | 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 commentbug24315 | 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 |
| |\ \ \ \ \ | |||||
| | * \ \ \ \ | merge heads | Alexandru Scvortov | 2011-09-22 | 2 | -120/+106 |
| | |\ \ \ \ \ | |||||
| | | * \ \ \ \ | Merged bug23866 into default | Emile Joubert | 2011-09-22 | 58 | -749/+1134 |
| | | |\ \ \ \ \ | |||||
| | | | * \ \ \ \ | Merging bug24433 to default | Matthew Sackman | 2011-09-22 | 1 | -119/+105 |
| | | | |\ \ \ \ \ | |||||
| | | | | * | | | | | Avoid construction of intermediate queuebug24433 | Matthew Sackman | 2011-09-22 | 1 | -6/+7 |
| | | | | | | | | | | |||||
| | | | | * | | | | | merge default into bug24433 | Matthias Radestock | 2011-09-19 | 1 | -116/+101 |
| | | | | |\ \ \ \ \ | |||||
| | | | | | * | | | | | count queue consumers as required by the spec | Matthias Radestock | 2011-09-19 | 1 | -10/+9 |
| | | | | | | | | | | | |||||
| | | | | | * | | | | | merge default into bug24433 | Matthias Radestock | 2011-09-18 | 1 | -19/+13 |
| | | | | | |\ \ \ \ \ | |||||
| | | | | | * \ \ \ \ \ | merge default into bug24433 | Matthias Radestock | 2011-09-18 | 0 | -0/+0 |
| | | | | | |\ \ \ \ \ \ | |||||
| | | | | | * | | | | | | | improved compiling- and working-ness | Matthias Radestock | 2011-09-18 | 1 | -34/+33 |
| | | | | | | | | | | | | | |||||
| | | | | | * | | | | | | | merge from default | Matthias Radestock | 2011-09-18 | 1 | -48/+47 |
| | | | | | |\ \ \ \ \ \ \ | |||||
| | | | | | * | | | | | | | | work in progress | Matthias Radestock | 2011-09-17 | 1 | -140/+117 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This doesn't even compile; but I want to stash it away so I can cherry pick some of the refactorings and tweaks for 'default'. |