summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* adds file to generate the erlang releaseAlvaro Videla2012-11-071-0/+148
|
* adds Makefile for standalone mac releaseAlvaro Videla2012-11-071-0/+61
|
* adds the erlang base dir before calling erlAlvaro Videla2012-11-074-4/+12
|
* Merged bug23935 into defaultEmile Joubert2012-11-046-39/+71
|\
| * I know, why don't we get those the right way round? *headdesk*Simon MacMullen2012-11-011-1/+1
| |
| * feeding of vertical alignment obsessionMatthias Radestock2012-11-011-3/+3
| |
| * Unify address and host. Stick ports in the state, just because we're ↵Simon MacMullen2012-11-014-49/+42
| | | | | | | | grabbing them anyway.
| * More clarity.Simon MacMullen2012-10-311-2/+4
| |
| * Store name, host and peerhost as binary in the first place.Simon MacMullen2012-10-302-7/+8
| |
| * merge default into bug23935Matthias Radestock2012-10-295-20/+56
| |\
| | * These should be binary.Simon MacMullen2012-10-291-2/+2
| | |
| | * Merge defaultSimon MacMullen2012-10-2930-378/+921
| | |\
| | * \ merge headsSimon MacMullen2012-10-222-10/+9
| | |\ \
| | | * | I feel a great sadness.Simon MacMullen2012-10-191-1/+1
| | | | |
| | | * | Move host and peer_host to creattion since they will not change now.Simon MacMullen2012-10-191-9/+8
| | | | |
| | * | | cosmeticMatthias Radestock2012-10-191-1/+1
| | |/ /
| | * | OopsSimon MacMullen2012-10-191-3/+0
| | | |
| | * | OK, I prefer this. Patch the dns lookups into connection_string, this makes ↵Simon MacMullen2012-10-193-25/+37
| | | | | | | | | | | | | | | | names come out correctly for channels, stomp, mqtt and means we can remove some special casing from mgmt. Remove the extra process. Add a mechanism to disable the whole thing in case people have broken configs.
| | * | Symmetry. Link to the spawned process. Remove i/2 grossness.Simon MacMullen2012-10-192-9/+29
| | | |
| | * | Merge defaultSimon MacMullen2012-10-192-4/+14
| | |\ \
| | | * | First pass at reverse DNS lookups for clients.Simon MacMullen2012-10-012-4/+14
| | | | |
* | | | | be more assertive in property decodingMatthias Radestock2012-11-041-1/+1
| | | | |
* | | | | cosmeticMatthias Radestock2012-11-031-41/+43
| | | | |
* | | | | cosmetic: vertical alignment / shrinkageMatthias Radestock2012-11-032-81/+42
| | | | |
* | | | | Merge bug23225Simon MacMullen2012-11-024-34/+63
|\ \ \ \ \
| * | | | | only trigger stats emission from writers in the serverMatthias Radestock2012-11-023-16/+39
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | (and not the Erlang client) The server (and *only* the server) starts channels with rabbit_channel_sup:start_link({tcp, ...}). Writers are created as part of that. We pass an extra argument to rabbit_writer:start_link in this case, indicating that the reader wants be told by the writer to emit stats. Internally, the writer handles the stats/no_stats distinction by initialising the stats timer differently. We introduce a new function to create a disabled stats timer, thus taking advantage of all the existing logic in rabbit_event that suppresses timer/stats operations when stats are disabled. This approach requires inclusion of rabbit_event in rabbit_common.
| * | | | | ensure connection stats emission for write-only connectionsMatthias Radestock2012-11-012-30/+36
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | We set up a stats timer in the writers but rather emitting any stats directly from there we just get them to 'ping' the reader, which will then emit stats based on its own timer. The timer in the writer is created when a socket operation has been confirmed. a little bit of drive-by refactoring to make implementation easier: - move state creation into one place - move reader into state TODO: suppress all this when in the Erlang client
* | | | | | Merge bug25262Simon MacMullen2012-11-011-1/+1
|\ \ \ \ \ \
| * \ \ \ \ \ Merge bug25263Simon MacMullen2012-11-010-0/+0
| |\ \ \ \ \ \ | | |/ / / / /
| * | | | | | fix heinous bugMatthias Radestock2012-11-011-1/+1
| |/ / / / /
* | | | | | sort list_* resultsMatthias Radestock2012-11-011-1/+1
|/ / / / /
* | | | | Merge bug25164Simon MacMullen2012-11-016-55/+98
|\ \ \ \ \
| * | | | | refactor: s/lookup_absent/not_found_or_absentMatthias Radestock2012-10-312-21/+17
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | and s/not_found_or_absent/not_found_or_absent_dirty and make the signatures match
| * | | | | merge default into bug25164Matthias Radestock2012-10-316-55/+102
| |\ \ \ \ \ |/ / / / / /
| * | | | | merge default into bug25164Matthias Radestock2012-10-245-52/+98
| |\ \ \ \ \
| | * | | | | better error messages for 'absent' queues in binding commandsMatthias Radestock2012-10-243-24/+45
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - change binding:call_with_source_and_destination/3 to replace {error, source_not_found | destination_not_found | source_and_destination_not_found} with {error, {resources_missing, [{not_found, #resource{}} | {absent, Q}]}}. - the change ripples through rabbit_channel:binding_action, which can now produce nice not_founds. - We now only report one of the errors when there is something wrong with both source and destination. I reckon this is acceptable; we could do better but it would involve a fair bit of extra code.
| | * | | | | better error messages for 'absent' queues in various commandsMatthias Radestock2012-10-243-25/+41
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - move channel:absent/1 to misc, since we need it in multiple modules - change amqqueue:with/3 s.t. the error fun is invoked with not_found|{'absent', Q}. - let this change ripple through to with/2, making it return either error. This in turn has just two call sites - in 'queue.declare' in the channel, which we expand to handle the 'absent' case (producing a descriptive not_found error, as per above) - in mq_misc:if_mirrored_queue, whose callers currently do not handle errors at all - see bug 25236 - let the change also ripple through to with_or_die, handling the new 'absent' case as above. This takes care of passive queue.declare. - with_or_die is called by with_exclusive_access_or_die. This takes care of basic.get, basic.consume, queue.delete and queue.purge
| | * | | | | better error messages for 'absent' queues on declarationMatthias Radestock2012-10-243-18/+27
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - change amqqueue:internal_declare to return {absent, Q} instead of 'not_found' - let this ripple through amqqueue_process:declare, stopping with {absent, Q} instead - that in in turn will end up in in amqqueue:declare/5. Instead of inovking misc:not_found(QName), which was EXITing, we make {absent, Q} part of the API. - at the call site in the channel we handle the new {absent, Q} case and produce a nice error message.
* | | | | | | HA optimisation: don't broadcast 'drop' when nothing has been droppedMatthias Radestock2012-10-311-1/+4
| | | | | | |
* | | | | | | fix R12B-3 build breakageMatthias Radestock2012-10-301-3/+3
| |_|/ / / / |/| | | | | | | | | | | | | | | | | | | | | | | looks like one cannot define two macros with the same name but different arity
* | | | | | merge bug25258 into defaultMatthias Radestock2012-10-294-11/+116
|\ \ \ \ \ \
| * \ \ \ \ \ merge headsMatthias Radestock2012-10-291-58/+45
| |\ \ \ \ \ \ | | |_|_|_|_|/ | |/| | | | |
| * | | | | | Merge headsSimon MacMullen2012-10-294-11/+116
| |\ \ \ \ \ \
| | * \ \ \ \ \ Merge bug25244Simon MacMullen2012-10-294-11/+116
| | |\ \ \ \ \ \
| | | * | | | | | An extensive list of transformations lead me here. I think this is more ↵Simon MacMullen2012-10-291-58/+46
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | readable.
| | | * | | | | | Rearrange args to put the big structure we're working with at the end; more ↵Simon MacMullen2012-10-291-10/+10
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | OTPish. Yes, rabbit_misc:table_lookup and rabbit_misc:set_table_value get this wrong, but we should not copy that.
| | | * | | | | | Refactor a bitSimon MacMullen2012-10-291-17/+12
| | | | | | | | |
| | | * | | | | | make basic tests fit into rabbit_tests a bit more cleanlyTim Watson2012-10-291-74/+76
| | | | | | | | |
| | | * | | | | | refactorTim Watson2012-10-291-15/+15
| | | | | | | | |
| | | * | | | | | migrate rabbit_basic tests to rabbit_testsTim Watson2012-10-292-111/+84
| | | | | | | | |
View Lorry Controller Status