diff options
| author | Ben Hood <0x6e6562@gmail.com> | 2008-12-07 02:01:59 +0000 |
|---|---|---|
| committer | Ben Hood <0x6e6562@gmail.com> | 2008-12-07 02:01:59 +0000 |
| commit | ff2368fc2e3606248709ef3309eaf51245edcad2 (patch) | |
| tree | ea9ececedfa380fee08d9f4d9a2f9fc5671112fc | |
| parent | 9c8e90bde666981f5cc716abbeb7d55d4d10bdce (diff) | |
| download | rabbitmq-server-ff2368fc2e3606248709ef3309eaf51245edcad2.tar.gz | |
Shutting dialyzer up
| -rw-r--r-- | src/rabbit_channel.erl | 7 | ||||
| -rw-r--r-- | src/rabbit_limiter.erl | 16 |
2 files changed, 17 insertions, 6 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index a8db5b3f..b17a2b06 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -424,14 +424,15 @@ handle_method(#'basic.cancel'{consumer_tag = ConsumerTag, end end; -handle_method(#'basic.qos'{global = true}, _, _State) -> +handle_method(#'basic.qos'{global = Flag = true}, _, _State) -> rabbit_misc:protocol_error(not_implemented, - "Global flag for basic.qos not implementented"); + "Global flag (~s) for basic.qos not implementented", [Flag]); handle_method(#'basic.qos'{prefetch_size = Size}, _, _State) when Size /= 0 -> rabbit_misc:protocol_error(not_implemented, - "Pre-fetch size for basic.qos not implementented"); + "Pre-fetch size (~s) for basic.qos not implementented", + [Size]); handle_method(#'basic.qos'{prefetch_count = PrefetchCount}, _, State = #ch{limiter = Limiter}) -> diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index adc2c721..8509eab8 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -2,9 +2,6 @@ %% bailed. -module(rabbit_limiter). - -% I'm starting out with a gen_server because of the synchronous query -% that the queue process makes -behaviour(gen_server). -export([init/1, terminate/2, code_change/3, handle_call/3, handle_cast/2, @@ -13,6 +10,19 @@ -export([set_prefetch_count/2, can_send/2, decrement_capacity/2]). -export([unregister_queue/2]). +%%---------------------------------------------------------------------------- + +-ifdef(use_specs). + +-spec(set_prefetch_count/2 :: (pid(), non_neg_integer()) -> 'ok'). +-spec(can_send/2 :: (pid(), pid()) -> bool()). +-spec(decrement_capacity/2 :: (pid(), non_neg_integer()) -> 'ok'). +-spec(unregister_queue/2 :: (pid(), pid()) -> 'ok'). + +-endif. + +%%---------------------------------------------------------------------------- + -record(lim, {prefetch_count = 0, ch_pid, queues = sets:new(), |