summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Expose the msg_store file size limit to configuration. Also some suitable ↵Matthew Sackman2010-06-176-62/+89
| | | | derivisions in tests.
* Added test to invoke the queue index walkerMatthew Sackman2010-06-171-3/+4
|
* Mergin' headsMatthew Sackman2010-06-171-14/+18
|\
| * rename betas_from_segment_entries and make it more efficientMatthias Radestock2010-06-171-14/+18
| | | | | | | | | | ...by exploiting the ability of queue_index:{deliver,ack} to take multiple SeqIds
* | Removed unenforced redundancy in function argsMatthew Sackman2010-06-171-4/+5
|/
* make queue_index:deliver take a list of SeqIdsMatthias Radestock2010-06-173-54/+47
| | | | | ...rather than just a single SeqId. This brings it in line with 'ack', simplifies the code, and is useful in variable_queue.
* get rid of vq:read_one_index_segmentMatthias Radestock2010-06-173-29/+18
| | | | | | | | | | | | The purpose of the function was to keep reading until either some data was found or the end was reached. However, both call sites contain loops already that effectively do the same, making the function redundant. There is also a small tweak to the qi:read API - it now returns the "next seq id to read". Previously it was returning 'undefined' when the requested (exclusive) End was inside the same segment as the Start, so now we simply return that End in that case.
* renameMatthias Radestock2010-06-161-6/+4
|
* refactor: invert condition to make it easier to readMatthias Radestock2010-06-161-3/+3
|
* minor refactorMatthias Radestock2010-06-161-2/+2
|
* cosmeticMatthias Radestock2010-06-161-9/+5
|
* restructure 'purge' in order to make its operation more obviousMatthias Radestock2010-06-161-15/+18
|
* simplify 'purge'Matthias Radestock2010-06-161-29/+21
| | | | it doesn't need to compute the Count since we already know it
* cosmeticMatthias Radestock2010-06-161-26/+27
|
* Merging headsMatthew Sackman2010-06-151-64/+79
|\
| * assert vq state invariantsMatthias Radestock2010-06-151-64/+79
| | | | | | | | as a post condition on all exported functions
* | Improved test coverage of the queue index walkerMatthew Sackman2010-06-152-6/+35
|/
* Good lord, how did that get through?Matthew Sackman2010-06-151-1/+1
|
* cosmeticMatthias Radestock2010-06-151-22/+14
|
* minor refactorMatthias Radestock2010-06-151-6/+5
|
* tweak: trust our own code a bit moreMatthias Radestock2010-06-151-2/+1
|
* minor refactor: rename functionMatthias Radestock2010-06-151-10/+10
|
* Merging default into bug 21673Matthew Sackman2010-06-1440-380/+697
|\
| * Merged bug 21842.Simon MacMullen2010-06-141-2/+2
| |\
| | * restart bug21842 off defaultAlexandru Scvortov2010-06-141-2/+2
| | |
| * | Clarify comment.Simon MacMullen2010-06-141-3/+3
| | |
| * | Merging bug 18524 onto defaultMatthew Sackman2010-06-117-72/+116
| |\ \
| | * | removed unnecessary ifdefsAlexandru Scvortov2010-06-111-6/+3
| | | |
| | * | ifdefs surround ALL the specsAlexandru Scvortov2010-06-111-1/+1
| | | |
| | * | fixed specsAlexandru Scvortov2010-06-093-8/+8
| | | |
| | * | cosmeticAlexandru Scvortov2010-06-091-3/+1
| | | |
| | * | enclosed generated specs in -ifdefsAlexandru Scvortov2010-06-091-5/+6
| | | |
| | * | spaces instead of tabs in autogenerated codeAlexandru Scvortov2010-06-091-2/+2
| | | |
| | * | removed duplicated codeAlexandru Scvortov2010-06-091-40/+21
| | | |
| | * | codegen.py now works with latest rabbit-codegenAlexandru Scvortov2010-06-031-1/+3
| | | |
| | * | updated .hgignoreAlexandru Scvortov2010-06-031-0/+1
| | | |
| | * | rabbit_framing_spec.hrl is now generatedAlexandru Scvortov2010-06-033-111/+85
| | | |
| | * | auto-generation of all function specs for rabbit_framingAlexandru Scvortov2010-06-032-19/+40
| | | |
| | * | more rabbit_framing specs are generated automaticallyAlexandru Scvortov2010-06-022-3/+72
| | | |
| * | | Merge headsEmile Joubert2010-06-111-7/+2
| |\ \ \
| | * \ \ Merged bug21846 into defaultEmile Joubert2010-06-111-7/+2
| | |\ \ \ | | | |_|/ | | |/| |
| | | * | Remove unused variable.Simon MacMullen2010-06-081-1/+0
| | | | |
| | | * | Prevent the same delivery tag being used more than once.Simon MacMullen2010-06-081-6/+2
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Note that we change from command_invalid to not_found as the former is a connection error, and the latter a channel error. Both 0-8 and 0-9-1 specify a channel error.
| * | | | Merging bug 22847 onto defaultMatthew Sackman2010-06-112-16/+14
| |\ \ \ \ | | |/ / / | |/| | |
| | * | | Don't reply after replying.Simon MacMullen2010-06-101-1/+1
| | | | |
| | * | | might as well do the reply first thing, before the case.Simon MacMullen2010-06-091-1/+1
| | | | |
| | * | | Move synchronous amqqueue:requeue/3 from amqp_0_9_1 to defaultSimon MacMullen2010-06-092-16/+14
| | |/ /
| * | | Merging bug 22848 onto defaultMatthew Sackman2010-06-108-19/+71
| |\ \ \
| | * | | Use precondition_failed for equivalence failure.Simon MacMullen2010-06-102-3/+3
| | | | |
| | * | | Cosmetic.Simon MacMullen2010-06-101-4/+4
| | | | |