From 7ed006219939aa44e6216a808693d66ec1a53283 Mon Sep 17 00:00:00 2001
From: Magnus Ahltorp <map@kth.se>
Date: Thu, 16 Mar 2017 16:04:35 +0100
Subject: Make number of fsync processed configurable

---
 src/fsyncport.erl | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

(limited to 'src')

diff --git a/src/fsyncport.erl b/src/fsyncport.erl
index 55d21ff..c516fa8 100644
--- a/src/fsyncport.erl
+++ b/src/fsyncport.erl
@@ -29,9 +29,10 @@ fsyncall(Paths, Timeout) ->
 init(ExtPrg) ->
     lager:debug("starting fsync service"),
     process_flag(trap_exit, true),
+    FsyncProcesses = application:get_env(plop, fsync_parallel_tasks, 32),
     Ports = lists:map(fun(_N) -> open_port({spawn_executable, ExtPrg},
                                            [{packet, 2}]) end,
-		      lists:seq(1, 32)),
+		      lists:seq(1, FsyncProcesses)),
     lager:debug("fsync service started", []),
     {ok, #state{idleports = Ports, busyports = dict:new(),
                 waiting = queue:new(), requests = dict:new()}}.
-- 
cgit v1.1