summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Increase the amount of symmetry.bug25152Simon MacMullen2012-09-171-7/+7
|
* bring queue/exchange removal cost back down to O(binding_count)Matthias Radestock2012-09-151-20/+30
| | | | by performing all mnesia read operations before writes
* guard deletes on disk tables in order to eliminate superfluos fsyncsMatthias Radestock2012-09-153-5/+23
| | | | | Unfortunately this makes queue deletion O(binding_count^2), so further work is needed.
* Merge bug24914Simon MacMullen2012-09-145-105/+127
|\
| * merge bug25118 into defaultTim Watson2012-09-145-105/+127
| |\
| | * merge default into bug25118bug25118Tim Watson2012-09-145-105/+127
| | |\ | |/ /
| | * updated the essay to explain how the sync status works nowFrancesco Mazzoli2012-09-131-19/+25
| | |
| | * two little fixes...Francesco Mazzoli2012-09-061-2/+2
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | It turns out that the problems I had with the kill-multi test on default was because the messages were start publishing right after the queue was created. I thought that once queue.declare returned, it meant that the queue was present on all nodes, but it wasn't, and for this reason we had the mismatching messages and the purging. Once I discovered that, I went back two my code and immediately discovered two very silly mistakes. I feel silly as well now. I think that bug 25130 still has a reason to extist, but I wouldn't worry about it now.
| | * cosmeticsFrancesco Mazzoli2012-09-041-1/+1
| | |
| | * cosmeticsFrancesco Mazzoli2012-09-042-4/+1
| | |
| | * cosmeticsFrancesco Mazzoli2012-09-041-1/+1
| | |
| | * merge defaultFrancesco Mazzoli2012-09-047-110/+222
| | |\
| | * | remove differences with defaultFrancesco Mazzoli2012-09-041-10/+12
| | | |
| | * | track the delta of the depths, and replace `pending_ack' with `depth' in BQFrancesco Mazzoli2012-09-044-71/+52
| | | | | | | | | | | | | | | | The kill-multi test is still failing...
| | * | was getting `set_length' instead of `drop'Francesco Mazzoli2012-09-041-1/+1
| | | |
| | * | fix depth delta in the `publish' instructionFrancesco Mazzoli2012-09-041-1/+1
| | | |
| | * | forgot debug line inFrancesco Mazzoli2012-09-031-1/+0
| | | |
| | * | store the depth of master and slave instead of the unknown pending msgsFrancesco Mazzoli2012-09-032-69/+92
| | | |
| | * | refactoring: make the var match the fieldMatthias Radestock2012-08-311-8/+7
| | | |
| | * | refactoring: inline helper functionMatthias Radestock2012-08-311-24/+25
| | | |
| | * | cosmeticMatthias Radestock2012-08-311-3/+2
| | | |
| | * | styleFrancesco Mazzoli2012-08-311-5/+3
| | | |
| | * | revert `set_synchronized' => `update_unknown_pending'Francesco Mazzoli2012-08-311-22/+22
| | | | | | | | | | | | | | | | | | | | Matthias likes the old names better, arguing that the main purpose of that function is to do that mnesia transaction.
| | * | `set_synchronized' => `update_unknown_pending'Francesco Mazzoli2012-08-311-22/+22
| | | |
| | * | `set_length' => `drop'Francesco Mazzoli2012-08-311-2/+2
| | | |
| | * | `external_pending' => `unknown_pending'Francesco Mazzoli2012-08-311-6/+9
| | | |
| | * | use `set_synchronized' instead than manually increasingFrancesco Mazzoli2012-08-311-6/+2
| | | |
| | * | simplify `set_length' case, fixing the ToDrop < 0 branchFrancesco Mazzoli2012-08-311-20/+16
| | | | | | | | | | | | | | | | The unknown pending counter wasn't updated correctly
| | * | add the delta in `set_synchronized', fixes the call in `set_length'Francesco Mazzoli2012-08-311-3/+3
| | | |
| | * | `set_synchronized' accepts the difference instead of separate argsFrancesco Mazzoli2012-08-311-7/+7
| | | |
| | * | do not track external pendings until we receive `length'Francesco Mazzoli2012-08-311-2/+7
| | | | | | | | | | | | | | | | Otherwise, we might break some assertions.
| | * | actually, it looks like the slave might receive messages before `length'Francesco Mazzoli2012-08-311-1/+1
| | | | | | | | | | | | | | | | | | | | This is not a problem, since the worse that can happen is that we have a bogus sync state in the until `length' is received.
| | * | `length' should be the first instructions, lets assert thatFrancesco Mazzoli2012-08-311-1/+1
| | | |
| | * | get the external pending acks at the beginningFrancesco Mazzoli2012-08-312-5/+7
| | | |
| | * | add a callback to backing queue to get the number of pending acksFrancesco Mazzoli2012-08-313-7/+17
| | | |
| | * | matthias doesn't like the nested `set_synchronised' :(Francesco Mazzoli2012-08-301-20/+18
| | | |
| | * | take into account requeues when setting synch state for slavesFrancesco Mazzoli2012-08-302-58/+65
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | To do this, keep count all the fetches we've seen that require an ack for messages we don't have (e.g. when the queue we have is shorter than on the master). We then decrease this counter appropriately when requeueing, acking, and set_length'ing. Given this, we can deem the slave synced only when the length is the same *and* the counter described above is 9 - there are no pending acks on the master for messages we don't have. I might have missed something (I barely tested this) but it seems to do the trick.
* | | | fix comment in node_monitor, keep {error, enoent} in `try_read_file'bug24914Francesco Mazzoli2012-09-141-12/+8
| | | |
* | | | merge defaultFrancesco Mazzoli2012-09-149-822/+1299
|\ \ \ \ | |/ / / |/| | |
| * | | get cluster nodes from mnesia when legacy/non existant status fileFrancesco Mazzoli2012-09-131-2/+8
| | | | | | | | | | | | | | | | | | | | This is necessary because the upgrade process needs to remove the replicas of the schemas.
| * | | check the cluster consistency after the upgradeFrancesco Mazzoli2012-09-133-10/+12
| | | |
| * | | always call init_db with all nodesFrancesco Mazzoli2012-09-121-6/+6
| | | |
| * | | more informative and useful error messagesFrancesco Mazzoli2012-09-122-4/+10
| | | |
| * | | do not give up when finding an inconsistent nodeFrancesco Mazzoli2012-09-111-7/+10
| | | |
| * | | oopsFrancesco Mazzoli2012-09-111-2/+2
| | | |
| * | | split cluster status file and running nodes fileFrancesco Mazzoli2012-09-112-118/+97
| | | |
| * | | OopsSimon MacMullen2012-09-101-1/+1
| | | |
| * | | Attempt at simplifying check_cluster_consistency/0, but I am having trouble ↵Simon MacMullen2012-09-101-36/+40
| | | | | | | | | | | | | | | | with systest.
| * | | Typos and rephrasingSimon MacMullen2012-09-073-6/+6
| | | |
| * | | typo in rabbitmqctl man pageFrancesco Mazzoli2012-09-051-1/+1
| | | |
View Lorry Controller Status