diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2020-03-23 23:11:46 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2020-03-23 23:11:46 +0300 |
| commit | 260c0a0b6a61d8506b712c8b7580715e5bd99c63 (patch) | |
| tree | 3622863ca27c4697fdffaea6e53d0934b7299742 | |
| parent | 1e0e0ed8fb7e764b370585bb0e9268c37ede8c3d (diff) | |
| download | rabbitmq-server-git-260c0a0b6a61d8506b712c8b7580715e5bd99c63.tar.gz | |
Compile from scratchstartup_memory_fix
| -rw-r--r-- | src/rabbit_msg_store.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 32c30e48f9..e04ba8f139 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -1798,7 +1798,7 @@ build_index_worker(Gatherer, State = #msstate { dir = Dir }, readers = 0 }), ok = gatherer:finish(Gatherer). -enqueue_build_index_workers(Gatherer, Left, [], State) -> +enqueue_build_index_workers(_Gatherer, _Left, [], _State) -> exit(normal); enqueue_build_index_workers(Gatherer, Left, [File|Files], State) -> ok = worker_pool:dispatch_sync( @@ -1834,7 +1834,7 @@ reduce_index(Gatherer, LastFile, end. rebuild_index(Gatherer, Files, State) -> - lists:foreach(fun (File) -> + lists:foreach(fun (_File) -> ok = gatherer:fork(Gatherer) end, Files), Pid = spawn( |