diff options
Diffstat (limited to 'lib/poolparty/pool/worker.ex')
-rw-r--r-- | lib/poolparty/pool/worker.ex | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/lib/poolparty/pool/worker.ex b/lib/poolparty/pool/worker.ex index c4685f5..5ae4161 100644 --- a/lib/poolparty/pool/worker.ex +++ b/lib/poolparty/pool/worker.ex @@ -1,20 +1,25 @@ defmodule PoolParty.Pool.Worker do use GenServer + require Logger def start_link(opts \\ []) do + Logger.debug("[#{__MODULE__}]: Starting worker") GenServer.start_link(__MODULE__, {}, opts) end def init(_) do + Logger.debug("[#{__MODULE__}]: Initializing Worker") PoolParty.Scheduler.join(self) {:ok, nil} end def process(pid, function, args) do + Logger.debug("[#{__MODULE__}: Casting Process request") GenServer.cast(pid, {:compute, function, args}) end def handle_cast({:compute, function, args}, _) do + Logger.debug("[#{__MODULE__}]: Process request received") PoolParty.Scheduler.ready({:result, function.(args), self}) {:noreply, nil} end |