| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Remove silly race. | Simon MacMullen | 2014-08-21 | 1 | -5/+12 |
| | | |||||
| * | Merge in default | Simon MacMullen | 2014-08-20 | 5 | -15/+185 |
| |\ | |||||
| | * | Merge bug26353 | Simon MacMullen | 2014-08-20 | 0 | -0/+0 |
| | |\ | |||||
| | * | | Those diagnostics are actually a bit dubious, they insert quite a delay and ↵ | Simon MacMullen | 2014-08-20 | 1 | -2/+1 |
| | |/ | | | | | | | aren't really designed to be logged. | ||||
| | * | call/2 -> call/3. | Simon MacMullen | 2014-08-20 | 1 | -1/+2 |
| | | | |||||
| | * | MErge bug25813 | Simon MacMullen | 2014-08-20 | 10 | -84/+111 |
| | |\ | |||||
| | | * | stable to default | Simon MacMullen | 2014-08-20 | 55 | -833/+2145 |
| | | |\ | |||||
| | | * \ | Merge bug26354 | Simon MacMullen | 2014-08-20 | 1 | -1/+1 |
| | | |\ \ | |||||
| | | | * | | Get the message format right for this case too. | Simon MacMullen | 2014-08-20 | 1 | -1/+1 |
| | | |/ / | |||||
| | * | | | Fix a race. | Simon MacMullen | 2014-08-20 | 1 | -1/+7 |
| | | | | | |||||
| | * | | | Return 1 consumer. | Simon MacMullen | 2014-08-18 | 1 | -2/+3 |
| | | | | | |||||
| | * | | | Implement declaration. | Simon MacMullen | 2014-08-18 | 1 | -2/+40 |
| | | | | | |||||
| | * | | | Prevent malicious channels from sending messages to arbitrary processes with ↵ | Simon MacMullen | 2014-08-18 | 2 | -3/+26 |
| | | | | | | | | | | | | | | | | | this mechanism. | ||||
| | * | | | We'll just document that mandatory doesn't work. | Simon MacMullen | 2014-08-18 | 1 | -1/+0 |
| | | | | | |||||
| | * | | | base64 encoding is expensive enough to make it worth precalculating the ↵ | Simon MacMullen | 2014-08-15 | 1 | -12/+14 |
| | | | | | | | | | | | | | | | | | encoded pid just in case we want to reuse it. | ||||
| | * | | | Remove support for decorators to modify routing for the default exchange; it ↵ | Simon MacMullen | 2014-08-14 | 1 | -6/+5 |
| | | | | | | | | | | | | | | | | | doesn't make a ton of sense. Also no longer describe this as an optimisation since some of it is more than that. | ||||
| | * | | | We don't need to worry about confirms, they will get sent. Change to a soft ↵ | Simon MacMullen | 2014-08-14 | 1 | -4/+6 |
| | | | | | | | | | | | | | | | | | error for new errors. | ||||
| | * | | | Support cancel. | Simon MacMullen | 2014-08-14 | 1 | -1/+9 |
| | | | | | |||||
| | * | | | Unused var. | Simon MacMullen | 2014-08-14 | 1 | -1/+1 |
| | | | | | |||||
| | * | | | Security hole-- | Simon MacMullen | 2014-08-14 | 2 | -21/+25 |
| | | | | | |||||
| | * | | | Rename this thing for consistency and also RabbitMQ-specificness. | Simon MacMullen | 2014-08-14 | 2 | -6/+7 |
| | | | | | |||||
| | * | | | Prototype of fast RPC replies. | Simon MacMullen | 2014-08-13 | 2 | -5/+92 |
| | | | | | |||||
| * | | | | Cosmetic | Simon MacMullen | 2014-08-20 | 1 | -2/+1 |
| | | | | | |||||
| * | | | | Make this test make sense for the new regime. There will of course need to ↵ | Simon MacMullen | 2014-08-20 | 1 | -8/+4 |
| | | | | | | | | | | | | | | | | | be lots of new tests but at least this passes now. | ||||
| * | | | | Switch to making our restart decisions based on explicitly determining ↵ | Simon MacMullen | 2014-08-20 | 4 | -96/+78 |
| | | | | | | | | | | | | | | | | | whether we are starting for the first time or not. This is not very OTPish but it turns out to be necessary: there's no way to distinguish between losing a race to declare, starting a new slave, and restarting to a new slave otherwise. As an upside this code is shorter and more obviously correct (to me at least). | ||||
| * | | | | Allow crashing queue processes to come back as slaves if that's what we need. | Simon MacMullen | 2014-08-20 | 2 | -1/+10 |
| | | | | | |||||
| * | | | | This is perhaps more honest; if the queue was transient we will not recover ↵ | Simon MacMullen | 2014-08-20 | 1 | -2/+1 |
| | | | | | | | | | | | | | | | | | anything and if the queue is mirrored we will restart a slave and then also not recover anything. | ||||
| * | | | | Allow transient queues to recover. | Simon MacMullen | 2014-08-20 | 1 | -8/+11 |
| | | | | | |||||
| * | | | | We handled that case in 359da524140b | Simon MacMullen | 2014-08-20 | 1 | -1/+0 |
| | | | | | |||||
| * | | | | Add an intermediate supervisor so that if a queue exceeds its restart limit ↵ | Simon MacMullen | 2014-08-20 | 4 | -26/+73 |
| | | | | | | | | | | | | | | | | | we don't bring the whole server down! | ||||
| * | | | | Log that we recovered. Also store updated pid in Mnesia! | Simon MacMullen | 2014-08-19 | 1 | -6/+14 |
| | | | | | |||||
| * | | | | Allow crashing queues to recover themselves. | Simon MacMullen | 2014-08-19 | 3 | -36/+48 |
| | | | | | |||||
| * | | | | Remove a pointless check here - we will check from within an Mnesia tx in ↵ | Simon MacMullen | 2014-08-19 | 1 | -24/+13 |
| | | | | | | | | | | | | | | | | | rabbit_mirror_queue_slave:init_it/4 anyway, which makes much more sense (and it will make little sense to check at slave start if we can restart a crashed slave). | ||||
| * | | | | Another copy of the master_in_recovery check. Not sure that's very elegant, ↵ | Simon MacMullen | 2014-08-19 | 4 | -24/+50 |
| | | | | | | | | | | | | | | | | | but I don't think we have much choice. | ||||
| * | | | | Roll slave startup into the new mechanism. | Simon MacMullen | 2014-08-19 | 9 | -105/+65 |
| | | | | | |||||
| * | | | | Various spec-ish fixes. | Simon MacMullen | 2014-08-19 | 3 | -9/+5 |
| | | | | | |||||
| * | | | | First step along the way to queue restarts. Create a "prequeue" module whose ↵ | Simon MacMullen | 2014-08-19 | 4 | -112/+179 |
| | |_|/ |/| | | | | | | | | job it is to decide how to proceed, and then have the supervisor start that. At the moment we only handle rabbit_amqqueue_process startup through this, but that will change. Also move the tx which decides whether we successfully declared the queue or not into the first part of the queue startup (before we call into the queue) since in future it will be needed for other things. | ||||
| * | | | stable to default | Simon MacMullen | 2014-08-18 | 55 | -833/+2145 |
| |\ \ \ | |_|/ |/| | | |||||
| | * | | stable to default | Simon MacMullen | 2014-08-15 | 1 | -0/+9 |
| | |\ \ | |||||
| | * \ \ | Merge bug26345 | Simon MacMullen | 2014-08-14 | 4 | -39/+38 |
| | |\ \ \ | |||||
| | | * | | | Further simplify logging. Get rabbit_log to figure out whether the group ↵ | Simon MacMullen | 2014-08-14 | 4 | -39/+38 |
| | |/ / / | | | | | | | | | | | | | leader switcheroo is needed, rather than leaving it up to the caller. We now have one logging API. Woot! | ||||
| | * | | | Merge bug26306 | Simon MacMullen | 2014-08-13 | 28 | -291/+518 |
| | |\ \ \ | |||||
| | | * \ \ | Merge bug26337 (again) | Simon MacMullen | 2014-08-13 | 11 | -79/+125 |
| | | |\ \ \ | | | | |/ | | | |/| | |||||
| | | | * | | stable to default | Simon MacMullen | 2014-08-13 | 54 | -800/+2107 |
| | | | |\ \ | |||||
| | | | | * | | For some reason post bug 26337 we need to make sure this gets logged in the ↵ | Simon MacMullen | 2014-08-12 | 1 | -1/+1 |
| | | | | | | | | | | | | | | | | | | | | | | | | | server and not though rabbitmqctl. | ||||
| | | | | * | | Merge bug25884 | Simon MacMullen | 2014-08-12 | 1 | -2/+2 |
| | | | | |\ \ | |||||
| | | | | | * | | Actually maybe that's clearer. | Simon MacMullen | 2014-08-12 | 1 | -2/+2 |
| | | | | | | | | |||||
| | | | | * | | | Rename | Simon MacMullen | 2014-08-12 | 3 | -7/+6 |
| | | | | | | | | |||||
| | | | | * | | | And max-length is implemented in terms of messages_ready, so do the same for ↵ | Simon MacMullen | 2014-08-12 | 1 | -1/+1 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | max-bytes | ||||
| | | | | * | | | Merge in default | Simon MacMullen | 2014-08-12 | 3 | -31/+54 |
| | | | | |\ \ \ | | | | | |/ / | |||||
 |
index : delta/rabbitmq-server-git.git | |
| github.com: rabbitmq/rabbitmq-server.git |
| summaryrefslogtreecommitdiff |