diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-05-02 15:07:02 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-05-02 15:07:02 +0100 |
| commit | 9fb731afcc9758cd445acc870d27900fbfd338e8 (patch) | |
| tree | db358f46efc263cbd7805a01f48e4648113a6ca7 /src | |
| parent | 74979e5c28b2577b6f1cae2d9c49e70d1bba5bb9 (diff) | |
| download | rabbitmq-server-git-9fb731afcc9758cd445acc870d27900fbfd338e8.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 6 | ||||
| -rw-r--r-- | src/rabbit_invariable_queue.erl | 25 | ||||
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
3 files changed, 12 insertions, 23 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index ab88a3c294..02254b4e7f 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -175,8 +175,10 @@ set_sync_timer(State, _Fun) -> {State, 0}. ensure_rate_timer(State = #q{rate_timer_ref = undefined}) -> - {ok, TRef} = timer:apply_after(?RAM_DURATION_UPDATE_INTERVAL, rabbit_amqqueue, - update_ram_duration, [self()]), + {ok, TRef} = timer:apply_after( + ?RAM_DURATION_UPDATE_INTERVAL, + rabbit_amqqueue, update_ram_duration, + [self()]), State#q{rate_timer_ref = TRef}; ensure_rate_timer(State = #q{rate_timer_ref = just_measured}) -> State#q{rate_timer_ref = undefined}; diff --git a/src/rabbit_invariable_queue.erl b/src/rabbit_invariable_queue.erl index 722ea321b5..b4fd91560f 100644 --- a/src/rabbit_invariable_queue.erl +++ b/src/rabbit_invariable_queue.erl @@ -178,30 +178,21 @@ requeue(AckTags, State = #iv_state { pending_ack = PA, queue = Q, PA1 = remove_acks(AckTags, PA), State #iv_state { pending_ack = PA1, queue = Q1, len = Len1 }. -len(#iv_state { len = Len }) -> - Len. +len(#iv_state { len = Len }) -> Len. -is_empty(State) -> - 0 == len(State). +is_empty(State) -> 0 == len(State). -set_ram_duration_target(_DurationTarget, State) -> - %% HA! - State. +set_ram_duration_target(_DurationTarget, State) -> State. -ram_duration(State) -> - {0, State}. +ram_duration(State) -> {0, State}. -needs_sync(_State) -> - false. +needs_sync(_State) -> false. -sync(State) -> - State. +sync(State) -> State. -handle_pre_hibernate(State) -> - State. +handle_pre_hibernate(State) -> State. -status(_State) -> - []. +status(_State) -> []. %%---------------------------------------------------------------------------- diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index b5cf98450d..96f5401ab4 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -236,10 +236,6 @@ pending_ack :: dict() }). --spec(tx_commit_post_msg_store/5 :: - (boolean(), [guid()], [ack()], {pid(), any()}, state()) -> state()). --spec(tx_commit_index/1 :: (state()) -> state()). - -include("rabbit_backing_queue_spec.hrl"). -endif. |