diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-07-29 15:43:17 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-07-29 15:43:17 +0100 |
| commit | a55b4219197ace8dabc6135c920bcd7dfecf724f (patch) | |
| tree | ce9d956278cb828442bf14a5121b87c690ac6b6e /src | |
| parent | 27c3ec5d16bd07c3f2cf96c82d5164efd78f252a (diff) | |
| parent | 5032e2f6c063d5b4438bb399ef9adecbdb97df74 (diff) | |
| download | rabbitmq-server-git-a55b4219197ace8dabc6135c920bcd7dfecf724f.tar.gz | |
Merge bug25668
Diffstat (limited to 'src')
| -rw-r--r-- | src/priority_queue.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_reader.erl | 3 |
2 files changed, 4 insertions, 1 deletions
diff --git a/src/priority_queue.erl b/src/priority_queue.erl index 0dc198195e..18e1e8d984 100644 --- a/src/priority_queue.erl +++ b/src/priority_queue.erl @@ -51,7 +51,7 @@ -type(q() :: pqueue()). -type(priority() :: integer() | 'infinity'). --type(squeue() :: {queue, [any()], [any()]}). +-type(squeue() :: {queue, [any()], [any()], non_neg_integer()}). -type(pqueue() :: squeue() | {pqueue, [{priority(), squeue()}]}). -spec(new/0 :: () -> pqueue()). diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 3cf88d06b2..0fa812c675 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -756,6 +756,9 @@ refuse_connection(Sock, Exception, {A, B, C, D}) -> ok = inet_op(fun () -> rabbit_net:send(Sock, <<"AMQP",A,B,C,D>>) end), throw(Exception). +-ifdef(use_specs). +-spec(refuse_connection/2 :: (rabbit_net:socket(), any()) -> no_return()). +-endif. refuse_connection(Sock, Exception) -> refuse_connection(Sock, Exception, {0, 0, 9, 1}). |