diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2017-07-07 18:38:35 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2017-07-07 18:38:35 +0300 |
| commit | aa1496bb198900355291617038d40592998c4a1c (patch) | |
| tree | 21b4019c3c2b7cb77c58cf0ea77fb976fdac2d05 /src | |
| parent | c71fcffcb0b7d4967a611beb605de4d0df2a370c (diff) | |
| download | rabbitmq-server-git-aa1496bb198900355291617038d40592998c4a1c.tar.gz | |
Wording, correct a type spec
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_sup_sup.erl | 6 | ||||
| -rw-r--r-- | src/rabbit_recovery_terms.erl | 4 |
2 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_amqqueue_sup_sup.erl b/src/rabbit_amqqueue_sup_sup.erl index 00e4d65cc1..b5ef86255d 100644 --- a/src/rabbit_amqqueue_sup_sup.erl +++ b/src/rabbit_amqqueue_sup_sup.erl @@ -63,7 +63,7 @@ find_for_vhost(VHost, Node) -> Result -> {error, {queue_supervisor_not_found, Result}} end. --spec start_for_vhost(rabbit_types:vhost()) -> {ok, pid()} | ok | {error, term()}. +-spec start_for_vhost(rabbit_types:vhost()) -> {ok, pid()} | {error, term()}. start_for_vhost(VHost) -> case rabbit_vhost_sup_sup:vhost_sup(VHost) of {ok, VHostSup} -> @@ -72,8 +72,8 @@ start_for_vhost(VHost) -> {rabbit_amqqueue_sup_sup, {rabbit_amqqueue_sup_sup, start_link, []}, transient, infinity, supervisor, [rabbit_amqqueue_sup_sup]}); - %% we can get here if a vhost is created and immediately - %% deleted, e.g. some integration tests do it + %% we can get here if a vhost is added and removed concurrently + %% e.g. some integration tests do it {error, {no_such_vhost, VHost}} -> rabbit_log:error("Failed to start a queue process supervisor for vhost ~s: vhost no longer exists!", [VHost]), diff --git a/src/rabbit_recovery_terms.erl b/src/rabbit_recovery_terms.erl index 9b195c2cc2..73fc9c7449 100644 --- a/src/rabbit_recovery_terms.erl +++ b/src/rabbit_recovery_terms.erl @@ -56,8 +56,8 @@ start(VHost) -> {?MODULE, start_link, [VHost]}, transient, ?WORKER_WAIT, worker, [?MODULE]}); - %% we can get here if a vhost is created and immediately - %% deleted, e.g. some integration tests do it + %% we can get here if a vhost is added and removed concurrently + %% e.g. some integration tests do it {error, {no_such_vhost, VHost}} -> rabbit_log:error("Failed to start a recovery terms manager for vhost ~s: vhost no longer exists!", [VHost]) |