diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2010-07-21 17:27:33 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2010-07-21 17:27:33 +0100 |
| commit | 07151068cc291547ea4c349af80f97e40795bd87 (patch) | |
| tree | a86136dc7b4cbe36d79bf7f5be56a28bc332c767 | |
| parent | fdd1b2f0ee18f49860a99b4b3fdbabda7550c13d (diff) | |
| download | rabbitmq-server-07151068cc291547ea4c349af80f97e40795bd87.tar.gz | |
Increase priority of stats messages for channel and queue. Don't use gen_server2 for reader since it's not a real gen_server anyway.
| -rw-r--r-- | src/rabbit_amqqueue.erl | 5 | ||||
| -rw-r--r-- | src/rabbit_channel.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_reader.erl | 2 |
3 files changed, 3 insertions, 6 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 7bc85f2e..2c5465e6 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -308,7 +308,7 @@ consumers_all(VHostPath) -> stat(#amqqueue{pid = QPid}) -> delegate_call(QPid, stat, infinity). emit_stats(#amqqueue{pid = QPid}) -> - delegate_cast(QPid, emit_stats). + delegate_pcast(QPid, 8, emit_stats). delete(#amqqueue{ pid = QPid }, IfUnused, IfEmpty) -> delegate_call(QPid, {delete, IfUnused, IfEmpty}, infinity). @@ -454,9 +454,6 @@ safe_delegate_call_ok(H, F, Pids) -> delegate_call(Pid, Msg, Timeout) -> delegate:invoke(Pid, fun (P) -> gen_server2:call(P, Msg, Timeout) end). -delegate_cast(Pid, Msg) -> - delegate:invoke(Pid, fun (P) -> gen_server2:cast(P, Msg) end). - delegate_pcall(Pid, Pri, Msg, Timeout) -> delegate:invoke(Pid, fun (P) -> gen_server2:pcall(P, Pri, Msg, Timeout) end). diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 8597e477..aedd17c8 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -158,7 +158,7 @@ info_all(Items) -> rabbit_misc:filter_exit_map(fun (C) -> info(C, Items) end, list()). emit_stats(Pid) -> - gen_server2:cast(Pid, emit_stats). + gen_server2:pcast(Pid, 8, emit_stats). %%--------------------------------------------------------------------------- diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 1143794e..d96d5066 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -188,7 +188,7 @@ info(Pid, Items) -> end. emit_stats(Pid) -> - gen_server2:cast(Pid, emit_stats). + gen_server:cast(Pid, emit_stats). setup_profiling() -> Value = rabbit_misc:get_config(profiling_enabled, false), |