fix remaining timeouts
This commit is contained in:
parent
5c5d2e3355
commit
771854002f
2 changed files with 7 additions and 7 deletions
|
@ -18,23 +18,23 @@ defmodule Floof.PacketSpool do
|
||||||
|
|
||||||
## packet is expected to be of type :XferBlob
|
## packet is expected to be of type :XferBlob
|
||||||
def store(hash, packet) do
|
def store(hash, packet) do
|
||||||
GenServer.call(__MODULE__, {:store, hash, packet, true})
|
GenServer.call(__MODULE__, {:store, hash, packet, true}, :infinity)
|
||||||
end
|
end
|
||||||
|
|
||||||
def store_multi(packets) do
|
def store_multi(packets) do
|
||||||
GenServer.call(__MODULE__, {:store, packets, true})
|
GenServer.call(__MODULE__, {:store, packets, true}, :infinity)
|
||||||
end
|
end
|
||||||
|
|
||||||
def store_new(hash, packet) do
|
def store_new(hash, packet) do
|
||||||
GenServer.call(__MODULE__, {:store, hash, packet, false})
|
GenServer.call(__MODULE__, {:store, hash, packet, false}, :infinity)
|
||||||
end
|
end
|
||||||
|
|
||||||
def store_new_multi(packets) do
|
def store_new_multi(packets) do
|
||||||
GenServer.call(__MODULE__, {:store, packets, false})
|
GenServer.call(__MODULE__, {:store, packets, false}, :infinity)
|
||||||
end
|
end
|
||||||
|
|
||||||
def fetch(hash) do
|
def fetch(hash) do
|
||||||
GenServer.call(__MODULE__, {:fetch, hash})
|
GenServer.call(__MODULE__, {:fetch, hash}, :infinity)
|
||||||
end
|
end
|
||||||
|
|
||||||
def drop(hash) do
|
def drop(hash) do
|
||||||
|
@ -145,7 +145,7 @@ defmodule Floof.PacketSpool do
|
||||||
|
|
||||||
@impl true
|
@impl true
|
||||||
def handle_info(:collect_garbage, state) do
|
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 ->
|
:error ->
|
||||||
nil
|
nil
|
||||||
|
|
||||||
|
|
|
@ -69,7 +69,7 @@ defmodule Floof.SessionManager do
|
||||||
end
|
end
|
||||||
|
|
||||||
def peek(key) do
|
def peek(key) do
|
||||||
GenServer.call(__MODULE__, {:peek, key})
|
GenServer.call(__MODULE__, {:peek, key}, :infinity)
|
||||||
end
|
end
|
||||||
|
|
||||||
def drop(key, subkeys) do
|
def drop(key, subkeys) do
|
||||||
|
|
Loading…
Reference in a new issue