diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-01-15 15:57:43 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-01-15 15:57:43 +0000 |
| commit | 7b69f26e71792e5d2e24211a0cd3e4d5506e9af9 (patch) | |
| tree | e402153a270f3b691eeb345361880ae325e30b88 /src | |
| parent | 74a4070769036768cc2b08440c56eeb00ac254b2 (diff) | |
| download | rabbitmq-server-git-7b69f26e71792e5d2e24211a0cd3e4d5506e9af9.tar.gz | |
add some comments
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 3 | ||||
| -rw-r--r-- | src/rabbit_limiter.erl | 5 |
2 files changed, 6 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 513d305021..8ef0f7e184 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -855,7 +855,8 @@ consumer_queues(Consumers) -> %% tell the limiter about the number of acks that have been received %% for messages delivered to subscribed consumers, but not acks for -%% messages sent in a response to a basic.get. +%% messages sent in a response to a basic.get (identified by their +%% 'none' consumer tag) notify_limiter(undefined, _Acked) -> ok; notify_limiter(LimiterPid, Acked) -> diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index 3776edd0b5..49a9c195b7 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -56,8 +56,11 @@ -record(lim, {prefetch_count = 0, ch_pid, - queues = dict:new(), + queues = dict:new(), % QPid -> {MonitorRef, Notify} volume = 0}). +%% 'Notify' is a boolean that indicates whether a queue should be +%% notified of a change in the limit or volume that may allow it to +%% deliver more messages via the limiter's channel. %%---------------------------------------------------------------------------- %% API |