| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | changed usage of #message_properties{} to ?BASE_MESSAGE_PROPERTIES | Rob Harrop | 2010-10-06 | 1 | -2/+2 |
| | | |||||
| * | Merging default into bug 23111 | Matthew Sackman | 2010-10-06 | 3 | -79/+103 |
| |\ | |||||
| | * | merge bug23133 into default | Matthias Radestock | 2010-10-06 | 4 | -27/+29 |
| | |\ | |||||
| | * | | refactor file summary updating in write/remove | Matthias Radestock | 2010-10-06 | 1 | -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. | ||||
| | * | | cosmetic | Matthias Radestock | 2010-10-05 | 1 | -11/+10 |
| | | | | |||||
| | * | | cosmetic | Matthias Radestock | 2010-10-05 | 1 | -6/+5 |
| | | | | |||||
| | * | | Use delete_object, not match_delete | Matthew Sackman | 2010-10-04 | 1 | -1/+1 |
| | | | | |||||
| | * | | Introduce delete_object and use it to solve race | Matthew Sackman | 2010-10-04 | 3 | -19/+23 |
| | | | | |||||
| | * | | Merging default into bug 23133 | Matthew Sackman | 2010-10-02 | 19 | -130/+401 |
| | |\ \ | |||||
| | * \ \ | Merging default into bug23133 | Matthew Sackman | 2010-09-24 | 35 | -709/+962 |
| | |\ \ \ | |||||
| | * | | | | when a message is written the ref_count is always 1 | Matthias Radestock | 2010-09-09 | 1 | -4/+4 |
| | | | | | | |||||
| | * | | | | adjust function name for consistency | Matthias Radestock | 2010-09-09 | 1 | -5/+5 |
| | | | | | | |||||
| | * | | | | oops | Matthias Radestock | 2010-09-09 | 1 | -1/+1 |
| | | | | | | |||||
| | * | | | | minor refactor | Matthias Radestock | 2010-09-09 | 1 | -9/+7 |
| | | | | | | |||||
| | * | | | | tweak | Matthias Radestock | 2010-09-09 | 1 | -25/+24 |
| | | | | | | |||||
| | * | | | | cosmetic tweaks and minor simplifications | Matthias Radestock | 2010-09-09 | 1 | -36/+31 |
| | | | | | | |||||
| | * | | | | Merging bug 23233 into bug 23133 | Matthew Sackman | 2010-09-08 | 1 | -63/+50 |
| | |\ \ \ \ | |||||
| | * | | | | | Scan the file and remove from the index as necessary on file delete rather ↵ | Matthew Sackman | 2010-09-08 | 1 | -1/+4 |
| | | | | | | | | | | | | | | | | | | | | | | | | | than index_delete_by_file | ||||
| | * | | | | | Merging default into bug 23133 | Matthew Sackman | 2010-09-08 | 41 | -1391/+1696 |
| | |\ \ \ \ \ | |||||
| | * | | | | | | Fixed the bug. The problem was that I was not removing msgs from the index ↵ | Matthew Sackman | 2010-09-08 | 1 | -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 23133 | Matthew Sackman | 2010-08-19 | 11 | -130/+161 |
| | |\ \ \ \ \ \ | |||||
| | * | | | | | | | Abstract refcount == 0 to imply not_found for appropriate call sites | Matthew Sackman | 2010-08-18 | 1 | -9/+13 |
| | | | | | | | | | |||||
| | * | | | | | | | By this stage of the client-read, we know a GC can't start and can't be in ↵ | Matthew Sackman | 2010-08-18 | 1 | -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 function | Matthew Sackman | 2010-08-18 | 1 | -28/+26 |
| | | | | | | | | | |||||
| | * | | | | | | | cosmetic | Matthew Sackman | 2010-08-18 | 1 | -9/+8 |
| | | | | | | | | | |||||
| | * | | | | | | | Because we can increment the refcount back above 0, the calculation of the ↵ | Matthew Sackman | 2010-08-18 | 1 | -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 Sackman | 2010-08-18 | 1 | -5/+7 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | mangled with. | ||||
| | * | | | | | | | treat the dedup cache the same way as the index - permit 0 ref_counts and ↵ | Matthew Sackman | 2010-08-17 | 1 | -7/+5 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | prune on file roll | ||||
| | * | | | | | | | Merging default into bug 23133 | Matthew Sackman | 2010-08-17 | 3 | -97/+183 |
| | |\ \ \ \ \ \ \ | |||||
| | * | | | | | | | | Permit 0 ref counts and don't actually forget about messages until the file ↵ | Matthew Sackman | 2010-08-16 | 1 | -40/+78 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | gets removed | ||||
| * | | | | | | | | | cosmetics | Matthew Sackman | 2010-10-06 | 1 | -7/+4 |
| | | | | | | | | | | |||||
| * | | | | | | | | | Refactoring and cosmetic | Matthew Sackman | 2010-10-06 | 1 | -33/+29 |
| | | | | | | | | | | |||||
| * | | | | | | | | | cosmetic | Matthew Sackman | 2010-10-06 | 2 | -29/+28 |
| | | | | | | | | | | |||||
| * | | | | | | | | | cosmetic | Matthew Sackman | 2010-10-06 | 2 | -5/+4 |
| | | | | | | | | | | |||||
| * | | | | | | | | | cosmetic | Matthew Sackman | 2010-10-06 | 1 | -1/+1 |
| | | | | | | | | | | |||||
| * | | | | | | | | | Overeager M-/... I did run dialyzer but it failed to spot it. | Matthew Sackman | 2010-10-06 | 1 | -4/+3 |
| | | | | | | | | | | |||||
| * | | | | | | | | | Trailing whitespace only | Matthew Sackman | 2010-10-06 | 2 | -23/+22 |
| | | | | | | | | | | |||||
| * | | | | | | | | | msg_properties -> message_properties in order to be consistent with message ↵ | Matthew Sackman | 2010-10-06 | 8 | -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 bug23111 | Matthew Sackman | 2010-10-06 | 11 | -263/+588 |
| |\ \ \ \ \ \ \ \ \ | |_|_|_|_|_|_|_|/ |/| | | | | | | | | |||||
| | * | | | | | | | | merge with default | Rob Harrop | 2010-09-29 | 11 | -261/+591 |
| | |\ \ \ \ \ \ \ \ | |||||
| | | * | | | | | | | | casing change and added ttl to the list of queue items in rabbitmqctl | Rob Harrop | 2010-09-29 | 1 | -7/+10 |
| | | | | | | | | | | | |||||
| | | * | | | | | | | | refactoring | Rob Harrop | 2010-09-29 | 1 | -3/+5 |
| | | | | | | | | | | | |||||
| | | * | | | | | | | | fixed bug with queue length and collect during run | Rob Harrop | 2010-09-29 | 2 | -4/+9 |
| | | | | | | | | | | | |||||
| | | * | | | | | | | | merge with default | Rob Harrop | 2010-09-29 | 11 | -258/+578 |
| | | |\ \ \ \ \ \ \ \ | |||||
| | | | * \ \ \ \ \ \ \ | merge with default | Rob Harrop | 2010-09-28 | 4 | -22/+48 |
| | | | |\ \ \ \ \ \ \ \ | |||||
| | | | * | | | | | | | | | removed peek, and restructured dropwhile to not load message content from disk | Rob Harrop | 2010-09-28 | 6 | -97/+69 |
| | | | | | | | | | | | | | |||||
| | | | * | | | | | | | | | added timer to collect expired messages | Rob Harrop | 2010-09-28 | 1 | -13/+33 |
| | | | | | | | | | | | | | |||||
| | | | * | | | | | | | | | cosmetic | Rob Harrop | 2010-09-28 | 2 | -2/+4 |
| | | | | | | | | | | | | | |||||
| | | | * | | | | | | | | | added peek to ivq. some tests for peek | Rob Harrop | 2010-09-27 | 3 | -3/+15 |
| | | | | | | | | | | | | | |||||
| | | | * | | | | | | | | | added peek to backing queue, implemented in vq | Rob Harrop | 2010-09-27 | 4 | -5/+71 |
| | | | | | | | | | | | | | |||||
