summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* don't evict messages from RAM when inserting them into pending_ackbug25311Matthias Radestock2012-11-231-10/+7
|
* 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
|\
| * Explainbug23625Simon 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 foldbug25314Emile Joubert2012-11-225-11/+12
| |/ / / / / /
| * | | | | | Merged stableEmile Joubert2012-11-228-72/+129
| |\ \ \ \ \ \
| | * \ \ \ \ \ 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 dropbug25302Emile 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
| | | | | | | | | |
| | | * | | | | | | introduce bq:drop/2 and use it in slaves to prevent msg fetchingMatthias Radestock2012-11-204-28/+49
| | | |/ / / / / / | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - 'drop' is the same as 'fetch' except it doesn't read messages from the msg store - slaves never fetch messages, they only drop them - technically, mq_master:drop doesn't need to exist, since 'drop' is only invoked by the slaves, but we provide an implementation for completeness.
| | | * | | | | | format mq slave message queueMatthias Radestock2012-11-191-1/+3
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | to facilitate debugging
| | | * | | | | | cosmeticMatthias Radestock2012-11-191-3/+3
| | | | | | | | |
| | | * | | | | | optimise "no messages dead-lettered during expiry" caseMatthias Radestock2012-11-191-2/+4
| | | | | | | | |
| | | * | | | | | Added tag rabbitmq_v3_0_0 for changeset b7a660ce4855Simon MacMullen2012-11-190-0/+0
| | | | | | | | |
* | | | | | | | | Merge bug25305Simon MacMullen2012-11-223-13/+24
|\ \ \ \ \ \ \ \ \ | |/ / / / / / / /
| * | | | | | | | Merged bug25306Emile Joubert2012-11-222-11/+20
| |\ \ \ \ \ \ \ \ | | |/ / / / / / / | |/| | | | | | |
| | * | | | | | | leave the ram_msg_count unchanged in BQ:foldbug25306Matthias 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
| | | | | | | | |
| * | | | | | | | merge bug25301 into stableMatthias Radestock2012-11-221-2/+4
| |\ \ \ \ \ \ \ \ | | |/ / / / / / / | |/| | | | | | |
| | * | | | | | | branch from stable, expire messages eagerlybug25301Tim Watson2012-11-211-2/+4
| |/ / / / / / /
* | | | | | | | ack unroutable dead-lettered messages straight awaybug25305Matthias Radestock2012-11-201-12/+18
|/ / / / / / / | | | | | | | | | | | | | | | | | | | | | thus plugging a leak
* | | | | | | create 'stable' branchMatthias Radestock2012-11-200-0/+0
|/ / / / / /
* | | | | | Changelogs for 3.0.0rabbitmq_v3_0_0Simon MacMullen2012-11-192-0/+9
|/ / / / /
* | | | | merge bug25297 into defaultMatthias Radestock2012-11-161-1/+1
|\ \ \ \ \ | |_|_|_|/ |/| | | |
| * | | | plug leakbug25297Matthias Radestock2012-11-161-1/+1
|/ / / /
* | | | fixmeMatthias Radestock2012-11-161-1/+2
| | | |
* | | | refactor stop_laterMatthias Radestock2012-11-161-18/+15
| | | | | | | | | | | | | | | | | | | | | | | | - s/stop_later/stop - since it's always called with Reason=normal there is no point passing that around / storing it
* | | | Merge bug25295Simon MacMullen2012-11-161-4/+5
|\ \ \ \
| * | | | always monitor queues from which we are (possibly) delivering messagesbug25295Matthias Radestock2012-11-151-4/+5
| |/ / / | | | | | | | | | | | | | | | | so that stats associated with these queues are cleared out from the channel's process dictionary when these queues disappear.
* | | | refactor: extract some helpersMatthias Radestock2012-11-161-14/+16
| | | | | | | | | | | | | | | | | | | | ...to make it abundantly clear which queue operations amount to an ack/requeue.
View Lorry Controller Status