summaryrefslogtreecommitdiff
path: root/src
Commit message (Expand)AuthorAgeFilesLines
* Remove ?CREDIT_CPU_BOUND and have /1 versions of ack and send instead.Simon MacMullen2012-01-244-5/+13
* More doc.Simon MacMullen2012-01-201-0/+3
* More credit for the queue -> msg_store case.Simon MacMullen2012-01-195-21/+20
* Correct comment and use spawn_linkSimon MacMullen2012-01-181-12/+13
* Ignore bump_credit messages in rabbit_tests.Simon MacMullen2012-01-181-8/+19
* merge headsMatthias Radestock2012-01-171-0/+4
|\
| * Flow control: queue slave -> msg_store.Simon MacMullen2012-01-171-0/+4
* | two flavours of 'write'Matthias Radestock2012-01-172-14/+28
* | more sensible arg orderMatthias Radestock2012-01-171-13/+13
|/
* Don't pass the client pid in for write.Simon MacMullen2012-01-171-3/+5
* Flow control: vq -> msg_store.Simon MacMullen2012-01-172-17/+30
* 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 rabbit_router:deliver into rabbit_amqqueue:deliverMatthias Radestock2012-01-167-92/+67
| * Revert b03fe604af24. Not enough sleep.Simon MacMullen2012-01-131-2/+2
| * Emit the timeout in the stats event.Simon 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-132-64/+42
* | merge default into bug24664Matthias Radestock2012-01-133-51/+51
|\ \ | |/
| * a little bit of refactoring on the readerMatthias Radestock2012-01-121-35/+23
| * oopsMatthias Radestock2012-01-121-3/+5
| * 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-102-14/+18
| * 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-122-5/+23
* | 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