summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* HiPE credit_flow - this gets MCM -x 1 -y 1 -i 5 from 29.5kHz to 30.8kHz.bug24664Simon MacMullen2012-01-181-1/+1
* For direct client we *do* want the reader pid (amqp_channel) rather than the ...Simon MacMullen2012-01-181-2/+3
* make flow control explicit in the channel APIMatthias Radestock2012-01-162-9/+14
* simplify publisher monitoring codeMatthias Radestock2012-01-161-28/+11
* only monitor publishers when they publish with flow controlMatthias Radestock2012-01-161-2/+2
* provide two flavours of rabbit_amqqueue:deliverMatthias Radestock2012-01-164-44/+56
* merge default into bug24664Matthias Radestock2012-01-167-92/+67
|\
| * Merge bug24681Simon MacMullen2012-01-160-0/+0
| |\
| * | merge rabbit_router:deliver into rabbit_amqqueue:deliverbug24681Matthias Radestock2012-01-167-92/+67
| |/
| * Revert b03fe604af24. Not enough sleep.Simon MacMullen2012-01-131-2/+2
| * Merge bug 24673Simon MacMullen2012-01-130-0/+0
| |\
| * | Emit the timeout in the stats event.bug24673Simon MacMullen2012-01-131-2/+2
| |/
* | it's really not worthwhile exporting process_channel_frameMatthias Radestock2012-01-161-21/+5
* | do not hard-wire the channel interaction into process_channel_frameMatthias Radestock2012-01-131-12/+20
* | Reinstate a bit of code that accidentally got nuked in 9a87718c74df.Simon MacMullen2012-01-131-2/+3
* | sender_down / receiver_down -> peer_down.Simon MacMullen2012-01-135-14/+11
* | Merge heads of bug 24664 again.Simon MacMullen2012-01-135-13/+13
|\ \
| * | rabbit_flow -> credit_flowSimon MacMullen2012-01-135-13/+13
* | | cosmetic(ish)Matthias Radestock2012-01-131-5/+5
|/ /
* | Merge heads of bug 24664Simon MacMullen2012-01-131-21/+23
|\ \
| * | update 'last_blocked_by' while blockedMatthias Radestock2012-01-131-21/+23
* | | Move rabbit_flow:send invocation from router into channel; monitor all queues...Simon MacMullen2012-01-132-71/+60
|/ /
* | apply flow control to content bearing methods onlyMatthias Radestock2012-01-132-3/+5
* | unblock, if possible, when channels disappearMatthias Radestock2012-01-131-4/+5
* | simplified running<->blocking/blocked state transitionsMatthias Radestock2012-01-133-80/+55
* | merge default into bug24664Matthias Radestock2012-01-137-57/+58
|\ \ | |/
| * a little bit of refactoring on the readerMatthias Radestock2012-01-121-35/+23
| * Merge bug24636 moreEmile Joubert2012-01-121-3/+5
| |\
| | * oopsbug24636Matthias Radestock2012-01-121-3/+5
| * | Merged bug24636 into defaultEmile Joubert2012-01-123-3/+3
| |\ \ | | |/ | |/|
| | * Merged bug24665 into defaultEmile Joubert2012-01-101-2/+1
| | |\
| | * | don't start cpu_supbug24617Matthias Radestock2012-01-093-3/+3
| * | | rename fd stats items to make their meaning more obviousMatthias Radestock2012-01-112-7/+7
| * | | cosmeticMatthias Radestock2012-01-101-11/+11
| * | | include a few more pieces of info in rabbit:statusMatthias Radestock2012-01-101-1/+8
| * | | include fd info in rabbit:status()Matthias Radestock2012-01-103-17/+22
| | |/ | |/|
| * | cosmetic: remove nonsensical commentMatthias Radestock2012-01-101-2/+1
| |/
* | Attempt to show information about blocking due to memory alarm and flow contr...Simon MacMullen2012-01-123-7/+45
* | Flow control: channel -> queue slaveSimon MacMullen2012-01-121-3/+5
* | Avert eyesore.Simon MacMullen2012-01-121-5/+3
* | Have queues monitor publishing channels so we can remove them from the flow d...Simon MacMullen2012-01-122-3/+41
* | Rename bump/1 to handle_bump_msg/1, add a comment and specs.Simon MacMullen2012-01-123-6/+31
* | Matthias points out that we don't need to remember that a pid has gone away: ...Simon MacMullen2012-01-121-8/+2
* | Improve book-keeping - now we treat a receiver having gone away as granting u...Simon MacMullen2012-01-123-19/+19
* | Allow one sending process to be blocked by more than one receiving process si...Simon MacMullen2012-01-121-8/+14
* | Ahem++Simon MacMullen2012-01-121-2/+2
* | Refactor / tidy, and sneakily fix an off-by-one error (ahem).Simon MacMullen2012-01-121-20/+13
* | Oops.Simon MacMullen2012-01-121-1/+1
* | Actually we should use conn_pid here since that goes to the same place for ne...Simon MacMullen2012-01-111-2/+2
* | Get the channel to "block" by not issuing any more credit, rather than callin...Simon MacMullen2012-01-115-47/+54