summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorEssien Ita Essien <essiene@gmail.com>2009-01-11 19:03:49 +0100
committerEssien Ita Essien <essiene@gmail.com>2009-01-11 19:03:49 +0100
commit0942349b64ca29ed671c20d16281d68004daf26b (patch)
treec85ca31c5552c732f19ad38738feaf6f36b5e013 /src
parent3e64595aa92a809ac176a86a2dbe41b51f0633cf (diff)
downloadrabbitmq-server-0942349b64ca29ed671c20d16281d68004daf26b.tar.gz
Add dialyser spec definitions to rabbit_net.erl
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_net.erl26
1 files changed, 25 insertions, 1 deletions
diff --git a/src/rabbit_net.erl b/src/rabbit_net.erl
index 3887d725..871cd976 100644
--- a/src/rabbit_net.erl
+++ b/src/rabbit_net.erl
@@ -31,11 +31,35 @@
-module(rabbit_net).
-include("rabbit.hrl").
+-include_lib("kernel/include/inet.hrl").
-export([async_recv/3, close/1, controlling_process/2,
getstat/2, peername/1, port_command/2,
send/2, sockname/1]).
-
+%%---------------------------------------------------------------------------
+
+-ifdef(use_specs).
+
+-type(stat_option() ::
+ 'recv_cnt' | 'recv_max' | 'recv_avg' | 'recv_oct' | 'recv_dvi' |
+ 'send_cnt' | 'send_max' | 'send_avg' | 'send_oct' | 'send_pend').
+-type(timeout() :: 'infinity' | non_neg_integer()).
+
+-spec(async_recv/3 :: (socket(), integer(), timeout()) -> {'ok', ref()}).
+-spec(close/1 :: (socket()) -> 'ok' | {'error', any()}).
+-spec(controlling_process/2 :: (socket(), pid()) -> 'ok' | {'error', any()}).
+-spec(port_command/2 :: (socket(), iolist()) -> 'true').
+-spec(send/2 :: (socket(), iolist()) -> 'ok' | {'error', any()}).
+-spec(peername/1 :: (socket()) ->
+ {'ok', {ip_address(), non_neg_integer()}} | {'error', any()}).
+-spec(sockname/1 :: (socket()) ->
+ {'ok', {ip_address(), non_neg_integer()}} | {'error', any()}).
+-spec(getstat/2 :: (socket(), [stat_option()]) ->
+ {'ok', [{stat_option(), integer()}]} | {'error', any()}).
+
+-endif.
+
+%%---------------------------------------------------------------------------
async_recv(Sock, Length, Timeout) when is_record(Sock, ssl_socket) ->