summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Since we should not normally see warnings now, let's zhuzh them up.Simon MacMullen2011-05-231-1/+2
|
* Rename variableSimon MacMullen2011-05-231-2/+2
|
* Introduce variableSimon MacMullen2011-05-231-2/+4
|
* Exclude mochiweb from the xref check.Simon MacMullen2011-05-231-1/+3
|
* merge bug24118 into defaultMatthias Radestock2011-05-205-43/+47
|\
| * merge bug24117 into defaultMatthias Radestock2011-05-195-32/+34
| |\
| | * BQ:idle_timeout => BQ:timeoutMatthew Sackman2011-05-195-12/+12
| | |
| | * whitespaceMatthew Sackman2011-05-181-1/+0
| | |
| | * Well it's no shorter, but it closer matches the originalMatthew Sackman2011-05-181-14/+14
| | |
| | * BQ:needs_idle_timeout :: State -> Bool ==> BQ:needs_timeout :: State -> ↵Matthew Sackman2011-05-185-26/+29
| | | | | | | | | | | | (false | idle | timed); which better reflects the different needs
| * | simplifyMatthias Radestock2011-05-191-21/+14
| | |
| * | Merge bug24116 into defaultRob Harrop2011-05-191-8/+17
| |\ \ | | |/ | |/|
| | * And now, after testing it, actually make it work by correcting one of the ↵Matthew Sackman2011-05-181-10/+15
| | | | | | | | | | | | counters...
| | * Do not read the msg surviving dropwhile1Matthew Sackman2011-05-181-8/+12
| |/
* | some more inliningMatthias Radestock2011-05-191-21/+18
| |
* | cosmeticMatthias Radestock2011-05-191-17/+17
| |
* | fix error handling and construct xname on init rather than every messageMatthias Radestock2011-05-191-14/+16
| | | | | | | | | | | | | | | | | | | | | | | | I have no idea why that 'catch' was there. There is nothing to go wrong during publish except the exchange may not be found. Which the 'catch' wasn't catching since that is just an ordinary {error, not_found} return. Cue explosion. So now we handle that and print a nice error message. Also, there is no point constructing the exchange name for every message; doing that once, on init, is enough. That has the further advantage that now the implementation matches the spec (rabbit_exchange:name() is a qualified name, not a binary).
* | inliningMatthias Radestock2011-05-191-32/+25
| |
* | sometimes clarity trumps performanceMatthias Radestock2011-05-191-9/+4
| | | | | | | | | | I can't actually detect a difference in performance here, though I'm sure the new code is slower than the old one.
* | funs are too expensive here. Ouch.Simon MacMullen2011-05-191-14/+13
| |
* | Further refactoringSimon MacMullen2011-05-192-21/+17
| |
* | Refactor.Simon MacMullen2011-05-191-23/+22
| |
* | Slightly tighter specs, tidy imports.Simon MacMullen2011-05-192-4/+5
| |
* | Fold refresh_config in with (un)set_env, abstract into rabbit.Simon MacMullen2011-05-193-15/+19
| |
* | RenameSimon MacMullen2011-05-192-4/+4
| |
* | rabbitmqctl refresh_channel_configSimon MacMullen2011-05-193-1/+22
| |
* | Refactor a bit and push more work "below" checking the state. This reduces ↵Simon MacMullen2011-05-191-17/+22
| | | | | | | | the cost from 2.3% to 1.1%.
* | Only check the application environment when a channel starts up.Simon MacMullen2011-05-182-21/+34
|/
* merge bug24004 into defaultMatthias Radestock2011-05-1724-227/+501
|\
| * merge bug23939 into defaultMatthias Radestock2011-05-1611-127/+338
| |\
| | * Merging bug23899 to defaultMatthew Sackman2011-05-122-23/+10
| | |\
| | | * I cannot BELIEVE that anyone was so UNPROFFESSIONNAL as to OMIT these TYPES.Simon MacMullen2011-05-031-2/+2
| | | |
| | | * Remove dead code.Simon MacMullen2011-05-031-14/+1
| | | |
| | | * Separate out different types for network and direct connections, don't check ↵Simon MacMullen2011-05-031-8/+8
| | | | | | | | | | | | | | | | the password for direct ones.
| | * | Fix racy bug in tests as reported by Simon. Bug created in bug24037 I suspectMatthew Sackman2011-05-101-1/+1
| | | |
| | * | Merging bug23559 to defaultMatthew Sackman2011-05-102-94/+129
| | |\ \
| | | * | track buffer size explicitly, resulting in a small performance improvementMatthias Radestock2011-05-101-20/+22
| | | | | | | | | | | | | | | | | | | | Also rename recv_length to recv_len for consistency and brevity.
| | | * | refactor: extract commonality between tcp and ssl recvMatthias Radestock2011-05-101-13/+9
| | | | | | | | | | | | | | | | | | | | ...and add a guard, for consistency with other funs
| | | * | optimise common case that buf contains a single binaryMatthias Radestock2011-04-261-2/+5
| | | | | | | | | | | | | | | | | | | | This turns out to improve performance *a lot*.
| | | * | make ssl workMatthias Radestock2011-04-072-75/+93
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | ...and handle socket errors It turns out that for active sockets the messages sent by tcp and ssl sockets to the controlling process differ gratuitously.
| | | * | get heartbeat monitor to pause when it shouldMatthias Radestock2011-04-071-2/+2
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | On 'default' we kick off another prim_inet:async_recv *before* handling the frame we've just received. This is done for performance reasons - essentially we are reading ahead - and leads to the following sequence of events: 1. receive memory alarm -> change state to 'blocking' 2. receive a 'publish' method frame 3. kick off another prim_inet:async_recv 4. handle frame, detecting that it is a 'publish' frame and thus changing the state to 'blocked' 5. receive the frame header for another frame (e.g. the message header, or could be something on another channel, or a heartbeat) 6. since the state is 'blocked' and we pause the heartbeat monitor and *don't* kick off another prim_inet:async_recv On this branch we don't read ahead since a) that would complicate the logic a fair bit, and b) we could end up draining a fair chunk of data from the socket, rather than just a frame header. As a result we need to make sure the heartbeat monitor gets paused as soon as we transition to the 'blocked' state.
| | | * | tweakMatthias Radestock2011-04-071-1/+1
| | | | |
| | | * | merge default into bug23559Matthias Radestock2011-04-06138-7682/+10008
| | | |\ \
| | | * | | experiment with uing {active,once} instead of prim_inet:async_recvMatthias Radestock2010-11-302-23/+39
| | | | | |
| | * | | | Merge bug20589 into defaultEmile Joubert2011-05-104-0/+183
| | |\ \ \ \
| | | * | | | IndentationEmile Joubert2011-05-101-3/+3
| | | | | | |
| | | * | | | trace_exchange -> trace_exchangesSimon MacMullen2011-05-051-9/+13
| | | | | | |
| | | * | | | Merge from defaultSimon MacMullen2011-05-0513-230/+335
| | | |\ \ \ \ | | | | | |_|/ | | | | |/| |
| | | * | | | Simplify tap_trace_in/out, don't make msg_to_table return a tuple, refactor, ↵Simon MacMullen2011-04-141-41/+33
| | | | | | | | | | | | | | | | | | | | | | | | | | | | cosmetics.
| | | * | | | Cosmetic.Simon MacMullen2011-04-121-4/+3
| | | | | | |
View Lorry Controller Status