diff options
| author | Tim Watson <tim@rabbitmq.com> | 2014-01-23 15:24:00 +0000 |
|---|---|---|
| committer | Tim Watson <tim@rabbitmq.com> | 2014-01-23 15:24:00 +0000 |
| commit | ea9cbf46e5660d23dd0fe896022e4957990f22ec (patch) | |
| tree | a2cd6926ff08a6019fcb4e69fbd6529f4f662ceb /src | |
| parent | bc69688a7dd662441754b4f284d2067e65d2e323 (diff) | |
| download | rabbitmq-server-git-ea9cbf46e5660d23dd0fe896022e4957990f22ec.tar.gz | |
Refactor (recovery-terms restart strategy)
Use rabbit_sup:start_child/1, since a transient restart is fine.
Match on rabbit_recovery_terms:recover/0, since we want to crash if that fails.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_recovery_terms.erl | 7 |
2 files changed, 3 insertions, 6 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 3da56c9387..8db6717d76 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -343,7 +343,7 @@ bounds(State = #qistate { segments = Segments }) -> {LowSeqId, NextSeqId, State}. recover(DurableQueueNames) -> - rabbit_recovery_terms:recover(), + ok = rabbit_recovery_terms:recover(), {DurableTerms, DurableDirectories} = lists:foldl( fun(QName, {RecoveryTerms, ValidDirectories}) -> diff --git a/src/rabbit_recovery_terms.erl b/src/rabbit_recovery_terms.erl index dda5794240..6e2a4a3d53 100644 --- a/src/rabbit_recovery_terms.erl +++ b/src/rabbit_recovery_terms.erl @@ -45,11 +45,8 @@ -define(SERVER, ?MODULE). recover() -> - case supervisor:start_child(rabbit_sup, - {?SERVER, {?MODULE, start_link, []}, - permanent, 16#ffffffff, worker, - [?SERVER]}) of - {ok, _} -> ok; + case rabbit_sup:start_child(?MODULE) of + ok -> ok; {error, {already_started, _}} -> ok; {error, _}=Err -> Err end. |