summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* rename queue_index:terminate_and_erase to delete_and_terminateMatthias Radestock2010-05-203-11/+11
| | | | to match the corresponding function in variable_queue
* cosmeticMatthew Sackman2010-05-191-1/+1
|
* cosmeticMatthew Sackman2010-05-191-1/+1
|
* do the minimum amount of work necessary on clean queue recoveryMatthias Radestock2010-05-191-67/+60
| | | | Only read from the journal. No segment reading. No writing.
* Added test which hits all cases in journal_minus_segment which do not ↵Matthew Sackman2010-05-191-0/+21
| | | | require duplicates between segment and journal
* Merging headsMatthew Sackman2010-05-191-24/+15
|\
| * refactorMatthias Radestock2010-05-191-11/+6
| |
| * cosmeticMatthias Radestock2010-05-191-13/+9
| |
* | Full code coverage of segment_plus_journalMatthew Sackman2010-05-191-0/+21
|/
* Drop PubCount and AckCount in favour of UnackedCountMatthew Sackman2010-05-191-91/+78
|
* some inliningMatthias Radestock2010-05-191-28/+16
| | | | and removal of some comments that weren't particularly useful
* avoid unnecessary matchMatthias Radestock2010-05-191-1/+1
|
* keep complete pub/del/ack entries in journal on recoveryMatthias Radestock2010-05-191-1/+1
| | | | | | | | | | | | | IF there is no entry for that message in the segment This is - more efficient, since there could be quite a few of these and we are avoiding an array update for them - more consistent with the other 'keep' cases - the same as would happen if the journal had been built up by queue operations rather than through recovery The entries are filtered out eventually when flushing the journal.
* seed journal_minus_segment with the original journalMatthias Radestock2010-05-191-22/+23
| | | | | | | | ...and modify/remove things in/from it; rather than building a new journal from scratch. The result is the same, but this way of doing things a) better reflects what this function is about, and b) should be more efficient in the common case where the journal does not contain stale entries
* journal_plus_segment -> segment_plus_journalMatthias Radestock2010-05-191-10/+10
| | | | | This better reflects what we are actually doing, i.e. we take the segment and add the journal.
* KeepAck -> KeepAckedMatthias Radestock2010-05-181-17/+17
|
* minor refactorMatthias Radestock2010-05-181-16/+16
|
* Added documentation regarding the clean shutdown and startup optimisationsMatthew Sackman2010-05-183-11/+48
|
* Added specs for msg_store_gcMatthew Sackman2010-05-181-0/+13
|
* No need to build up a list of transient queue indices to deleteMatthew Sackman2010-05-181-9/+7
|
* Removing erroneous conjunctive clause in testMatthew Sackman2010-05-181-1/+1
|
* merge headsMatthias Radestock2010-05-181-45/+39
|\
| * Refactored bpqueue testsMatthew Sackman2010-05-181-45/+39
| |
* | correct commentMatthias Radestock2010-05-181-7/+8
|/
* take the journal into consideration in recover_segmentMatthias Radestock2010-05-181-44/+51
| | | | which removes the need for an initial flush
* Merging default into bug 21673Matthew Sackman2010-05-184-8/+33
|\
| * Merge bug22763 into defaultDavid Wragg2010-05-161-1/+13
| |\
| | * Warn, rather than die, on not-found module in boot step constructionTony Garnock-Jones2010-05-151-1/+13
| | |
| * | Merge bug22762 into defaultDavid Wragg2010-05-161-0/+6
| |\ \
| | * | It's _rabbit_erllibdir, not _maindirTony Garnock-Jones2010-05-151-2/+4
| | | |
| | * | Clean out plugin activation state on uninstall and upgradeTony Garnock-Jones2010-05-151-0/+4
| | |/
| * | Merge bug22756 into defaultDavid Wragg2010-05-161-6/+13
| |\ \ | | |/ | |/|
| | * merge default into bug22756Tony Garnock-Jones2010-05-141-1/+1
| | |\
| | * | Remove traces of plugins on "remove" and "upgrade" as well as "purge"Tony Garnock-Jones2010-05-141-6/+13
| | | |
| * | | Merge bug22754 into default (nothing to do with floating point)David Wragg2010-05-141-1/+1
| |\ \ \ | | |_|/ | |/| |
| | * | Do not install the INSTALL file in debian packagesMatthew Sackman2010-05-131-1/+1
| |/ /
* | | vq:delete1 does not need to return nor pass around any countMatthew Sackman2010-05-181-15/+11
| | |
* | | Because of the change to qi:read, we now don't need δ to start on a segment ↵Matthew Sackman2010-05-182-12/+2
| | | | | | | | | | | | boundary. This removes the need for current_segment_boundary
* | | Cosmetics and documentationMatthew Sackman2010-05-181-19/+21
| | |
* | | cosmeticMatthias Radestock2010-05-181-11/+8
| | |
* | | Apparently it's wrong to do the least amount of work possible.Matthew Sackman2010-05-181-32/+23
| | |
* | | Reworked reading from the queue to still be limited to a maximum of one ↵Matthew Sackman2010-05-183-91/+120
| | | | | | | | | | | | segment, but with a more natural start+end interface
* | | Corrections to documentation in queue_indexMatthew Sackman2010-05-181-25/+30
| | |
* | | Drop segment_size and instead have a current_segment as well as a ↵Matthew Sackman2010-05-183-20/+12
| | | | | | | | | | | | next_segment function
* | | Renaming some very long function name to a much shorter nameMatthew Sackman2010-05-183-24/+15
| | |
* | | rename some qi funsMatthias Radestock2010-05-183-130/+117
| | |
* | | cosmeticMatthias Radestock2010-05-171-6/+4
| | |
* | | fix typoMatthias Radestock2010-05-171-2/+2
| | |
* | | Change how we handle a gc finding concurrent readers on the same file. ↵Matthew Sackman2010-05-172-23/+60
| | | | | | | | | | | | Previously we were just waiting and trying again. Now we get the readers to signal to the GC when they're done. This itself introduces a race and so has to carefully deal with such notifications arriving after the GC has completed, but it removes a magic number. Also fixed a bug which mean readers were reading from locked files. Whoops.
* | | Improved incorrect or outdated documentation in msg_storeMatthew Sackman2010-05-171-30/+27
| | |