summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* inline two funs for compactness and claritybug23742Matthias Radestock2011-01-261-31/+23
|
* simplifyMatthias Radestock2011-01-261-4/+4
|
* refactor 'write' handler for clarityMatthias Radestock2011-01-261-34/+38
|
* return State from write_message rather than it calling noreplyMatthias Radestock2011-01-261-38/+41
| | | | | This makes the API more consistent (cf read_message etc). Also, shuffle order of some write actions for consistency
* If we don't actually write the msg and the msg isn't in the current file ↵Matthew Sackman2011-01-251-3/+15
| | | | then delete it if its pending write count is 0
* Merged bug23740 into defaultSimon MacMullen2011-01-253-2/+4
|\
| * merge bug23582 into default (rabbitmq-multi start_all fails ...)Alexandru Scvortov2011-01-253-2/+4
| |\
| | * Cope with the new style port-only listener type (but limited to IPv4 when ↵bug23582Simon MacMullen2011-01-251-0/+2
| | | | | | | | | | | | starting multiple nodes).
| | * Revert IPv6 changes to rabbit-multi*.Simon MacMullen2011-01-252-2/+2
| |/
* | On pre_hibernate, report the real ram duration, not infinity. The assumption ↵bug23740Matthew Sackman2011-01-251-4/+4
|/ | | | that pre_hibernation implies hibernation that will last for long enough for the ram duration to go to inifinity is not correct.
* bug23154 (ipv6) merged into defaultMarek Majkowski2011-01-246-83/+117
|\
| * Merge 23534 into default.Simon MacMullen2011-01-24117-5167/+4514
| |\
| | * fix typosMatthias Radestock2011-01-231-7/+6
| | |
| | * dependently type acktag producing functionsMatthias Radestock2011-01-232-9/+12
| | | | | | | | | | | | | | | s.t. the "blank ack" case is manifest Switched from blank_ack to the more universal 'undefined' in the process.
| | * Merge bug23201 to defaultSimon MacMullen2011-01-212-33/+55
| | |\
| | | * Rename the info item for consistency.bug23201Simon MacMullen2011-01-212-3/+3
| | | |
| | | * fold casesAlexandru Scvortov2011-01-211-10/+4
| | | |
| | | * merge from defaultAlexandru Scvortov2011-01-212-34/+62
| | | |\
| | | | * rename variables for consistencyAlexandru Scvortov2011-01-211-9/+9
| | | | |
| | | | * Correct unused variable name.Simon MacMullen2011-01-211-1/+1
| | | | |
| | | | * Fix docsSimon MacMullen2011-01-211-3/+1
| | | | |
| | | | * comprehensions are more conciseAlexandru Scvortov2011-01-191-6/+4
| | | | |
| | | | * swap tuple elements for readability; inline a functionAlexandru Scvortov2011-01-191-18/+18
| | | | |
| | | | * fix break when stats were offAlexandru Scvortov2011-01-191-5/+5
| | | | |
| | | | * merge from defaultAlexandru Scvortov2011-01-1910-247/+341
| | | | |\
| | | | * \ merge from defaultAlexandru Scvortov2011-01-185-153/+67
| | | | |\ \
| | | | * | | merge duplicate codeAlexandru Scvortov2011-01-181-33/+24
| | | | | | |
| | | | * | | stats for confirms work againAlexandru Scvortov2011-01-181-12/+17
| | | | | | |
| | | | * | | merge from defaultAlexandru Scvortov2011-01-142-36/+97
| | | | |\ \ \
| | | | | * | | cosmeticAlexandru Scvortov2011-01-141-5/+5
| | | | | | | |
| | | | | * | | keep track of de-duplicated confirmsAlexandru Scvortov2011-01-141-7/+9
| | | | | | | |
| | | | | * | | don't do confirm stats book-keeping unless stats are enabledAlexandru Scvortov2011-01-141-30/+36
| | | | | | | |
| | | | | * | | for queues, log partial confirms rather than full confirmsAlexandru Scvortov2011-01-141-4/+4
| | | | | | | |
| | | | | * | | merge from defaultAlexandru Scvortov2011-01-1462-1453/+2562
| | | | | |\ \ \
| | | | | * | | | add stats again; update docsAlexandru Scvortov2010-12-092-0/+14
| | | | | | | | |
| | | | | * | | | CosmeticSimon MacMullen2010-12-081-6/+3
| | | | | | | | |
| | | | | * | | | Merge default into bug23201.Simon MacMullen2010-12-081-24/+57
| | | | | |\ \ \ \
| | | | | | * | | | add missing caseAlexandru Scvortov2010-12-061-3/+6
| | | | | | | | | |
| | | | | | * | | | add stats for confirmsAlexandru Scvortov2010-12-061-8/+7
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | To recap, a published message is confirmed by the channel. A message is confirmed only after all the queues it was published to confirm it. With the current change, the emitted stats look like this: {channel_exchange_stats, [{{resource,<<"/">>,exchange,<<"direct">>}, [{confirm,545},{publish,545}]}]}, {channel_queue_exchange_stats, [{{<0.204.0>,{resource,<<"/">>,exchange,<<"direct">>}}, [{confirm,545},{publish,545}]}, {{<0.195.0>,{resource,<<"/">>,exchange,<<"direct">>}}, [{confirm,545},{publish,545}]}]}] The confirm field in channel_exchange_stats represents the number of messages sent to that exchange that have also been confirmed. If the exchanged routed the message to different queues, this number is only increased when all queues have confirmed the message. If the message was unroutable or was routed to 0 queues, this number is still increased. This is the number of basic.confirms sent back to publisher. The confirm field in channel_queue_exchange_stats represents the number of messages confirmed by that queue (but not necessarily confirmed by the channel). In channel_exchange_stats, if the number of confirms lags behind the number of publishes, one of the queues is not confirming messages in a timely fashion.
| | | | | | * | | | merge default into bug23201Alexandru Scvortov2010-12-011-24/+57
| | | | | | |\ \ \ \
| | | | | | | * | | | update exchange and queue_exchange stats on confirmsAlexandru Scvortov2010-10-311-30/+52
| | | | | | | | | | |
| | | | | | | * | | | merge from bug20284Alexandru Scvortov2010-10-291-0/+16
| | | | | | | |\ \ \ \
| | | | | | | | * | | | added fine grained statsAlexandru Scvortov2010-09-301-0/+6
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Channel now emits the number of publisher acks (confirms) sent to the publisher. If this number is less than the number of publishes, it means that the broker isn't coping with the amount of incoming messages.
| | | | | | | | * | | | add confirm related info keysAlexandru Scvortov2010-09-291-0/+10
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Added the following info_keys: - confirm :: The type of the channel. Is one of none, single, multiple. - unconfirmed :: The number of unconfirmed messages.
| | * | | | | | | | | | merge bug23626 into defaultMatthias Radestock2011-01-211-4/+7
| | |\ \ \ \ \ \ \ \ \ \ | | | |/ / / / / / / / /
| | | * | | | | | | | | Merging bug23723 into defaultMatthew Sackman2011-01-201-4/+7
| | | |\ \ \ \ \ \ \ \ \
| | | | * | | | | | | | | handle errors in list_consumersbug23723Matthias Radestock2011-01-201-4/+7
| | | |/ / / / / / / / /
| | * | | | | | | | | | move channel lookups into handle_ methodsbug23626Matthias Radestock2011-01-201-43/+29
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This avoids double lookup in some paths and unnecessary invocations of run_message_queue. Also inline recorde_current_channel_tx, which eliminates some lookup. And allow rollback to trigger the forgetting of a channel record.
| | * | | | | | | | | | Deal with the possibility of a ch DOWN overtaking other messages from the ↵Matthew Sackman2011-01-201-14/+26
| | |/ / / / / / / / / | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | channel
| * | | | | | | | | | Add helpful comment about windows flushing to rabbitmqctlbug23534Emile Joubert2010-11-241-0/+1
| | | | | | | | | | |
View Lorry Controller Status