diff --git a/lib/floof/packet_spool.ex b/lib/floof/packet_spool.ex index 3dc7b7d..285e6f6 100644 --- a/lib/floof/packet_spool.ex +++ b/lib/floof/packet_spool.ex @@ -18,23 +18,23 @@ defmodule Floof.PacketSpool do ## packet is expected to be of type :XferBlob def store(hash, packet) do - GenServer.call(__MODULE__, {:store, hash, packet, true}) + GenServer.call(__MODULE__, {:store, hash, packet, true}, :infinity) end def store_multi(packets) do - GenServer.call(__MODULE__, {:store, packets, true}) + GenServer.call(__MODULE__, {:store, packets, true}, :infinity) end def store_new(hash, packet) do - GenServer.call(__MODULE__, {:store, hash, packet, false}) + GenServer.call(__MODULE__, {:store, hash, packet, false}, :infinity) end def store_new_multi(packets) do - GenServer.call(__MODULE__, {:store, packets, false}) + GenServer.call(__MODULE__, {:store, packets, false}, :infinity) end def fetch(hash) do - GenServer.call(__MODULE__, {:fetch, hash}) + GenServer.call(__MODULE__, {:fetch, hash}, :infinity) end def drop(hash) do @@ -145,7 +145,7 @@ defmodule Floof.PacketSpool do @impl true def handle_info(:collect_garbage, state) do - case GenServer.call(Floof.SessionManager, :get_keep_only) do + case GenServer.call(Floof.SessionManager, :get_keep_only, :infinity) do :error -> nil diff --git a/lib/floof/session_manager.ex b/lib/floof/session_manager.ex index 9914979..faf9b32 100644 --- a/lib/floof/session_manager.ex +++ b/lib/floof/session_manager.ex @@ -69,7 +69,7 @@ defmodule Floof.SessionManager do end def peek(key) do - GenServer.call(__MODULE__, {:peek, key}) + GenServer.call(__MODULE__, {:peek, key}, :infinity) end def drop(key, subkeys) do