diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-08-24 15:59:05 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-08-24 15:59:05 +0100 |
| commit | 70deb4e625469caaf60f295290537a170ee33e4e (patch) | |
| tree | 4c0a768b30373e353cb07e168c241a6b5ac29efb | |
| parent | 4040998294bd2d7e3e5e7af892c088af77343801 (diff) | |
| download | rabbitmq-server-70deb4e625469caaf60f295290537a170ee33e4e.tar.gz | |
refactoring
| -rw-r--r-- | src/rabbit_channel.erl | 23 | ||||
| -rw-r--r-- | src/rabbit_msg_store.erl | 32 |
2 files changed, 27 insertions, 28 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 4fcdf4eb..7bff5a0c 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -178,17 +178,18 @@ init([Channel, ReaderPid, WriterPid, Username, VHost, CollectorPid]) -> {ok, State, hibernate, {backoff, ?HIBERNATE_AFTER_MIN, ?HIBERNATE_AFTER_MIN, ?DESIRED_HIBERNATE}}. -prioritise_call(info, _From, _State) -> - 9; -prioritise_call({info, _Items}, _From, _State) -> - 9; -prioritise_call(_Msg, _From, _State) -> - 0. - -prioritise_cast(emit_stats, _State) -> - 7; -prioritise_cast(_Msg, _State) -> - 0. +prioritise_call(Msg, _From, _State) -> + case Msg of + info -> 9; + {info, _Items} -> 9; + _ -> 0 + end. + +prioritise_cast(Msg, _State) -> + case Msg of + emit_stats -> 7; + _ -> 0 + end. handle_call(info, _From, State) -> reply(infos(?INFO_KEYS, State), State); diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 3b3f678b..27017ddc 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -581,23 +581,21 @@ init([Server, BaseDir, ClientRefs, StartupFunState]) -> hibernate, {backoff, ?HIBERNATE_AFTER_MIN, ?HIBERNATE_AFTER_MIN, ?DESIRED_HIBERNATE}}. -prioritise_call({new_client_state, _Ref}, _From, _State) -> - 7; -prioritise_call(successfully_recovered_state, _From, _State) -> - 7; -prioritise_call({read, _Guid}, _From, _State) -> - 2; -prioritise_call(_Msg, _From, _State) -> - 0. - -prioritise_cast(sync, _State) -> - 8; -prioritise_cast({gc_done, _Reclaimed, _Source, _Destination}, _State) -> - 8; -prioritise_cast({set_maximum_since_use, _Age}, _State) -> - 8; -prioritise_cast(_Msg, _State) -> - 0. +prioritise_call(Msg, _From, _State) -> + case Msg of + {new_client_state, _Ref} -> 7; + successfully_recovered_state -> 7; + {read, _Guid} -> 2; + _ -> 0 + end. + +prioritise_cast(Msg, _State) -> + case Msg of + sync -> 8; + {gc_done, _Reclaimed, _Source, _Destination} -> 8; + {set_maximum_since_use, _Age} -> 8; + _ -> 0 + end. handle_call({read, Guid}, From, State) -> State1 = read_message(Guid, From, State), |