summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* cosmetic: more sensible ordering of state componentsMatthias Radestock2010-06-141-33/+39
| | | | essential vars first, followed by derived vars and counters/rates/etc
* minor refactorMatthias Radestock2010-06-131-11/+8
|
* refactor: extract accumulation of SeqIds and Guids from acksMatthias Radestock2010-06-121-34/+25
|
* refactor: simplify 'fetch'Matthias Radestock2010-06-121-34/+17
|
* refactor: extract conditional calls to qi:deliverMatthias Radestock2010-06-121-23/+19
|
* refactor: extract #msg_status initialisationMatthias Radestock2010-06-121-15/+13
|
* refactor: simplify publish_deliveredMatthias Radestock2010-06-121-25/+17
| | | | | - extract recoding of pending acks - use maybe_write_to_disk
* refactor: extract similarities between ack and requeueMatthias Radestock2010-06-121-76/+48
|
* refactor: make 'ack' and 'requeue' look very similar indeedMatthias Radestock2010-06-121-37/+37
| | | | ...prior to combining them
* fix small persistent_count counting bugMatthias Radestock2010-06-121-3/+3
| | | | | | ...which doesn't actually matter since it would only result in the persistent_count of transient queues being wrong, which get nuked on startup anyway (the only place that makes use of the persistent_count).
* cosmeticMatthias Radestock2010-06-031-174/+212
|
* cosmeticMatthias Radestock2010-06-031-10/+11
|
* cosmeticMatthias Radestock2010-06-031-2/+2
|
* refactor: introduce helper funMatthias Radestock2010-06-031-49/+38
|
* cosmeticMatthias Radestock2010-06-031-74/+63
|
* refactor: simplify code with some helper funsMatthias Radestock2010-06-031-24/+15
|
* drop segment num from fun call in segment_{fold,map}Matthias Radestock2010-06-021-13/+10
| | | | | | | to abstract away from the dict-ness of the segment store. The segment number isn't actually needed in most cases and can be easily extracted from the #segment.
* refactor: rename segment_fetch_keys to segments_numsMatthias Radestock2010-06-021-3/+3
| | | | to abstract away from the dict-ness of the segment store
* refactor: remove superfluous clauseMatthias Radestock2010-06-021-2/+0
| | | | | ...which was an optimisation too far, particular since a similar clause is not present in the related functions
* tweak: more LRU-like cache behaviourMatthias Radestock2010-06-021-1/+1
|
* remove erroneous commentMatthias Radestock2010-06-021-3/+1
|
* cosmeticMatthias Radestock2010-05-281-1/+1
|
* inliningMatthias Radestock2010-05-281-6/+4
|
* merge default into bug21673Matthias Radestock2010-05-2811-281/+415
|\
| * remove misleading commentsMatthias Radestock2010-05-281-5/+0
| |
| * cosmeticMatthias Radestock2010-05-271-4/+4
| |
| * some minor refactoringMatthias Radestock2010-05-272-82/+65
| |
| * Merge bug22596 into defaultEmile Joubert2010-05-271-1/+1
| |\
| | * clusternode is a listMatthew Sackman2010-04-081-1/+1
| | |
| * | Merging bug 21824 onto defaultMatthew Sackman2010-05-275-22/+159
| |\ \
| | * | Cosmetics and formattingMatthew Sackman2010-05-274-19/+19
| | | |
| | * | Merging default into bug 21824Matthew Sackman2010-05-2710-129/+147
| | |\ \
| | * | | No reason for this to be a dict of lists.Simon MacMullen2010-05-201-2/+2
| | | | |
| | * | | Forgot to add this.Simon MacMullen2010-05-201-0/+110
| | | | |
| | * | | Move the former bug21824 into a new branch that comes off bug21915 (and thus ↵Simon MacMullen2010-05-204-20/+47
| | | | | | | | | | | | | | | | | | | | default) rather than amqp_0_9_1.
| * | | | Merging bug 22812 into defaultMatthew Sackman2010-05-272-26/+36
| |\ \ \ \ | | |_|/ / | |/| | |
| | * | | Minor refactorMatthew Sackman2010-05-271-3/+4
| | | | |
| | * | | We were only applying the local shortcut in the case when we were *only*Simon MacMullen2010-05-271-20/+24
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | talking to a local node. This is wrong because: 1) We could then happen to pick a local delegate and a remote delegate that were the same process, and deadlock. 2) There's still a possibility of messages overtaking if sometimes they go via delegates locally and sometimes not. So fix that to always avoid the delegates when communicating locally, even if we're communicating remotely at the same time.
| | * | | Make error messages in the logs a bit clearer.Simon MacMullen2010-05-261-6/+11
| | | | |
| * | | | Merging bug21915 onto default. Note that this has some semantic changes ↵Matthew Sackman2010-05-275-193/+184
| |\ \ \ \ | | | | | | | | | | | | | | | | | | which are 'safe' for 0-8 and more in line with 0-9-1. This is: an exclusive queue can only be redeclared in the same connection as created the queue and the redeclaration must also specify exclusivity.
| | * | | | CosmeticsMatthew Sackman2010-05-272-33/+25
| | | | | |
| | * | | | Don't eat errors that could be returned by F.Simon MacMullen2010-05-261-5/+5
| | | | | |
| | * | | | Clean up a bit.Simon MacMullen2010-05-262-9/+3
| | | | | |
| | * | | | Move F into with_or_die.Simon MacMullen2010-05-261-8/+15
| | | | | |
| | * | | | Correct specs.Simon MacMullen2010-05-261-2/+1
| | | | | |
| | * | | | Merge default into 21915.Simon MacMullen2010-05-265-44/+69
| | |\ \ \ \ | | | |/ / /
| | * | | | Move our protocol_error outside the with_or_die to stop it being eaten.Simon MacMullen2010-05-261-15/+12
| | | | | |
| | * | | | Reinstate check_configure_permitted in queue.declare passive when queue ↵Simon MacMullen2010-05-261-2/+3
| | | | | | | | | | | | | | | | | | | | | | | | already exists.
| | * | | | Revert bug introduced in "cosmetics" commit 41b7270f9546.Simon MacMullen2010-05-261-1/+1
| | | | | |
| | * | | | 80 col fix.Simon MacMullen2010-05-261-1/+2
| | | | | |