summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Set is the defaultBen Hood2008-10-131-1/+0
|
* Changed index from ordered_set to set for durable routesBen Hood2008-10-131-1/+1
|
* maybe_auto_delete should always return okMatthias Radestock2008-10-121-1/+2
|
* cosmeticMatthias Radestock2008-10-121-6/+3
|
* some minor formatting fixesMatthias Radestock2008-10-121-4/+4
|
* refactoring: never construct reverse routes/bindings directlyMatthias Radestock2008-10-121-6/+7
|
* fix indentation and commentsMatthias Radestock2008-10-121-68/+57
|
* inline delete_bindings/1Matthias Radestock2008-10-121-30/+22
| | | | | and also refactor indexed_delete to use a list comprehension instead of lists:foreach and return 'ok'.
* rejig call_with_exchangeMatthias Radestock2008-10-121-15/+14
| | | | | | | | | | We don't really need two flavours of call_with_exchange. In delete_bindings/1 we can assume the exchange exists - this code is called as part of queue deletion and we don't care about exchanges that have gone missing. Also, it is sufficient to use an ordinary read rather than wread.
* Removed superfluous commentBen Hood2008-10-111-3/+0
|
* Don't hassle the HOFBen Hood2008-10-111-10/+8
|
* Reinstated list_exchange_bindings/1Ben Hood2008-10-101-2/+21
|
* Changed select for has_bindings into a continuationBen Hood2008-10-101-3/+8
|
* Refactored all of the exchange delete functionsBen Hood2008-10-101-69/+57
|
* Default binding should be restored in exchange moduleBen Hood2008-10-101-7/+3
|
* Simplified has_bindings because it only needs to do simple select and countBen Hood2008-10-081-16/+10
|
* Brought forwards delete function into loop to avoid delete_object wildcard ↵Ben Hood2008-10-071-6/+6
| | | | issue when it is fixed in OTP
* Fixes for dialyzerBen Hood2008-10-062-5/+5
|
* Merged default into 18776Ben Hood2008-10-067-75/+97
|\
| * merge bug19485 into defaultHubert Plociniczak2008-10-051-19/+18
| |\
| | * propagate channel/connection errors when in closing stateMatthias Radestock2008-10-031-19/+18
| | |
| * | Merged bug19219 into defaultBen Hood2008-10-042-50/+63
| |\ \ | | |/ | |/|
| | * cosmetic refactoringMatthias Radestock2008-10-011-7/+7
| | |
| | * oopsMatthias Radestock2008-09-301-1/+1
| | |
| | * modulate gen_server:call timeout when doing work in parallelMatthias Radestock2008-09-302-50/+63
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | When we fire off lots of gen_server:calls in parallel, we may create enough work for the VM to cause the calls to time out - since the amount of work that can actually be done in parallel is finite. The fix is to adjust the timeout based on the total workload. Alternatively we could not have any timeout at all, but that is bad Erlang style since a small error somewhere could result in stuck processes. I moved the parallelisation - and hence timeout modulation - from the channel into the amqqueue module, changing the API in the process - commit, rollback and notify_down now all operate on lists of QPids (and I've renamed the functions to make that clear). The alternative would have been to add Timeout params to these three functions, but I reckon the API is cleaner this way, particularly considering that rollback doesn't actually do a call - it does a cast and hence doesn't require a timeout - so in the alternative API we'd either have to expose that fact indirectly by not having a Timeout param, or have a bogus Timeout param, neither of which is particularly appealing. I considered making the functions take sets instead of lists, since that's what the channel code produces, plus sets have a more efficient length operation. However, API-wise I reckon lists are nicer, plus it means I can give a more precise type to dialyzer - sets would be opaque and non-polymorphic.
| * | merge bug18784Matthias Radestock2008-10-012-3/+11
| |\ \ | | |/ | |/|
| | * Migrate branch bug18784Tony Garnock-Jones2008-07-032-3/+11
| | |
| * | Merged 19455 into defaultBen Hood2008-09-282-2/+6
| |\ \
| | * | disable NagleMatthias Radestock2008-09-282-2/+6
| |/ /
* | | Lock demotionBen Hood2008-10-061-5/+7
| | |
* | | Further refactoringsBen Hood2008-10-061-17/+10
| | |
* | | Refactored call_with_exchangeBen Hood2008-10-061-15/+9
| | |
* | | Factored out route deletion with reverse lookupBen Hood2008-10-061-19/+25
| | |
* | | Factored out re-entry conditionBen Hood2008-10-061-8/+7
| | |
* | | Fixed full table scan when deleting forwards routesBen Hood2008-10-061-11/+12
| | |
* | | Refactored deleting forwards bindingsBen Hood2008-10-051-6/+8
| | |
* | | Makes better use out of the reverse routes when deletingBen Hood2008-10-051-17/+40
| | |
* | | Minor refactoring of the continuationBen Hood2008-10-051-12/+6
| | |
* | | Fixes for auto-delete exchangesBen Hood2008-10-051-27/+67
| | |
* | | Fix for not cleaning up durable auto_delete exchanges properlyBen Hood2008-09-301-1/+5
| | |
* | | SimplicationsBen Hood2008-09-301-9/+7
| | |
* | | Made better use of pattern matching in mnesia:delete_object/1Ben Hood2008-09-301-20/+15
| | |
* | | Fix for auto_delete exchangesBen Hood2008-09-301-0/+15
| | |
* | | Reverse routes and durable routes now get deletedBen Hood2008-09-291-2/+12
| | |
* | | cosmetic changes and some minor refactoringMatthias Radestock2008-09-284-111/+87
| | |
* | | Binned resource() typeBen Hood2008-09-272-5/+1
| | |
* | | Removed e_m_t/2Ben Hood2008-09-273-10/+6
| | |
* | | rabbit_exchange:{add,delete}_binding/1 should not be exportedBen Hood2008-09-271-1/+0
| | |
* | | Truncated lines in this patch to 78Ben Hood2008-09-273-16/+28
| | |
* | | Swapped position of exchange and queue in binding APIsBen Hood2008-09-273-6/+6
| | |
View Lorry Controller Status