diff options
| author | Alex Auvolat <alex@adnab.me> | 2018-09-11 17:48:48 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2018-09-11 17:48:48 +0200 |
| commit | f8702768d38381390bcdaf50ada28239aab87b56 (patch) | |
| tree | 4ac19ffadddd726090b80c5df3f1ae79ecce5e85 /shard/lib/manager.ex | |
| parent | 9695231c327e052c5d5bc61197cc8222599fb91a (diff) | |
| download | shard-f8702768d38381390bcdaf50ada28239aab87b56.tar.gz shard-f8702768d38381390bcdaf50ada28239aab87b56.zip | |
Fix cleanups ?
Diffstat (limited to 'shard/lib/manager.ex')
| -rw-r--r-- | shard/lib/manager.ex | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/shard/lib/manager.ex b/shard/lib/manager.ex index 8cedce2..7aa3758 100644 --- a/shard/lib/manager.ex +++ b/shard/lib/manager.ex @@ -148,9 +148,7 @@ defmodule Shard.Manager do add_peer(ip, port, state) currtime = System.os_time :second :ets.insert(state.outbox, {peer_id, msg, currtime}) - outbox_cleanup = [{{:_, :_, :'$1'}, - [{:<, :'$1', currtime - 60}], - [:'$1']}] + outbox_cleanup = [ {{:_, :_, :'$1'}, [{:<, :'$1', currtime - 60}], [true]} ] :ets.select_delete(state.outbox, outbox_cleanup) _ -> Logger.info "Dropping message #{inspect msg} for peer #{inspect peer_id}: peer not in database" |