@@ -249,9 +249,7 @@ defmodule Hemdal.Host do
249249 @ impl GenServer
250250 @ doc false
251251 def handle_call ( { :exec_background , pid , cmd , args } , _from , % __MODULE__ { max_workers: :infinity } = state ) do
252- Logger . debug (
253- "host => workers: #{ state . workers } /infinity ; queue length: #{ Queue . len ( state . queue ) } "
254- )
252+ Logger . debug ( "host => workers: #{ state . workers } /infinity ; queue length: #{ Queue . len ( state . queue ) } " )
255253
256254 send_result = & send ( pid , & 1 )
257255 ref = spawn_monitor ( fn -> run_in_background ( cmd , args , send_result , state ) end )
@@ -264,9 +262,7 @@ defmodule Hemdal.Host do
264262 % __MODULE__ { max_workers: max_workers , workers: workers , queue: queue } = state
265263 )
266264 when workers >= max_workers do
267- Logger . debug (
268- "host => workers: #{ workers } /#{ max_workers } ; queue length: #{ Queue . len ( queue ) + 1 } "
269- )
265+ Logger . debug ( "host => workers: #{ workers } /#{ max_workers } ; queue length: #{ Queue . len ( queue ) + 1 } " )
270266
271267 queue = Queue . in ( { { :exec_background , pid , cmd , args } , from } , queue )
272268 { :noreply , % __MODULE__ { state | queue: queue } }
@@ -277,17 +273,13 @@ defmodule Hemdal.Host do
277273 ref = spawn_monitor ( fn -> run_in_background ( cmd , args , send_result , state ) end )
278274 workers = state . workers + 1
279275
280- Logger . debug (
281- "host => workers: #{ workers } /#{ state . max_workers } ; queue length: #{ Queue . len ( state . queue ) } "
282- )
276+ Logger . debug ( "host => workers: #{ workers } /#{ state . max_workers } ; queue length: #{ Queue . len ( state . queue ) } " )
283277
284278 { :reply , { :ok , ref } , % __MODULE__ { state | workers: workers } }
285279 end
286280
287281 def handle_call ( { :exec , cmd , args } , from , % __MODULE__ { max_workers: :infinity } = state ) do
288- Logger . debug (
289- "host => workers: #{ state . workers } /infinity ; queue length: #{ Queue . len ( state . queue ) } "
290- )
282+ Logger . debug ( "host => workers: #{ state . workers } /infinity ; queue length: #{ Queue . len ( state . queue ) } " )
291283
292284 send_result = & GenServer . reply ( from , & 1 )
293285 spawn_monitor ( fn -> run_in_background ( cmd , args , send_result , state ) end )
@@ -300,9 +292,7 @@ defmodule Hemdal.Host do
300292 % __MODULE__ { max_workers: max_workers , workers: workers , queue: queue } = state
301293 )
302294 when workers >= max_workers do
303- Logger . debug (
304- "host => workers: #{ workers } /#{ max_workers } ; queue length: #{ Queue . len ( queue ) + 1 } "
305- )
295+ Logger . debug ( "host => workers: #{ workers } /#{ max_workers } ; queue length: #{ Queue . len ( queue ) + 1 } " )
306296
307297 queue = Queue . in ( { { :exec , cmd , args } , from } , queue )
308298 { :noreply , % __MODULE__ { state | queue: queue } }
@@ -313,9 +303,7 @@ defmodule Hemdal.Host do
313303 spawn_monitor ( fn -> run_in_background ( cmd , args , send_result , state ) end )
314304 workers = state . workers + 1
315305
316- Logger . debug (
317- "host => workers: #{ workers } /#{ state . max_workers } ; queue length: #{ Queue . len ( state . queue ) } "
318- )
306+ Logger . debug ( "host => workers: #{ workers } /#{ state . max_workers } ; queue length: #{ Queue . len ( state . queue ) } " )
319307
320308 { :noreply , % __MODULE__ { state | workers: workers } }
321309 end
@@ -408,7 +396,7 @@ defmodule Hemdal.Host do
408396 defp run_in_background ( cmd , args , send_result , % __MODULE__ { host: % _ { module: mod } = host } ) do
409397 mod . transaction ( host , fn handler ->
410398 with { :ok , errorlevel , output } <- exec_cmd ( handler , mod , cmd , args ) ,
411- { :ok , % { "status" => status } = data } <- decode ( output ) do
399+ { :ok , % { "status" => status } = data } <- decode ( output ) do
412400 Logger . debug ( "command exit(#{ errorlevel } ) output: #{ inspect ( data ) } " )
413401 run_result ( data , errorlevel , status )
414402 else
0 commit comments