diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2019-02-01 20:28:32 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2019-02-01 20:28:32 +0300 |
| commit | 82c23614e1b5364dde4723148af7687abfd5b2b7 (patch) | |
| tree | 46c0db7ba18621215c90e725682a39e80c4aa5fe /src/gatherer.erl | |
| parent | fccacda101cb9a4f4968152228ba47a616d8587b (diff) | |
| parent | 7e8bb7fae33ae7f3979deb08691b58fb5717fb69 (diff) | |
| download | rabbitmq-server-git-82c23614e1b5364dde4723148af7687abfd5b2b7.tar.gz | |
Merge branch 'master' into rabbit-fifo-snapshotting-fix
Diffstat (limited to 'src/gatherer.erl')
| -rw-r--r-- | src/gatherer.erl | 24 |
1 files changed, 14 insertions, 10 deletions
diff --git a/src/gatherer.erl b/src/gatherer.erl index a8b55892c1..1625468a52 100644 --- a/src/gatherer.erl +++ b/src/gatherer.erl @@ -39,16 +39,6 @@ %%---------------------------------------------------------------------------- --spec start_link() -> rabbit_types:ok_pid_or_error(). --spec stop(pid()) -> 'ok'. --spec fork(pid()) -> 'ok'. --spec finish(pid()) -> 'ok'. --spec in(pid(), any()) -> 'ok'. --spec sync_in(pid(), any()) -> 'ok'. --spec out(pid()) -> {'value', any()} | 'empty'. - -%%---------------------------------------------------------------------------- - -define(HIBERNATE_AFTER_MIN, 1000). -define(DESIRED_HIBERNATE, 10000). @@ -58,24 +48,38 @@ %%---------------------------------------------------------------------------- +-spec start_link() -> rabbit_types:ok_pid_or_error(). + start_link() -> gen_server2:start_link(?MODULE, [], [{timeout, infinity}]). +-spec stop(pid()) -> 'ok'. + stop(Pid) -> gen_server2:call(Pid, stop, infinity). +-spec fork(pid()) -> 'ok'. + fork(Pid) -> gen_server2:call(Pid, fork, infinity). +-spec finish(pid()) -> 'ok'. + finish(Pid) -> gen_server2:cast(Pid, finish). +-spec in(pid(), any()) -> 'ok'. + in(Pid, Value) -> gen_server2:cast(Pid, {in, Value}). +-spec sync_in(pid(), any()) -> 'ok'. + sync_in(Pid, Value) -> gen_server2:call(Pid, {in, Value}, infinity). +-spec out(pid()) -> {'value', any()} | 'empty'. + out(Pid) -> gen_server2:call(Pid, out, infinity). |