summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexandru Scvortov <alexandru@rabbitmq.com>2011-08-05 12:21:47 +0100
committerAlexandru Scvortov <alexandru@rabbitmq.com>2011-08-05 12:21:47 +0100
commit4fb7a0370842cc90af48fb628103563376f89e3e (patch)
treec18baeecb82733db49081cdfb9e4472ec58d77ab
parenta1e7aab0236b6cf7d99b540f8f778468e44a4846 (diff)
downloadrabbitmq-server-git-4fb7a0370842cc90af48fb628103563376f89e3e.tar.gz
amqqueue_sup, delegate specs are up to date
Nothing to do for bpqueue.
-rw-r--r--src/delegate.erl6
-rw-r--r--src/rabbit_amqqueue_sup.erl11
2 files changed, 14 insertions, 3 deletions
diff --git a/src/delegate.erl b/src/delegate.erl
index 17046201ad..edb4eba4ae 100644
--- a/src/delegate.erl
+++ b/src/delegate.erl
@@ -28,13 +28,13 @@
-ifdef(use_specs).
-spec(start_link/1 ::
- (non_neg_integer()) -> {'ok', pid()} | {'error', any()}).
--spec(invoke_no_result/2 ::
- (pid() | [pid()], fun ((pid()) -> any())) -> 'ok').
+ (non_neg_integer()) -> {'ok', pid()} | ignore | {'error', any()}).
-spec(invoke/2 ::
( pid(), fun ((pid()) -> A)) -> A;
([pid()], fun ((pid()) -> A)) -> {[{pid(), A}],
[{pid(), term()}]}).
+-spec(invoke_no_result/2 ::
+ (pid() | [pid()], fun ((pid()) -> any())) -> 'ok').
-endif.
diff --git a/src/rabbit_amqqueue_sup.erl b/src/rabbit_amqqueue_sup.erl
index 2c28adcefd..c70d6f560d 100644
--- a/src/rabbit_amqqueue_sup.erl
+++ b/src/rabbit_amqqueue_sup.erl
@@ -26,6 +26,17 @@
-define(SERVER, ?MODULE).
+-ifdef(use_specs).
+
+-spec(start_link/0 ::
+ () -> rabbit_types:ok_or_error2(pid(), {already_started, pid()})).
+-spec(start_child/2 ::
+ (node(), [any()]) -> rabbit_types:ok(pid() | undefined) |
+ rabbit_types:ok({pid(), any()}) |
+ rabbit_types:error(any())).
+
+-endif.
+
start_link() ->
supervisor2:start_link({local, ?SERVER}, ?MODULE, []).