summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Improved documentation and added additional tests for bpqueueMatthew Sackman2010-05-132-6/+80
|
* Merge default into bug 21673Matthew Sackman2010-05-133-51/+58
|\
| * Merging bug 22732 into defaultMatthew Sackman2010-05-131-1/+1
| |\
| | * Merge duplicate commitsEmile Joubert2010-05-120-0/+0
| | |\
| | | * Register memory alarm after channel openEmile Joubert2010-05-121-1/+1
| | |/ | |/| | | | | | | to prevent a closed channel from producing channel_flow
| | * Register memory alarm after channel openEmile Joubert2010-05-121-1/+1
| |/
| * merge bug22697 into defaultMatthias Radestock2010-05-072-50/+57
| |\
| | * get rid of now redundant 'sync' call handlerMatthias Radestock2010-05-072-27/+23
| | | | | | | | | | | | and some cosmetic changes
| | * More sensible registration and cancellation to various servicesMatthew Sackman2010-05-071-6/+6
| | |
| | * Move the internal declare step into the queue process side of thingsMatthew Sackman2010-05-072-44/+55
| |/
* | Reverse the order so that we stop and then unlink+capture_exit. We don't ↵Matthew Sackman2010-05-132-2/+2
| | | | | | | | think this should make any difference, but it's a little neater
* | tweak msg_store_index initialisation APIMatthias Radestock2010-05-134-25/+27
| |
* | cosmeticMatthias Radestock2010-05-131-9/+17
| |
* | correct harmless off-by-one mistakeMatthias Radestock2010-05-101-2/+2
| | | | | | | | | | | | | | | | | | | | a gc can only take place if we have at least three files - the current file (which we cannot gc), the source file and the destination file. We do a quick check wether there is enough data - garbage or otherwise - to require more than two files. This can give false positives since the last message in a file can overrun the limit, but that's ok as the code that follows performs more accurate (but also more expensive) checks.
* | nitpickMatthias Radestock2010-05-101-1/+1
| |
* | change the way we pick gc candidatesMatthias Radestock2010-05-101-87/+72
| | | | | | | | | | | | instead of picking them with a random geometric distribution, which requires a magic constant and involved some rather obscure code, we simply pick the eldest suitable file pair.
* | trigger possible msg_store gc in all the right placesMatthias Radestock2010-05-101-15/+13
| | | | | | | | | | | | | | | | | | - on removal of a message (since there is now more garbage) - at the end of init (since the recovery may have created garbage) - after rolling to a new file (since the old current file may be eligible for compaction with it's left neighbour) - at the end of gc (since we may not have reclaimed enough garbage to drop below the gc threshold)
* | more obvious check for current fileMatthias Radestock2010-05-101-9/+8
| | | | | | | | and some cosmetic tweaks
* | minor refactorMatthias Radestock2010-05-071-8/+6
| |
* | oopsMatthias Radestock2010-05-061-2/+2
| |
* | refactoring and tweaking of gatherer code and usageMatthias Radestock2010-05-063-120/+110
| | | | | | | | | | | | | | | | | | | | | | - better function names - get rid of the notion of named forks; just counting them is sufficient - don't terminate automatically, which results in a more symmetric API and allows gatherer reuse - in the gatherer usage, spawn workers with a thunk rather than MFA, which is less cryptic - use of folds and list comprehensions in queue_index_walker, in preference over recursion
* | merge default into bug21673Matthias Radestock2010-05-0612-242/+473
|\ \ | |/
| * Merging bug 19844 onto defaultMatthew Sackman2010-05-058-173/+460
| |\
| | * CosmeticsMatthew Sackman2010-05-053-12/+8
| | |
| | * Retain all exception information if thrown. Use that to rethrow in the ↵Simon MacMullen2010-05-054-47/+63
| | | | | | | | | | | | single pid case, and mimic gen_server:multi_call in the multiple pid case.
| | * cosmeticMatthew Sackman2010-04-301-4/+4
| | |
| | * FPid => FunMatthew Sackman2010-04-301-24/+24
| | |
| | * Cosmetics and minor refactoringsMatthew Sackman2010-04-302-41/+45
| | |
| | * result, not return...Simon MacMullen2010-04-294-17/+17
| | |
| | * Rename invoke_async as it's not really async.Simon MacMullen2010-04-294-17/+17
| | |
| | * Commit 0ab19fce3677 broke effect visibility again! This time, go through a ↵Simon MacMullen2010-04-291-11/+18
| | | | | | | | | | | | predictable process on the local side.
| | * cosmeticsMatthew Sackman2010-04-281-4/+4
| | |
| | * cosmeticsMatthew Sackman2010-04-281-6/+6
| | |
| | * Don't use server(Hash) to name the delegate process.Simon MacMullen2010-04-282-3/+2
| | |
| | * Explain asyncness.Simon MacMullen2010-04-281-0/+5
| | |
| | * Always catch, don't ever allow the server process to die.Simon MacMullen2010-04-281-1/+4
| | |
| | * Parallelise communication with multiple nodes.Simon MacMullen2010-04-281-7/+17
| | |
| | * Move the gen_server2-via-delegate code into amqqueue; it should only be used ↵Simon MacMullen2010-04-282-40/+32
| | | | | | | | | | | | there anyway.
| | * Rename delegate:call and :cast to :invoke and :invoke_async.Simon MacMullen2010-04-284-34/+34
| | |
| | * Cache the actual delegate process name, not the result of process_count.Simon MacMullen2010-04-281-15/+14
| | |
| | * Remove gen_server2 use, bump up timeouts, tidy GoodRes / BadRes checking.Simon MacMullen2010-04-281-9/+7
| | |
| | * cosmeticsMatthew Sackman2010-04-274-26/+18
| | |
| | * Merging default into bug 19844Matthew Sackman2010-04-276-126/+99
| | |\
| | * | Fixing up coverage - it would appear the coverage is *very* sensitive about ↵Matthew Sackman2010-04-261-3/+2
| | | | | | | | | | | | | | | | how it gets started
| | * | Merging default into bug19844Matthew Sackman2010-04-2613-85/+440
| | |\ \
| | * | | Add / fix specs, and remove some unreachable code.Simon MacMullen2010-04-224-8/+32
| | | | |
| | * | | If the other node is down and we're only going to delegate:cast anyway we ↵Simon MacMullen2010-04-221-3/+8
| | | | | | | | | | | | | | | | | | | | don't want to log an error, so handle badrpc by ignoring it.
| | * | | Use 2x CPUs as the number of delegate processes.Simon MacMullen2010-04-223-40/+19
| | | | |
| | * | | Use phash2/2, remove string:concat.Simon MacMullen2010-04-222-3/+3
| | | | |
| | * | | Remove delegate_sup_sup, make delegates restartable on error.Simon MacMullen2010-04-222-2/+2
| | | | |