summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* changed usage of #message_properties{} to ?BASE_MESSAGE_PROPERTIESRob Harrop2010-10-061-2/+2
|
* Merging default into bug 23111Matthew Sackman2010-10-063-79/+103
|\
| * merge bug23133 into defaultMatthias Radestock2010-10-064-27/+29
| |\
| * | refactor file summary updating in write/removeMatthias Radestock2010-10-061-32/+20
| | | | | | | | | | | | | | | This change makes it more obvious what is going on and also nicely aligns the structure of the 'write' handler and remove_message/2.
| * | cosmeticMatthias Radestock2010-10-051-11/+10
| | |
| * | cosmeticMatthias Radestock2010-10-051-6/+5
| | |
| * | Use delete_object, not match_deleteMatthew Sackman2010-10-041-1/+1
| | |
| * | Introduce delete_object and use it to solve raceMatthew Sackman2010-10-043-19/+23
| | |
| * | Merging default into bug 23133Matthew Sackman2010-10-0219-130/+401
| |\ \
| * \ \ Merging default into bug23133Matthew Sackman2010-09-2435-709/+962
| |\ \ \
| * | | | when a message is written the ref_count is always 1Matthias Radestock2010-09-091-4/+4
| | | | |
| * | | | adjust function name for consistencyMatthias Radestock2010-09-091-5/+5
| | | | |
| * | | | oopsMatthias Radestock2010-09-091-1/+1
| | | | |
| * | | | minor refactorMatthias Radestock2010-09-091-9/+7
| | | | |
| * | | | tweakMatthias Radestock2010-09-091-25/+24
| | | | |
| * | | | cosmetic tweaks and minor simplificationsMatthias Radestock2010-09-091-36/+31
| | | | |
| * | | | Merging bug 23233 into bug 23133Matthew Sackman2010-09-081-63/+50
| |\ \ \ \
| * | | | | Scan the file and remove from the index as necessary on file delete rather ↵Matthew Sackman2010-09-081-1/+4
| | | | | | | | | | | | | | | | | | | | | | | | than index_delete_by_file
| * | | | | Merging default into bug 23133Matthew Sackman2010-09-0841-1391/+1696
| |\ \ \ \ \
| * | | | | | Fixed the bug. The problem was that I was not removing msgs from the index ↵Matthew Sackman2010-09-081-43/+27
| | | | | | | | | | | | | | | | | | | | | | | | | | | | for the dest in a gc if they had a refcount of 0. Thus they could later be reincremented. I was also thoughtlessly doing an index_delete_by_file on the src post gc, which should be unnecessary - 0 refcounts are now removed as they're discovered, and non-zero will be updated to be in the dest. This leaves only 1 worrying use of index_delete_by_file which is now in delete_file_if_empty. Here, scanning and deleting as we find msgs will be constant time and simple. Note this also features a very rough hacking out of the use of contiguous top in GC which turns out to be essential for this bug. However the real fix for that will be in bug 23233 which will block this bug.
| * | | | | | Merging default into bug 23133Matthew Sackman2010-08-1911-130/+161
| |\ \ \ \ \ \
| * | | | | | | Abstract refcount == 0 to imply not_found for appropriate call sitesMatthew Sackman2010-08-181-9/+13
| | | | | | | |
| * | | | | | | By this stage of the client-read, we know a GC can't start and can't be in ↵Matthew Sackman2010-08-181-2/+1
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | progress. Thus even if the refcount is 0, we're still safe to read it. What's more, this area of code has never made provision for the index_lookup to return a not_found - it will crash if that happens. Thus if the implicit assumption is that the message must exist, then by the same token, we know the refcount will always be > 0
| * | | | | | | Abstraction of the inner write functionMatthew Sackman2010-08-181-28/+26
| | | | | | | |
| * | | | | | | cosmeticMatthew Sackman2010-08-181-9/+8
| | | | | | | |
| * | | | | | | Because we can increment the refcount back above 0, the calculation of the ↵Matthew Sackman2010-08-181-1/+1
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | contiguous top needs to be contiguousTop + totalSize, because the validtotalsize can contain data that's well beyond the old contiguous top
| * | | | | | | Backed out changeset c47670da4830 - I decided the dedup cache shouldn't be ↵Matthew Sackman2010-08-181-5/+7
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | mangled with.
| * | | | | | | treat the dedup cache the same way as the index - permit 0 ref_counts and ↵Matthew Sackman2010-08-171-7/+5
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | prune on file roll
| * | | | | | | Merging default into bug 23133Matthew Sackman2010-08-173-97/+183
| |\ \ \ \ \ \ \
| * | | | | | | | Permit 0 ref counts and don't actually forget about messages until the file ↵Matthew Sackman2010-08-161-40/+78
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | gets removed
* | | | | | | | | cosmeticsMatthew Sackman2010-10-061-7/+4
| | | | | | | | |
* | | | | | | | | Refactoring and cosmeticMatthew Sackman2010-10-061-33/+29
| | | | | | | | |
* | | | | | | | | cosmeticMatthew Sackman2010-10-062-29/+28
| | | | | | | | |
* | | | | | | | | cosmeticMatthew Sackman2010-10-062-5/+4
| | | | | | | | |
* | | | | | | | | cosmeticMatthew Sackman2010-10-061-1/+1
| | | | | | | | |
* | | | | | | | | Overeager M-/... I did run dialyzer but it failed to spot it.Matthew Sackman2010-10-061-4/+3
| | | | | | | | |
* | | | | | | | | Trailing whitespace onlyMatthew Sackman2010-10-062-23/+22
| | | | | | | | |
* | | | | | | | | msg_properties -> message_properties in order to be consistent with message ↵Matthew Sackman2010-10-068-117/+120
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | and basic_message (though within vq, we have plenty of msg_-prefixes so don't bother inside the msg_status record in there). Also, tidied up a lot of trailing whitespace
* | | | | | | | | Merging default into bug23111Matthew Sackman2010-10-0611-263/+588
|\ \ \ \ \ \ \ \ \ | |_|_|_|_|_|_|_|/ |/| | | | | | | |
| * | | | | | | | merge with defaultRob Harrop2010-09-2911-261/+591
| |\ \ \ \ \ \ \ \
| | * | | | | | | | casing change and added ttl to the list of queue items in rabbitmqctlRob Harrop2010-09-291-7/+10
| | | | | | | | | |
| | * | | | | | | | refactoringRob Harrop2010-09-291-3/+5
| | | | | | | | | |
| | * | | | | | | | fixed bug with queue length and collect during runRob Harrop2010-09-292-4/+9
| | | | | | | | | |
| | * | | | | | | | merge with defaultRob Harrop2010-09-2911-258/+578
| | |\ \ \ \ \ \ \ \
| | | * \ \ \ \ \ \ \ merge with defaultRob Harrop2010-09-284-22/+48
| | | |\ \ \ \ \ \ \ \
| | | * | | | | | | | | removed peek, and restructured dropwhile to not load message content from diskRob Harrop2010-09-286-97/+69
| | | | | | | | | | | |
| | | * | | | | | | | | added timer to collect expired messagesRob Harrop2010-09-281-13/+33
| | | | | | | | | | | |
| | | * | | | | | | | | cosmeticRob Harrop2010-09-282-2/+4
| | | | | | | | | | | |
| | | * | | | | | | | | added peek to ivq. some tests for peekRob Harrop2010-09-273-3/+15
| | | | | | | | | | | |
| | | * | | | | | | | | added peek to backing queue, implemented in vqRob Harrop2010-09-274-5/+71
| | | | | | | | | | | |