| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Rename states to hopefully be clearer; add more comments. | Simon MacMullen | 2013-04-17 | 1 | -12/+42 |
| | | |||||
| * | First pass at splitting all the autoheal stuff out into a separate module. | Simon MacMullen | 2013-04-17 | 2 | -188/+223 |
| | | |||||
| * | Remove io:formats | Simon MacMullen | 2013-04-08 | 1 | -2/+0 |
| | | |||||
| * | Deal with partial partitions. | Simon MacMullen | 2013-04-08 | 1 | -13/+19 |
| | | |||||
| * | Umm, order by *best* partition first! | Simon MacMullen | 2013-04-08 | 1 | -2/+3 |
| | | |||||
| * | WIP commit: start to deal with non-consistent partitions. all_partitions/1 ↵ | Simon MacMullen | 2013-03-28 | 1 | -16/+54 |
| | | | | | needs attention though. | ||||
| * | Merge default | Simon MacMullen | 2013-03-27 | 1 | -9/+161 |
| |\ | |||||
| | * | Cosmetic | Simon MacMullen | 2013-03-27 | 1 | -1/+2 |
| | | | |||||
| | * | Merge in default, add a touch more logging, and don't restart autoheal if ↵ | Simon MacMullen | 2013-03-27 | 1 | -19/+57 |
| | |\ | | | | | | | | | | it's already started. | ||||
| | * | | Simplistic way of selecting a winner: order by the number of connections, ↵ | Simon MacMullen | 2013-03-26 | 1 | -19/+28 |
| | | | | | | | | | | | | | then the size of the partition. | ||||
| | * | | Figure out a global view of partitions. | Simon MacMullen | 2013-03-26 | 1 | -1/+21 |
| | | | | |||||
| | * | | Add some logging | Simon MacMullen | 2013-03-26 | 1 | -3/+11 |
| | | | | |||||
| | * | | merge default | Simon MacMullen | 2013-03-26 | 20 | -398/+733 |
| | |\ \ | |||||
| | * | | | First pass at autohealing. | Simon MacMullen | 2013-03-19 | 1 | -11/+121 |
| | | | | | |||||
| * | | | | Merged bug25499 into default | Emile Joubert | 2013-03-27 | 2 | -2/+14 |
| |\ \ \ \ | |_|_|/ |/| | | | |||||
| | * | | | Check if the rabbit process is running and thus avoid deadlocks in the ↵ | Simon MacMullen | 2013-03-22 | 2 | -2/+11 |
| | | | | | | | | | | | | | | | | | application controller. | ||||
| | * | | | Merge in default. | Simon MacMullen | 2013-03-22 | 12 | -306/+436 |
| | |\ \ \ | |||||
| * | \ \ \ | Merged bug25491 into default | Emile Joubert | 2013-03-27 | 19 | -397/+732 |
| |\ \ \ \ \ | | |_|_|/ | |/| | | | |||||
| | * | | | | Merge bug24114 into default | Emile Joubert | 2013-03-26 | 0 | -0/+0 |
| | |\ \ \ \ | |||||
| | * \ \ \ \ | Merged default into bug24114 | Emile Joubert | 2013-03-25 | 49 | -743/+1583 |
| | |\ \ \ \ \ | | |/ / / / | |||||
| | | * | | | | merge bug23749 into default | Matthias Radestock | 2013-03-22 | 5 | -62/+255 |
| | | |\ \ \ \ | | | |_|/ / | | |/| | | | |||||
| | | | * | | | Update essay for credit (and fix a few typos I couldn't be bothered to ↵ | Simon MacMullen | 2013-03-22 | 1 | -12/+26 |
| | | | | | | | | | | | | | | | | | | | | | | | | | separate out). | ||||
| | | | * | | | Move serial arithmetic out of the broker. | Simon MacMullen | 2013-03-22 | 2 | -75/+0 |
| | | | | | | | |||||
| | | | * | | | get rid of unused imports | Matthias Radestock | 2013-03-21 | 1 | -2/+0 |
| | | | | | | | |||||
| | | | * | | | fix typo | Matthias Radestock | 2013-03-21 | 1 | -1/+1 |
| | | | | | | | |||||
| | | | * | | | cosmetic(ish) | Matthias Radestock | 2013-03-21 | 2 | -14/+11 |
| | | | | | | | |||||
| | | | * | | | re-introduce state-transition optimisation for possibly_unblock | Matthias Radestock | 2013-03-21 | 1 | -23/+27 |
| | | | | | | | |||||
| | | | * | | | Merge in default | Simon MacMullen | 2013-03-21 | 9 | -42/+81 |
| | | | |\ \ \ | |||||
| | | | * \ \ \ | Merge bug23749+bug25461 into bug23749 | Simon MacMullen | 2013-03-21 | 0 | -0/+0 |
| | | | |\ \ \ \ | |||||
| | | | * | | | | | suspended =/= has run out of credit. | Simon MacMullen | 2013-03-21 | 1 | -1/+1 |
| | | | | | | | | | |||||
| | | | * | | | | | Cosmetic, reduce distance to bug25461, remove dead comment | Simon MacMullen | 2013-03-21 | 2 | -16/+11 |
| | | | | | | | | | |||||
| | | | * | | | | | oops | Simon MacMullen | 2013-03-21 | 1 | -1/+1 |
| | | | | | | | | | |||||
| | | | * | | | | | Merge the two can_sends and tidy up. | Simon MacMullen | 2013-03-21 | 2 | -42/+25 |
| | | | | | | | | | |||||
| | | | * | | | | | First attempt at merging these two bugs; this compiles at least. | Simon MacMullen | 2013-03-20 | 9 | -50/+362 |
| | | | |\ \ \ \ \ | | | | |/ / / / | |||||
| | | | | * | | | | Merge in default | Simon MacMullen | 2013-03-20 | 6 | -53/+322 |
| | | | | |\ \ \ \ | |||||
| | | | | | * \ \ \ | merge default into bug23749 | Matthias Radestock | 2013-02-21 | 0 | -0/+0 |
| | | | | | |\ \ \ \ | |||||
| | | | | | * | | | | | Well, that was embarassing. | Simon MacMullen | 2013-02-21 | 1 | -1/+1 |
| | | | | | | | | | | | |||||
| | | | | | * | | | | | simplifying refactor | Matthias Radestock | 2013-02-21 | 1 | -12/+12 |
| | | | | | | | | | | | |||||
| | | | | | * | | | | | Correct use of gb_trees APIs... | Simon MacMullen | 2013-02-21 | 1 | -12/+6 |
| | | | | | | | | | | | |||||
| | | | | | * | | | | | Oops | Simon MacMullen | 2013-02-21 | 1 | -14/+7 |
| | | | | | | | | | | | |||||
| | | | | | * | | | | | Use gb_trees rather than dict for performance. | Simon MacMullen | 2013-02-21 | 1 | -15/+21 |
| | | | | | | | | | | | |||||
| | | | | | * | | | | | Remove blocked_ctags, and a few knock-on simplifications. | Simon MacMullen | 2013-02-21 | 2 | -39/+24 |
| | | | | | | | | | | | |||||
| | | | | | * | | | | | simplify queue's basic_consume handler | Matthias Radestock | 2013-02-21 | 1 | -15/+7 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - the call to update_ch_record in the is_ch_blocked(C1) == false branch was superfluos since the preceding update_consumer_count calls update_ch_record - all the checking whether the channel is blocked, and associated branching was just an optimisation. And not a particularly important one, since a) the "a new consumer comes along while its channel is blocked" case is hardly on the critical path, and b) exactly the same check is performed as part of run_message_queue (in deliver_msg_to_consumer/3). So get rid of it. - the is_empty & send_drained logic can be invoked earlier, which allows us to use the #cr we have rather than looking it up again. We can do this since the only case we need to catch here is that of a consumer coming along while the queue is empty already. If it becomes empty as part of run_message_queue then send_drained will be invoked in 'fetch'. | ||||
| | | | | | * | | | | | merge default into bug23749 | Matthias Radestock | 2013-02-20 | 1 | -1/+1 |
| | | | | | |\ \ \ \ \ | |||||
| | | | | | * | | | | | | optimise possibly_unblock | Matthias Radestock | 2013-02-20 | 1 | -15/+18 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | when the channel is blocked there is no point going through the expensive consumer re-partitioning | ||||
| | | | | | * | | | | | | refactor | Matthias Radestock | 2013-02-20 | 1 | -9/+6 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | it's convenient for callers to have maybe_send_drained thread through the state | ||||
| | | | | | * | | | | | | cosmetic - reduce distance to 'default' | Matthias Radestock | 2013-02-20 | 1 | -20/+17 |
| | | | | | | | | | | | | |||||
| | | | | | * | | | | | | oops | Matthias Radestock | 2013-02-20 | 1 | -1/+1 |
| | | | | | | | | | | | | |||||
| | | | | | * | | | | | | cosmetic | Matthias Radestock | 2013-02-20 | 1 | -14/+14 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | move functions to a better place | ||||
| | | | | | * | | | | | | merge default into bug23749 | Matthias Radestock | 2013-02-20 | 1 | -2/+2 |
| | | | | | |\ \ \ \ \ \ | |||||
