diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2020-02-19 13:36:38 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2020-02-19 13:36:38 +0300 |
| commit | 8ad0eb0e5f70b09236e2ec0da91132762070930d (patch) | |
| tree | 24161b3801182e4fbe6f48baa1134082b279bdd1 /src | |
| parent | d9318ab187ac7794ec1767bc4fed58ab316972de (diff) | |
| download | rabbitmq-server-git-8ad0eb0e5f70b09236e2ec0da91132762070930d.tar.gz | |
gatherer:stop/1 now does the unlinking
so no need to do it twice
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_msg_store.erl | 1 | ||||
| -rw-r--r-- | src/rabbit_queue_index.erl | 2 |
2 files changed, 0 insertions, 3 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index c845575f5c..fdef5c3606 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -1751,7 +1751,6 @@ build_index(Gatherer, Left, [], sum_file_size = SumFileSize }) -> case gatherer:out(Gatherer) of empty -> - unlink(Gatherer), ok = gatherer:stop(Gatherer), ok = index_clean_up_temporary_reference_count_entries(State), Offset = case ets:lookup(FileSummaryEts, Left) of diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 42995685f6..dd7e973905 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -717,7 +717,6 @@ queue_index_walker({start, DurableQueues}) when is_list(DurableQueues) -> queue_index_walker({next, Gatherer}) when is_pid(Gatherer) -> case gatherer:out(Gatherer) of empty -> - unlink(Gatherer), ok = gatherer:stop(Gatherer), finished; {value, {MsgId, Count}} -> @@ -1432,7 +1431,6 @@ foreach_queue_index(Funs) -> end) end || QueueDirName <- QueueDirNames], empty = gatherer:out(Gatherer), - unlink(Gatherer), ok = gatherer:stop(Gatherer). transform_queue(Dir, Gatherer, {JournalFun, SegmentFun}) -> |