summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* oops - we mean 'not is_permanent' hereTim Watson2012-11-301-2/+2
|
* handle {permanent, Delay} for dynamic childrenTim Watson2012-11-291-12/+8
|
* merge headsTim Watson2012-11-2913-120/+92
|\
| * merge default (again)Tim Watson2012-11-2713-120/+92
| |\
| | * Merge bug25323Simon MacMullen2012-11-277-57/+40
| | |\
| | | * mark all messages enqueued in the slave as 'delivered'Matthias Radestock2012-11-267-57/+40
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | which is a much better than the set_delivered logic, which we can now get rid of. In doing so it also becomes clear that having the 'delivered' flag in the #message_properties is less than ideal. It is mutable and we never bothered updating vq s.t. it sets the flag correctly. So lets get rid of it and add a parameter to bq:publish instead
| | * | cosmeticMatthias Radestock2012-11-271-5/+3
| | | |
| | * | remove cruftMatthias Radestock2012-11-261-1/+0
| | | |
| | * | merge stable into defaultTim Watson2012-11-265-38/+31
| | |\ \
| | | * \ merge bug25309 into stableTim Watson2012-11-265-38/+31
| | | |\ \
| | | | * \ merge stable into bug25309Tim Watson2012-11-263-25/+42
| | | | |\ \ | | | | |/ / | | | |/| |
| | | | * | recover for accidental merge with defaultTim Watson2012-11-261-1/+1
| | | | | |
| | | | * | Fix a race where we decide on the BQ before writing the #amqqueue{} to ↵Simon MacMullen2012-11-221-4/+5
| | | | | | | | | | | | | | | | | | | | | | | | Mnesia, then the policy changes and we are therefore not notified. We now only make the initial decision after we can be assured we will be informed of subsequent changes.
| | | | * | Carry on if an individual notification fails.Simon MacMullen2012-11-211-2/+2
| | | | | |
| | | | * | Useful guard.Simon MacMullen2012-11-211-1/+1
| | | | | |
| | | | * | Don't try to assert result of {add,drop}_mirror.Simon MacMullen2012-11-211-11/+3
| | | | | |
| | | | * | Make start/stop mirroring into a cast not a call.Simon MacMullen2012-11-212-19/+19
| | | | | |
| | * | | | merge bug25303 into defaultMatthias Radestock2012-11-264-9/+11
| | |\ \ \ \
| | | * | | | cosmeticMatthias Radestock2012-11-261-3/+2
| | | | | | |
| | | * | | | Untuple fold functionEmile Joubert2012-11-264-6/+6
| | | | | | |
| | | * | | | Add message properties to backing queue foldEmile Joubert2012-11-234-9/+12
| | | | | | |
| | * | | | | Merged bug25311Emile Joubert2012-11-267-61/+140
| | |\ \ \ \ \ | | | | |_|_|/ | | | |/| | |
| | * | | | | don't evict messages from RAM when inserting them into pending_ackMatthias Radestock2012-11-231-10/+7
| | | | | | |
* | | | | | | observe use_specsTim Watson2012-11-291-12/+65
| | | | | | |
* | | | | | | explain why we're not using lists:keyfind/3Tim Watson2012-11-291-0/+1
| | | | | | |
* | | | | | | reduce distance to OTPTim Watson2012-11-291-2/+3
|/ / / / / /
* | | | | | merge defaultTim Watson2012-11-2737-1019/+1461
|\ \ \ \ \ \ | | |/ / / / | |/| | | |
| * | | | | merge bug25324 into defaultMatthias Radestock2012-11-241-1/+1
| |\ \ \ \ \
| | * | | | | 'pid' is a valid INFO_KEYMatthias Radestock2012-11-241-1/+1
| |/ / / / / | | | | | | | | | | | | | | | | | | and some code, namely the clustering tests, rely on that
| * | | | | merge bug25303 into defaultMatthias Radestock2012-11-235-9/+93
| |\ \ \ \ \ | | | |/ / / | | |/| | |
| | * | | | cosmeticMatthias Radestock2012-11-231-6/+5
| | | | | |
| | * | | | more precise signatureMatthias Radestock2012-11-231-3/+2
| | | | | |
| | * | | | Better type signatureEmile Joubert2012-11-232-7/+3
| | | | | | | | | | | | | | | | | | | | | | | | ...and rollback amqqueue_process changes
| | * | | | Propagate API changeEmile Joubert2012-11-233-2/+17
| | | | | |
| | * | | | Backing queue fold testsEmile Joubert2012-11-231-2/+20
| | | | | |
| | * | | | Refactor backing queue delta foldEmile Joubert2012-11-231-39/+32
| | | | | |
| | * | | | QC test for backing queue foldEmile Joubert2012-11-222-5/+22
| | | | | |
| | * | | | Merged defaultEmile Joubert2012-11-225-23/+30
| | |\ \ \ \
| | * \ \ \ \ Merged defaultEmile Joubert2012-11-221-0/+47
| | |\ \ \ \ \
| | | * | | | | Minimal backing queue foldEmile Joubert2012-11-214-22/+83
| | | | | | | |
| * | | | | | | Merged bug25315Emile Joubert2012-11-237-151/+197
| |\ \ \ \ \ \ \ | | | |_|_|/ / / | | |/| | | | |
| | * | | | | | refactor: vq:ram_ack_index doesn't need to be a gb_treeMatthias Radestock2012-11-231-12/+11
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | a gb_set suffices
| | * | | | | | merge bug23625 into defaultMatthias Radestock2012-11-234-106/+137
| | |\ \ \ \ \ \ | | | |_|_|/ / / | | |/| | | | |
| | | * | | | | ExplainSimon MacMullen2012-11-221-0/+10
| | | | | | | |
| | | * | | | | Don't duplicate name.Simon MacMullen2012-11-221-1/+1
| | | | | | | |
| | | * | | | | optimiseMatthias Radestock2012-11-161-2/+4
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | this brings perf roughly on par with default
| | | * | | | | identify queues by name rather than pid in channel statsMatthias Radestock2012-11-162-67/+86
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - in deliver_to_queues, take the result of rabbit_amqqueue:lookup and use it to a) add entries to a QPid -> QName mapping in the state for all master pids, and b) setup monitors for all master pids - for the stats creation in deliver_to_queues, map the DeliveredQPids to the associated QNames, via the mapping in the State. Note that this will ignore slave pids, hence we only get one stat per QName (which is good). Also, in the event that the master died between lookup and delivery (and the delivery was 'mandatory'), we will not record any stats at all. - in monitor_delivering_queue, which is called by basic.{consume,get} we add to the mapping - in ack/2 we use the mapping to obtain QNames from QPids, and use that in stats. Since a queue may have vanished prior to the ack/reject arriving, we need to handle the case of no entry being present in the mapping for the given QPid. - in record_sent we have the QName anyway, so can just record stats against that instead of the QPid. - in the 'DOWN' handler we use the mapping to determine the QName from the pid, and pass that to erase_queue_stats, which can now remove entries based on the QName. We then remove the entry from the mapping.
| | | * | | | | propagate API changeMatthias Radestock2012-11-161-1/+1
| | | | | | | |
| | | * | | | | merge default into bug23625Matthias Radestock2012-11-162-38/+38
| | | |\ \ \ \ \
| | | | * \ \ \ \ merge default into bug23625Matthias Radestock2012-11-164-89/+69
| | | | |\ \ \ \ \
View Lorry Controller Status