summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Rework code so that it's even more efficient, handles errors properly and ↵bug23602Matthew Sackman2011-01-241-14/+33
| | | | also more obviously implements RFC4616 correctly
* Merging default into bug23602Matthew Sackman2011-01-241-8/+14
|\
| * Don't use re where it can be easily avoided in the plain auth mechMatthew Sackman2010-12-141-8/+14
| |
* | 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
| * | | | | | | | | | Merge this to stop it danglingSimon MacMullen2011-01-200-0/+0
| |\ \ \ \ \ \ \ \ \ \
| | * | | | | | | | | | start confirm sequence numbering at 1 instead of 0bug23671Matthias Radestock2011-01-111-1/+1
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | in order to avoid conflict with special meaning of deliver_tag=0 in basic.ack
| * | | | | | | | | | | Merged bug23434 into defaultEmile Joubert2011-01-190-0/+0
| |\ \ \ \ \ \ \ \ \ \ \ | | | |_|_|_|_|_|_|_|/ / | | |/| | | | | | | | |
| * | | | | | | | | | | Correct all remaining copyright noticesbug23434Matthew Sackman2011-01-1913-382/+155
| | | | | | | | | | | |
| * | | | | | | | | | | Correct copyright messageMatthew Sackman2011-01-191-1/+1
| | | | | | | | | | | |
| * | | | | | | | | | | Update .erl and .hrl license boilerplatesMatthew Sackman2011-01-1993-2323/+997
| |/ / / / / / / / / /
| * | | | | | | | | | merge bug23705 into defaultMatthias Radestock2011-01-180-0/+0
| |\ \ \ \ \ \ \ \ \ \
| * | | | | | | | | | | sync_timer => sync_timeoutbug23705Matthew Sackman2011-01-182-8/+8
| | | | | | | | | | | |
| * | | | | | | | | | | Specialise the sync_timer in order to permit us to unset the sync_timer_refMatthew Sackman2011-01-182-5/+13
| |/ / / / / / / / / /
View Lorry Controller Status