summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* 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
* 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
| | | |\ \ \
| | | * \ \ \ merge default into bug23625Matthias Radestock2012-11-152-38/+38
| | | |\ \ \ \
| | | | * \ \ \ merge default into bug23625Matthias Radestock2012-11-151-6/+4
| | | | |\ \ \ \
| | | | * | | | | reference queue by name in consumer eventsMatthias Radestock2012-11-151-18/+22
| | | | | | | | |
| | | | * | | | | emit names instead of pids in queue process' queue eventsMatthias Radestock2012-11-152-20/+16
| | | | | | | | |
| | | | * | | | | restart branchMatthias Radestock2012-11-150-0/+0
| | | | | | | | |
| * | | | | | | | stable to defaultSimon MacMullen2012-11-228-83/+141
| |\ \ \ \ \ \ \ \
| | * \ \ \ \ \ \ \ merge bug25314 into defaultMatthias Radestock2012-11-220-0/+0
| | |\ \ \ \ \ \ \ \ | | | | |_|_|_|_|/ / | | | |/| | | | | |
| | * | | | | | | | Rename backing queue foldEmile Joubert2012-11-225-11/+12
| | |/ / / / / / /
| | * | | | | | | Merged stableEmile Joubert2012-11-228-72/+129
| | |\ \ \ \ \ \ \
| * | \ \ \ \ \ \ \ Merge bug25305Simon MacMullen2012-11-223-13/+24
| |\ \ \ \ \ \ \ \ \ | | |/ / / / / / / /
| | * | | | | | | | Merged bug25306Emile Joubert2012-11-222-11/+20
| | |\ \ \ \ \ \ \ \
| | | * | | | | | | | leave the ram_msg_count unchanged in BQ:foldMatthias Radestock2012-11-221-5/+7
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | since we are not moving messages *into the queue*
| | | * | | | | | | | add test for invoking bq:fold when messages are on diskMatthias Radestock2012-11-211-0/+7
| | | | | | | | | | |
| | | * | | | | | | | assert after foldMatthias Radestock2012-11-211-7/+6
| | | | | | | | | | |
| | | * | | | | | | | assertionMatthias Radestock2012-11-201-0/+1
| | | | | | | | | | |
| * | | | | | | | | | ack unroutable dead-lettered messages straight awayMatthias Radestock2012-11-201-12/+18
| | |/ / / / / / / / | |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | thus plugging a leak
* | | | | | | | | | propagate API changeMatthias Radestock2012-11-221-4/+4
| | | | | | | | | |
* | | | | | | | | | bq api tweak: don't include remaining message count in fetch/drop resultMatthias Radestock2012-11-226-47/+42
| |_|/ / / / / / / |/| | | | | | | |
* | | | | | | | | merge stable into defaultMatthias Radestock2012-11-228-72/+129
|\ \ \ \ \ \ \ \ \ | |_|/ / / / / / / |/| | | | | | | |
| * | | | | | | | refactor: simplify rabbit_exchange:serialise_eventsMatthias Radestock2012-11-211-6/+2
| | | | | | | | |
| * | | | | | | | simplify & optimise rabbit_exchange:callback/4Matthias Radestock2012-11-211-9/+5
| | | | | | | | |
| * | | | | | | | Merged bug25302Emile Joubert2012-11-211-1/+0
| |\ \ \ \ \ \ \ \
| | * | | | | | | | remove unused vqstate fieldMatthias Radestock2012-11-201-1/+0
| | | |_|_|_|_|_|/ | | |/| | | | | |
| * | | | | | | | BQ quickcheck postcondition for dropEmile Joubert2012-11-211-2/+2
| | | | | | | | |
| * | | | | | | | some quick check testsMatthias Radestock2012-11-201-22/+48
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | all work ok, but then again that's also the case when I completely break vq.
| * | | | | | | | add test of vq:dropMatthias Radestock2012-11-201-0/+15
| | | | | | | | |
View Lorry Controller Status