summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Merge bug24182 into defaultSteve Powell2012-02-232-1/+41
|\
| * Move the mode thing into the server too.Simon MacMullen2012-02-202-6/+9
| |
| * Move code from rabbitmq-auth-mechanism-ssl onto the brokerSimon MacMullen2012-02-201-1/+38
| |
* | Merge bug24482Simon MacMullen2012-02-23139-1282/+1931
|\ \
| * \ Merge bug24739Simon MacMullen2012-02-220-0/+0
| |\ \
| | * \ Merge bug24706 (again).Simon MacMullen2012-02-220-0/+0
| | |\ \
| * | \ \ Merge bug24706 in (a dependency).Steve Powell2012-02-221-0/+3
| |\ \ \ \ | | |/ / / | |/| | |
| | * | | Take default owner/group for confdirSteve Powell2012-02-221-1/+1
| | | | |
| | * | | Merge in defaultSteve Powell2012-02-228-44/+63
| | |\ \ \ | | | |/ /
| | * | | It's not just for enabled pluginsSimon MacMullen2012-02-141-3/+3
| | | | |
| | * | | Ah… the number of indirections there are here… :-(Steve Powell2012-02-101-0/+1
| | | | |
| | * | | Get macports installation to create enabled_plugins_file directory if it ↵Steve Powell2012-02-101-0/+2
| | | | | | | | | | | | | | | | | | | | doesn't exist.
| * | | | 'nother oopsSteve Powell2012-02-221-1/+1
| | | | |
| * | | | Oops, typoSteve Powell2012-02-221-1/+1
| | | | |
| * | | | Merge default inSteve Powell2012-02-22134-868/+1316
| |\ \ \ \ | | | |/ / | | |/| |
| | * | | Resurrect default without bug24494, for real this time.Simon MacMullen2012-02-211-1/+1
| | | | |
| | * | | Merged bug24365 into defaultEmile Joubert2012-02-202-4/+21
| | |\ \ \ | | | |_|/ | | |/| |
| | | * | How do I hate thee, coverage? Let me count the ways.Simon MacMullen2012-02-171-0/+7
| | | | | | | | | | | | | | | | | | | | Now that ctl reset disconnects us from the distributed system, it breaks coverage each time we do it. Fix all that up again.
| | | * | Merge in defaultSimon MacMullen2012-02-152-4/+14
| | | |\ \
| | | | * | Fix tests, at the cost of a leetle tiny bit of ugliness.Simon MacMullen2011-08-221-1/+7
| | | | | |
| | | | * | Leave the Erlang distributed system when resetting.Simon MacMullen2011-08-221-3/+7
| | | | | |
| | * | | | merge bug24381 into default (Windows INSTALL file is not readable using notepad)Alexandru Scvortov2012-02-171-0/+3
| | |\ \ \ \ | | | |/ / / | | |/| | |
| | | * | | Use DOS/Windows linebreaksEmile Joubert2012-02-161-0/+3
| | |/ / /
| | * | | Merge bug24086Simon MacMullen2012-02-156-36/+55
| | |\ \ \
| | | * | | refactor: less strange variable scopingMatthias Radestock2012-02-141-7/+8
| | | | | |
| | | * | | Remerge bug24714Emile Joubert2012-02-152-13/+8
| | | |\ \ \
| | | | * | | Unmerge bug20337Emile Joubert2012-02-151-1/+1
| | | | | | |
| | | | * | | simplifying refactorMatthias Radestock2012-02-131-12/+7
| | | | | |/ | | | | |/|
| | | * | | monitor nodes just onceMatthias Radestock2012-02-091-9/+12
| | | |/ /
| | | * | remove cruftMatthias Radestock2012-02-091-1/+1
| | | | |
| | | * | Merge bug24668 (make consumer flow control more like credit_flow; improve ↵Simon MacMullen2012-02-093-6/+26
| | | |\ \ | | | | | | | | | | | | | | | | | | performance along the way)
| | | | * | CosmeticSimon MacMullen2012-02-091-1/+1
| | | | | |
| | | | * | credit_flow-like throttling of queue->writer message flowMatthias Radestock2012-02-073-6/+26
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Previously we effectively had a credit_spec of {100,1}, i.e. the queue would send up to 100 messages to a consumer channel/writer, and the writer would 'ack' them individually. That is horrendeously inefficient: - when draining a queue, after the queue had sent 100 messages it would block the consumer, unblock when the notify_sent 'ack' came in, send another message to the channel/queue, block again. So a vast amount of work per message - in a cluster, the notify_sent 'acks' effectively doubled the cross-cluster traffic We now use a scheme much like credit_flow. Except we cannot *actually* use credit_flow because - rather than wanting to know whether a sender is lacking credit for *any* receiver, as indicated by credit_flow:blocked(), we need to know *which* receiver we are lacking credit for. - (lack of) credit from receiver should *not* propagate to senders, i.e. sender and receiver credits are completely decoupled. Instead the queue should, er, queue messages when receivers cannot keep up. While we could modify credit_flow to accomodate the above, the changes would be quite unpleasant and not actually reduce the amount of code vs implementing a more specialised scheme. The downside is that the contract for using rabbit_amqqueue:notify_sent becomes somewhat mysterious. In particular it sets up a monitor for queues in the caller, and expects the caller to invoke rabbit_amqqueue:notify_sent_queue_down when a 'DOWN' message is received.
| | * | | | handle framing errors promptlyMatthias Radestock2012-02-091-10/+10
| | |/ / /
| | * | | refactor channel frame handlingMatthias Radestock2012-02-091-24/+21
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | ...so there is just one process_channel_frame call site. Also, ensure control_throttle isn't called twice, which would happen when processing a 'channel.close_ok' frame. No harm in it, really, but unnecessary.
| | * | | Merged bug24505 into defaultEmile Joubert2012-02-083-103/+117
| | |\ \ \
| | | * \ \ Merge bug24234Simon MacMullen2012-02-081-11/+32
| | | |\ \ \
| | | | * | | Committed some changes by mistake...Francesco Mazzoli2012-02-013-32/+13
| | | | | | |
| | | | * | | Cosmetic, restored reject/4 arguments to the previous order.Francesco Mazzoli2012-02-014-20/+40
| | | | | | |
| | | | * | | Merge default.Francesco Mazzoli2012-02-011-12/+32
| | | | |\ \ \
| | | | | * \ \ Merge default.Francesco Mazzoli2012-01-3118-257/+445
| | | | | |\ \ \
| | | | | * | | | Renamede reject_tx/4 to reject/4.Francesco Mazzoli2012-01-311-4/+4
| | | | | | | | |
| | | | | * | | | Delete extra whitespace.Francesco Mazzoli2012-01-251-2/+0
| | | | | | | | |
| | | | | * | | | Cons instead of append, reject does not change the channel state.Francesco Mazzoli2012-01-251-6/+5
| | | | | | | | |
| | | | | * | | | 'case' statement styleFrancesco Mazzoli2012-01-251-2/+3
| | | | | | | | |
| | | | | * | | | reject doesn't need to know about the channel state.Francesco Mazzoli2012-01-251-5/+6
| | | | | | | | |
| | | | | * | | | Fix to reject_tx, list comprehension instead of map.Francesco Mazzoli2012-01-251-2/+3
| | | | | | | | |
| | | | | * | | | Flatten the list of lists.Francesco Mazzoli2012-01-251-1/+1
| | | | | | | | |
| | | | | * | | | Executing basick.{nack,reject} transactionally.Francesco Mazzoli2012-01-241-15/+36
| | | | | | | | |
| | | * | | | | | Merge bug24730Simon MacMullen2012-02-082-83/+67
| | | |\ \ \ \ \ \
View Lorry Controller Status