diff options
| author | Rob Harrop <rob@rabbitmq.com> | 2010-11-10 12:11:07 +0000 |
|---|---|---|
| committer | Rob Harrop <rob@rabbitmq.com> | 2010-11-10 12:11:07 +0000 |
| commit | 4f8a5842e1bc068fe6e1eb04378dd11e14dcd819 (patch) | |
| tree | 88021438a4772dabd18f1cd9a53e4a20a168e61d | |
| parent | cb4825213644553644b61df28f8aa6e37496b053 (diff) | |
| download | rabbitmq-server-git-4f8a5842e1bc068fe6e1eb04378dd11e14dcd819.tar.gz | |
Fixed up the specs for the heartbeater
| -rw-r--r-- | src/rabbit_heartbeat.erl | 14 |
1 files changed, 11 insertions, 3 deletions
diff --git a/src/rabbit_heartbeat.erl b/src/rabbit_heartbeat.erl index 08462d74ce..ebdfbdc67e 100644 --- a/src/rabbit_heartbeat.erl +++ b/src/rabbit_heartbeat.erl @@ -43,15 +43,23 @@ -export_type([heartbeaters/0]). -type(heartbeaters() :: rabbit_types:maybe({pid(), pid()})). --type(callback_fun() :: fun (() -> any())). + +-type(send_fun() :: fun ((rabbit_net:socket()) -> any())). +-type(timeout_fun() :: fun (() -> any())). -spec(start_heartbeat_sender/3 :: - (rabbit_net:socket(), non_neg_integer(), callback_fun()) -> + (rabbit_net:socket(), non_neg_integer(), send_fun()) -> rabbit_types:ok(pid())). -spec(start_heartbeat_receiver/3 :: - (rabbit_net:socket(), non_neg_integer(), callback_fun()) -> + (rabbit_net:socket(), non_neg_integer(), timeout_fun()) -> rabbit_types:ok(pid())). +-spec(start_heartbeat_fun/3 :: + (pid(), send_fun(), timeout_fun()) -> + fun((rabbit_net:socket(), non_neg_integer()) + -> heartbeaters())). + + -spec(pause_monitor/1 :: (heartbeaters()) -> 'ok'). -spec(resume_monitor/1 :: (heartbeaters()) -> 'ok'). |