summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* CosmeticSimon MacMullen2012-10-191-17/+17
|
* merge defaultTim Watson2012-10-184-10/+19
|\
| * Merge bug21413Simon MacMullen2012-10-1723-839/+1196
| |\
| * | Further spec correctness for RPMEmile Joubert2012-10-043-6/+10
| | |
| * | Change RPM service launcherEmile Joubert2012-09-282-2/+7
| | |
| * | Lintian warningsEmile Joubert2012-09-281-2/+2
| | |
* | | oopsTim Watson2012-10-175-14/+20
| | |
* | | do not couple gm with rabbit_miscTim Watson2012-10-176-59/+81
| | |
* | | use the worker pool for gm mnesia txnsTim Watson2012-10-171-12/+12
| |/ |/|
* | Fix formatted error handling as broken by Matthias in 891e659f0e77.Simon MacMullen2012-10-162-6/+8
| |
* | cosmeticMatthias Radestock2012-10-161-4/+2
| |
* | one less place to equate mirrors with nodesMatthias Radestock2012-10-163-9/+8
| |
* | merge bug25202 into defaultMatthias Radestock2012-10-166-17/+52
|\ \
| * | cosmeticMatthias Radestock2012-10-163-7/+4
| | |
| * | merge default into bug25202Matthias Radestock2012-10-162-127/+78
| |\ \ | |/ / |/| |
* | | merge headsMatthias Radestock2012-10-161-5/+7
|\ \ \
| * | | compare pids instead of nodes in slave's handle_call/gm_deathsMatthias Radestock2012-10-161-5/+7
| | | |
* | | | Merge bug25225Simon MacMullen2012-10-162-102/+55
|\ \ \ \ | |/ / / |/| | |
| * | | merge slave 'confirm' decision making and actionMatthias Radestock2012-10-151-31/+21
| | | | | | | | | | | | | | | | similar to what we did in rabbit_amqqueue_process
| * | | refactor: handle all msg statuses uniformlyMatthias Radestock2012-10-151-6/+1
| | | |
| * | | refactor: deal with 'publish' and 'publish_delivered' in separate clausesMatthias Radestock2012-10-151-12/+11
| | | |
| * | | refactor: extract commonality between 'publish' and 'discard'Matthias Radestock2012-10-151-73/+30
| | | |
| * | | deal with confirms in slave 'discard'Matthias Radestock2012-10-151-2/+14
| | | |
| * | | merge default into bug25225Matthias Radestock2012-10-151-11/+9
| |\ \ \
| * \ \ \ merge default into bug25225Matthias Radestock2012-10-123-79/+61
| |\ \ \ \
| * | | | | optimise x-message-ttl=0 & confirms path on queueMatthias Radestock2012-10-121-14/+10
| | | | | | | | | | | | | | | | | | | | | | | | changes to slave still to come
* | | | | | remove comment that doesn't make any sense and is irrelevantMatthias Radestock2012-10-161-2/+0
| | | | | |
* | | | | | merge headsMatthias Radestock2012-10-161-1/+1
|\ \ \ \ \ \
| * | | | | | TypoSimon MacMullen2012-10-161-1/+1
| | | | | | |
* | | | | | | refactor: don't track slave's master_pid separatelyMatthias Radestock2012-10-161-18/+16
|/ / / / / /
| | | | * | Make sure we don't stomp on GMPids if a slave manages to get to Mnesia ↵Simon MacMullen2012-10-161-3/+6
| | | | | | | | | | | | | | | | | | | | | | | | before us.
| | | | * | We don't need the 'existing' records, and without them we don't need to ↵Simon MacMullen2012-10-162-7/+4
| | | | | | | | | | | | | | | | | | | | | | | | compare GMPids for sameness.
| | | | * | simplifyMatthias Radestock2012-10-161-4/+1
| | | | | |
| | | | * | merge default into bug25202Matthias Radestock2012-10-1612-162/+309
| | | | |\ \ | |_|_|_|/ / |/| | | | | | | | | | | | | | | | | ...and in the process inline mq_slave:forget_slave and fix a bug in it (it was looking at the wrong element of the tuple)
* | | | | | refactor: slightly more sensible signature for add_slaveMatthias Radestock2012-10-161-6/+8
| | | | | |
* | | | | | refactor: correct confusing variable namingMatthias Radestock2012-10-161-6/+6
| | | | | |
* | | | | | merge bug25207 into defaultTim Watson2012-10-150-0/+0
|\ \ \ \ \ \ | | |_|/ / / | |/| | | |
* | | | | | merge default (again)Tim Watson2012-10-151-11/+9
|\ \ \ \ \ \ | |/ / / / /
| * | | | | Merge bug25226Simon MacMullen2012-10-150-0/+0
| |\ \ \ \ \ | | | |/ / / | | |/| | |
| * | | | | plug leakMatthias Radestock2012-10-131-11/+9
| |/ / / / | | | | | | | | | | | | | | | | | | | | always remove from PendingCh when we receive a msg via gm that we previously received from the channel.
* | | | | merge defaultTim Watson2012-10-1511-211/+344
|\ \ \ \ \ | |/ / / /
| * | | | correct essay & comments regarding the 'delayed confirm' rationaleMatthias Radestock2012-10-122-23/+22
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Matthew has confirmed that the "we don't know the msg_seq_no until we receive the msg from the channel" reason is bogus. The msg_seq_no is allocated by the channel prior to routing and thus is the same across the master and all slaves. Hence the 'publish' via gm contains all the information we need to issue a confirm. Nevertheless we cannot actually issue the confirm until we've received the message from the channel. The essay now explains the real reason.
| * | | | store less in the slave's msg_id_statusMatthias Radestock2012-10-121-20/+16
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | There is no need to track the ChPid of 'published' and 'confirmed'. Also: neater conversion of msg_id_status on promotion.
| * | | | refactor: simplify confirm handling in queueMatthias Radestock2012-10-121-31/+19
| | | | | | | | | | | | | | | | | | | | three functions into one
| * | | | cosmeticMatthias Radestock2012-10-121-3/+2
| | | | |
| * | | | re-instate TODOMatthias Radestock2012-10-121-0/+1
| | | | |
| * | | | a spot of inliningMatthias Radestock2012-10-121-15/+10
| |/ / / | | | | | | | | | | | | | | | | ...and refactoring; exploiting the fact that maybe_record_confirm_message is a no-op when Confirm == never
| * | | Merge headsSimon MacMullen2012-10-121-2/+4
| |\ \ \
| | * \ \ Merge bug25222Simon MacMullen2012-10-120-0/+0
| | |\ \ \
| | * | | | monitor channel on discardMatthias Radestock2012-10-121-2/+4
| | |/ / / | | | | | | | | | | | | | | | | | | | | | | | | | just as we do for publish/publish_delivered w/o that there is a 20s delay in slaves cleaning up after channel closure if all the messages sent on the channel were discarded.