diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-08-25 10:12:04 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-08-25 10:12:04 +0100 |
| commit | d6577c86146aadfecea3b661ad68e1aaca0fadd4 (patch) | |
| tree | c07b86ada9e240e2d5ba485c3d516bd16cd96e6a /src/worker_pool_worker.erl | |
| parent | 01ff49aee63b0551b5c858a0318fd3d2538cb7ee (diff) | |
| download | rabbitmq-server-d6577c86146aadfecea3b661ad68e1aaca0fadd4.tar.gz | |
removed all references to pcall and pcast
Diffstat (limited to 'src/worker_pool_worker.erl')
| -rw-r--r-- | src/worker_pool_worker.erl | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/src/worker_pool_worker.erl b/src/worker_pool_worker.erl index 42049d50..e8796491 100644 --- a/src/worker_pool_worker.erl +++ b/src/worker_pool_worker.erl @@ -38,7 +38,7 @@ -export([set_maximum_since_use/2]). -export([init/1, handle_call/3, handle_cast/2, handle_info/2, - terminate/2, code_change/3]). + terminate/2, code_change/3, prioritise_cast/2]). %%---------------------------------------------------------------------------- @@ -71,7 +71,7 @@ submit_async(Pid, Fun) -> gen_server2:cast(Pid, {submit_async, Fun}). set_maximum_since_use(Pid, Age) -> - gen_server2:pcast(Pid, 8, {set_maximum_since_use, Age}). + gen_server2:cast(Pid, {set_maximum_since_use, Age}). run({M, F, A}) -> apply(M, F, A); @@ -88,6 +88,11 @@ init([WId]) -> {ok, WId, hibernate, {backoff, ?HIBERNATE_AFTER_MIN, ?HIBERNATE_AFTER_MIN, ?DESIRED_HIBERNATE}}. +prioritise_cast({set_maximum_since_use, _Age}, _State) -> + 8; +prioritise_cast(_Msg, _State) -> + 0. + handle_call({submit, Fun}, From, WId) -> gen_server2:reply(From, run(Fun)), ok = worker_pool:idle(WId), |