summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* No.Simon MacMullen2013-01-141-1/+0
|
* Merge defaultSimon MacMullen2013-01-148-47/+308
|\
| * Improve workingness further. We now should be handling multiple blocks for ↵Simon MacMullen2013-01-142-67/+76
| | | | | | | | different reasons correctly.
| * Right. There were a lot of bugs. This fixes most of them. One major ↵Simon MacMullen2013-01-113-46/+55
| | | | | | | | confusion was that both the adapter and the credit impl were trying to normalise against remote count, now it's just the adapter. Also when we get credit we need to unblock. Also there were various things that assumed our local credit could not go negative - well it can and we just need to wait for it to be positive again.
| * Second attempt at moving credit into the queue. This time we pretend the ↵Simon MacMullen2013-01-104-149/+155
| | | | | | | | | | | | limiter is still doing the work. While testing this I note that the credit calculation is crazy when testing with Proton. But it was just as bad before, so let's commit.
| * consumer_mapping changed since this branch was last worked on.Simon MacMullen2013-01-101-5/+5
| |
| * I added that clause early in the history of this bug and it's always been ↵Simon MacMullen2013-01-091-2/+1
| | | | | | | | wrong. The semantics of that line are just "set is_limit_active to false if the limiter is disabled", is_blocked (which only deals with the channel.flow case anyway) has nothing to do with it.
| * Stub for 1.0 support.Simon MacMullen2013-01-082-1/+42
| |
| * Merge in default.Simon MacMullen2013-01-075-31/+228
| |\
| | * ResurrectSimon MacMullen2013-01-071-0/+1
| | |
| | * And correct specsMichael Bridgen2011-08-241-2/+5
| | |
| | * Rectify some poor conflict resolution choices.Michael Bridgen2011-08-242-8/+14
| | |
| | * Merge in default. Many conflicts unhappy faceMichael Bridgen2011-08-2331-519/+2196
| | |\
| | * \ Merge in defaultSimon MacMullen2011-08-035-41/+235
| | |\ \
| | | * | Remove some dead TODOs from when this was very young.Simon MacMullen2011-07-251-10/+0
| | | | |
| | | * | Face down, nine-edge first.Simon MacMullen2011-07-252-4/+9
| | | | |
| | | * | ...and unbreak.Simon MacMullen2011-07-251-7/+5
| | | | |
| | | * | Merge in default.Simon MacMullen2011-07-22104-4654/+8964
| | | |\ \
| | | * \ \ Merge in defaultSimon MacMullen2011-02-185-41/+242
| | | |\ \ \
| | | | * | | Use serial number arithmetic for creditMichael Bridgen2011-02-113-7/+85
| | | | | | |
| | | | * | | Separate calculating the credit from updating the state, and do it properly.Michael Bridgen2011-02-091-12/+22
| | | | | | |
| | | | * | | Remove io:formatSimon MacMullen2011-02-091-1/+0
| | | | | | |
| | | | * | | Use a base for basic.credit, to account for messages that have been ↵Michael Bridgen2011-02-092-24/+40
| | | | | | | | | | | | | | | | | | | | | | | | | | | | delivered but not received by the client
| | | | * | | Remove redundant fields from credit-ok.Simon MacMullen2011-02-031-4/+1
| | | | | | |
| | | | * | | Change mind again on how this should work - have a synchronous reply method, ↵Simon MacMullen2011-02-031-4/+4
| | | | | | | | | | | | | | | | | | | | | | | | | | | | and an async method for spontaneous notification.
| | | | * | | Send a credit-state when magical draining happens.Simon MacMullen2011-02-022-5/+15
| | | | | | |
| | | | * | | Return a basic.credit-state after receiving a basic.credit.Simon MacMullen2011-02-021-1/+17
| | | | | | |
| | | | * | | Credit needs to be per ctag.Simon MacMullen2011-02-023-74/+127
| | | | | | |
| | | | * | | Support drain (probably in a rather inefficient way).Simon MacMullen2011-02-012-17/+22
| | | | | | |
| | | | * | | Beginning of channel.credit support. Tests pass, except for drain=true.Simon MacMullen2011-02-013-43/+60
| | | | | | |
* | | | | | | oops; nuke unused varMatthias Radestock2013-01-121-1/+1
| | | | | | |
* | | | | | | extract a vq helper fun for constructing a msg_statusMatthias Radestock2013-01-121-21/+24
| | | | | | |
* | | | | | | cosmeticMatthias Radestock2013-01-121-6/+6
| | | | | | |
* | | | | | | unmodalise vq:read_msgMatthias Radestock2013-01-121-27/+27
| | | | | | |
* | | | | | | cosmetic renameMatthias Radestock2013-01-101-9/+8
| | | | | | |
* | | | | | | merge bug25345 into defaultMatthias Radestock2013-01-094-198/+236
|\ \ \ \ \ \ \
| * \ \ \ \ \ \ merge headsMatthias Radestock2013-01-081-11/+10
| |\ \ \ \ \ \ \
| | * \ \ \ \ \ \ merge stable into defaultMatthias Radestock2013-01-0827-1014/+1627
| | |\ \ \ \ \ \ \
| | | * \ \ \ \ \ \ merge stable into defaultMatthias Radestock2013-01-081-7/+10
| | | |\ \ \ \ \ \ \
| | * | \ \ \ \ \ \ \ merge bug25353 into stableMatthias Radestock2013-01-081-1/+1
| | |\ \ \ \ \ \ \ \ \ | | | | |/ / / / / / / | | | |/| | | | | | |
| | | * | | | | | | | merge bug25353 into stableMatthias Radestock2013-01-081-1/+1
| | | |\ \ \ \ \ \ \ \
| | * | | | | | | | | | tidy upMatthias Radestock2013-01-081-4/+0
| | |/ / / / / / / / /
| | * | | | | | | | | copy change from rabbit_amqqueue_process to slaveMatthias Radestock2013-01-081-7/+9
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | for consistency
| * | | | | | | | | | Merged bug25327Emile Joubert2013-01-081-68/+65
| |\ \ \ \ \ \ \ \ \ \ | | |_|_|/ / / / / / / | |/| | | | | | | | |
| | * | | | | | | | | merge default into bug25327Matthias Radestock2013-01-0417-374/+745
| | |\ \ \ \ \ \ \ \ \
| | * | | | | | | | | | some more control flow abstractionMatthias Radestock2013-01-041-26/+21
| | | | | | | | | | | |
| | * | | | | | | | | | merge bug25372 into bug25327Matthias Radestock2013-01-021-64/+66
| | |\ \ \ \ \ \ \ \ \ \
| | | * | | | | | | | | | refactor: extract dead lettering commonalityMatthias Radestock2013-01-011-45/+35
| | | | | | | | | | | | |
| | | * | | | | | | | | | don't send dead-lettered messages to self() during 'reject' handlingMatthias Radestock2013-01-011-36/+33
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | since they all end up in the mailbox, consuming memory
| | | * | | | | | | | | | renameMatthias Radestock2013-01-011-7/+7
| | | | | | | | | | | | |