summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* 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.
| * | | merge bug25192 into defaultTim Watson2012-10-120-0/+0
| |\ \ \
| * \ \ \ merge default (again)Tim Watson2012-10-122-18/+11
| |\ \ \ \ | | |/ / /
| | * | | Merged bug25195 into defaultEmile Joubert2012-10-126-33/+172
| | |\ \ \ | | | |/ /
| | * | | Merge defaultSimon MacMullen2012-10-104-44/+44
| | |\ \ \
| * | | | | Unused variable.Simon MacMullen2012-10-121-1/+1
| | | | | |
| * | | | | Merge in defaultSimon MacMullen2012-10-1210-91/+230
| |\ \ \ \ \ | | | |_|/ / | | |/| | |
| | * | | | Bug 25110 broke ability to invoke "rabbitmqctl stop_app; rabbitmqctl ↵Simon MacMullen2012-10-111-2/+5
| | | | | | | | | | | | | | | | | | | | | | | | status". Fix that.
| | * | | | remove a remnant of 'immediate'Matthias Radestock2012-10-111-10/+4
| | | | | |
| | * | | | better typesMatthias Radestock2012-10-111-3/+4
| | | | | |
| | * | | | merge bug25110 into defaultMatthias Radestock2012-10-112-1/+127
| | |\ \ \ \
| | | * | | | Remove rabbit_misc:interval_operation/3, it doesn't really work.Simon MacMullen2012-10-091-13/+0
| | | | | | |
| | | * | | | cosmetic: trains stationMatthias Radestock2012-10-081-2/+2
| | | | | | |
View Lorry Controller Status