summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Ensure rabbitmq-env.conf file is fixed location, even in Generic-Unix case.Steve Powell2012-02-132-4/+4
|
* Update misleading commentSteve Powell2012-02-131-1/+1
|
* Merge headsSteve Powell2012-02-131-0/+2
|\
| * Add directory for enabled plugins in the standalone generic-unix caseSteve Powell2012-02-131-0/+2
| |
* | Merge headsSteve Powell2012-02-100-0/+0
|\ \
| * \ Merge in defaultSteve Powell2012-02-0913-174/+248
| |\ \
* | \ \ Merge in 24739 (again).Steve Powell2012-02-1011-46/+116
|\ \ \ \
| * \ \ \ Merge in 24739 (I need this fix).Steve Powell2012-02-1011-46/+116
| |\ \ \ \
| | * | | | Comment for future readersSteve Powell2012-02-101-1/+1
| | | |_|/ | | |/| |
| | * | | TypoSteve Powell2012-02-101-2/+2
| | | | |
| | * | | OK Now I see which rabbitmq-sys is really updated in macports :-(Steve Powell2012-02-102-4/+9
| | | | |
| | * | | Another go at reinplace syntaxSteve Powell2012-02-101-1/+1
| | | | |
| | * | | Simplify macports Makefile and delimit MACPORTS_PREFIX in the usual way.Steve Powell2012-02-102-5/+3
| | | | |
| | * | | Escape $ in Portfile reinplace commandSteve Powell2012-02-101-1/+1
| | | | |
| | * | | Merge default inSteve Powell2012-02-1011-43/+110
| | |\ \ \
| | | * | | Refactor generic-unix rabbitmq-sys for easy updatability;Steve Powell2012-02-104-26/+22
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | simplify macports mods to generic-unix package; make rabbitmq-env independent of package installation; adjust rabbitmq-sys in base scripts to allow rabbitmq-env to work everywhere.
| | | * | | Remove dependencies upon sed -i which is not posix-compliantSteve Powell2012-02-094-19/+25
| | | |/ /
| | | * | Merge in defaultSteve Powell2012-02-06129-285/+417
| | | |\ \
| | | * | | Give alternative to 'todos' which (can) work on macosSteve Powell2012-02-061-1/+1
| | | | | |
| | | * | | Merge default in.Steve Powell2012-02-028-25/+103
| | | |\ \ \
| | | | * \ \ Merge default inSteve Powell2012-02-0116-140/+218
| | | | |\ \ \
| | | | * | | | Modify generic-unix packaging step to override rabbitmq-sys defaults.Steve Powell2012-01-304-9/+43
| | | | | | | |
| | | | * | | | Merge default inSteve Powell2012-01-3015-250/+382
| | | | |\ \ \ \
| | | | * | | | | Move defaults to rabbitmq-sysSteve Powell2012-01-302-8/+39
| | | | | | | | |
| | | | * | | | | Change CONFIG_FILE, LOG_BASE, MNESIA_BASE and ENABLED_PLUGINS_FILE defaultsSteve Powell2012-01-261-6/+6
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - CONFIG_FILE to ${RABBIT_HOME}/rabbitmq - LOG_BASE to ${RABBIT_HOME}/log - MNESIA_BASE to ${RABBIT_HOME}/mnesia - ENABLED_PLUGINS_FILE to ${RABBIT_HOME}/enabled_plugins
| | | | * | | | | Merge bug24706 inSteve Powell2012-01-264-24/+37
| | | | |\ \ \ \ \
* | | | | | | | | | 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.
* | | | | | | | 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.
* | | | | | | | 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
| |\ \ \ \ \ \ \ \ \ \ \
| | * | | | | | | | | | | refactor: remove cruftMatthias Radestock2012-02-081-31/+24
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The equivalence proof is left as an exercise to the reader.
| | * | | | | | | | | | | refactor: extract commonality between basic.deliver and basic.getMatthias Radestock2012-02-071-52/+43
| | | |_|_|/ / / / / / / | | |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | ...and move the writer communication as early as possible, which improves latency.
View Lorry Controller Status